feat: remove peerConnectionStorage in AgentServicesProps

cardano-foundation · May 8, 2024 · 8ad3edb · 8ad3edb
1 parent b85b3a8
commit 8ad3edb
Show file tree

Hide file tree

Showing 3 changed files with 10 additions and 11 deletions.
diff --git a/src/core/agent/agent.ts b/src/core/agent/agent.ts
@@ -57,6 +57,7 @@ class Agent {
   private connectionStorage!: ConnectionStorage;
   private connectionNoteStorage!: ConnectionNoteStorage;
   private notificationStorage!: NotificationStorage;
+  private peerConnectionStorage!: PeerConnectionStorage;
 
   private signifyClient!: SignifyClient;
   static ready = false;
@@ -126,8 +127,8 @@ class Agent {
     return this.credentialService;
   }
 
-  get peerConnectionStorage() {
-    return this.agentServicesProps.peerConnectionStorage;
+  get peerConnectionMetadataStorage() {
+    return this.peerConnectionStorage;
   }
 
   get basicStorage() {
@@ -204,14 +205,14 @@ class Agent {
         credentialStorage: new CredentialStorage(
           this.getStorageService<CredentialMetadataRecord>(this.storageSession)
         ),
-        peerConnectionStorage: new PeerConnectionStorage(
-          this.getStorageService<PeerConnectionMetadataRecord>(
-            this.storageSession
-          )
-        ),
       };
 
-      Agent.ready = true;
+      (this.peerConnectionStorage = new PeerConnectionStorage(
+        this.getStorageService<PeerConnectionMetadataRecord>(
+          this.storageSession
+        )
+      )),
+      (Agent.ready = true);
     }
   }
 

diff --git a/src/core/agent/agent.types.ts b/src/core/agent/agent.types.ts
@@ -100,7 +100,6 @@ interface AgentServicesProps {
   eventService: EventService;
   identifierStorage: IdentifierStorage;
   credentialStorage: CredentialStorage;
-  peerConnectionStorage: PeerConnectionStorage;
 }
 
 interface CreateIdentifierResult {

diff --git a/src/core/agent/records/peerConnectionStorage.ts b/src/core/agent/records/peerConnectionStorage.ts
@@ -31,8 +31,7 @@ class PeerConnectionStorage {
   async getAllPeerConnectionMetadata(): Promise<
     PeerConnectionMetadataRecord[]
     > {
-    const records = await this.storageService.findAllByQuery(
-      {},
+    const records = await this.storageService.getAll(
       PeerConnectionMetadataRecord
     );
     return records;