Skip to content

Commit d0dfce2

Browse files
committed
refactor(web_chat): name the surface subscribers after their new module (#5002)
The four EventHandler::name() returns still read `channels::web::*`, naming a module that no longer exists after the relocation. AGENTS.md's convention is `<domain>::<purpose>`, and sibling subscribers follow it (`cron::delivery`, `memory::conversations::persistence`). Log-output only: `name()` is consumed at src/core/event_bus/bus.rs:145,169 and both uses are tracing fields. Dispatch filters on `domains()`, not `name()`. Verified nothing keys on the old strings — no classifier, filter, or frontend reference.
1 parent 92041df commit d0dfce2

1 file changed

Lines changed: 4 additions & 4 deletions

File tree

src/openhuman/web_chat/event_bus.rs

Lines changed: 4 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -121,7 +121,7 @@ struct EgressSurfaceSubscriber;
121121
#[async_trait]
122122
impl EventHandler for EgressSurfaceSubscriber {
123123
fn name(&self) -> &str {
124-
"channels::web::egress_surface"
124+
"web_chat::egress_surface"
125125
}
126126

127127
fn domains(&self) -> Option<&[&str]> {
@@ -178,7 +178,7 @@ struct ArtifactSurfaceSubscriber;
178178
#[async_trait]
179179
impl EventHandler for ArtifactSurfaceSubscriber {
180180
fn name(&self) -> &str {
181-
"channels::web::artifact_surface"
181+
"web_chat::artifact_surface"
182182
}
183183

184184
fn domains(&self) -> Option<&[&str]> {
@@ -326,7 +326,7 @@ struct ApprovalSurfaceSubscriber;
326326
#[async_trait]
327327
impl EventHandler for ApprovalSurfaceSubscriber {
328328
fn name(&self) -> &str {
329-
"channels::web::approval_surface"
329+
"web_chat::approval_surface"
330330
}
331331

332332
fn domains(&self) -> Option<&[&str]> {
@@ -411,7 +411,7 @@ struct AutomationHaltSubscriber;
411411
#[async_trait]
412412
impl EventHandler for AutomationHaltSubscriber {
413413
fn name(&self) -> &str {
414-
"channels::web::automation_halt"
414+
"web_chat::automation_halt"
415415
}
416416

417417
fn domains(&self) -> Option<&[&str]> {

0 commit comments

Comments
 (0)