fix: dataStoreDeleteVerifiableCredential

decentralized-identity · Aug 5, 2021 · 1f45475 · 1f45475
1 parent 2bc69e4
commit 1f45475
Show file tree

Hide file tree

Showing 5 changed files with 5 additions and 4 deletions.
diff --git a/__tests__/localAgent.test.ts b/__tests__/localAgent.test.ts
@@ -78,6 +78,7 @@ let dbConnection: Promise<Connection>
 
 const setup = async (options?: IAgentOptions): Promise<boolean> => {
   dbConnection = createConnection({
+    name: 'test',
     type: 'sqlite',
     database: databaseFile,
     synchronize: true,

diff --git a/__tests__/localMemoryStoreAgent.test.ts b/__tests__/localMemoryStoreAgent.test.ts
@@ -65,6 +65,7 @@ let dbConnection: Promise<Connection>
 
 const setup = async (options?: IAgentOptions): Promise<boolean> => {
   dbConnection = createConnection({
+    name: 'test',
     type: 'sqlite',
     database: databaseFile,
     synchronize: true,

diff --git a/__tests__/restAgent.test.ts b/__tests__/restAgent.test.ts
@@ -101,6 +101,7 @@ const getAgent = (options?: IAgentOptions) =>
 
 const setup = async (options?: IAgentOptions): Promise<boolean> => {
   dbConnection = createConnection({
+    name: 'test',
     type: 'sqlite',
     database: databaseFile,
     synchronize: true,

diff --git a/__tests__/shared/didDiscovery.ts b/__tests__/shared/didDiscovery.ts
@@ -103,7 +103,7 @@ export default (testContext: {
 
     // THIS HAS TO BE THE LAST TEST IN THIS FILE!
     it('should return errors', async () => {
-      const connection = getConnection()
+      const connection = getConnection('test')
       await connection.query('PRAGMA foreign_keys = OFF;')
       await connection.query('DROP TABLE claim;')
 

diff --git a/packages/data-store/src/data-store.ts b/packages/data-store/src/data-store.ts
@@ -67,9 +67,7 @@ export class DataStore implements IAgentPlugin {
       .getRepository(Claim)
       .find({ where: [{ credential: credentialEntity }] })
 
-    claims.forEach(async (claim) => {
-      await claim.remove()
-    })
+    await (await this.dbConnection).getRepository(Claim).remove(claims)
 
     await (await this.dbConnection).getRepository(Credential).remove(credentialEntity)