import * as amqp from 'amqplib';

import { FatalError, ISLAND } from '../../utils/error';
import ListenableAdapter from '../listenable-adapter';

export interface RabbitMqAdapterOptions {
  url: string;
  serviceName?: string;
  socketOptions?: {heartbeat?: number, noDelay: boolean};
  rpcTimeout?: number;
}

export default class RabbitMqAdapter<T> extends ListenableAdapter<T, RabbitMqAdapterOptions> {
  protected connection: amqp.Connection;
  /**
   * @returns {Promise<void>}
   * @override
   */
  public async initialize() {
    if (!this.options) throw new FatalError(ISLAND.ERROR.E0025_MISSING_ADAPTER_OPTIONS);
    const options = this.options;
    const connection = await Promise.resolve(amqp.connect(options.url, options.socketOptions));
    this.connection = connection;
  }

  public listen() {
    return Promise.resolve();
  }
}