From de011c235820d54be5594f78752771f04a8308df Mon Sep 17 00:00:00 2001
From: Tau <tau@nowhere>
Date: Mon, 26 Nov 2018 17:12:23 -0500
Subject: [PATCH] Factorize aimedb connection setup

---
 src/aimedb.js | 14 ++++++++++----
 1 file changed, 10 insertions(+), 4 deletions(-)

diff --git a/src/aimedb.js b/src/aimedb.js
index 5c63f93..1cbbcfb 100644
--- a/src/aimedb.js
+++ b/src/aimedb.js
@@ -135,9 +135,7 @@ class Framer extends Transform {
   }
 }
 
-async function dispatch(socket) {
-  console.log('Aimedb: Connection opened')
-
+function setup(socket) {
   const input = pipeline(
     socket,
     crypto
@@ -158,6 +156,14 @@ async function dispatch(socket) {
     socket,
   )
 
+  return { input, output }
+}
+
+async function aimedb(socket) {
+  console.log('Aimedb: Connection opened')
+
+  const { input, output } = setup(socket)
+
   try {
     for await (const req of input) {
       console.log('Aimedb: Decode', req)
@@ -191,4 +197,4 @@ async function dispatch(socket) {
   socket.end()
 }
 
-module.exports = dispatch
+module.exports = aimedb