sockit/MessageEngine.js at master · frenkie/sockit · GitHub

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
var debug = require('debug')('message-engine');

/**
 * @param {Socket.io} socket
 * @param {Object} messages Hash of message name/object pairs to handle
 */
var MessageEngine = function ( socket, messages ) {

    this.socket = socket;
    this.messages = messages;

    this.prepareArgumentHandlers();
    this.bindSocketHandlers();
};

MessageEngine.prototype = {

    bindSocketHandlers: function () {

        var engine = this;

        this.socket.on('connection', function ( client ) {

            for ( message in engine.messages ) {
                if ( engine.messages.hasOwnProperty( message ) ) {
                    (function ( messageName ) {
                        client.on( messageName, function ( data ) {
                            engine.handleMessage( client, messageName, data );
                        } );
                    })( message );
                }
            }
        });
    },

    handleMessage: function ( client, name, args ) {

        var messageObject = this.messages[ name ];

        args = args || [];

        if ( messageObject ) {

            if ( messageObject.handleArguments && typeof messageObject.handleArguments === 'function' ) {
                debug('handling arguments of '+ name, args );
                args = messageObject.handleArguments.apply( messageObject.handleArguments, args );
            }

            if ( args && args.length !== 0 ) {
                debug('sending '+ name, args );
                debug( typeof args );
                this.socket.emit( name, args );
            } else {
                debug('sending '+ name );
                this.socket.emit( name );
            }
        }
    },

    /**
     * Evals the message's function definitions to real functions
     */
    prepareArgumentHandlers: function () {

        for ( message in this.messages ) {
            if ( this.messages.hasOwnProperty( message ) ) {

                var message = this.messages[ message ];
                if ( message.handleArguments ) {
                    message.handleArguments = eval( message.handleArguments );
                }
            }
        }
    }
};

module.exports = MessageEngine;