1 | "use strict";
|
2 | Object.defineProperty(exports, "__esModule", { value: true });
|
3 | const Socket = require("socket.io-client");
|
4 | const logger = require("@nodeswork/logger");
|
5 | const sbase = require("@nodeswork/sbase");
|
6 | const def_1 = require("./def");
|
7 | const errors = require("./errors");
|
8 | const LOG = logger.getLogger();
|
9 | function connectSocket(nodesworkServer, token, appletManager) {
|
10 | const url = `${nodesworkServer}/device`;
|
11 | const socket = Socket(url, { query: `token=${token}` });
|
12 | LOG.info('Connecting to socket server', { url });
|
13 | sbase.socket.socketRpcHost(socket, appletManager, def_1.nam.socketRpcEventNamePrefix);
|
14 | socket
|
15 | .on('connect', () => {
|
16 | LOG.info('Device socket is connected.');
|
17 | })
|
18 | .on('error', (msg) => {
|
19 | switch (msg) {
|
20 | case 'token is invalid':
|
21 | throw errors.UNAUTHENTICATED_ERROR;
|
22 | default:
|
23 | LOG.error('Socket connection error', msg);
|
24 | }
|
25 | })
|
26 | .on('connect_failed', () => {
|
27 | LOG.error('Device socket connects failed');
|
28 | })
|
29 | .on('connect_error', () => {
|
30 |
|
31 | LOG.error('Device socket connection lost');
|
32 | })
|
33 | .on('disconnect', function () {
|
34 | LOG.error('Device socket disconnected', arguments);
|
35 | });
|
36 | }
|
37 | exports.connectSocket = connectSocket;
|
38 |
|
39 |
|