pub/ImplabJs: src/implab/messaging/Client.js comparison

comparison src/implab/messaging/Client.js @ 0:fc2517695ee1

Initial commit, draft import of existing work

author	cin
date	Thu, 01 Jun 2017 13:20:03 +0300
parents
children	7d7059d2a810

comparison

equal deleted inserted replaced

--1:000000000000
+:fc2517695ee1
+define(
+[ "dojo/_base/declare", "dojo/_base/lang", "dojo/Evented", "../_LogMixin" ],
+function(declare, lang, Evented, _LogMixin) {
+return declare([ Evented, _LogMixin ], {
+_session : null,
+_destination : null,
+_id : null,
+constructor : function(session, destination, options) {
+this._destination = destination;
+this._session = session;
+},
+getDestination : function() {
+return this._destination;
+},
+start : function() {
+var me = this;
+return me._session.createClient(me.prepareOptions({})).then(
+function(id) {
+me._id = id;
+return me;
+});
+},
+prepareOptions : function(options) {
+var me = this;
+options.mode = me.getMode();
+options.destination = me.getDestination();
+options.client = function(msg) {
+me.process(msg);
+};
+return options;
+},
+process : function(msg) {
+this.warn("Messages are not acceped by this client");
+},
+stop : function() {
+var me = this;
+if (me._id) {
+me.log("stop");
+return me._session.deleteClient({'clientId': me._id}).then(function() {
+me._id = null;
+return me;
+});
+}
+},
+toString : function() {
+return "["
++ [
+this.getMode().toUpperCase(),
+this.getDestination(),
+this._id ].join(',') + "]";
+}
+});
+});