RageStudio/comty
1
0
Fork 0
mirror of https://github.com/ragestudio/comty.git synced 2025-06-10 02:54:15 +00:00
Code Issues Packages Projects Releases Wiki Activity

reimplement connection & initialization

Browse Source
This commit is contained in:
SrGooglo 2023-05-24 17:37:25 +00:00
parent 53200388d6
commit 25ecee4c2d
1 changed files with 41 additions and 11 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

52
packages/app/src/cores/api/index.js
View File

@ -5,8 +5,7 @@ import createClient from "comty.js"
import measurePing from "comty.js/handlers/measurePing"
import request from "comty.js/handlers/request"
import useRequest from "comty.js/hooks/useRequest"
import SessionModel from "comty.js/models/session"
import { reconnectWebsockets } from "comty.js"
export default class APICore extends Core {
static refName = "api"
@ -23,6 +22,7 @@ export default class APICore extends Core {
unlistenEvent: this.unlistenEvent.bind(this),
measurePing: measurePing,
useRequest: useRequest,
reconnectWebsockets: reconnectWebsockets,
}
listenEvent(key, handler, instance) {
@ -33,18 +33,46 @@ export default class APICore extends Core {
this.instance.wsInstances[instance ?? "default"].off(key, handler)
}
pendingPingsFromInstance = {}
createPingIntervals() {
Object.keys(this.instance.wsInstances).forEach((instance) => {
console.debug(`[API] Creating ping interval for ${instance}`)
if (this.instance.wsInstances[instance].pingInterval) {
clearInterval(this.instance.wsInstances[instance].pingInterval)
}
this.instance.wsInstances[instance].pingInterval = setInterval(() => {
if (this.instance.wsInstances[instance].pendingPingTry && this.instance.wsInstances[instance].pendingPingTry > 3) {
console.debug(`[API] Ping timeout for ${instance}`)
return clearInterval(this.instance.wsInstances[instance].pingInterval)
}
const timeStart = Date.now()
//console.debug(`[API] Ping ${instance}`, this.instance.wsInstances[instance].pendingPingTry)
this.instance.wsInstances[instance].emit("ping", () => {
this.instance.wsInstances[instance].latency = Date.now() - timeStart
this.instance.wsInstances[instance].pendingPingTry = 0
})
this.instance.wsInstances[instance].pendingPingTry = this.instance.wsInstances[instance].pendingPingTry ? this.instance.wsInstances[instance].pendingPingTry + 1 : 1
}, 5000)
// clear interval on close
this.instance.wsInstances[instance].on("close", () => {
clearInterval(this.instance.wsInstances[instance].pingInterval)
})
})
}
async onInitialize() {
this.instance = await createClient({
enableWs: true,
wsParams: {
chat: (opts) => {
opts.auth = {
token: SessionModel.token,
}
return opts
}
}
})
this.instance.eventBus.on("auth:login_success", () => {
@ -74,6 +102,8 @@ export default class APICore extends Core {
console.debug("[API] Attached to", this.instance)
this.createPingIntervals()
return this.instance
}
}