Compare commits

..

No commits in common. "master" and "v1.4.3" have entirely different histories.

16 changed files with 43 additions and 285 deletions

View file

@ -111,11 +111,9 @@ $ eltro --watch my_watch_name --npm build
Not only does eltro allow you to use any assertion library of your own choosing, it also comes with it's own assertion library based on node's default [assert](https://nodejs.org/api/assert.html) with a few extra methods:
* `assert.equalWithMargin(value, test, margin, [message])`: Check if number value is equal to test with error margin.
* `assert.notOk(value, [message])`: Assert value is not ok.
* `assert.match(value, test, [message])`: Check if value matches RegExp test.
* `assert.notMatch(value, [message])`: Check if value does not match RegExp test.
* `assert.throwsAndCatch(fn, [message])`: Checks if function fn throws and returns the thrown error.
* `assert.isFulfilled(promise, [message])`: Assert the promise resolves.
* `assert.isRejected(promise, [message])`: Assert the promise gets rejects.

11
cli.mjs
View file

@ -27,20 +27,15 @@ function PrintHelp() {
process.exit(1)
}
function showErrorAndExit(message = '', err = null, code = 1, clean = false) {
if (!clean) {
console.log('')
}
function showErrorAndExit(message = '', err = null, code = 1) {
console.log('')
if (message) {
console.error(`\x1b[31m${message}\x1b[0m`)
}
if (err) {
printError(err, '', clean)
if (err.inner) {
return showErrorAndExit(null, err.inner, code, true)
}
printError(err)
} else {
PrintHelp()
}

View file

@ -57,14 +57,6 @@ assert.throwsAndCatch = (fn, message) => {
return err
}
assert.equalWithMargin = (value, test, margin = 0.005, message) => {
assert.strictEqual(typeof value, 'number', 'Value should be number')
assert.strictEqual(typeof test, 'number', 'Test should be number')
let difference = Math.abs(value - test)
assert.ok(difference <= margin, message || `${value} ± ${margin} != ${test} (difference of ${difference} > ${margin})`)
}
assert.isFulfilled = (promise, message) => {
return Promise.resolve(true)
.then(() => promise)

View file

@ -440,9 +440,9 @@ export function getFilesFromTarget(files, match, insidePath, grabAll, insideStar
})
}
export function printError(err, msg, clean = false) {
export function printError(err, msg) {
let before = msg || ''
if (!clean) console.error('')
console.error('')
console.error('\x1b[31m '
+ before + err.toString()
+ '\x1b[0m\n \x1b[90m'

View file

@ -117,7 +117,6 @@ process.on('uncaughtException', function(err) {
})
function Eltro() {
this.process = process
this.__timeout = 2000
this.hasExclusive = false
this.reporter = 'list'
@ -160,8 +159,8 @@ Eltro.prototype.begin = function() {
}
Eltro.prototype.__runTest = async function(stats, test, prefix = 'Test', child = null) {
if (this.reporter === 'list' && prefix === 'Test') {
this.process.stdout.write(' \x1b[90m? ' + test.name + '\x1b[0m')
if (this.reporter === 'list') {
process.stdout.write(' \x1b[90m? ' + test.name + '\x1b[0m')
}
let markRealTest = child || test
@ -280,24 +279,24 @@ Eltro.prototype.__runTest = async function(stats, test, prefix = 'Test', child =
this.captureOutsideExceptions = null
if (this.reporter === 'list') {
readline.clearLine(this.process.stdout, 0)
readline.cursorTo(this.process.stdout, 0, null)
readline.clearLine(process.stdout, 0)
readline.cursorTo(process.stdout, 0, null)
if (markRealTest.skipTest) {
this.process.stdout.write(' \x1b[94m- ' + markRealTest.name + '\x1b[0m\n')
process.stdout.write(' \x1b[94m- ' + markRealTest.name + '\x1b[0m\n')
} else if (!markRealTest.error) {
if (!test.name.startsWith('~')) {
this.process.stdout.write(' \x1b[32m√\x1b[90m ' + markRealTest.name + ' (' + markRealTest.totalTime + 'ms)\x1b[0m\n')
process.stdout.write(' \x1b[32m√\x1b[90m ' + markRealTest.name + ' (' + markRealTest.totalTime + 'ms)\x1b[0m\n')
}
} else if (prefix === 'Test') {
this.process.stdout.write(' \x1b[31m' + this.failedTests.length + ') ' + markRealTest.name + ' (' + markRealTest.totalTime + 'ms)\x1b[0m\n')
process.stdout.write(' \x1b[31m' + this.failedTests.length + ') ' + markRealTest.name + ' (' + markRealTest.totalTime + 'ms)\x1b[0m\n')
}
} else if (this.reporter === 'dot') {
if (markRealTest.skipTest) {
this.process.stdout.write('\x1b[94m.\x1b[0m')
} else if (markRealTest.error) {
this.process.stdout.write('\x1b[31m.\x1b[0m')
process.stdout.write('\x1b[94m.\x1b[0m')
} else if (!markRealTest.error) {
process.stdout.write('\x1b[32m.\x1b[0m')
} else if (prefix === 'Test') {
this.process.stdout.write('\x1b[32m.\x1b[0m')
process.stdout.write('\x1b[31m.\x1b[0m')
}
}
}
@ -305,7 +304,7 @@ Eltro.prototype.__runTest = async function(stats, test, prefix = 'Test', child =
Eltro.prototype.__runGroup = async function(g, stats) {
if (g.tests.length) {
if (this.reporter === 'list') {
this.process.stdout.write(' ' + g.name + '\n')
console.log(' ' + g.name)
}
}
if (g.before) {
@ -352,8 +351,8 @@ Eltro.prototype.__runGroup = async function(g, stats) {
Eltro.prototype.run = async function() {
if (this.reporter && this.reporter !== 'test') {
this.process.stdout.write('' + '\n')
this.process.stdout.write('' + '\n')
console.log('')
console.log('')
}
captureUnknownErrors(this)
@ -382,23 +381,23 @@ Eltro.prototype.run = async function() {
}
}
} else if (this.reporter) {
this.process.stdout.write('' + '\n')
this.process.stdout.write('' + '\n')
console.log('')
console.log('')
if (stats.passed) {
this.process.stdout.write(' \x1b[32m' + stats.passed + ' passing \x1b[90m(' + (end[0] * 1000 + Math.round(end[1] / 1000000)) + 'ms)\x1b[0m' + '\n')
console.log(' \x1b[32m' + stats.passed + ' passing \x1b[90m(' + (end[0] * 1000 + Math.round(end[1] / 1000000)) + 'ms)\x1b[0m')
}
if (stats.failed) {
this.process.stdout.write(' \x1b[31m' + stats.failed + ' failing\x1b[0m' + '\n')
console.log(' \x1b[31m' + stats.failed + ' failing\x1b[0m')
}
if (stats.skipped) {
this.process.stdout.write(' \x1b[94m' + stats.skipped + ' pending\x1b[0m' + '\n')
console.log(' \x1b[94m' + stats.skipped + ' pending\x1b[0m')
}
this.process.stdout.write('' + '\n')
console.log('')
if (this.failedTests.length) {
for (let x = 0; x < this.failedTests.length; x++) {
let test = this.failedTests[x];
this.process.stdout.write(' ' + (x + 1) + ') ' + test.name + ':' + '\n')
console.log(' ' + (x + 1) + ') ' + test.name + ':')
printError(test.error)
}
}

View file

@ -4,41 +4,25 @@ import { spawn, exec } from 'child_process'
const execPromise = promisify(exec)
export default function kill(pid, signal) {
let pids = new Set([pid])
let pids = new Set()
let getSpawn = null
let getPids = null
switch (process.platform) {
case 'win32':
return execPromise('taskkill /pid ' + pid + ' /T /F').then(() => pids)
return execPromise('taskkill /pid ' + pid + ' /T /F')
case 'darwin':
getSpawn = function(parentPid) {
return spawn('pgrep', ['-P', parentPid])
}
getPids = function(data) {
return data.match(/\d+/g).map(Number)
}
break
default:
getSpawn = function (parentPid) {
return exec('ps -opid="" -oppid="" | grep ' + parentPid)
}
getPids = function(data, parentPid) {
let output = data.trim().split('\n')
return output.map(line => {
let [child, parent] = line.trim().split(/ +/)
if (Number(parent) === parentPid) {
return Number(child)
}
return 0
}).filter(x => x)
return spawn('ps', ['-o', 'pid', '--no-headers', '--ppid', parentPid])
}
break
}
return buildTree(pids, getSpawn, getPids, pid)
return buildTree(pids, getSpawn, pid)
.then(function() {
for (let pid of pids) {
try {
@ -47,38 +31,28 @@ export default function kill(pid, signal) {
if (err.code !== 'ESRCH') throw err;
}
}
return pids
})
}
function buildTree(allPids, spawnGetChildren, spawnGetPids, parentPid) {
allPids.add(parentPid)
function buildTree(allPids, spawnGetChildren, parentPid) {
allPids.set(parentPid)
let ps = spawnGetChildren(parentPid)
let data = ''
let err = ''
ps.stdout.on('data', function(buf) {
data += buf.toString('ascii')
})
ps.stderr.on('data', function(buf) {
err += buf.toString('ascii')
})
return new Promise(function(res, rej) {
return new Promise(function(res) {
ps.on('close', function(code) {
// Check if ps errored out
if (code !== 0 && err.trim()) {
return rej(new Error('Error running ps to kill processes:\n\t' + err))
}
// Check if we otherwise got an error code (usually means empty results)
if (code !== 0 || !data.trim()) return res()
let pids = spawnGetPids(data, parentPid)
// Check if we got error code (usually means empty results)
if (code !== 0) return res()
res(Promise.all(
pids.filter(pid => pid && !allPids.has(pid))
.map(buildTree.bind(this, allPids, spawnGetChildren, spawnGetPids))
allData.match(/\d+/g)
.map(Number)
.filter(pid => !bla.has(pid))
.map(buildTree.bind(this, allPids, spawnGetChildren))
))
})
})

View file

@ -34,7 +34,6 @@ export function stub(returnFunc = null) {
func.lastCall = null
func.called = false
func.callCount = 0
func.calls = calls
func.findCall = function(fn) {
for (let call of calls) {

View file

@ -1,6 +1,6 @@
{
"name": "eltro",
"version": "1.5.0",
"version": "1.4.3",
"description": "Eltro is a tiny no-dependancy test framework for node",
"main": "index.mjs",
"scripts": {

View file

@ -29,41 +29,6 @@ t.describe('#notOk()', function() {
})
})
t.describe('#equalWithMargin()', function() {
t.test('should support default margin for floating point math', function() {
let check = 0.1 + 0.2
assertExtended.throws(function() {
assertExtended.strictEqual(check, 0.3)
}, assertExtended.AssertionError)
assertExtended.equalWithMargin(check, 0.3)
})
t.test('should support custom margin', function() {
assertExtended.equalWithMargin(1, 2, 1)
})
t.test('should fail if margin is too small', function() {
assertExtended.throws(function() {
assertExtended.equalWithMargin(1, 2, 0.9)
}, assertExtended.AssertionError)
})
t.test('should support custom message', function () {
const assertMessage = 'Hello world'
let error = null
try {
assertExtended.equalWithMargin(1, 2, 0, assertMessage)
} catch (err) {
error = err
}
assert.ok(error)
assert.match(error.message, new RegExp(assertMessage))
})
})
t.describe('#throwAndCatch()', function() {
t.test('should work and return the original error', function() {
const assertError = new Error('Speed')

View file

@ -8,9 +8,6 @@ function CreateT() {
t.logger = {
log: stub()
}
t.process = {
stdout: { write: stub() }
}
return t
}
@ -287,60 +284,6 @@ e.describe('#beforeEach()', function() {
assert.match(t.logger.log.getCallN(4)[0], /DDDD/)
assert.match(t.logger.log.getCallN(4)[0], /BBBB/)
})
e.describe('reporter', function() {
e.test('should not log before each with reporter list', async function() {
const t = CreateT()
t.reporter = 'list'
t.begin()
t.describe('BBBB', function() {
t.beforeEach(function() {})
t.describe('CCCC', function() {
t.test('c1', function() { })
t.test('c2', function() { })
})
t.describe('DDDD', function() {
t.test('d1', function() { })
})
t.test('AAAA', function() { })
})
await t.run()
for (let row of t.process.stdout.write.calls) {
assert.notMatch(row.filter(x => x).join(' '), /before each/i)
}
})
e.test('should not log success before each with reporter dot', async function() {
const t = CreateT()
t.reporter = 'dot'
t.begin()
t.describe('BBBB', function() {
t.beforeEach(function() {})
t.describe('CCCC', function() {
t.test('c1', function() { })
t.test('c2', function() { })
})
t.describe('DDDD', function() {
t.test('d1', function() { })
})
t.test('AAAA', function() { })
})
await t.run()
let total = 0
for (let row of t.process.stdout.write.calls) {
if (row.filter(x => x).join(' ').match(/\[32m\./)) {
total++
}
}
assert.strictEqual(total, 4)
})
})
})
e.describe('#after()', function() {
@ -736,60 +679,6 @@ e.describe('#afterEach()', function() {
assert.match(t.logger.log.getCallN(5)[0], /JJJJ/)
assert.match(t.logger.log.getCallN(5)[0], /YYYY/)
})
e.describe('reporter', function() {
e.test('should not log before each with reporter list', async function() {
const t = CreateT()
t.reporter = 'list'
t.begin()
t.describe('BBBB', function() {
t.afterEach(function() {})
t.describe('CCCC', function() {
t.test('c1', function() { })
t.test('c2', function() { })
})
t.describe('DDDD', function() {
t.test('d1', function() { })
})
t.test('AAAA', function() { })
})
await t.run()
for (let row of t.process.stdout.write.calls) {
assert.notMatch(row.filter(x => x).join(' '), /after each/i)
}
})
e.test('should not log success before each with reporter dot', async function() {
const t = CreateT()
t.reporter = 'dot'
t.begin()
t.describe('BBBB', function() {
t.afterEach(function() {})
t.describe('CCCC', function() {
t.test('c1', function() { })
t.test('c2', function() { })
})
t.describe('DDDD', function() {
t.test('d1', function() { })
})
t.test('AAAA', function() { })
})
await t.run()
let total = 0
for (let row of t.process.stdout.write.calls) {
if (row.filter(x => x).join(' ').match(/\[32m\./)) {
total++
}
}
assert.strictEqual(total, 4)
})
})
})
let commonBeforeTests = ['before', 'beforeEach']

View file

@ -234,6 +234,7 @@ e.test('Eltro should support capturing unknown errors outside scope', async func
t.describe('', function() {
t.test('', function(cb) {
process.nextTick(function() {
console.log('throw')
throw assertError
})
})

View file

@ -1,41 +0,0 @@
import { spawn } from 'child_process'
import t from '../../lib/eltro.mjs'
import assert from '../../lib/assert.mjs'
import kill from '../../lib/kill.mjs'
t.describe('kill', function() {
let worker
t.afterEach(function() {
if (worker?.pid && !worker.killed) {
worker.kill()
}
})
t.test('should kill process correctly', function(done) {
worker = spawn('node', ['./test/kill/runner.mjs'])
assert.ok(worker.pid)
worker.on('exit', done.finish(function(code, signal) {
assert.ok(code || signal)
}))
kill(worker.pid)
})
t.test('should succeed in killing tree', async function() {
worker = spawn('node', ['./test/kill/runner.mjs'])
assert.ok(worker.pid)
// Give it some time to start
await new Promise(res => {
worker.stdout.on('data', function(data) {
if (data.toString().indexOf('secondary') >= 0) res()
})
})
return kill(worker.pid).then(function(pids) {
assert.strictEqual(pids.size, 2)
})
})
})

View file

@ -1,11 +0,0 @@
import { spawn } from 'child_process'
console.log('primary', process.pid)
let secondary = spawn('node', ['./test/kill/second_runner.mjs'])
secondary.stdout.on('data', function(data) {
process.stdout.write(data)
})
setInterval(function() { console.log('primary', process.pid) }, 100)

View file

@ -1,2 +0,0 @@
console.log('secondary', process.pid)
setInterval(function() { console.log('secondary', process.pid) }, 100)

View file

@ -28,7 +28,7 @@ t.afterEach(function(done) {
t.after(function() {
if (builder) {
return builder.cleanup()
builder.cleanup()
}
})

View file

@ -173,7 +173,7 @@ Builder.prototype.newRandomFiles = function(fpath, count) {
}
Builder.prototype.cleanup = function() {
return fs.rm(this.root, { recursive: true, force: true })
return fs.rmdir(this.root)
}
Builder.prototype.getAllDirectories = function() {