import { type IDisposable } from '#/_base/di/lifecycle';
import { Service } from '#/_base/di/service';
import { LifecycleScope } from '#/app/scopes';
import { ScopeActivation, registerScopedService } from '#/_base/di/scope';
import { Emitter, type Event } from '#/_base/event';

import { IEventService } from './event';
import type { Event2 } from './event2';

export class EventService extends Service implements IEventService {
  declare readonly _serviceBrand: undefined;

  private readonly emitter = this._register(new Emitter<Event2<any>>('publish'));
  readonly onDidPublish: Event<Event2<any>> = this.emitter.event;

  get listenerCount(): number {
    return this.emitter.listenerCount;
  }

  publish(event: Event2<any>): void {
    this.emitter.fire(event);
  }

  subscribe(handler: (event: Event2<any>) => void): IDisposable {
    return this.emitter.event(handler);
  }
}

registerScopedService(
  LifecycleScope.App,
  IEventService,
  EventService,
  ScopeActivation.OnScopeCreated,
  'event',
);