@sz-md/postoffice

JSON Spec:

{
    "requestId": "<client-request-id>",
    "request": "Request Body"
}

{
    "originRequestId": "<client-request-id>",
    "response": "Response body"
}

API:

.onrequest = function(body) {} // request handler
send()
request() // returns promise
rejectPendingRequests()

Client:

const PostOffice = require("@sz-sw/postoffice")
const NodeTCPSocket = require("@sz-md/node-tcp-socket")

async function main() {
    const instance = await PostOffice.create()
    const socket = await NodeTCPSocket.create({
        host: "localhost",
        port: 1337
    })

    socket.on("data", instance.receiveBytes)
    instance.sendBytes = socket.write

    console.log(
        await instance.sendRequest("request…")
    )
}
main()
`

Server:

const PostOffice = require("@sz-sw/postoffice")
const instance = await PostOffice.create()

connection.on("data", instance.receiveBytes)
instance.sendBytes = connection.write.bind(connection)

instance.onrequest = function(body) {
    return "My answer is: 42"
}