diff --git a/server/server.go b/server/server.go index 0f88c4a..6d9fab4 100644 --- a/server/server.go +++ b/server/server.go @@ -3,6 +3,7 @@ package server import ( "context" "fmt" + "log/slog" "net" "net/http" "strings" @@ -132,7 +133,7 @@ func (s *Server) Start(ctx context.Context) error { } go func() { if err := s.apiV2Service.GetGRPCServer().Serve(listen); err != nil { - println("grpc server listen error") + slog.Log(ctx, slog.LevelError, "failed to start grpc server") } }() diff --git a/store/db/db.go b/store/db/db.go index 9995411..6c14be2 100644 --- a/store/db/db.go +++ b/store/db/db.go @@ -6,6 +6,7 @@ import ( "embed" "fmt" "io/fs" + "log/slog" "os" "regexp" "sort" @@ -119,23 +120,23 @@ func (db *DB) Open(ctx context.Context) (err error) { if err := os.WriteFile(backupDBFilePath, rawBytes, 0644); err != nil { return errors.Wrap(err, "failed to write raw database file") } - println("succeed to copy a backup database file") + slog.Log(ctx, slog.LevelInfo, "succeed to copy a backup database file") - println("start migrate") + slog.Log(ctx, slog.LevelInfo, "start migrate") for _, minorVersion := range minorVersionList { normalizedVersion := minorVersion + ".0" if version.IsVersionGreaterThan(normalizedVersion, latestMigrationHistoryVersion) && version.IsVersionGreaterOrEqualThan(currentVersion, normalizedVersion) { - println("applying migration for", normalizedVersion) + slog.Log(ctx, slog.LevelInfo, fmt.Sprintf("applying migration for %s", normalizedVersion)) if err := db.applyMigrationForMinorVersion(ctx, minorVersion); err != nil { return errors.Wrap(err, "failed to apply minor version migration") } } } - println("end migrate") + slog.Log(ctx, slog.LevelInfo, "end migrate") // remove the created backup db file after migrate succeed if err := os.Remove(backupDBFilePath); err != nil { - println(fmt.Sprintf("Failed to remove temp database file, err %v", err)) + slog.Log(ctx, slog.LevelError, fmt.Sprintf("Failed to remove temp database file, err %v", err)) } } } else {