commit 2b7c8fcaa59a1fbeb2e038246f29377fcb2f2664
parent 93b0c2db1e5aa0a42b1c4be63f658f5b67be1b5d
Author: lash <dev@holbrook.no>
Date: Sat, 18 Jan 2025 15:42:27 +0000
Remove noisy logs and commented code
Diffstat:
3 files changed, 0 insertions(+), 18 deletions(-)
diff --git a/db/fs/dump.go b/db/fs/dump.go
@@ -10,7 +10,6 @@ import (
func(fdb *fsDb) Dump(ctx context.Context, key []byte) (*db.Dumper, error) {
var err error
- //key = append([]byte{db.DATATYPE_USERDATA}, key...)
key = append([]byte{fdb.Prefix()}, key...)
fdb.matchPrefix = key
fdb.elements, err = os.ReadDir(fdb.dir)
diff --git a/db/gdbm/dump.go b/db/gdbm/dump.go
@@ -12,7 +12,6 @@ import (
// TODO: userdata is hardcoded here, should not be
func(gdb *gdbmDb) Dump(ctx context.Context, key []byte) (*db.Dumper, error) {
- //gdb.SetPrefix(db.DATATYPE_USERDATA)
gdb.SetLanguage(nil)
lk, err := gdb.ToKey(ctx, key)
if err != nil {
@@ -33,7 +32,6 @@ func(gdb *gdbmDb) Dump(ctx context.Context, key []byte) (*db.Dumper, error) {
if !bytes.HasPrefix(k, key) {
continue
}
- //gdb.SetPrefix(k[0])
logg.TraceCtxf(ctx, "dump trace", "k", k, "key", key)
kk, err := gdb.DecodeKey(ctx, k)
if err != nil {
@@ -62,7 +60,6 @@ func(gdb *gdbmDb) dumpFunc(ctx context.Context) ([]byte, []byte) {
gdb.it = nil
return nil, nil
}
- //if bytes.HasPrefix(k[1:], gdb.itBase) {
if bytes.HasPrefix(k, gdb.itBase) {
match = true
break
@@ -72,7 +69,6 @@ func(gdb *gdbmDb) dumpFunc(ctx context.Context) ([]byte, []byte) {
gdb.it = nil
return nil, nil
}
- //gdb.SetPrefix(k[0])
logg.TraceCtxf(ctx, "gdbm dump func", "key", k)
kk, err := gdb.DecodeKey(ctx, k)
if err != nil {
diff --git a/db/postgres/dump.go b/db/postgres/dump.go
@@ -13,7 +13,6 @@ func(pdb *pgDb) Dump(ctx context.Context, key []byte) (*db.Dumper, error) {
return nil, err
}
- //pdb.SetPrefix(db.DATATYPE_USERDATA)
pdb.SetLanguage(nil)
lk, err := pdb.ToKey(ctx, key)
if err != nil {
@@ -22,7 +21,6 @@ func(pdb *pgDb) Dump(ctx context.Context, key []byte) (*db.Dumper, error) {
k := lk.Default
query := fmt.Sprintf("SELECT key, value FROM %s.kv_vise WHERE key >= $1", pdb.schema)
- logg.TraceCtxf(ctx, "getkey", "q", query, "key", k)
rs, err := tx.Query(ctx, query, k)
if err != nil {
logg.Debugf("query fail", "err", err)
@@ -30,25 +28,17 @@ func(pdb *pgDb) Dump(ctx context.Context, key []byte) (*db.Dumper, error) {
return nil, err
}
defer tx.Commit(ctx)
- //defer rs.Close()
if rs.Next() {
var kk []byte
var vv []byte
-// r, err := rs.Values()
-// if err != nil {
-// return nil, err
-// }
err = rs.Scan(&kk, &vv)
if err != nil {
return nil, err
}
- //tx.Rollback(ctx)
- //tx.Commit(ctx)
pdb.it = rs
pdb.itBase = k
kk, err = pdb.DecodeKey(ctx, kk)
- logg.Debugf("pg decode", "k", kk, "o", k, "err", err, "vv", vv)
if err != nil {
return nil, err
}
@@ -71,13 +61,10 @@ func(pdb *pgDb) dumpFunc(ctx context.Context) ([]byte, []byte) {
if err != nil {
return nil, nil
}
- //r := pdb.it.RawValues()
- //k, err := pdb.DecodeKey(ctx, r[0])
k, err := pdb.DecodeKey(ctx, kk)
if err != nil {
return nil, nil
}
- logg.Debugf("pg decode dump", "k", kk, "o", k, "err", err, "vv", vv)
return k, vv
}