test: @putout/engine-reporter: subscribe: coverage

Author: coderaiser

.nycrc.json

@@ -8,7 +8,6 @@
         "**/.*.*",
         "**/scripts",
         "**/register.mjs",
-        "packages/engine-reporter/**/subscribe.*",
         "packages/*/coverage",
         "packages/*/bin",
         "packages/*/test",

packages/engine-reporter/.nycrc.json

@@ -7,7 +7,6 @@
         "test",
         "coverage",
         ".*.*",
-        "**/subscribe.js",
         "**/*.config.*"
     ],
     "branches": 100,

packages/engine-reporter/lib/subscribe.js

@@ -1,7 +1,7 @@
-import {keypress} from '@putout/cli-keypress';
-import {createReport} from './index.js';
+import {keypress as _keypress} from '@putout/cli-keypress';
+import {createReport as _createReport} from './index.js';
 
-export const subscribe = async ({write, cwd, args, worker, exit}) => {
+export const subscribe = async ({write, cwd, args, worker, exit, createReport = _createReport, keypress = _keypress}) => {
     const {isStop} = keypress();
     const report = await createReport({
         args,

packages/engine-reporter/lib/subscribe.spec.js

@@ -0,0 +1,244 @@
+import {EventEmitter} from 'node:events';
+import {setTimeout} from 'node:timers/promises';
+import {test, stub} from 'supertape';
+import {subscribe} from './subscribe.js';
+
+const {assign} = Object;
+
+test('putout: engine-reporter: subscribe: keypress', async (t) => {
+    const worker = new EventEmitter();
+    const isStop = stub();
+    const keypress = stub().returns({
+        isStop,
+    });
+    
+    const report = stub();
+    const createReport = stub().returns(report);
+    const write = stub();
+    
+    const args = [];
+    const cwd = '/';
+    const exit = stub();
+    
+    await subscribe({
+        write,
+        cwd,
+        args,
+        worker,
+        exit,
+        createReport,
+        keypress,
+    });
+    
+    t.calledWithNoArgs(keypress);
+    t.end();
+});
+
+test('putout: engine-reporter: subscribe: createReport', async (t) => {
+    const worker = new EventEmitter();
+    const isStop = stub();
+    const keypress = stub().returns({
+        isStop,
+    });
+    
+    const report = stub();
+    const createReport = stub().returns(report);
+    const write = stub();
+    
+    const args = [];
+    const cwd = '/';
+    const exit = stub();
+    
+    await subscribe({
+        write,
+        cwd,
+        args,
+        worker,
+        exit,
+        createReport,
+        keypress,
+    });
+    
+    const expected = {
+        args,
+        cwd,
+        exit,
+    };
+    
+    t.calledWith(createReport, [expected]);
+    t.end();
+});
+
+test('putout: engine-reporter: subscribe: worker: message: progress', async (t) => {
+    const worker = new EventEmitter();
+    const isStop = stub();
+    const keypress = stub().returns({
+        isStop,
+    });
+    
+    const report = stub();
+    const createReport = stub().returns(report);
+    const write = stub();
+    
+    const args = [];
+    const cwd = '/';
+    const exit = stub();
+    
+    await subscribe({
+        write,
+        cwd,
+        args,
+        worker,
+        exit,
+        createReport,
+        keypress,
+    });
+    
+    const data = 'hello';
+    
+    worker.emit('message', ['progress', data]);
+    
+    t.calledWith(report, [data]);
+    t.end();
+});
+
+test('putout: engine-reporter: subscribe: worker: message: progress: write', async (t) => {
+    const worker = new EventEmitter();
+    const isStop = stub();
+    const keypress = stub().returns({
+        isStop,
+    });
+    
+    const report = stub();
+    const createReport = stub().returns(report);
+    const write = stub();
+    
+    const args = [];
+    const cwd = '/';
+    const exit = stub();
+    
+    write.hello = 'ss';
+    
+    await subscribe({
+        write,
+        cwd,
+        args,
+        worker,
+        exit,
+        createReport,
+        keypress,
+    });
+    
+    worker.emit('message', ['progress', 'hello']);
+    
+    await setTimeout(1);
+    
+    t.calledWith(write, ['']);
+    t.end();
+});
+
+test('putout: engine-reporter: subscribe: worker: message: progress: write: line', async (t) => {
+    const worker = new EventEmitter();
+    const isStop = stub();
+    const keypress = stub().returns({
+        isStop,
+    });
+    
+    const report = stub().returns('world');
+    const createReport = stub().returns(report);
+    const write = stub();
+    
+    const args = [];
+    const cwd = '/';
+    const exit = stub();
+    
+    await subscribe({
+        write,
+        cwd,
+        args,
+        worker,
+        exit,
+        createReport,
+        keypress,
+    });
+    
+    worker.emit('message', ['progress', 'hello']);
+    
+    await setTimeout(1);
+    
+    t.calledWith(write, ['world']);
+    t.end();
+});
+
+test('putout: engine-reporter: subscribe: worker: message', async (t) => {
+    const worker = new EventEmitter();
+    const isStop = stub();
+    const keypress = stub().returns({
+        isStop,
+    });
+    
+    const report = stub();
+    const createReport = stub().returns(report);
+    const write = stub();
+    
+    const args = [];
+    const cwd = '/';
+    const exit = stub();
+    
+    await subscribe({
+        write,
+        cwd,
+        args,
+        worker,
+        exit,
+        createReport,
+        keypress,
+    });
+    
+    const data = 'hello';
+    
+    worker.emit('message', ['start', data]);
+    
+    t.notCalled(report);
+    t.end();
+});
+
+test('putout: engine-reporter: subscribe: worker: message: progress: isStop', async (t) => {
+    const postMessage = stub();
+    const worker = new EventEmitter();
+    
+    assign(worker, {
+        postMessage,
+    });
+    const isStop = stub().returns(true);
+    
+    const keypress = stub().returns({
+        isStop,
+    });
+    
+    const report = stub().returns('world');
+    const createReport = stub().returns(report);
+    const write = stub();
+    
+    const args = [];
+    const cwd = '/';
+    const exit = stub();
+    
+    await subscribe({
+        write,
+        cwd,
+        args,
+        worker,
+        exit,
+        createReport,
+        keypress,
+    });
+    
+    worker.emit('message', ['progress', 'hello']);
+    await setTimeout(1);
+    
+    const expected = ['stop'];
+    
+    t.calledWith(postMessage, [expected]);
+    t.end();
+});