aboutsummaryrefslogtreecommitdiff
path: root/src/server/database.ts
diff options
context:
space:
mode:
authoranika-ahluwalia <anika.ahluwalia@gmail.com>2020-04-18 17:56:30 -0500
committeranika-ahluwalia <anika.ahluwalia@gmail.com>2020-04-18 17:56:30 -0500
commit04e2cdc30dd71cccb066f713a93cdc4d3bbd169c (patch)
treeebacc25b4b99ac74b4bf79c12d0ae17a46033b0b /src/server/database.ts
parenta261ab5e9697277bec029803f1fa0c890f0c8fd5 (diff)
parent9f8e76451b807ed8f51ef32aab9b2255dfccd525 (diff)
Merge branch 'master' of https://github.com/browngraphicslab/Dash-Web into script_documents
Diffstat (limited to 'src/server/database.ts')
-rw-r--r--src/server/database.ts18
1 files changed, 12 insertions, 6 deletions
diff --git a/src/server/database.ts b/src/server/database.ts
index a46531641..1da31c5ff 100644
--- a/src/server/database.ts
+++ b/src/server/database.ts
@@ -14,7 +14,7 @@ export namespace Database {
export let disconnect: Function;
const schema = 'Dash';
const port = 27017;
- export const url = `mongodb://localhost:${port}/${schema}`;
+ export const url = `mongodb://localhost:${port}/`;
enum ConnectionStates {
disconnected = 0,
@@ -35,7 +35,7 @@ export namespace Database {
console.log(`mongoose established default connection at ${url}`);
resolve();
});
- mongoose.connect(url, { useNewUrlParser: true });
+ mongoose.connect(url, { useNewUrlParser: true, useUnifiedTopology: true, dbName: schema });
});
}
} catch (e) {
@@ -46,17 +46,22 @@ export namespace Database {
}
}
- class Database implements IDatabase {
+ export class Database implements IDatabase {
public static DocumentsCollection = 'documents';
private MongoClient = mongodb.MongoClient;
private currentWrites: { [id: string]: Promise<void> } = {};
private db?: mongodb.Db;
private onConnect: (() => void)[] = [];
-
constructor() {
- this.MongoClient.connect(url, { connectTimeoutMS: 30000, socketTimeoutMS: 30000 }, (_err, client) => {
+ }
+
+ doConnect() {
+ console.error(`\nConnecting to Mongo with URL : ${url}\n`);
+ this.MongoClient.connect(url, { connectTimeoutMS: 30000, socketTimeoutMS: 30000, useUnifiedTopology: true }, (_err, client) => {
+ console.error("mongo connect response\n");
if (!client) {
- console.error("\nPlease start MongoDB by running 'mongod' in a terminal before continuing...\n");
+ console.error("\nMongo connect failed with the error:\n");
+ console.log(_err);
process.exit(0);
}
this.db = client.db();
@@ -65,6 +70,7 @@ export namespace Database {
}
public async update(id: string, value: any, callback: (err: mongodb.MongoError, res: mongodb.UpdateWriteOpResult) => void, upsert = true, collectionName = Database.DocumentsCollection) {
+
if (this.db) {
const collection = this.db.collection(collectionName);
const prom = this.currentWrites[id];