Compare commits
No commits in common. "master" and "master" have entirely different histories.
1 changed files with 2 additions and 18 deletions
|
@ -7,6 +7,7 @@ import (
|
||||||
"fmt"
|
"fmt"
|
||||||
"os"
|
"os"
|
||||||
"path"
|
"path"
|
||||||
|
"strconv"
|
||||||
|
|
||||||
"git.frostfs.info/TrueCloudLab/monza/internal/bytecode"
|
"git.frostfs.info/TrueCloudLab/monza/internal/bytecode"
|
||||||
"github.com/nspcc-dev/neo-go/pkg/core/block"
|
"github.com/nspcc-dev/neo-go/pkg/core/block"
|
||||||
|
@ -46,12 +47,7 @@ func Open(ctx context.Context, dir, endpoint string, rewrite bool) (*Chain, erro
|
||||||
return nil, fmt.Errorf("rpc get version: %w", err)
|
return nil, fmt.Errorf("rpc get version: %w", err)
|
||||||
}
|
}
|
||||||
|
|
||||||
validationBlock, err := getValidationBlock(cli)
|
dbPath := path.Join(dir, strconv.Itoa(int(v.Protocol.Network))+".db")
|
||||||
if err != nil {
|
|
||||||
return nil, fmt.Errorf("error get validation block: %w", err)
|
|
||||||
}
|
|
||||||
|
|
||||||
dbPath := path.Join(dir, validationBlock.Hash().StringLE()+".db")
|
|
||||||
if rewrite {
|
if rewrite {
|
||||||
_ = os.Remove(dbPath) // ignore error if file does not exist, etc.
|
_ = os.Remove(dbPath) // ignore error if file does not exist, etc.
|
||||||
}
|
}
|
||||||
|
@ -64,18 +60,6 @@ func Open(ctx context.Context, dir, endpoint string, rewrite bool) (*Chain, erro
|
||||||
return &Chain{db, v.Protocol.StateRootInHeader, cli}, nil
|
return &Chain{db, v.Protocol.StateRootInHeader, cli}, nil
|
||||||
}
|
}
|
||||||
|
|
||||||
func getValidationBlock(cli *rpcclient.Client) (*block.Block, error) {
|
|
||||||
// not 0, because it always has the same hash
|
|
||||||
const validationBlockIndex = 1
|
|
||||||
var err error
|
|
||||||
validBlock, err := cli.GetBlockByIndex(validationBlockIndex)
|
|
||||||
if err != nil {
|
|
||||||
return nil, fmt.Errorf("error sending request for block: %w", err)
|
|
||||||
}
|
|
||||||
|
|
||||||
return validBlock, nil
|
|
||||||
}
|
|
||||||
|
|
||||||
func (d *Chain) Block(i uint32) (res *block.Block, err error) {
|
func (d *Chain) Block(i uint32) (res *block.Block, err error) {
|
||||||
cached, err := d.block(i)
|
cached, err := d.block(i)
|
||||||
if err != nil {
|
if err != nil {
|
||||||
|
|
Loading…
Reference in a new issue