Mailspring/packages/nylas-dashboard/app.js

79 lines
2.5 KiB
JavaScript
Raw Normal View History

const Hapi = require('hapi');
const HapiWebSocket = require('hapi-plugin-websocket');
const Inert = require('inert');
const {DatabaseConnector, PubsubConnector, SchedulerUtils, NylasError} = require(`nylas-core`);
global.Promise = require('bluebird');
global.NylasError = NylasError;
const server = new Hapi.Server();
server.connection({ port: process.env.PORT / 1 + 1 || 5101 });
DatabaseConnector.forShared().then(({Account}) => {
server.register([HapiWebSocket, Inert], () => {
server.route({
method: "POST",
path: "/accounts",
config: {
plugins: {
websocket: {
only: true,
connect: (wss, ws) => {
Account.findAll().then((accounts) => {
accounts.forEach((acct) => {
ws.send(JSON.stringify({ cmd: "ACCOUNT", payload: acct }));
});
});
this.observable = PubsubConnector.observeAllAccounts().subscribe((accountId) => {
Account.find({where: {id: accountId}}).then((acct) => {
ws.send(JSON.stringify({ cmd: "ACCOUNT", payload: acct }));
});
});
this.pollInterval = setInterval(() => {
SchedulerUtils.listActiveAccounts().then((accountIds) => {
ws.send(JSON.stringify({ cmd: "ACTIVE", payload: accountIds}))
});
const assignments = {};
SchedulerUtils.forEachAccountList((identity, accountIds) => {
for (const accountId of accountIds) {
assignments[accountId] = identity;
}
}).then(() =>
ws.send(JSON.stringify({ cmd: "ASSIGNMENTS", payload: assignments}))
)
}, 1000);
},
disconnect: () => {
clearInterval(this.pollInterval);
this.observable.dispose();
},
},
},
},
handler: (request, reply) => {
if (request.payload.cmd === "PING") {
reply(JSON.stringify({ result: "PONG" }));
return;
}
},
});
server.route({
method: 'GET',
path: '/{param*}',
handler: {
directory: {
path: require('path').join(__dirname, 'public'),
},
},
});
server.start((startErr) => {
if (startErr) { throw startErr; }
console.log('Dashboard running at:', server.info.uri);
});
});
});