Skip to content

Commit 0289640

Browse files
committed
fix: routing
1 parent dcde579 commit 0289640

File tree

4 files changed

+18
-6
lines changed

4 files changed

+18
-6
lines changed

cmd/debts/main.go

Lines changed: 8 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -8,6 +8,7 @@ package main
88

99
import (
1010
"context"
11+
"strings"
1112
"time"
1213

1314
"github.com/Gearbox-protocol/sdk-go/core"
@@ -22,9 +23,14 @@ import (
2223
)
2324

2425
func StartServer(lc fx.Lifecycle, debtEng ds.DebtEngineI, config *config.Config, shutdowner fx.Shutdowner, client core.ClientI) {
26+
chainid := core.GetChainId(client)
27+
routeKey := log.GetNetworkName(chainid)
28+
if strings.Contains("anvil.gearbox.foundation", config.EthProvider) {
29+
routeKey = log.GetTestNet(chainid)
30+
}
2531
log.NewAMQPService(config.AMQPEnable, config.AMQPUrl, log.LoggingConfig{
26-
ChainId: core.GetChainId(client),
27-
Exchange: "TelegramBot",
32+
ROUTE_KEY: routeKey,
33+
Exchange: "TelegramBot",
2834
}, config.AppName)
2935
// Starting server
3036
lc.Append(fx.Hook{

cmd/main.go

Lines changed: 7 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -9,6 +9,7 @@ package main
99
import (
1010
"context"
1111
_ "net/http/pprof"
12+
"strings"
1213
"time"
1314

1415
"github.com/Gearbox-protocol/sdk-go/core"
@@ -32,12 +33,17 @@ import (
3233
// }
3334

3435
func StartServer(lc fx.Lifecycle, engine ds.EngineI, cfg *config.Config, client core.ClientI) {
36+
chainid := core.GetChainId(client)
37+
routeKey := log.GetNetworkName(chainid)
38+
if strings.Contains("anvil.gearbox.foundation", cfg.EthProvider) {
39+
routeKey = log.GetTestNet(chainid)
40+
}
3541
log.NewAMQPService(
3642
cfg.AMQPEnable,
3743
cfg.AMQPUrl,
3844
log.LoggingConfig{
3945
Exchange: "TelegramBot",
40-
ChainId: core.GetChainId(client),
46+
ROUTE_KEY: routeKey,
4147
RiskEndpoint: cfg.RiskEndpoint,
4248
RiskSecret: cfg.RiskSecret,
4349
},

go.mod

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -3,7 +3,7 @@ module github.com/Gearbox-protocol/third-eye
33
go 1.20
44

55
require (
6-
github.com/Gearbox-protocol/sdk-go v0.0.0-20250320003540-9953f5c38c6b
6+
github.com/Gearbox-protocol/sdk-go v0.0.0-20250320030710-74b546ddd79c
77
github.com/ethereum/go-ethereum v1.13.14
88
github.com/go-playground/validator/v10 v10.4.1
99
github.com/google/go-cmp v0.5.9

go.sum

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -5,8 +5,8 @@ contrib.go.opencensus.io/exporter/ocagent v0.6.0/go.mod h1:zmKjrJcdo0aYcVS7bmEeS
55
github.com/BurntSushi/toml v0.3.1 h1:WXkYYl6Yr3qBf1K79EBnL4mak0OimBfB0XUf9Vl28OQ=
66
github.com/BurntSushi/toml v0.3.1/go.mod h1:xHWCNGjB5oqiDr8zfno3MHue2Ht5sIBksp03qcyfWMU=
77
github.com/DataDog/zstd v1.4.5 h1:EndNeuB0l9syBZhut0wns3gV1hL8zX8LIu6ZiVHWLIQ=
8-
github.com/Gearbox-protocol/sdk-go v0.0.0-20250320003540-9953f5c38c6b h1:l3pNJGDpRDmSkqoh/zI048M4uvqC0mt5fPKrpNp/X7o=
9-
github.com/Gearbox-protocol/sdk-go v0.0.0-20250320003540-9953f5c38c6b/go.mod h1:jRBSOG94bpGc5ci8EWIPUVXZdaGEaekMNmhajbmWFVU=
8+
github.com/Gearbox-protocol/sdk-go v0.0.0-20250320030710-74b546ddd79c h1:Hy4vgH4/+12OOByDZ7/bNCZ9++b7mjiaPl0cW0UFCxo=
9+
github.com/Gearbox-protocol/sdk-go v0.0.0-20250320030710-74b546ddd79c/go.mod h1:jRBSOG94bpGc5ci8EWIPUVXZdaGEaekMNmhajbmWFVU=
1010
github.com/Microsoft/go-winio v0.6.1 h1:9/kr64B9VUZrLm5YYwbGtUJnMgqWVOdUAXu6Migciow=
1111
github.com/Microsoft/go-winio v0.6.1/go.mod h1:LRdKpFKfdobln8UmuiYcKPot9D2v6svN5+sAH+4kjUM=
1212
github.com/OffchainLabs/go-ethereum v1.13.4-0.20240313010929-e5d8587e7227 h1:+/3TrD+q+BP36jGj2Bycdmrc/joKLNbc5ImePQzKRLM=

0 commit comments

Comments
 (0)