class CommandBus {
  private commandStream = new Subject<CommandMessage>();

  emit<T>(command: CommandMessage<T>): void {
    this.commandStream.next(command);
  }

  on<T>(type: string): Observable<CommandMessage<T>> {
    return this.commandStream.pipe(
      filter(cmd => cmd.type === type)
    );
  }

  // Hỗ trợ gửi lệnh và nhận phản hồi
  emitWithResponse<T, R>(type: string, data: T): Observable<R> {
    // Logic quản lý requestId và ReplaySubject
  }

  respond<R>(message: CommandMessage, response: R): void { /* gửi phản hồi */ }
}

class EventBus {
  private eventStream = new Subject<EventMessage>();

  emit<T>(event: EventMessage<T>): void {
    this.eventStream.next(event);
  }

  on<T>(type: string): Observable<T> {
    return this.eventStream.pipe(
      filter(e => e.type === type),
      map(e => e.payload as T)
    );
  }
}

// Gửi lệnh tạo người dùng
commandBus.emit({ type: 'CreateUser', data: { email: '[email protected]' }});

// Nghe xử lý lệnh
commandBus.on<{ email: string }>('CreateUser').subscribe(command => {
  userService.create(command.data.email);
  if (command.requestId) {
    commandBus.respond(command, { id: 'new-user-123' });
  }
});

// Phát sự kiện sau khi tạo thành công
eventBus.emit({
  type: 'UserCreated',
  payload: { userId: 'new-user-123', email: '[email protected]', timestamp: new Date().toISOString() }
});

// Module khác lắng nghe sự kiện UserCreated
eventBus.on<{ userId: string; email: string }>('UserCreated').subscribe(data => {
  notificationService.sendWelcomeEmail(data.email);
});

describe('UserCommandHandler', () => {
  it('xử lý CreateUser và phát sự kiện UserCreated', () => {
    // Mô phỏng dịch vụ tạo user và eventBus.emit
    // Xác minh gọi đúng và phát sự kiện
  });
});

describe('UserRegistrationComponent', () => {
  it('phát hành CreateUser command khi submit form', () => {
    // Mô phỏng CommandBus.emitWithResponse
    // Gọi submitForm và kiểm tra command được gửi
  });
});

@CommandHandler('CreateUser')
async handleCreateUser(command: CommandMessage<CreateUserData>) {
  // Xử lý tạo user và phát sự kiện
}