Interactions avec la db

db/Database.js

@@ -6,24 +6,50 @@ class Database{
 
     constructor(url){
         this.#client = new MongoClient(url);
+        this.connect();
     }
 
     async connect(){
         try {
-            await this.#client.connect();
-            await this.listDatabases()    
+            await this.#client.connect();    
         } catch (e) {
             console.error(e);
             await this.#client.close();
         }
     }
 
-    async listDatabases(){
-        let databasesList = await this.#client.db().admin().listDatabases();
-     
-        console.log("Databases:");
-        databasesList.databases.forEach(db => console.log(` - ${db.name}`));
+    async close(){
+        await this.#client.close();
+    }
+
+    async listCollections(){
+        return await this.#db.collections();
     };
+
+    async init(nomDB){
+        this.#db = this.#client.db(nomDB);
+        await this.#db.createCollection('users'); // table des utilisateurs
+        await this.#db.createCollection('documents'); // table des documents
+        await this.#db.createCollection('partage'); // table qui associe les utilisateurs aux documents
+
+        console.log("Collections créées !");
+    }
+
+    async insert(collection, data){
+        await this.#db.collection(collection).insertOne(data);
+    }
+
+    async insertMany(collection, data){
+        await this.#db.collection(collection).insertMany(data);
+    }
+
+    async find(collection, query){
+        return await this.#db.collection(collection).find(query).toArray();
+    }
+
 }
 
-module.exports = Database;
+db = new Database("mongodb://127.0.0.1:27017/test?retryWrites=true&w=majority");
\ No newline at end of file
+db.init("collab");
+
+module.exports = db;
\ No newline at end of file