kylefang/gaze-indexer
1
0
Fork 0
mirror of https://github.com/alexgo-io/gaze-indexer.git synced 2026-04-29 12:15:13 +08:00
Code Issues Packages Projects Releases Wiki Activity

feat(btc): use slogx

Browse Source 
Co-authored-by: Gaze <gazenw@users.noreply.github.com>
This commit is contained in:
Gaze
2024-04-10 04:40:06 +07:00
parent 60d4c8ba51
commit 8fdc705bae
2 changed files with 8 additions and 5 deletions
Download Patch File Download Diff File Expand all files Collapse all files

9
cmd/main.go
View File

@@ -10,6 +10,7 @@ import (
"github.com/btcsuite/btcd/rpcclient"
"github.com/btcsuite/btclog"
"github.com/gaze-network/indexer-network/pkg/logger"
"github.com/gaze-network/indexer-network/pkg/logger/slogx"
)
var (
@@ -30,7 +31,7 @@ func main() {
Output: "text",
Debug: true,
}); err != nil {
logger.Panic("Failed to initialize logger: %v", logger.AttrError(err))
logger.Panic("Failed to initialize logger: %v", slogx.Error(err))
}
client, err := rpcclient.New(&rpcclient.ConnConfig{
@@ -41,17 +42,17 @@ func main() {
// DisableTLS: true,
}, nil)
if err != nil {
logger.Panic("Failed to create Bitcoin Core RPC Client", logger.AttrError(err))
logger.Panic("Failed to create Bitcoin Core RPC Client", slogx.Error(err))
}
defer client.Shutdown()
if err := client.Ping(); err != nil {
logger.Panic("Failed to ping Bitcoin Core RPC Server", logger.AttrError(err))
logger.Panic("Failed to ping Bitcoin Core RPC Server", slogx.Error(err))
}
peerInfo, err := client.GetPeerInfo()
if err != nil {
logger.Panic("Failed to get peer info", logger.AttrError(err))
logger.Panic("Failed to get peer info", slogx.Error(err))
}
logger.Info("Connected to Bitcoin Core RPC Server", slog.Int("peers", len(peerInfo)))

4
modules/bitcoin/processor.go
View File

@@ -3,6 +3,7 @@ package bitcoin
import (
"cmp"
"context"
"log/slog"
"slices"
"github.com/cockroachdb/errors"
@@ -10,6 +11,7 @@ import (
"github.com/gaze-network/indexer-network/core/types"
"github.com/gaze-network/indexer-network/modules/bitcoin/internal/datagateway"
"github.com/gaze-network/indexer-network/pkg/logger"
"github.com/gaze-network/indexer-network/pkg/logger/slogx"
)
// Make sure to implement the BitcoinProcessor interface
@@ -57,7 +59,7 @@ func (p *Processor) Process(ctx context.Context, inputs []*types.Block) error {
if err != nil {
return errors.Wrapf(err, "failed to insert block, height: %d, hash: %s", b.Header.Height, b.Header.Hash)
}
logger.InfoContext(ctx, "Block inserted", "height", b.Header.Height, "hash", b.Header.Hash)
logger.InfoContext(ctx, "Block inserted", slog.Int64("height", b.Header.Height), slogx.Stringer("hash", b.Header.Hash))
}
return nil