Spacebar/server
1
0
Fork 0
mirror of https://github.com/spacebarchat/server.git synced 2024-09-20 01:31:34 +02:00
Code Issues Releases Activity

Allow running api, cdn, gateway separately

Browse Source
This commit is contained in:
Madeline 2022-10-31 13:16:29 +11:00
parent 152ed6da95
commit 9a7a43a725
No known key found for this signature in database
GPG Key ID: 1958E017C36F2E47
5 changed files with 19 additions and 14 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

3
package.json
View File

@ -5,6 +5,9 @@
"scripts": {
"postinstall": "npx patch-package",
"start": "node dist/bundle/start.js",
"start:api": "node dist/api/start.js",
"start:cdn": "node dist/cdn/start.js",
"start:gateway": "node dist/gateway/start.js",
"build": "tsc -p .",
"setup": "npm run build && npm run generate:schema",
"generate:rights": "node scripts/rights.js",

5
src/api/Server.ts
View File

@ -1,7 +1,7 @@
import "missing-native-js-functions";
import { Server, ServerOptions } from "lambert-server";
import { Authentication, CORS } from "./middlewares/";
import { Config, initDatabase, initEvent } from "@fosscord/util";
import { BannedWords, Config, initDatabase, initEvent } from "@fosscord/util";
import { ErrorHandler } from "./middlewares/ErrorHandler";
import { BodyParser } from "./middlewares/BodyParser";
import { Router, Request, Response, NextFunction } from "express";
@ -14,7 +14,7 @@ import { initInstance } from "./util/handlers/Instance";
import { registerRoutes } from "@fosscord/util";
import { red } from "picocolors";
export interface FosscordServerOptions extends ServerOptions {}
export interface FosscordServerOptions extends ServerOptions { }
declare global {
namespace Express {
@ -38,6 +38,7 @@ export class FosscordServer extends Server {
await Config.init();
await initEvent();
await initInstance();
await BannedWords.init();
let logRequests = process.env["LOG_REQUESTS"] != undefined;
if (logRequests) {

1
src/api/start.ts
View File

@ -1,3 +1,4 @@
require("module-alias/register");
process.on("uncaughtException", console.error);
process.on("unhandledRejection", console.error);

3
src/gateway/Server.ts
View File

@ -1,7 +1,7 @@
import "missing-native-js-functions";
import dotenv from "dotenv";
dotenv.config();
import { closeDatabase, Config, initDatabase, initEvent } from "@fosscord/util";
import { BannedWords, closeDatabase, Config, initDatabase, initEvent } from "@fosscord/util";
import ws from "ws";
import { Connection } from "./events/Connection";
import http from "http";
@ -50,6 +50,7 @@ export class Server {
await initDatabase();
await Config.init();
await initEvent();
await BannedWords.init();
if (!this.server.listening) {
this.server.listen(this.port);
console.log(`[Gateway] online on 0.0.0.0:${this.port}`);

21
src/util/util/RabbitMQ.ts
View File

@ -1,5 +1,5 @@
import amqp, { Connection, Channel } from "amqplib";
// import Config from "./Config";
import { Config } from "./Config";
export const RabbitMQ: {
connection: Connection | null;
@ -9,15 +9,14 @@ export const RabbitMQ: {
connection: null,
channel: null,
init: async function () {
return;
// const host = Config.get().rabbitmq.host;
// if (!host) return;
// console.log(`[RabbitMQ] connect: ${host}`);
// this.connection = await amqp.connect(host, {
// timeout: 1000 * 60,
// });
// console.log(`[RabbitMQ] connected`);
// this.channel = await this.connection.createChannel();
// console.log(`[RabbitMQ] channel created`);
const host = Config.get().rabbitmq.host;
if (!host) return;
console.log(`[RabbitMQ] connect: ${host}`);
this.connection = await amqp.connect(host, {
timeout: 1000 * 60,
});
console.log(`[RabbitMQ] connected`);
this.channel = await this.connection.createChannel();
console.log(`[RabbitMQ] channel created`);
},
};