some updates

This commit is contained in:
srgooglo 2022-01-10 11:59:43 +01:00
parent dbcbf8d6b9
commit 755b15d909

View File

@ -8,16 +8,16 @@ const FixedMethods = {
// TODO: AutoConnection // TODO: AutoConnection
class Controller { class Controller {
constructor(params = {}) { constructor(params = {}) {
console.warn("[Linebridge] Controller is not finished yet. Please use regular bridges instead.")
this.params = params this.params = params
this.pool = [] this.pool = []
this.initialize()
} }
async initialize() { async initialize() {
if (typeof this.params.servers !== "undefined" && Array.isArray(this.params.servers)) { if (typeof this.params.servers !== "undefined" && Array.isArray(this.params.servers)) {
for await (let server of this.params.servers) { for await (let server of this.params.servers) {
this.appendServer(server) await this.appendServer(server)
} }
} }
@ -31,8 +31,7 @@ class Controller {
server = new Bridge({ server = new Bridge({
origin: server, origin: server,
}) })
} } else if (typeof server === "object" && server instanceof Bridge) {
if (typeof server === "object" && server instanceof Bridge) {
server = new Bridge(...server) server = new Bridge(...server)
} }
@ -44,7 +43,7 @@ class Controller {
async connect(server) { async connect(server) {
if (server instanceof Bridge) { if (server instanceof Bridge) {
server.initialize() await server.initialize()
} else { } else {
throw new Error("Invalid server. Expected Bridge instance.") throw new Error("Invalid server. Expected Bridge instance.")
} }
@ -140,7 +139,8 @@ function generateDispatcher(instance, method, route, handleRequestContext) {
} }
if (typeof handleRequestContext === "function") { if (typeof handleRequestContext === "function") {
requestParams = { ...requestParams, ...handleRequestContext() } const context = await handleRequestContext()
requestParams = { ...requestParams, ...context }
} }
let result = { let result = {