Function handleLine

apps/memos-local-plugin/bridge/stdio.ts:153–225

(line: string)

  }

  async function handleLine(line: string): Promise<void> {
    if (closed) return;
    const trimmed = line.trim();
    if (trimmed.length === 0) return;

    let msg: JsonRpcRequest | null = null;
    try {
      msg = JSON.parse(trimmed) as JsonRpcRequest;
    } catch (err) {
      writeLine(
        errorResponse(null, JSONRPC_PARSE_ERROR, "invalid JSON", {
          text: err instanceof Error ? err.message : String(err),
        }),
      );
      return;
    }

    // Reverse-direction response: the client is replying to a request
    // we previously sent via `serverRequest`. Match by `srv-` ID and
    // resolve / reject the matching pending promise.
    const raw = msg as unknown as Record<string, unknown>;
    if (
      raw &&
      typeof raw === "object" &&
      typeof raw.id === "string" &&
      (raw.id as string).startsWith("srv-") &&
      (raw.result !== undefined || raw.error !== undefined)
    ) {
      const id = raw.id as string;
      const pending = serverPending.get(id);
      if (pending) {
        serverPending.delete(id);
        if (pending.timer) clearTimeout(pending.timer);
        if (raw.error != null) {
          pending.reject(raw.error);
        } else {
          pending.resolve(raw.result);
        }
      }
      return;
    }

    if (!msg || typeof msg !== "object" || msg.jsonrpc !== "2.0" || !msg.method) {
      writeLine(errorResponse(msg?.id ?? null, JSONRPC_INVALID_REQUEST, "not JSON-RPC 2.0"));
      return;
    }

    try {
      const result = await dispatch(msg.method, msg.params);
      if (msg.id !== undefined && msg.id !== null) {
        const ok: JsonRpcSuccess = {
          jsonrpc: "2.0",
          id: msg.id,
          result,
        };
        writeLine(ok);
      }
    } catch (err) {