From d9d61f82490b35db8b656e280b713432b428c897 Mon Sep 17 00:00:00 2001 From: Daniel Aloni Date: Sun, 18 Feb 2024 17:14:25 +0200 Subject: [PATCH] =?UTF-8?q?=E2=99=BB=EF=B8=8F=20Final=20provisioner=20rout?= =?UTF-8?q?e.?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- src/Bridge.ts | 6 +++--- src/config/Defaults.ts | 2 +- src/mqtt/mqttConnectionManager.ts | 6 +++--- src/provisioning/provisioner.ts | 20 ++++++++++---------- 4 files changed, 17 insertions(+), 17 deletions(-) diff --git a/src/Bridge.ts b/src/Bridge.ts index 726cc1210..b0b82b2a2 100644 --- a/src/Bridge.ts +++ b/src/Bridge.ts @@ -141,14 +141,14 @@ export class Bridge { const routers = []; if (this.config.jira) { routers.push({ - route: "/bridge/jira", + route: "/provisioner/jira", router: new JiraProvisionerRouter(this.config.jira, this.tokenStore).getRouter(), }); this.connectionManager.registerProvisioningConnection(JiraProjectConnection); } if (this.config.github && this.github) { routers.push({ - route: "/bridge/github", + route: "/provisioner/github", router: new GitHubProvisionerRouter(this.config.github, this.tokenStore, this.github).getRouter(), }); this.connectionManager.registerProvisioningConnection(GitHubRepoConnection); @@ -162,7 +162,7 @@ export class Bridge { if (this.config.mqtt?.enabled) { // Register the internal backend route for get all live connections routers.push({ - route: "/bridge/mqtt", + route: "/provisioner/mqtt", router: new MqttProvisionerRouter(this.config.provisioning).getRouter(), }); this.connectionManager.registerProvisioningConnection(MqttConnection); diff --git a/src/config/Defaults.ts b/src/config/Defaults.ts index 752a05eec..a5eb8b4fd 100644 --- a/src/config/Defaults.ts +++ b/src/config/Defaults.ts @@ -46,7 +46,7 @@ export const DefaultConfigRoot: BridgeConfigRoot = { }, }, bot: { - displayname: "Hookshot Bot", + displayname: "Bridge Bot", avatar: "mxc://half-shot.uk/2876e89ccade4cb615e210c458e2a7a6883fe17d" }, serviceBots: [ diff --git a/src/mqtt/mqttConnectionManager.ts b/src/mqtt/mqttConnectionManager.ts index 54f855bb6..2fe8bd289 100644 --- a/src/mqtt/mqttConnectionManager.ts +++ b/src/mqtt/mqttConnectionManager.ts @@ -1,7 +1,7 @@ import { Logger } from "matrix-appservice-bridge"; import { BridgeConfigMqtt } from "../config/Config"; import { Pool } from "pg"; -import { SelectSpaceConnectionsArgs, selectSpaceConnections, selectConnection, insertConnection, updateConnectionAssociatedSpaces, deleteSpaceFromConnectionAndPrune, selectAllConnections } from "../db/generated/queries_sql"; +import { selectConnection, insertConnection, updateConnectionAssociatedSpaces, deleteSpaceFromConnectionAndPrune } from "../db/generated/queries_sql"; import axios from "axios"; import "dotenv/config"; import { MqttConnectionState } from "../Connections/MqttConnection"; @@ -9,10 +9,10 @@ import * as fs from 'fs'; const log = new Logger("MqttConnectionsManager"); -function executeSchema(dbCli: Pool) { +async function executeSchema(dbCli: Pool) { try { const schemaSql = fs.readFileSync('./src/db/schema.sql', 'utf8'); - dbCli.query(schemaSql); + await dbCli.query(schemaSql); log.info('MQTT table created successfully'); } catch (err) { log.info('Error creating MQTT table: ', err); diff --git a/src/provisioning/provisioner.ts b/src/provisioning/provisioner.ts index 072fa4825..7b9be097e 100644 --- a/src/provisioning/provisioner.ts +++ b/src/provisioning/provisioner.ts @@ -24,7 +24,7 @@ export class Provisioner { private readonly botUsersManager: BotUsersManager, private readonly as: Appservice, additionalRoutes: {route: string, router: Router}[]) { - this.expressRouter.use("/bridge", (req, _res, next) => { + this.expressRouter.use("/provisioner", (req, _res, next) => { Metrics.provisioningHttpRequest.inc({path: req.path, method: req.method}); next(); }); @@ -42,44 +42,44 @@ export class Provisioner { maxAge: 86400, // 24 hours }; this.expressRouter.use(cors(corsOptions)); - this.expressRouter.get("/bridge/health", this.getHealth); - this.expressRouter.use("/bridge", this.checkAuth.bind(this)); + this.expressRouter.get("/provisioner/health", this.getHealth); + this.expressRouter.use("/provisioner", this.checkAuth.bind(this)); this.expressRouter.use(express.json()); this.expressRouter.get( - "/bridge/connectiontypes", + "/provisioner/connectiontypes", this.getConnectionTypes.bind(this), ); - this.expressRouter.use("/bridge", this.checkUserId.bind(this)); + this.expressRouter.use("/provisioner", this.checkUserId.bind(this)); additionalRoutes.forEach(route => { this.expressRouter.use(route.route, route.router); }); // Room Routes this.expressRouter.get<{roomId: string}, unknown, unknown, {userId: string}>( - "/bridge/:roomId/connections", + "/provisioner/:roomId/connections", this.checkRoomId.bind(this), (...args) => this.checkUserPermission("read", ...args), this.getConnections.bind(this), ); this.expressRouter.get<{roomId: string, connectionId: string}, unknown, unknown, {userId: string}>( - "/bridge/:roomId/connections/:connectionId", + "/provisioner/:roomId/connections/:connectionId", this.checkRoomId.bind(this), (...args) => this.checkUserPermission("read", ...args), this.getConnection.bind(this), ); this.expressRouter.put<{roomId: string, type: string}, unknown, Record, {userId: string}>( - "/bridge/:roomId/connections/:type", + "/provisioner/:roomId/connections/:type", this.checkRoomId.bind(this), (...args) => this.checkUserPermission("write", ...args), this.putConnection.bind(this), ); this.expressRouter.patch<{roomId: string, connectionId: string}, unknown, Record, {userId: string}>( - "/bridge/:roomId/connections/:connectionId", + "/provisioner/:roomId/connections/:connectionId", this.checkRoomId.bind(this), (...args) => this.checkUserPermission("write", ...args), this.patchConnection.bind(this), ); this.expressRouter.delete<{roomId: string, connectionId: string}, unknown, unknown, {userId: string}>( - "/bridge/:roomId/connections/:connectionId", + "/provisioner/:roomId/connections/:connectionId", this.checkRoomId.bind(this), (...args) => this.checkUserPermission("write", ...args), this.deleteConnection.bind(this),