all files / lib/routers/ mountStreamers.spec.js

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
 
 
1×
 
1×
 
1×
 
 
 
 
1×
 
 
 
 
 
 
1×
1×
 
1×
1×
1×
 
 
 
 
 
 
1×
 
 
1×
1×
1×
1×
 
 
 
1×
 
 
1×
 
 
 
 
1×
1×
1×
 
 
 
 
 
 
 
 
 
 
 
1×
 
 
'use strict';
 
var _DataAPI = require('../DataAPI');
 
var _DataAPI2 = _interopRequireDefault(_DataAPI);
 
function _interopRequireDefault(obj) { return obj && obj.__esModule ? obj : { default: obj }; }
 
/* eslint-disable import/first */
 
//region 1. Platform Libraries
const request = require('supertest');
//endregion
 
//region 2. Project Libraries
 
//endregion
 
describe('Route /streamers', () => {
        const dataAPI = new _DataAPI2.default();
 
        before(function before(done) {
                this.timeout(3000);
                dataAPI.initialize({
                        environment: 'unit-test',
                        heartbeatInterval: 10,
                        logLevel: 'ERROR',
                        mongoUrl: process.env.CLIO_MONGO_URL,
                        port: 15925
                });
                dataAPI.start(done);
        });
 
        let streamerID;
        describe('POST', () => {
                it('should create new streamer', done => {
                        request(dataAPI.expressApp).post('/streamers').send({
                                port: 15925,
                                publicIp: '19.19.19.19'
                        }).expect(201).expect(res => {
                                Iif (res.text.length !== 24) {
                                        throw new Error('Invalid Streamer ID');
                                }
                                streamerID = res.text;
                        }).end( /** @type function */done);
                });
        });
 
        describe('PUT', () => {
                it('should update existing streamer', done => {
                        request(dataAPI.expressApp).put(`/streamers/${ streamerID }`).send({
                                streamIds: [],
                                cpuLoad: 12.3,
                                mem: {
                                        load: 10.0,
                                        current: 102.4,
                                        total: 1024
                                }
                        }).expect(200).end( /** @type function */done);
                });
        });
 
        after(done => dataAPI.stop(done));
});
//# sourceMappingURL=mountStreamers.spec.js.map