Fix tests

Author: mpv1989

src/test/23-aql-queries-stream.ts

@@ -7,8 +7,8 @@ const ARANGO_VERSION = Number(process.env.ARANGO_VERSION || 30000);
 const describe34 = ARANGO_VERSION >= 30400 ? describe : describe.skip;
 
 describe34("AQL Stream queries", function() {
-  // create database takes 11s in a standard cluster
-  this.timeout(20000);
+  // create database takes 11s in a standard cluster and sometimes even more
+  this.timeout(30000);
 
   let name = `testdb_${Date.now()}`;
   let db: Database;
@@ -82,51 +82,69 @@ describe34("AQL Stream queries", function() {
     });
   });
   describe("with some data", () => {
-    let cname = "MyTestCollection"
+    let cname = "MyTestCollection";
     before(done => {
       let collection = db.collection(cname);
-      collection.create()
+      collection
+        .create()
         .then(() => {
-          return Promise.all(Array.apply(null, { length: 1000 })
-            .map(Number.call, Number)
-            .map((i: Number) => collection.save({ hallo: i })));
-        }).then(() => void done()).catch(done);
+          return Promise.all(
+            Array.apply(null, { length: 1000 })
+              .map(Number.call, Number)
+              .map((i: Number) => collection.save({ hallo: i }))
+          );
+        })
+        .then(() => void done())
+        .catch(done);
     });
     /*after(done => {
       db.collection(cname).drop().then(() => done()).catch(done);
     });*/
-    it("can access large collection in parallel", (done) => {
+    it("can access large collection in parallel", done => {
       let collection = db.collection(cname);
       let query = aql`FOR doc in ${collection} RETURN doc`;
       const opts = { batchSize: 250, options: { stream: true } };
 
       let count = 0;
-      Promise.all(Array.apply(null, { length: 25 }).map(() => db.query(query, opts)))
+      Promise.all(
+        Array.apply(null, { length: 25 }).map(() => db.query(query, opts))
+      )
         .then(cursors => {
-          return Promise.all(cursors.map(c => (c as ArrayCursor).each(() => { count++ })))
-        }).then(() => {
+          return Promise.all(
+            cursors.map(c =>
+              (c as ArrayCursor).each(() => {
+                count++;
+              })
+            )
+          );
+        })
+        .then(() => {
           expect(count).to.equal(25 * 1000);
           done();
-        }).catch(done);
+        })
+        .catch(done);
     });
-    it("can do writes and reads", (done) => {
+    it("can do writes and reads", done => {
       let collection = db.collection(cname);
       let readQ = aql`FOR doc in ${collection} RETURN doc`;
       let writeQ = aql`FOR i in 1..1000 LET y = SLEEP(1) INSERT {forbidden: i} INTO ${collection}`;
       const opts = { batchSize: 500, ttl: 5, options: { stream: true } };
 
-      // 900s lock timeout + 5s ttl 
+      // 900s lock timeout + 5s ttl
       let readCursor = db.query(readQ, opts);
       let writeCursor = db.query(writeQ, opts);
 
       // the read cursor should always win
-      Promise.race([readCursor, writeCursor]).then(c => {
-        // therefore no document should have been written here
-        return c.every((d: any) => !(d.hasOwnProperty("forbidden")))
-      }).then(isOk => {
-        expect(isOk).to.equal(true);
-        done();
-      }).catch(done);
+      Promise.race([readCursor, writeCursor])
+        .then(c => {
+          // therefore no document should have been written here
+          return c.every((d: any) => !d.hasOwnProperty("forbidden"));
+        })
+        .then(isOk => {
+          expect(isOk).to.equal(true);
+          done();
+        })
+        .catch(done);
     });
   });
 });