Press n or j to go to the next uncovered block, b, p or k for the previous block.
| 1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 19 20 21 22 23 24 25 26 27 28 29 30 31 32 33 34 35 36 37 38 39 40 41 42 43 44 45 46 47 48 49 50 51 52 53 54 55 56 57 58 59 60 61 62 63 64 65 66 67 68 69 70 71 72 73 74 75 76 77 78 79 80 81 82 83 84 85 86 87 88 89 90 91 92 93 94 95 96 97 98 99 100 | 1x 1x 1x 1x 1x 1x 1x 1x 1x 1x 1x 1x 1x 1x 1x 1x 53x 53x 53x 53x 53x 53x 53x 53x 53x 53x 53x 53x 53x 53x 53x 53x 296x 296x 53x 53x 53x 53x 53x 53x 53x 53x 53x 53x 53x 53x 53x 53x 53x 288x 241x 241x 288x 53x 53x 1x 1x 1x 1x 1x 1x 1x 1x 1x 1x 1x 1x 1x 1x 1x 1x 1x 1x 1x 1x 1x 1x 1x 1x 1x 1x 1x 1x 1x 1x 1x 21x 21x 21x 21x 21x 53x 21x | import {TestExecutor, type ITestLogger} from '@feasibleone/blong-chain';
import {withProgress} from '@feasibleone/blong-lib';
import assert from 'node:assert';
type Step = (a: typeof assert, results: object) => object | Promise<object>;
type Steps = (Promise<(Step | Step[]) & {name: string}>[] | Step[]) & {
name: string;
autoSnapshot?: boolean;
mask?: string[];
};
interface ITestContext {
test: (name: string, fn: (t: unknown) => void | Promise<void>) => unknown;
}
const runSteps =
(
steps: Steps,
log?: ITestLogger,
results = {$meta: {}},
): ((t: ITestContext) => Promise<void>) =>
async (t: ITestContext) => {
// Use new parallel TestExecutor for improved performance
const executor = new TestExecutor({
concurrency: 10,
log,
autoSnapshot: (steps as Steps).autoSnapshot,
mask: (steps as Steps).mask,
});
// Resolve any promises in steps array
const resolvedSteps: (Step | Step[])[] = [];
for (const stepPromise of steps) {
resolvedSteps.push(await stepPromise);
}
// Execute with parallel executor, passing test context for nested output
try {
await withProgress(
log,
`run ${steps.name}`,
executor.execute(resolvedSteps, results.$meta || {}, t),
{
getProgress: () => {
const progress = executor.getProgress();
return {done: progress.completedSteps, total: progress.totalSteps};
},
},
);
// Copy results from executor context to results object
const progress = executor.getProgress();
for (const [name, stepProgress] of progress.steps) {
if (stepProgress.result !== undefined) {
(results as Record<string, unknown>)[name] = stepProgress.result;
}
}
} catch (error) {
// Preserve error with context
throw error;
}
};
// const runStepsSerial =
// (
// steps: Steps,
// results = {$meta: {}} as Record<string, unknown>,
// ): ((t: ITestContext) => Promise<void>) =>
// async (t: ITestContext) => {
// for (const [index, stepPromise] of steps.entries()) {
// const step = await stepPromise;
// if (Array.isArray(step))
// t.test(
// step.name || `step ${index + 1}`,
// runStepsSerial(step, results) as (t: unknown) => void | Promise<void>,
// );
// else if (typeof step === 'function') {
// const name = step.name;
// if (name) {
// await t.test(name, async () => {
// const result = await step(assert, results);
// if (results) (results as Record<string, unknown>)[name] = result;
// });
// } else {
// await t.test(`step ${index + 1}`, async () => {
// await step(assert, results);
// });
// }
// }
// }
// };
export default async (
test: ITestContext,
log?: ITestLogger,
): Promise<(steps: Steps) => unknown> => {
const context = test || (await import('node:test')).default;
return steps =>
context.test(steps.name, runSteps(steps, log) as (t: unknown) => void | Promise<void>);
};
|