/**
* @license
* Copyright 2026 Google LLC
* SPDX-License-Identifier: Apache-2.0
*/
import type {WriteStream} from 'node:fs';
import process from 'node:process';
import readline from 'node:readline';
import {parseArgs} from 'node:util';
import {logger, flushLogs, saveLogsToFile} from '../../logger.js';
import type {OsType} from '../types.js';
import {WatchdogMessageType} from '../types.js';
import {ClearcutSender} from './clearcut-sender.js';
function main() {
const {values} = parseArgs({
options: {
'parent-pid': {type: 'string'},
'app-version': {type: 'string'},
'os-type': {type: 'string'},
'log-file': {type: 'string'},
},
strict: true,
});
const parentPid = parseInt(values['parent-pid'] ?? '', 10);
const appVersion = values['app-version'];
const osType = parseInt(values['os-type'] ?? '', 10);
const logFile = values['log-file'];
let logStream: WriteStream | undefined;
if (logFile) {
logStream = saveLogsToFile(logFile);
}
const exit = (code: number) => {
if (!logStream) {
process.exit(code);
}
void flushLogs(logStream).finally(() => {
process.exit(code);
});
};
if (isNaN(parentPid) || !appVersion || isNaN(osType)) {
logger(
'Invalid arguments provided for watchdog process: ',
JSON.stringify({parentPid, appVersion, osType}),
);
exit(1);
return;
}
logger(
'Watchdog started',
JSON.stringify(
{
pid: process.pid,
parentPid,
version: appVersion,
osType,
},
null,
2,
),
);
const sender = new ClearcutSender(appVersion, osType as OsType);
let isShuttingDown = false;
function onParentDeath(reason: string) {
if (isShuttingDown) {
return;
}
isShuttingDown = true;
logger(`Parent death detected (${reason}). Sending shutdown event...`);
sender
.sendShutdownEvent()
.then(() => {
logger('Shutdown event sent. Exiting.');
exit(0);
})
.catch(err => {
logger('Failed to send shutdown event', err);
exit(1);
});
}
process.stdin.on('end', () => onParentDeath('stdin end'));
process.stdin.on('close', () => onParentDeath('stdin close'));
process.on('disconnect', () => onParentDeath('ipc disconnect'));
const rl = readline.createInterface({
input: process.stdin,
terminal: false,
});
rl.on('line', line => {
try {
if (!line.trim()) {
return;
}
const msg = JSON.parse(line);
if (msg.type === WatchdogMessageType.LOG_EVENT && msg.payload) {
sender.send(msg.payload).catch(err => {
logger('Error sending event', err);
});
}
} catch (err) {
logger('Failed to parse IPC message', err);
}
});
}
try {
main();
} catch (err) {
console.error('Watchdog fatal error:', err);
process.exit(1);
}
