Creating acceptEvent

Author: perki

src/appTemplates/AppClientAccount.js

@@ -59,16 +59,15 @@ class AppClientAccount extends Application {
       params: { types: ['request/collector-client-v1'], streams: [this.baseStreamId], limit: MAX_COLLECTORS }
     }];
     const [accessesRes, eventRes] = await this.connection.api(apiCalls);
+    const accessHDSCollectorMap = {};
     for (const access of accessesRes.accesses) {
-      // do something
-      console.log('##', access);
-    }
-    for (const access of accessesRes.accessDeletions) {
-      // do something
-      console.log('##', access);
+      if (access.clientData.hdsCollectorClient) {
+        accessHDSCollectorMap[access.name] = access;
+      }
     }
     for (const event of eventRes.events) {
       const collectorClient = new CollectorClient(this, event);
+      if (accessHDSCollectorMap[collectorClient.key] != null) collectorClient.accessData = accessHDSCollectorMap[collectorClient.key];
       this.cache.collectorClientsMap[collectorClient.key] = collectorClient;
     }
 

src/appTemplates/CollectorClient.js

@@ -27,16 +27,21 @@ class CollectorClient {
     return this.eventData.content.requesterEventId;
   }
 
+  get requestData () {
+    return this.eventData.content.requesterEventData.content;
+  }
+
   get status () {
     if (!this.accessData && this.eventData.status === CollectorClient.STATUSES.refused) {
       return CollectorClient.STATUSES.refused;
     }
     return CollectorClient.STATUSES.incoming;
   }
 
-  constructor (app, eventData) {
+  constructor (app, eventData, accessData = null) {
     this.app = app;
     this.eventData = eventData;
+    this.accessData = accessData;
   }
 
   /**
@@ -47,7 +52,7 @@ class CollectorClient {
     const publicStreamId = accessInfo.clientData.hdsCollector.public.streamId;
     // get request event cont
     const requesterConnection = new pryv.Connection(apiEndpoint);
-    const requesterEvents = await requesterConnection.apiOne('events.get', { streams: [publicStreamId], limit: 1 }, 'events');
+    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);
 
     const eventData = {
@@ -64,6 +69,54 @@ class CollectorClient {
     return new CollectorClient(app, event);
   }
 
+  /**
+   * Accept current request
+   */
+  async accept () {
+    // create access for requester
+    if (this.accessData != null) throw new HDSLibError('Access Info already set');
+    // create access
+    const cleanedPermissions = this.requestData.permissions.map((p) => {
+      if (p.streamId) return { streamId: p.streamId, level: p.level };
+      return p;
+    });
+    const accessCreateData = {
+      name: this.key,
+      type: 'shared',
+      permissions: cleanedPermissions,
+      clientData: {
+        hdsCollectorClient: {
+          version: 0,
+          eventData: this.eventData
+        }
+      }
+    };
+    const accessData = await this.app.connection.apiOne('accesses.create', accessCreateData, 'access');
+    this.accessData = accessData;
+    if (!this.accessData.apiEndpoint) throw new HDSLibError('Failed creating request access', accessData);
+
+    // sent access credentials to requester
+    // check content of accessInfo
+    const publicStreamId = this.eventData.content.accessInfo.clientData.hdsCollector.inbox.streamId;
+    const requesterEventId = this.requesterEventId;
+    const requestrerApiEndpoint = this.eventData.content.apiEndpoint;
+
+    // acceptEvent to be sent to requester
+    const acceptEvent = {
+      type: 'credentials/collector-v1',
+      streamIds: [publicStreamId],
+      content: {
+        apiEndpoint: this.accessData.apiEndpoint,
+        eventId: requesterEventId
+      }
+    };
+
+    const requesterConnection = new pryv.Connection(requestrerApiEndpoint);
+    const requesterEvent = await requesterConnection.apiOne('events.create', acceptEvent, 'event');
+
+    return { accessData, requesterEvent };
+  }
+
   /**
    * return the key to discriminate collectorClients
    * @param {PryvAccessInfo} accessInfo

tests/apptemplates.test.js

@@ -134,6 +134,9 @@ describe('[APTX] appTemplates', function () {
     // set request content
     const requestContent = {
       version: 0,
+      requester: {
+        name: 'Test requester name'
+      },
       description: {
         en: 'Short Description'
       },
@@ -194,6 +197,19 @@ describe('[APTX] appTemplates', function () {
     assert.equal(collectorClientsCached.length, 1);
     const collectorClients = await appClient.getCollectorClients(true);
     assert.equal(collectorClients.length, 1);
+
+    // check requestData
+    assert.deepEqual(collectorClient.requestData, requestContent);
+
+    // accept
+    const acceptResult = await collectorClient.accept();
+    assert.equal(acceptResult.requesterEvent.content.eventId, invite.eventId);
+    assert.ok(!!acceptResult.requesterEvent.content.apiEndpoint);
+
+    // force refresh and check online
+    const collectorClients2 = await appClient.getCollectorClients(true);
+    assert.equal(collectorClients2.length, 1);
+    assert.deepEqual(collectorClients2[0].accessData, acceptResult.accessData);
   });
 
   describe('[APCX] app Templates Client', function () {