Appwrite/appwrite
1
0
Fork 0
mirror of https://github.com/appwrite/appwrite.git synced 2026-05-26 13:51:13 +00:00
Code Issues Packages Projects Releases Wiki Activity

Fix subspan ending main request span

Browse Source
This commit is contained in:
Matej Bačo
2026-05-19 15:23:34 +02:00
parent c5b8535a7f
commit f7b09c090b
1 changed files with 10 additions and 5 deletions
Download Patch File Download Diff File Expand all files Collapse all files
src/Utopia/Bus/Bus.php
+10 -5
View File
@@ -37,14 +37,19 @@ class Bus
foreach ($listeners as $listener) {
$deps = array_map($resolver, $listener->getInjections());
Span::init('listener.' . $listener::getName());
Span::add('bus.event', $event::class);
Span::current()?->add('listener.' . $listener::getName() . '.event', $event::class);
try {
($listener->getCallback())($event, ...$deps);
Span::current()?->add('listener.' . $listener::getName() . '.success', true);
} catch (\Throwable $e) {
Span::error($e);
} finally {
Span::current()?->finish();
Span::current()?->add('listener.' . $listener::getName() . '.success', false);
Span::current()?->add('listener.' . $listener::getName() . '.error.code', $e->getCode());
Span::current()?->add('listener.' . $listener::getName() . '.error.message', $e->getMessage());
Span::current()?->add('listener.' . $listener::getName() . '.error.line', $e->getLine());
Span::current()?->add('listener.' . $listener::getName() . '.error.file', $e->getFile());
Span::current()?->add('listener.' . $listener::getName() . '.error.trace', $e->getTraceAsString());
}
}
}