serviceManager.js
2.44 KB
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
78
79
80
81
82
83
84
85
86
87
88
89
90
// Generated by CoffeeScript 1.8.0
var ServiceManager, Services, fs, getMethodProxy, getServiceInterface, path, utils, _,
__slice = [].slice;
path = require('path');
fs = require('fs');
_ = require('underscore');
utils = require('./utils');
Services = {};
utils.registerClass(ServiceManager = (function() {
function ServiceManager() {
this.services = {};
}
ServiceManager.prototype.get = function(name) {
if (_.has(this.services, name)) {
return this.services[name];
}
return null;
};
ServiceManager.prototype.registerLocalClass = function(name) {
var e, serviceClass;
serviceClass = null;
try {
serviceClass = require("./service/" + name);
} catch (_error) {
e = _error;
utils.log("local service class not found: " + name);
throw e;
}
return this.services[name] = new serviceClass;
};
ServiceManager.prototype.registerProxyClass = function(name) {
var intf, method, service, _i, _len, _ref;
intf = getServiceInterface(name);
if (!intf) {
utils.exit("proxy service class not found: " + name);
}
if (intf.name !== name) {
utils.exit("proxy interface '" + intf.name + "' loaded when '" + name + "' requested");
}
service = {};
_ref = intf.methods;
for (_i = 0, _len = _ref.length; _i < _len; _i++) {
method = _ref[_i];
service[method.name] = getMethodProxy(name, method.name);
}
return this.services[name] = service;
};
return ServiceManager;
})());
getMethodProxy = function(intfName, methodName) {
return function() {
var args, channel, channels, _i, _len, _results;
channels = arguments[0], args = 2 <= arguments.length ? __slice.call(arguments, 1) : [];
if (!_.isArray(channels)) {
channels = [channels];
}
_results = [];
for (_i = 0, _len = channels.length; _i < _len; _i++) {
channel = channels[_i];
_results.push(channel.sendMessage.apply(channel, [intfName, methodName].concat(__slice.call(args))));
}
return _results;
};
};
getServiceInterface = function(name) {
var contents, fileName, jsonName, serviceInterface;
jsonName = "" + name + ".json";
fileName = path.join(utils.options.staticWebDir, 'interfaces', jsonName);
if (!utils.fileExistsSync(fileName)) {
return null;
}
contents = fs.readFileSync(fileName, 'utf8');
serviceInterface = JSON.parse(contents);
return serviceInterface.interfaces[0];
};
module.exports = new ServiceManager;