123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478479480481482483484485486487488489490491492493494495496497498499500501502503504505506507508509510511512513514515516517518519520521522523524525526527528529530531532533534535536537538539540541542543544545546547548549550551552553554555556557558559560561562563564565566567568569570571572573574575576577578579580581582583584585586587588589590591592593594595596597598599600601602603604605606607608609610611612613614615616617618619620621622623624625626627628629630631632633634635636637638639640641642643644645646647648649650651652653654655656657658659660661662663664665666667668669670671672673674675676677678679680681682683684685686687688689690691692693694695696697698699700701702703704705706707708709710711712713714715716717718719720721722723724725726727728729730731732733734735736737738739740741742743744745746747748749750751752753754755756757758759760761762763764765766767768769770771772773774775776777778779780781782783784785786787788789790791792793794795796797798799800801802803804805806807808809810811812813814815816817818819820821822823824825826827828829830831832833834835836837838839840841842843844845846847848849850851852853854855856857858859860861862863864865866867868869870871872873874875876877878879880881882883884885886887888889890891892893894895896897898899900901902903904905906907908909910911912913914915916917918919920921922923924925926927928929930931932933934935936937938939940941942943944945946947948949950951952953954955956957958959960961962963964965966967968969970971972973974975976977978979980981982983984985986987988989990991992993994995996997998999100010011002100310041005100610071008100910101011101210131014101510161017101810191020102110221023102410251026102710281029103010311032103310341035103610371038103910401041104210431044104510461047104810491050105110521053105410551056105710581059106010611062106310641065106610671068106910701071107210731074107510761077107810791080108110821083108410851086108710881089109010911092109310941095109610971098109911001101110211031104110511061107110811091110111111121113111411151116111711181119112011211122112311241125112611271128112911301131113211331134113511361137113811391140114111421143114411451146114711481149115011511152115311541155115611571158115911601161116211631164116511661167116811691170117111721173117411751176117711781179118011811182118311841185118611871188118911901191119211931194119511961197119811991200120112021203120412051206120712081209121012111212121312141215121612171218121912201221122212231224122512261227122812291230123112321233123412351236123712381239124012411242124312441245124612471248124912501251125212531254125512561257125812591260126112621263126412651266126712681269127012711272127312741275127612771278127912801281128212831284128512861287128812891290129112921293129412951296129712981299130013011302130313041305130613071308130913101311131213131314131513161317131813191320132113221323132413251326132713281329133013311332133313341335133613371338133913401341134213431344134513461347134813491350135113521353135413551356135713581359136013611362136313641365136613671368136913701371137213731374137513761377137813791380138113821383138413851386138713881389139013911392139313941395139613971398139914001401140214031404140514061407140814091410141114121413141414151416141714181419142014211422142314241425142614271428142914301431143214331434143514361437143814391440144114421443144414451446144714481449145014511452145314541455145614571458145914601461146214631464146514661467146814691470147114721473147414751476147714781479148014811482148314841485148614871488148914901491149214931494149514961497149814991500150115021503150415051506150715081509151015111512151315141515151615171518151915201521152215231524152515261527152815291530153115321533153415351536153715381539154015411542154315441545154615471548154915501551155215531554155515561557155815591560156115621563156415651566156715681569157015711572157315741575157615771578157915801581158215831584158515861587158815891590159115921593159415951596159715981599160016011602160316041605160616071608160916101611161216131614161516161617161816191620162116221623162416251626162716281629163016311632163316341635163616371638163916401641164216431644164516461647164816491650165116521653165416551656165716581659166016611662166316641665166616671668166916701671167216731674167516761677167816791680168116821683168416851686168716881689169016911692169316941695169616971698169917001701170217031704170517061707170817091710171117121713171417151716171717181719172017211722172317241725172617271728172917301731173217331734173517361737173817391740174117421743174417451746174717481749175017511752175317541755175617571758175917601761176217631764176517661767176817691770177117721773177417751776177717781779178017811782178317841785178617871788178917901791179217931794179517961797179817991800180118021803180418051806180718081809181018111812181318141815181618171818181918201821182218231824182518261827182818291830183118321833183418351836183718381839184018411842184318441845184618471848184918501851185218531854185518561857185818591860186118621863186418651866186718681869187018711872187318741875187618771878187918801881188218831884188518861887188818891890189118921893189418951896189718981899190019011902190319041905190619071908190919101911191219131914191519161917191819191920192119221923192419251926192719281929193019311932193319341935193619371938193919401941194219431944194519461947194819491950195119521953195419551956195719581959196019611962196319641965196619671968196919701971197219731974197519761977197819791980198119821983198419851986198719881989199019911992199319941995199619971998199920002001200220032004200520062007200820092010201120122013201420152016201720182019202020212022202320242025202620272028202920302031203220332034203520362037203820392040204120422043204420452046204720482049205020512052205320542055205620572058205920602061206220632064206520662067206820692070207120722073207420752076207720782079208020812082208320842085208620872088208920902091209220932094209520962097209820992100210121022103210421052106210721082109211021112112211321142115211621172118211921202121212221232124212521262127212821292130213121322133213421352136213721382139214021412142214321442145214621472148214921502151215221532154215521562157215821592160216121622163216421652166216721682169217021712172217321742175217621772178217921802181218221832184218521862187218821892190219121922193219421952196219721982199220022012202220322042205220622072208220922102211221222132214221522162217221822192220222122222223222422252226222722282229223022312232223322342235223622372238223922402241224222432244224522462247224822492250225122522253225422552256225722582259226022612262226322642265226622672268226922702271227222732274227522762277227822792280228122822283228422852286228722882289229022912292229322942295229622972298229923002301230223032304230523062307230823092310231123122313231423152316231723182319232023212322232323242325232623272328232923302331233223332334233523362337233823392340234123422343234423452346234723482349235023512352235323542355235623572358235923602361236223632364236523662367236823692370237123722373237423752376237723782379238023812382238323842385238623872388238923902391239223932394239523962397239823992400240124022403240424052406240724082409241024112412241324142415241624172418241924202421242224232424242524262427242824292430243124322433243424352436243724382439244024412442244324442445244624472448244924502451245224532454245524562457245824592460246124622463246424652466246724682469247024712472247324742475247624772478247924802481248224832484248524862487248824892490249124922493249424952496249724982499250025012502250325042505250625072508250925102511251225132514251525162517251825192520252125222523252425252526252725282529253025312532253325342535253625372538253925402541254225432544254525462547254825492550255125522553255425552556255725582559256025612562256325642565256625672568256925702571257225732574257525762577257825792580258125822583258425852586258725882589259025912592259325942595259625972598259926002601260226032604260526062607260826092610261126122613261426152616261726182619262026212622262326242625262626272628262926302631263226332634263526362637263826392640264126422643264426452646264726482649265026512652265326542655265626572658265926602661266226632664266526662667266826692670267126722673267426752676267726782679268026812682268326842685268626872688268926902691269226932694269526962697269826992700270127022703270427052706270727082709271027112712271327142715271627172718271927202721272227232724272527262727272827292730273127322733273427352736273727382739274027412742274327442745274627472748274927502751275227532754275527562757275827592760276127622763276427652766276727682769277027712772277327742775277627772778277927802781278227832784278527862787278827892790279127922793279427952796279727982799280028012802280328042805280628072808280928102811281228132814281528162817281828192820282128222823282428252826282728282829283028312832283328342835283628372838283928402841284228432844284528462847284828492850285128522853285428552856285728582859286028612862286328642865286628672868286928702871287228732874287528762877287828792880288128822883288428852886288728882889289028912892289328942895289628972898289929002901290229032904290529062907290829092910291129122913291429152916291729182919292029212922292329242925292629272928292929302931293229332934293529362937293829392940294129422943294429452946294729482949295029512952295329542955295629572958295929602961296229632964296529662967296829692970297129722973297429752976297729782979298029812982298329842985298629872988298929902991299229932994299529962997299829993000300130023003300430053006300730083009301030113012301330143015301630173018301930203021302230233024302530263027302830293030303130323033303430353036303730383039304030413042304330443045304630473048304930503051305230533054305530563057305830593060306130623063306430653066306730683069307030713072307330743075307630773078307930803081308230833084308530863087308830893090309130923093309430953096309730983099310031013102310331043105310631073108310931103111311231133114311531163117311831193120312131223123312431253126312731283129313031313132313331343135313631373138313931403141314231433144314531463147314831493150315131523153315431553156315731583159316031613162316331643165316631673168316931703171317231733174317531763177317831793180318131823183318431853186318731883189319031913192319331943195319631973198319932003201320232033204320532063207320832093210321132123213321432153216321732183219322032213222322332243225322632273228322932303231323232333234323532363237323832393240324132423243324432453246324732483249325032513252325332543255325632573258325932603261326232633264326532663267326832693270327132723273327432753276327732783279328032813282328332843285328632873288328932903291329232933294329532963297329832993300330133023303330433053306330733083309331033113312331333143315331633173318331933203321332233233324332533263327332833293330333133323333333433353336333733383339334033413342334333443345334633473348334933503351335233533354335533563357335833593360336133623363336433653366336733683369337033713372337333743375337633773378337933803381338233833384338533863387338833893390339133923393339433953396339733983399340034013402340334043405340634073408340934103411341234133414341534163417341834193420342134223423342434253426342734283429343034313432343334343435343634373438343934403441344234433444344534463447344834493450345134523453345434553456345734583459346034613462346334643465346634673468346934703471347234733474347534763477347834793480348134823483348434853486348734883489349034913492349334943495349634973498349935003501350235033504350535063507350835093510351135123513351435153516351735183519352035213522352335243525352635273528352935303531353235333534353535363537353835393540354135423543354435453546354735483549355035513552355335543555355635573558355935603561356235633564356535663567356835693570357135723573357435753576357735783579358035813582358335843585358635873588358935903591359235933594359535963597359835993600360136023603360436053606360736083609361036113612361336143615361636173618361936203621362236233624362536263627362836293630363136323633363436353636363736383639364036413642364336443645364636473648364936503651365236533654365536563657365836593660366136623663366436653666366736683669367036713672367336743675367636773678367936803681368236833684368536863687368836893690369136923693369436953696369736983699370037013702370337043705370637073708370937103711371237133714371537163717371837193720372137223723372437253726372737283729373037313732373337343735373637373738373937403741374237433744374537463747374837493750375137523753375437553756375737583759376037613762376337643765376637673768376937703771377237733774377537763777377837793780378137823783378437853786378737883789379037913792379337943795379637973798379938003801380238033804380538063807380838093810381138123813381438153816381738183819382038213822382338243825382638273828382938303831383238333834383538363837383838393840384138423843384438453846384738483849385038513852385338543855385638573858385938603861386238633864386538663867386838693870387138723873387438753876387738783879388038813882388338843885388638873888388938903891389238933894389538963897389838993900390139023903390439053906390739083909391039113912391339143915391639173918391939203921392239233924392539263927392839293930393139323933393439353936393739383939394039413942394339443945394639473948394939503951395239533954395539563957395839593960396139623963396439653966396739683969397039713972397339743975397639773978397939803981398239833984398539863987398839893990399139923993399439953996399739983999400040014002400340044005400640074008400940104011401240134014401540164017401840194020402140224023402440254026402740284029403040314032403340344035403640374038403940404041404240434044404540464047404840494050405140524053405440554056405740584059406040614062406340644065406640674068406940704071407240734074407540764077407840794080408140824083408440854086408740884089409040914092409340944095409640974098409941004101410241034104410541064107410841094110411141124113411441154116411741184119412041214122412341244125412641274128412941304131413241334134413541364137413841394140414141424143414441454146414741484149415041514152415341544155415641574158415941604161416241634164416541664167416841694170417141724173417441754176417741784179418041814182418341844185418641874188418941904191419241934194419541964197419841994200420142024203420442054206420742084209421042114212421342144215421642174218421942204221422242234224422542264227422842294230423142324233423442354236423742384239424042414242424342444245424642474248424942504251425242534254425542564257425842594260426142624263426442654266426742684269427042714272427342744275427642774278427942804281428242834284428542864287428842894290429142924293429442954296429742984299430043014302430343044305430643074308430943104311431243134314431543164317431843194320432143224323432443254326432743284329433043314332433343344335433643374338433943404341434243434344434543464347434843494350435143524353435443554356435743584359436043614362436343644365436643674368436943704371437243734374437543764377437843794380438143824383438443854386438743884389439043914392439343944395439643974398439944004401440244034404440544064407440844094410441144124413441444154416441744184419442044214422442344244425442644274428442944304431443244334434443544364437443844394440444144424443444444454446444744484449445044514452445344544455445644574458445944604461446244634464446544664467446844694470447144724473447444754476447744784479448044814482448344844485448644874488448944904491449244934494449544964497449844994500450145024503450445054506450745084509451045114512451345144515451645174518451945204521452245234524452545264527452845294530453145324533453445354536453745384539454045414542454345444545454645474548454945504551455245534554455545564557455845594560456145624563456445654566456745684569 |
- /*! Socket.IO.js build:0.9.17, development. Copyright(c) 2011 LearnBoost <dev@learnboost.com> MIT Licensed */
- var io = ('undefined' === typeof module ? {} : module.exports);
- (function () {
- /**
- * socket.io
- * Copyright(c) 2011 LearnBoost <dev@learnboost.com>
- * MIT Licensed
- */
- (function (exports, global) {
- /**
- * IO namespace.
- *
- * @namespace
- */
- var io = exports;
- /**
- * Socket.IO version
- *
- * @api public
- */
- io.version = '0.9.17';
- /**
- * Protocol implemented.
- *
- * @api public
- */
- io.protocol = 1;
- /**
- * Available transports, these will be populated with the available transports
- *
- * @api public
- */
- io.transports = [];
- /**
- * Keep track of jsonp callbacks.
- *
- * @api private
- */
- io.j = [];
- /**
- * Keep track of our io.Sockets
- *
- * @api private
- */
- io.sockets = {};
- /**
- * Manages connections to hosts.
- *
- * @param {String} uri
- * @Param {Boolean} force creation of new socket (defaults to false)
- * @api public
- */
- io.connect = function (host, details) {
- var uri = io.util.parseUri(host)
- , uuri
- , socket;
- if (global && global.location) {
- uri.protocol = uri.protocol || global.location.protocol.slice(0, -1);
- uri.host = uri.host || (global.document
- ? global.document.domain : global.location.hostname);
- uri.port = uri.port || global.location.port;
- }
- uuri = io.util.uniqueUri(uri);
- var options = {
- host: uri.host
- , secure: 'https' == uri.protocol
- , port: uri.port || ('https' == uri.protocol ? 443 : 80)
- , query: uri.query || ''
- };
- io.util.merge(options, details);
- if (options['force new connection'] || !io.sockets[uuri]) {
- socket = new io.Socket(options);
- }
- if (!options['force new connection'] && socket) {
- io.sockets[uuri] = socket;
- }
- socket = socket || io.sockets[uuri];
- // if path is different from '' or /
- return socket.of(uri.path.length > 1 ? uri.path : '');
- };
- })('object' === typeof module ? module.exports : (this.io = {}), this);
- /**
- * socket.io
- * Copyright(c) 2011 LearnBoost <dev@learnboost.com>
- * MIT Licensed
- */
- (function (exports, global) {
- /**
- * Utilities namespace.
- *
- * @namespace
- */
- var util = exports.util = {};
- /**
- * Parses an URI
- *
- * @author Steven Levithan <stevenlevithan.com> (MIT license)
- * @api public
- */
- var re = /^(?:(?![^:@]+:[^:@\/]*@)([^:\/?#.]+):)?(?:\/\/)?((?:(([^:@]*)(?::([^:@]*))?)?@)?([^:\/?#]*)(?::(\d*))?)(((\/(?:[^?#](?![^?#\/]*\.[^?#\/.]+(?:[?#]|$)))*\/?)?([^?#\/]*))(?:\?([^#]*))?(?:#(.*))?)/;
- var parts = ['source', 'protocol', 'authority', 'userInfo', 'user', 'password',
- 'host', 'port', 'relative', 'path', 'directory', 'file', 'query',
- 'anchor'];
- util.parseUri = function (str) {
- var m = re.exec(str || '')
- , uri = {}
- , i = 14;
- while (i--) {
- uri[parts[i]] = m[i] || '';
- }
- return uri;
- };
- /**
- * Produces a unique url that identifies a Socket.IO connection.
- *
- * @param {Object} uri
- * @api public
- */
- util.uniqueUri = function (uri) {
- var protocol = uri.protocol
- , host = uri.host
- , port = uri.port;
- if ('document' in global) {
- host = host || document.domain;
- port = port || (protocol == 'https'
- && document.location.protocol !== 'https:' ? 443 : document.location.port);
- } else {
- host = host || 'localhost';
- if (!port && protocol == 'https') {
- port = 443;
- }
- }
- return (protocol || 'http') + '://' + host + ':' + (port || 80);
- };
- /**
- * Mergest 2 query strings in to once unique query string
- *
- * @param {String} base
- * @param {String} addition
- * @api public
- */
- util.query = function (base, addition) {
- var query = util.chunkQuery(base || '')
- , components = [];
- util.merge(query, util.chunkQuery(addition || ''));
- for (var part in query) {
- if (query.hasOwnProperty(part)) {
- components.push(part + '=' + query[part]);
- }
- }
- return components.length ? '?' + components.join('&') : '';
- };
- /**
- * Transforms a querystring in to an object
- *
- * @param {String} qs
- * @api public
- */
- util.chunkQuery = function (qs) {
- var query = {}
- , params = qs.split('&')
- , i = 0
- , l = params.length
- , kv;
- for (; i < l; ++i) {
- kv = params[i].split('=');
- if (kv[0]) {
- query[kv[0]] = kv[1];
- }
- }
- return query;
- };
- /**
- * Executes the given function when the page is loaded.
- *
- * io.util.load(function () { console.log('page loaded'); });
- *
- * @param {Function} fn
- * @api public
- */
- var pageLoaded = false;
- util.load = function (fn) {
- if ('document' in global && document.readyState === 'complete' || pageLoaded) {
- return fn();
- }
- util.on(global, 'load', fn, false);
- };
- /**
- * Adds an event.
- *
- * @api private
- */
- util.on = function (element, event, fn, capture) {
- if (element.attachEvent) {
- element.attachEvent('on' + event, fn);
- } else if (element.addEventListener) {
- element.addEventListener(event, fn, capture);
- }
- };
- /**
- * Generates the correct `XMLHttpRequest` for regular and cross domain requests.
- *
- * @param {Boolean} [xdomain] Create a request that can be used cross domain.
- * @returns {XMLHttpRequest|false} If we can create a XMLHttpRequest.
- * @api private
- */
- util.request = function (xdomain) {
- if (xdomain && 'undefined' != typeof XDomainRequest && !util.ua.hasCORS) {
- return new XDomainRequest();
- }
- if ('undefined' != typeof XMLHttpRequest && (!xdomain || util.ua.hasCORS)) {
- return new XMLHttpRequest();
- }
- if (!xdomain) {
- try {
- return new window[(['Active'].concat('Object').join('X'))]('Microsoft.XMLHTTP');
- } catch (e) {
- }
- }
- return null;
- };
- /**
- * XHR based transport constructor.
- *
- * @constructor
- * @api public
- */
- /**
- * Change the internal pageLoaded value.
- */
- if ('undefined' != typeof window) {
- util.load(function () {
- pageLoaded = true;
- });
- }
- /**
- * Defers a function to ensure a spinner is not displayed by the browser
- *
- * @param {Function} fn
- * @api public
- */
- util.defer = function (fn) {
- if (!util.ua.webkit || 'undefined' != typeof importScripts) {
- return fn();
- }
- util.load(function () {
- setTimeout(fn, 100);
- });
- };
- /**
- * Merges two objects.
- *
- * @api public
- */
- util.merge = function merge(target, additional, deep, lastseen) {
- var seen = lastseen || []
- , depth = typeof deep == 'undefined' ? 2 : deep
- , prop;
- for (prop in additional) {
- if (additional.hasOwnProperty(prop) && util.indexOf(seen, prop) < 0) {
- if (typeof target[prop] !== 'object' || !depth) {
- target[prop] = additional[prop];
- seen.push(additional[prop]);
- } else {
- util.merge(target[prop], additional[prop], depth - 1, seen);
- }
- }
- }
- return target;
- };
- /**
- * Merges prototypes from objects
- *
- * @api public
- */
- util.mixin = function (ctor, ctor2) {
- util.merge(ctor.prototype, ctor2.prototype);
- };
- /**
- * Shortcut for prototypical and static inheritance.
- *
- * @api private
- */
- util.inherit = function (ctor, ctor2) {
- function f() {
- };
- f.prototype = ctor2.prototype;
- ctor.prototype = new f;
- };
- /**
- * Checks if the given object is an Array.
- *
- * io.util.isArray([]); // true
- * io.util.isArray({}); // false
- *
- * @param Object obj
- * @api public
- */
- util.isArray = Array.isArray || function (obj) {
- return Object.prototype.toString.call(obj) === '[object Array]';
- };
- /**
- * Intersects values of two arrays into a third
- *
- * @api public
- */
- util.intersect = function (arr, arr2) {
- var ret = []
- , longest = arr.length > arr2.length ? arr : arr2
- , shortest = arr.length > arr2.length ? arr2 : arr;
- for (var i = 0, l = shortest.length; i < l; i++) {
- if (~util.indexOf(longest, shortest[i]))
- ret.push(shortest[i]);
- }
- return ret;
- };
- /**
- * Array indexOf compatibility.
- *
- * @see bit.ly/a5Dxa2
- * @api public
- */
- util.indexOf = function (arr, o, i) {
- for (var j = arr.length, i = i < 0 ? i + j < 0 ? 0 : i + j : i || 0;
- i < j && arr[i] !== o; i++) {
- }
- return j <= i ? -1 : i;
- };
- /**
- * Converts enumerables to array.
- *
- * @api public
- */
- util.toArray = function (enu) {
- var arr = [];
- for (var i = 0, l = enu.length; i < l; i++)
- arr.push(enu[i]);
- return arr;
- };
- /**
- * UA / engines detection namespace.
- *
- * @namespace
- */
- util.ua = {};
- /**
- * Whether the UA supports CORS for XHR.
- *
- * @api public
- */
- util.ua.hasCORS = 'undefined' != typeof XMLHttpRequest && (function () {
- try {
- var a = new XMLHttpRequest();
- } catch (e) {
- return false;
- }
- return a.withCredentials != undefined;
- })();
- /**
- * Detect webkit.
- *
- * @api public
- */
- util.ua.webkit = 'undefined' != typeof navigator
- && /webkit/i.test(navigator.userAgent);
- /**
- * Detect iPad/iPhone/iPod.
- *
- * @api public
- */
- util.ua.iDevice = 'undefined' != typeof navigator
- && /iPad|iPhone|iPod/i.test(navigator.userAgent);
- })('undefined' != typeof io ? io : module.exports, this);
- /**
- * socket.io
- * Copyright(c) 2011 LearnBoost <dev@learnboost.com>
- * MIT Licensed
- */
- (function (exports, io) {
- /**
- * Expose constructor.
- */
- exports.EventEmitter = EventEmitter;
- /**
- * Event emitter constructor.
- *
- * @api public.
- */
- function EventEmitter() {
- };
- /**
- * Adds a listener
- *
- * @api public
- */
- EventEmitter.prototype.on = function (name, fn) {
- if (!this.$events) {
- this.$events = {};
- }
- if (!this.$events[name]) {
- this.$events[name] = fn;
- } else if (io.util.isArray(this.$events[name])) {
- this.$events[name].push(fn);
- } else {
- this.$events[name] = [this.$events[name], fn];
- }
- return this;
- };
- EventEmitter.prototype.addListener = EventEmitter.prototype.on;
- /**
- * Adds a volatile listener.
- *
- * @api public
- */
- EventEmitter.prototype.once = function (name, fn) {
- var self = this;
- function on() {
- self.removeListener(name, on);
- fn.apply(this, arguments);
- };
- on.listener = fn;
- this.on(name, on);
- return this;
- };
- /**
- * Removes a listener.
- *
- * @api public
- */
- EventEmitter.prototype.removeListener = function (name, fn) {
- if (this.$events && this.$events[name]) {
- var list = this.$events[name];
- if (io.util.isArray(list)) {
- var pos = -1;
- for (var i = 0, l = list.length; i < l; i++) {
- if (list[i] === fn || (list[i].listener && list[i].listener === fn)) {
- pos = i;
- break;
- }
- }
- if (pos < 0) {
- return this;
- }
- list.splice(pos, 1);
- if (!list.length) {
- delete this.$events[name];
- }
- } else if (list === fn || (list.listener && list.listener === fn)) {
- delete this.$events[name];
- }
- }
- return this;
- };
- /**
- * Removes all listeners for an event.
- *
- * @api public
- */
- EventEmitter.prototype.removeAllListeners = function (name) {
- if (name === undefined) {
- this.$events = {};
- return this;
- }
- if (this.$events && this.$events[name]) {
- this.$events[name] = null;
- }
- return this;
- };
- /**
- * Gets all listeners for a certain event.
- *
- * @api publci
- */
- EventEmitter.prototype.listeners = function (name) {
- if (!this.$events) {
- this.$events = {};
- }
- if (!this.$events[name]) {
- this.$events[name] = [];
- }
- if (!io.util.isArray(this.$events[name])) {
- this.$events[name] = [this.$events[name]];
- }
- return this.$events[name];
- };
- /**
- * Emits an event.
- *
- * @api public
- */
- EventEmitter.prototype.emit = function (name) {
- if (!this.$events) {
- return false;
- }
- var handler = this.$events[name];
- if (!handler) {
- return false;
- }
- var args = Array.prototype.slice.call(arguments, 1);
- if ('function' == typeof handler) {
- handler.apply(this, args);
- } else if (io.util.isArray(handler)) {
- var listeners = handler.slice();
- for (var i = 0, l = listeners.length; i < l; i++) {
- listeners[i].apply(this, args);
- }
- } else {
- return false;
- }
- return true;
- };
- })(
- 'undefined' != typeof io ? io : module.exports
- , 'undefined' != typeof io ? io : module.parent.exports
- );
- /**
- * socket.io
- * Copyright(c) 2011 LearnBoost <dev@learnboost.com>
- * MIT Licensed
- */
- /**
- * Based on JSON2 (http://www.JSON.org/js.html).
- */
- (function (exports, nativeJSON) {
- "use strict";
- // use native JSON if it's available
- if (nativeJSON && nativeJSON.parse) {
- return exports.JSON = {
- parse: nativeJSON.parse
- , stringify: nativeJSON.stringify
- };
- }
- var JSON = exports.JSON = {};
- function f(n) {
- // Format integers to have at least two digits.
- return n < 10 ? '0' + n : n;
- }
- function date(d, key) {
- return isFinite(d.valueOf()) ?
- d.getUTCFullYear() + '-' +
- f(d.getUTCMonth() + 1) + '-' +
- f(d.getUTCDate()) + 'T' +
- f(d.getUTCHours()) + ':' +
- f(d.getUTCMinutes()) + ':' +
- f(d.getUTCSeconds()) + 'Z' : null;
- };
- var cx = /[\u0000\u00ad\u0600-\u0604\u070f\u17b4\u17b5\u200c-\u200f\u2028-\u202f\u2060-\u206f\ufeff\ufff0-\uffff]/g,
- escapable = /[\\\"\x00-\x1f\x7f-\x9f\u00ad\u0600-\u0604\u070f\u17b4\u17b5\u200c-\u200f\u2028-\u202f\u2060-\u206f\ufeff\ufff0-\uffff]/g,
- gap,
- indent,
- meta = { // table of character substitutions
- '\b': '\\b',
- '\t': '\\t',
- '\n': '\\n',
- '\f': '\\f',
- '\r': '\\r',
- '"': '\\"',
- '\\': '\\\\'
- },
- rep;
- function quote(string) {
- // If the string contains no control characters, no quote characters, and no
- // backslash characters, then we can safely slap some quotes around it.
- // Otherwise we must also replace the offending characters with safe escape
- // sequences.
- escapable.lastIndex = 0;
- return escapable.test(string) ? '"' + string.replace(escapable, function (a) {
- var c = meta[a];
- return typeof c === 'string' ? c :
- '\\u' + ('0000' + a.charCodeAt(0).toString(16)).slice(-4);
- }) + '"' : '"' + string + '"';
- }
- function str(key, holder) {
- // Produce a string from holder[key].
- var i, // The loop counter.
- k, // The member key.
- v, // The member value.
- length,
- mind = gap,
- partial,
- value = holder[key];
- // If the value has a toJSON method, call it to obtain a replacement value.
- if (value instanceof Date) {
- value = date(key);
- }
- // If we were called with a replacer function, then call the replacer to
- // obtain a replacement value.
- if (typeof rep === 'function') {
- value = rep.call(holder, key, value);
- }
- // What happens next depends on the value's type.
- switch (typeof value) {
- case 'string':
- return quote(value);
- case 'number':
- // JSON numbers must be finite. Encode non-finite numbers as null.
- return isFinite(value) ? String(value) : 'null';
- case 'boolean':
- case 'null':
- // If the value is a boolean or null, convert it to a string. Note:
- // typeof null does not produce 'null'. The case is included here in
- // the remote chance that this gets fixed someday.
- return String(value);
- // If the type is 'object', we might be dealing with an object or an array or
- // null.
- case 'object':
- // Due to a specification blunder in ECMAScript, typeof null is 'object',
- // so watch out for that case.
- if (!value) {
- return 'null';
- }
- // Make an array to hold the partial results of stringifying this object value.
- gap += indent;
- partial = [];
- // Is the value an array?
- if (Object.prototype.toString.apply(value) === '[object Array]') {
- // The value is an array. Stringify every element. Use null as a placeholder
- // for non-JSON values.
- length = value.length;
- for (i = 0; i < length; i += 1) {
- partial[i] = str(i, value) || 'null';
- }
- // Join all of the elements together, separated with commas, and wrap them in
- // brackets.
- v = partial.length === 0 ? '[]' : gap ?
- '[\n' + gap + partial.join(',\n' + gap) + '\n' + mind + ']' :
- '[' + partial.join(',') + ']';
- gap = mind;
- return v;
- }
- // If the replacer is an array, use it to select the members to be stringified.
- if (rep && typeof rep === 'object') {
- length = rep.length;
- for (i = 0; i < length; i += 1) {
- if (typeof rep[i] === 'string') {
- k = rep[i];
- v = str(k, value);
- if (v) {
- partial.push(quote(k) + (gap ? ': ' : ':') + v);
- }
- }
- }
- } else {
- // Otherwise, iterate through all of the keys in the object.
- for (k in value) {
- if (Object.prototype.hasOwnProperty.call(value, k)) {
- v = str(k, value);
- if (v) {
- partial.push(quote(k) + (gap ? ': ' : ':') + v);
- }
- }
- }
- }
- // Join all of the member texts together, separated with commas,
- // and wrap them in braces.
- v = partial.length === 0 ? '{}' : gap ?
- '{\n' + gap + partial.join(',\n' + gap) + '\n' + mind + '}' :
- '{' + partial.join(',') + '}';
- gap = mind;
- return v;
- }
- }
- // If the JSON object does not yet have a stringify method, give it one.
- JSON.stringify = function (value, replacer, space) {
- // The stringify method takes a value and an optional replacer, and an optional
- // space parameter, and returns a JSON text. The replacer can be a function
- // that can replace values, or an array of strings that will select the keys.
- // A default replacer method can be provided. Use of the space parameter can
- // produce text that is more easily readable.
- var i;
- gap = '';
- indent = '';
- // If the space parameter is a number, make an indent string containing that
- // many spaces.
- if (typeof space === 'number') {
- for (i = 0; i < space; i += 1) {
- indent += ' ';
- }
- // If the space parameter is a string, it will be used as the indent string.
- } else if (typeof space === 'string') {
- indent = space;
- }
- // If there is a replacer, it must be a function or an array.
- // Otherwise, throw an error.
- rep = replacer;
- if (replacer && typeof replacer !== 'function' &&
- (typeof replacer !== 'object' ||
- typeof replacer.length !== 'number')) {
- throw new Error('JSON.stringify');
- }
- // Make a fake root object containing our value under the key of ''.
- // Return the result of stringifying the value.
- return str('', {'': value});
- };
- // If the JSON object does not yet have a parse method, give it one.
- JSON.parse = function (text, reviver) {
- // The parse method takes a text and an optional reviver function, and returns
- // a JavaScript value if the text is a valid JSON text.
- var j;
- function walk(holder, key) {
- // The walk method is used to recursively walk the resulting structure so
- // that modifications can be made.
- var k, v, value = holder[key];
- if (value && typeof value === 'object') {
- for (k in value) {
- if (Object.prototype.hasOwnProperty.call(value, k)) {
- v = walk(value, k);
- if (v !== undefined) {
- value[k] = v;
- } else {
- delete value[k];
- }
- }
- }
- }
- return reviver.call(holder, key, value);
- }
- // Parsing happens in four stages. In the first stage, we replace certain
- // Unicode characters with escape sequences. JavaScript handles many characters
- // incorrectly, either silently deleting them, or treating them as line endings.
- text = String(text);
- cx.lastIndex = 0;
- if (cx.test(text)) {
- text = text.replace(cx, function (a) {
- return '\\u' +
- ('0000' + a.charCodeAt(0).toString(16)).slice(-4);
- });
- }
- // In the second stage, we run the text against regular expressions that look
- // for non-JSON patterns. We are especially concerned with '()' and 'new'
- // because they can cause invocation, and '=' because it can cause mutation.
- // But just to be safe, we want to reject all unexpected forms.
- // We split the second stage into 4 regexp operations in order to work around
- // crippling inefficiencies in IE's and Safari's regexp engines. First we
- // replace the JSON backslash pairs with '@' (a non-JSON character). Second, we
- // replace all simple value tokens with ']' characters. Third, we delete all
- // open brackets that follow a colon or comma or that begin the text. Finally,
- // we look to see that the remaining characters are only whitespace or ']' or
- // ',' or ':' or '{' or '}'. If that is so, then the text is safe for eval.
- if (/^[\],:{}\s]*$/
- .test(text.replace(/\\(?:["\\\/bfnrt]|u[0-9a-fA-F]{4})/g, '@')
- .replace(/"[^"\\\n\r]*"|true|false|null|-?\d+(?:\.\d*)?(?:[eE][+\-]?\d+)?/g, ']')
- .replace(/(?:^|:|,)(?:\s*\[)+/g, ''))) {
- // In the third stage we use the eval function to compile the text into a
- // JavaScript structure. The '{' operator is subject to a syntactic ambiguity
- // in JavaScript: it can begin a block or an object literal. We wrap the text
- // in parens to eliminate the ambiguity.
- j = eval('(' + text + ')');
- // In the optional fourth stage, we recursively walk the new structure, passing
- // each name/value pair to a reviver function for possible transformation.
- return typeof reviver === 'function' ?
- walk({'': j}, '') : j;
- }
- // If the text is not JSON parseable, then a SyntaxError is thrown.
- throw new SyntaxError('JSON.parse');
- };
- })(
- 'undefined' != typeof io ? io : module.exports
- , typeof JSON !== 'undefined' ? JSON : undefined
- );
- /**
- * socket.io
- * Copyright(c) 2011 LearnBoost <dev@learnboost.com>
- * MIT Licensed
- */
- (function (exports, io) {
- /**
- * Parser namespace.
- *
- * @namespace
- */
- var parser = exports.parser = {};
- /**
- * Packet types.
- */
- var packets = parser.packets = [
- 'disconnect'
- , 'connect'
- , 'heartbeat'
- , 'message'
- , 'json'
- , 'event'
- , 'ack'
- , 'error'
- , 'noop'
- ];
- /**
- * Errors reasons.
- */
- var reasons = parser.reasons = [
- 'transport not supported'
- , 'client not handshaken'
- , 'unauthorized'
- ];
- /**
- * Errors advice.
- */
- var advice = parser.advice = [
- 'reconnect'
- ];
- /**
- * Shortcuts.
- */
- var JSON = io.JSON
- , indexOf = io.util.indexOf;
- /**
- * Encodes a packet.
- *
- * @api private
- */
- parser.encodePacket = function (packet) {
- var type = indexOf(packets, packet.type)
- , id = packet.id || ''
- , endpoint = packet.endpoint || ''
- , ack = packet.ack
- , data = null;
- switch (packet.type) {
- case 'error':
- var reason = packet.reason ? indexOf(reasons, packet.reason) : ''
- , adv = packet.advice ? indexOf(advice, packet.advice) : '';
- if (reason !== '' || adv !== '')
- data = reason + (adv !== '' ? ('+' + adv) : '');
- break;
- case 'message':
- if (packet.data !== '')
- data = packet.data;
- break;
- case 'event':
- var ev = {name: packet.name};
- if (packet.args && packet.args.length) {
- ev.args = packet.args;
- }
- data = JSON.stringify(ev);
- break;
- case 'json':
- data = JSON.stringify(packet.data);
- break;
- case 'connect':
- if (packet.qs)
- data = packet.qs;
- break;
- case 'ack':
- data = packet.ackId
- + (packet.args && packet.args.length
- ? '+' + JSON.stringify(packet.args) : '');
- break;
- }
- // construct packet with required fragments
- var encoded = [
- type
- , id + (ack == 'data' ? '+' : '')
- , endpoint
- ];
- // data fragment is optional
- if (data !== null && data !== undefined)
- encoded.push(data);
- return encoded.join(':');
- };
- /**
- * Encodes multiple messages (payload).
- *
- * @param {Array} messages
- * @api private
- */
- parser.encodePayload = function (packets) {
- var decoded = '';
- if (packets.length == 1)
- return packets[0];
- for (var i = 0, l = packets.length; i < l; i++) {
- var packet = packets[i];
- decoded += '\ufffd' + packet.length + '\ufffd' + packets[i];
- }
- return decoded;
- };
- /**
- * Decodes a packet
- *
- * @api private
- */
- var regexp = /([^:]+):([0-9]+)?(\+)?:([^:]+)?:?([\s\S]*)?/;
- parser.decodePacket = function (data) {
- var pieces = data.match(regexp);
- if (!pieces) return {};
- var id = pieces[2] || ''
- , data = pieces[5] || ''
- , packet = {
- type: packets[pieces[1]]
- , endpoint: pieces[4] || ''
- };
- // whether we need to acknowledge the packet
- if (id) {
- packet.id = id;
- if (pieces[3])
- packet.ack = 'data';
- else
- packet.ack = true;
- }
- // handle different packet types
- switch (packet.type) {
- case 'error':
- var pieces = data.split('+');
- packet.reason = reasons[pieces[0]] || '';
- packet.advice = advice[pieces[1]] || '';
- break;
- case 'message':
- packet.data = data || '';
- break;
- case 'event':
- try {
- var opts = JSON.parse(data);
- packet.name = opts.name;
- packet.args = opts.args;
- } catch (e) {
- }
- packet.args = packet.args || [];
- break;
- case 'json':
- try {
- packet.data = JSON.parse(data);
- } catch (e) {
- }
- break;
- case 'connect':
- packet.qs = data || '';
- break;
- case 'ack':
- var pieces = data.match(/^([0-9]+)(\+)?(.*)/);
- if (pieces) {
- packet.ackId = pieces[1];
- packet.args = [];
- if (pieces[3]) {
- try {
- packet.args = pieces[3] ? JSON.parse(pieces[3]) : [];
- } catch (e) {
- }
- }
- }
- break;
- case 'disconnect':
- case 'heartbeat':
- break;
- }
- ;
- return packet;
- };
- /**
- * Decodes data payload. Detects multiple messages
- *
- * @return {Array} messages
- * @api public
- */
- parser.decodePayload = function (data) {
- // IE doesn't like data[i] for unicode chars, charAt works fine
- if (data.charAt(0) == '\ufffd') {
- var ret = [];
- for (var i = 1, length = ''; i < data.length; i++) {
- if (data.charAt(i) == '\ufffd') {
- ret.push(parser.decodePacket(data.substr(i + 1).substr(0, length)));
- i += Number(length) + 1;
- length = '';
- } else {
- length += data.charAt(i);
- }
- }
- return ret;
- } else {
- return [parser.decodePacket(data)];
- }
- };
- })(
- 'undefined' != typeof io ? io : module.exports
- , 'undefined' != typeof io ? io : module.parent.exports
- );
- /**
- * socket.io
- * Copyright(c) 2011 LearnBoost <dev@learnboost.com>
- * MIT Licensed
- */
- (function (exports, io) {
- /**
- * Expose constructor.
- */
- exports.Transport = Transport;
- /**
- * This is the transport template for all supported transport methods.
- *
- * @constructor
- * @api public
- */
- function Transport(socket, sessid) {
- this.socket = socket;
- this.sessid = sessid;
- };
- /**
- * Apply EventEmitter mixin.
- */
- io.util.mixin(Transport, io.EventEmitter);
- /**
- * Indicates whether heartbeats is enabled for this transport
- *
- * @api private
- */
- Transport.prototype.heartbeats = function () {
- return true;
- };
- /**
- * Handles the response from the server. When a new response is received
- * it will automatically update the timeout, decode the message and
- * forwards the response to the onMessage function for further processing.
- *
- * @param {String} data Response from the server.
- * @api private
- */
- Transport.prototype.onData = function (data) {
- this.clearCloseTimeout();
- // If the connection in currently open (or in a reopening state) reset the close
- // timeout since we have just received data. This check is necessary so
- // that we don't reset the timeout on an explicitly disconnected connection.
- if (this.socket.connected || this.socket.connecting || this.socket.reconnecting) {
- this.setCloseTimeout();
- }
- if (data !== '') {
- // todo: we should only do decodePayload for xhr transports
- var msgs = io.parser.decodePayload(data);
- if (msgs && msgs.length) {
- for (var i = 0, l = msgs.length; i < l; i++) {
- this.onPacket(msgs[i]);
- }
- }
- }
- return this;
- };
- /**
- * Handles packets.
- *
- * @api private
- */
- Transport.prototype.onPacket = function (packet) {
- this.socket.setHeartbeatTimeout();
- if (packet.type == 'heartbeat') {
- return this.onHeartbeat();
- }
- if (packet.type == 'connect' && packet.endpoint == '') {
- this.onConnect();
- }
- if (packet.type == 'error' && packet.advice == 'reconnect') {
- this.isOpen = false;
- }
- this.socket.onPacket(packet);
- return this;
- };
- /**
- * Sets close timeout
- *
- * @api private
- */
- Transport.prototype.setCloseTimeout = function () {
- if (!this.closeTimeout) {
- var self = this;
- this.closeTimeout = setTimeout(function () {
- self.onDisconnect();
- }, this.socket.closeTimeout);
- }
- };
- /**
- * Called when transport disconnects.
- *
- * @api private
- */
- Transport.prototype.onDisconnect = function () {
- if (this.isOpen) this.close();
- this.clearTimeouts();
- this.socket.onDisconnect();
- return this;
- };
- /**
- * Called when transport connects
- *
- * @api private
- */
- Transport.prototype.onConnect = function () {
- this.socket.onConnect();
- return this;
- };
- /**
- * Clears close timeout
- *
- * @api private
- */
- Transport.prototype.clearCloseTimeout = function () {
- if (this.closeTimeout) {
- clearTimeout(this.closeTimeout);
- this.closeTimeout = null;
- }
- };
- /**
- * Clear timeouts
- *
- * @api private
- */
- Transport.prototype.clearTimeouts = function () {
- this.clearCloseTimeout();
- if (this.reopenTimeout) {
- clearTimeout(this.reopenTimeout);
- }
- };
- /**
- * Sends a packet
- *
- * @param {Object} packet object.
- * @api private
- */
- Transport.prototype.packet = function (packet) {
- this.send(io.parser.encodePacket(packet));
- };
- /**
- * Send the received heartbeat message back to server. So the server
- * knows we are still connected.
- *
- * @param {String} heartbeat Heartbeat response from the server.
- * @api private
- */
- Transport.prototype.onHeartbeat = function (heartbeat) {
- this.packet({type: 'heartbeat'});
- };
- /**
- * Called when the transport opens.
- *
- * @api private
- */
- Transport.prototype.onOpen = function () {
- this.isOpen = true;
- this.clearCloseTimeout();
- this.socket.onOpen();
- };
- /**
- * Notifies the base when the connection with the Socket.IO server
- * has been disconnected.
- *
- * @api private
- */
- Transport.prototype.onClose = function () {
- var self = this;
- /* FIXME: reopen delay causing a infinit loop
- this.reopenTimeout = setTimeout(function () {
- self.open();
- }, this.socket.options['reopen delay']);*/
- this.isOpen = false;
- this.socket.onClose();
- this.onDisconnect();
- };
- /**
- * Generates a connection url based on the Socket.IO URL Protocol.
- * See <https://github.com/learnboost/socket.io-node/> for more details.
- *
- * @returns {String} Connection url
- * @api private
- */
- Transport.prototype.prepareUrl = function () {
- var options = this.socket.options;
- return this.scheme() + '://'
- + options.host + ':' + options.port + '/'
- + options.resource + '/' + io.protocol
- + '/' + this.name + '/' + this.sessid;
- };
- /**
- * Checks if the transport is ready to start a connection.
- *
- * @param {Socket} socket The socket instance that needs a transport
- * @param {Function} fn The callback
- * @api private
- */
- Transport.prototype.ready = function (socket, fn) {
- fn.call(this);
- };
- })(
- 'undefined' != typeof io ? io : module.exports
- , 'undefined' != typeof io ? io : module.parent.exports
- );
- /**
- * socket.io
- * Copyright(c) 2011 LearnBoost <dev@learnboost.com>
- * MIT Licensed
- */
- (function (exports, io, global) {
- /**
- * Expose constructor.
- */
- exports.Socket = Socket;
- /**
- * Create a new `Socket.IO client` which can establish a persistent
- * connection with a Socket.IO enabled server.
- *
- * @api public
- */
- function Socket(options) {
- this.options = {
- port: 80
- , secure: false
- , document: 'document' in global ? document : false
- , resource: 'socket.io'
- , transports: io.transports
- , 'connect timeout': 10000
- , 'try multiple transports': true
- , 'reconnect': true
- , 'reconnection delay': 500
- , 'reconnection limit': Infinity
- , 'reopen delay': 3000
- , 'max reconnection attempts': 10
- , 'sync disconnect on unload': false
- , 'auto connect': true
- , 'flash policy port': 10843
- , 'manualFlush': false
- };
- io.util.merge(this.options, options);
- this.connected = false;
- this.open = false;
- this.connecting = false;
- this.reconnecting = false;
- this.namespaces = {};
- this.buffer = [];
- this.doBuffer = false;
- if (this.options['sync disconnect on unload'] &&
- (!this.isXDomain() || io.util.ua.hasCORS)) {
- var self = this;
- io.util.on(global, 'beforeunload', function () {
- self.disconnectSync();
- }, false);
- }
- if (this.options['auto connect']) {
- this.connect();
- }
- };
- /**
- * Apply EventEmitter mixin.
- */
- io.util.mixin(Socket, io.EventEmitter);
- /**
- * Returns a namespace listener/emitter for this socket
- *
- * @api public
- */
- Socket.prototype.of = function (name) {
- if (!this.namespaces[name]) {
- this.namespaces[name] = new io.SocketNamespace(this, name);
- if (name !== '') {
- this.namespaces[name].packet({type: 'connect'});
- }
- }
- return this.namespaces[name];
- };
- /**
- * Emits the given event to the Socket and all namespaces
- *
- * @api private
- */
- Socket.prototype.publish = function () {
- this.emit.apply(this, arguments);
- var nsp;
- for (var i in this.namespaces) {
- if (this.namespaces.hasOwnProperty(i)) {
- nsp = this.of(i);
- nsp.$emit.apply(nsp, arguments);
- }
- }
- };
- /**
- * Performs the handshake
- *
- * @api private
- */
- function empty() {
- };
- Socket.prototype.handshake = function (fn) {
- var self = this
- , options = this.options;
- function complete(data) {
- if (data instanceof Error) {
- self.connecting = false;
- self.onError(data.message);
- } else {
- fn.apply(null, data.split(':'));
- }
- };
- var url = [
- 'http' + (options.secure ? 's' : '') + ':/'
- , options.host + ':' + options.port
- , options.resource
- , io.protocol
- , io.util.query(this.options.query, 't=' + +new Date)
- ].join('/');
- if (this.isXDomain() && !io.util.ua.hasCORS) {
- var insertAt = document.getElementsByTagName('script')[0]
- , script = document.createElement('script');
- script.src = url + '&jsonp=' + io.j.length;
- insertAt.parentNode.insertBefore(script, insertAt);
- io.j.push(function (data) {
- complete(data);
- script.parentNode.removeChild(script);
- });
- } else {
- var xhr = io.util.request();
- xhr.open('GET', url, true);
- if (this.isXDomain()) {
- xhr.withCredentials = true;
- }
- xhr.onreadystatechange = function () {
- if (xhr.readyState == 4) {
- xhr.onreadystatechange = empty;
- if (xhr.status == 200) {
- complete(xhr.responseText);
- } else if (xhr.status == 403) {
- self.onError(xhr.responseText);
- } else {
- self.connecting = false;
- !self.reconnecting && self.onError(xhr.responseText);
- }
- }
- };
- xhr.send(null);
- }
- };
- /**
- * Find an available transport based on the options supplied in the constructor.
- *
- * @api private
- */
- Socket.prototype.getTransport = function (override) {
- var transports = override || this.transports, match;
- for (var i = 0, transport; transport = transports[i]; i++) {
- if (io.Transport[transport]
- && io.Transport[transport].check(this)
- && (!this.isXDomain() || io.Transport[transport].xdomainCheck(this))) {
- return new io.Transport[transport](this, this.sessionid);
- }
- }
- return null;
- };
- /**
- * Connects to the server.
- *
- * @param {Function} [fn] Callback.
- * @returns {io.Socket}
- * @api public
- */
- Socket.prototype.connect = function (fn) {
- if (this.connecting) {
- return this;
- }
- var self = this;
- self.connecting = true;
- this.handshake(function (sid, heartbeat, close, transports) {
- self.sessionid = sid;
- self.closeTimeout = close * 1000;
- self.heartbeatTimeout = heartbeat * 1000;
- if (!self.transports)
- self.transports = self.origTransports = (transports ? io.util.intersect(
- transports.split(',')
- , self.options.transports
- ) : self.options.transports);
- self.setHeartbeatTimeout();
- function connect(transports) {
- if (self.transport) self.transport.clearTimeouts();
- self.transport = self.getTransport(transports);
- if (!self.transport) return self.publish('connect_failed');
- // once the transport is ready
- self.transport.ready(self, function () {
- self.connecting = true;
- self.publish('connecting', self.transport.name);
- self.transport.open();
- if (self.options['connect timeout']) {
- self.connectTimeoutTimer = setTimeout(function () {
- if (!self.connected) {
- self.connecting = false;
- if (self.options['try multiple transports']) {
- var remaining = self.transports;
- while (remaining.length > 0 && remaining.splice(0, 1)[0] !=
- self.transport.name) {
- }
- if (remaining.length) {
- connect(remaining);
- } else {
- self.publish('connect_failed');
- }
- }
- }
- }, self.options['connect timeout']);
- }
- });
- }
- connect(self.transports);
- self.once('connect', function () {
- clearTimeout(self.connectTimeoutTimer);
- fn && typeof fn == 'function' && fn();
- });
- });
- return this;
- };
- /**
- * Clears and sets a new heartbeat timeout using the value given by the
- * server during the handshake.
- *
- * @api private
- */
- Socket.prototype.setHeartbeatTimeout = function () {
- clearTimeout(this.heartbeatTimeoutTimer);
- if (this.transport && !this.transport.heartbeats()) return;
- var self = this;
- this.heartbeatTimeoutTimer = setTimeout(function () {
- self.transport.onClose();
- }, this.heartbeatTimeout);
- };
- /**
- * Sends a message.
- *
- * @param {Object} data packet.
- * @returns {io.Socket}
- * @api public
- */
- Socket.prototype.packet = function (data) {
- if (this.connected && !this.doBuffer) {
- this.transport.packet(data);
- } else {
- this.buffer.push(data);
- }
- return this;
- };
- /**
- * Sets buffer state
- *
- * @api private
- */
- Socket.prototype.setBuffer = function (v) {
- this.doBuffer = v;
- if (!v && this.connected && this.buffer.length) {
- if (!this.options['manualFlush']) {
- this.flushBuffer();
- }
- }
- };
- /**
- * Flushes the buffer data over the wire.
- * To be invoked manually when 'manualFlush' is set to true.
- *
- * @api public
- */
- Socket.prototype.flushBuffer = function () {
- this.transport.payload(this.buffer);
- this.buffer = [];
- };
- /**
- * Disconnect the established connect.
- *
- * @returns {io.Socket}
- * @api public
- */
- Socket.prototype.disconnect = function () {
- if (this.connected || this.connecting) {
- if (this.open) {
- this.of('').packet({type: 'disconnect'});
- }
- // handle disconnection immediately
- this.onDisconnect('booted');
- }
- return this;
- };
- /**
- * Disconnects the socket with a sync XHR.
- *
- * @api private
- */
- Socket.prototype.disconnectSync = function () {
- // ensure disconnection
- var xhr = io.util.request();
- var uri = [
- 'http' + (this.options.secure ? 's' : '') + ':/'
- , this.options.host + ':' + this.options.port
- , this.options.resource
- , io.protocol
- , ''
- , this.sessionid
- ].join('/') + '/?disconnect=1';
- xhr.open('GET', uri, false);
- xhr.send(null);
- // handle disconnection immediately
- this.onDisconnect('booted');
- };
- /**
- * Check if we need to use cross domain enabled transports. Cross domain would
- * be a different port or different domain name.
- *
- * @returns {Boolean}
- * @api private
- */
- Socket.prototype.isXDomain = function () {
- var port = global.location.port ||
- ('https:' == global.location.protocol ? 443 : 80);
- return this.options.host !== global.location.hostname
- || this.options.port != port;
- };
- /**
- * Called upon handshake.
- *
- * @api private
- */
- Socket.prototype.onConnect = function () {
- if (!this.connected) {
- this.connected = true;
- this.connecting = false;
- if (!this.doBuffer) {
- // make sure to flush the buffer
- this.setBuffer(false);
- }
- this.emit('connect');
- }
- };
- /**
- * Called when the transport opens
- *
- * @api private
- */
- Socket.prototype.onOpen = function () {
- this.open = true;
- };
- /**
- * Called when the transport closes.
- *
- * @api private
- */
- Socket.prototype.onClose = function () {
- this.open = false;
- clearTimeout(this.heartbeatTimeoutTimer);
- };
- /**
- * Called when the transport first opens a connection
- *
- * @param text
- */
- Socket.prototype.onPacket = function (packet) {
- this.of(packet.endpoint).onPacket(packet);
- };
- /**
- * Handles an error.
- *
- * @api private
- */
- Socket.prototype.onError = function (err) {
- if (err && err.advice) {
- if (err.advice === 'reconnect' && (this.connected || this.connecting)) {
- this.disconnect();
- if (this.options.reconnect) {
- this.reconnect();
- }
- }
- }
- this.publish('error', err && err.reason ? err.reason : err);
- };
- /**
- * Called when the transport disconnects.
- *
- * @api private
- */
- Socket.prototype.onDisconnect = function (reason) {
- var wasConnected = this.connected
- , wasConnecting = this.connecting;
- this.connected = false;
- this.connecting = false;
- this.open = false;
- if (wasConnected || wasConnecting) {
- this.transport.close();
- this.transport.clearTimeouts();
- if (wasConnected) {
- this.publish('disconnect', reason);
- if ('booted' != reason && this.options.reconnect && !this.reconnecting) {
- this.reconnect();
- }
- }
- }
- };
- /**
- * Called upon reconnection.
- *
- * @api private
- */
- Socket.prototype.reconnect = function () {
- this.reconnecting = true;
- this.reconnectionAttempts = 0;
- this.reconnectionDelay = this.options['reconnection delay'];
- var self = this
- , maxAttempts = this.options['max reconnection attempts']
- , tryMultiple = this.options['try multiple transports']
- , limit = this.options['reconnection limit'];
- function reset() {
- if (self.connected) {
- for (var i in self.namespaces) {
- if (self.namespaces.hasOwnProperty(i) && '' !== i) {
- self.namespaces[i].packet({type: 'connect'});
- }
- }
- self.publish('reconnect', self.transport.name, self.reconnectionAttempts);
- }
- clearTimeout(self.reconnectionTimer);
- self.removeListener('connect_failed', maybeReconnect);
- self.removeListener('connect', maybeReconnect);
- self.reconnecting = false;
- delete self.reconnectionAttempts;
- delete self.reconnectionDelay;
- delete self.reconnectionTimer;
- delete self.redoTransports;
- self.options['try multiple transports'] = tryMultiple;
- };
- function maybeReconnect() {
- if (!self.reconnecting) {
- return;
- }
- if (self.connected) {
- return reset();
- }
- ;
- if (self.connecting && self.reconnecting) {
- return self.reconnectionTimer = setTimeout(maybeReconnect, 1000);
- }
- if (self.reconnectionAttempts++ >= maxAttempts) {
- if (!self.redoTransports) {
- self.on('connect_failed', maybeReconnect);
- self.options['try multiple transports'] = true;
- self.transports = self.origTransports;
- self.transport = self.getTransport();
- self.redoTransports = true;
- self.connect();
- } else {
- self.publish('reconnect_failed');
- reset();
- }
- } else {
- if (self.reconnectionDelay < limit) {
- self.reconnectionDelay *= 2; // exponential back off
- }
- self.connect();
- self.publish('reconnecting', self.reconnectionDelay, self.reconnectionAttempts);
- self.reconnectionTimer = setTimeout(maybeReconnect, self.reconnectionDelay);
- }
- };
- this.options['try multiple transports'] = false;
- this.reconnectionTimer = setTimeout(maybeReconnect, this.reconnectionDelay);
- this.on('connect', maybeReconnect);
- };
- })(
- 'undefined' != typeof io ? io : module.exports
- , 'undefined' != typeof io ? io : module.parent.exports
- , this
- );
- /**
- * socket.io
- * Copyright(c) 2011 LearnBoost <dev@learnboost.com>
- * MIT Licensed
- */
- (function (exports, io) {
- /**
- * Expose constructor.
- */
- exports.SocketNamespace = SocketNamespace;
- /**
- * Socket namespace constructor.
- *
- * @constructor
- * @api public
- */
- function SocketNamespace(socket, name) {
- this.socket = socket;
- this.name = name || '';
- this.flags = {};
- this.json = new Flag(this, 'json');
- this.ackPackets = 0;
- this.acks = {};
- };
- /**
- * Apply EventEmitter mixin.
- */
- io.util.mixin(SocketNamespace, io.EventEmitter);
- /**
- * Copies emit since we override it
- *
- * @api private
- */
- SocketNamespace.prototype.$emit = io.EventEmitter.prototype.emit;
- /**
- * Creates a new namespace, by proxying the request to the socket. This
- * allows us to use the synax as we do on the server.
- *
- * @api public
- */
- SocketNamespace.prototype.of = function () {
- return this.socket.of.apply(this.socket, arguments);
- };
- /**
- * Sends a packet.
- *
- * @api private
- */
- SocketNamespace.prototype.packet = function (packet) {
- packet.endpoint = this.name;
- this.socket.packet(packet);
- this.flags = {};
- return this;
- };
- /**
- * Sends a message
- *
- * @api public
- */
- SocketNamespace.prototype.send = function (data, fn) {
- var packet = {
- type: this.flags.json ? 'json' : 'message'
- , data: data
- };
- if ('function' == typeof fn) {
- packet.id = ++this.ackPackets;
- packet.ack = true;
- this.acks[packet.id] = fn;
- }
- return this.packet(packet);
- };
- /**
- * Emits an event
- *
- * @api public
- */
- SocketNamespace.prototype.emit = function (name) {
- var args = Array.prototype.slice.call(arguments, 1)
- , lastArg = args[args.length - 1]
- , packet = {
- type: 'event'
- , name: name
- };
- if ('function' == typeof lastArg) {
- packet.id = ++this.ackPackets;
- packet.ack = 'data';
- this.acks[packet.id] = lastArg;
- args = args.slice(0, args.length - 1);
- }
- packet.args = args;
- return this.packet(packet);
- };
- /**
- * Disconnects the namespace
- *
- * @api private
- */
- SocketNamespace.prototype.disconnect = function () {
- if (this.name === '') {
- this.socket.disconnect();
- } else {
- this.packet({type: 'disconnect'});
- this.$emit('disconnect');
- }
- return this;
- };
- /**
- * Handles a packet
- *
- * @api private
- */
- SocketNamespace.prototype.onPacket = function (packet) {
- var self = this;
- function ack() {
- self.packet({
- type: 'ack'
- , args: io.util.toArray(arguments)
- , ackId: packet.id
- });
- };
- switch (packet.type) {
- case 'connect':
- this.$emit('connect');
- break;
- case 'disconnect':
- if (this.name === '') {
- this.socket.onDisconnect(packet.reason || 'booted');
- } else {
- this.$emit('disconnect', packet.reason);
- }
- break;
- case 'message':
- case 'json':
- var params = ['message', packet.data];
- if (packet.ack == 'data') {
- params.push(ack);
- } else if (packet.ack) {
- this.packet({type: 'ack', ackId: packet.id});
- }
- this.$emit.apply(this, params);
- break;
- case 'event':
- var params = [packet.name].concat(packet.args);
- if (packet.ack == 'data')
- params.push(ack);
- this.$emit.apply(this, params);
- break;
- case 'ack':
- if (this.acks[packet.ackId]) {
- this.acks[packet.ackId].apply(this, packet.args);
- delete this.acks[packet.ackId];
- }
- break;
- case 'error':
- if (packet.advice) {
- this.socket.onError(packet);
- } else {
- if (packet.reason == 'unauthorized') {
- this.$emit('connect_failed', packet.reason);
- } else {
- this.$emit('error', packet.reason);
- }
- }
- break;
- }
- };
- /**
- * Flag interface.
- *
- * @api private
- */
- function Flag(nsp, name) {
- this.namespace = nsp;
- this.name = name;
- };
- /**
- * Send a message
- *
- * @api public
- */
- Flag.prototype.send = function () {
- this.namespace.flags[this.name] = true;
- this.namespace.send.apply(this.namespace, arguments);
- };
- /**
- * Emit an event
- *
- * @api public
- */
- Flag.prototype.emit = function () {
- this.namespace.flags[this.name] = true;
- this.namespace.emit.apply(this.namespace, arguments);
- };
- })(
- 'undefined' != typeof io ? io : module.exports
- , 'undefined' != typeof io ? io : module.parent.exports
- );
- /**
- * socket.io
- * Copyright(c) 2011 LearnBoost <dev@learnboost.com>
- * MIT Licensed
- */
- (function (exports, io, global) {
- /**
- * Expose constructor.
- */
- exports.websocket = WS;
- /**
- * The WebSocket transport uses the HTML5 WebSocket API to establish an
- * persistent connection with the Socket.IO server. This transport will also
- * be inherited by the FlashSocket fallback as it provides a API compatible
- * polyfill for the WebSockets.
- *
- * @constructor
- * @extends {io.Transport}
- * @api public
- */
- function WS(socket) {
- io.Transport.apply(this, arguments);
- };
- /**
- * Inherits from Transport.
- */
- io.util.inherit(WS, io.Transport);
- /**
- * Transport name
- *
- * @api public
- */
- WS.prototype.name = 'websocket';
- /**
- * Initializes a new `WebSocket` connection with the Socket.IO server. We attach
- * all the appropriate listeners to handle the responses from the server.
- *
- * @returns {Transport}
- * @api public
- */
- WS.prototype.open = function () {
- var query = io.util.query(this.socket.options.query)
- , self = this
- , Socket
- if (!Socket) {
- Socket = global.MozWebSocket || global.WebSocket;
- }
- this.websocket = new Socket(this.prepareUrl() + query);
- this.websocket.onopen = function () {
- self.onOpen();
- self.socket.setBuffer(false);
- };
- this.websocket.onmessage = function (ev) {
- self.onData(ev.data);
- };
- this.websocket.onclose = function () {
- self.onClose();
- self.socket.setBuffer(true);
- };
- this.websocket.onerror = function (e) {
- self.onError(e);
- };
- return this;
- };
- /**
- * Send a message to the Socket.IO server. The message will automatically be
- * encoded in the correct message format.
- *
- * @returns {Transport}
- * @api public
- */
- // Do to a bug in the current IDevices browser, we need to wrap the send in a
- // setTimeout, when they resume from sleeping the browser will crash if
- // we don't allow the browser time to detect the socket has been closed
- if (io.util.ua.iDevice) {
- WS.prototype.send = function (data) {
- var self = this;
- setTimeout(function () {
- self.websocket.send(data);
- }, 0);
- return this;
- };
- } else {
- WS.prototype.send = function (data) {
- this.websocket.send(data);
- return this;
- };
- }
- /**
- * Payload
- *
- * @api private
- */
- WS.prototype.payload = function (arr) {
- for (var i = 0, l = arr.length; i < l; i++) {
- this.packet(arr[i]);
- }
- return this;
- };
- /**
- * Disconnect the established `WebSocket` connection.
- *
- * @returns {Transport}
- * @api public
- */
- WS.prototype.close = function () {
- this.websocket.close();
- return this;
- };
- /**
- * Handle the errors that `WebSocket` might be giving when we
- * are attempting to connect or send messages.
- *
- * @param {Error} e The error.
- * @api private
- */
- WS.prototype.onError = function (e) {
- this.socket.onError(e);
- };
- /**
- * Returns the appropriate scheme for the URI generation.
- *
- * @api private
- */
- WS.prototype.scheme = function () {
- return this.socket.options.secure ? 'wss' : 'ws';
- };
- /**
- * Checks if the browser has support for native `WebSockets` and that
- * it's not the polyfill created for the FlashSocket transport.
- *
- * @return {Boolean}
- * @api public
- */
- WS.check = function () {
- return ('WebSocket' in global && !('__addTask' in WebSocket))
- || 'MozWebSocket' in global;
- };
- /**
- * Check if the `WebSocket` transport support cross domain communications.
- *
- * @returns {Boolean}
- * @api public
- */
- WS.xdomainCheck = function () {
- return true;
- };
- /**
- * Add the transport to your public io.transports array.
- *
- * @api private
- */
- io.transports.push('websocket');
- })(
- 'undefined' != typeof io ? io.Transport : module.exports
- , 'undefined' != typeof io ? io : module.parent.exports
- , this
- );
- /**
- * socket.io
- * Copyright(c) 2011 LearnBoost <dev@learnboost.com>
- * MIT Licensed
- */
- (function (exports, io) {
- /**
- * Expose constructor.
- */
- exports.flashsocket = Flashsocket;
- /**
- * The FlashSocket transport. This is a API wrapper for the HTML5 WebSocket
- * specification. It uses a .swf file to communicate with the server. If you want
- * to serve the .swf file from a other server than where the Socket.IO script is
- * coming from you need to use the insecure version of the .swf. More information
- * about this can be found on the github page.
- *
- * @constructor
- * @extends {io.Transport.websocket}
- * @api public
- */
- function Flashsocket() {
- io.Transport.websocket.apply(this, arguments);
- };
- /**
- * Inherits from Transport.
- */
- io.util.inherit(Flashsocket, io.Transport.websocket);
- /**
- * Transport name
- *
- * @api public
- */
- Flashsocket.prototype.name = 'flashsocket';
- /**
- * Disconnect the established `FlashSocket` connection. This is done by adding a
- * new task to the FlashSocket. The rest will be handled off by the `WebSocket`
- * transport.
- *
- * @returns {Transport}
- * @api public
- */
- Flashsocket.prototype.open = function () {
- var self = this
- , args = arguments;
- WebSocket.__addTask(function () {
- io.Transport.websocket.prototype.open.apply(self, args);
- });
- return this;
- };
- /**
- * Sends a message to the Socket.IO server. This is done by adding a new
- * task to the FlashSocket. The rest will be handled off by the `WebSocket`
- * transport.
- *
- * @returns {Transport}
- * @api public
- */
- Flashsocket.prototype.send = function () {
- var self = this, args = arguments;
- WebSocket.__addTask(function () {
- io.Transport.websocket.prototype.send.apply(self, args);
- });
- return this;
- };
- /**
- * Disconnects the established `FlashSocket` connection.
- *
- * @returns {Transport}
- * @api public
- */
- Flashsocket.prototype.close = function () {
- WebSocket.__tasks.length = 0;
- io.Transport.websocket.prototype.close.call(this);
- return this;
- };
- /**
- * The WebSocket fall back needs to append the flash container to the body
- * element, so we need to make sure we have access to it. Or defer the call
- * until we are sure there is a body element.
- *
- * @param {Socket} socket The socket instance that needs a transport
- * @param {Function} fn The callback
- * @api private
- */
- Flashsocket.prototype.ready = function (socket, fn) {
- function init() {
- var options = socket.options
- , port = options['flash policy port']
- , path = [
- 'http' + (options.secure ? 's' : '') + ':/'
- , options.host + ':' + options.port
- , options.resource
- , 'static/flashsocket'
- , 'WebSocketMain' + (socket.isXDomain() ? 'Insecure' : '') + '.swf'
- ];
- // Only start downloading the swf file when the checked that this browser
- // actually supports it
- if (!Flashsocket.loaded) {
- if (typeof WEB_SOCKET_SWF_LOCATION === 'undefined') {
- // Set the correct file based on the XDomain settings
- WEB_SOCKET_SWF_LOCATION = path.join('/');
- }
- if (port !== 843) {
- WebSocket.loadFlashPolicyFile('xmlsocket://' + options.host + ':' + port);
- }
- WebSocket.__initialize();
- Flashsocket.loaded = true;
- }
- fn.call(self);
- }
- var self = this;
- if (document.body) return init();
- io.util.load(init);
- };
- /**
- * Check if the FlashSocket transport is supported as it requires that the Adobe
- * Flash Player plug-in version `10.0.0` or greater is installed. And also check if
- * the polyfill is correctly loaded.
- *
- * @returns {Boolean}
- * @api public
- */
- Flashsocket.check = function () {
- if (
- typeof WebSocket == 'undefined'
- || !('__initialize' in WebSocket) || !swfobject
- ) return false;
- return swfobject.getFlashPlayerVersion().major >= 10;
- };
- /**
- * Check if the FlashSocket transport can be used as cross domain / cross origin
- * transport. Because we can't see which type (secure or insecure) of .swf is used
- * we will just return true.
- *
- * @returns {Boolean}
- * @api public
- */
- Flashsocket.xdomainCheck = function () {
- return true;
- };
- /**
- * Disable AUTO_INITIALIZATION
- */
- if (typeof window != 'undefined') {
- WEB_SOCKET_DISABLE_AUTO_INITIALIZATION = true;
- }
- /**
- * Add the transport to your public io.transports array.
- *
- * @api private
- */
- io.transports.push('flashsocket');
- })(
- 'undefined' != typeof io ? io.Transport : module.exports
- , 'undefined' != typeof io ? io : module.parent.exports
- );
- /* SWFObject v2.2 <http://code.google.com/p/swfobject/>
- is released under the MIT License <http://www.opensource.org/licenses/mit-license.php>
- */
- if ('undefined' != typeof window) {
- var swfobject = function () {
- var D = "undefined", r = "object", S = "Shockwave Flash", W = "ShockwaveFlash.ShockwaveFlash",
- q = "application/x-shockwave-flash", R = "SWFObjectExprInst", x = "onreadystatechange", O = window,
- j = document, t = navigator, T = false, U = [h], o = [], N = [], I = [], l, Q, E, B, J = false,
- a = false, n, G, m = true, M = function () {
- var aa = typeof j.getElementById != D && typeof j.getElementsByTagName != D && typeof j.createElement != D,
- ah = t.userAgent.toLowerCase(), Y = t.platform.toLowerCase(),
- ae = Y ? /win/.test(Y) : /win/.test(ah), ac = Y ? /mac/.test(Y) : /mac/.test(ah),
- af = /webkit/.test(ah) ? parseFloat(ah.replace(/^.*webkit\/(\d+(\.\d+)?).*$/, "$1")) : false,
- X = !+"\v1", ag = [0, 0, 0], ab = null;
- if (typeof t.plugins != D && typeof t.plugins[S] == r) {
- ab = t.plugins[S].description;
- if (ab && !(typeof t.mimeTypes != D && t.mimeTypes[q] && !t.mimeTypes[q].enabledPlugin)) {
- T = true;
- X = false;
- ab = ab.replace(/^.*\s+(\S+\s+\S+$)/, "$1");
- ag[0] = parseInt(ab.replace(/^(.*)\..*$/, "$1"), 10);
- ag[1] = parseInt(ab.replace(/^.*\.(.*)\s.*$/, "$1"), 10);
- ag[2] = /[a-zA-Z]/.test(ab) ? parseInt(ab.replace(/^.*[a-zA-Z]+(.*)$/, "$1"), 10) : 0
- }
- } else {
- if (typeof O[(['Active'].concat('Object').join('X'))] != D) {
- try {
- var ad = new window[(['Active'].concat('Object').join('X'))](W);
- if (ad) {
- ab = ad.GetVariable("$version");
- if (ab) {
- X = true;
- ab = ab.split(" ")[1].split(",");
- ag = [parseInt(ab[0], 10), parseInt(ab[1], 10), parseInt(ab[2], 10)]
- }
- }
- } catch (Z) {
- }
- }
- }
- return {w3: aa, pv: ag, wk: af, ie: X, win: ae, mac: ac}
- }(), k = function () {
- if (!M.w3) {
- return
- }
- if ((typeof j.readyState != D && j.readyState == "complete") || (typeof j.readyState == D && (j.getElementsByTagName("body")[0] || j.body))) {
- f()
- }
- if (!J) {
- if (typeof j.addEventListener != D) {
- j.addEventListener("DOMContentLoaded", f, false)
- }
- if (M.ie && M.win) {
- j.attachEvent(x, function () {
- if (j.readyState == "complete") {
- j.detachEvent(x, arguments.callee);
- f()
- }
- });
- if (O == top) {
- (function () {
- if (J) {
- return
- }
- try {
- j.documentElement.doScroll("left")
- } catch (X) {
- setTimeout(arguments.callee, 0);
- return
- }
- f()
- })()
- }
- }
- if (M.wk) {
- (function () {
- if (J) {
- return
- }
- if (!/loaded|complete/.test(j.readyState)) {
- setTimeout(arguments.callee, 0);
- return
- }
- f()
- })()
- }
- s(f)
- }
- }();
- function f() {
- if (J) {
- return
- }
- try {
- var Z = j.getElementsByTagName("body")[0].appendChild(C("span"));
- Z.parentNode.removeChild(Z)
- } catch (aa) {
- return
- }
- J = true;
- var X = U.length;
- for (var Y = 0; Y < X; Y++) {
- U[Y]()
- }
- }
- function K(X) {
- if (J) {
- X()
- } else {
- U[U.length] = X
- }
- }
- function s(Y) {
- if (typeof O.addEventListener != D) {
- O.addEventListener("load", Y, false)
- } else {
- if (typeof j.addEventListener != D) {
- j.addEventListener("load", Y, false)
- } else {
- if (typeof O.attachEvent != D) {
- i(O, "onload", Y)
- } else {
- if (typeof O.onload == "function") {
- var X = O.onload;
- O.onload = function () {
- X();
- Y()
- }
- } else {
- O.onload = Y
- }
- }
- }
- }
- }
- function h() {
- if (T) {
- V()
- } else {
- H()
- }
- }
- function V() {
- var X = j.getElementsByTagName("body")[0];
- var aa = C(r);
- aa.setAttribute("type", q);
- var Z = X.appendChild(aa);
- if (Z) {
- var Y = 0;
- (function () {
- if (typeof Z.GetVariable != D) {
- var ab = Z.GetVariable("$version");
- if (ab) {
- ab = ab.split(" ")[1].split(",");
- M.pv = [parseInt(ab[0], 10), parseInt(ab[1], 10), parseInt(ab[2], 10)]
- }
- } else {
- if (Y < 10) {
- Y++;
- setTimeout(arguments.callee, 10);
- return
- }
- }
- X.removeChild(aa);
- Z = null;
- H()
- })()
- } else {
- H()
- }
- }
- function H() {
- var ag = o.length;
- if (ag > 0) {
- for (var af = 0; af < ag; af++) {
- var Y = o[af].id;
- var ab = o[af].callbackFn;
- var aa = {success: false, id: Y};
- if (M.pv[0] > 0) {
- var ae = c(Y);
- if (ae) {
- if (F(o[af].swfVersion) && !(M.wk && M.wk < 312)) {
- w(Y, true);
- if (ab) {
- aa.success = true;
- aa.ref = z(Y);
- ab(aa)
- }
- } else {
- if (o[af].expressInstall && A()) {
- var ai = {};
- ai.data = o[af].expressInstall;
- ai.width = ae.getAttribute("width") || "0";
- ai.height = ae.getAttribute("height") || "0";
- if (ae.getAttribute("class")) {
- ai.styleclass = ae.getAttribute("class")
- }
- if (ae.getAttribute("align")) {
- ai.align = ae.getAttribute("align")
- }
- var ah = {};
- var X = ae.getElementsByTagName("param");
- var ac = X.length;
- for (var ad = 0; ad < ac; ad++) {
- if (X[ad].getAttribute("name").toLowerCase() != "movie") {
- ah[X[ad].getAttribute("name")] = X[ad].getAttribute("value")
- }
- }
- P(ai, ah, Y, ab)
- } else {
- p(ae);
- if (ab) {
- ab(aa)
- }
- }
- }
- }
- } else {
- w(Y, true);
- if (ab) {
- var Z = z(Y);
- if (Z && typeof Z.SetVariable != D) {
- aa.success = true;
- aa.ref = Z
- }
- ab(aa)
- }
- }
- }
- }
- }
- function z(aa) {
- var X = null;
- var Y = c(aa);
- if (Y && Y.nodeName == "OBJECT") {
- if (typeof Y.SetVariable != D) {
- X = Y
- } else {
- var Z = Y.getElementsByTagName(r)[0];
- if (Z) {
- X = Z
- }
- }
- }
- return X
- }
- function A() {
- return !a && F("6.0.65") && (M.win || M.mac) && !(M.wk && M.wk < 312)
- }
- function P(aa, ab, X, Z) {
- a = true;
- E = Z || null;
- B = {success: false, id: X};
- var ae = c(X);
- if (ae) {
- if (ae.nodeName == "OBJECT") {
- l = g(ae);
- Q = null
- } else {
- l = ae;
- Q = X
- }
- aa.id = R;
- if (typeof aa.width == D || (!/%$/.test(aa.width) && parseInt(aa.width, 10) < 310)) {
- aa.width = "310"
- }
- if (typeof aa.height == D || (!/%$/.test(aa.height) && parseInt(aa.height, 10) < 137)) {
- aa.height = "137"
- }
- j.title = j.title.slice(0, 47) + " - Flash Player Installation";
- var ad = M.ie && M.win ? (['Active'].concat('').join('X')) : "PlugIn",
- ac = "MMredirectURL=" + O.location.toString().replace(/&/g, "%26") + "&MMplayerType=" + ad + "&MMdoctitle=" + j.title;
- if (typeof ab.flashvars != D) {
- ab.flashvars += "&" + ac
- } else {
- ab.flashvars = ac
- }
- if (M.ie && M.win && ae.readyState != 4) {
- var Y = C("div");
- X += "SWFObjectNew";
- Y.setAttribute("id", X);
- ae.parentNode.insertBefore(Y, ae);
- ae.style.display = "none";
- (function () {
- if (ae.readyState == 4) {
- ae.parentNode.removeChild(ae)
- } else {
- setTimeout(arguments.callee, 10)
- }
- })()
- }
- u(aa, ab, X)
- }
- }
- function p(Y) {
- if (M.ie && M.win && Y.readyState != 4) {
- var X = C("div");
- Y.parentNode.insertBefore(X, Y);
- X.parentNode.replaceChild(g(Y), X);
- Y.style.display = "none";
- (function () {
- if (Y.readyState == 4) {
- Y.parentNode.removeChild(Y)
- } else {
- setTimeout(arguments.callee, 10)
- }
- })()
- } else {
- Y.parentNode.replaceChild(g(Y), Y)
- }
- }
- function g(ab) {
- var aa = C("div");
- if (M.win && M.ie) {
- aa.innerHTML = ab.innerHTML
- } else {
- var Y = ab.getElementsByTagName(r)[0];
- if (Y) {
- var ad = Y.childNodes;
- if (ad) {
- var X = ad.length;
- for (var Z = 0; Z < X; Z++) {
- if (!(ad[Z].nodeType == 1 && ad[Z].nodeName == "PARAM") && !(ad[Z].nodeType == 8)) {
- aa.appendChild(ad[Z].cloneNode(true))
- }
- }
- }
- }
- }
- return aa
- }
- function u(ai, ag, Y) {
- var X, aa = c(Y);
- if (M.wk && M.wk < 312) {
- return X
- }
- if (aa) {
- if (typeof ai.id == D) {
- ai.id = Y
- }
- if (M.ie && M.win) {
- var ah = "";
- for (var ae in ai) {
- if (ai[ae] != Object.prototype[ae]) {
- if (ae.toLowerCase() == "data") {
- ag.movie = ai[ae]
- } else {
- if (ae.toLowerCase() == "styleclass") {
- ah += ' class="' + ai[ae] + '"'
- } else {
- if (ae.toLowerCase() != "classid") {
- ah += " " + ae + '="' + ai[ae] + '"'
- }
- }
- }
- }
- }
- var af = "";
- for (var ad in ag) {
- if (ag[ad] != Object.prototype[ad]) {
- af += '<param name="' + ad + '" value="' + ag[ad] + '" />'
- }
- }
- aa.outerHTML = '<object classid="clsid:D27CDB6E-AE6D-11cf-96B8-444553540000"' + ah + ">" + af + "</object>";
- N[N.length] = ai.id;
- X = c(ai.id)
- } else {
- var Z = C(r);
- Z.setAttribute("type", q);
- for (var ac in ai) {
- if (ai[ac] != Object.prototype[ac]) {
- if (ac.toLowerCase() == "styleclass") {
- Z.setAttribute("class", ai[ac])
- } else {
- if (ac.toLowerCase() != "classid") {
- Z.setAttribute(ac, ai[ac])
- }
- }
- }
- }
- for (var ab in ag) {
- if (ag[ab] != Object.prototype[ab] && ab.toLowerCase() != "movie") {
- e(Z, ab, ag[ab])
- }
- }
- aa.parentNode.replaceChild(Z, aa);
- X = Z
- }
- }
- return X
- }
- function e(Z, X, Y) {
- var aa = C("param");
- aa.setAttribute("name", X);
- aa.setAttribute("value", Y);
- Z.appendChild(aa)
- }
- function y(Y) {
- var X = c(Y);
- if (X && X.nodeName == "OBJECT") {
- if (M.ie && M.win) {
- X.style.display = "none";
- (function () {
- if (X.readyState == 4) {
- b(Y)
- } else {
- setTimeout(arguments.callee, 10)
- }
- })()
- } else {
- X.parentNode.removeChild(X)
- }
- }
- }
- function b(Z) {
- var Y = c(Z);
- if (Y) {
- for (var X in Y) {
- if (typeof Y[X] == "function") {
- Y[X] = null
- }
- }
- Y.parentNode.removeChild(Y)
- }
- }
- function c(Z) {
- var X = null;
- try {
- X = j.getElementById(Z)
- } catch (Y) {
- }
- return X
- }
- function C(X) {
- return j.createElement(X)
- }
- function i(Z, X, Y) {
- Z.attachEvent(X, Y);
- I[I.length] = [Z, X, Y]
- }
- function F(Z) {
- var Y = M.pv, X = Z.split(".");
- X[0] = parseInt(X[0], 10);
- X[1] = parseInt(X[1], 10) || 0;
- X[2] = parseInt(X[2], 10) || 0;
- return (Y[0] > X[0] || (Y[0] == X[0] && Y[1] > X[1]) || (Y[0] == X[0] && Y[1] == X[1] && Y[2] >= X[2])) ? true : false
- }
- function v(ac, Y, ad, ab) {
- if (M.ie && M.mac) {
- return
- }
- var aa = j.getElementsByTagName("head")[0];
- if (!aa) {
- return
- }
- var X = (ad && typeof ad == "string") ? ad : "screen";
- if (ab) {
- n = null;
- G = null
- }
- if (!n || G != X) {
- var Z = C("style");
- Z.setAttribute("type", "text/css");
- Z.setAttribute("media", X);
- n = aa.appendChild(Z);
- if (M.ie && M.win && typeof j.styleSheets != D && j.styleSheets.length > 0) {
- n = j.styleSheets[j.styleSheets.length - 1]
- }
- G = X
- }
- if (M.ie && M.win) {
- if (n && typeof n.addRule == r) {
- n.addRule(ac, Y)
- }
- } else {
- if (n && typeof j.createTextNode != D) {
- n.appendChild(j.createTextNode(ac + " {" + Y + "}"))
- }
- }
- }
- function w(Z, X) {
- if (!m) {
- return
- }
- var Y = X ? "visible" : "hidden";
- if (J && c(Z)) {
- c(Z).style.visibility = Y
- } else {
- v("#" + Z, "visibility:" + Y)
- }
- }
- function L(Y) {
- var Z = /[\\\"<>\.;]/;
- var X = Z.exec(Y) != null;
- return X && typeof encodeURIComponent != D ? encodeURIComponent(Y) : Y
- }
- var d = function () {
- if (M.ie && M.win) {
- window.attachEvent("onunload", function () {
- var ac = I.length;
- for (var ab = 0; ab < ac; ab++) {
- I[ab][0].detachEvent(I[ab][1], I[ab][2])
- }
- var Z = N.length;
- for (var aa = 0; aa < Z; aa++) {
- y(N[aa])
- }
- for (var Y in M) {
- M[Y] = null
- }
- M = null;
- for (var X in swfobject) {
- swfobject[X] = null
- }
- swfobject = null
- })
- }
- }();
- return {
- registerObject: function (ab, X, aa, Z) {
- if (M.w3 && ab && X) {
- var Y = {};
- Y.id = ab;
- Y.swfVersion = X;
- Y.expressInstall = aa;
- Y.callbackFn = Z;
- o[o.length] = Y;
- w(ab, false)
- } else {
- if (Z) {
- Z({success: false, id: ab})
- }
- }
- }, getObjectById: function (X) {
- if (M.w3) {
- return z(X)
- }
- }, embedSWF: function (ab, ah, ae, ag, Y, aa, Z, ad, af, ac) {
- var X = {success: false, id: ah};
- if (M.w3 && !(M.wk && M.wk < 312) && ab && ah && ae && ag && Y) {
- w(ah, false);
- K(function () {
- ae += "";
- ag += "";
- var aj = {};
- if (af && typeof af === r) {
- for (var al in af) {
- aj[al] = af[al]
- }
- }
- aj.data = ab;
- aj.width = ae;
- aj.height = ag;
- var am = {};
- if (ad && typeof ad === r) {
- for (var ak in ad) {
- am[ak] = ad[ak]
- }
- }
- if (Z && typeof Z === r) {
- for (var ai in Z) {
- if (typeof am.flashvars != D) {
- am.flashvars += "&" + ai + "=" + Z[ai]
- } else {
- am.flashvars = ai + "=" + Z[ai]
- }
- }
- }
- if (F(Y)) {
- var an = u(aj, am, ah);
- if (aj.id == ah) {
- w(ah, true)
- }
- X.success = true;
- X.ref = an
- } else {
- if (aa && A()) {
- aj.data = aa;
- P(aj, am, ah, ac);
- return
- } else {
- w(ah, true)
- }
- }
- if (ac) {
- ac(X)
- }
- })
- } else {
- if (ac) {
- ac(X)
- }
- }
- }, switchOffAutoHideShow: function () {
- m = false
- }, ua: M, getFlashPlayerVersion: function () {
- return {major: M.pv[0], minor: M.pv[1], release: M.pv[2]}
- }, hasFlashPlayerVersion: F, createSWF: function (Z, Y, X) {
- if (M.w3) {
- return u(Z, Y, X)
- } else {
- return undefined
- }
- }, showExpressInstall: function (Z, aa, X, Y) {
- if (M.w3 && A()) {
- P(Z, aa, X, Y)
- }
- }, removeSWF: function (X) {
- if (M.w3) {
- y(X)
- }
- }, createCSS: function (aa, Z, Y, X) {
- if (M.w3) {
- v(aa, Z, Y, X)
- }
- }, addDomLoadEvent: K, addLoadEvent: s, getQueryParamValue: function (aa) {
- var Z = j.location.search || j.location.hash;
- if (Z) {
- if (/\?/.test(Z)) {
- Z = Z.split("?")[1]
- }
- if (aa == null) {
- return L(Z)
- }
- var Y = Z.split("&");
- for (var X = 0; X < Y.length; X++) {
- if (Y[X].substring(0, Y[X].indexOf("=")) == aa) {
- return L(Y[X].substring((Y[X].indexOf("=") + 1)))
- }
- }
- }
- return ""
- }, expressInstallCallback: function () {
- if (a) {
- var X = c(R);
- if (X && l) {
- X.parentNode.replaceChild(l, X);
- if (Q) {
- w(Q, true);
- if (M.ie && M.win) {
- l.style.display = "block"
- }
- }
- if (E) {
- E(B)
- }
- }
- a = false
- }
- }
- }
- }();
- }
- // Copyright: Hiroshi Ichikawa <http://gimite.net/en/>
- // License: New BSD License
- // Reference: http://dev.w3.org/html5/websockets/
- // Reference: http://tools.ietf.org/html/draft-hixie-thewebsocketprotocol
- (function () {
- if ('undefined' == typeof window || window.WebSocket) return;
- var console = window.console;
- if (!console || !console.log || !console.error) {
- console = {
- log: function () {
- }, error: function () {
- }
- };
- }
- if (!swfobject.hasFlashPlayerVersion("10.0.0")) {
- console.error("Flash Player >= 10.0.0 is required.");
- return;
- }
- if (location.protocol == "file:") {
- console.error(
- "WARNING: web-socket-js doesn't work in file:///... URL " +
- "unless you set Flash Security Settings properly. " +
- "Open the page via Web server i.e. http://...");
- }
- /**
- * This class represents a faux web socket.
- * @param {string} url
- * @param {array or string} protocols
- * @param {string} proxyHost
- * @param {int} proxyPort
- * @param {string} headers
- */
- WebSocket = function (url, protocols, proxyHost, proxyPort, headers) {
- var self = this;
- self.__id = WebSocket.__nextId++;
- WebSocket.__instances[self.__id] = self;
- self.readyState = WebSocket.CONNECTING;
- self.bufferedAmount = 0;
- self.__events = {};
- if (!protocols) {
- protocols = [];
- } else if (typeof protocols == "string") {
- protocols = [protocols];
- }
- // Uses setTimeout() to make sure __createFlash() runs after the caller sets ws.onopen etc.
- // Otherwise, when onopen fires immediately, onopen is called before it is set.
- setTimeout(function () {
- WebSocket.__addTask(function () {
- WebSocket.__flash.create(
- self.__id, url, protocols, proxyHost || null, proxyPort || 0, headers || null);
- });
- }, 0);
- };
- /**
- * Send data to the web socket.
- * @param {string} data The data to send to the socket.
- * @return {boolean} True for success, false for failure.
- */
- WebSocket.prototype.send = function (data) {
- if (this.readyState == WebSocket.CONNECTING) {
- throw "INVALID_STATE_ERR: Web Socket connection has not been established";
- }
- // We use encodeURIComponent() here, because FABridge doesn't work if
- // the argument includes some characters. We don't use escape() here
- // because of this:
- // https://developer.mozilla.org/en/Core_JavaScript_1.5_Guide/Functions#escape_and_unescape_Functions
- // But it looks decodeURIComponent(encodeURIComponent(s)) doesn't
- // preserve all Unicode characters either e.g. "\uffff" in Firefox.
- // Note by wtritch: Hopefully this will not be necessary using ExternalInterface. Will require
- // additional testing.
- var result = WebSocket.__flash.send(this.__id, encodeURIComponent(data));
- if (result < 0) { // success
- return true;
- } else {
- this.bufferedAmount += result;
- return false;
- }
- };
- /**
- * Close this web socket gracefully.
- */
- WebSocket.prototype.close = function () {
- if (this.readyState == WebSocket.CLOSED || this.readyState == WebSocket.CLOSING) {
- return;
- }
- this.readyState = WebSocket.CLOSING;
- WebSocket.__flash.close(this.__id);
- };
- /**
- * Implementation of {@link <a href="http://www.w3.org/TR/DOM-Level-2-Events/events.html#Events-registration">DOM 2 EventTarget Interface</a>}
- *
- * @param {string} type
- * @param {function} listener
- * @param {boolean} useCapture
- * @return void
- */
- WebSocket.prototype.addEventListener = function (type, listener, useCapture) {
- if (!(type in this.__events)) {
- this.__events[type] = [];
- }
- this.__events[type].push(listener);
- };
- /**
- * Implementation of {@link <a href="http://www.w3.org/TR/DOM-Level-2-Events/events.html#Events-registration">DOM 2 EventTarget Interface</a>}
- *
- * @param {string} type
- * @param {function} listener
- * @param {boolean} useCapture
- * @return void
- */
- WebSocket.prototype.removeEventListener = function (type, listener, useCapture) {
- if (!(type in this.__events)) return;
- var events = this.__events[type];
- for (var i = events.length - 1; i >= 0; --i) {
- if (events[i] === listener) {
- events.splice(i, 1);
- break;
- }
- }
- };
- /**
- * Implementation of {@link <a href="http://www.w3.org/TR/DOM-Level-2-Events/events.html#Events-registration">DOM 2 EventTarget Interface</a>}
- *
- * @param {Event} event
- * @return void
- */
- WebSocket.prototype.dispatchEvent = function (event) {
- var events = this.__events[event.type] || [];
- for (var i = 0; i < events.length; ++i) {
- events[i](event);
- }
- var handler = this["on" + event.type];
- if (handler) handler(event);
- };
- /**
- * Handles an event from Flash.
- * @param {Object} flashEvent
- */
- WebSocket.prototype.__handleEvent = function (flashEvent) {
- if ("readyState" in flashEvent) {
- this.readyState = flashEvent.readyState;
- }
- if ("protocol" in flashEvent) {
- this.protocol = flashEvent.protocol;
- }
- var jsEvent;
- if (flashEvent.type == "open" || flashEvent.type == "error") {
- jsEvent = this.__createSimpleEvent(flashEvent.type);
- } else if (flashEvent.type == "close") {
- // TODO implement jsEvent.wasClean
- jsEvent = this.__createSimpleEvent("close");
- } else if (flashEvent.type == "message") {
- var data = decodeURIComponent(flashEvent.message);
- jsEvent = this.__createMessageEvent("message", data);
- } else {
- throw "unknown event type: " + flashEvent.type;
- }
- this.dispatchEvent(jsEvent);
- };
- WebSocket.prototype.__createSimpleEvent = function (type) {
- if (document.createEvent && window.Event) {
- var event = document.createEvent("Event");
- event.initEvent(type, false, false);
- return event;
- } else {
- return {type: type, bubbles: false, cancelable: false};
- }
- };
- WebSocket.prototype.__createMessageEvent = function (type, data) {
- if (document.createEvent && window.MessageEvent && !window.opera) {
- var event = document.createEvent("MessageEvent");
- event.initMessageEvent("message", false, false, data, null, null, window, null);
- return event;
- } else {
- // IE and Opera, the latter one truncates the data parameter after any 0x00 bytes.
- return {type: type, data: data, bubbles: false, cancelable: false};
- }
- };
- /**
- * Define the WebSocket readyState enumeration.
- */
- WebSocket.CONNECTING = 0;
- WebSocket.OPEN = 1;
- WebSocket.CLOSING = 2;
- WebSocket.CLOSED = 3;
- WebSocket.__flash = null;
- WebSocket.__instances = {};
- WebSocket.__tasks = [];
- WebSocket.__nextId = 0;
- /**
- * Load a new flash security policy file.
- * @param {string} url
- */
- WebSocket.loadFlashPolicyFile = function (url) {
- WebSocket.__addTask(function () {
- WebSocket.__flash.loadManualPolicyFile(url);
- });
- };
- /**
- * Loads WebSocketMain.swf and creates WebSocketMain object in Flash.
- */
- WebSocket.__initialize = function () {
- if (WebSocket.__flash) return;
- if (WebSocket.__swfLocation) {
- // For backword compatibility.
- window.WEB_SOCKET_SWF_LOCATION = WebSocket.__swfLocation;
- }
- if (!window.WEB_SOCKET_SWF_LOCATION) {
- console.error("[WebSocket] set WEB_SOCKET_SWF_LOCATION to location of WebSocketMain.swf");
- return;
- }
- var container = document.createElement("div");
- container.id = "webSocketContainer";
- // Hides Flash box. We cannot use display: none or visibility: hidden because it prevents
- // Flash from loading at least in IE. So we move it out of the screen at (-100, -100).
- // But this even doesn't work with Flash Lite (e.g. in Droid Incredible). So with Flash
- // Lite, we put it at (0, 0). This shows 1x1 box visible at left-top corner but this is
- // the best we can do as far as we know now.
- container.style.position = "absolute";
- if (WebSocket.__isFlashLite()) {
- container.style.left = "0px";
- container.style.top = "0px";
- } else {
- container.style.left = "-100px";
- container.style.top = "-100px";
- }
- var holder = document.createElement("div");
- holder.id = "webSocketFlash";
- container.appendChild(holder);
- document.body.appendChild(container);
- // See this article for hasPriority:
- // http://help.adobe.com/en_US/as3/mobile/WS4bebcd66a74275c36cfb8137124318eebc6-7ffd.html
- swfobject.embedSWF(
- WEB_SOCKET_SWF_LOCATION,
- "webSocketFlash",
- "1" /* width */,
- "1" /* height */,
- "10.0.0" /* SWF version */,
- null,
- null,
- {hasPriority: true, swliveconnect: true, allowScriptAccess: "always"},
- null,
- function (e) {
- if (!e.success) {
- console.error("[WebSocket] swfobject.embedSWF failed");
- }
- });
- };
- /**
- * Called by Flash to notify JS that it's fully loaded and ready
- * for communication.
- */
- WebSocket.__onFlashInitialized = function () {
- // We need to set a timeout here to avoid round-trip calls
- // to flash during the initialization process.
- setTimeout(function () {
- WebSocket.__flash = document.getElementById("webSocketFlash");
- WebSocket.__flash.setCallerUrl(location.href);
- WebSocket.__flash.setDebug(!!window.WEB_SOCKET_DEBUG);
- for (var i = 0; i < WebSocket.__tasks.length; ++i) {
- WebSocket.__tasks[i]();
- }
- WebSocket.__tasks = [];
- }, 0);
- };
- /**
- * Called by Flash to notify WebSockets events are fired.
- */
- WebSocket.__onFlashEvent = function () {
- setTimeout(function () {
- try {
- // Gets events using receiveEvents() instead of getting it from event object
- // of Flash event. This is to make sure to keep message order.
- // It seems sometimes Flash events don't arrive in the same order as they are sent.
- var events = WebSocket.__flash.receiveEvents();
- for (var i = 0; i < events.length; ++i) {
- WebSocket.__instances[events[i].webSocketId].__handleEvent(events[i]);
- }
- } catch (e) {
- console.error(e);
- }
- }, 0);
- return true;
- };
- // Called by Flash.
- WebSocket.__log = function (message) {
- console.log(decodeURIComponent(message));
- };
- // Called by Flash.
- WebSocket.__error = function (message) {
- console.error(decodeURIComponent(message));
- };
- WebSocket.__addTask = function (task) {
- if (WebSocket.__flash) {
- task();
- } else {
- WebSocket.__tasks.push(task);
- }
- };
- /**
- * Test if the browser is running flash lite.
- * @return {boolean} True if flash lite is running, false otherwise.
- */
- WebSocket.__isFlashLite = function () {
- if (!window.navigator || !window.navigator.mimeTypes) {
- return false;
- }
- var mimeType = window.navigator.mimeTypes["application/x-shockwave-flash"];
- if (!mimeType || !mimeType.enabledPlugin || !mimeType.enabledPlugin.filename) {
- return false;
- }
- return mimeType.enabledPlugin.filename.match(/flashlite/i) ? true : false;
- };
- if (!window.WEB_SOCKET_DISABLE_AUTO_INITIALIZATION) {
- if (window.addEventListener) {
- window.addEventListener("load", function () {
- WebSocket.__initialize();
- }, false);
- } else {
- window.attachEvent("onload", function () {
- WebSocket.__initialize();
- });
- }
- }
- })();
- /**
- * socket.io
- * Copyright(c) 2011 LearnBoost <dev@learnboost.com>
- * MIT Licensed
- */
- (function (exports, io, global) {
- /**
- * Expose constructor.
- *
- * @api public
- */
- exports.XHR = XHR;
- /**
- * XHR constructor
- *
- * @costructor
- * @api public
- */
- function XHR(socket) {
- if (!socket) return;
- io.Transport.apply(this, arguments);
- this.sendBuffer = [];
- };
- /**
- * Inherits from Transport.
- */
- io.util.inherit(XHR, io.Transport);
- /**
- * Establish a connection
- *
- * @returns {Transport}
- * @api public
- */
- XHR.prototype.open = function () {
- this.socket.setBuffer(false);
- this.onOpen();
- this.get();
- // we need to make sure the request succeeds since we have no indication
- // whether the request opened or not until it succeeded.
- this.setCloseTimeout();
- return this;
- };
- /**
- * Check if we need to send data to the Socket.IO server, if we have data in our
- * buffer we encode it and forward it to the `post` method.
- *
- * @api private
- */
- XHR.prototype.payload = function (payload) {
- var msgs = [];
- for (var i = 0, l = payload.length; i < l; i++) {
- msgs.push(io.parser.encodePacket(payload[i]));
- }
- this.send(io.parser.encodePayload(msgs));
- };
- /**
- * Send data to the Socket.IO server.
- *
- * @param data The message
- * @returns {Transport}
- * @api public
- */
- XHR.prototype.send = function (data) {
- this.post(data);
- return this;
- };
- /**
- * Posts a encoded message to the Socket.IO server.
- *
- * @param {String} data A encoded message.
- * @api private
- */
- function empty() {
- };
- XHR.prototype.post = function (data) {
- var self = this;
- this.socket.setBuffer(true);
- function stateChange() {
- if (this.readyState == 4) {
- this.onreadystatechange = empty;
- self.posting = false;
- if (this.status == 200) {
- self.socket.setBuffer(false);
- } else {
- self.onClose();
- }
- }
- }
- function onload() {
- this.onload = empty;
- self.socket.setBuffer(false);
- };
- this.sendXHR = this.request('POST');
- if (global.XDomainRequest && this.sendXHR instanceof XDomainRequest) {
- this.sendXHR.onload = this.sendXHR.onerror = onload;
- } else {
- this.sendXHR.onreadystatechange = stateChange;
- }
- this.sendXHR.send(data);
- };
- /**
- * Disconnects the established `XHR` connection.
- *
- * @returns {Transport}
- * @api public
- */
- XHR.prototype.close = function () {
- this.onClose();
- return this;
- };
- /**
- * Generates a configured XHR request
- *
- * @param {String} url The url that needs to be requested.
- * @param {String} method The method the request should use.
- * @returns {XMLHttpRequest}
- * @api private
- */
- XHR.prototype.request = function (method) {
- var req = io.util.request(this.socket.isXDomain())
- , query = io.util.query(this.socket.options.query, 't=' + +new Date);
- req.open(method || 'GET', this.prepareUrl() + query, true);
- if (method == 'POST') {
- try {
- if (req.setRequestHeader) {
- req.setRequestHeader('Content-type', 'text/plain;charset=UTF-8');
- } else {
- // XDomainRequest
- req.contentType = 'text/plain';
- }
- } catch (e) {
- }
- }
- return req;
- };
- /**
- * Returns the scheme to use for the transport URLs.
- *
- * @api private
- */
- XHR.prototype.scheme = function () {
- return this.socket.options.secure ? 'https' : 'http';
- };
- /**
- * Check if the XHR transports are supported
- *
- * @param {Boolean} xdomain Check if we support cross domain requests.
- * @returns {Boolean}
- * @api public
- */
- XHR.check = function (socket, xdomain) {
- try {
- var request = io.util.request(xdomain),
- usesXDomReq = (global.XDomainRequest && request instanceof XDomainRequest),
- socketProtocol = (socket && socket.options && socket.options.secure ? 'https:' : 'http:'),
- isXProtocol = (global.location && socketProtocol != global.location.protocol);
- if (request && !(usesXDomReq && isXProtocol)) {
- return true;
- }
- } catch (e) {
- }
- return false;
- };
- /**
- * Check if the XHR transport supports cross domain requests.
- *
- * @returns {Boolean}
- * @api public
- */
- XHR.xdomainCheck = function (socket) {
- return XHR.check(socket, true);
- };
- })(
- 'undefined' != typeof io ? io.Transport : module.exports
- , 'undefined' != typeof io ? io : module.parent.exports
- , this
- );
- /**
- * socket.io
- * Copyright(c) 2011 LearnBoost <dev@learnboost.com>
- * MIT Licensed
- */
- (function (exports, io) {
- /**
- * Expose constructor.
- */
- exports.htmlfile = HTMLFile;
- /**
- * The HTMLFile transport creates a `forever iframe` based transport
- * for Internet Explorer. Regular forever iframe implementations will
- * continuously trigger the browsers buzy indicators. If the forever iframe
- * is created inside a `htmlfile` these indicators will not be trigged.
- *
- * @constructor
- * @extends {io.Transport.XHR}
- * @api public
- */
- function HTMLFile(socket) {
- io.Transport.XHR.apply(this, arguments);
- };
- /**
- * Inherits from XHR transport.
- */
- io.util.inherit(HTMLFile, io.Transport.XHR);
- /**
- * Transport name
- *
- * @api public
- */
- HTMLFile.prototype.name = 'htmlfile';
- /**
- * Creates a new Ac...eX `htmlfile` with a forever loading iframe
- * that can be used to listen to messages. Inside the generated
- * `htmlfile` a reference will be made to the HTMLFile transport.
- *
- * @api private
- */
- HTMLFile.prototype.get = function () {
- this.doc = new window[(['Active'].concat('Object').join('X'))]('htmlfile');
- this.doc.open();
- this.doc.write('<html></html>');
- this.doc.close();
- this.doc.parentWindow.s = this;
- var iframeC = this.doc.createElement('div');
- iframeC.className = 'socketio';
- this.doc.body.appendChild(iframeC);
- this.iframe = this.doc.createElement('iframe');
- iframeC.appendChild(this.iframe);
- var self = this
- , query = io.util.query(this.socket.options.query, 't=' + +new Date);
- this.iframe.src = this.prepareUrl() + query;
- io.util.on(window, 'unload', function () {
- self.destroy();
- });
- };
- /**
- * The Socket.IO server will write script tags inside the forever
- * iframe, this function will be used as callback for the incoming
- * information.
- *
- * @param {String} data The message
- * @param {document} doc Reference to the context
- * @api private
- */
- HTMLFile.prototype._ = function (data, doc) {
- // unescape all forward slashes. see GH-1251
- data = data.replace(/\\\//g, '/');
- this.onData(data);
- try {
- var script = doc.getElementsByTagName('script')[0];
- script.parentNode.removeChild(script);
- } catch (e) {
- }
- };
- /**
- * Destroy the established connection, iframe and `htmlfile`.
- * And calls the `CollectGarbage` function of Internet Explorer
- * to release the memory.
- *
- * @api private
- */
- HTMLFile.prototype.destroy = function () {
- if (this.iframe) {
- try {
- this.iframe.src = 'about:blank';
- } catch (e) {
- }
- this.doc = null;
- this.iframe.parentNode.removeChild(this.iframe);
- this.iframe = null;
- CollectGarbage();
- }
- };
- /**
- * Disconnects the established connection.
- *
- * @returns {Transport} Chaining.
- * @api public
- */
- HTMLFile.prototype.close = function () {
- this.destroy();
- return io.Transport.XHR.prototype.close.call(this);
- };
- /**
- * Checks if the browser supports this transport. The browser
- * must have an `Ac...eXObject` implementation.
- *
- * @return {Boolean}
- * @api public
- */
- HTMLFile.check = function (socket) {
- if (typeof window != "undefined" && (['Active'].concat('Object').join('X')) in window) {
- try {
- var a = new window[(['Active'].concat('Object').join('X'))]('htmlfile');
- return a && io.Transport.XHR.check(socket);
- } catch (e) {
- }
- }
- return false;
- };
- /**
- * Check if cross domain requests are supported.
- *
- * @returns {Boolean}
- * @api public
- */
- HTMLFile.xdomainCheck = function () {
- // we can probably do handling for sub-domains, we should
- // test that it's cross domain but a subdomain here
- return false;
- };
- /**
- * Add the transport to your public io.transports array.
- *
- * @api private
- */
- io.transports.push('htmlfile');
- })(
- 'undefined' != typeof io ? io.Transport : module.exports
- , 'undefined' != typeof io ? io : module.parent.exports
- );
- /**
- * socket.io
- * Copyright(c) 2011 LearnBoost <dev@learnboost.com>
- * MIT Licensed
- */
- (function (exports, io, global) {
- /**
- * Expose constructor.
- */
- exports['xhr-polling'] = XHRPolling;
- /**
- * The XHR-polling transport uses long polling XHR requests to create a
- * "persistent" connection with the server.
- *
- * @constructor
- * @api public
- */
- function XHRPolling() {
- io.Transport.XHR.apply(this, arguments);
- };
- /**
- * Inherits from XHR transport.
- */
- io.util.inherit(XHRPolling, io.Transport.XHR);
- /**
- * Merge the properties from XHR transport
- */
- io.util.merge(XHRPolling, io.Transport.XHR);
- /**
- * Transport name
- *
- * @api public
- */
- XHRPolling.prototype.name = 'xhr-polling';
- /**
- * Indicates whether heartbeats is enabled for this transport
- *
- * @api private
- */
- XHRPolling.prototype.heartbeats = function () {
- return false;
- };
- /**
- * Establish a connection, for iPhone and Android this will be done once the page
- * is loaded.
- *
- * @returns {Transport} Chaining.
- * @api public
- */
- XHRPolling.prototype.open = function () {
- var self = this;
- io.Transport.XHR.prototype.open.call(self);
- return false;
- };
- /**
- * Starts a XHR request to wait for incoming messages.
- *
- * @api private
- */
- function empty() {
- };
- XHRPolling.prototype.get = function () {
- if (!this.isOpen) return;
- var self = this;
- function stateChange() {
- if (this.readyState == 4) {
- this.onreadystatechange = empty;
- if (this.status == 200) {
- self.onData(this.responseText);
- self.get();
- } else {
- self.onClose();
- }
- }
- };
- function onload() {
- this.onload = empty;
- this.onerror = empty;
- self.retryCounter = 1;
- self.onData(this.responseText);
- self.get();
- };
- function onerror() {
- self.retryCounter++;
- if (!self.retryCounter || self.retryCounter > 3) {
- self.onClose();
- } else {
- self.get();
- }
- };
- this.xhr = this.request();
- if (global.XDomainRequest && this.xhr instanceof XDomainRequest) {
- this.xhr.onload = onload;
- this.xhr.onerror = onerror;
- } else {
- this.xhr.onreadystatechange = stateChange;
- }
- this.xhr.send(null);
- };
- /**
- * Handle the unclean close behavior.
- *
- * @api private
- */
- XHRPolling.prototype.onClose = function () {
- io.Transport.XHR.prototype.onClose.call(this);
- if (this.xhr) {
- this.xhr.onreadystatechange = this.xhr.onload = this.xhr.onerror = empty;
- try {
- this.xhr.abort();
- } catch (e) {
- }
- this.xhr = null;
- }
- };
- /**
- * Webkit based browsers show a infinit spinner when you start a XHR request
- * before the browsers onload event is called so we need to defer opening of
- * the transport until the onload event is called. Wrapping the cb in our
- * defer method solve this.
- *
- * @param {Socket} socket The socket instance that needs a transport
- * @param {Function} fn The callback
- * @api private
- */
- XHRPolling.prototype.ready = function (socket, fn) {
- var self = this;
- io.util.defer(function () {
- fn.call(self);
- });
- };
- /**
- * Add the transport to your public io.transports array.
- *
- * @api private
- */
- io.transports.push('xhr-polling');
- })(
- 'undefined' != typeof io ? io.Transport : module.exports
- , 'undefined' != typeof io ? io : module.parent.exports
- , this
- );
- /**
- * socket.io
- * Copyright(c) 2011 LearnBoost <dev@learnboost.com>
- * MIT Licensed
- */
- (function (exports, io, global) {
- /**
- * There is a way to hide the loading indicator in Firefox. If you create and
- * remove a iframe it will stop showing the current loading indicator.
- * Unfortunately we can't feature detect that and UA sniffing is evil.
- *
- * @api private
- */
- var indicator = global.document && "MozAppearance" in
- global.document.documentElement.style;
- /**
- * Expose constructor.
- */
- exports['jsonp-polling'] = JSONPPolling;
- /**
- * The JSONP transport creates an persistent connection by dynamically
- * inserting a script tag in the page. This script tag will receive the
- * information of the Socket.IO server. When new information is received
- * it creates a new script tag for the new data stream.
- *
- * @constructor
- * @extends {io.Transport.xhr-polling}
- * @api public
- */
- function JSONPPolling(socket) {
- io.Transport['xhr-polling'].apply(this, arguments);
- this.index = io.j.length;
- var self = this;
- io.j.push(function (msg) {
- self._(msg);
- });
- };
- /**
- * Inherits from XHR polling transport.
- */
- io.util.inherit(JSONPPolling, io.Transport['xhr-polling']);
- /**
- * Transport name
- *
- * @api public
- */
- JSONPPolling.prototype.name = 'jsonp-polling';
- /**
- * Posts a encoded message to the Socket.IO server using an iframe.
- * The iframe is used because script tags can create POST based requests.
- * The iframe is positioned outside of the view so the user does not
- * notice it's existence.
- *
- * @param {String} data A encoded message.
- * @api private
- */
- JSONPPolling.prototype.post = function (data) {
- var self = this
- , query = io.util.query(
- this.socket.options.query
- , 't=' + (+new Date) + '&i=' + this.index
- );
- if (!this.form) {
- var form = document.createElement('form')
- , area = document.createElement('textarea')
- , id = this.iframeId = 'socketio_iframe_' + this.index
- , iframe;
- form.className = 'socketio';
- form.style.position = 'absolute';
- form.style.top = '0px';
- form.style.left = '0px';
- form.style.display = 'none';
- form.target = id;
- form.method = 'POST';
- form.setAttribute('accept-charset', 'utf-8');
- area.name = 'd';
- form.appendChild(area);
- document.body.appendChild(form);
- this.form = form;
- this.area = area;
- }
- this.form.action = this.prepareUrl() + query;
- function complete() {
- initIframe();
- self.socket.setBuffer(false);
- };
- function initIframe() {
- if (self.iframe) {
- self.form.removeChild(self.iframe);
- }
- try {
- // ie6 dynamic iframes with target="" support (thanks Chris Lambacher)
- iframe = document.createElement('<iframe name="' + self.iframeId + '">');
- } catch (e) {
- iframe = document.createElement('iframe');
- iframe.name = self.iframeId;
- }
- iframe.id = self.iframeId;
- self.form.appendChild(iframe);
- self.iframe = iframe;
- };
- initIframe();
- // we temporarily stringify until we figure out how to prevent
- // browsers from turning `\n` into `\r\n` in form inputs
- this.area.value = io.JSON.stringify(data);
- try {
- this.form.submit();
- } catch (e) {
- }
- if (this.iframe.attachEvent) {
- iframe.onreadystatechange = function () {
- if (self.iframe.readyState == 'complete') {
- complete();
- }
- };
- } else {
- this.iframe.onload = complete;
- }
- this.socket.setBuffer(true);
- };
- /**
- * Creates a new JSONP poll that can be used to listen
- * for messages from the Socket.IO server.
- *
- * @api private
- */
- JSONPPolling.prototype.get = function () {
- var self = this
- , script = document.createElement('script')
- , query = io.util.query(
- this.socket.options.query
- , 't=' + (+new Date) + '&i=' + this.index
- );
- if (this.script) {
- this.script.parentNode.removeChild(this.script);
- this.script = null;
- }
- script.async = true;
- script.src = this.prepareUrl() + query;
- script.onerror = function () {
- self.onClose();
- };
- var insertAt = document.getElementsByTagName('script')[0];
- insertAt.parentNode.insertBefore(script, insertAt);
- this.script = script;
- if (indicator) {
- setTimeout(function () {
- var iframe = document.createElement('iframe');
- document.body.appendChild(iframe);
- document.body.removeChild(iframe);
- }, 100);
- }
- };
- /**
- * Callback function for the incoming message stream from the Socket.IO server.
- *
- * @param {String} data The message
- * @api private
- */
- JSONPPolling.prototype._ = function (msg) {
- this.onData(msg);
- if (this.isOpen) {
- this.get();
- }
- return this;
- };
- /**
- * The indicator hack only works after onload
- *
- * @param {Socket} socket The socket instance that needs a transport
- * @param {Function} fn The callback
- * @api private
- */
- JSONPPolling.prototype.ready = function (socket, fn) {
- var self = this;
- if (!indicator) return fn.call(this);
- io.util.load(function () {
- fn.call(self);
- });
- };
- /**
- * Checks if browser supports this transport.
- *
- * @return {Boolean}
- * @api public
- */
- JSONPPolling.check = function () {
- return 'document' in global;
- };
- /**
- * Check if cross domain requests are supported
- *
- * @returns {Boolean}
- * @api public
- */
- JSONPPolling.xdomainCheck = function () {
- return true;
- };
- /**
- * Add the transport to your public io.transports array.
- *
- * @api private
- */
- io.transports.push('jsonp-polling');
- })(
- 'undefined' != typeof io ? io.Transport : module.exports
- , 'undefined' != typeof io ? io : module.parent.exports
- , this
- );
- if (typeof define === "function" && define.amd) {
- define([], function () {
- return io;
- });
- }
- })();
|