aykhans/slash-e
1
0
Fork 0
mirror of https://github.com/aykhans/slash-e.git synced 2025-04-20 22:07:15 +00:00
Code Issues Actions Packages Projects Releases Wiki Activity

chore: update logger

Browse Source
This commit is contained in:
Steven 2023-11-07 07:43:18 +08:00
parent 67c3bbf1ee
commit 8faaf8ced1
2 changed files with 8 additions and 6 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

3
server/server.go
View File

@ -3,6 +3,7 @@ package server
import ( import (
"context" "context"
"fmt" "fmt"
"log/slog"
"net" "net"
"net/http" "net/http"
"strings" "strings"
@ -132,7 +133,7 @@ func (s *Server) Start(ctx context.Context) error {
} }
go func() { go func() {
if err := s.apiV2Service.GetGRPCServer().Serve(listen); err != nil { if err := s.apiV2Service.GetGRPCServer().Serve(listen); err != nil {
println("grpc server listen error") slog.Log(ctx, slog.LevelError, "failed to start grpc server")
} }
}() }()

11
store/db/db.go
View File

@ -6,6 +6,7 @@ import (
"embed" "embed"
"fmt" "fmt"
"io/fs" "io/fs"
"log/slog"
"os" "os"
"regexp" "regexp"
"sort" "sort"
@ -119,23 +120,23 @@ func (db *DB) Open(ctx context.Context) (err error) {
if err := os.WriteFile(backupDBFilePath, rawBytes, 0644); err != nil { if err := os.WriteFile(backupDBFilePath, rawBytes, 0644); err != nil {
return errors.Wrap(err, "failed to write raw database file") 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 { for _, minorVersion := range minorVersionList {
normalizedVersion := minorVersion + ".0" normalizedVersion := minorVersion + ".0"
if version.IsVersionGreaterThan(normalizedVersion, latestMigrationHistoryVersion) && version.IsVersionGreaterOrEqualThan(currentVersion, normalizedVersion) { 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 { if err := db.applyMigrationForMinorVersion(ctx, minorVersion); err != nil {
return errors.Wrap(err, "failed to apply minor version migration") 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 // remove the created backup db file after migrate succeed
if err := os.Remove(backupDBFilePath); err != nil { 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 { } else {