joyent-portal/packages/portal-api/lib/index.js

'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}`);
  };
};