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 with linebridge 0.15

Browse Source
This commit is contained in:
SrGooglo 2023-01-26 19:40:10 +00:00
parent 7f3e60f28e
commit 7ecc3ef3eb
1 changed files with 37 additions and 59 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

96
packages/server/src/api.js
View File

@ -1,6 +1,8 @@
import path from "path" import { Server, registerBaseAliases } from "linebridge/dist/server"
import { Server as LinebridgeServer } from "linebridge/dist/server"
registerBaseAliases()
import path from "path"
import express from "express" import express from "express"
import bcrypt from "bcrypt" import bcrypt from "bcrypt"
import passport from "passport" import passport from "passport"
@ -8,54 +10,21 @@ import passport from "passport"
import jwt from "jsonwebtoken" import jwt from "jsonwebtoken"
import EventEmitter from "@foxify/events" import EventEmitter from "@foxify/events"
import { User, Session, Config } from "./models" import { User, Session, Config } from "@models"
import DbManager from "./classes/DbManager" import DbManager from "@classes/DbManager"
import { createStorageClientInstance } from "./classes/StorageClient" import { createStorageClientInstance } from "@classes/StorageClient"
import internalEvents from "./events" import internalEvents from "./events"
const ExtractJwt = require("passport-jwt").ExtractJwt const ExtractJwt = require("passport-jwt").ExtractJwt
const LocalStrategy = require("passport-local").Strategy const LocalStrategy = require("passport-local").Strategy
const controllers = require("./controllers")
const middlewares = require("./middlewares")
global.signLocation = process.env.signLocation global.signLocation = process.env.signLocation
export default class Server { export default class API {
DB = new DbManager() server = global.server = new Server({
listen_port: process.env.MAIN_LISTEN_PORT ?? 3000,
eventBus = global.eventBus = new EventEmitter()
storage = global.storage = createStorageClientInstance()
controllers = [
controllers.ConfigController,
controllers.RolesController,
controllers.FollowerController,
controllers.SessionController,
controllers.UserController,
controllers.FilesController,
controllers.PublicController,
controllers.PostsController,
controllers.StreamingController,
controllers.BadgesController,
controllers.CommentsController,
controllers.SearchController,
controllers.FeaturedEventsController,
controllers.PlaylistsController,
controllers.FeedController,
controllers.SyncController,
]
middlewares = middlewares
server = global.server = new LinebridgeServer({
port: process.env.MAIN_LISTEN_PORT || 3000,
headers: {
"Access-Control-Expose-Headers": "regenerated_token",
},
onWSClientConnection: (...args) => { onWSClientConnection: (...args) => {
this.onWSClientConnection(...args) this.onWSClientConnection(...args)
}, },
@ -63,10 +32,19 @@ export default class Server {
this.onWSClientDisconnect(...args) this.onWSClientDisconnect(...args)
}, },
}, },
this.controllers, require("@controllers"),
this.middlewares require("@middlewares"),
{
"Access-Control-Expose-Headers": "regenerated_token",
},
) )
DB = new DbManager()
eventBus = global.eventBus = new EventEmitter()
storage = global.storage = createStorageClientInstance()
jwtStrategy = global.jwtStrategy = { jwtStrategy = global.jwtStrategy = {
jwtFromRequest: ExtractJwt.fromAuthHeaderAsBearerToken(), jwtFromRequest: ExtractJwt.fromAuthHeaderAsBearerToken(),
secretOrKey: this.server.oskid, secretOrKey: this.server.oskid,
@ -76,25 +54,25 @@ export default class Server {
} }
constructor() { constructor() {
this.server.engineInstance.use(express.json()) this.server.engine_instance.use(express.json())
this.server.engineInstance.use(express.urlencoded({ extended: true })) this.server.engine_instance.use(express.urlencoded({ extended: true }))
this.server.wsInterface["clients"] = [] this.server.websocket_instance["clients"] = []
this.server.wsInterface["findUserIdFromClientID"] = (searchClientId) => { this.server.websocket_instance["findUserIdFromClientID"] = (searchClientId) => {
return this.server.wsInterface.clients.find(client => client.id === searchClientId)?.userId ?? false return this.server.websocket_instance.clients.find(client => client.id === searchClientId)?.userId ?? false
} }
this.server.wsInterface["getClientSockets"] = (userId) => { this.server.websocket_instance["getClientSockets"] = (userId) => {
return this.server.wsInterface.clients.filter(client => client.userId === userId).map((client) => { return this.server.websocket_instance.clients.filter(client => client.userId === userId).map((client) => {
return client?.socket return client?.socket
}) })
} }
this.server.wsInterface["broadcast"] = async (channel, ...args) => { this.server.websocket_instance["broadcast"] = async (channel, ...args) => {
for await (const client of this.server.wsInterface.clients) { for await (const client of this.server.websocket_instance.clients) {
client.socket.emit(channel, ...args) client.socket.emit(channel, ...args)
} }
} }
global.wsInterface = this.server.wsInterface global.websocket_instance = this.server.websocket_instance
global.uploadCachePath = process.env.uploadCachePath ?? path.resolve(process.cwd(), "cache") global.uploadCachePath = process.env.uploadCachePath ?? path.resolve(process.cwd(), "cache")
@ -220,7 +198,7 @@ export default class Server {
.catch(err => done(err, null, this.jwtStrategy)) .catch(err => done(err, null, this.jwtStrategy))
})) }))
this.server.engineInstance.use(passport.initialize()) this.server.engine_instance.use(passport.initialize())
} }
initWebsockets() { initWebsockets() {
@ -238,7 +216,7 @@ export default class Server {
}) })
} }
this.server.wsInterface.eventsChannels.push(["/main", "authenticate", async (socket, authPayload) => { this.server.websocket_instance.eventsChannels.push(["/main", "authenticate", async (socket, authPayload) => {
if (!authPayload) { if (!authPayload) {
return onAuthenticatedFailed(socket, "missing_auth_payload") return onAuthenticatedFailed(socket, "missing_auth_payload")
} }
@ -279,7 +257,7 @@ export default class Server {
} }
attachClientSocket = async (socket, userData) => { attachClientSocket = async (socket, userData) => {
const client = this.server.wsInterface.clients.find(c => c.id === socket.id) const client = this.server.websocket_instance.clients.find(c => c.id === socket.id)
if (client) { if (client) {
client.socket.disconnect() client.socket.disconnect()
@ -291,7 +269,7 @@ export default class Server {
user_id: userData._id.toString(), user_id: userData._id.toString(),
} }
this.server.wsInterface.clients.push(clientObj) this.server.websocket_instance.clients.push(clientObj)
console.log(`📣 Client [${socket.id}] authenticated as ${userData.username}`) console.log(`📣 Client [${socket.id}] authenticated as ${userData.username}`)
@ -299,10 +277,10 @@ export default class Server {
} }
detachClientSocket = async (socket) => { detachClientSocket = async (socket) => {
const client = this.server.wsInterface.clients.find(c => c.id === socket.id) const client = this.server.websocket_instance.clients.find(c => c.id === socket.id)
if (client) { if (client) {
this.server.wsInterface.clients = this.server.wsInterface.clients.filter(c => c.id !== socket.id) this.server.websocket_instance.clients = this.server.websocket_instance.clients.filter(c => c.id !== socket.id)
console.log(`📣🔴 Client [${socket.id}] authenticated as ${client.user_id} disconnected`) console.log(`📣🔴 Client [${socket.id}] authenticated as ${client.user_id} disconnected`)