2017-06-28 10:20:22 +02:00
|
|
|
'use strict';
|
|
|
|
|
2018-12-03 08:59:13 +01:00
|
|
|
const Controller = require('../controller');
|
2018-11-29 20:46:24 +01:00
|
|
|
const { clientRegisterSchema: schema } = require('./register-schema');
|
2017-06-28 10:20:22 +02:00
|
|
|
|
2018-12-03 08:59:13 +01:00
|
|
|
class RegisterController extends Controller {
|
2019-04-30 21:14:23 +02:00
|
|
|
constructor({ clientInstanceStore, clientApplicationsStore }, getLogger) {
|
2018-12-03 08:59:13 +01:00
|
|
|
super();
|
2019-04-30 21:14:23 +02:00
|
|
|
this.logger = getLogger('/api/client/register');
|
2018-11-29 20:46:24 +01:00
|
|
|
this.clientInstanceStore = clientInstanceStore;
|
|
|
|
this.clientApplicationsStore = clientApplicationsStore;
|
2017-06-28 10:20:22 +02:00
|
|
|
|
2018-12-03 08:59:13 +01:00
|
|
|
this.post('/', this.handleRegister);
|
2018-11-29 20:46:24 +01:00
|
|
|
}
|
2017-06-28 10:20:22 +02:00
|
|
|
|
2018-11-29 20:46:24 +01:00
|
|
|
async handleRegister(req, res) {
|
|
|
|
const data = req.body;
|
2020-01-02 19:23:52 +01:00
|
|
|
const { value, error } = schema.validate(data);
|
2018-11-29 20:46:24 +01:00
|
|
|
|
|
|
|
if (error) {
|
2019-04-30 21:14:23 +02:00
|
|
|
this.logger.warn('Invalid client data posted', error);
|
2018-11-29 20:46:24 +01:00
|
|
|
return res.status(400).json(error);
|
|
|
|
}
|
|
|
|
|
2020-01-02 19:23:52 +01:00
|
|
|
value.clientIp = req.ip;
|
2018-11-29 20:46:24 +01:00
|
|
|
|
|
|
|
try {
|
2020-01-02 19:23:52 +01:00
|
|
|
await this.clientApplicationsStore.upsert(value);
|
|
|
|
await this.clientInstanceStore.insert(value);
|
|
|
|
const { appName, instanceId } = value;
|
2019-04-30 21:14:23 +02:00
|
|
|
this.logger.info(
|
2020-04-14 22:29:11 +02:00
|
|
|
`New client registration: appName=${appName}, instanceId=${instanceId}`,
|
2018-11-29 20:46:24 +01:00
|
|
|
);
|
|
|
|
return res.status(202).end();
|
|
|
|
} catch (err) {
|
2019-04-30 21:14:23 +02:00
|
|
|
this.logger.error('failed to register client', err);
|
2018-11-29 20:46:24 +01:00
|
|
|
return res.status(500).end();
|
|
|
|
}
|
|
|
|
}
|
|
|
|
}
|
|
|
|
|
|
|
|
module.exports = RegisterController;
|