import "mocha"; import { expect } from "chai"; import { TestHelper } from "../../helper/index"; import { MongoPortable } from "../../../src/core/index"; import { Collection } from "../../../src/collection/index"; import { Selector } from "../../../src/selector/index"; import { ObjectId } from "../../../src/document/index"; TestHelper.initLogger(); var TEST_DOC = null; var buildDoc = function(obj) { if (TEST_DOC === null) { TEST_DOC = { _id: new ObjectId(123456789), stringField: "yes", numberField: 9 }; } return TEST_DOC; }; var TEST_DDBB = "test_database"; var TEST_COLL = "test_collection"; // var TEST_DOC = { // _id: __id, // stringField: "yes", // numberField: 9 // }; var db = null; describe("Collection", function() { this.timeout(process.env.MOCHA_TIMEOUT || 2000); before(function() { db = new MongoPortable(TEST_DDBB, null); }); after(function() { db.dropDatabase(); db = null; }); describe("#Constructor", function() { it("should have the dependencies ready", function() { TestHelper.assertDependencies([MongoPortable, Collection, Selector]); expect(db).to.exist; expect(db._databaseName).to.be.equal(TEST_DDBB); //expect(MongoPortable._connHelper.hasConnection(TEST_DDBB)).to.be.true; }); it("should be able to instanciate", function() { var coll = new Collection(db, TEST_COLL); expect(coll).to.exist; expect(coll.name).to.be.equal(TEST_COLL); expect(coll.fullName).to.be.equal(db._databaseName + '.' + TEST_COLL); }); }); describe("#CRUD", function() { describe(" - Create", function() { it("should be able to insert a document", function(done) { db.collection(TEST_COLL, null) .then(coll => { buildDoc(null); coll.insert(TEST_DOC, function(error, inserted) { expect(error).to.not.exist; expect(inserted).to.exist; expect(inserted.stringField).to.be.equal(TEST_DOC.stringField); expect(inserted.numberField).to.be.equal(TEST_DOC.numberField); expect(coll.docs).to.have.length(1); done(); }); }); }); it("should be able to save a new document", function(done) { db.collection(TEST_COLL).then(coll => { // new document coll.save({ stringField: "save", numberField: 3 }).then(inserted => { expect(inserted).to.exist; expect(inserted._id).to.exist; expect(inserted.stringField).to.be.equal("save"); expect(inserted.numberField).to.be.equal(3); done(); }); }); }); it("should be able to save an existing document", function(done) { db.collection(TEST_COLL).then(coll => { // update / upsert coll.save({ _id: 12345, stringField: "save" }).then((updatedInfo) => { expect(updatedInfo).to.exist; expect(updatedInfo.updated).to.exist; expect(updatedInfo.inserted).to.exist; expect(updatedInfo.updated.documents).to.not.exist; expect(updatedInfo.updated.count).to.be.equal(0); expect(updatedInfo.inserted.documents).to.be.instanceof(Array); expect(updatedInfo.inserted.count).to.be.equal(1); var inserted = updatedInfo.inserted.documents[0]; expect(inserted._id).to.be.equal("12345"); expect(inserted.stringField).to.be.equal("save"); done(); }); }); }); }); describe(" - Read", function() { it("should be able to read the first document", function(done) { db.collection(TEST_COLL).then(coll => { coll.findOne(function(error, doc) { expect(doc).to.exist; expect(doc._id).to.exist; expect(doc.stringField).to.exist; expect(doc.numberField).to.be.equal(TEST_DOC.numberField); done(); }); }) }); it("should be able to read a document", function(done) { db.collection(TEST_COLL).then(coll => { coll.findOne({stringField: "yes"}, {_id: -1, numberField: 1}, { fields: { numberField: 1 }}) .then(doc => { expect(doc).to.exist; expect(doc._id).to.not.exist; expect(doc.stringField).to.not.exist; expect(doc.numberField).to.be.equal(TEST_DOC.numberField); coll.findOne({_id: 123456789}, null, { fields: { numberField: 1 }}) .then(doc => { expect(doc).to.not.exist; coll.findOne(TEST_DOC._id) .then(doc => { expect(doc).to.exist; expect(doc._id).to.exist; expect(doc.stringField).to.be.equal(TEST_DOC.stringField); expect(doc.numberField).to.be.equal(TEST_DOC.numberField); // doc = coll.findOne({_id: new ObjectId()}); // expect(doc).to.not.exist; coll.findOne({_id: TEST_DOC._id}, function(error, doc) { expect(doc).to.exist; expect(doc._id).to.exist; expect(doc.stringField).to.exist; expect(doc.numberField).to.be.equal(TEST_DOC.numberField); done(); }); }) }); }); }); }); it("should be able to read several documents", function(done) { db.collection(TEST_COLL).then(coll => { coll.find({stringField: "yes"}).then(docs => { expect(docs).to.exist; for (let doc of docs) { expect(doc).to.exist; expect(doc._id).to.exist; expect(doc.stringField).to.exist; expect(doc.numberField).to.exist; } done(); }); }); /* var docs = coll.find({_id: new ObjectId()}, null, { forceFetch: true }); expect(docs).to.exist; expect(docs).to.have.length(0); // Callback var calls = 3; coll.find(function(error, docs) { expect(error).to.not.exist; expect(docs).to.exist; expect(docs).to.have.length(3); var doc = docs[0]; expect(doc).to.exist; expect(doc._id).to.exist; expect(doc.stringField).to.exist; expect(doc.numberField).to.exist; if (calls === 1) { done(); } else { calls--; } }); coll.find({ stringField: "yes" }, function(error, docs) { expect(error).to.not.exist; expect(docs).to.exist; expect(docs).to.have.length(1); var doc = docs[0]; expect(doc).to.exist; expect(doc._id).to.exist; expect(doc.stringField).to.exist; expect(doc.numberField).to.exist; if (calls === 1) { done(); } else { calls--; } }); coll.find({ stringField: "yes" }, { stringField: -1 }, function(error, docs) { expect(error).to.not.exist; expect(docs).to.exist; expect(docs).to.have.length(1); var doc = docs[0]; expect(doc).to.exist; expect(doc._id).to.exist; expect(doc.stringField).to.not.exist; expect(doc.numberField).to.exist; if (calls === 1) { done(); } else { calls--; } }); */ }); }); describe(" - Update", function() { it("should be able to update a document", function(done) { db.collection(TEST_COLL).then(coll => { coll.update( TEST_DOC._id, { numberField: 5, unexistingField: 1, _id: "non updated" } ).then(updatedInfo => { expect(updatedInfo).to.exist; expect(updatedInfo.updated).to.exist; expect(updatedInfo.inserted).to.exist; expect(updatedInfo.updated.documents).to.be.instanceof(Array); expect(updatedInfo.updated.count).to.be.equal(1); expect(updatedInfo.inserted.documents).to.not.exist; expect(updatedInfo.inserted.count).to.be.equal(0); var updated = updatedInfo.updated.documents[0]; expect(updated.unexistingField).to.not.exist; expect(updated._id).to.be.eql(TEST_DOC._id); expect(updated.stringField).to.be.equal("yes"); expect(updated.numberField).to.be.equal(5); coll.findOne({stringField: "yes"}).then(doc => { expect(doc).to.exist; expect(doc.stringField).to.be.equal("yes"); expect(doc.numberField).to.be.equal(5); done(); }); }); }); /**/ // coll.insert({ // _id: "TESTING", // objectField1: { // arrayField1: [1, 2, "3"], // arrayField2: [{ // subField1: "test1" // }, { // subField1: "test2" // }] // }, // arrayField1: [1, 2, "3"], // arrayField2: [{ // subField1: "test1" // }, { // subField1: "test2" // }] // }); // coll.update( // { // _id: "TESTING" // }, { // $set: { // "objectField1.arrayField1.1": "setted", // "objectField1.arrayField2.1.subField1": "setted", // "arrayField1.1": "setted", // "arrayField2.1.subField1": "setted" // } // }); /**/ // By _id /* // By field updatedInfo = coll.update({stringField: "yes"}, {numberField: 1}); expect(updatedInfo).to.exist; expect(updatedInfo.updated).to.exist; expect(updatedInfo.inserted).to.exist; expect(updatedInfo.updated.documents).to.be.instanceof(Array); expect(updatedInfo.updated.count).to.be.equal(1); expect(updatedInfo.inserted.documents).to.not.exist; expect(updatedInfo.inserted.count).to.be.equal(0); updated = updatedInfo.updated.documents[0]; expect(updated.stringField).to.be.equal("yes"); expect(updated.numberField).to.be.equal(1); doc = coll.findOne({stringField: "yes"}); expect(doc).to.exist; expect(doc.stringField).to.be.equal("yes"); expect(doc.numberField).to.be.equal(1); // No matches updatedInfo = coll.update({stringField: "nope"}, {numberField: 1}); expect(updatedInfo).to.exist; expect(updatedInfo.updated).to.exist; expect(updatedInfo.inserted).to.exist; expect(updatedInfo.updated.documents).to.not.exist; expect(updatedInfo.updated.count).to.be.equal(0); expect(updatedInfo.inserted.documents).to.not.exist; expect(updatedInfo.inserted.count).to.be.equal(0); */ }); describe("should be able to use update operators", function() { var expectUpdateInfo = function(error, updatedInfo, nUpdated, nInserted) { expect(error).to.not.exist; expect(updatedInfo).to.exist; expect(updatedInfo.updated).to.exist; expect(updatedInfo.inserted).to.exist; if (nUpdated > 0) { expect(updatedInfo.updated.documents).to.be.instanceof(Array); expect(updatedInfo.updated.count).to.be.equal(nUpdated); } else { expect(updatedInfo.updated.documents).to.not.exist; expect(updatedInfo.updated.count).to.be.equal(0); } if (nInserted > 0) { expect(updatedInfo.inserted.documents).to.be.instanceof(Array); expect(updatedInfo.inserted.count).to.be.equal(nInserted); } else { expect(updatedInfo.inserted.documents).to.not.exist; expect(updatedInfo.inserted.count).to.be.equal(0); } }; before(function(done) { db.collection("FIELD_OP").then(coll => { coll.bulkInsert([ { stringField: "field_op", numberField: 3 }, { stringField: "array_op", arrayField: ["first", "inside", "other", "last"] }, { stringField: "yep6", numberField: 7 }, { stringField: "yep8", numberField: 9 } ]).then(docs => { done(); }); }); }); describe("- Field Update Operators", function() { before(function() { this.timeout(5000); }); after(function() { this.timeout(2000); }); it("should update with the $inc operator", function(done) { db.collection("FIELD_OP").then(coll => { coll.update( { stringField: "field_op" }, { $inc: { numberField: 2, otherNumberField: 3 } }).then((updatedInfo) => { expectUpdateInfo(null, updatedInfo, 1, 0); coll.findOne({stringField: "field_op"}).then(doc => { expect(doc).to.exist; expect(doc.stringField).to.be.equal("field_op"); expect(doc.numberField).to.be.equal(5); expect(doc.otherNumberField).to.be.equal(3); done(); }); }); }); }); it.skip("should update with the $mul operator", function() { }); it("should update with the $rename operator", function(done) { db.collection("FIELD_OP").then(coll => { var selector = { stringField: "field_op" }; var update = { $rename: { numberField: 'numericField' } }; coll.update(selector, update).then(updatedInfo => { expectUpdateInfo(null, updatedInfo, 1, 0); coll.findOne({stringField: "field_op"}).then(doc => { expect(doc).to.exist; expect(doc.stringField).to.be.equal("field_op"); expect(doc.numberField).to.not.exist; expect(doc.numericField).to.be.equal(5); done(); }); }); }); }); it.skip("should update with the $setOnInsert operator", function() { }); it("should update with the $set operator", function(done) { db.collection("FIELD_OP").then(coll => { var selector = { stringField: "field_op" }; var update = { $set: { booleanField: true, "objectField.field": ["yes!", "noo"], newField: "ok", "newArray.1": "second" } }; coll.update(selector, update).then(updatedInfo => { expectUpdateInfo(null, updatedInfo, 1, 0); coll.findOne({stringField: "field_op"}).then(doc => { expect(doc).to.exist; expect(doc.stringField).to.be.equal("field_op"); expect(doc.numberField).to.not.exist; expect(doc.numericField).to.be.equal(5); expect(doc.booleanField).to.be.true; expect(doc.objectField).to.be.eql({ field: ["yes!", "noo"] }); expect(doc.newField).to.be.equal("ok"); expect(doc.newArray).to.exist; expect(doc.newArray).to.be.instanceof(Array); expect(doc.newArray).to.have.length(2); expect(doc.newArray[1]).to.be.equal("second"); done(); }); }); }); }); it("should update with the $unset operator", function(done) { db.collection("FIELD_OP").then(coll => { var selector = { stringField: "field_op", "objectField.field.1": "noo" }; var update = { $unset: { booleanField: "does not matter", "newArray.1": "neither does this" // TODO } }; coll.update(selector, update).then(updatedInfo => { expectUpdateInfo(null, updatedInfo, 1, 0); coll.findOne({stringField: "field_op"}).then(doc => { expect(doc).to.exist; expect(doc.stringField).to.be.equal("field_op"); expect(doc.numberField).to.not.exist; expect(doc.numericField).to.be.equal(5); expect(doc.booleanField).to.not.exist; expect(doc.objectField).to.be.eql({ field: ["yes!", "noo"] }); expect(doc.newArray).to.exist; expect(doc.newArray).to.have.length(2); expect(doc.newArray[1]).to.be.equal(null); done(); }); }); }); }); it.skip("should update with the $min operator", function() { }); it.skip("should update with the $max operator", function() { }); it.skip("should update with the $currentDate operator", function() { }); }); /* describe("- Array Update Operators", function() { it("should update with the $addToSet operator", function() { var coll = db.collection("FIELD_OP"); var selector = { stringField: "array_op" }; var update = { $addToSet: { arrayField: "newly", unexistingArray: "first" } }; var updatedInfo = coll.update(selector, update); expectUpdateInfo(null, updatedInfo, 1, 0); var doc = coll.findOne({stringField: "array_op"}); expect(doc).to.exist; expect(doc.stringField).to.be.equal("array_op"); expect(doc.arrayField).to.exist; expect(doc.arrayField).to.have.length(5); expect(doc.arrayField[1]).to.be.equal("inside"); expect(doc.arrayField[4]).to.be.equal("newly"); expect(doc.unexistingArray).to.exist; expect(doc.unexistingArray).to.have.length(1); expect(doc.unexistingArray[0]).to.be.equal("first"); // operator $each update = { $addToSet: { unexistingArray: { $each: ["first", "second"] } } }; updatedInfo = coll.update(selector, update); expectUpdateInfo(null, updatedInfo, 1, 0); doc = coll.findOne({stringField: "array_op"}); expect(doc).to.exist; expect(doc.stringField).to.be.equal("array_op"); expect(doc.arrayField).to.exist; expect(doc.arrayField).to.have.length(5); expect(doc.arrayField[1]).to.be.equal("inside"); expect(doc.arrayField[4]).to.be.equal("newly"); expect(doc.unexistingArray).to.exist; expect(doc.unexistingArray).to.have.length(2); expect(doc.unexistingArray[1]).to.be.equal("second"); }); it("should update with the $pop operator", function() { var coll = db.collection("FIELD_OP"); var selector = { stringField: "array_op" }; var update = { $pop: { arrayField: 1 } }; var updatedInfo = coll.update(selector, update); expectUpdateInfo(null, updatedInfo, 1, 0); update['$pop'].arrayField = -1; updatedInfo = coll.update(selector, update); expectUpdateInfo(null, updatedInfo, 1, 0); var doc = coll.findOne({stringField: "array_op"}); expect(doc).to.exist; expect(doc.stringField).to.be.equal("array_op"); expect(doc.arrayField).to.exist; expect(doc.arrayField).to.have.length(3); expect(doc.arrayField[0]).to.not.be.equal("first"); expect(doc.arrayField[2]).to.be.equal("last"); }); it("should update with the $push operator", function() { var coll = db.collection("FIELD_OP"); var selector = { stringField: "array_op" }; var update = { $push: { arrayField: "added", arrayField2: "first" } }; var updatedInfo = coll.update(selector, update); expectUpdateInfo(null, updatedInfo, 1, 0); var doc = coll.findOne({stringField: "array_op"}); expect(doc).to.exist; expect(doc.stringField).to.be.equal("array_op"); expect(doc.arrayField).to.exist; expect(doc.arrayField).to.have.length(4); expect(doc.arrayField[3]).to.be.equal("added"); expect(doc.arrayField2).to.exist; expect(doc.arrayField2).to.have.length(1); expect(doc.arrayField2[0]).to.be.equal("first"); }); it("should update with the $pushAll operator", function() { // TODO Change, as is deprecated in MongoDB 2.4+ var coll = db.collection("FIELD_OP"); var selector = { stringField: "array_op" }; var update = { $pushAll: { arrayField2: ["second", "third", "ot99her", "some99thing", "last"], addedArray: ["new"] } }; var updatedInfo = coll.update(selector, update); expectUpdateInfo(null, updatedInfo, 1, 0); var doc = coll.findOne({stringField: "array_op"}); expect(doc).to.exist; expect(doc.stringField).to.be.equal("array_op"); expect(doc.arrayField).to.exist; expect(doc.arrayField2).to.exist; expect(doc.arrayField2).to.have.length(6); expect(doc.arrayField2[0]).to.be.equal("first"); expect(doc.arrayField2[1]).to.be.equal("second"); expect(doc.arrayField2[2]).to.be.equal("third"); expect(doc.arrayField2[5]).to.be.equal("last"); expect(doc.addedArray).to.exist; expect(doc.addedArray).to.have.length(1); expect(doc.addedArray[0]).to.be.equal("new"); }); it("should update with the $pull operator", function() { var coll = db.collection("FIELD_OP"); var selector = { stringField: "array_op" }; var update = { $pull: { arrayField: "first", arrayField2: { $regex: /^[\D][a-z]+[\d]+[a-z]+$/, $options: 'ig' } } }; var updatedInfo = coll.update(selector, update); expectUpdateInfo(null, updatedInfo, 1, 0); var doc = coll.findOne({stringField: "array_op"}); expect(doc).to.exist; expect(doc.stringField).to.be.equal("array_op"); expect(doc.arrayField).to.exist; expect(doc.arrayField).to.have.length(4); expect(doc.arrayField2).to.exist; expect(doc.arrayField2).to.have.length(4); expect(doc.arrayField2[0]).to.be.equal("first"); expect(doc.arrayField2[1]).to.be.equal("second"); expect(doc.arrayField2[2]).to.be.equal("third"); expect(doc.arrayField2[3]).to.be.equal("last"); }); it("should update with the $pullAll operator", function() { var coll = db.collection("FIELD_OP"); var selector = { stringField: "array_op" }; var update = { $pullAll: { arrayField2: ["first", "last"] } }; var updatedInfo = coll.update(selector, update); expectUpdateInfo(null, updatedInfo, 1, 0); var doc = coll.findOne({stringField: "array_op"}); expect(doc).to.exist; expect(doc.stringField).to.be.equal("array_op"); expect(doc.arrayField).to.exist; expect(doc.arrayField).to.have.length(4); expect(doc.arrayField2).to.exist; expect(doc.arrayField2).to.have.length(2); expect(doc.arrayField2[0]).to.not.be.equal("first"); expect(doc.arrayField2[1]).to.not.be.equal("last"); }); }); */ describe.skip("- Bitwise Update Operators", function() { it("should update with the $bit operator", function() { }); }); describe.skip("- Isolation Update Operators", function() { it("should update with the $isolated operator", function() { }); }); }); it("should be able to use upsert a document", function(done) { db.collection(TEST_COLL).then(coll => { coll.update( { stringField: "noope" }, { stringField: "yees", numberField: 2 }, { upsert: true } ).then(updatedInfo => { expect(updatedInfo).to.exist; expect(updatedInfo.updated).to.exist; expect(updatedInfo.inserted).to.exist; expect(updatedInfo.updated.documents).to.not.exist; expect(updatedInfo.updated.count).to.be.equal(0); expect(updatedInfo.inserted.documents).to.be.instanceof(Array); expect(updatedInfo.inserted.count).to.be.equal(1); var created = updatedInfo.inserted.documents[0]; expect(created).to.exist; expect(created.stringField).to.be.equal("yees"); expect(created.numberField).to.be.equal(2); coll.findOne({stringField: "yees"}).then(doc => { expect(doc).to.exist; expect(doc.stringField).to.be.equal("yees"); expect(doc.numberField).to.be.equal(2); done(); }); }); }); }); it("should be able to update several documents", function(done) { db.collection(TEST_COLL).then(coll => { // add _id coll.update( { stringField: /^ye+s$/ig }, { numberField: 9 }, { multi: true } ).then(updatedInfo => { expect(updatedInfo).to.exist; expect(updatedInfo.updated).to.exist; expect(updatedInfo.inserted).to.exist; expect(updatedInfo.updated.documents).to.be.instanceof(Array); expect(updatedInfo.updated.count).to.be.equal(2); expect(updatedInfo.inserted.documents).to.not.exist; expect(updatedInfo.inserted.count).to.be.equal(0); var updated1 = updatedInfo.updated.documents[0]; var updated2 = updatedInfo.updated.documents[1]; expect(updated1.stringField).to.be.equal("yes"); expect(updated1.numberField).to.be.equal(9); expect(updated2.stringField).to.be.equal("yees"); expect(updated2.numberField).to.be.equal(9); coll.find({ numberField: 9 }).then(docs => { expect(docs.length).to.be.equal(2); done(); }); }); }); }); it("should be able to override a document", function(done) { db.collection(TEST_COLL).then(coll => { // add _id coll.update( { stringField: "yees" }, { numberField: 10, booleanField: true, $inc: { numberField: 1 } }, { override: true } ).then(updatedInfo => { expect(updatedInfo).to.exist; expect(updatedInfo.updated).to.exist; expect(updatedInfo.inserted).to.exist; expect(updatedInfo.updated.documents).to.be.instanceof(Array); expect(updatedInfo.updated.count).to.be.equal(1); expect(updatedInfo.inserted.documents).to.not.exist; expect(updatedInfo.inserted.count).to.be.equal(0); var updated = updatedInfo.updated.documents[0]; expect(updated.stringField).to.not.exist; expect(updated.numberField).to.be.equal(10); expect(updated.booleanField).to.be.true; coll.find({numberField: 10}).then(docs => { expect(docs.length).to.be.equal(1); done(); }); }); }); }); it.skip("should be able to update as MongoDB does", function() { var coll = db.collection(TEST_COLL); var updatedInfo = coll.update( { stringField: "yes" }, { $inc: { numberField: 2 } }, { updateAsMongo: true } ); expect(updatedInfo).to.exist; expect(updatedInfo.updated).to.exist; expect(updatedInfo.inserted).to.exist; expect(updatedInfo.updated.documents).to.be.instanceof(Array); expect(updatedInfo.updated.count).to.be.equal(1); expect(updatedInfo.inserted.documents).to.not.exist; expect(updatedInfo.inserted.count).to.be.equal(0); var updated = updatedInfo.updated.documents[0]; expect(updated).to.exist; expect(updated.stringField).to.be.equal("yes"); expect(updated.numberField).to.be.equal(3); var doc = coll.findOne({stringField: "yes"}); expect(doc).to.exist; expect(doc.stringField).to.be.equal("yes"); expect(doc.numberField).to.be.equal(3); }); }); describe(" - Delete", function() { it.skip("should be able to remove a document", function(done) { var coll = db.collection(TEST_COLL); var removed = coll.remove({stringField: "yes"}); expect(removed).to.exist; expect(removed).to.be.instanceof(Array); expect(removed).to.be.have.length(1); expect(removed[0].stringField).to.be.equal("yes"); var doc = coll.findOne({stringField: "yes"}); expect(doc).to.not.exist; // Remove by _id coll.delete(TEST_DOC._id, function(error, removed) { expect(error).to.not.exist; expect(removed).to.exist; expect(removed).to.be.instanceof(Array); expect(removed).to.be.have.length(0); done(); }); }); it("should be able to remove all documents", function(done) { let docsToInsert = []; let numDocs = 50; for (let i = 1; i <= numDocs; i++) { docsToInsert.push({ numberField: i }); } db.collection("TEST_COLL_DELETE").then(coll => { coll.bulkInsert(docsToInsert).then(inserted => { expect(inserted).to.exist; expect(inserted).to.have.length(numDocs); coll.remove({}).then(removed => { expect(removed).to.exist; expect(removed).to.have.length(numDocs); // var doc = coll.findOne({stringField: "yes"}); coll.find().then(docs => { expect(docs).to.exist; expect(removed).to.have.length(0); done(); }).catch(error => { expect(error).to.not.exists; done(); }); }).catch(error => { expect(error).to.not.exists; done(); }); }).catch(error => { expect(error).to.not.exists; done(); }); }).catch(error => { expect(error).to.not.exists; done(); }); }); it.skip("should be able to destroy all documents", function(done) { var coll = db.collection(TEST_COLL); coll.destroy(function (error, removed) { expect(error).to.not.exist; expect(removed).to.exist; expect(removed).to.be.true; var doc = coll.findOne({stringField: "yes"}); expect(doc).to.not.exist; done(); }); }); it.skip("should be able to drop the collection", function(done) { var coll = db.collection(TEST_COLL); coll.drop(function (error, removed) { expect(error).to.not.exist; expect(removed).to.exist; expect(removed).to.be.true; var doc = coll.findOne({stringField: "yes"}); expect(doc).to.not.exist; done(); }); }); }); }); describe("#Backups", function() { var ID = null; // before(function() { // if (db) db.dropDatabase(); // db = new MongoPortable("BACKUPS", null); // db.collection("pruebas") // .insert({ stringField: "first" }, { chain: true }) // .insert({ stringField: "second" }, { chain: true }) // .insert({ stringField: "third" }, { chain: true }) // .insert({ stringField: "fourth" }); // }); describe.skip("#Backups", function() { it("should create a new backup", function(done) { var coll = db.collection("pruebas"); var snapshot = coll.backup("FIRST"); expect(snapshot).to.exist; expect(snapshot.backupID).to.exist; expect(snapshot.documents).to.exist; expect(snapshot.backupID).to.be.equal("FIRST"); expect(snapshot.documents).to.be.instanceof(Array); expect(snapshot.documents).to.have.length(4); coll.insert({ stringField: "new" }); coll.backup(function(error, snapshot) { expect(snapshot.backupID).to.exist; expect(snapshot.documents).to.exist; expect(snapshot.documents).to.be.instanceof(Array); expect(snapshot.documents).to.have.length(5); ID = snapshot.backupID; done(); }); }); it("should retrieve all backups", function() { var coll = db.collection("pruebas"); var snapshots = coll.backups(); expect(snapshots).to.exist; expect(snapshots).to.be.instanceof(Array); expect(snapshots).to.have.length(2); expect(snapshots[0].id).to.be.equal("FIRST"); expect(snapshots[0].documents).to.be.instanceof(Array); expect(snapshots[0].documents).to.have.length(4); expect(snapshots[1].documents).to.be.instanceof(Array); expect(snapshots[1].documents).to.have.length(5); }); it("should restore a backup", function() { var coll = db.collection("pruebas"); expect(coll.find().count()).to.be.equal(5); // By backupID var cursor = coll.restore("FIRST").find(); expect(cursor.count()).to.be.equal(4); }); it("should remove a backup", function() { var coll = db.collection("pruebas"); var removed = coll.removeBackup(ID); expect(removed).to.exist; expect(removed).to.be.equal(ID); var snapshots = coll.backups(); expect(snapshots).to.exist; expect(snapshots).to.be.instanceof(Array); expect(snapshots).to.have.length(1); }); it("should restore the only backup", function() { var coll = db.collection("pruebas"); expect(coll.find().count()).to.be.equal(4); // By backupID var cursor = coll.restore(function(error) { expect(error).to.not.exist; }).find(); expect(cursor.count()).to.be.equal(4); }); it("should drop all the backups", function(done) { var coll = db.collection("pruebas"); coll.removeBackup(function(error, removed) { expect(error).to.not.exist; expect(removed).to.be.true; done(); }); }); }); }); });