1
>
/*---------------------------------------------------------------------------------------------
codexAppServerClient.ts
2
>
* Copyright (c) Microsoft Corporation. All rights reserved.
3
>
* Licensed under the MIT License. See License.txt in the project root for license information.
4
>
*--------------------------------------------------------------------------------------------*/
5
>
6
>
import type { Readable, Writable } from 'stream';
7
>
import { CancellationError } from '../../../../base/common/errors.js';
8
>
import { Emitter, Event } from '../../../../base/common/event.js';
9
>
import { Disposable, type IDisposable, toDisposable } from '../../../../base/common/lifecycle.js';
10
>
import { hasKey } from '../../../../base/common/types.js';
11
>
import type { ClientNotification } from './protocol/generated/ClientNotification.js';
12
>
import type { ClientRequest } from './protocol/generated/ClientRequest.js';
13
>
import type { RequestId } from './protocol/generated/RequestId.js';
14
>
import type { ServerNotification } from './protocol/generated/ServerNotification.js';
15
>
import type { ServerRequest } from './protocol/generated/ServerRequest.js';
16
>
17
>
// #region Wire types
18
>
//
19
>
// JSON-RPC 2.0 over NDJSON, with the `"jsonrpc": "2.0"` field *omitted on
20
>
// the wire* per the codex app-server convention. The generated
21
>
// `ClientRequest` / `ClientNotification` / `ServerRequest` /
22
>
// `ServerNotification` unions encode `method` + `params` shapes; we add
23
>
// `id` + `result` / `error` envelopes on top.
24
>
25
>
interface IWireResponseSuccess<R = unknown> {
26
>
readonly id: RequestId;
27
>
readonly result: R;
28
>
readonly error?: undefined;
29
>
readonly method?: undefined;
30
>
}
31
>
32
>
interface IWireResponseError {
33
>
readonly id: RequestId;
34
>
readonly result?: undefined;
35
>
readonly error: { readonly code: number; readonly message: string; readonly data?: unknown };
36
>
readonly method?: undefined;
37
>
}
38
>
39
>
type WireMessage = ClientNotification | ClientRequest | ServerNotification | ServerRequest | IWireResponseSuccess | IWireResponseError;
40
>
41
>
// #endregion
42
>
43
>
/**
44
>
* Standard JSON-RPC error codes.
45
>
*
46
>
* @see https://www.jsonrpc.org/specification#error_object
47
>
*/
48
>
export const enum JsonRpcErrorCode {
49
>
ParseError = -32700,
50
>
InvalidRequest = -32600,
51
>
MethodNotFound = -32601,
52
>
InvalidParams = -32602,
53
>
InternalError = -32603,
54
>
}
55
>
56
>
/**
57
>
* Error thrown when a remote request responds with an `error` envelope.
58
>
*/
59
>
export class JsonRpcError extends Error {
60
>
constructor(
61
readonly code: number,
62
message: string,