Add logs

blocknative · Sep 5, 2023 · cc830d0 · cc830d0
1 parent fa57cfd
commit cc830d0
Show file tree

Hide file tree

Showing 2 changed files with 12 additions and 3 deletions.
diff --git a/cmd/dreamboat/main.go b/cmd/dreamboat/main.go
@@ -194,7 +194,7 @@ func main() {
 		return
 	}
 
-	simFallb := fallback.NewFallback()
+	simFallb := fallback.NewFallback(logger)
 	simFallb.AttachMetrics(m)
 
 	simManager := sim.NewManager(logger, simFallb)

diff --git a/sim/client/fallback/fallback.go b/sim/client/fallback/fallback.go
@@ -4,6 +4,8 @@ import (
 	"context"
 	"errors"
 
+	"github.com/lthibault/log"
+
 	sim "github.com/blocknative/dreamboat/sim/client"
 	"github.com/blocknative/dreamboat/sim/client/types"
 )
@@ -14,10 +16,14 @@ type Fallback struct {
 	clientsHTTP []sim.Client
 	atLeastOne  bool
 	m           Metrics
+
+	l log.Logger
 }
 
-func NewFallback() *Fallback {
-	f := &Fallback{}
+func NewFallback(l log.Logger) *Fallback {
+	f := &Fallback{
+		l: l,
+	}
 	f.initMetrics()
 	return f
 }
@@ -117,6 +123,7 @@ func (f *Fallback) validateBlock(ctx context.Context, c sim.Client, block *types
 		return err, false
 	}
 
+	f.l.With(log.F{"node": node}).WithError(err).Warn("validation fallback")
 	f.m.ServedFrom.WithLabelValues(c.Kind(), node, "fallback").Inc()
 	return err, true
 }
@@ -169,6 +176,8 @@ func (f *Fallback) validateBlockV2(ctx context.Context, c sim.Client, block *typ
 		return err, false
 	}
 
+	f.l.With(log.F{"node": node}).WithError(err).Warn("validation fallback")
+
 	f.m.ServedFrom.WithLabelValues(c.Kind(), node, "fallback").Inc()
 	return err, true
 }