test.js

import test from 'tape'
import logger from './index.js'

test((t) => {
	const buf = []
	const log = logger('myservice', (e) => buf.push(e))

	log('level 1')

	const sublog = log.create('downstream')

	sublog('level 2 A')
	sublog('level 2 B')

	t.deepEqual(buf, [
		['myservice', 'level 1'],
		['myservice', 'downstream', 'level 2 A'],
		['myservice', 'downstream', 'level 2 B'],
	])
	t.end()
})

test('Queue namespaced data until `out` is set', (t) => {
	const log = logger('myservice')

	log('level 1 A')

	const sublog = log.create('downstream')

	sublog('level 2 A')
	sublog('level 2 B')

	const buf = []
	log.out((e) => buf.push(e))

	log('level 1 B')
	sublog('level 2 C')
	sublog.create('origin')('level 3 A')

	t.deepEqual(buf, [
		['myservice', 'level 1 A'],
		['myservice', 'downstream', 'level 2 A'],
		['myservice', 'downstream', 'level 2 B'],
		['myservice', 'level 1 B'],
		['myservice', 'downstream', 'level 2 C'],
		['myservice', 'downstream', 'origin', 'level 3 A'],
	])
	t.end()
})

test('Rerouting `out`', (t) => {
	const log = logger('myservice')

	log('level 1 A')

	const sublog = log.create('downstream')

	sublog('level 2 A')

	const buf = []
	log.out((e) => buf.push(e))

	log('level 1 B')

	const buf2 = []
	log.out((e) => buf2.push(e))

	log('level 1 C')
	sublog('level 2 B')
	log('level 1 D')

	t.deepEqual(buf, [
		['myservice', 'level 1 A'],
		['myservice', 'downstream', 'level 2 A'],
		['myservice', 'level 1 B'],
	])
	t.deepEqual(buf2, [
		['myservice', 'level 1 C'],
		['myservice', 'downstream', 'level 2 B'],
		['myservice', 'level 1 D'],
	])
	t.end()
})

test('Queue data while `out` is detached', (t) => {
	const log = logger('myservice')

	log('level 1 A')

	const sublog = log.create('downstream')

	sublog('level 2 A')
	sublog('level 2 B')

	const buf = []
	log.out((e) => buf.push(e))
	log.out(null)

	log('level 1 B')
	sublog('level 2 C')
	sublog.create('origin')('level 3 A')

	const buf2 = []
	log.out((e) => buf2.push(e))

	t.deepEqual(buf, [
		['myservice', 'level 1 A'],
		['myservice', 'downstream', 'level 2 A'],
		['myservice', 'downstream', 'level 2 B'],
	])
	t.deepEqual(buf2, [
		['myservice', 'level 1 B'],
		['myservice', 'downstream', 'level 2 C'],
		['myservice', 'downstream', 'origin', 'level 3 A'],
	])
	t.end()
})