Evgenii Stratonikov
a739c57a06
Some checks failed
Tests and linters / Lint (pull_request) Failing after 3s
Tests and linters / Tests (1.20) (pull_request) Failing after 3s
Tests and linters / Tests (1.21) (pull_request) Failing after 3s
Tests and linters / Tests with -race (pull_request) Failing after 3s
Tests and linters / Staticcheck (pull_request) Failing after 3s
Vulncheck / Vulncheck (pull_request) Failing after 3s
Build / Build Components (1.20) (pull_request) Successful in 1m42s
Build / Build Components (1.21) (pull_request) Successful in 1m46s
Epoch can be ticked by IR in the background. Because the only usecase for this is to apply some changes, the right behaviour is ignoring an error, not retrying. Signed-off-by: Evgenii Stratonikov <e.stratonikov@yadro.com>
65 lines
1.7 KiB
Go
65 lines
1.7 KiB
Go
package morph
|
|
|
|
import (
|
|
"errors"
|
|
"fmt"
|
|
"strings"
|
|
|
|
"github.com/nspcc-dev/neo-go/pkg/io"
|
|
"github.com/nspcc-dev/neo-go/pkg/rpcclient/unwrap"
|
|
"github.com/nspcc-dev/neo-go/pkg/smartcontract/callflag"
|
|
"github.com/nspcc-dev/neo-go/pkg/util"
|
|
"github.com/nspcc-dev/neo-go/pkg/vm/emit"
|
|
"github.com/spf13/cobra"
|
|
"github.com/spf13/viper"
|
|
)
|
|
|
|
func forceNewEpochCmd(cmd *cobra.Command, _ []string) error {
|
|
wCtx, err := newInitializeContext(cmd, viper.GetViper())
|
|
if err != nil {
|
|
return fmt.Errorf("can't to initialize context: %w", err)
|
|
}
|
|
|
|
cs, err := wCtx.Client.GetContractStateByID(1)
|
|
if err != nil {
|
|
return fmt.Errorf("can't get NNS contract info: %w", err)
|
|
}
|
|
|
|
nmHash, err := nnsResolveHash(wCtx.ReadOnlyInvoker, cs.Hash, netmapContract+".frostfs")
|
|
if err != nil {
|
|
return fmt.Errorf("can't get netmap contract hash: %w", err)
|
|
}
|
|
|
|
bw := io.NewBufBinWriter()
|
|
if err := emitNewEpochCall(bw, wCtx, nmHash); err != nil {
|
|
return err
|
|
}
|
|
|
|
if err := wCtx.sendConsensusTx(bw.Bytes()); err != nil {
|
|
return err
|
|
}
|
|
|
|
if err := wCtx.awaitTx(); err != nil {
|
|
if strings.Contains(err.Error(), "invalid epoch") {
|
|
cmd.Println("Epoch has already ticked.")
|
|
return nil
|
|
}
|
|
return err
|
|
}
|
|
return nil
|
|
}
|
|
|
|
func emitNewEpochCall(bw *io.BufBinWriter, wCtx *initializeContext, nmHash util.Uint160) error {
|
|
curr, err := unwrap.Int64(wCtx.ReadOnlyInvoker.Call(nmHash, "epoch"))
|
|
if err != nil {
|
|
return errors.New("can't fetch current epoch from the netmap contract")
|
|
}
|
|
|
|
newEpoch := curr + 1
|
|
wCtx.Command.Printf("Current epoch: %d, increase to %d.\n", curr, newEpoch)
|
|
|
|
// In NeoFS this is done via Notary contract. Here, however, we can form the
|
|
// transaction locally.
|
|
emit.AppCall(bw.BinWriter, nmHash, "newEpoch", callflag.All, newEpoch)
|
|
return bw.Err
|
|
}
|