Function startAppleAppLogStream

src/daemon/app-log-ios.ts:302–350

(params: {
  backend: AppLogResult['backend'];
  cmd: string;
  args: string[];
  stream: fs.WriteStream;
  redactionPatterns: RegExp[];
  pidPath?: string;
  stopSignals?: NodeJS.Signals[];
})

}

function startAppleAppLogStream(params: {
  backend: AppLogResult['backend'];
  cmd: string;
  args: string[];
  stream: fs.WriteStream;
  redactionPatterns: RegExp[];
  pidPath?: string;
  stopSignals?: NodeJS.Signals[];
}): AppLogResult {
  let state: AppLogState = 'active';
  const background = runCmdBackground(params.cmd, params.args, {
    allowFailure: true,
    captureOutput: false,
  });
  void background.wait.catch(() => {});
  const child = background.child;
  const writer = createLineWriter(params.stream, { redactionPatterns: params.redactionPatterns });
  if (typeof child.pid === 'number') {
    writePidFile(params.pidPath, child.pid);
  }
  const wait = attachChildToStream(child, params.stream, {
    endStreamOnClose: true,
    writer,
  }).then(
    (result) => {
      state = result.exitCode === 0 ? 'ended' : 'failed';
      clearPidFile(params.pidPath);
      return result;
    },
    (error: unknown) => {
      state = 'failed';
      clearPidFile(params.pidPath);
      throw error;
    },
  );
  return {
    backend: params.backend,
    getState: () => state,
    startedAt: Date.now(),
    wait,
    stop: async () => {
      for (const signal of params.stopSignals ?? ['SIGINT', 'SIGKILL']) {
        child.kill(signal);
        await waitForChildExit(wait);
      }
      clearPidFile(params.pidPath);
    },
  };
}