mmintel/gridpilot.gg
1
0
Fork 0
Code Issues Pull Requests 1 Actions Packages Projects Releases Wiki Activity

wip

Browse Source
This commit is contained in:
Marc Mintel
2025-12-01 17:27:56 +01:00
parent e7ada8aa23
commit 98a09a3f2b
41 changed files with 2341 additions and 1525 deletions
Download Patch File Download Diff File Expand all files Collapse all files

151
tests/e2e/workflows/full-hosted-session.workflow.e2e.test.ts
View File

@@ -4,12 +4,12 @@ import {
FixtureServer,
} from 'packages/infrastructure/adapters/automation';
import { InMemorySessionRepository } from 'packages/infrastructure/repositories/InMemorySessionRepository';
import { MockAutomationEngineAdapter } from 'packages/infrastructure/adapters/automation/engine/MockAutomationEngineAdapter';
import { MockBrowserAutomationAdapter } from 'packages/infrastructure/adapters/automation/engine/MockBrowserAutomationAdapter';
import { AutomationEngineAdapter } from 'packages/infrastructure/adapters/automation/engine/AutomationEngineAdapter';
import { StartAutomationSessionUseCase } from 'packages/application/use-cases/StartAutomationSessionUseCase';
import { StepId } from 'packages/domain/value-objects/StepId';
import { PinoLogAdapter } from 'packages/infrastructure/adapters/logging/PinoLogAdapter';
describe('Workflow – hosted session end-to-end (fixture-backed)', () => {
describe('Workflow – hosted session end-to-end (fixture-backed, real stack)', () => {
let server: FixtureServer;
let adapter: PlaywrightAutomationAdapter;
let baseUrl: string;
@@ -19,16 +19,21 @@ describe('Workflow – hosted session end-to-end (fixture-backed)', () => {
const info = await server.start();
baseUrl = info.url;
const logger = new PinoLogAdapter();
adapter = new PlaywrightAutomationAdapter(
{
headless: true,
timeout: 10_000,
baseUrl,
mode: 'mock',
mode: 'real',
userDataDir: '',
},
logger,
);
const connectResult = await adapter.connect();
const connectResult = await adapter.connect(false);
expect(connectResult.success).toBe(true);
expect(adapter.isConnected()).toBe(true);
});
afterAll(async () => {
@@ -36,114 +41,58 @@ describe('Workflow – hosted session end-to-end (fixture-backed)', () => {
await server.stop();
});
function createFixtureEngine() {
function createRealEngine() {
const repository = new InMemorySessionRepository();
const engine = new MockAutomationEngineAdapter(adapter, repository);
const engine = new AutomationEngineAdapter(adapter, repository);
const useCase = new StartAutomationSessionUseCase(engine, adapter, repository);
return { repository, engine, useCase };
}
it('runs 1–17 from use case and stops automation at manual Track Conditions (STOPPED_AT_STEP_18)', async () => {
const { repository, engine, useCase } = createFixtureEngine();
it(
'runs 1–17 from use case and stops automation at manual Track Conditions (STOPPED_AT_STEP_18)',
async () => {
const { repository, engine, useCase } = createRealEngine();
const config: any = {
sessionName: 'Fixture E2E – full workflow',
trackId: 'spa',
carIds: ['dallara-f3'],
};
const config: any = {
sessionName: 'Fixture E2E – full workflow (real stack)',
trackId: 'spa',
carIds: ['dallara-f3'],
};
const dto = await useCase.execute(config);
const dto = await useCase.execute(config);
expect(dto.state).toBe('PENDING');
expect(dto.currentStep).toBe(1);
expect(dto.state).toBe('PENDING');
expect(dto.currentStep).toBe(1);
await engine.executeStep(StepId.create(1), config);
await adapter.navigateToPage(server.getFixtureUrl(1));
const deadline = Date.now() + 60_000;
let finalSession = null;
await engine.executeStep(StepId.create(1), config);
// Poll repository until automation loop completes
// MockAutomationEngineAdapter drives the step orchestrator internally.
// Session should end in STOPPED_AT_STEP_18 after completing automated step 17.
// eslint-disable-next-line no-constant-condition
while (true) {
const sessions = await repository.findAll();
finalSession = sessions[0] ?? null;
const deadline = Date.now() + 60_000;
let finalSession = null;
if (finalSession && finalSession.state.isStoppedAtStep18()) {
break;
// eslint-disable-next-line no-constant-condition
while (true) {
const sessions = await repository.findAll();
finalSession = sessions[0] ?? null;
if (finalSession && finalSession.state.isStoppedAtStep18()) {
break;
}
if (Date.now() > deadline) {
throw new Error('Timed out waiting for automation workflow to complete');
}
await new Promise((resolve) => setTimeout(resolve, 250));
}
if (Date.now() > deadline) {
throw new Error('Timed out waiting for automation workflow to complete');
}
await new Promise((resolve) => setTimeout(resolve, 250));
}
expect(finalSession).not.toBeNull();
expect(finalSession!.state.isStoppedAtStep18()).toBe(true);
expect(finalSession!.currentStep.value).toBe(17);
expect(finalSession!.startedAt).toBeInstanceOf(Date);
expect(finalSession!.completedAt).toBeInstanceOf(Date);
expect(finalSession!.errorMessage).toBeUndefined();
});
it('marks session as FAILED on mid-flow automation error with diagnostics', async () => {
const repository = new InMemorySessionRepository();
const failingAdapter = new MockBrowserAutomationAdapter({
simulateFailures: true,
failureRate: 1.0,
});
await failingAdapter.connect();
const engine = new MockAutomationEngineAdapter(
failingAdapter as any,
repository,
);
const useCase = new StartAutomationSessionUseCase(
engine,
failingAdapter as any,
repository,
);
const config: any = {
sessionName: 'Fixture E2E – failure workflow',
trackId: 'spa',
carIds: ['dallara-f3'],
};
const dto = await useCase.execute(config);
expect(dto.state).toBe('PENDING');
expect(dto.currentStep).toBe(1);
await engine.executeStep(StepId.create(1), config);
const deadline = Date.now() + 30_000;
let finalSession = null;
// Poll for failure state
// eslint-disable-next-line no-constant-condition
while (true) {
const sessions = await repository.findAll();
finalSession = sessions[0] ?? null;
if (finalSession && finalSession.state.isFailed()) {
break;
}
if (Date.now() > deadline) {
throw new Error('Timed out waiting for automation workflow to fail');
}
await new Promise((resolve) => setTimeout(resolve, 200));
}
await failingAdapter.disconnect();
expect(finalSession).not.toBeNull();
expect(finalSession!.state.isFailed()).toBe(true);
expect(finalSession!.errorMessage).toBeDefined();
});
expect(finalSession).not.toBeNull();
expect(finalSession!.state.isStoppedAtStep18()).toBe(true);
expect(finalSession!.currentStep.value).toBe(17);
expect(finalSession!.startedAt).toBeInstanceOf(Date);
expect(finalSession!.completedAt).toBeInstanceOf(Date);
expect(finalSession!.errorMessage).toBeUndefined();
},
);
});