chore: add back logs

web/projects/setup-wizard/src/app/services/api.service.ts

@@ -2,6 +2,9 @@ import * as jose from 'node-jose'
 import {
   DiskInfo,
   DiskListResponse,
+  FollowLogsReq,
+  FollowLogsRes,
+  Log,
   PartitionInfo,
   StartOSDiskInfo,
 } from '@start9labs/shared'
@@ -22,6 +25,10 @@ export abstract class ApiService {
   abstract execute(setupInfo: T.SetupExecuteParams): Promise<T.SetupProgress> // setup.execute
   abstract complete(): Promise<T.SetupResult> // setup.complete
   abstract exit(): Promise<void> // setup.exit
+  abstract followServerLogs(params: FollowLogsReq): Promise<FollowLogsRes> // setup.logs.follow
+  abstract openLogsWebsocket$(
+    config: WebSocketSubjectConfig<Log>,
+  ): Observable<Log>
   abstract openProgressWebsocket$(guid: string): Observable<T.FullProgress>
 
   async encrypt(toEncrypt: string): Promise<T.EncryptedWire> {

web/projects/setup-wizard/src/app/services/live-api.service.ts

@@ -3,8 +3,11 @@ import { Inject, Injectable } from '@angular/core'
 import {
   DiskListResponse,
   encodeBase64,
+  FollowLogsReq,
+  FollowLogsRes,
   HttpService,
   isRpcError,
+  Log,
   RpcError,
   RPCOptions,
   StartOSDiskInfo,
@@ -12,7 +15,7 @@ import {
 import { T } from '@start9labs/start-sdk'
 import * as jose from 'node-jose'
 import { Observable } from 'rxjs'
-import { webSocket } from 'rxjs/webSocket'
+import { webSocket, WebSocketSubjectConfig } from 'rxjs/webSocket'
 import { ApiService } from './api.service'
 
 @Injectable({
@@ -96,6 +99,14 @@ export class LiveApiService extends ApiService {
     })
   }
 
+  async followServerLogs(params: FollowLogsReq): Promise<FollowLogsRes> {
+    return this.rpcRequest({ method: 'setup.logs.follow', params })
+  }
+
+  openLogsWebsocket$({ url }: WebSocketSubjectConfig<Log>): Observable<Log> {
+    return webSocket(`http://start.local/ws/${url}`)
+  }
+
   async complete(): Promise<T.SetupResult> {
     const res = await this.rpcRequest<T.SetupResult>({
       method: 'setup.complete',

web/projects/setup-wizard/src/app/services/mock-api.service.ts

@@ -2,12 +2,16 @@ import { Injectable } from '@angular/core'
 import {
   DiskListResponse,
   encodeBase64,
+  FollowLogsReq,
+  FollowLogsRes,
+  Log,
   pauseFor,
   StartOSDiskInfo,
 } from '@start9labs/shared'
 import { T } from '@start9labs/start-sdk'
 import * as jose from 'node-jose'
-import { Observable, of } from 'rxjs'
+import { interval, map, Observable, of } from 'rxjs'
+import { WebSocketSubjectConfig } from 'rxjs/webSocket'
 import { ApiService } from './api.service'
 
 @Injectable({
@@ -266,6 +270,24 @@ export class MockApiService extends ApiService {
     }
   }
 
+  async followServerLogs(params: FollowLogsReq): Promise<FollowLogsRes> {
+    await pauseFor(1000)
+    return {
+      startCursor: 'fakestartcursor',
+      guid: 'fake-guid',
+    }
+  }
+
+  openLogsWebsocket$(config: WebSocketSubjectConfig<Log>): Observable<Log> {
+    return interval(500).pipe(
+      map(() => ({
+        timestamp: new Date().toISOString(),
+        message: 'fake log entry',
+        bootId: 'boot-id',
+      })),
+    )
+  }
+
   async complete(): Promise<T.SetupResult> {
     await pauseFor(1000)
     return {