69
70
constructor(
72
>
@IFileService private readonly _fileService: IFileService,
73
>
@ILogService private readonly _logService: ILogService,
74
>
) {
75
>
super();
76
>
this._directory = joinPath(this._options.logsHome, AHP_LOG_DIR);
77
>
// Truncate connectionId to avoid filesystem filename length limits (e.g. 255 on ext4/APFS)
78
>
const safeConnectionId = sanitizeFilePart(this._options.connectionId).slice(0, 64);
79
>
this._baseName = `ahp-${toFileTimestamp(new Date())}-${safeConnectionId}.jsonl`;
80
>
this._maxFileSizeBytes = this._options.maxFileSizeBytes ?? DEFAULT_MAX_FILE_SIZE_BYTES;
81
>
this._maxFiles = this._options.maxFiles ?? DEFAULT_MAX_FILES;
82
>
this._currentFile = joinPath(this._directory, this._baseName);
83
>
}
84
85
get resource(): URI {
87
>
}
88
89
log(message: object, dir: AhpLogDirection, byteLength?: number): void {
91
>
ts: new Date().toISOString(),
92
>
dir,
93
>
connectionId: this._options.connectionId,
94
>
transport: this._options.transport,
95
>
...(typeof byteLength === 'number' ? { byteLength } : {}),
96
>
};
97
>
const entry = { ...message, _ahpLog: meta };
98
>
// Fast path: serialize once. The vast majority of messages are small, so
99
>
// we only pay a single stringify and use its length to decide whether the
100
>
// rare oversized-message path below is needed.
101
>
let body = stringifyAhpLogEntry(entry);
102
>
if (body.length > MAX_LOG_LINE_LENGTH) {
103
// Slow path (rare): a single message carried very large payloads. Walk
104
// the object via a replacer that elides long string values, keeping the