feat: redirect console

packages/peeky-runner/src/message.ts

@@ -9,6 +9,7 @@ export interface WorkerRemoteMethods {
   onTestError: (suiteId: string, testId: string, duration: number, error: TestErrorData) => void
   onTestSuccess: (suiteId: string, testId: string, duration: number) => void
   transform: (id: string) => Promise<TransformResult>
+  onLog: (suiteId: string, testId: string, type: 'stdout' | 'stderr', text: string) => void
 }
 
 export interface TestErrorData {

packages/peeky-runner/src/runner.ts

@@ -76,6 +76,14 @@ export async function setupRunner (options: RunnerOptions) {
         const test = suite.tests.find(t => t.id === testId)
         consola.log(chalk.green(`${chalk.bgGreenBright.black.bold(' PASS ')} ${suite.title} › ${chalk.bold(test.title)} ${chalk.grey(`(${formatDurationToString(duration)})`)}`))
       },
+
+      onLog: (suiteId, testId, type, text) => {
+        const suite = suiteMap[suiteId]
+        const test = suite?.tests.find(t => t.id === testId)
+        consola.log(chalk.dim(`\n[${type}] ${test ? `${suite.title} › ${chalk.bold(test.title)}` : 'unknown test'}\n`))
+        process[type].write(text)
+        process[type].write('\n')
+      },
     }, handleMessage)
 
     const result = await pool.run({

packages/peeky-runner/src/runtime/console.ts

@@ -0,0 +1,26 @@
+import { Console } from 'console'
+import { Writable } from 'stream'
+import { currentSuite, currentTest } from './global-context.js'
+import { toMainThread } from './message.js'
+
+export function setupConsole () {
+  function createWritable (type: 'stdout' | 'stderr') {
+    return new Writable({
+      write: (chunk, enconding, callback) => {
+        toMainThread().onLog(currentSuite?.id, currentTest?.id, type, String(chunk))
+        callback()
+      },
+    })
+  }
+  const stdout = createWritable('stdout')
+  const stderr = createWritable('stderr')
+
+  const console = new Console({
+    stdout,
+    stderr,
+    colorMode: true,
+    groupIndentation: 2,
+  })
+
+  globalThis.console = console
+}

packages/peeky-runner/src/runtime/global-context.ts

@@ -0,0 +1,12 @@
+import { Test, TestSuite } from '../types.js'
+
+export let currentSuite: TestSuite
+export let currentTest: Test
+
+export function setCurrentSuite (suite: TestSuite) {
+  currentSuite = suite
+}
+
+export function setCurrentTest (test: Test) {
+  currentTest = test
+}

packages/peeky-runner/src/runtime/run-tests.ts

@@ -1,12 +1,15 @@
 import { basename } from 'path'
 import { performance } from 'perf_hooks'
 import type { Context, Test } from '../types'
+import { setCurrentSuite, setCurrentTest } from './global-context.js'
 import { toMainThread } from './message.js'
 
 export async function runTests (ctx: Context) {
   const { default: sinon } = await import('sinon')
 
   for (const suite of ctx.suites) {
+    setCurrentSuite(suite)
+
     let testsToRun: Test[]
     const onlyTests = suite.tests.filter(t => t.flag === 'only')
     if (onlyTests.length) {
@@ -35,6 +38,7 @@ export async function runTests (ctx: Context) {
       }
 
       for (const test of testsToRun) {
+        setCurrentTest(test)
         sinon.restore()
 
         for (const handler of suite.beforeEachHandlers) {
@@ -65,6 +69,8 @@ export async function runTests (ctx: Context) {
         for (const handler of suite.afterEachHandlers) {
           await handler()
         }
+
+        setCurrentTest(null)
       }
 
       for (const handler of suite.afterAllHandlers) {
@@ -83,5 +89,7 @@ export async function runTests (ctx: Context) {
       testErrors: suite.testErrors,
       otherErrors: suite.otherErrors,
     }, performance.now() - suiteTime)
+
+    setCurrentSuite(null)
   }
 }

packages/peeky-runner/src/runtime/setup.ts

@@ -1,4 +1,5 @@
 import { PeekyConfig, setupConfigLoader } from '@peeky/config'
+import { setupConsole } from './console.js'
 
 let initialized = false
 export let baseConfig: PeekyConfig
@@ -12,5 +13,7 @@ export async function setupWorker () {
   await configLoader.destroy()
   baseConfig = config
 
+  setupConsole()
+
   initialized = true
 }