mirror of
https://gitlab.com/pulsechaincom/prysm-pulse.git
synced 2025-01-08 10:41:19 +00:00
689800d065
Sharding: * Sharding: add actor flag to sharding group for app help * Sharding: ensure rpcClient is not nil before calling Close() * Sharding: revert shardingcmd.go comments * Sharding: more address Str() fixes Former-commit-id: 0b3d8b73ac1b20eb5c018a71be1d935a1fb860ef [formerly 6cd1df472713e95f6b9f8a0a7b6bbd88a5dd2ca2] Former-commit-id: 90c7e1a70d46c1f889576a7f2f253a02414c3654
61 lines
1.9 KiB
Go
61 lines
1.9 KiB
Go
package node
|
|
|
|
import (
|
|
"context"
|
|
"fmt"
|
|
"math/big"
|
|
"time"
|
|
|
|
"github.com/ethereum/go-ethereum/log"
|
|
"github.com/ethereum/go-ethereum/node"
|
|
"github.com/ethereum/go-ethereum/rpc"
|
|
"github.com/ethereum/go-ethereum/sharding"
|
|
"github.com/ethereum/go-ethereum/sharding/contracts"
|
|
)
|
|
|
|
// dialRPC endpoint to node.
|
|
func dialRPC(endpoint string) (*rpc.Client, error) {
|
|
if endpoint == "" {
|
|
endpoint = node.DefaultIPCEndpoint(clientIdentifier)
|
|
}
|
|
return rpc.Dial(endpoint)
|
|
}
|
|
|
|
// initSMC initializes the sharding manager contract bindings.
|
|
// If the SMC does not exist, it will be deployed.
|
|
func initSMC(n *shardingNode) (*contracts.SMC, error) {
|
|
b, err := n.client.CodeAt(context.Background(), sharding.ShardingManagerAddress, nil)
|
|
if err != nil {
|
|
return nil, fmt.Errorf("unable to get contract code at %s: %v", sharding.ShardingManagerAddress.Str(), err)
|
|
}
|
|
|
|
// Deploy SMC for development only.
|
|
// TODO: Separate contract deployment from the sharding node. It would only need to be deployed
|
|
// once on the mainnet, so this code would not need to ship with the node.
|
|
if len(b) == 0 {
|
|
log.Info(fmt.Sprintf("No sharding manager contract found at %s. Deploying new contract.", sharding.ShardingManagerAddress.Str()))
|
|
|
|
txOps, err := n.CreateTXOpts(big.NewInt(0))
|
|
if err != nil {
|
|
return nil, fmt.Errorf("unable to initiate the transaction: %v", err)
|
|
}
|
|
|
|
addr, tx, contract, err := contracts.DeploySMC(txOps, n.client)
|
|
if err != nil {
|
|
return nil, fmt.Errorf("unable to deploy sharding manager contract: %v", err)
|
|
}
|
|
|
|
for pending := true; pending; _, pending, err = n.client.TransactionByHash(context.Background(), tx.Hash()) {
|
|
if err != nil {
|
|
return nil, fmt.Errorf("unable to get transaction by hash: %v", err)
|
|
}
|
|
time.Sleep(1 * time.Second)
|
|
}
|
|
|
|
log.Info(fmt.Sprintf("New contract deployed at %s", addr.Str()))
|
|
return contract, nil
|
|
}
|
|
|
|
return contracts.NewSMC(sharding.ShardingManagerAddress, n.client)
|
|
}
|