src/hero.mjs: Add skeleton for makePipeReaderFn()

2 files changed, 40 insertions, 5 deletions

diff --git a/src/hero.mjs b/src/hero.mjs
index 8cbbe36..0a086ad 100644
--- a/src/hero.mjs
+++ b/src/hero.mjs
@@ -357,6 +357,17 @@ export const makeLineEmitter = fn => {
 	};
 };
 
+export const makePipeReaderFn = ({
+	lineFn,
+} = {
+	lineFn: lineHandler
+}) => path => {
+	mkfifo(path);
+	// TODO
+};
+
+export const makePipeReader = makePipeReaderFn();
+
 export const buildRoutes = (routes, globalInterceptors = []) =>
 	routes.reduce(
 		(acc, [methods, path, handlerFn, interceptors = []]) =>
@@ -374,12 +385,16 @@ export const buildRoutes = (routes, globalInterceptors = []) =>
 
 export const promisifyServer = (name, serverHandle) => ({
 	ref:    serverHandle,
-	listen: util.promisify((udsPath, ...args) => {
+	listen: util.promisify((socket, pipe, ...args) => {
+		assert.equal(typeof socket, "string");
+		assert.equal(typeof pipe,   "string");
 		configLogger({ name });
-		if (fs.existsSync(udsPath)) {
-			fs.unlinkSync(udsPath);
-		}
-		return serverHandle.listen(udsPath, ...args)
+
+		rmIf(pipe);
+		makePipeReader(pipe);
+
+		rmIf(socket);
+		return serverHandle.listen(socket, ...args)
 	}),
 	close:  util.promisify((...args) => serverHandle.close(...args)),
 	events: serverHandle,
diff --git a/tests/js/hero.mjs b/tests/js/hero.mjs
index 1debdc5..d4c6b57 100644
--- a/tests/js/hero.mjs
+++ b/tests/js/hero.mjs
@@ -33,6 +33,7 @@ import {
 	rmIf,
 	mkfifo,
 	makeLineEmitter,
+	makePipeReaderFn,
 	buildRoutes,
 	promisifyServer,
 	buildServer,
@@ -1369,6 +1370,24 @@ const test_makeLineEmitter = async t => {
 	});
 };
 
+const test_makePipeReaderFn = async t => {
+	t.start("makePipeReaderFn()");
+
+	await t.test("we can close it manually with no data", async () => {
+		const path = "tests/hero-2.pipe";
+		const lines = [];
+		const lineFn = x => lines.push(x);
+		const makePipeReader = makePipeReaderFn({ lineFn: null });
+	});
+
+	await t.test("closing on pipe EOF reopens", async () => {
+		const path = "tests/hero-3.pipe";
+		const lines = [];
+		const lineFn = x => lines.push(x);
+		const makePipeReader = makePipeReaderFn({ lineFn });
+	});
+};
+
 const test_buildRoutes = async t => {
 	t.start("buildRoutes()");
 
@@ -1604,6 +1623,7 @@ await runner.runTests([
 	test_rmIf,
 	test_mkfifo,
 	test_makeLineEmitter,
+	test_makePipeReaderFn,
 	test_promisifyServer,
 	test_buildServer,
 ]);