Added byVersion to status

KeychainMDIP · Dec 19, 2024 · 666850e · 666850e
1 parent f189bd6
commit 666850e
Show file tree

Hide file tree

Showing 3 changed files with 28 additions and 7 deletions.
diff --git a/packages/gatekeeper/src/gatekeeper-lib.js b/packages/gatekeeper/src/gatekeeper-lib.js
@@ -125,9 +125,11 @@ export async function checkDIDs(options = {}) {
 
     const total = dids.length;
     let n = 0;
+    let confirmed = 0;
     let ephemeral = 0;
     let invalid = 0;
     const byRegistry = {};
+    const byVersion = {};
 
     for (const did of dids) {
         n += 1;
@@ -137,16 +139,19 @@ export async function checkDIDs(options = {}) {
                 console.log(`resolved ${n}/${total} ${did} OK`);
             }
 
+            if (doc.didDocumentMetadata.confirmed) {
+                confirmed += 1;
+            }
+
             if (doc.mdip.validUntil) {
                 ephemeral += 1;
             }
 
-            if (byRegistry[doc.mdip.registry]) {
-                byRegistry[doc.mdip.registry] += 1;
-            }
-            else {
-                byRegistry[doc.mdip.registry] = 1;
-            }
+            const registry = doc.mdip.registry;
+            byRegistry[registry] = (byRegistry[registry] || 0) + 1;
+
+            const version = doc.didDocumentMetadata.version;
+            byVersion[version] = (byVersion[version] || 0) + 1;
         }
         catch (error) {
             invalid += 1;
@@ -156,7 +161,7 @@ export async function checkDIDs(options = {}) {
         }
     }
 
-    return { total, ephemeral, invalid, byRegistry };
+    return { total, confirmed, ephemeral, invalid, byRegistry, byVersion };
 }
 
 export async function initRegistries(csvRegistries) {

diff --git a/services/gatekeeper/server/src/gatekeeper-api.js b/services/gatekeeper/server/src/gatekeeper-api.js
@@ -262,6 +262,7 @@ async function gcLoop() {
     try {
         const response = await gatekeeper.verifyDb();
         console.log(`DID garbage collection: ${JSON.stringify(response)} waiting ${config.gcInterval} minutes...`);
+        await checkDids();
     }
     catch (error) {
         console.error(`Error in DID garbage collection: ${error}`);
@@ -293,11 +294,23 @@ async function reportStatus() {
 
     console.log(`DID Database (${config.db}):`);
     console.log(`  Total: ${status.dids.total}`);
+
     console.log(`  By registry:`);
     const registries = Object.keys(status.dids.byRegistry).sort();
     for (let registry of registries) {
         console.log(`    ${registry}: ${status.dids.byRegistry[registry]}`);
     }
+
+    console.log(`  By version:`);
+    let count = 0;
+    for (let version of [1, 2, 3, 4, 5]) {
+        const num = status.dids.byVersion[version];
+        console.log(`    ${version}: ${num}`);
+        count += num;
+    }
+    console.log(`    6+: ${status.dids.total - count}`);
+
+    console.log(`  Confirmed: ${status.dids.confirmed}`);
     console.log(`  Ephemeral: ${status.dids.ephemeral}`);
     console.log(`  Invalid: ${status.dids.invalid}`);
 

diff --git a/tests/gatekeeper.test.js b/tests/gatekeeper.test.js
@@ -2625,8 +2625,11 @@ describe('checkDIDs', () => {
         const check = await gatekeeper.checkDIDs({ chatty: true });
 
         expect(check.total).toBe(2);
+        expect(check.confirmed).toBe(2);
         expect(check.ephemeral).toBe(1);
         expect(check.invalid).toBe(0);
+        expect(check.byRegistry['local']).toBe(2);
+        expect(check.byVersion[1]).toBe(2);
     });
 
     it('should report invalid DIDs', async () => {