feat: implemented untested NodesAuditGet

Author: CDeltakai

src/nodes/agent/handlers/NodesAuditsGet.ts

@@ -2,57 +2,61 @@ import type { ContextTimed } from '@matrixai/contexts';
 import type { DB } from '@matrixai/db';
 import type { JSONValue } from '@matrixai/rpc';
 import type Sigchain from '../../../sigchain/Sigchain';
-import type {
-  AgentRPCRequestParams,
-  AgentRPCResponseResult,
-  ClaimIdMessage,
-  AgentClaimMessage,
-  AuditIdMessage,
-  AgentAuditMessage,
+import type 
+{
+    AgentRPCRequestParams,
+    AgentRPCResponseResult,
+    AuditIdMessage,
+    AgentAuditMessage,
 } from '../types';
 import { ServerHandler } from '@matrixai/rpc';
-import * as claimsUtils from '../../../claims/utils';
 import type Audit from '../../../audit/Audit';
-import { AuditEventId } from '@/ids';
+import { AuditEventId, AuditEventIdEncoded } from '@/ids';
 
 /**
- * Gets the sigchain claims of a node
+ * Gets audit events from a node 
  */
-class NodesClaimsGet extends ServerHandler<
-  {
-    sigchain: Sigchain;
-    db: DB;
-    seek?: AuditEventId | number;
-    seekTo?: AuditEventId | number;
-    limit?: number;
-  },
-  AgentRPCRequestParams<AuditIdMessage>,
-  AgentRPCResponseResult<AgentAuditMessage>
-> {
-  public handle = async function* (
-    _input: AuditIdMessage,
-    _cancel: (reason?: any) => void,
-    _meta: Record<string, JSONValue> | undefined,
-    ctx: ContextTimed,
-  ): AsyncGenerator<AgentRPCResponseResult<AgentAuditMessage>> {
-    const { audit, db }: { audit: Audit; db: DB } = this.container;
-    yield* db.withTransactionG(async function* (tran): AsyncGenerator<
-      AgentRPCResponseResult<AgentClaimMessage>
-    > {
-      for await (const [claimId, signedClaim] of audit.getAuditEvents(
-        { order: 'asc' },
-        tran,
-      )) {
-        ctx.signal.throwIfAborted();
-        const encodedClaim = claimsUtils.generateSignedClaim(signedClaim);
-        const response: AgentClaimMessage = {
-          claimIdEncoded: claimsUtils.encodeClaimId(claimId),
-          signedTokenEncoded: encodedClaim,
-        };
-        yield response;
-      }
-    });
-  };
+class NodesAuditEventsGet extends ServerHandler<
+    {
+        sigchain: Sigchain;
+        db: DB;
+    },
+    AgentRPCRequestParams<AuditIdMessage>,
+    AgentRPCResponseResult<AgentAuditMessage>
+>
+{
+    public handle = async function* (
+        input: AgentRPCRequestParams<AuditIdMessage>,
+        _cancel: (reason?: any) => void,
+        _meta: Record<string, JSONValue> | undefined,
+        ctx: ContextTimed
+    ): AsyncGenerator<AgentRPCResponseResult<AgentAuditMessage>>
+    {
+        const { seek, seekEnd, limit } = input;
+        const { audit, db }: { audit: Audit; db: DB } = this.container;
+
+        yield* db.withTransactionG(async function* ( tran ): AsyncGenerator<AgentRPCResponseResult<AgentAuditMessage>>
+        {
+
+            for await (
+                const auditEvent of audit.getAuditEvents(
+                [],
+                {
+                    seek,
+                    seekEnd,
+                    limit
+                },
+                tran)
+            )
+            {
+                ctx.signal.throwIfAborted();
+                yield {
+                    auditIdEncoded: auditEvent.id.toString() as AuditEventIdEncoded,
+                };
+            }
+            
+        });
+    };
 }
 
-export default NodesClaimsGet;
+export default NodesAuditEventsGet;

src/nodes/agent/types.ts

@@ -4,7 +4,7 @@ import type {
   JSONRPCResponseResult,
 } from '@matrixai/rpc';
 import type { SignedTokenEncoded } from '../../tokens/types';
-import type { AuditEventIdEncoded, ClaimIdEncoded, NodeIdEncoded, VaultIdEncoded } from '../../ids';
+import type { AuditEventId, AuditEventIdEncoded, ClaimIdEncoded, NodeIdEncoded, VaultIdEncoded } from '../../ids';
 import type { VaultAction, VaultName } from '../../vaults/types';
 import type { SignedNotification } from '../../notifications/types';
 import type { Host, Hostname, Port } from '../../network/types';
@@ -18,6 +18,10 @@ type AgentRPCResponseResult<T extends JSONObject = JSONObject> =
 
 type AuditIdMessage = {
   auditIdEncoded: AuditEventIdEncoded
+  seek?: AuditEventId | number;
+  seekEnd?: AuditEventId | number;
+  order?: 'asc' | 'desc';
+  limit?: number;
 }
 
 type AgentAuditMessage = Partial<AuditIdMessage> & {