Message queue with Socket.io

npm install socketio-mq

yarn add socketio-mq

import { RemoteHandler, StaticClient, Server } from “socketio-mq“

const delay = (ms: number) => new Promise((resolve) => setTimeout(resolve, ms))

class ServiceA extends StaticClient {
static id = “service-a“
static url = “http://localhost:3000“

// Use @RemoteHandler for register method as “remote-able” or else these methods will be recognize as not “remote-able” and throw error if trying to use remote
@RemoteHandler
async getPosts(userID: number) {
await delay(1000)
return [“post1“, “post2“, “post3“]
}
}

class ServiceB extends StaticClient {
@RemoteHandler
async getUser(id: number) {
await delay(1000)
return { id, name: “John Doe“ }
}
}

const server = new Server(3000)

const serviceA = ServiceA.getInstance() // Singleton support (ip and url is defined in class)
const serviceB = new ServiceB(“service-b“, “http://localhost:3000“) // Construct new instance (will override “ip” or “url” if you specific in constructor params)

const remoteB = serviceA.use(ServiceB, “service-b“) // Create remote service B

;(async () => {
const user = await remoteB.getUser(1) // remote call
const post = await serviceA.getPosts(1) // normal call

console.log(`user: ${JSON.stringify(user)}, post: ${post}`)
})()

import { DynamicClient, Server } from “socketio-mq“

const delay = (ms: number) => new Promise((resolve) => setTimeout(resolve, ms))

// Define events map first

type EventMapA = {
getPosts: (userID: number) => Promise<string[]>
}

type EventMapB = {
getUser: (id: number) => Promise<{ id: number; name: string }>
}

const server = new Server(3000)
const serviceA = new DynamicClient<EventMapA>(
“service-a“,
“http://localhost:3000“
)
const serviceB = new DynamicClient<EventMapB>(
“service-b“,
“http://localhost:3000“
)

serviceB.on(“getUser“, async (id: number) => {
await delay(1000)
return { id, name: “John Doe“ }
})

// We will not register handler for “getPosts” here to see error!
// a.on(“getPosts”, async (userID: number) => {
// await delay(1000)
// return [“post1”, “post2”, “post3”]
// })
;(async () => {
const remoteB = serviceA.use<EventMapB>(“service-b“)

const user = await remoteB.getUser(1)
const post = await serviceA.useSelf().getPosts(1)
console.log(`user ${JSON.stringify(user)}, post: ${post}`)
})().catch((e) => {
console.log(“We got an error: “, e)
// Error: Client “service-a” does not have a handler for event “getPosts”. Make sure to call the “on” method to register the handler!
})

import { Server } from “socketio-mq“
const server = new Server(3000) // Socket.io server will lift at http://localhost:3000