import {
  MessageHandler, RequestManyOptions, RequestOptions, SendOptions,
  Subject, BrokerResponse,
} from './types/broker.js';

export interface Broker {
  get clientId(): number | undefined;

  get name(): string;

  connect(): Promise<this>;
  disconnect(): Promise<void>;

  createInbox(): string;

  on<T>(
    subject: Subject,
    listener: MessageHandler<T>,
  ): void;
  on<T>(
    subject: Subject,
    listener: MessageHandler<T>,
    queue: string | undefined,
  ): void;

  off<T>(
    subject: Subject,
    listener: MessageHandler<T>,
  ): void;

  send<T>(
    subject: Subject,
    data: T,
    options?: SendOptions,
  ): Promise<void>;

  requestMany<T, R>(
    subject: Subject,
    data: T,
    options?: RequestManyOptions,
  ): AsyncIterable<BrokerResponse<R>>;

  request<T, R>(
    subject: Subject,
    data: T,
    options?: RequestOptions,
  ): Promise<BrokerResponse<R | undefined>>;
}