From d3b4728fb2ad8a15fd81d6db1865bd7b8c762561 Mon Sep 17 00:00:00 2001 From: Liran Cohen Date: Thu, 26 Sep 2024 18:27:16 -0400 Subject: [PATCH] Enable event-stream by default for DwnApi. (#910) * enable event stream --- .changeset/rotten-lions-flash.md | 5 +++++ .changeset/rude-socks-pay.md | 8 ++++++++ packages/agent/src/dwn-api.ts | 3 +++ 3 files changed, 16 insertions(+) create mode 100644 .changeset/rotten-lions-flash.md create mode 100644 .changeset/rude-socks-pay.md diff --git a/.changeset/rotten-lions-flash.md b/.changeset/rotten-lions-flash.md new file mode 100644 index 000000000..defffce22 --- /dev/null +++ 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 new file mode 100644 index 000000000..3bc6098a0 --- /dev/null +++ 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 index 4626ef2e3..a1d29b4e8 100644 --- 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 }); }