eosswedenorg/thalos
1
0
Fork 0
mirror of https://github.com/eosswedenorg/thalos synced 2026-07-04 12:03:41 +02:00
Code Releases Activity

config/config.go: use shipclient.NULL_BLOCK_NUMBER instead of defining our own.

Browse source
This commit is contained in:
Henrik Hautakoski 2023-03-08 15:56:45 +01:00
parent bd5037b044
commit acdf827223
3 changed files with 9 additions and 7 deletions
Download patch file Download diff file Expand all files Collapse all files

8
config/config.go
View file

@ -3,9 +3,9 @@ package config
import ( import (
"encoding/json" "encoding/json"
"io/ioutil" "io/ioutil"
)
const NULL_BLOCK_NUMBER uint32 = 0xffffffff shipclient "github.com/eosswedenorg-go/antelope-ship-client"
)
type RedisConfig struct { type RedisConfig struct {
Addr string `json:"addr"` Addr string `json:"addr"`
@ -37,8 +37,8 @@ type Config struct {
func Parse(data []byte) (*Config, error) { func Parse(data []byte) (*Config, error) {
cfg := Config{ cfg := Config{
StartBlockNum: NULL_BLOCK_NUMBER, StartBlockNum: shipclient.NULL_BLOCK_NUMBER,
EndBlockNum: NULL_BLOCK_NUMBER, EndBlockNum: shipclient.NULL_BLOCK_NUMBER,
MaxMessagesInFlight: 10, MaxMessagesInFlight: 10,
IrreversibleOnly: false, IrreversibleOnly: false,
Redis: RedisConfig{ Redis: RedisConfig{

6
config/config_test.go
View file

@ -4,12 +4,14 @@ import (
"testing" "testing"
"github.com/stretchr/testify/require" "github.com/stretchr/testify/require"
shipclient "github.com/eosswedenorg-go/antelope-ship-client"
) )
func TestParse_Default(t *testing.T) { func TestParse_Default(t *testing.T) {
expected := Config{ expected := Config{
StartBlockNum: NULL_BLOCK_NUMBER, StartBlockNum: shipclient.NULL_BLOCK_NUMBER,
EndBlockNum: NULL_BLOCK_NUMBER, EndBlockNum: shipclient.NULL_BLOCK_NUMBER,
MaxMessagesInFlight: 10, MaxMessagesInFlight: 10,
IrreversibleOnly: false, IrreversibleOnly: false,
Redis: RedisConfig{ Redis: RedisConfig{

2
main.go
View file

@ -205,7 +205,7 @@ func main() {
return return
} }
if conf.StartBlockNum == config.NULL_BLOCK_NUMBER { if conf.StartBlockNum == shipclient.NULL_BLOCK_NUMBER {
if conf.IrreversibleOnly { if conf.IrreversibleOnly {
conf.StartBlockNum = uint32(chainInfo.LastIrreversibleBlockNum) conf.StartBlockNum = uint32(chainInfo.LastIrreversibleBlockNum)
} else { } else {