import { NatsPubSub } from 'iworks-nats-subscriptions';

import config from './config';

const pubsub = new NatsPubSub({
  connection: {
    url: config.NATS_HOST,
    json: true,
    verbose: true,
  },
});

export const publish = (eventName: string, payload: any) => {
  if (config.DEBUG) {
    console.debug(`Published event ${eventName}: ${JSON.stringify(payload)}\n`);
  }
  pubsub.publish(eventName, payload);
};

export const subscribe = (eventName: string) => () => pubsub.asyncIterator(eventName);