diff --git a/blockfetch.go b/blockfetch.go index 4e5f47ea..d6c51089 100644 --- a/blockfetch.go +++ b/blockfetch.go @@ -38,8 +38,6 @@ func (n *Node) blockfetchClientConnOpts() []blockfetch.BlockFetchOptionFunc { blockfetch.WithBatchDoneFunc(n.blockfetchClientBatchDone), blockfetch.WithBatchStartTimeout(2 * time.Second), blockfetch.WithBlockTimeout(2 * time.Second), - // Set the recv queue size to 2x our block batch size - blockfetch.WithRecvQueueSize(1000), } } diff --git a/database/plugin/blob/aws/database.go b/database/plugin/blob/aws/database.go index 3eb6b3f3..f22e3288 100644 --- a/database/plugin/blob/aws/database.go +++ b/database/plugin/blob/aws/database.go @@ -66,7 +66,9 @@ func New( const prefix = "s3://" if !strings.HasPrefix(strings.ToLower(dataDir), prefix) { cancel() - return nil, errors.New("s3 blob: expected dataDir='s3://[/prefix]'") + return nil, errors.New( + "s3 blob: expected dataDir='s3://[/prefix]'", + ) } path := strings.TrimPrefix(strings.ToLower(dataDir), prefix) diff --git a/database/plugin/metadata/sqlite/account.go b/database/plugin/metadata/sqlite/account.go index b7c3ce66..bbb28224 100644 --- a/database/plugin/metadata/sqlite/account.go +++ b/database/plugin/metadata/sqlite/account.go @@ -268,11 +268,11 @@ func (d *MetadataStoreSqlite) SetStakeRegistrationDelegation( pkh := cert.PoolKeyHash tmpItem := models.StakeRegistrationDelegation{ StakingKey: stakeKey, - PoolKeyHash: pkh, + PoolKeyHash: pkh[:], AddedSlot: slot, DepositAmount: deposit, } - if err := d.SetAccount(stakeKey, pkh, nil, slot, true, txn); err != nil { + if err := d.SetAccount(stakeKey, pkh[:], nil, slot, true, txn); err != nil { return err } if txn != nil { diff --git a/database/plugin/metadata/sqlite/certs.go b/database/plugin/metadata/sqlite/certs.go index 8b71de4b..9582c3f8 100644 --- a/database/plugin/metadata/sqlite/certs.go +++ b/database/plugin/metadata/sqlite/certs.go @@ -45,7 +45,7 @@ func (d *MetadataStoreSqlite) GetStakeRegistrations( var tmpCert lcommon.StakeRegistrationCertificate for _, cert := range certs { tmpCert = lcommon.StakeRegistrationCertificate{ - CertType: lcommon.CertificateTypeStakeRegistration, + CertType: uint(lcommon.CertificateTypeStakeRegistration), StakeCredential: lcommon.Credential{ // TODO: determine correct type // CredType: lcommon.CredentialTypeAddrKeyHash, diff --git a/database/plugin/metadata/sqlite/pool.go b/database/plugin/metadata/sqlite/pool.go index b2ac10cb..c427b53c 100644 --- a/database/plugin/metadata/sqlite/pool.go +++ b/database/plugin/metadata/sqlite/pool.go @@ -81,7 +81,7 @@ func (d *MetadataStoreSqlite) GetPoolRegistrations( for _, cert := range certs { tmpMargin = lcommon.GenesisRat{Rat: cert.Margin.Rat} tmpCert = lcommon.PoolRegistrationCertificate{ - CertType: lcommon.CertificateTypePoolRegistration, + CertType: uint(lcommon.CertificateTypePoolRegistration), Operator: lcommon.PoolKeyHash( lcommon.NewBlake2b224(cert.PoolKeyHash), ), diff --git a/go.mod b/go.mod index d34b6126..329dd524 100644 --- a/go.mod +++ b/go.mod @@ -11,7 +11,7 @@ require ( connectrpc.com/grpcreflect v1.3.0 github.com/aws/aws-sdk-go-v2/config v1.31.11 github.com/aws/aws-sdk-go-v2/service/s3 v1.88.3 - github.com/blinklabs-io/gouroboros v0.139.0 + github.com/blinklabs-io/gouroboros v0.140.0 github.com/blinklabs-io/ouroboros-mock v0.3.9 github.com/blinklabs-io/plutigo v0.0.13 github.com/btcsuite/btcd/btcutil v1.1.6 diff --git a/go.sum b/go.sum index f57bdd81..612f5629 100644 --- a/go.sum +++ b/go.sum @@ -122,8 +122,8 @@ github.com/bits-and-blooms/bitset v1.20.0 h1:2F+rfL86jE2d/bmw7OhqUg2Sj/1rURkBn3M github.com/bits-and-blooms/bitset v1.20.0/go.mod h1:7hO7Gc7Pp1vODcmWvKMRA9BNmbv6a/7QIWpPxHddWR8= github.com/blang/semver v3.5.1+incompatible h1:cQNTCjp13qL8KC3Nbxr/y2Bqb63oX6wdnnjpJbkM4JQ= github.com/blang/semver v3.5.1+incompatible/go.mod h1:kRBLl5iJ+tD4TcOOxsy/0fnwebNt5EWlYSAyrTnjyyk= -github.com/blinklabs-io/gouroboros v0.139.0 h1:ctoHFEuXhJlMcUC1fe5x6IX1tqZnS/BAaBDeHiXskeU= -github.com/blinklabs-io/gouroboros v0.139.0/go.mod h1:FxKQNNNRQN5F/Cl4pnW7SHhpPo7fD57mTPGo4N9ulnY= +github.com/blinklabs-io/gouroboros v0.140.0 h1:dFK2iunkTflCI2hlDSGZJJ7JerYhpdE41HnBUVvjj9E= +github.com/blinklabs-io/gouroboros v0.140.0/go.mod h1:FxKQNNNRQN5F/Cl4pnW7SHhpPo7fD57mTPGo4N9ulnY= github.com/blinklabs-io/ouroboros-mock v0.3.9 h1:UnciDccJ5tZCR1xI0BcxGZcYjJ/PS5MpnjiiGtrZ680= github.com/blinklabs-io/ouroboros-mock v0.3.9/go.mod h1:uTkE8/LAYL7yQSntH48Pudf5Xn+jaBWMj+9udbzYXhI= github.com/blinklabs-io/plutigo v0.0.13 h1:JztPigFmknQmQ3Ti1+mdTY96ihOUDh6wJ3pPnN2YYBU= diff --git a/ledger/view.go b/ledger/view.go index d75fcc4d..2264f1a1 100644 --- a/ledger/view.go +++ b/ledger/view.go @@ -101,7 +101,7 @@ func (lv *LedgerView) PoolCurrentState( } reg := pool.Registration[latestIdx] tmp := lcommon.PoolRegistrationCertificate{ - CertType: lcommon.CertificateTypePoolRegistration, + CertType: uint(lcommon.CertificateTypePoolRegistration), Operator: lcommon.PoolKeyHash( lcommon.NewBlake2b224(pool.PoolKeyHash), ),