@betit/orion-node-sdk NPM

Installation

$ npm install @betit/orion-node-sdk

Basic example

Note - You will need to have running all of the orion dependencies

Add the following into foo.js and then run VERBOSE=true node foo.js

const ORION = require('@betit/orion-node-sdk');
const FOO = new ORION.Service('foo');

FOO.handle('get', (req, reply) => {
  reply(new ORION.Response('foo'));
});

FOO.listen(() => FOO.logger.createMessage('ready').send());

Then add the following into bar.js and then run node bar.js

const ORION = require('@betit/orion-node-sdk');
const BAR = new ORION.Service('bar');

const REQ = new ORION.Request('/foo/get');
BAR.call(REQ, res => {
  // do stuff
});

You can find more detailed examples in the examples folder.

Async example

This utility also supports functionality with Promises, so the following code can be also used:

const ORION = require('@betit/orion-node-sdk');
const FOO = new ORION.Service('foo');

FOO.handle('get', async (req) => {
  return new ORION.Response('foo');
});

async function initFOO() {
  await FOO.listen();
  FOO.logger.createMessage('ready').send()
}

init().then(exit);

And in bar.js:

const ORION = require('@betit/orion-node-sdk');
const BAR = new ORION.Service('bar');

const REQ = new ORION.Request('/foo/get');

async function main() {
  const res = await BAR.call(REQ);
  // do stuff
}

main().then(exit);

Also, subscriptions can now be looped forever using:

const ORION = require('@betit/orion-node-sdk');
const BAR = new ORION.Service('bar');

async function processEvents() {
  const producer = BAR.onAsync("event");

  while (true) {
    const event = await producer.consume();
  }
}

...

Health checks

Support for health checking is present if the services are running with the environment variable WATCHDOG=true. Also, a watchdog must be running in the same environment as the service.

You can write a network health check as:

const ping = require('ping');
const host = '1.1.1.1';

async function checkNetwork(): Promise<[string, OrionError | undefined]> {
  const isAlive = await ping.promise.probe(host);
  
  if (!isAlive) {
    return [`Can't connect to ${host}`, new OrionError('CRIT')];
  } else {
    return ['', undefined];
  }
}

const healthCheck = {
  checkIsWorking: checkNetwork,
  name: 'have_I_external_net',
  timeout: 1000,
};

const SERVICE = new Service('service_name');
SERVICE.registerHealthCheck(envDependency);