Event log

.gitignore

@@ -13,9 +13,11 @@ try.js
 # default location for levelDB data storage in a non-browser env
 MESSAGESTORE
 DATASTORE
+EVENTLOG
 # location for levelDB data storage for non-browser tests
 TEST-DATASTORE
 TEST-MESSAGESTORE
+TEST-EVENTLOG
 
 # default location for index specific levelDB data storage in a non-browser env
 INDEX

README.md

@@ -3,7 +3,7 @@
 # Decentralized Web Node (DWN) SDK
 
 Code Coverage
-![Statements](https://img.shields.io/badge/statements-93.84%25-brightgreen.svg?style=flat) ![Branches](https://img.shields.io/badge/branches-92.39%25-brightgreen.svg?style=flat) ![Functions](https://img.shields.io/badge/functions-91.01%25-brightgreen.svg?style=flat) ![Lines](https://img.shields.io/badge/lines-93.84%25-brightgreen.svg?style=flat)
+![Statements](https://img.shields.io/badge/statements-93.05%25-brightgreen.svg?style=flat) ![Branches](https://img.shields.io/badge/branches-92.58%25-brightgreen.svg?style=flat) ![Functions](https://img.shields.io/badge/functions-90.63%25-brightgreen.svg?style=flat) ![Lines](https://img.shields.io/badge/lines-93.05%25-brightgreen.svg?style=flat)
 
 ## Introduction
 

package.json

@@ -52,6 +52,7 @@
     "@js-temporal/polyfill": "0.4.3",
     "@noble/ed25519": "1.7.1",
     "@noble/secp256k1": "1.7.1",
+    "@scure/base": "1.1.1",
     "@swc/helpers": "0.3.8",
     "@types/eccrypto": "1.1.3",
     "@types/ms": "0.7.31",
@@ -76,6 +77,7 @@
     "multiformats": "11.0.2",
     "randombytes": "2.1.0",
     "readable-stream": "4.3.0",
+    "ulid": "2.3.0",
     "secp256k1": "5.0.0",
     "uuid": "8.3.2",
     "varint": "6.0.0"

src/dwn.ts

@@ -1,5 +1,6 @@
 import type { BaseMessage } from './core/types.js';
 import type { DataStore } from './store/data-store.js';
+import type { EventLog } from './event-log/event-log.js';
 import type { MessageStore } from './store/message-store.js';
 import type { MethodHandler } from './interfaces/types.js';
 import type { Readable } from 'readable-stream';
@@ -8,6 +9,7 @@ import type { TenantGate } from './core/tenant-gate.js';
 import { AllowAllTenantGate } from './core/tenant-gate.js';
 import { DataStoreLevel } from './store/data-store-level.js';
 import { DidResolver } from './did/did-resolver.js';
+import { EventLogLevel } from './event-log/event-log-level.js';
 import { MessageReply } from './core/message-reply.js';
 import { MessageStoreLevel } from './store/message-store-level.js';
 import { PermissionsRequestHandler } from './interfaces/permissions/handlers/permissions-request.js';
@@ -24,22 +26,26 @@ export class Dwn {
   private didResolver: DidResolver;
   private messageStore: MessageStore;
   private dataStore: DataStore;
+  private eventLog: EventLog;
   private tenantGate: TenantGate;
 
   private constructor(config: DwnConfig) {
     this.didResolver = config.didResolver!;
     this.messageStore = config.messageStore!;
     this.dataStore = config.dataStore!;
+    this.eventLog = config.eventLog!;
     this.tenantGate = config.tenantGate!;
 
     this.methodHandlers = {
       [DwnInterfaceName.Permissions + DwnMethodName.Request] : new PermissionsRequestHandler(this.didResolver, this.messageStore, this.dataStore),
-      [DwnInterfaceName.Protocols + DwnMethodName.Configure] : new ProtocolsConfigureHandler(this.didResolver, this.messageStore, this.dataStore),
-      [DwnInterfaceName.Protocols + DwnMethodName.Query]     : new ProtocolsQueryHandler(this.didResolver, this.messageStore, this.dataStore),
-      [DwnInterfaceName.Records + DwnMethodName.Delete]      : new RecordsDeleteHandler(this.didResolver, this.messageStore, this.dataStore),
-      [DwnInterfaceName.Records + DwnMethodName.Query]       : new RecordsQueryHandler(this.didResolver, this.messageStore, this.dataStore),
-      [DwnInterfaceName.Records + DwnMethodName.Read]        : new RecordsReadHandler(this.didResolver, this.messageStore, this.dataStore),
-      [DwnInterfaceName.Records + DwnMethodName.Write]       : new RecordsWriteHandler(this.didResolver, this.messageStore, this.dataStore),
+      [DwnInterfaceName.Protocols + DwnMethodName.Configure] : new ProtocolsConfigureHandler(
+        this.didResolver, this.messageStore, this.dataStore, this.eventLog),
+      [DwnInterfaceName.Protocols + DwnMethodName.Query] : new ProtocolsQueryHandler(this.didResolver, this.messageStore, this.dataStore),
+      [DwnInterfaceName.Records + DwnMethodName.Delete]  : new RecordsDeleteHandler(
+        this.didResolver, this.messageStore, this.dataStore, this.eventLog),
+      [DwnInterfaceName.Records + DwnMethodName.Query] : new RecordsQueryHandler(this.didResolver, this.messageStore, this.dataStore),
+      [DwnInterfaceName.Records + DwnMethodName.Read]  : new RecordsReadHandler(this.didResolver, this.messageStore, this.dataStore),
+      [DwnInterfaceName.Records + DwnMethodName.Write] : new RecordsWriteHandler(this.didResolver, this.messageStore, this.dataStore, this.eventLog),
     };
   }
 
@@ -52,6 +58,7 @@ export class Dwn {
     config.tenantGate ??= new AllowAllTenantGate();
     config.messageStore ??= new MessageStoreLevel();
     config.dataStore ??= new DataStoreLevel();
+    config.eventLog ??= new EventLogLevel();
 
     const dwn = new Dwn(config);
     await dwn.open();
@@ -62,11 +69,13 @@ export class Dwn {
   private async open(): Promise<void> {
     await this.messageStore.open();
     await this.dataStore.open();
+    await this.eventLog.open();
   }
 
   public async close(): Promise<void> {
     this.messageStore.close();
     this.dataStore.close();
+    this.eventLog.close();
   }
 
   /**
@@ -119,6 +128,10 @@ export class Dwn {
     // @ts-ignore
     await this.dataStore['dump']?.();
     console.groupEnd();
+
+    console.group('eventLog');
+    await this.eventLog['dump']?.();
+    console.groupEnd();
   }
 };
 
@@ -127,4 +140,5 @@ export type DwnConfig = {
   messageStore?: MessageStore;
   dataStore?: DataStore;
   tenantGate?: TenantGate;
+  eventLog?: EventLog
 };