Skip to content

Commit fb30861

Browse files
authored
fix: output logging plugin and logging level in chainsync (#518)
1 parent 823ef4a commit fb30861

File tree

2 files changed

+7
-6
lines changed

2 files changed

+7
-6
lines changed

input/chainsync/chainsync.go

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -230,7 +230,7 @@ func (c *ChainSync) setupConnection() error {
230230
if c.autoReconnect {
231231
c.autoReconnectDelay = 0
232232
if c.logger != nil {
233-
c.logger.Info(fmt.Sprintf(
233+
c.logger.Error(fmt.Sprintf(
234234
"reconnecting to %s due to error: %s",
235235
c.dialAddress,
236236
err,
@@ -268,7 +268,7 @@ func (c *ChainSync) setupConnection() error {
268268
// Restart the connection
269269
if err := c.Start(); err != nil {
270270
if c.logger != nil {
271-
c.logger.Info(fmt.Sprintf(
271+
c.logger.Error(fmt.Sprintf(
272272
"reconnecting to %s due to error: %s",
273273
c.dialAddress,
274274
err,

output/log/log.go

Lines changed: 5 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -15,6 +15,7 @@
1515
package log
1616

1717
import (
18+
"fmt"
1819
"log/slog"
1920

2021
"github.com/blinklabs-io/adder/event"
@@ -63,14 +64,14 @@ func (l *LogOutput) Start() error {
6364
}
6465
switch l.level {
6566
case "info":
66-
l.outputLogger.Info("", "event", evt)
67+
l.outputLogger.Info("", "event", fmt.Sprintf("%+v", evt))
6768
case "warn":
68-
l.outputLogger.Warn("", "event", evt)
69+
l.outputLogger.Warn("", "event", fmt.Sprintf("%+v", evt))
6970
case "error":
70-
l.outputLogger.Error("", "event", evt)
71+
l.outputLogger.Error("", "event", fmt.Sprintf("%+v", evt))
7172
default:
7273
// Use INFO level if log level isn't recognized
73-
l.outputLogger.Info("", "event", evt)
74+
l.outputLogger.Info("", "event", fmt.Sprintf("%+v", evt))
7475
}
7576
}
7677
}()

0 commit comments

Comments
 (0)