Support multiple invites from same doctor + robustness fixes

- CollectorClient.keyFromInfo uses accessId instead of accessName,
  so each invite from the same doctor gets a unique key
- handleIncomingRequest no longer throws on different eventId/endpoint,
  allowing patients to accept multiple data set invites from one doctor
- createAppStreams ignores item-already-exists for stream name collisions
- streamData.children guard (from Plan 29)

Author: perki

ts/appTemplates/AppClientAccount.ts

@@ -40,20 +40,13 @@ export class AppClientAccount extends Application {
     if (this.cache.collectorClientsMap[collectorClientKey]) {
       const collectorClient = this.cache.collectorClientsMap[collectorClientKey];
       logger.debug('AppClient:handleIncomingRequest found existing', { collectorClient });
-      if (collectorClient.requesterApiEndpoint !== apiEndpoint) {
-        // console.log('⚠️⚠️⚠️⚠️ RESET! Found existing collectorClient with a different apiEndpoint', { actual: collectorClient.requesterApiEndpoint, incoming: apiEndpoint });
-        throw new HDSLibError('Found existing collectorClient with a different apiEndpoint', { actual: collectorClient.requesterApiEndpoint, incoming: apiEndpoint });
-        // we might consider reseting() in the future;
-        // return await collectorClient.reset(apiEndpoint, incomingEventId, accessInfo);
+      // Same access, same endpoint — idempotent, return existing
+      if (collectorClient.requesterApiEndpoint === apiEndpoint) {
+        return collectorClient;
       }
-      if (incomingEventId && collectorClient.requesterEventId !== incomingEventId) {
-        throw new HDSLibError('Found existing collectorClient with a different eventId', { actual: collectorClient.requesterEventId, incoming: incomingEventId });
-        // console.log('⚠️⚠️⚠️⚠️ RESET! Found existing collectorClient with a different eventId', { actual: collectorClient.requesterEventId, incoming: incomingEventId });
-        // we might consider reseting() in the future;
-        // return await collectorClient.reset(apiEndpoint, incomingEventId, accessInfo);
-        // return null;
-      }
-      return collectorClient;
+      // Different apiEndpoint or eventId for same key — this shouldn't happen with id-based keys
+      // but handle gracefully by logging and creating new (will get a different key from its own accessInfo)
+      logger.info('AppClient:handleIncomingRequest existing key collision, creating new client');
     }
     // check if comming form hdsCollector
     if (!accessInfo?.clientData?.hdsCollector || (accessInfo.clientData?.hdsCollector as any)?.version !== 0) {

ts/appTemplates/Application.ts

@@ -221,8 +221,15 @@ async function createAppStreams (app: Application): Promise<void> {
       { method: 'streams.create', params: { id: app.baseStreamId, name: app.appName, parentId: APPS_ROOT_STREAM } }
     ];
     const streamCreateResult = await app.connection.api(apiCalls);
-    if (streamCreateResult[1].error) throw new Error('Failed creating app streams ' + JSON.stringify(streamCreateResult[1].error));
-    const stream = (streamCreateResult[1] as any).stream;
-    app.cache.streamData = stream;
+    const appStreamResult = streamCreateResult[1] as any;
+    if (appStreamResult.error && appStreamResult.error.id !== 'item-already-exists') {
+      throw new Error('Failed creating app streams ' + JSON.stringify(appStreamResult.error));
+    }
+    if (appStreamResult.stream) {
+      app.cache.streamData = appStreamResult.stream;
+    } else {
+      // Stream already existed — load it
+      await app.loadStreamData();
+    }
   }
 }

ts/appTemplates/CollectorClient.ts

@@ -356,7 +356,8 @@ export class CollectorClient {
    * @param {PryvAccessInfo} accessInfo
    */
   static keyFromInfo (info) {
-    return info.user.username + ':' + info.name;
+    // Use access id when available (unique per invite), fall back to name for backwards compat
+    return info.user.username + ':' + (info.id || info.name);
   }
 
   // -------------------- access update requests ------------- //