rpc.ts

import type { JsonRpcParams, JsonRpcResult } from "./jsonrpccommon.ts";
import { JsonRpcClientWin } from "./jsonrpcwin.ts";
import type { JsonRpcClient } from "./mod.ts";
import { SmokeviewProcess } from "./process.ts";

export class SmvRpc {
  public rpc: JsonRpcClient;
  constructor(private process: SmokeviewProcess) {
    this.rpc = new JsonRpcClientWin(process.socketPath);
  }
  async call(method: string, params?: JsonRpcParams): Promise<JsonRpcResult> {
    return await this.rpc.call(method, params);
  }
  async notify(method: string, params?: JsonRpcParams): Promise<JsonRpcResult> {
    return await this.rpc.notify(method, params);
  }
  close() {
    this.rpc.close();
    this.process.close();
  }
}

export async function startSmvRpc(smvPath: string): Promise<SmvRpc> {
  const smv = new SmokeviewProcess(smvPath);
  const smvRpc = await smv.launch();
  return smvRpc;
}