const { defineProviderFactory } = require('brick-engine');
const {RegistryClient, clusterClientSetup, defineListener } = require('brick-cluster-client');

class Agent {
  /**
   * 代理进程模块构建函数
   * @param {RegistryClient} registry
   */
  constructor(registry) {
    this.registry = registry;
  }

  onAgentEvent(reg) {
    console.log(`Agent Event ${JSON.stringify(reg)}`);
    this.registry.publish({ eventName: 'worker', msg: 'publish with agent' });
  }

}

exports.Agent = Agent;

// 定义Agent对象构建工厂
defineProviderFactory(Agent, { deps: [{ id: RegistryClient }] });

// 定义绑定监听事件
defineListener(Agent, { reg: { eventName: 'agent' }, method: 'onAgentEvent' });

// 安装RegistryClient,以及监听器插件
clusterClientSetup(Agent, { registry: { isLeader: true, isBroadcast: true } });