Testing CollectorClient.reset

Author: perki

src/appTemplates/CollectorClient.js

@@ -97,14 +97,16 @@ class CollectorClient {
    * reset with new request Event of ApiEndpoint
    * Identical as create but keep current event
    */
-  async reset (apiEndpoint, requesterEventId, accessInfo) {
+  async reset (apiEndpoint, requesterEventId) {
     if (this.accessData && this.accessData?.deleted != null) {
       logger.error('TODO try to revoke current access');
     }
+    // get accessInfo
+    const requesterConnection = new pryv.Connection(apiEndpoint);
+    const accessInfo = await requesterConnection.accessInfo();
     // check content of accessInfo
     const publicStreamId = accessInfo.clientData.hdsCollector.public.streamId;
     // get request event cont
-    const requesterConnection = new pryv.Connection(apiEndpoint);
     const requesterEvents = await requesterConnection.apiOne('events.get', { types: ['request/collector-v1'], streams: [publicStreamId], limit: 1 }, 'events');
     if (!requesterEvents[0]) throw new HDSLibError('Cannot find requester event in public stream', requesterEvents);
 

tests/apptemplates.test.js

@@ -4,6 +4,7 @@ const { createUserAndPermissions, pryv, createUser, createUserPermissions } = re
 const AppManagingAccount = require('../src/appTemplates/AppManagingAccount');
 const AppClientAccount = require('../src/appTemplates/AppClientAccount');
 const Collector = require('../src/appTemplates/Collector');
+const CollectorClient = require('../src/appTemplates/CollectorClient');
 
 describe('[APTX] appTemplates', function () {
   this.timeout(10000);
@@ -311,6 +312,13 @@ describe('[APTX] appTemplates', function () {
       } catch (e) {
         assert.equal(e.message, 'Found existing collectorClient with a different apiEndpoint');
       }
+
+      // reset to new incoming (might be implement later)
+      const requesterConnection = new pryv.Connection(inviteSharingData1.apiEndpoint);
+      const accessInfo = await requesterConnection.accessInfo();
+      const collectorClient = await new0.appClient.getCollectorClientByKey(CollectorClient.keyFromInfo(accessInfo));
+      await collectorClient.reset(inviteSharingData1.apiEndpoint, inviteSharingData1.eventId);
+      assert.equal(collectorClient.status, CollectorClient.STATUSES.incoming);
     });
   });