Function startAndroidAppLog

src/daemon/app-log-android.ts:73–136

(
  deviceId: string,
  appBundleId: string,
  stream: fs.WriteStream,
  redactionPatterns: RegExp[],
  pidPath?: string,
)

}

export async function startAndroidAppLog(
  deviceId: string,
  appBundleId: string,
  stream: fs.WriteStream,
  redactionPatterns: RegExp[],
  pidPath?: string,
): Promise<AppLogResult> {
  let state: AppLogState = 'recovering';
  let stopped = false;
  let activeChild: AndroidAdbProcess | undefined;
  let activeWait: ReturnType<typeof attachChildToStream> | undefined;

  const wait = (async () => {
    try {
      while (!stopped) {
        const pid = await resolveAndroidPid(deviceId, appBundleId);
        if (!pid) {
          state = 'recovering';
          await sleep(1_000);
          continue;
        }
        const provider = resolveAndroidAdbProvider(androidDeviceForSerial(deviceId));
        const child = streamAndroidLogcatWithAdb(provider, { pid });
        activeChild = child;
        const writer = createLineWriter(stream, { redactionPatterns });
        activeWait = attachChildToStream(child, stream, { endStreamOnClose: false, writer });
        if (typeof child.pid === 'number') {
          writePidFile(pidPath, child.pid);
        }
        state = 'active';
        await activeWait;
        clearPidFile(pidPath);
        activeChild = undefined;
        activeWait = undefined;
        if (stopped) return { stdout: '', stderr: '', exitCode: 0 };
        state = 'recovering';
        await sleep(500);
      }
      return { stdout: '', stderr: '', exitCode: 0 };
    } finally {
      stream.end();
      clearPidFile(pidPath);
    }
  })();

  return {
    backend: 'android',
    getState: () => state,
    startedAt: Date.now(),
    wait,
    stop: async () => {
      stopped = true;
      if (activeChild && !activeChild.killed) {
        activeChild.kill('SIGINT');
      }
      if (activeWait) await waitForChildExit(activeWait);
      if (activeChild && !activeChild.killed) {
        activeChild.kill('SIGKILL');