@@ -29,26 +29,18 @@ var dop = {
2929 protocol : { } ,
3030 transports : { listen :{ } , connect :{ } } ,
3131
32- CONS : {
33- CLOSE : '~CLOSE' ,
34- OPEN : '~OPEN ' ,
35- CONNECTING : '~CONNECTING ' ,
32+ // Constants
33+ cons : {
34+ TOKEN : '~TOKEN_DOP ' ,
35+ DOP : '~DOP ' ,
3636 CONNECT : '~CONNECT' ,
37- RECONNECT : '~RECONNECT ' ,
38- SEND : '~SEND '
37+ SEND : '~SEND ' ,
38+ DISCONNECT : '~DISCONNECT '
3939 }
4040
4141} ;
4242
4343
44- // Special properties assigned to user objects
45- var CONS = {
46- socket_token : '~TOKEN_DOP' ,
47- dop : '~dop'
48- } ;
49-
50-
51-
5244
5345
5446
@@ -174,11 +166,12 @@ function websocket(dop, node, options) {
174166 // Variables
175167 var api = options . transport . getApi ( ) ,
176168 socket = new api ( url ) ,
177- send_queue = [ ] ;
169+ send_queue = [ ] ,
170+ readyState ;
178171
179172 // Helpers
180173 function send ( message ) {
181- ( socket . readyState === socket . constructor . OPEN && node . readyState === dop . CONS . CONNECT ) ?
174+ ( socket . readyState === socket . constructor . OPEN && readyState === CONNECT ) ?
182175 socket . send ( message )
183176 :
184177 send_queue . push ( message ) ;
@@ -191,20 +184,20 @@ function websocket(dop, node, options) {
191184 // Socket events
192185 function onopen ( ) {
193186 // Reconnect
194- if ( node . readyState === dop . CONS . CONNECTING )
187+ if ( readyState === CONNECTING )
195188 socket . send ( node . tokenServer ) ;
196189 // Connect
197190 else {
198191 socket . send ( '' ) ; // Empty means we want to get connected
199- node . readyState = dop . CONS . OPEN ;
192+ readyState = OPEN ;
200193 }
201194 dop . core . emitOpen ( node , socket , options . transport ) ;
202195 }
203196 function onmessage ( message ) {
204197 // console.log( 'C<<: `'+message.data+'`' );
205198 // Reconnecting
206- if ( node . readyState === dop . CONS . CONNECTING && message . data === node . tokenServer ) {
207- node . readyState = dop . CONS . CONNECT ;
199+ if ( readyState === CONNECTING && message . data === node . tokenServer ) {
200+ readyState = CONNECT ;
208201 dop . core . setSocketToNode ( node , socket ) ;
209202 dop . core . emitReconnect ( node , oldSocket ) ;
210203 sendQueue ( ) ;
@@ -213,43 +206,43 @@ function websocket(dop, node, options) {
213206 dop . core . emitMessage ( node , message . data , message ) ;
214207 }
215208 function onclose ( ) {
216- node . readyState = dop . CONS . CLOSE ;
209+ readyState = CLOSE ;
217210 dop . core . emitClose ( node , socket ) ;
218211 }
219212
220213 // dop events
221214 function onconnect ( message_response ) {
222- if ( node . readyState === dop . CONS . CONNECTING ) {
215+ if ( readyState === CONNECTING ) {
223216 dop . core . emitDisconnect ( node ) ;
224217 dop . core . setSocketToNode ( node , socket ) ;
225218 }
226219 socket . send ( message_response ) ;
227- node . readyState = dop . CONS . CONNECT ;
220+ readyState = CONNECT ;
228221 dop . core . emitConnect ( node ) ;
229222 sendQueue ( ) ;
230223 }
231224 function ondisconnect ( ) {
232- node . readyState = dop . CONS . CLOSE ;
225+ readyState = CLOSE ;
233226 socket . close ( ) ;
234227 }
235228
236229 function reconnect ( ) {
237- if ( node . readyState !== dop . CONS . CONNECT ) {
230+ if ( readyState !== CONNECT ) {
238231 oldSocket = socket ;
239232 socket = new api ( url ) ;
240- node . readyState = dop . CONS . CONNECTING ;
233+ readyState = CONNECTING ;
241234 addListeners ( socket , onopen , onmessage , onclose ) ;
242235 removeListeners ( oldSocket , onopen , onmessage , onclose ) ;
243236 }
244237 }
245238
246239 // Setting up
247240 dop . core . setSocketToNode ( node , socket ) ;
248- node . readyState = dop . CONS . CLOSE ;
241+ readyState = CLOSE ;
249242 node . reconnect = reconnect ;
250- node . on ( dop . CONS . CONNECT , onconnect ) ;
251- node . on ( dop . CONS . SEND , send ) ;
252- node . on ( dop . CONS . DISCONNECT , ondisconnect ) ;
243+ node . on ( dop . cons . CONNECT , onconnect ) ;
244+ node . on ( dop . cons . SEND , send ) ;
245+ node . on ( dop . cons . DISCONNECT , ondisconnect ) ;
253246 addListeners ( socket , onopen , onmessage , onclose ) ;
254247
255248 return socket ;
@@ -278,6 +271,13 @@ else {
278271 root . dopTransportsConnectWebsocket = websocket ;
279272}
280273
274+ // Cons
275+ var CLOSE = 0 ,
276+ OPEN = 1 ,
277+ CONNECTING = 2 ,
278+ CONNECT = 3 ;
279+
280+
281281} ) ( this ) ;
282282
283283
@@ -687,7 +687,7 @@ dop.getAction = function(mutations) {
687687////////// src/api/getNodeBySocket.js
688688
689689dop . getNodeBySocket = function ( socket ) {
690- return dop . data . node [ socket [ CONS . socket_token ] ] ;
690+ return dop . data . node [ socket [ dop . cons . TOKEN ] ] ;
691691} ;
692692
693693
@@ -696,7 +696,7 @@ dop.getNodeBySocket = function(socket) {
696696////////// src/api/getObject.js
697697
698698dop . getObjectDop = function ( object ) {
699- return object [ CONS . dop ] ;
699+ return object [ dop . cons . DOP ] ;
700700} ;
701701
702702dop . getObjectId = function ( object ) {
@@ -897,9 +897,9 @@ dop.core.setAction = function(destiny, prop, value, typeofValue, path) {
897897 var typeofDestiny = dop . util . typeof ( destiny [ prop ] ) ;
898898
899899 // Array mutations
900- if ( typeofValue == 'object' && value . hasOwnProperty ( CONS . dop ) ) {
900+ if ( typeofValue == 'object' && value . hasOwnProperty ( dop . cons . DOP ) ) {
901901
902- var mutations = value [ CONS . dop ] ,
902+ var mutations = value [ dop . cons . DOP ] ,
903903 mutation ,
904904 index = 0 ,
905905 total = mutations . length ;
@@ -969,7 +969,7 @@ dop.core.setAction = function(destiny, prop, value, typeofValue, path) {
969969 // }
970970} ;
971971// dop.core.setActionLoop = function() {
972- // if (prop === CONS. dop)
972+ // if (prop === dop.cons.DOP )
973973// return true;
974974// };
975975
@@ -1166,10 +1166,10 @@ dop.core.emitMessage = function(node, message_string, message_raw) {
11661166
11671167
11681168 // var messages,
1169- // user = (socket[CONS.socket_token ] === undefined) ?
1169+ // user = (socket[dop.cons.TOKEN ] === undefined) ?
11701170 // socket
11711171 // :
1172- // node.users[ socket[CONS.socket_token ] ];
1172+ // node.users[ socket[dop.cons.TOKEN ] ];
11731173
11741174
11751175
@@ -1329,11 +1329,11 @@ dop.core.node = function() {
13291329
13301330
13311331dop . core . node . prototype . send = function ( message ) {
1332- this . emit ( dop . CONS . SEND , message ) ;
1332+ this . emit ( dop . cons . SEND , message ) ;
13331333} ;
13341334
13351335dop . core . node . prototype . disconnect = function ( ) {
1336- this . emit ( dop . CONS . DISCONNECT ) ;
1336+ this . emit ( dop . cons . DISCONNECT ) ;
13371337} ;
13381338
13391339dop . core . node . prototype . subscribe = function ( ) {
@@ -1809,8 +1809,8 @@ dop.core.configureObject = function(object, path, parent) {
18091809 object [ property ] = dop . core . configureObject ( value , path . concat ( property ) , object ) ;
18101810 }
18111811
1812- // Setting ~dop object
1813- Object . defineProperty ( object , CONS . dop , { value :path . slice ( 0 ) } ) ;
1812+ // Setting ~DOP object
1813+ Object . defineProperty ( object , dop . cons . DOP , { value :path . slice ( 0 ) } ) ;
18141814 object_dop = dop . getObjectDop ( object ) ;
18151815 object_dop . m = [ ] ; // mutations
18161816 object_dop . o = [ ] ; // observers
@@ -2012,10 +2012,10 @@ dop.core.injectMutationInAction = function(action, mutation, isUnaction) {
20122012 if ( isMutationArray )
20132013 action = action [ prop ] ;
20142014
2015- if ( ! isObject ( action [ CONS . dop ] ) )
2016- action [ CONS . dop ] = [ ] ;
2015+ if ( ! isObject ( action [ dop . cons . DOP ] ) )
2016+ action [ dop . cons . DOP ] = [ ] ;
20172017
2018- var mutations = action [ CONS . dop ] ;
2018+ var mutations = action [ dop . cons . DOP ] ;
20192019
20202020 // swap
20212021 if ( mutation . swaps !== undefined ) {
@@ -2437,7 +2437,7 @@ dop.core.remoteFunction = function $DOP_REMOTE_function(object, property) {
24372437
24382438dop . core . setSocketToNode = function ( node , socket ) {
24392439 node . socket = socket ;
2440- socket [ CONS . socket_token ] = node . token ;
2440+ socket [ dop . cons . TOKEN ] = node . token ;
24412441} ;
24422442
24432443
@@ -2476,7 +2476,7 @@ dop.protocol._onconnect = function(node, request_id, request, response) {
24762476
24772477 // Node is connected correctly
24782478 if ( response [ 0 ] === 0 )
2479- node . emit ( dop . CONS . CONNECT , request , response ) ;
2479+ node . emit ( dop . cons . CONNECT , request , response ) ;
24802480
24812481
24822482 // We must manage the rejection
@@ -2613,7 +2613,7 @@ dop.protocol.onconnect = function(node, request_id, request) {
26132613 var tokenServer = request [ 1 ] ,
26142614 response = dop . core . createResponse ( request_id , 0 ) ;
26152615 node . tokenServer = tokenServer ;
2616- node . emit ( dop . CONS . CONNECT , JSON . stringify ( response ) ) ;
2616+ node . emit ( dop . cons . CONNECT , JSON . stringify ( response ) ) ;
26172617} ;
26182618
26192619
0 commit comments