feat: post merge changes (forgot to stage)

src/core/agent/records/connectionRecord.ts

@@ -7,11 +7,13 @@ interface ConnectionRecordStorageProps {
   tags?: Tags;
   alias: string;
   oobi: string;
+  groupId?: string;
 }
 
 class ConnectionRecord extends BaseRecord {
   alias!: string;
   oobi!: string;
+  groupId?: string;
   static readonly type = "ConnectionRecord";
   readonly type = ConnectionRecord.type;
 
@@ -22,13 +24,15 @@ class ConnectionRecord extends BaseRecord {
       this.createdAt = props.createdAt ?? new Date();
       this.alias = props.alias;
       this.oobi = props.oobi;
+      this.groupId = props.groupId;
       this._tags = props.tags ?? {};
     }
   }
 
   getTags() {
     return {
       ...this._tags,
+      groupId: this.groupId,
     };
   }
 }

src/core/agent/records/identifierStorage.ts

@@ -69,6 +69,21 @@ class IdentifierStorage {
     const record = new IdentifierMetadataRecord(data);
     await this.storageService.save(record);
   }
+
+  async getIdentifierMetadataByGroupId(
+    groupId: string
+  ): Promise<IdentifierMetadataRecord | null> {
+    const records = await this.storageService.findAllByQuery(
+      {
+        groupId,
+      },
+      IdentifierMetadataRecord
+    );
+    if (records.length > 0) {
+      return records[0];
+    }
+    return null;
+  }
 }
 
 export { IdentifierStorage };

src/core/agent/services/connectionService.ts

@@ -158,7 +158,6 @@ class ConnectionService extends AgentService {
     const connectionsDetails: ConnectionShortDetails[] = [];
     const metadatas = await this.getAllConnectionMetadata();
     metadatas.forEach(async (connection) => {
-      connectionsDetails.push(this.getConnectionShortDetails(connection));
       // @TODO - foconnor: This filter should be via the SQL, may cause a regression so this is a temp solution.
       if (connection.getTag("groupId") === undefined) {
         connectionsDetails.push(this.getConnectionShortDetails(connection));