1465050545

Build Type

github

Committed by GitHub

Commit Message

Merge 9f70e6a28 into 0da5d93d7

Pull Request Pull Request #295: Add timing functionality

Run Details

160 of 164 branches covered (97.56%)

Branch coverage included in aggregate %.

23 of 30 new or added lines in 4 files covered. (76.67%)

7 existing lines in 1 file now uncovered.

294 of 306 relevant lines covered (96.08%)

102.88 hits per line

Source File
Press 'n' to go to next uncovered line, 'b' for previous

67.74

/src/completion-listener.js

const Rx = require('rxjs');
const { bufferCount, switchMap, take, tap } = require('rxjs/operators');
const _ = require('lodash');

module.exports = class CompletionListener {
    constructor({ successCondition, scheduler, showTimings}) {
        this.successCondition = successCondition;
        this.scheduler = scheduler;
        this.showTimings = showTimings;
    }

    isSuccess(exitCodes) {
        switch (this.successCondition) {
        /* eslint-disable indent */
            case 'first':
                return exitCodes[0] === 0;

            case 'last':
                return exitCodes[exitCodes.length - 1] === 0;

            default:
                return exitCodes.every(exitCode => exitCode === 0);
            /* eslint-enable indent */
        }
    }

    printExitInfoTimingTableIfValid(exitInfos) {
        if (!Array.isArray(exitInfos)) { return exitInfos; }

        const exitInfoTable = _(exitInfos)
            .map(({ command, timings, index, killed, exitCode }) => {
                const readableDurationMs = (timings.endDate - timings.startDate).toLocaleString();
                return {
                    'call-index': index,
                    name: command.name,
                    duration: `~${readableDurationMs}ms`,
                    'exit-code': exitCode,
                    killed,
                    command: command.command,
                };
            })
            .sortBy('duration')
            .value();

        console.log('\nTimings:');
        console.table(exitInfoTable);
        return exitInfos;
    };

    listen(commands) {
        const closeStreams = commands.map(command => command.close);
        return Rx.merge(...closeStreams)
            .pipe(
                bufferCount(closeStreams.length),
                switchMap(exitInfos =>
                    this.isSuccess(exitInfos.map(({ exitCode }) => exitCode))
                        ? Rx.of(exitInfos, this.scheduler)
                        : Rx.throwError(exitInfos, this.scheduler)
                ),
                take(1),
                tap((exitInfos) =>  {
                    if (this.showTimings) { this.printExitInfoTimingTableIfValid(exitInfos); }
                })
            )
            .toPromise();
    }
};

1	const Rx = require('rxjs');	18✔
2	const { bufferCount, switchMap, take, tap } = require('rxjs/operators');	18✔
3	const _ = require('lodash');	18✔
4
5	module.exports = class CompletionListener {	18✔
6	constructor({ successCondition, scheduler, showTimings}) {
7	this.successCondition = successCondition;	144✔
8	this.scheduler = scheduler;	144✔
9	this.showTimings = showTimings;	144✔
10	}
11
12	isSuccess(exitCodes) {
13	switch (this.successCondition) {	63✔
14	/* eslint-disable indent */
15	case 'first':
16	return exitCodes[0] === 0;	18✔
17
18	case 'last':
19	return exitCodes[exitCodes.length - 1] === 0;	18✔
20
21	default:
22	return exitCodes.every(exitCode => exitCode === 0);	54✔
23	/* eslint-enable indent */
24	}
25	}
26
27	printExitInfoTimingTableIfValid(exitInfos) {
NEW UNCOV 28	if (!Array.isArray(exitInfos)) { return exitInfos; }	×
29
NEW UNCOV 30	const exitInfoTable = _(exitInfos)	×
31	.map(({ command, timings, index, killed, exitCode }) => {
NEW UNCOV 32	const readableDurationMs = (timings.endDate - timings.startDate).toLocaleString();	×
NEW UNCOV 33	return {	×
34	'call-index': index,
35	name: command.name,
36	duration: `~${readableDurationMs}ms`,
37	'exit-code': exitCode,
38	killed,
39	command: command.command,
40	};
41	})
42	.sortBy('duration')
43	.value();
44
NEW UNCOV 45	console.log('\nTimings:');	×
NEW UNCOV 46	console.table(exitInfoTable);	×
NEW UNCOV 47	return exitInfos;	×
48	};
49
50	listen(commands) {
51	const closeStreams = commands.map(command => command.close);	315✔
52	return Rx.merge(...closeStreams)	144✔
53	.pipe(
54	bufferCount(closeStreams.length),
55	switchMap(exitInfos =>
56	this.isSuccess(exitInfos.map(({ exitCode }) => exitCode))	126✔
57	? Rx.of(exitInfos, this.scheduler)
58	: Rx.throwError(exitInfos, this.scheduler)
59	),
60	take(1),
61	tap((exitInfos) => {
62	if (this.showTimings) { this.printExitInfoTimingTableIfValid(exitInfos); }	36!
63	})
64	)
65	.toPromise();
66	}
67	};

open-cli-tools / concurrently / 1465050545

Source File Press 'n' to go to next uncovered line, 'b' for previous

Source File
Press 'n' to go to next uncovered line, 'b' for previous