Preparing for v2

Author: perki

components/pryv-monitor/test/monitor-edge-cases.test.js

@@ -168,7 +168,7 @@ describe('[MEDX] Monitor Edge Cases', function () {
       const createRes = await conn.api([{
         method: 'events.create',
         params: {
-          streamId: global.testStreamId,
+          streamIds: [global.testStreamId],
           type: 'note/txt',
           content: 'to be deleted ' + Date.now()
         }

components/pryv-monitor/test/monitor.test.js

@@ -57,7 +57,7 @@ describe('[MONX] Monitor', function () {
         {
           method: 'events.create',
           params: {
-            streamId: global.testStreamId,
+            streamIds: [global.testStreamId],
             type: 'note/txt',
             content: 'hello monitor'
           }
@@ -72,7 +72,7 @@ describe('[MONX] Monitor', function () {
       await monitor.start();
 
       const eventData = {
-        streamId: global.testStreamId,
+        streamIds: [global.testStreamId],
         type: 'note/txt',
         content: 'hello monitor ' + new Date()
       };

components/pryv-monitor/test/socket.test.js

@@ -24,7 +24,7 @@ describe('[MSKX] Monitor + Socket.IO', function () {
       let count = 0;
 
       const eventData = {
-        streamId: global.testStreamId,
+        streamIds: [global.testStreamId],
         type: 'note/txt',
         content: 'hello monitor ' + new Date()
       };
@@ -58,7 +58,7 @@ describe('[MSKX] Monitor + Socket.IO', function () {
       monitor.stop();
 
       const eventData = {
-        streamId: global.testStreamId,
+        streamIds: [global.testStreamId],
         type: 'note/txt',
         content: 'hello monitor ' + new Date()
       };

components/pryv-monitor/test/timer.test.js

@@ -40,7 +40,7 @@ describe('[TIMX] Monitor + EventsTimer', function () {
       });
 
       const eventData = {
-        streamId: global.testStreamId,
+        streamIds: [global.testStreamId],
         type: 'note/txt',
         content: 'hello monitor ' + new Date()
       };
@@ -75,7 +75,7 @@ describe('[TIMX] Monitor + EventsTimer', function () {
       });
 
       const eventData = {
-        streamId: global.testStreamId,
+        streamIds: [global.testStreamId],
         type: 'note/txt',
         content: 'hello monitor ' + new Date()
       };

components/pryv-socket.io/test/socket.io.test.js

@@ -46,7 +46,7 @@ describe('[SKIX] Socket.IO', function () {
       try {
         await conn.socket.open();
       } catch (e) {
-        if (e.message === 'Not Found' || e.message.startsWith('getaddrinfo ENOTFOUND') || e.message === 'fetch failed') {
+        if (e.message === 'Not Found' || e.message.startsWith('getaddrinfo ENOTFOUND') || e.message === 'fetch failed' || e.message.includes('Unknown user')) {
           return;
         }
         if (typeof document !== 'undefined') { // in browser
@@ -145,7 +145,7 @@ describe('[SKIX] Socket.IO', function () {
         return done();
       }
       conn.socket.on('eventsChanged', onEventChanged);
-      conn.api([{ method: 'events.create', params: { type: 'note/txt', streamId: testStreamId, content: 'hello' } }]);
+      conn.api([{ method: 'events.create', params: { type: 'note/txt', streamIds: [testStreamId], content: 'hello' } }]);
     });
 
     it('[SNTC] Catches streamChanges', (done) => {