nodebb-plugin-emoji/lib/pubsub.ts

import { hostname } from 'os';

import buildAssets from './build';

const nconf = require.main.require('nconf');
const winston = require.main.require('winston');
const pubsub = require.main.require('./src/pubsub');

const primary = nconf.get('isPrimary') === 'true' || nconf.get('isPrimary') === true;

export async function build() {
  if (pubsub.pubClient) {
    pubsub.publish('emoji:build', {
      hostname: hostname(),
    });
  }

  if (primary) {
    await buildAssets();
  }
}

const logErrors = (err: Error) => {
  if (err) {
    winston.error(err);
  }
};

if (primary) {
  pubsub.on('emoji:build', (data: { hostname: string }) => {
    if (data.hostname !== hostname()) {
      buildAssets().catch(logErrors);
    }
  });
}