Factorize aimedb connection setup
This commit is contained in:
+10
-4
@@ -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
|
||||
|
||||
Reference in New Issue
Block a user