From 5da2769288a89d61092126d1a7f843951345ef63 Mon Sep 17 00:00:00 2001 From: mkelvers Date: Wed, 24 Jun 2026 12:03:15 +0200 Subject: [PATCH] refactor: consolidate fx event error description into single function --- internal/observability/fx.go | 25 +++++-------------------- 1 file changed, 5 insertions(+), 20 deletions(-) diff --git a/internal/observability/fx.go b/internal/observability/fx.go index 177f6bd..21e9759 100644 --- a/internal/observability/fx.go +++ b/internal/observability/fx.go @@ -20,32 +20,17 @@ func (fxLogger) LogEvent(event fxevent.Event) { } func describeFXEventError(event fxevent.Event) (string, map[string]any, error) { - if ok, eventName, fields, err := describeFXExecutionEventError(event); ok { - return eventName, fields, err - } - - return describeFXLifecycleEventError(event) -} - -func describeFXExecutionEventError(event fxevent.Event) (bool, string, map[string]any, error) { switch e := event.(type) { case *fxevent.Provided: - return true, "fx_provide_failed", map[string]any{"constructor": e.ConstructorName}, e.Err + return "fx_provide_failed", map[string]any{"constructor": e.ConstructorName}, e.Err case *fxevent.Invoked: - return true, "fx_invoke_failed", map[string]any{"function": e.FunctionName}, e.Err + return "fx_invoke_failed", map[string]any{"function": e.FunctionName}, e.Err case *fxevent.Run: - return true, "fx_run_failed", map[string]any{"function": e.Name, "kind": e.Kind}, e.Err + return "fx_run_failed", map[string]any{"function": e.Name, "kind": e.Kind}, e.Err case *fxevent.OnStartExecuted: - return true, "fx_on_start_failed", map[string]any{"caller": e.CallerName, "function": e.FunctionName, "runtime": e.Runtime}, e.Err + return "fx_on_start_failed", map[string]any{"caller": e.CallerName, "function": e.FunctionName, "runtime": e.Runtime}, e.Err case *fxevent.OnStopExecuted: - return true, "fx_on_stop_failed", map[string]any{"caller": e.CallerName, "function": e.FunctionName, "runtime": e.Runtime}, e.Err - default: - return false, "", nil, nil - } -} - -func describeFXLifecycleEventError(event fxevent.Event) (string, map[string]any, error) { - switch e := event.(type) { + return "fx_on_stop_failed", map[string]any{"caller": e.CallerName, "function": e.FunctionName, "runtime": e.Runtime}, e.Err case *fxevent.Started: return "fx_start_failed", nil, e.Err case *fxevent.Stopped: