import { EventService } from '../../services/event-service';
import { FatalError, ISLAND } from '../../utils/error';
import ListenableAdapter from '../listenable-adapter';
import { AmqpChannelPoolAdapter } from './amqp-channel-pool-adapter';

export interface EventAdapterOptions {
  amqpChannelPoolAdapter: AmqpChannelPoolAdapter;
  consumerAmqpChannelPoolAdapter?: AmqpChannelPoolAdapter;
  serviceName: string;
}

export class EventAdapter extends ListenableAdapter<EventService, EventAdapterOptions> {
  async initialize(): Promise<void> {
    if (!this.options) throw new FatalError(ISLAND.ERROR.E0025_MISSING_ADAPTER_OPTIONS);
    this._adaptee = new EventService(this.options.serviceName || 'unknownService');
    const amqpChannelPoolService = this.options.amqpChannelPoolAdapter.adaptee;
    if (!amqpChannelPoolService) {
      throw new FatalError(ISLAND.ERROR.E0008_AMQP_CHANNEL_POOL_REQUIRED, 'AmqpChannelPoolService required');
    }

    const { consumerAmqpChannelPoolAdapter } = this.options;
    const consumerAmqpChannelPool = consumerAmqpChannelPoolAdapter && consumerAmqpChannelPoolAdapter.adaptee;
    await amqpChannelPoolService.waitForInit();
    if (consumerAmqpChannelPool) {
      await consumerAmqpChannelPool.waitForInit();
    }
    return this._adaptee.initialize(amqpChannelPoolService, consumerAmqpChannelPool);
  }

  listen(): Promise<void> {
    return this.adaptee.startConsume();
  }

  async destroy(): Promise<any> {
    await super.destroy();
    return this.adaptee.purge();
  }

  async sigInfo(): Promise<void> {
    await this.adaptee.sigInfo();
  }
}