dynamic-record - npm Package Compare versions

Comparing version 0.4.1 to 0.4.2

build/DynamicSchema.js

@@ -147,4 +147,28 @@ "use strict";
     /**
-     * Add an index to the table's schema
+     * Drop the table from the database.
      *
+     * @method dropTable
+     * @memberOf DynamicSchema
+     * @instance
+     * @return {Promise}
+     */
+    dropTable() {
+        return connect.then((db) => {
+            return db.collection("_schema").deleteOne({ "_$id": this.tableSlug }).then((result) => {
+                return db.collection(this.tableSlug).drop();
+            }).then(() => {
+                return db.collection("_counters").deleteOne({ "_$id": this.tableSlug });
+            }).then(() => {
+                this.tableName = null;
+                this.tableSlug = null;
+                this.definition = {};
+                return Promise.resolve();
+            });
+        }).catch((err) => {
+            return Promise.reject(err);
+        });
+    }
+    /**
+     * Add an index to the table's schema.
+     *
      * @method renameTable
@@ -151,0 +175,0 @@ * @memberOf DynamicSchema

package.json

 {
   "name": "dynamic-record",
-  "version": "0.4.1",
+  "version": "0.4.2",
   "description": "A bare minimum Javascript implementation of the Active Record pattern",
@@ -5,0 +5,0 @@ "keywords": [

src/DynamicSchema.ts

@@ -195,5 +195,31 @@ require("dotenv").config();
 
+
 	/**
-	 * Add an index to the table's schema
+	 * Drop the table from the database.
 	 *
+	 * @method dropTable
+	 * @memberOf DynamicSchema
+	 * @instance
+	 * @return {Promise}
+	 */
+	dropTable(){
+		return connect.then((db) => {
+			return db.collection("_schema").deleteOne({"_$id": this.tableSlug}).then((result) => {
+				return db.collection(this.tableSlug).drop();
+			}).then(() => {
+				return db.collection("_counters").deleteOne({"_$id": this.tableSlug});
+			}).then(() => {
+				this.tableName = null;
+				this.tableSlug = null;
+				this.definition = {};
+				return Promise.resolve();
+			});
+		}).catch((err) => {
+			return Promise.reject(err);
+		});
+	}
+
+	/**
+	 * Add an index to the table's schema.
+	 *
 	 * @method renameTable
@@ -200,0 +226,0 @@ * @memberOf DynamicSchema

test/DynamicSchema.js

@@ -106,2 +106,70 @@ // For setup and clean ups
 
+	describe("dropTable()", function(){
+		let table;
+
+		beforeEach(function(done){
+			utils.dropTestTable().then((reply) => {
+				table = new DynamicSchema();
+				table.createTable(testSchema).then(() => {
+					done();
+				}).catch((err) => {
+					done(err);
+				});
+			});
+		});
+
+		after(function(){
+			return utils.dropTestTable();
+		});
+
+		it("should remove the table's entry in the _schema table", function(done){
+			connect.then((db) => {
+				table.dropTable().then(() => {
+					return db.collection("_schema").findOne({"_$id": testSchema.$id});
+				}).then((schema) => {
+					assert.isNull(schema, "Entry under _schema table is deleted.");
+					done();
+				});
+			}).catch((err) => {
+				done(err);
+			});
+		});
+		it("should drop the table itself", function(done){
+			connect.then((db) => {
+				table.dropTable().then(() => {
+					return db.listCollections({name: testSchema.$id}).toArray();
+				}).then((items) => {
+					assert.isEmpty(items, "Table is dropped from the database");
+					done();
+				});
+			}).catch((err) => {
+				done(err);
+			});
+		});
+		it("should remove the table's entry in the _counters table", function(done){
+			connect.then((db) => {
+				table.dropTable().then(() => {
+					return db.collection("_counters").findOne({"_$id": testSchema.$id});
+				}).then((schema) => {
+					assert.isNull(schema, "Entry under _counters table is deleted.");
+					done();
+				});
+			}).catch((err) => {
+				done(err);
+			});
+		});
+		it("should remove existing data from the instance", function(done){
+			connect.then((db) => {
+				table.dropTable().then(() => {
+					assert.isNull(table.tableName, "Table name is set to null");
+					assert.isNull(table.tableSlug, "Table slug is set to null");
+					assert.isEmpty(table.definition, "Table definition is emptied");
+					done();
+				});
+			}).catch((err) => {
+				done(err);
+			});
+		});
+	});
+
 	describe("renameTable()", function(){
@@ -108,0 +176,0 @@ // Instance of DynamicSchema used for testing

No alert changes

Worsened metrics

Total package byte prevSize

125812

decreased by-83.21%

Number of package files

29

decreased by-45.28%

Lines of code

3720

decreased by-30.74%

No dependency changes