add watch mode, add new reporters

Author: olton

__tests__/simple.test.js

@@ -1,3 +1,3 @@
 test(`Simple test`, () => {
-    expect(1).toBe(2)
+    expect(1).toBe(1)
 })

cli/easytest.js

@@ -22,6 +22,11 @@ const argv = yargs(hideBin(process.argv))
         type: 'boolean',
         description: 'Run in observation mode'
     })
+    .option('parallel', {
+        alias: 'p',
+        type: 'boolean',
+        description: 'Run in parallel mode'
+    })
     .option('include', {
         alias: 'i',
         type: 'string',

src/core/parallel-runner.js

@@ -2,7 +2,7 @@ import { Worker } from 'worker_threads';
 import path from 'path';
 import { fileURLToPath } from 'url';
 
-// Получаем правильный путь к worker.js относительно текущего модуля
+// Отримуємо правильний шлях до worker.js відносно поточного модуля
 const __dirname = path.dirname(fileURLToPath(import.meta.url));
 const workerPath = path.join(__dirname, '..', 'workers', 'worker.js');
 
@@ -12,12 +12,12 @@ export async function parallel(testQueue, maxWorkers = 4) {
     let failedTests = 0;
     let coverage = [];
 
-    // Разделяем файлы на группы для параллельного запуска
+    // Розділяємо файли на групи для паралельного запуску
     for (let i = 0; i < files.length; i += maxWorkers) {
         chunks.push(files.slice(i, i + maxWorkers));
     }
 
-    // Выполняем тесты для каждого чанка
+    // Виконуємо тести для кожного чанка
     for (const chunk of chunks) {
         const workerPromises = chunk.map(file => {
             return new Promise((resolve, reject) => {
@@ -54,12 +54,12 @@ export async function parallel(testQueue, maxWorkers = 4) {
             });
         });
 
-        // Ждем завершения всех тестов в текущем чанке
+        // Чекаємо завершення всіх тестів у поточному чанку
         const results = await Promise.all(workerPromises);
         failedTests += results.reduce((sum, val) => sum + val, 0);
     }
 
-    // Возвращаем количество проваленных тестов и данные о покрытии
+    // Повертаємо кількість провалених тестів та дані про покриття
     return {
         failedTests,
         coverage

src/core/runner.js

@@ -25,7 +25,7 @@ const setupAndTeardown = async (funcs, type) => {
 
 export const runner = async (queue, options) => {
     const startTime = process.hrtime()
-    const {verbose, test: spec, skip} = options
+    const {verbose, test: spec, skip, parallel} = options
 
     let passedTests = 0
     let failedTests = 0
@@ -39,7 +39,7 @@ export const runner = async (queue, options) => {
         }
         totalTestCount += q[1].tests.length;
     }
-    if (!verbose) {
+    if (!verbose && !parallel) {
         log(`\n`)
         progressBar = new ProgressBar(totalTestCount);
     }
@@ -134,7 +134,9 @@ export const runner = async (queue, options) => {
                     if (verbose) {
                         logExpect(test.name, expect, testDuration)
                     } else {
-                        progressBar && progressBar.increment();
+                        if (!parallel) {
+                            progressBar && progressBar.increment();
+                        }
                     }
                 }
 
@@ -197,7 +199,9 @@ export const runner = async (queue, options) => {
                 if (verbose) {
                     logExpect(test.name, expect)
                 } else {
-                    progressBar && progressBar.increment();
+                    if (!parallel) { 
+                        progressBar && progressBar.increment();
+                    }
                 }
             }
         }
@@ -209,16 +213,19 @@ export const runner = async (queue, options) => {
     const [seconds, nanoseconds] = process.hrtime(startTime);
     const duration = (seconds * 1e9 + nanoseconds) / 1e6;
 
-    log(`\n`)
+    if (!parallel) { log(`\n`) }
+    
     for (const [file, result] of Object.entries(global.testResults)) {
         const fileStatus = result.completed ? chalk.green('🟢') : chalk.red('🔴')
         log(`${fileStatus} ${file}...${result.completed ? chalk.green("OK") : chalk.red("FAIL")} 🕑 ${chalk.whiteBright(`${result.duration} ms`)}`)
     }
 
-    log(chalk.gray(`------------------------------------------------`))
-    log(`${chalk.gray("Tests completed in")} ${chalk.whiteBright.bold(duration)} ms`)
-    log(`${chalk.gray("Total")}: ${chalk.blue.bold(totalTests)}, ${chalk.gray("Passed")}: ${chalk.green.bold(passedTests)}, ${chalk.gray("Failed")}: ${chalk.red.bold(failedTests)}`)
-    log(`\n`)
+    if (!parallel) {
+        log(chalk.gray(`------------------------------------------------`))
+        log(`${chalk.gray("Tests completed in")} ${chalk.whiteBright.bold(duration)} ms`)
+        log(`${chalk.gray("Total")}: ${chalk.blue.bold(totalTests)}, ${chalk.gray("Passed")}: ${chalk.green.bold(passedTests)}, ${chalk.gray("Failed")}: ${chalk.red.bold(failedTests)}`)
+        log(`\n`)
+    } 
 
     return failedTests
 }

src/workers/worker.js

@@ -10,26 +10,26 @@ import { hooksRegistry } from '../core/hooks.js';
 import { registerGlobals } from '../core/registry.js';
 import { coverageFilter } from '../core/coverage.js';
 
-// Получаем данные о файле теста из основного потока
+// Отримуємо дані про файл тесту з основного потоку
 const { file, config: workerConfig } = workerData;
 
-// Асинхронное выполнение тестов в отдельном потоке
+// Асинхронне виконання тестів в окремому потоці
 async function runTest() {
-    // Инициализация глобальных объектов
+    // Ініціалізація глобальних об'єктів
     global.config = workerConfig;
     global.passed = {};
 
-    // Регистрируем глобальные функции и переменные
+    // Реєструємо глобальні функції та змінні
     registerGlobals();
 
-    // Настройка DOM если требуется
-    if (config.dom) {
+    // Налаштування DOM якщо потрібно
+    if (global.config.dom) {
         await DOM.setup();
     }
 
-    // Инициализация сессии для измерения покрытия кода
+    // Ініціалізація сесії для вимірювання покриття коду
     let session;
-    let coverage = null; 
+    let coverage = null;
     session = new inspector.Session();
     session.connect();
 
@@ -39,40 +39,40 @@ async function runTest() {
         detailed: true
     });
 
-    // Подготавливаем очередь для тестируемого файла
+    // Підготовка черги для тестованого файлу
     testQueue.setCurrentFile(file);
     hooksRegistry.clearFileLevelHooks();
 
-    // Импортируем тестовый файл
+    // Імпорт тестового файлу
     const fileUrl = pathToFileURL(realpathSync(file)).href;
     await import(fileUrl);
 
-    // Создаем временную очередь только для этого файла
+    // Створюємо тимчасову чергу тільки для цього файлу
     const fileQueue = new Map();
     fileQueue.set(file, testQueue.getQueue().get(file));
 
-    // Запускаем тесты для этого файла
-    const result = await runner(fileQueue);
+    // Запускаємо тести для цього файлу
+    const result = await runner(fileQueue, config);
 
-    // Собираем информацию о покрытии кода
+    // Збираємо інформацію про покриття коду
     const coverageData = await session.post('Profiler.takePreciseCoverage');
     await session.post('Profiler.stopPreciseCoverage');
     coverage = coverageFilter(coverageData);
 
-    // Очищаем DOM, если он был инициализирован
-    if (config.dom) {
+    // Очищення DOM, якщо він був ініціалізований
+    if (global.config.dom) {
         await DOM.bye();
     }
 
-    // Отправляем результат обратно в основной поток
+    // Відправляємо результат назад в основний потік
     parentPort.postMessage({
         file,
         result,
         coverage
     });
 }
 
-// Обработка ошибок
+// Обробка помилок
 process.on('unhandledRejection', (reason) => {
     parentPort.postMessage({
         file,
@@ -85,7 +85,7 @@ process.on('unhandledRejection', (reason) => {
     process.exit(1);
 });
 
-// Запускаем выполнение тестов
+// Запускаємо виконання тестів
 runTest().catch(error => {
     parentPort.postMessage({
         file,