123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478479480481482483484485486487488489490491492493494495496497498499 |
- "use strict";
- // reflector.js
- //
- var parseurl = require( './parse-url' ),
- persistence = require( './persistence' ),
- helpers = require( './helpers' ),
- fs = require( 'fs' );
- function parseSocketUrl( socket ) {
- try
- {
- var query = require('url')
- .parse(socket.handshake.url)
- .query;
- var referer = require('querystring')
- .parse(query)
- .pathname;
- var resObj = require('querystring')
- .parse(query)
- .path;
- var namespace = referer;
- if(!namespace) return null;
- if (namespace[namespace.length - 1] != "/")
- namespace += "/";
- let parsedPath = JSON.parse(resObj);
-
- if (parsedPath) {
- return parsedPath
- }
- // else {
- // return parseurl.Process(namespace);
- // }
-
- }
- catch (e)
- {
- return null;
- }
- }
- function GetLoadForSocket( processedURL ) {
- if ( processedURL[ 'private_path' ] ) {
- return persistence.GetLoadInformation( processedURL );
- }
- return { 'save_name': undefined, 'save_revision': undefined, 'explicit_revision': undefined, 'application_path': undefined };
- }
- //Get the instance ID from the handshake headers for a socket
- function GetNamespace( processedURL ) {
- if ( ( processedURL[ 'instance' ] ) && ( processedURL[ 'public_path' ] ) ) {
- return helpers.JoinPath( processedURL[ 'public_path' ], processedURL[ 'application' ], processedURL[ 'instance' ] );
- }
- return undefined;
- }
- function GetNow( ) {
- return new Date( ).getTime( ) / 1000.0;
- }
- function OnConnection( socket ) {
- let resObj = parseSocketUrl( socket );
-
- if (resObj == null) {
- setInterval(function() {
- var address = socket.conn.request.headers.host;
- var obj = {};
- for (var prop in global.instances) {
- obj[prop] = {
- "instance":address + prop,
- "clients": Object.keys(global.instances[prop].clients).length
- };
- }
- var json = JSON.stringify(obj);
- socket.emit('getWebAppUpdate', json);
- }, 3000);
- // socket.on('getWebAppUpdate', function(msg){
-
- // });
- return
- }
- let processedURL = resObj.path;
- //get instance for new connection
- var namespace = GetNamespace( processedURL );
- if ( namespace == undefined ) {
- return;
- }
- //prepare for persistence request in case that's what this is
- var loadInfo = resObj.loadInfo //GetLoadForSocket( processedURL );
- var saveObject = resObj.saveObject //persistence.LoadSaveObject( loadInfo );
-
- //if it's a new instance, setup record
- if( !global.instances[ namespace ] ) {
- global.instances[ namespace ] = { };
- global.instances[ namespace ].clients = { };
- global.instances[ namespace ].pendingList = [ ];
- global.instances[ namespace ].start_time = undefined;
- global.instances[ namespace ].pause_time = undefined;
- global.instances[ namespace ].rate = 1.0;
- global.instances[ namespace ].setTime = function( time ) {
- this.start_time = GetNow( ) - time;
- this.pause_time = undefined;
- this.rate = 1.0;
- };
- global.instances[ namespace ].isPlaying = function( ) {
- if ( ( this.start_time != undefined ) && ( this.pause_time == undefined ) ) {
- return true;
- }
- return false
- };
- global.instances[ namespace ].isPaused = function( ) {
- if ( ( this.start_time != undefined ) && ( this.pause_time != undefined ) ) {
- return true;
- }
- return false
- };
- global.instances[ namespace ].isStopped = function( ) {
- if ( this.start_time == undefined ) {
- return true;
- }
- return false;
- };
- global.instances[ namespace ].getTime = function( ) {
- if ( this.isPlaying( ) ) {
- return ( GetNow( ) - this.start_time ) * this.rate;
- } else if ( this.isPaused( ) ) {
- return ( this.pause_time - this.start_time ) * this.rate;
- }
- else {
- return 0.0;
- }
- };
- global.instances[ namespace ].play = function( ) {
- if ( this.isStopped( ) ) {
- this.start_time = GetNow( );
- this.pause_time = undefined;
- } else if ( this.isPaused( ) ) {
- this.start_time = this.start_time + ( GetNow( ) - this.pause_time );
- this.pause_time = undefined;
- }
- };
- global.instances[ namespace ].pause = function( ) {
- if ( this.isPlaying( ) ) {
- this.pause_time = GetNow( );
- }
- };
- global.instances[ namespace ].stop = function( ) {
- if ( ( this.isPlaying( ) ) || ( this.isPaused( ) ) ) {
- this.start_time = undefined;
- this.pause_time = undefined;
- }
- };
- global.instances[ namespace ].setTime( 0.0 );
- if ( saveObject ) {
- if ( saveObject[ "queue" ] ) {
- if ( saveObject[ "queue" ][ "time" ] ) {
- global.instances[ namespace ].setTime( saveObject[ "queue" ][ "time" ] );
- }
- }
- }
-
- global.instances[ namespace ].state = { };
-
- var log;
- function generateLogFile() {
- try {
- if ( !fs.existsSync( './/log/' ) ) {
- fs.mkdir( './/log/', function ( err ) {
- if ( err ) {
- console.log ( err );
- }
- })
- }
- log = fs.createWriteStream( './/log/' + namespace.replace( /[\\\/]/g, '_' ), { 'flags': 'a' } );
- } catch( err ) {
- console.log( 'Error generating Node Server Log File\n');
- }
- }
- global.instances[ namespace ].Log = function ( message, level ) {
- if( global.logLevel >= level ) {
- if ( !log ) {
- generateLogFile();
- }
- log.write( message + '\n' );
- global.log( message + '\n' );
- }
- };
-
- global.instances[ namespace ].Error = function ( message, level ) {
- var red, brown, reset;
- red = '\u001b[31m';
- brown = '\u001b[33m';
- reset = '\u001b[0m';
- if ( global.logLevel >= level ) {
- if ( !log ) {
- generateLogFile();
- }
- log.write( message + '\n' );
- global.log( red + message + reset + '\n' );
- }
- };
- //keep track of the timer for this instance
- global.instances[ namespace ].timerID = setInterval( function ( ) {
- var message = { parameters: [ ], time: global.instances[ namespace ].getTime( ) };
- for ( var i in global.instances[ namespace ].clients ) {
- var client = global.instances[ namespace ].clients[ i ];
- if ( ! client.pending ) {
- client.emit( 'message', message );
- }
- }
- if(global.instances[ namespace ]){
- if ( global.instances[ namespace ].pendingList.pending ) {
- global.instances[ namespace ].pendingList.push( message );
- }
- }
- }, 50 );
- }
- //add the new client to the instance data
- global.instances[ namespace ].clients[ socket.id ] = socket;
- socket.pending = true;
- //Get the descriptor for the `clients.vwf` child.
- var clientDescriptor = GetClientDescriptor( socket );
-
- // The time for the setState message should be the time the new client joins, so save that time
- var setStateTime = global.instances[ namespace ].getTime( );
-
- // If this client is the first, it can just load the application, and mark it not pending
- if ( Object.keys( global.instances[ namespace ].clients ).length === 1 ) {
-
- if ( saveObject ) {
- socket.emit( 'message', {
- action: "setState",
- parameters: [ saveObject ],
- time: global.instances[ namespace ].getTime( )
- } );
- }
- else {
- var instance = namespace;
- //Get the state and load it.
- //Now the server has a rough idea of what the simulation is
-
- socket.emit( 'message', {
- action: "createNode",
- parameters: [ "http://vwf.example.com/clients.vwf" ],
- time: global.instances[ namespace ].getTime( )
- } );
-
- socket.emit( 'message', {
- action: "createNode",
- parameters: [
- ( processedURL.public_path === "/" ? "" : processedURL.public_path ) + "/" + processedURL.application,
- "application"
- ],
- time: global.instances[ namespace ].getTime( )
- } );
- }
-
- socket.pending = false;
-
- //xapi.logClient( saveObject, loadInfo[ 'application_path' ], loadInfo[ 'save_name' ], namespace, clientDescriptor.properties || {}, true, true );
- }
- else { //this client is not the first, we need to get the state and mark it pending
- if ( ! global.instances[ namespace ].pendingList.pending ) {
- var firstclient = Object.keys( global.instances[ namespace ].clients )[ 0 ];
- firstclient = global.instances[ namespace ].clients[ firstclient ];
- firstclient.emit( 'message', {
- action: "getState",
- respond: true,
- time: global.instances[ namespace ].getTime( )
- } );
- global.instances[ namespace ].Log( 'GetState from Client', 2 );
- global.instances[ namespace ].pendingList.pending = true;
- }
- socket.pending = true;
-
- }
-
- //Create a child in the application's 'clients.vwf' global to represent this client.
- var clientNodeMessage = {
- action: "createChild",
- parameters: [ "http://vwf.example.com/clients.vwf", socket.id, clientDescriptor ],
- time: global.instances[ namespace ].getTime( )
- };
-
- // Send messages to all the existing clients (that are not pending),
- // telling them to create a new node under the "clients" parent for the new client
- for ( var i in global.instances[ namespace ].clients ) {
- var client = global.instances[ namespace ].clients[ i ];
- if ( !client.pending ) {
- client.emit ( 'message', clientNodeMessage );
- }
- }
- if ( global.instances[ namespace ].pendingList.pending ) {
- global.instances[ namespace ].pendingList.push( clientNodeMessage );
- }
- socket.on( 'message', function ( msg ) {
-
- //need to add the client identifier to all outgoing messages
- try {
- var message = JSON.parse( msg );
- }
- catch ( e ) {
- console.error( "Error on socket message: ", e );
- return;
- }
-
- message.client = socket.id;
- message.time = global.instances[ namespace ].getTime( );
-
- if ( message.result === undefined ) {
-
- //distribute message to all clients on given instance
- for ( var i in global.instances[ namespace ].clients ) {
- var client = global.instances[ namespace ].clients[ i ];
-
- //just a regular message, so push if the client is pending a load, otherwise just send it.
- if ( ! client.pending ) {
- client.emit( 'message', message );
- }
- }
-
- if (global.instances[ namespace ]) {
- if ( global.instances[ namespace ].pendingList.pending ) {
- global.instances[ namespace ].pendingList.push( message );
- }
- }
- } else if ( message.action == "getState" ) {
-
- //distribute message to all clients on given instance
- for ( var i in global.instances[ namespace ].clients ) {
- var client = global.instances[ namespace ].clients[ i ];
-
- //if the message was get state, then fire all the pending messages after firing the setState
- if ( client.pending ) {
- global.instances[ namespace ].Log( 'Got State', 2 );
- var state = message.result;
- global.instances[ namespace ].Log( state, 2 );
- client.emit( 'message', { action: "setState", parameters: [ state ], time: setStateTime } );
- client.pending = false;
- for ( var j = 0; j < global.instances[ namespace ].pendingList.length; j++ ) {
- client.emit( 'message', global.instances[ namespace ].pendingList[ j ] );
- }
- //xapi.logClient( state, undefined, undefined, namespace, GetClientDescriptor( client ).properties || {}, true, false );
- }
- }
-
- global.instances[ namespace ].pendingList = [ ];
-
- } else if ( message.action === "execute" ) {
-
- var evaluation = socket.pendingEvaluations && socket.pendingEvaluations.shift();
-
- if ( evaluation ) {
- evaluation.resolve( message.result );
- clearTimeout( evaluation.timeout );
- }
-
- }
-
- } );
- // When a client disconnects, go ahead and remove the instance data
- socket.on( 'disconnect', function ( ) {
-
- // Remove the disconnecting client
- var leavingClient = global.instances[ namespace ].clients[ socket.id ];
- global.instances[ namespace ].clients[ socket.id ] = null;
- delete global.instances[ namespace ].clients[ socket.id ];
- if ( leavingClient.pendingEvaluations ) {
- leavingClient.pendingEvaluations.forEach( function( evaluation ) {
- evaluation.reject( new Error( "connection closed" ) );
- clearTimeout( evaluation.timeout );
- } );
- }
- // Notify others of the disconnecting client. Delete the child representing this client in the application's `clients.vwf` global.
- var clientMessage = { action: "deleteChild", parameters: [ "http://vwf.example.com/clients.vwf", socket.id ], time: global.instances[ namespace ].getTime( ) };
- for ( var i in global.instances[ namespace ].clients ) {
- var client = global.instances[ namespace ].clients[ i ];
- if ( ! client.pending ) {
- client.emit ( 'message', clientMessage );
- }
- }
- if ( global.instances[ namespace ].pendingList.pending ) {
- global.instances[ namespace ].pendingList.push( clientMessage );
- }
-
- // If it's the last client, delete the data and the timer
- if ( Object.keys( global.instances[ namespace ].clients ).length == 0 ) {
- clearInterval( global.instances[ namespace ].timerID );
- delete global.instances[ namespace ];
- // xapi.logClient( undefined, loadInfo[ 'application_path' ], loadInfo[ 'save_name' ], namespace, clientDescriptor.properties || {}, false, true );
- } else {
- // xapi.logClient( undefined, loadInfo[ 'application_path' ], loadInfo[ 'save_name' ], namespace, clientDescriptor.properties || {}, false, false );
- }
- } );
- }
- function Evaluate( namespace, node, expression ) {
- return new Promise( function( resolve, reject ) {
- var firstClientID = Object.keys( global.instances[ namespace ].clients )[ 0 ];
- var firstClient = global.instances[ namespace ].clients[ firstClientID ];
- if ( firstClient ) {
- firstClient.pendingEvaluations = firstClient.pendingEvaluations || [];
- firstClient.pendingEvaluations.push( {
- resolve: resolve,
- reject: reject,
- timeout: setTimeout( function() { reject( new Error( "timeout" ) ) }, 1000 ),
- } );
- firstClient.emit( "message", { node: node, action: "execute", parameters: [ expression ], respond: true, time: global.instances[ namespace ].getTime() } );
- } else {
- reject( new Error( "no clients are connected" ) );
- }
- } );
- }
- /// Get a descriptor for the `clients.vwf` child for a new client. An authenticator may set a
- /// descriptor in the session at `session.vwf.client`. If the authenticator doesn't provide a
- /// descriptor, use an empty node inheriting from `client.vwf`.
- function GetClientDescriptor( socket ) {
- // socket.io doesn't provide access to the request and the session, but we do have the cookies.
- // Create a mock request and run it through the session middleware to recreate the session. This
- // creates a session object at `mockRequest.session`.
- var mockRequest = {
- headers: { cookie: socket.handshake.headers.cookie },
- connection: {},
- session: {},
- };
- var mockResponse = {
- getHeader: function() {},
- setHeader: function() {},
- };
- sessionStack.forEach( function( middleware ) {
- middleware( mockRequest, mockResponse, function() {} );
- } );
- // Get the descriptor from `vwf.client` in the session.
- var descriptor = ( mockRequest.session.vwf || {} ).client || {};
- // Set the default prototype.
- if ( ! descriptor.extends ) {
- descriptor.extends = "http://vwf.example.com/client.vwf";
- }
- return descriptor;
- }
- /// Middleware stack to parse a cookie session from `req.headers.cookie` into `req.session`.
- var sessionStack = [
- //cookieParser(),
- //cookieSession( { secret: config.get( 'session.secret' ) } ),
- ];
- function GetInstances() {
- return global.instances;
- }
- exports.OnConnection = OnConnection;
- exports.Evaluate = Evaluate;
- exports.GetInstances = GetInstances;
|