app/src/services/bootCheckService.ts - main - GreyCat/openhuman

app/src/services/bootCheckService.ts

46 строк2 KB

Martian

fix(tauri): identify foreign process on core port + consent-gated force-quit (#3331) (#3946)

23 июн 2026, 15:00

23 июн 2026, 15:00f1dcce4

/**
 * Service-backed transport for the boot-check orchestrator.
 *
 * The orchestrator (`app/src/lib/bootCheck/`) keeps all I/O behind a
 * `BootCheckTransport` interface so it can be unit-tested without Tauri.
 * This module is the production implementation: it owns the direct
 * `invoke` and `callCoreRpc` references so IPC stays localized to
 * `app/src/services/` per project conventions.
 */
import { invoke } from '@tauri-apps/api/core';

import type { BootCheckTransport, RecoveryOutcome } from '../lib/bootCheck';
import { callCoreRpc } from './coreRpcClient';

async function callRpc<T>(method: string, params?: Record<string, unknown>): Promise<T> {
  return callCoreRpc<T>({ method, params });
}

async function invokeCmd<T>(cmd: string, args?: Record<string, unknown>): Promise<T> {
  return invoke<T>(cmd, args);
}

/**
 * Invoke the `recover_port_conflict` Tauri command to reap stale OpenHuman
 * processes and restart the embedded core on any available port. When recovery
 * fails because a foreign process holds the port, the outcome carries that
 * process's identity in `foreign_owner`.
 */
export async function recoverPortConflict(): Promise<RecoveryOutcome> {
  return invokeCmd('recover_port_conflict');
}

/**
 * Invoke the `force_quit_port_owner` Tauri command to terminate the foreign
 * process holding the core RPC port, after the user consented to that pid.
 */
export async function forceQuitPortOwner(pid: number): Promise<RecoveryOutcome> {
  return invokeCmd('force_quit_port_owner', { pid });
}

export const bootCheckTransport: BootCheckTransport = {
  callRpc,
  invokeCmd,
  recoverPortConflict,
  forceQuitPortOwner,
};