-
Notifications
You must be signed in to change notification settings - Fork 0
/
init.go
79 lines (65 loc) · 1.9 KB
/
init.go
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
package initialization
import (
"errors"
"fmt"
"path/filepath"
"time"
"github.com/merlins-labs/merlins/v17/tests/e2e/util"
)
func InitChain(id, dataDir string, nodeConfigs []*NodeConfig, votingPeriod, expeditedVotingPeriod time.Duration, forkHeight int) (*Chain, error) {
chain, err := new(id, dataDir)
if err != nil {
return nil, err
}
for _, nodeConfig := range nodeConfigs {
newNode, err := newNode(chain, nodeConfig)
if err != nil {
return nil, err
}
chain.nodes = append(chain.nodes, newNode)
}
if err := initGenesis(chain, votingPeriod, expeditedVotingPeriod, forkHeight); err != nil {
return nil, err
}
var peers []string
for _, peer := range chain.nodes {
peerID := fmt.Sprintf("%s@%s:26656", peer.getNodeKey().ID(), peer.moniker)
peer.peerId = peerID
peers = append(peers, peerID)
}
for _, node := range chain.nodes {
if node.isValidator {
if err := node.initNodeConfigs(peers); err != nil {
return nil, err
}
}
}
return chain.export(), nil
}
func InitSingleNode(chainId, dataDir string, existingGenesisDir string, nodeConfig *NodeConfig, votingPeriod time.Duration, trustHeight int64, trustHash string, stateSyncRPCServers []string, persistentPeers []string) (*Node, error) {
if nodeConfig.IsValidator {
return nil, errors.New("creating individual validator nodes after starting up chain is not currently supported")
}
chain, err := new(chainId, dataDir)
if err != nil {
return nil, err
}
newNode, err := newNode(chain, nodeConfig)
if err != nil {
return nil, err
}
_, err = util.CopyFile(
existingGenesisDir,
filepath.Join(newNode.configDir(), "config", "genesis.json"),
)
if err != nil {
return nil, err
}
if err := newNode.initNodeConfigs(persistentPeers); err != nil {
return nil, err
}
if err := newNode.initStateSyncConfig(trustHeight, trustHash, stateSyncRPCServers); err != nil {
return nil, err
}
return newNode.export(), nil
}