(#1166) - web workers

bin/test-node.js

@@ -8,6 +8,8 @@ var excludedTests = [
   // auth_replication and cors need admin access (#1030)
   'test.auth_replication.js',
   'test.cors.js',
+  //no workers in node
+  'test.worker.js',
   // Plugins currnetly arent tested (#1031)
   'test.gql.js',
   'test.spatial.js'

lib/deps/ajax.js

@@ -78,7 +78,7 @@ function ajax(options, callback) {
     call(cb, errObj);
   };
 
-  if (typeof window !== 'undefined' && window.XMLHttpRequest) {
+  if (process.browser && typeof XMLHttpRequest !== 'undefined') {
     var timer, timedout = false;
     var xhr = new XMLHttpRequest();
 

tests/test.worker.js

@@ -0,0 +1,32 @@
+QUnit.module('worker');
+
+asyncTest('create it',1,function(){
+  var worker = new Worker('worker.js');
+  worker.addEventListener('message',function(e){
+    ok('pong',e.data);
+    worker.terminate();
+    start();
+  });
+  worker.postMessage('ping');
+});
+asyncTest('check pouch version',1,function(){
+  var worker = new Worker('worker.js');
+  worker.addEventListener('message',function(e){
+    ok(PouchDB.version,e.data);
+    worker.terminate();
+    start();
+  });
+  worker.postMessage('version');
+});
+asyncTest('create db',1,function(){
+  var worker = new Worker('worker.js');
+  worker.addEventListener('error',function(e){
+    throw e;
+  });
+  worker.addEventListener('message',function(e){
+    ok('lala',e.data);
+    worker.terminate();
+    start();
+  });
+  worker.postMessage(['create',testUtils.generateAdapterUrl(adapter)]);
+});

tests/webrunner.js

@@ -14,7 +14,8 @@ if (!testFiles.length) {
     'test.replication.js', 'test.views.js', 'test.taskqueue.js',
     'test.design_docs.js', 'test.issue221.js', 'test.http.js',
     'test.compaction.js', 'test.get.js',
-    'test.attachments.js', 'test.uuids.js', 'test.slash_id.js'
+    'test.attachments.js', 'test.uuids.js', 'test.slash_id.js',
+    'test.worker.js'
   ];
 }
 

tests/worker.js

@@ -0,0 +1,31 @@
+importScripts('../dist/pouchdb-nightly.js');
+function bigTest(name){
+  PouchDB(name,function(err,db){
+    if(err){
+      throw err;
+    }
+    db.post({_id:"blablah",key:'lala'},function(err){
+      if(err){
+        throw err;
+      }
+      db.get('blablah',function(err,doc){
+        if(err){
+          throw err;
+        }
+        self.postMessage(doc.key);
+        PouchDB.destroy(name);
+      });
+    });
+  });
+}
+self.addEventListener('message',function(e){
+  if(e.data==='ping'){
+    self.postMessage('pong');
+  }
+  if(e.data==='version'){
+    self.postMessage(PouchDB.version);
+  }
+  if(Array.isArray(e.data)&&e.data[0]==='create'){
+    bigTest(e.data[1]);
+  }
+});