pcbjam/tests/e2e/coroutine-pthread.spec.ts

import { test, expect, tryLoadApp } from './utils/fixtures';

// Isolated reproduction probe for the KiCad Asyncify-fiber x pthreads Chrome crash.
// Loads main_repro.html (fiber Call/Yield/Resume in main(), built WITH pthreads, no wx).
// Firefox should print "[REPRO] DONE"; if system Chrome crashes before DONE, the crash
// is reproduced in isolation.
test.describe('Coroutine pthread main() reproduction', () => {
  test('fiber-in-main + pthreads reaches DONE without renderer crash', async ({ page, testLogger }) => {
    await page.goto('/standalone/coroutine-pthread/main_repro.html');
    await tryLoadApp(page, 20000).catch(() => {});

    await expect
      .poll(() => testLogger.consoleLogs.some((l) => l.includes('[REPRO] DONE')), {
        timeout: 30000,
        message: 'should reach [REPRO] DONE (i.e. the main-context rewind survived)',
      })
      .toBe(true);

    // Sanity: the coroutine body must actually have run (fiber entry wired up).
    expect(
      testLogger.consoleLogs.some((l) => l.includes('[REPRO] coroutine body running')),
      'coroutine body should have executed'
    ).toBe(true);
  });

  // Probe #2: coroutine activated through nested JS<->wasm dynCall boundaries (KiCad's shape).
  test('nested dynCall-boundary fiber reaches DONE without renderer crash', async ({ page, testLogger }) => {
    await page.goto('/standalone/coroutine-pthread/nested_repro_ex.html');
    await tryLoadApp(page, 20000).catch(() => {});

    await expect
      .poll(() => testLogger.consoleLogs.some((l) => l.includes('[REPRO] DONE')), {
        timeout: 30000,
        message: 'should reach [REPRO] DONE (main rewind through the dynCall chain survived)',
      })
      .toBe(true);

    expect(
      testLogger.consoleLogs.some((l) => l.includes('[REPRO] coroutine body running')),
      'coroutine body should have executed'
    ).toBe(true);
  });

  // Probe #3: the full 13-scenario wx-event-loop harness, built WITH pthreads.
  test('wx event loop + pthreads coroutine suite completes without renderer crash', async ({ page, testLogger }) => {
    await page.goto('/standalone/coroutine-pthread/coroutine_test_wxpt.html');
    await tryLoadApp(page, 30000).catch(() => {});

    await expect
      .poll(() => testLogger.consoleLogs.find((l) => l.includes('[COROUTINE_TEST] SUMMARY')) ?? null, {
        timeout: 45000,
        message: 'wx+pthreads suite should emit a SUMMARY line (no crash)',
      })
      .not.toBeNull();

    const summary = testLogger.consoleLogs.find((l) => l.includes('[COROUTINE_TEST] SUMMARY'))!;
    const m = summary.match(/total=(\d+)\s+passed=(\d+)\s+failed=(\d+)/);
    expect(m, 'SUMMARY parseable').not.toBeNull();
    expect(Number(m![3]), 'no failed cases').toBe(0);
  });

  // Probe #4: coroutine activated via an embind (--bind) call.
  test('embind-activated fiber reaches DONE without renderer crash', async ({ page, testLogger }) => {
    await page.goto('/standalone/coroutine-pthread/embind_repro.html');
    await tryLoadApp(page, 20000).catch(() => {});

    await expect
      .poll(() => testLogger.consoleLogs.some((l) => l.includes('[REPRO] DONE')), {
        timeout: 30000,
        message: 'should reach [REPRO] DONE (rewind through the embind dispatch survived)',
      })
      .toBe(true);

    expect(
      testLogger.consoleLogs.some((l) => l.includes('ToolHost::activate')),
      'embind activate should have run'
    ).toBe(true);
  });

  // Probe #5: coroutine activated inside an emscripten_set_main_loop (rAF) callback
  // (the single JS->wasm boundary KiCad uses; matches "main-refresh" in the crash trace).
  test('main-loop(rAF)-activated fiber reaches DONE without renderer crash', async ({ page, testLogger }) => {
    await page.goto('/standalone/coroutine-pthread/mainloop_repro.html');
    await tryLoadApp(page, 20000).catch(() => {});

    await expect
      .poll(() => testLogger.consoleLogs.some((l) => l.includes('[REPRO] DONE')), {
        timeout: 30000,
        message: 'should reach [REPRO] DONE (rewind through the main-loop dynCall_v survived)',
      })
      .toBe(true);

    expect(
      testLogger.consoleLogs.some((l) => l.includes('activating coroutine inside main-loop refresh')),
      'main loop should have run and activated the coroutine'
    ).toBe(true);
  });

  // Probe #6: WebGL 2.0 + coroutine activated mid-render-frame (KiCad's GAL render path).
  test('WebGL2 + mid-frame fiber reaches DONE without renderer crash', async ({ page, testLogger }) => {
    await page.goto('/standalone/coroutine-pthread/gl_repro.html');
    await tryLoadApp(page, 20000).catch(() => {});

    await expect
      .poll(() => testLogger.consoleLogs.some((l) => l.includes('[REPRO] DONE')), {
        timeout: 30000,
        message: 'should reach [REPRO] DONE (rewind of a mid-GL-frame survived)',
      })
      .toBe(true);

    expect(
      testLogger.consoleLogs.some((l) => l.includes('WebGL2 context=')),
      'a WebGL2 context should have been created'
    ).toBe(true);
  });

  // Probe #7: WebGL2 + coroutine mid-frame + PTHREADS (the GL x pthreads combo KiCad uses).
  test('WebGL2 + pthreads mid-frame fiber reaches DONE without renderer crash', async ({ page, testLogger }) => {
    await page.goto('/standalone/coroutine-pthread/gl_repro_pt.html');
    await tryLoadApp(page, 25000).catch(() => {});

    await expect
      .poll(() => testLogger.consoleLogs.some((l) => l.includes('[REPRO] DONE')), {
        timeout: 30000,
        message: 'should reach [REPRO] DONE (GL + pthreads mid-frame rewind survived)',
      })
      .toBe(true);
  });

  // Probe #8: a VIRTUAL call via invoke_vi -> instrumented dynCall_vi made from the
  // asyncify-rewound frame AFTER a coroutine round-trip. This is the exact factor the
  // KiCad crash has that nested_repro lacked: PCB_EDIT_FRAME's ctor calls the virtual
  // setupUIConditions() after InvokeTool's first coroutine unwinds/rewinds the ctor stack.
  test('post-coroutine virtual call (invoke_vi->dynCall_vi) reaches DONE without renderer crash', async ({ page, testLogger }) => {
    await page.goto('/standalone/coroutine-pthread/vcall_repro.html');
    await tryLoadApp(page, 25000).catch(() => {});

    await expect
      .poll(() => testLogger.consoleLogs.some((l) => l.includes('[REPRO] DONE')), {
        timeout: 30000,
        message: 'should reach [REPRO] DONE (virtual call from the rewound frame survived)',
      })
      .toBe(true);

    expect(
      testLogger.consoleLogs.some((l) => l.includes('post-coroutine virtual call returned OK')),
      'the post-coroutine virtual call should have completed'
    ).toBe(true);
  });
});