aboutsummaryrefslogtreecommitdiff
path: root/node_modules/mongodb-core/test.js
diff options
context:
space:
mode:
authornanalelfe <nargiza.nosirova@mail.utoronto.ca>2016-07-27 12:46:04 +0000
committernanalelfe <nargiza.nosirova@mail.utoronto.ca>2016-07-27 12:46:04 +0000
commit7bee9b7e0968b650b3dbe2e35bf3a0d7d6e5e00e (patch)
tree4e63af46a6e306bfeac1ef4b8bd83e1b45a37257 /node_modules/mongodb-core/test.js
parent6520aa92a114d65b17b178a952c8985e84afd231 (diff)
Removed some unused modules with prune
Diffstat (limited to 'node_modules/mongodb-core/test.js')
-rw-r--r--node_modules/mongodb-core/test.js71
1 files changed, 0 insertions, 71 deletions
diff --git a/node_modules/mongodb-core/test.js b/node_modules/mongodb-core/test.js
deleted file mode 100644
index 8864284..0000000
--- a/node_modules/mongodb-core/test.js
+++ /dev/null
@@ -1,71 +0,0 @@
-var ReplSet = require('./lib2/topologies/replset'),
- ReadPreference = require('./lib2/topologies/read_preference');
-
-// Attempt to connect
-var server = new ReplSet([{
- host: 'localhost', port: 31000
-}, {
- host: 'localhost', port: 31001
-}], {
- setName: 'rs'
-});
-
-function executeCursors(_server, cb) {
- var count = 100;
-
- for(var i = 0; i < 100; i++) {
- // Execute the write
- var cursor = _server.cursor('test.test', {
- find: 'test.test'
- , query: {a:1}
- }, {readPreference: new ReadPreference('secondary')});
-
- // Get the first document
- cursor.next(function(err, doc) {
- count = count - 1;
- if(err) console.dir(err)
- if(count == 0) return cb();
- });
- }
-}
-
-server.on('connect', function(_server) {
- console.log("---------------------------------- 0")
- // Attempt authentication
- _server.auth('scram-sha-1', 'admin', 'root', 'root', function(err, r) {
- console.log("---------------------------------- 1")
- // console.dir(err)
- // console.dir(r)
-
- _server.insert('test.test', [{a:1}], function(err, r) {
- console.log("---------------------------------- 2")
- console.dir(err)
- if(r)console.dir(r.result)
- var name = null;
-
- _server.on('joined', function(_t, _server) {
- if(name == _server.name) {
- console.log("=========== joined :: " + _t + " :: " + _server.name)
- executeCursors(_server, function() {
- });
- }
- })
-
- // var s = _server.s.replicaSetState.secondaries[0];
- // s.destroy({emitClose:true});
- executeCursors(_server, function() {
- console.log("============== 0")
- // Attempt to force a server reconnect
- var s = _server.s.replicaSetState.secondaries[0];
- name = s.name;
- s.destroy({emitClose:true});
- // console.log("============== 1")
-
- // _server.destroy();
- // test.done();
- });
- });
- });
-});
-
-server.connect();