Skip to content

Commit 98b6663

Browse files
committed
gnosis-keyper: move config to package
1 parent d9f06a4 commit 98b6663

File tree

7 files changed

+21
-19
lines changed

7 files changed

+21
-19
lines changed

rolling-shutter/cmd/gnosiskeyper/gnosiskeyper.go

Lines changed: 4 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -11,6 +11,7 @@ import (
1111
"github.com/shutter-network/rolling-shutter/rolling-shutter/cmd/shversion"
1212
"github.com/shutter-network/rolling-shutter/rolling-shutter/gnosiskeyperwatcher"
1313
keyper "github.com/shutter-network/rolling-shutter/rolling-shutter/keyperimpl/gnosis"
14+
keyperconfig "github.com/shutter-network/rolling-shutter/rolling-shutter/keyperimpl/gnosis/config"
1415
"github.com/shutter-network/rolling-shutter/rolling-shutter/keyperimpl/gnosis/database"
1516
"github.com/shutter-network/rolling-shutter/rolling-shutter/medley/configuration/command"
1617
"github.com/shutter-network/rolling-shutter/rolling-shutter/medley/db"
@@ -38,7 +39,7 @@ Shuttermint node which have to be started separately in advance.`,
3839
return builder.Command()
3940
}
4041

41-
func main(config *keyper.Config) error {
42+
func main(config *keyperconfig.Config) error {
4243
log.Info().
4344
Str("version", shversion.Version()).
4445
Str("address", config.GetAddress().Hex()).
@@ -49,7 +50,7 @@ func main(config *keyper.Config) error {
4950
return service.RunWithSighandler(context.Background(), kpr)
5051
}
5152

52-
func initDB(cfg *keyper.Config) error {
53+
func initDB(cfg *keyperconfig.Config) error {
5354
ctx := context.Background()
5455
dbpool, err := pgxpool.Connect(ctx, cfg.DatabaseURL)
5556
if err != nil {
@@ -59,7 +60,7 @@ func initDB(cfg *keyper.Config) error {
5960
return db.InitDB(ctx, dbpool, database.Definition.Name(), database.Definition)
6061
}
6162

62-
func watch(cfg *keyper.Config) error {
63+
func watch(cfg *keyperconfig.Config) error {
6364
log.Info().Msg("starting monitor")
6465
return service.RunWithSighandler(context.Background(), gnosiskeyperwatcher.New(cfg))
6566
}

rolling-shutter/gnosisaccessnode/config.go

Lines changed: 3 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -3,7 +3,7 @@ package gnosisaccessnode
33
import (
44
"io"
55

6-
gnosiskeyper "github.com/shutter-network/rolling-shutter/rolling-shutter/keyperimpl/gnosis"
6+
gnosisconfig "github.com/shutter-network/rolling-shutter/rolling-shutter/keyperimpl/gnosis/config"
77
"github.com/shutter-network/rolling-shutter/rolling-shutter/medley/configuration"
88
"github.com/shutter-network/rolling-shutter/rolling-shutter/medley/metricsserver"
99
"github.com/shutter-network/rolling-shutter/rolling-shutter/p2p"
@@ -13,7 +13,7 @@ type Config struct {
1313
InstanceID uint64
1414

1515
GnosisNode *configuration.EthnodeConfig
16-
Contracts *gnosiskeyper.GnosisContractsConfig
16+
Contracts *gnosisconfig.GnosisContractsConfig
1717
P2P *p2p.Config
1818
Metrics *metricsserver.MetricsConfig
1919

@@ -22,7 +22,7 @@ type Config struct {
2222

2323
func (c *Config) Init() {
2424
c.GnosisNode = configuration.NewEthnodeConfig()
25-
c.Contracts = gnosiskeyper.NewGnosisContractsConfig()
25+
c.Contracts = gnosisconfig.NewGnosisContractsConfig()
2626
c.P2P = p2p.NewConfig()
2727
c.Metrics = metricsserver.NewConfig()
2828
}

rolling-shutter/gnosiskeyperwatcher/blocks.go

Lines changed: 3 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -8,12 +8,12 @@ import (
88
"github.com/ethereum/go-ethereum/ethclient"
99
"github.com/rs/zerolog/log"
1010

11-
keyper "github.com/shutter-network/rolling-shutter/rolling-shutter/keyperimpl/gnosis"
11+
gnosisconfig "github.com/shutter-network/rolling-shutter/rolling-shutter/keyperimpl/gnosis/config"
1212
"github.com/shutter-network/rolling-shutter/rolling-shutter/medley/service"
1313
)
1414

1515
type BlocksWatcher struct {
16-
config *keyper.Config
16+
config *gnosisconfig.Config
1717
blocksChannel chan *BlockReceivedEvent
1818
}
1919

@@ -22,7 +22,7 @@ type BlockReceivedEvent struct {
2222
Time time.Time
2323
}
2424

25-
func NewBlocksWatcher(config *keyper.Config, blocksChannel chan *BlockReceivedEvent) *BlocksWatcher {
25+
func NewBlocksWatcher(config *gnosisconfig.Config, blocksChannel chan *BlockReceivedEvent) *BlocksWatcher {
2626
return &BlocksWatcher{
2727
config: config,
2828
blocksChannel: blocksChannel,

rolling-shutter/gnosiskeyperwatcher/keys.go

Lines changed: 3 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -9,22 +9,22 @@ import (
99
pubsub "github.com/libp2p/go-libp2p-pubsub"
1010
"github.com/rs/zerolog/log"
1111

12-
keyper "github.com/shutter-network/rolling-shutter/rolling-shutter/keyperimpl/gnosis"
12+
gnosisconfig "github.com/shutter-network/rolling-shutter/rolling-shutter/keyperimpl/gnosis/config"
1313
"github.com/shutter-network/rolling-shutter/rolling-shutter/medley/service"
1414
"github.com/shutter-network/rolling-shutter/rolling-shutter/p2p"
1515
"github.com/shutter-network/rolling-shutter/rolling-shutter/p2pmsg"
1616
)
1717

1818
type KeysWatcher struct {
19-
config *keyper.Config
19+
config *gnosisconfig.Config
2020
blocksChannel chan *BlockReceivedEvent
2121

2222
recentBlocksMux sync.Mutex
2323
recentBlocks map[uint64]*BlockReceivedEvent
2424
mostRecentBlock uint64
2525
}
2626

27-
func NewKeysWatcher(config *keyper.Config, blocksChannel chan *BlockReceivedEvent) *KeysWatcher {
27+
func NewKeysWatcher(config *gnosisconfig.Config, blocksChannel chan *BlockReceivedEvent) *KeysWatcher {
2828
return &KeysWatcher{
2929
config: config,
3030
blocksChannel: blocksChannel,

rolling-shutter/gnosiskeyperwatcher/watcher.go

Lines changed: 3 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -3,15 +3,15 @@ package gnosiskeyperwatcher
33
import (
44
"context"
55

6-
keyper "github.com/shutter-network/rolling-shutter/rolling-shutter/keyperimpl/gnosis"
6+
gnosisconfig "github.com/shutter-network/rolling-shutter/rolling-shutter/keyperimpl/gnosis/config"
77
"github.com/shutter-network/rolling-shutter/rolling-shutter/medley/service"
88
)
99

1010
type Watcher struct {
11-
config *keyper.Config
11+
config *gnosisconfig.Config
1212
}
1313

14-
func New(config *keyper.Config) *Watcher {
14+
func New(config *gnosisconfig.Config) *Watcher {
1515
return &Watcher{
1616
config: config,
1717
}

rolling-shutter/keyperimpl/gnosis/config.go renamed to rolling-shutter/keyperimpl/gnosis/config/config.go

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -1,4 +1,4 @@
1-
package gnosis
1+
package config
22

33
import (
44
"io"

rolling-shutter/keyperimpl/gnosis/messagingmiddleware.go

Lines changed: 4 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -15,6 +15,7 @@ import (
1515
"google.golang.org/protobuf/proto"
1616

1717
obskeyperdatabase "github.com/shutter-network/rolling-shutter/rolling-shutter/chainobserver/db/keyper"
18+
"github.com/shutter-network/rolling-shutter/rolling-shutter/keyperimpl/gnosis/config"
1819
"github.com/shutter-network/rolling-shutter/rolling-shutter/keyperimpl/gnosis/database"
1920
"github.com/shutter-network/rolling-shutter/rolling-shutter/keyperimpl/gnosis/gnosisssztypes"
2021
"github.com/shutter-network/rolling-shutter/rolling-shutter/medley"
@@ -26,7 +27,7 @@ import (
2627
)
2728

2829
type MessagingMiddleware struct {
29-
config *Config
30+
config *config.Config
3031
messaging p2p.Messaging
3132
dbpool *pgxpool.Pool
3233
}
@@ -62,8 +63,8 @@ func (h *WrappedMessageHandler) HandleMessage(ctx context.Context, msg p2pmsg.Me
6263
return replacedMsgs, nil
6364
}
6465

65-
func NewMessagingMiddleware(messaging p2p.Messaging, dbpool *pgxpool.Pool, config *Config) *MessagingMiddleware {
66-
return &MessagingMiddleware{messaging: messaging, dbpool: dbpool, config: config}
66+
func NewMessagingMiddleware(messaging p2p.Messaging, dbpool *pgxpool.Pool, cfg *config.Config) *MessagingMiddleware {
67+
return &MessagingMiddleware{messaging: messaging, dbpool: dbpool, config: cfg}
6768
}
6869

6970
func (i *MessagingMiddleware) Start(_ context.Context, runner service.Runner) error {

0 commit comments

Comments
 (0)