qwen-code/integration-tests/interactive/cron-interactive.test.ts

/**
 * @license
 * Copyright 2026 Qwen Team
 * SPDX-License-Identifier: Apache-2.0
 */

/**
 * In-session cron/loop interactive E2E tests.
 *
 * These drive the full interactive TUI via InteractiveSession (node-pty +
 * @xterm/headless) and read the rendered terminal screen. No browser needed.
 *
 * Ported from the standalone script at
 * terminal-capture/test-cron-interactive-e2e.ts.
 */

import { describe, it, expect, afterEach } from 'vitest';
import { InteractiveSession } from './interactive-session.js';

const IS_SANDBOX =
  process.env['QWEN_SANDBOX'] &&
  process.env['QWEN_SANDBOX']!.toLowerCase() !== 'false';

function makeEnv(): NodeJS.ProcessEnv {
  const env = { ...process.env };
  delete env['NO_COLOR'];
  return {
    ...env,
    QWEN_CODE_ENABLE_CRON: '1',
    FORCE_COLOR: '1',
    TERM: 'xterm-256color',
    NODE_NO_WARNINGS: '1',
  };
}

// These tests are flaky in the Docker sandbox environment, skip for now.
(IS_SANDBOX ? describe.skip : describe)('cron interactive', () => {
  let session: InteractiveSession | null = null;

  afterEach(async () => {
    if (session) {
      await session.close();
      session = null;
    }
  });

  it('loop fires inline in conversation', { timeout: 180_000 }, async () => {
    session = await InteractiveSession.start({
      env: makeEnv(),
      args: ['--approval-mode', 'yolo'],
    });

    await session.send(
      'Call cron_create with expression "*/1 * * * *" and prompt "PONG7742" and recurring true. Confirm briefly.',
    );

    await session.waitForScreen(
      (scr) => scr.includes('Cron: PONG7742'),
      'cron notification "Cron: PONG7742"',
      90_000,
    );

    await session.idle(5000);
    const finalScreen = await session.screen();
    const afterPrompt = finalScreen.slice(
      finalScreen.lastIndexOf('Cron: PONG7742'),
    );
    expect(afterPrompt).toContain('✦');
  });

  it('user input takes priority over cron', { timeout: 180_000 }, async () => {
    session = await InteractiveSession.start({
      env: makeEnv(),
      args: ['--approval-mode', 'yolo'],
    });

    await session.send(
      'Call cron_create with expression "*/1 * * * *" and prompt "CRONTICK99" and recurring true. Confirm briefly.',
    );

    await session.waitForScreen(
      (scr) => scr.includes('Cron: CRONTICK99'),
      'first cron fire "Cron: CRONTICK99"',
      90_000,
    );

    await session.idle(5000);
    await session.send('Reply with exactly USERPRIORITY77 nothing else');

    await session.waitForScreen(
      (scr) => scr.includes('USERPRIORITY77'),
      'model response containing USERPRIORITY77',
    );

    const screen = await session.screen();
    expect(screen).toContain('Type your message');
  });

  it(
    'error during cron turn does not kill the loop',
    { timeout: 180_000 },
    async () => {
      session = await InteractiveSession.start({
        env: makeEnv(),
        args: ['--approval-mode', 'yolo'],
      });

      await session.send(
        'Call cron_create with expression "*/1 * * * *" and prompt "Read the file /tmp/nonexistent_e2e_99.txt and report its contents. If it does not exist say FILEERR88." and recurring true. Confirm briefly.',
      );

      await session.waitForScreen(
        (scr) => scr.includes('FILEERR88'),
        'model reporting FILEERR88 from cron prompt',
        90_000,
      );

      await session.idle(5000);
      await session.send('Reply with exactly ALIVE99 nothing else');
      await session.waitForScreen(
        (scr) => scr.includes('ALIVE99'),
        'model response ALIVE99',
      );

      await session.send(
        'Call cron_list and tell me how many jobs exist. Say "COUNT: N"',
      );
      await session.idle(8000);
      const screen = await session.screen();
      expect(
        screen.includes('COUNT: 1') ||
          screen.includes('1 job') ||
          screen.includes('Active cron jobs (1)'),
      ).toBe(true);
    },
  );
});