Enable event-stream by default for DwnApi. (#910)

* enable event stream
TBD54566975 · Sep 26, 2024 · d3b4728 · d3b4728
1 parent 91ae997
commit d3b4728
Show file tree

Hide file tree

Showing 3 changed files with 16 additions and 0 deletions.
diff --git a/.changeset/rotten-lions-flash.md b/.changeset/rotten-lions-flash.md
@@ -0,0 +1,5 @@
+---
+"@web5/api": patch
+---
+
+Enable EventStream from agent.
diff --git a/.changeset/rude-socks-pay.md b/.changeset/rude-socks-pay.md
@@ -0,0 +1,8 @@
+---
+"@web5/agent": patch
+"@web5/identity-agent": patch
+"@web5/proxy-agent": patch
+"@web5/user-agent": patch
+---
+
+Enable EventEmitterStream
diff --git a/packages/agent/src/dwn-api.ts b/packages/agent/src/dwn-api.ts
@@ -7,6 +7,7 @@ import {
   DwnConfig,
   DwnInterfaceName,
   DwnMethodName,
+  EventEmitterStream,
   EventLogLevel,
   GenericMessage,
   Message,
@@ -156,6 +157,8 @@ export class AgentDwnApi {
 
     resumableTaskStore ??= new ResumableTaskStoreLevel({ location: `${dataPath}/DWN_RESUMABLETASKSTORE` });
 
+    eventStream ??= new EventEmitterStream();
+
     return await Dwn.create({ dataStore, didResolver, eventLog, eventStream, messageStore, tenantGate, resumableTaskStore });
   }