mirror of
https://github.com/pikami/cosmium.git
synced 2025-04-17 07:07:38 +01:00
Fix issues with persist flag; Use custom logger for badger
This commit is contained in:
parent
28e3c0c3d8
commit
598f2837af
@ -77,8 +77,13 @@ func (c *ServerConfig) PopulateCalculatedFields() {
|
|||||||
logger.SetLogLevel(logger.LogLevelInfo)
|
logger.SetLogLevel(logger.LogLevelInfo)
|
||||||
}
|
}
|
||||||
|
|
||||||
if c.PersistDataFilePath != "" {
|
fileInfo, err := os.Stat(c.PersistDataFilePath)
|
||||||
fileInfo, _ := os.Stat(c.PersistDataFilePath)
|
if c.PersistDataFilePath != "" && !os.IsNotExist(err) {
|
||||||
|
if err != nil {
|
||||||
|
logger.ErrorLn("Failed to get file info for persist path:", err)
|
||||||
|
os.Exit(1)
|
||||||
|
}
|
||||||
|
|
||||||
if c.DataStore == DataStoreJson && fileInfo.IsDir() {
|
if c.DataStore == DataStoreJson && fileInfo.IsDir() {
|
||||||
logger.ErrorLn("--Persist cannot be a directory when using json data store")
|
logger.ErrorLn("--Persist cannot be a directory when using json data store")
|
||||||
os.Exit(1)
|
os.Exit(1)
|
||||||
|
@ -15,6 +15,7 @@ type BadgerDataStoreOptions struct {
|
|||||||
|
|
||||||
func NewBadgerDataStore(options BadgerDataStoreOptions) *BadgerDataStore {
|
func NewBadgerDataStore(options BadgerDataStoreOptions) *BadgerDataStore {
|
||||||
badgerOpts := badger.DefaultOptions(options.PersistDataFilePath)
|
badgerOpts := badger.DefaultOptions(options.PersistDataFilePath)
|
||||||
|
badgerOpts = badgerOpts.WithLogger(newBadgerLogger())
|
||||||
if options.PersistDataFilePath == "" {
|
if options.PersistDataFilePath == "" {
|
||||||
badgerOpts = badgerOpts.WithInMemory(true)
|
badgerOpts = badgerOpts.WithInMemory(true)
|
||||||
}
|
}
|
||||||
|
28
internal/datastore/badger_datastore/badger_logger.go
Normal file
28
internal/datastore/badger_datastore/badger_logger.go
Normal file
@ -0,0 +1,28 @@
|
|||||||
|
package badgerdatastore
|
||||||
|
|
||||||
|
import (
|
||||||
|
"github.com/dgraph-io/badger/v4"
|
||||||
|
"github.com/pikami/cosmium/internal/logger"
|
||||||
|
)
|
||||||
|
|
||||||
|
type badgerLogger struct{}
|
||||||
|
|
||||||
|
func newBadgerLogger() badger.Logger {
|
||||||
|
return &badgerLogger{}
|
||||||
|
}
|
||||||
|
|
||||||
|
func (l *badgerLogger) Errorf(format string, v ...interface{}) {
|
||||||
|
logger.Errorf(format, v...)
|
||||||
|
}
|
||||||
|
|
||||||
|
func (l *badgerLogger) Warningf(format string, v ...interface{}) {
|
||||||
|
logger.Infof(format, v...)
|
||||||
|
}
|
||||||
|
|
||||||
|
func (l *badgerLogger) Infof(format string, v ...interface{}) {
|
||||||
|
logger.Infof(format, v...)
|
||||||
|
}
|
||||||
|
|
||||||
|
func (l *badgerLogger) Debugf(format string, v ...interface{}) {
|
||||||
|
logger.Debugf(format, v...)
|
||||||
|
}
|
Loading…
x
Reference in New Issue
Block a user