gerrit.onap Code Review - aai/esr-gui.git/blob

   1 var Server = require('./lib/topologies/server');
   2
   3 // Attempt to connect
   4 var server = new Server({
   5   host: 'localhost', port: 27017, socketTimeout: 500
   6 });
   7
   8 // function executeCursors(_server, cb) {
   9 //   var count = 100;
  10 //
  11 //   for(var i = 0; i < 100; i++) {
  12 //     // Execute the write
  13 //     var cursor = _server.cursor('test.test', {
  14 //         find: 'test.test'
  15 //       , query: {a:1}
  16 //     }, {readPreference: new ReadPreference('secondary')});
  17 //
  18 //     // Get the first document
  19 //     cursor.next(function(err, doc) {
  20 //       count = count - 1;
  21 //       if(err) console.dir(err)
  22 //       if(count == 0) return cb();
  23 //     });
  24 //   }
  25 // }
  26
  27 server.on('connect', function(_server) {
  28
  29   setInterval(function() {
  30     _server.insert('test.test', [{a:1}], function(err, r) {
  31       console.log("insert")
  32     });
  33   }, 1000)
  34   // console.log("---------------------------------- 0")
  35   // // Attempt authentication
  36   // _server.auth('scram-sha-1', 'admin', 'root', 'root', function(err, r) {
  37   //   console.log("---------------------------------- 1")
  38   //   // console.dir(err)
  39   //   // console.dir(r)
  40   //
  41   //   _server.insert('test.test', [{a:1}], function(err, r) {
  42   //     console.log("---------------------------------- 2")
  43   //     console.dir(err)
  44   //     if(r)console.dir(r.result)
  45   //     var name = null;
  46   //
  47   //     _server.on('joined', function(_t, _server) {
  48   //       if(name == _server.name) {
  49   //         console.log("=========== joined :: " + _t + " :: " + _server.name)
  50   //         executeCursors(_server, function() {
  51   //         });
  52   //       }
  53   //     })
  54   //
  55   //     // var s = _server.s.replicaSetState.secondaries[0];
  56   //     // s.destroy({emitClose:true});
  57   //     executeCursors(_server, function() {
  58   //       console.log("============== 0")
  59   //       // Attempt to force a server reconnect
  60   //       var s = _server.s.replicaSetState.secondaries[0];
  61   //       name = s.name;
  62   //       s.destroy({emitClose:true});
  63   //       // console.log("============== 1")
  64   //
  65   //       // _server.destroy();
  66   //       // test.done();
  67   //     });
  68   //   });
  69   // });
  70 });
  71
  72 server.connect();