betajs/betajs-server

Scoped.define("module:Sessions.RMIHelper", [      
         "base:Class",
         "base:Channels.ReadySender",
         "base:Net.SocketSenderChannel",
         "base:Net.SocketReceiverChannel",
         "base:RMI.Peer"
     ], function (Class, ReadySender, SocketSenderChannel, SocketReceiverChannel, Peer, scoped) {
     return Class.extend({scoped: scoped}, function (inherited) {
         return {
        
            constructor: function (active_session) {
                inherited.constructor.call(this);
                this.__active_session = active_session;
                active_session.rmi = this;
                this.__rmi_socket_sender = new SocketSenderChannel(null, "rmi");
                this.__rmi_sender = new ReadySender(this.__rmi_socket_sender);
                this.__rmi_receiver = new SocketReceiverChannel(null, "rmi");
                this.__rmi_peer = new Peer(this.__rmi_sender, this.__rmi_receiver);
                active_session.rmi_peer = this.__rmi_peer;
                this.stubs = {};
                this.skeletons = {};
                active_session.stubs = this.stubs;
                active_session.skeletons = this.skeletons;
                active_session.on("bind_socket", function (socket) {
                    this.__rmi_receiver.socket(socket);
                    this.__rmi_socket_sender.socket(socket);
                    this.__rmi_sender.ready();
                }, this);
                active_session.on("unbind_socket", function () {
                    this.__rmi_sender.unready();
                }, this);
                if ("initialize_rmi" in active_session)
                    active_session.initialize_rmi();
            },
            
            destroy: function () {
                for (var key in this.stubs)
                    this.stubs[key].destroy();
                for (key in this.skeletons)
                    this.skeletons[key].destroy();
                this.__rmi_peer.destroy();
                this.__rmi_receiver.destroy();
                this.__rmi_sender.destroy();
                inherited.destroy.call(this);
            }

         };
     });
});


Scoped.define("module:Sessions.RMIManagerHelper", [      
        "base:Class",
        "module:Sessions.RMIHelper"
    ], function (Class, RMIHelper, scoped) {
    return Class.extend({scoped: scoped}, {
        
        __add_active_session: function (session, active_session) {
            active_session.addHelper(RMIHelper);
        }
    
    });
});