diff --git a/adapter/fx/fx.go b/adapter/fx/fx.go new file mode 100644 index 0000000..999b051 --- /dev/null +++ b/adapter/fx/fx.go @@ -0,0 +1,142 @@ +package fx + +import ( + tea "github.com/structx/teapot" + "go.uber.org/fx/fxevent" +) + +type eventLogger struct { + l *tea.Logger +} + +// interface compliance +var _ fxevent.Logger = (*eventLogger)(nil) + +// New constructor fx event logger using tea logger +func New(logger *tea.Logger) fxevent.Logger { + return &eventLogger{ + l: logger, + } +} + +// LogEvent implements [fxevent.Logger]. +func (el *eventLogger) LogEvent(evt fxevent.Event) { + switch e := evt.(type) { + case *fxevent.BeforeRun: + el.l.Debug( + "[Fx] before run", + tea.String("kind", e.Kind), + tea.String("module_name", e.ModuleName), + tea.String("name", e.Name), + ) + case *fxevent.Decorated: + if e.Err != nil { + el.l.Error("[Fx] decorate", tea.Error(e.Err)) + return + } + case *fxevent.Invoked: + if e.Err != nil { + el.l.Error("[Fx] invoked", tea.Error(e.Err)) + return + } + case *fxevent.Invoking: + el.l.Debug("[Fx] invoking", + tea.String("function_name", e.FunctionName), + tea.String("module_name", e.ModuleName), + ) + case *fxevent.LoggerInitialized: + if e.Err != nil { + el.l.Error("[Fx] logger initialized", tea.Error(e.Err)) + return + } + el.l.Debug("[Fx] logger initialized", tea.String("constructor_name", e.ConstructorName)) + case *fxevent.OnStartExecuted: + if e.Err != nil { + el.l.Error("[Fx] on start executed", tea.Error(e.Err)) + return + } + el.l.Debug("[Fx] on start executed", + tea.String("caller_name", e.CallerName), + tea.String("function_name", e.FunctionName), + tea.String("method", e.Method), + tea.Int64("runtime", int64(e.Runtime)), + ) + case *fxevent.OnStartExecuting: + el.l.Debug("[Fx] on start executing", + tea.String("caller_name", e.CallerName), + tea.String("function_name", e.FunctionName), + ) + case *fxevent.OnStopExecuted: + if e.Err != nil { + el.l.Error("[Fx] on stop executed", tea.Error(e.Err)) + return + } + el.l.Debug("[Fx] on stop executed", + tea.String("caller_name", e.CallerName), + tea.String("function_name", e.FunctionName), + ) + case *fxevent.OnStopExecuting: + el.l.Debug("[Fx] on stop executing", + tea.String("caller_name", e.CallerName), + tea.String("function_name", e.FunctionName), + ) + case *fxevent.Provided: + if e.Err != nil { + el.l.Error("[Fx] provided", tea.Error(e.Err)) + return + } + el.l.Debug("[Fx] provided", + tea.String("constructor_name", e.ConstructorName), + tea.String("module_name", e.ModuleName), + tea.Bool("private", e.Private), + ) + case *fxevent.Replaced: + if e.Err != nil { + el.l.Error("[Fx] replaced", tea.Error(e.Err)) + return + } + el.l.Debug("[Fx] replaced", + tea.String("module_name", e.ModuleName), + tea.StringSlice("module_trace", e.ModuleTrace), + tea.StringSlice("output_type_names", e.OutputTypeNames), + tea.StringSlice("stacktrace", e.StackTrace), + ) + case *fxevent.RolledBack: + if e.Err != nil { + el.l.Error("[Fx] rolled back", tea.Error(e.Err)) + } + case *fxevent.RollingBack: + if e.StartErr != nil { + el.l.Error("[Fx] rolling back", tea.Error(e.StartErr)) + } + case *fxevent.Run: + if e.Err != nil { + el.l.Error("[Fx] run", tea.Error(e.Err)) + return + } + el.l.Debug("[Fx] run", + tea.String("kind", e.Kind), + tea.String("module_name", e.ModuleName), + tea.String("name", e.Name), + ) + case *fxevent.Started: + if e.Err != nil { + el.l.Error("[Fx] started", tea.Error(e.Err)) + } + case *fxevent.Stopped: + if e.Err != nil { + el.l.Error("[Fx] stopped", tea.Error(e.Err)) + } + case *fxevent.Stopping: + el.l.Debug("[Fx] stopping", tea.String("signal", e.Signal.String())) + case *fxevent.Supplied: + if e.Err != nil { + el.l.Debug("[Fx] supplied", + tea.String("module_name", e.ModuleName), + tea.String("type_name", e.TypeName), + tea.StringSlice("module_trace", e.ModuleTrace), + tea.StringSlice("stacktrace", e.StackTrace), + ) + } + } +} diff --git a/adapter/fx/go.mod b/adapter/fx/go.mod new file mode 100644 index 0000000..1569bbe --- /dev/null +++ b/adapter/fx/go.mod @@ -0,0 +1,13 @@ +module github.com/structx/teapot/adapter/fx + +go 1.25.5 + +require ( + github.com/structx/teapot v0.0.2 + go.uber.org/fx v1.24.0 +) + +require ( + go.uber.org/multierr v1.10.0 // indirect + go.uber.org/zap v1.26.0 // indirect +) diff --git a/adapter/fx/go.sum b/adapter/fx/go.sum new file mode 100644 index 0000000..928f630 --- /dev/null +++ b/adapter/fx/go.sum @@ -0,0 +1,18 @@ +github.com/davecgh/go-spew v1.1.1 h1:vj9j/u1bqnvCEfJOwUhtlOARqs3+rkHYY13jYWTU97c= +github.com/davecgh/go-spew v1.1.1/go.mod h1:J7Y8YcW2NihsgmVo/mv3lAwl/skON4iLHjSsI+c5H38= +github.com/pmezard/go-difflib v1.0.0 h1:4DBwDE0NGyQoBHbLQYPwSUPoCMWR5BEzIk/f1lZbAQM= +github.com/pmezard/go-difflib v1.0.0/go.mod h1:iKH77koFhYxTK1pcRnkKkqfTogsbg7gZNVY4sRDYZ/4= +github.com/stretchr/testify v1.8.1 h1:w7B6lhMri9wdJUVmEZPGGhZzrYTPvgJArz7wNPgYKsk= +github.com/stretchr/testify v1.8.1/go.mod h1:w2LPCIKwWwSfY2zedu0+kehJoqGctiVI29o6fzry7u4= +github.com/structx/teapot v0.0.2 h1:Hq2oxcuYuhUgsNP47PkETOxwO7EpkfB/0srt2ZtVVdc= +github.com/structx/teapot v0.0.2/go.mod h1:2Okp2a8rEEbRWxrEf9zwGPeafR6s9iUGOH6699wLVnY= +go.uber.org/fx v1.24.0 h1:wE8mruvpg2kiiL1Vqd0CC+tr0/24XIB10Iwp2lLWzkg= +go.uber.org/fx v1.24.0/go.mod h1:AmDeGyS+ZARGKM4tlH4FY2Jr63VjbEDJHtqXTGP5hbo= +go.uber.org/goleak v1.2.0 h1:xqgm/S+aQvhWFTtR0XK3Jvg7z8kGV8P4X14IzwN3Eqk= +go.uber.org/goleak v1.2.0/go.mod h1:XJYK+MuIchqpmGmUSAzotztawfKvYLUIgg7guXrwVUo= +go.uber.org/multierr v1.10.0 h1:S0h4aNzvfcFsC3dRF1jLoaov7oRaKqRGC/pUEJ2yvPQ= +go.uber.org/multierr v1.10.0/go.mod h1:20+QtiLqy0Nd6FdQB9TLXag12DsQkrbs3htMFfDN80Y= +go.uber.org/zap v1.26.0 h1:sI7k6L95XOKS281NhVKOFCUNIvv9e0w4BF8N3u+tCRo= +go.uber.org/zap v1.26.0/go.mod h1:dtElttAiwGvoJ/vj4IwHBS/gXsEu/pZ50mUIRWuG0so= +gopkg.in/yaml.v3 v3.0.1 h1:fxVm/GzAzEWqLHuvctI91KS9hhNmmWOoWu0XTYJS7CA= +gopkg.in/yaml.v3 v3.0.1/go.mod h1:K4uyk7z7BCEPqu6E+C64Yfv1cQ7kz7rIZviUmN+EgEM=