From 0b659f33eae144994a9080e6e84be51ab72348b2 Mon Sep 17 00:00:00 2001 From: Liran Cohen Date: Wed, 25 Sep 2024 17:17:09 -0400 Subject: [PATCH 1/2] enable event stream --- packages/agent/src/dwn-api.ts | 3 +++ 1 file changed, 3 insertions(+) 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 }); } From eb66ad6330366b4dffc3f61061b6f9932139fa90 Mon Sep 17 00:00:00 2001 From: Liran Cohen Date: Wed, 25 Sep 2024 17:18:50 -0400 Subject: [PATCH 2/2] enable event stream --- .changeset/rotten-lions-flash.md | 5 +++++ .changeset/rude-socks-pay.md | 8 ++++++++ 2 files changed, 13 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