Skip to content

Some tests to validate our mongodb wrapper #5638

New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

Sign up for GitHub

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

Merged
merged 4 commits into from
Oct 7, 2024
Merged

Some tests to validate our mongodb wrapper #5638

Changes from all commits
Commits
Show all changes
4 commits
Select commit Hold shift + click to select a range
0b99934
Some tests to validate our mongodb wrapper
Cookiezaurs Oct 7, 2024
50c6726
eslint
Cookiezaurs Oct 7, 2024
76edde1
more eslint
Cookiezaurs Oct 7, 2024
4d65c37
Merge branch 'next' into anna/next
Cookiezaurs Oct 7, 2024
File filter

Filter by extension

Filter by extension
Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
298 changes: 298 additions & 0 deletions test/unit-tests/db.tests.js
View file
Open in desktop
Original file line number Diff line number Diff line change
@@ -0,0 +1,298 @@
var request = require('supertest');
var should = require('should');
var testUtils = require("../../test/testUtils");
var plugins = require("../../plugins/pluginManager");
var db = "";


function runTest(options) {
it('Running with callbacks correctly', function(done) {
if (options.op === "insert") {
db.collection("testCommands").insert(options.query, function(err, res) {
if (err) {
done(err);
}
else {
res.should.have.property("acknowledged", true);
res.should.have.property("insertedCount", 1);
res.should.have.property("insertedId");
if (options.query._id) {
res.should.have.property("insertedId", options.query._id);
}
done();
}
});
}
else if (options.op === "findAndModify") {
db.collection("testCommands").findAndModify(options.query, options.sort || {}, options.update, options.options, function(err, res) {
should.not.exist(err);
console.log(JSON.stringify(res));


if (options.options.remove) {
res = res || {};
if (options.query._id) {
res.should.have.property("_id", options.query._id);
}
else {
res.should.have.property("_id");
}

if (options.query.name) {
res.should.have.property("name", options.query.name);
}
else {
res.should.have.property("name");
}
}
else {
res.should.have.property("value");
if (options.options.new) {
if (options.update.$set.name) {
res.value.should.have.property("name", options.update.$set.name);
}
}
else {
if (options.query.name) {
res.value.should.have.property("name", options.query.name);
}
}
if (options.query._id) {
res.value.should.have.property("_id", options.query._id);
}
}
done();
});
}
else {
done("unkonown op: " + options.op);
}
});

it('Running with callbacks + error', function(done) {
if (options.queryError) {
if (options.op === "insert") {
db.collection("testCommands").insert(options.queryError, function(err, res) {
if (err) {
err.should.have.property.code;
done();
}
else {
done("Should have failed with error but succeeded");
}
});
}
else if (options.op === "findAndModify") {
db.collection("testCommands").findAndModify(options.query, options.sort || [], options.update, options.options, function(err, res) {
should.not.exist(err);
console.log(" " + JSON.stringify(res));
res.should.have.property("value");
if (options.query.name) {
res.value.should.have.property("name", options.query);
}
if (options.query._id) {
res.value.should.have.property("_id", options.query._id);
}
done();
});
}
else {
done("unkonown op: " + options.op);
}
}
else {
done();
}

});

it('Running with promises correctly', async function() {
if (options.op === "insert") {

var res = await db.collection("testCommands2").insert(options.query);
console.log(" " + JSON.stringify(res));
res.should.have.property("acknowledged", true);
//res.should.have.property("insertedCount", 1);
res.should.have.property("insertedId");
if (options.query._id) {
res.should.have.property("insertedId", options.query._id);
}

}
else if (options.op === "findAndModify") {
var res = await db.collection("testCommands2").findAndModify(options.query, options.sort || [], options.update, options.options);
console.log(" " + JSON.stringify(res));

if (options.options.remove) {
if (options.query._id) {
res.should.have.property("_id", options.query._id);
}
else {
res.should.have.property("_id");
}

if (options.query.name) {
res.should.have.property("name", options.query.name);
}
else {
res.should.have.property("name");
}
}
else {
res.should.have.property("value");
if (options.options.new) {
res.value.should.have.property("name", options.update.$set.name);
}
else {
if (options.query.name) {
res.value.should.have.property("name", options.query.name);
}
}
if (options.query._id) {
res.value.should.have.property("_id", options.query._id);
}
else {
res.value.should.have.property("_id");
}
}

}
else {
throw new Error("unkonown op: " + options.op);
}
});

it('Running with promises + error', async function() {
if (options.queryError) {
if (options.op === "insert") {
try {
var res = await db.collection("testCommands2").insert(options.queryError);
throw new Error("Should have failed with error but succeeded");
}
catch (err) {
err.should.have.property.code;
}
}
else if (options.op === "findAndModify") {
try {
var res = await db.collection("testCommands2").findAndModify(options.query, options.sort || [], options.update, options.options);
throw new Error("Should have failed with error but succeeded");
}
catch (err) {
err.should.have.property.code;
}
}
else {
throw new Error("unkonown op: " + options.op);
}
}

});
}
describe('Testing Simple database operations', function() {

describe('Setting up db connection', function() {
before('Create db connection', async function() {
testUtils.db = await plugins.dbConnection("countly");
testUtils.client = testUtils.db.client;
});
it('Setting db', function(done) {
db = testUtils.client.db("countly");
done();
});
});

describe('Cleanup', function() {
it('should remove collection with callback', function(done) {
db.collection("testCommands").drop(function(err, res) {
if (err) {
console.log(err);
}
res.should.be.true;
done();
});

});
it('should remove collection with promise', async function() {
var res = await db.collection("testCommands2").drop();
res.should.be.true;
});
});

describe("testing insert operation", function() {
describe('should insert simple document without _id', function() {
runTest({"op": "insert", query: { name: "test" }});
});
describe('should insert simple document with _id', function() {
runTest({"op": "insert", query: {_id: "aaaaa", name: "test" }, queryError: {"_id": "aaaaa"}});
});
});

describe('Testing findAndModify', function() {
describe('Find and modify new + upsert(not existing)', function() {
runTest({"op": "findAndModify", query: {_id: "bbbb"}, "update": { $set: { name: "test_b" } }, "options": { new: true, upsert: true }});
});
describe('Find and modify new + upsert(existing)', function() {
runTest({"op": "findAndModify", query: {_id: "bbbb"}, "update": { $set: { name: "test_c" } }, "options": { new: true, upsert: true }});
});
describe('Find and modify upsert (existing)', function() {
runTest({"op": "findAndModify", query: {_id: "bbbb"}, "update": { $set: { name: "test_d" } }, "options": { upsert: true }});
});
describe('Find and modify upsert:false,new:true', function() {
runTest({"op": "findAndModify", query: { name: "test" }, "update": { $set: { name: "test2" } }, "options": { new: true }});
});
describe('Find and modify upsert:false,new:false', function() {
runTest({"op": "findAndModify", query: { name: "test" }, "update": { $set: { name: "test2" } }, "options": { new: false }});
});
describe('Find and modify remove:true', function() {
runTest({"op": "findAndModify", query: { _id: "aaaaa" }, "update": {}, "options": { remove: true }});
});
});

describe('Testing aggregation pipeline', function() {
describe('Run aggregation and get ', function() {
runTest({"op": "findAndModify", query: {_id: "bbbb"}, "update": { $set: { name: "test_c" } }, "options": { new: true, upsert: true }});
});
});

describe("test working with cursors", function() {
it("test cursor using await and going toArray()", async function() {
var cursor = db.collection("testCommands2").find();
var res = await cursor.toArray();
console.log(JSON.stringify(res));
res.length.should.be.above(0);
res.should.be.an.instanceOf(Array);
});
it("test cursor using await and going next()", async function() {
var cursor = await db.collection("testCommands2").find({});
var doc = await cursor.next();
while (doc) {
doc.should.have.property("_id");
doc.should.have.property("name");
doc = await cursor.next();
}
});
});



describe('Cleanup', function() {
it('should remove collection with callback', function(done) {
db.collection("testCommands").drop(function(err, res) {
if (err) {
console.log(err);
}
res.should.be.true;
done();
});

});
it('should remove collection with promise', async function() {
var res = await db.collection("testCommands2").drop();
res.should.be.true;
});
after('Close db connection', async function() {
testUtils.client.close();
});
});
});
Loading