refactor: mark stale documents

energywebfoundation · Nov 8, 2024 · e0fc937 · e0fc937
1 parent 1708b7d
commit e0fc937
Showing 1 changed file with 2 additions and 1 deletion.
diff --git a/src/modules/did/did.service.ts b/src/modules/did/did.service.ts
@@ -30,6 +30,7 @@ import {
   documentFromLogs,
   Resolver,
   mergeLogs,
+  addressOf,
 } from '@ew-did-registry/did-ethr-resolver';
 import { EthereumDIDRegistry__factory } from '../../ethers/factories/EthereumDIDRegistry__factory';
 import { EthereumDIDRegistry } from '../../ethers/EthereumDIDRegistry';
@@ -570,7 +571,7 @@ export class DIDService implements OnModuleInit, OnModuleDestroy {
     const staleDIDs = (
       await this.didRepository.find({ select: ['id'] })
     ).filter((doc) => {
-      const identity = doc.id.split(':')[3];
+      const identity = addressOf(doc.id);
       return changedIdentities.includes(identity);
     });
     await this.didSyncStatusRepository