75 lines
1.4 KiB
JavaScript
75 lines
1.4 KiB
JavaScript
'use strict';
|
|
|
|
const Schema = require('joyent-cp-gql-schema');
|
|
const Graphi = require('graphi');
|
|
const Piloted = require('piloted');
|
|
const PortalData = require('portal-data');
|
|
const PortalWatch = require('portal-watch');
|
|
const Pack = require('../package.json');
|
|
const Resolvers = require('./resolvers');
|
|
|
|
|
|
const internals = {};
|
|
|
|
|
|
module.exports = function (server, options, next) {
|
|
const docker = Piloted.service('docker-compose-api');
|
|
if (docker) {
|
|
options.data.dockerComposeHost = `tcp://${docker.address}:${docker.port}`;
|
|
}
|
|
|
|
const data = new PortalData(options.data);
|
|
|
|
const watch = new PortalWatch(Object.assign(options.watch, {
|
|
data
|
|
}));
|
|
|
|
data.on('error', (err) => {
|
|
server.log(['error'], err);
|
|
});
|
|
|
|
data.connect((err) => {
|
|
if (err) {
|
|
return next(err);
|
|
}
|
|
|
|
server.bind(Object.assign(data, {
|
|
watch
|
|
}));
|
|
|
|
Piloted.on('refresh', internals.refresh(data));
|
|
watch.poll();
|
|
|
|
server.register([
|
|
{
|
|
register: Graphi,
|
|
options: {
|
|
schema: Schema,
|
|
resolvers: Resolvers(data)
|
|
}
|
|
}
|
|
]);
|
|
|
|
next();
|
|
});
|
|
};
|
|
|
|
module.exports.attributes = {
|
|
name: Pack.name,
|
|
version: Pack.version,
|
|
once: true,
|
|
multiple: false
|
|
};
|
|
|
|
|
|
internals.refresh = function (data) {
|
|
return () => {
|
|
const docker = Piloted.service('docker-compose-api');
|
|
if (!docker) {
|
|
return;
|
|
}
|
|
|
|
data.reconnectCompose(`tcp://${docker.address}:${docker.port}`);
|
|
};
|
|
};
|