fix(data-store): replace typeOrm findOne queries including relations …

…with find (#1400)
decentralized-identity · Jul 4, 2024 · 034afc4 · 034afc4
1 parent 925fd81
commit 034afc4
Show file tree

Hide file tree

Showing 2 changed files with 4 additions and 4 deletions.
diff --git a/packages/data-store/src/data-store.ts b/packages/data-store/src/data-store.ts
@@ -63,7 +63,7 @@ export class DataStore implements IAgentPlugin {
   }
 
   async dataStoreGetMessage(args: IDataStoreGetMessageArgs): Promise<IMessage> {
-    const messageEntity = await (await getConnectedDb(this.dbConnection)).getRepository(Message).findOne({
+    const [messageEntity] = await (await getConnectedDb(this.dbConnection)).getRepository(Message).find({
       where: { id: args.id },
       relations: ['credentials', 'presentations'],
     })
@@ -73,7 +73,7 @@ export class DataStore implements IAgentPlugin {
   }
 
   async dataStoreDeleteMessage(args: IDataStoreDeleteMessageArgs): Promise<boolean> {
-    const messageEntity = await (await getConnectedDb(this.dbConnection)).getRepository(Message).findOne({
+    const [messageEntity] = await (await getConnectedDb(this.dbConnection)).getRepository(Message).find({
       where: { id: args.id },
       relations: ['credentials', 'presentations'],
     })

diff --git a/packages/data-store/src/identifier/did-store.ts b/packages/data-store/src/identifier/did-store.ts
@@ -48,7 +48,7 @@ export class DIDStore extends AbstractDIDStore {
       throw Error('[veramo:data-store:identifier-store] Get requires did or (alias and provider)')
     }
 
-    const identifier = await (await getConnectedDb(this.dbConnection)).getRepository(Identifier).findOne({
+    const [identifier] = await (await getConnectedDb(this.dbConnection)).getRepository(Identifier).find({
       where,
       relations: ['keys', 'services'],
     })
@@ -88,7 +88,7 @@ export class DIDStore extends AbstractDIDStore {
   }
 
   async deleteDID({ did }: { did: string }) {
-    const identifier = await (await getConnectedDb(this.dbConnection)).getRepository(Identifier).findOne({
+    const [identifier] = await (await getConnectedDb(this.dbConnection)).getRepository(Identifier).find({
       where: { did },
       relations: ['keys', 'services', 'issuedCredentials', 'issuedPresentations'],
     })