diff --git a/src/util/Config.ts b/src/util/Config.ts
index cbdc194c..10dddc88 100644
--- a/src/util/Config.ts
+++ b/src/util/Config.ts
@@ -25,17 +25,17 @@ export interface RateLimitOptions {
}
export interface Region {
- id: string,
- name: string,
- vip: boolean,
- custom: boolean,
- deprecated: boolean,
- optimal: boolean,
+ id: string;
+ name: string;
+ vip: boolean;
+ custom: boolean;
+ deprecated: boolean;
+ optimal: boolean;
}
export interface KafkaBroker {
- ip: string,
- port: number
+ ip: string;
+ port: number;
}
export interface DefaultOptions {
@@ -133,10 +133,13 @@ export interface DefaultOptions {
regions: {
default: string;
available: Region[];
- }
+ };
+ rabbitmq: {
+ host: string | null;
+ };
kafka: {
- brokers: KafkaBroker[] | null
- }
+ brokers: KafkaBroker[] | null;
+ };
}
export const DefaultOptions: DefaultOptions = {
@@ -230,17 +233,18 @@ export const DefaultOptions: DefaultOptions = {
},
regions: {
default: "fosscord",
- available: [
- { id: "fosscord", name: "Fosscord", vip: false, custom: false, deprecated: false, optimal: false },
- ]
+ available: [{ id: "fosscord", name: "Fosscord", vip: false, custom: false, deprecated: false, optimal: false }],
+ },
+ rabbitmq: {
+ host: null,
},
kafka: {
- brokers: null
- }
+ brokers: null,
+ },
};
export const ConfigSchema = new Schema({}, { strict: false });
-export interface DefaultOptionsDocument extends DefaultOptions, Document { }
+export interface DefaultOptionsDocument extends DefaultOptions, Document {}
export const ConfigModel = model<DefaultOptionsDocument>("Config", ConfigSchema, "config");
diff --git a/src/util/RabbitMQ.ts b/src/util/RabbitMQ.ts
new file mode 100644
index 00000000..9df95231
--- /dev/null
+++ b/src/util/RabbitMQ.ts
@@ -0,0 +1,14 @@
+import amqp, { Connection, Channel } from "amqplib";
+import Config from "./Config";
+
+var rabbitCon: Connection;
+var rabbitCh: Channel;
+
+export async function init() {
+ const host = Config.get().rabbitmq.host;
+ if (!host) return;
+ rabbitCon = await amqp.connect(host);
+ rabbitCh = await rabbitCon.createChannel();
+}
+
+export { rabbitCon, rabbitCh };
diff --git a/src/util/index.ts b/src/util/index.ts
index 7e8bca20..7523a6ad 100644
--- a/src/util/index.ts
+++ b/src/util/index.ts
@@ -5,4 +5,5 @@ export * from "./MessageFlags";
export * from "./Permissions";
export * from "./Snowflake";
export * from "./UserFlags";
-export * from "./toBigInt"
\ No newline at end of file
+export * from "./toBigInt";
+export * from "./RabbitMQ";
|
