refactor: skip unwanted logs

CHANGELOG.md

@@ -1,5 +1,9 @@
 # Changelog
 
+## [v1.1.1] - 2024-12-19
+
+* [#120](https://github.com/cosmos/cosmos-db/pull/120) Skip unwanted logs from PebbleDB
+
 ## [v1.1.0] - 2024-11-22
 
 * Allow full control in rocksdb opening

pebble.go

@@ -53,7 +53,7 @@
 )
 
 func init() {
 	dbCreator := func(name string, dir string, opts Options) (DB, error) {
 		return NewPebbleDB(name, dir, opts)
 	}
 	registerDBCreator(PebbleDBBackend, dbCreator, false)
@@ -72,6 +72,7 @@
 
 func NewPebbleDB(name string, dir string, opts Options) (DB, error) {
 	do := &pebble.Options{
+		Logger:                   &fatalLogger{},          // pebble info logs are messing up the logs (not a cosmossdk.io/log logger)
 		MaxConcurrentCompactions: func() int { return 3 }, // default 1
 	}
 
@@ -96,7 +97,6 @@
 
 // Get implements DB.
 func (db *PebbleDB) Get(key []byte) ([]byte, error) {
-	// fmt.Println("PebbleDB.Get")
 	if len(key) == 0 {
 		return nil, errKeyEmpty
 	}
@@ -232,7 +232,7 @@
 
 // NewBatchWithSize implements DB.
 // It does the same thing as NewBatch because we can't pre-allocate pebbleDBBatch
 func (db *PebbleDB) NewBatchWithSize(size int) Batch {
 	return newPebbleDBBatch(db)
 }
 
@@ -276,7 +276,7 @@
 var _ Batch = (*pebbleDBBatch)(nil)
 
 type pebbleDBBatch struct {
 	db    *PebbleDB
 	batch *pebble.Batch
 }
 
@@ -300,7 +300,7 @@
 	if b.batch == nil {
 		return errBatchClosed
 	}
 	b.batch.Set(key, value, nil)
 	return nil
 }
 
@@ -313,7 +313,7 @@
 	if b.batch == nil {
 		return errBatchClosed
 	}
 	b.batch.Delete(key, nil)
 	return nil
 }
 
@@ -492,3 +492,13 @@
 		panic("iterator is invalid")
 	}
 }
+
+type fatalLogger struct {
+	pebble.Logger
+}
+
+func (*fatalLogger) Fatalf(format string, args ...interface{}) {
+	pebble.DefaultLogger.Fatalf(format, args...)
+}
+
+func (*fatalLogger) Infof(format string, args ...interface{}) {}