mirror of
https://github.com/ragestudio/linebridge.git
synced 2025-06-09 18:44:17 +00:00
exclude socket arg
This commit is contained in:
parent
60c6b84414
commit
56d9efb257
@ -3,12 +3,12 @@ module.exports = function generateWSRequestDispatcher(instance, channel) {
|
|||||||
return new Promise(async (resolve, reject) => {
|
return new Promise(async (resolve, reject) => {
|
||||||
const req = instance.emit(channel, ...payload)
|
const req = instance.emit(channel, ...payload)
|
||||||
|
|
||||||
req.on("response", (socket, ...args) => {
|
req.on("response", (...args) => {
|
||||||
return resolve(socket, ...args)
|
return resolve(...args)
|
||||||
})
|
})
|
||||||
|
|
||||||
req.on("responseError", (socket, ...args) => {
|
req.on("responseError", (...args) => {
|
||||||
return reject(socket, ...args)
|
return reject(...args)
|
||||||
})
|
})
|
||||||
})
|
})
|
||||||
}
|
}
|
||||||
|
@ -122,10 +122,10 @@ class Server {
|
|||||||
|
|
||||||
handleWSClientConnection = async (socket) => {
|
handleWSClientConnection = async (socket) => {
|
||||||
socket.res = (...args) => {
|
socket.res = (...args) => {
|
||||||
socket.emit("response", socket, ...args)
|
socket.emit("response", ...args)
|
||||||
}
|
}
|
||||||
socket.err = (...args) => {
|
socket.err = (...args) => {
|
||||||
socket.emit("responseError", socket, ...args)
|
socket.emit("responseError", ...args)
|
||||||
}
|
}
|
||||||
|
|
||||||
if (typeof this.params.onWSClientConnection === "function") {
|
if (typeof this.params.onWSClientConnection === "function") {
|
||||||
|
Loading…
x
Reference in New Issue
Block a user