(&self, event: &Event<'_>, _ctx: Context<'_, S>)
| 138 | S: Subscriber, |
| 139 | { |
| 140 | fn on_event(&self, event: &Event<'_>, _ctx: Context<'_, S>) { |
| 141 | let meta = event.metadata(); |
| 142 | let mut visitor = LogVisitor::default(); |
| 143 | event.record(&mut visitor); |
| 144 | |
| 145 | let Some(sandbox_id) = visitor.sandbox_id else { |
| 146 | return; |
| 147 | }; |
| 148 | |
| 149 | let msg = visitor.message.unwrap_or_else(|| meta.name().to_string()); |
| 150 | let level = display_level(meta.target(), &meta.level().to_string()); |
| 151 | |
| 152 | let ts = openshell_core::time::now_ms(); |
| 153 | let log = SandboxLogLine { |
| 154 | sandbox_id: sandbox_id.clone(), |
| 155 | timestamp_ms: ts, |
| 156 | level, |
| 157 | target: meta.target().to_string(), |
| 158 | message: msg, |
| 159 | source: "gateway".to_string(), |
| 160 | fields: HashMap::new(), |
| 161 | }; |
| 162 | let evt = SandboxStreamEvent { |
| 163 | payload: Some(openshell_core::proto::sandbox_stream_event::Payload::Log( |
| 164 | log, |
| 165 | )), |
| 166 | }; |
| 167 | self.bus.publish(&sandbox_id, evt, self.default_tail); |
| 168 | } |
| 169 | } |
| 170 | |
| 171 | #[derive(Debug, Default)] |
nothing calls this directly
no test coverage detected