start-os/web/projects/shared/src/services/setup-logs.service.ts

import { StaticClassProvider } from '@angular/core'
import { defer, Observable, switchMap } from 'rxjs'
import { WebSocketSubjectConfig } from 'rxjs/webSocket'
import { Log } from '../types/api'
import { Constructor } from '../types/constructor'

interface Api {
  followLogs: () => Promise<string>
  openLogsWebsocket$: (config: WebSocketSubjectConfig<Log>) => Observable<Log>
}

export function provideSetupLogsService(
  api: Constructor<Api>,
): StaticClassProvider {
  return {
    provide: SetupLogsService,
    deps: [api],
    useClass: SetupLogsService,
  }
}

export class SetupLogsService extends Observable<Log> {
  private readonly log$ = defer(() => this.api.followLogs()).pipe(
    switchMap(url => this.api.openLogsWebsocket$({ url })),
  )

  constructor(private readonly api: Api) {
    super(subscriber => this.log$.subscribe(subscriber))
  }
}