Skip to content

Commit

Permalink
add logid
Browse files Browse the repository at this point in the history
  • Loading branch information
dhcmrlchtdj committed Jun 5, 2024
1 parent d4ad5aa commit aaf2392
Show file tree
Hide file tree
Showing 2 changed files with 17 additions and 10 deletions.
12 changes: 11 additions & 1 deletion cmd/feedbox/init_env.go
Original file line number Diff line number Diff line change
Expand Up @@ -7,6 +7,7 @@ import (
"syscall"

"github.com/joho/godotenv"
"github.com/rs/xid"
"github.com/rs/zerolog"
"github.com/rs/zerolog/pkgerrors"

Expand All @@ -26,8 +27,17 @@ func initEnv() {
util.CheckEnvs("ENV")
}

func initLogger() {
type LogIdHook struct{}

func (h LogIdHook) Run(e *zerolog.Event, _ zerolog.Level, _ string) {
e.Str("logId", xid.New().String())
}

func initLogger() zerolog.Logger {
zerolog.ErrorStackMarshaler = pkgerrors.MarshalStack // nolint:reassign
logger := zerolog.New(os.Stderr).With().Timestamp().Logger()
logger = logger.Hook(LogIdHook{})
return logger
}

func initDatabase(ctx context.Context) {
Expand Down
15 changes: 6 additions & 9 deletions cmd/feedbox/main.go
Original file line number Diff line number Diff line change
Expand Up @@ -36,12 +36,11 @@ func main() {
///

func startServerAndWorker() {
logger := zerolog.New(os.Stderr).With().Timestamp().Logger()
initEnv()
logger := initLogger()
ctx, cancel := context.WithCancel(context.Background())
ctx = logger.WithContext(ctx)

initEnv()
initLogger()
initDatabase(ctx)
defer database.Close()
initEmail()
Expand Down Expand Up @@ -69,12 +68,11 @@ func startServerAndWorker() {
}

func startServer() {
logger := zerolog.New(os.Stderr).With().Timestamp().Logger()
initEnv()
logger := initLogger()
ctx, cancel := context.WithCancel(context.Background())
ctx = logger.WithContext(ctx)

initEnv()
initLogger()
initDatabase(ctx)
defer database.Close()
initEmail()
Expand All @@ -87,11 +85,10 @@ func startServer() {
}

func startWorker() {
logger := zerolog.New(os.Stderr).With().Timestamp().Logger()
initEnv()
logger := initLogger()
ctx := logger.WithContext(context.Background())

initEnv()
initLogger()
initDatabase(ctx)
initEmail()
initTelegram()
Expand Down

0 comments on commit aaf2392

Please sign in to comment.