1 files changed, 12 insertions, 1 deletions
diff --git a/src/util/Database.ts b/src/util/Database.ts
index 5d9afab9..339ac65b 100644
--- a/src/util/Database.ts
+++ b/src/util/Database.ts
@@ -7,7 +7,12 @@ const uri = process.env.MONGO_URL || "mongodb://localhost:27017/fosscord?readPre
console.log(`[DB] connect: ${uri}`);
-const connection = mongoose.createConnection(uri, { autoIndex: true, useNewUrlParser: true, useUnifiedTopology: true });
+const connection = mongoose.createConnection(uri, {
+ autoIndex: true,
+ useNewUrlParser: true,
+ useUnifiedTopology: true,
+ useFindAndModify: false,
+});
export default <Connection>connection;
@@ -56,6 +61,12 @@ export class MongooseCache extends EventEmitter {
}
};
+ changeStream = (pipeline: any) => {
+ this.pipeline = pipeline;
+ this.destroy();
+ this.init();
+ };
+
convertResult = (obj: any) => {
if (obj instanceof Long) return BigInt(obj.toString());
if (typeof obj === "object") {
|
