mirror of
https://github.com/ragestudio/comty.git
synced 2025-06-11 03:24:16 +00:00
added ComtyClient
This commit is contained in:
parent
d316b1e6af
commit
3e49de7a0f
@ -4,12 +4,15 @@ import path from "path"
|
|||||||
import DbManager from "@classes/DbManager"
|
import DbManager from "@classes/DbManager"
|
||||||
import RedisClient from "@classes/RedisClient"
|
import RedisClient from "@classes/RedisClient"
|
||||||
import StorageClient from "@classes/StorageClient"
|
import StorageClient from "@classes/StorageClient"
|
||||||
|
import ComtyClient from "./classes/ComtyClient"
|
||||||
|
|
||||||
import hyperexpress from "hyper-express"
|
import hyperexpress from "hyper-express"
|
||||||
|
|
||||||
import pkg from "../package.json"
|
import pkg from "../package.json"
|
||||||
|
|
||||||
export default class WidgetsAPI {
|
export default class WidgetsAPI {
|
||||||
|
static useMiddlewaresOrder = ["useLogger", "useCors", "useAuth"]
|
||||||
|
|
||||||
server = global.server = new hyperexpress.Server()
|
server = global.server = new hyperexpress.Server()
|
||||||
|
|
||||||
listenIp = process.env.HTTP_LISTEN_IP ?? "0.0.0.0"
|
listenIp = process.env.HTTP_LISTEN_IP ?? "0.0.0.0"
|
||||||
@ -19,6 +22,10 @@ export default class WidgetsAPI {
|
|||||||
|
|
||||||
db = new DbManager()
|
db = new DbManager()
|
||||||
|
|
||||||
|
comty = global.comty = ComtyClient({
|
||||||
|
useWs: false,
|
||||||
|
})
|
||||||
|
|
||||||
redis = global.redis = RedisClient()
|
redis = global.redis = RedisClient()
|
||||||
|
|
||||||
storage = global.storage = StorageClient()
|
storage = global.storage = StorageClient()
|
||||||
@ -52,6 +59,22 @@ export default class WidgetsAPI {
|
|||||||
async __registerInternalMiddlewares() {
|
async __registerInternalMiddlewares() {
|
||||||
let middlewaresPath = fs.readdirSync(path.resolve(__dirname, "useMiddlewares"))
|
let middlewaresPath = fs.readdirSync(path.resolve(__dirname, "useMiddlewares"))
|
||||||
|
|
||||||
|
// sort middlewares
|
||||||
|
middlewaresPath = middlewaresPath.sort((a, b) => {
|
||||||
|
const aIndex = this.constructor.useMiddlewaresOrder.indexOf(a.replace(".js", ""))
|
||||||
|
const bIndex = this.constructor.useMiddlewaresOrder.indexOf(b.replace(".js", ""))
|
||||||
|
|
||||||
|
if (aIndex === -1) {
|
||||||
|
return 1
|
||||||
|
}
|
||||||
|
|
||||||
|
if (bIndex === -1) {
|
||||||
|
return -1
|
||||||
|
}
|
||||||
|
|
||||||
|
return aIndex - bIndex
|
||||||
|
})
|
||||||
|
|
||||||
for await (const middlewarePath of middlewaresPath) {
|
for await (const middlewarePath of middlewaresPath) {
|
||||||
const middleware = require(path.resolve(__dirname, "useMiddlewares", middlewarePath)).default
|
const middleware = require(path.resolve(__dirname, "useMiddlewares", middlewarePath)).default
|
||||||
|
|
||||||
|
Loading…
x
Reference in New Issue
Block a user