-
Notifications
You must be signed in to change notification settings - Fork 70
Commit
This commit does not belong to any branch on this repository, and may belong to a fork outside of the repository.
feat: Add ability to run the relayer (#78)
- Loading branch information
1 parent
8619333
commit cada290
Showing
15 changed files
with
273 additions
and
72 deletions.
There are no files selected for viewing
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| Original file line number | Diff line number | Diff line change |
|---|---|---|
| @@ -0,0 +1,71 @@ | ||
| package start | ||
|
|
||
| import ( | ||
| "fmt" | ||
| "github.com/dymensionxyz/roller/cmd/consts" | ||
| "github.com/dymensionxyz/roller/cmd/utils" | ||
| "os/exec" | ||
| "path/filepath" | ||
| ) | ||
|
|
||
| // Creates an IBC channel between the hub and the client, and return the source channel ID. | ||
| func createIBCChannelIfNeeded(rollappConfig utils.RollappConfig) (string, error) { | ||
| createClientsCmd := getCreateClientsCmd(rollappConfig, rollappConfig.RollappID, rollappConfig.HubData.ID) | ||
| fmt.Println("Creating clients...") | ||
| if err := utils.ExecBashCmdWithOSOutput(createClientsCmd); err != nil { | ||
| return "", err | ||
| } | ||
| dstConnectionId, err := GetDstConnectionIDFromYAMLFile(filepath.Join(rollappConfig.Home, consts.ConfigDirName.Relayer, | ||
| "config", "config.yaml")) | ||
| if err != nil { | ||
| return "", err | ||
| } | ||
| if dstConnectionId == "" { | ||
| createConnectionCmd := getCreateConnectionCmd(rollappConfig) | ||
| fmt.Println("Creating connection...") | ||
| if err := utils.ExecBashCmdWithOSOutput(createConnectionCmd); err != nil { | ||
| return "", err | ||
| } | ||
| } | ||
| srcChannelId, err := GetSourceChannelForConnection(dstConnectionId, rollappConfig) | ||
| if err != nil { | ||
| return "", err | ||
| } | ||
| if srcChannelId == "" { | ||
| createChannelCmd := getCreateChannelCmd(rollappConfig) | ||
| fmt.Println("Creating channel...") | ||
| if err := utils.ExecBashCmdWithOSOutput(createChannelCmd); err != nil { | ||
| return "", err | ||
| } | ||
| srcChannelId, err = GetSourceChannelForConnection(dstConnectionId, rollappConfig) | ||
| if err != nil { | ||
| return "", err | ||
| } | ||
| } | ||
| return srcChannelId, nil | ||
| } | ||
|
|
||
| func getCreateChannelCmd(config utils.RollappConfig) *exec.Cmd { | ||
| defaultRlyArgs := getRelayerDefaultArgs(config) | ||
| args := []string{"tx", "channel", "--override"} | ||
| args = append(args, defaultRlyArgs...) | ||
| return exec.Command(consts.Executables.Relayer, args...) | ||
| } | ||
|
|
||
| func getCreateClientsCmd(rollappConfig utils.RollappConfig, srcId string, dstId string) *exec.Cmd { | ||
| defaultRlyArgs := getRelayerDefaultArgs(rollappConfig) | ||
| args := []string{"tx", "clients"} | ||
| args = append(args, defaultRlyArgs...) | ||
| return exec.Command(consts.Executables.Relayer, args...) | ||
| } | ||
|
|
||
| func getRelayerDefaultArgs(config utils.RollappConfig) []string { | ||
| return []string{consts.DefaultRelayerPath, "--home", filepath.Join(config.Home, consts.ConfigDirName.Relayer)} | ||
| } | ||
|
|
||
| func getCreateConnectionCmd(config utils.RollappConfig) *exec.Cmd { | ||
| defaultRlyArgs := getRelayerDefaultArgs(config) | ||
| args := []string{"tx", "connection"} | ||
| args = append(args, defaultRlyArgs...) | ||
| return exec.Command(consts.Executables.Relayer, args...) | ||
| } |
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| Original file line number | Diff line number | Diff line change |
|---|---|---|
| @@ -0,0 +1,51 @@ | ||
| package start | ||
|
|
||
| import ( | ||
| "encoding/json" | ||
| "github.com/dymensionxyz/roller/cmd/consts" | ||
| "github.com/dymensionxyz/roller/cmd/utils" | ||
| "os/exec" | ||
| ) | ||
|
|
||
| // GetSourceChannelForConnection Returns the open source channel for the given destination connection ID. If no open channel exists, it returns an | ||
| // empty string. | ||
| func GetSourceChannelForConnection(dstConnectionID string, rollappConfig utils.RollappConfig) (string, error) { | ||
| commonDymdFlags := utils.GetCommonDymdFlags(rollappConfig) | ||
| args := []string{"query", "ibc", "channel", "connections", dstConnectionID} | ||
| args = append(args, commonDymdFlags...) | ||
| cmd := exec.Command(consts.Executables.Dymension, args...) | ||
| out, err := cmd.Output() | ||
| if err != nil { | ||
| return "", err | ||
| } | ||
| channelId, err := GetOpenStateChannelID(out) | ||
| if err != nil { | ||
| return "", err | ||
| } | ||
| return channelId, nil | ||
| } | ||
|
|
||
| type Channel struct { | ||
| State string `json:"state"` | ||
| Counterparty struct { | ||
| ChannelID string `json:"channel_id"` | ||
| } `json:"counterparty"` | ||
| } | ||
|
|
||
| type ChannelList struct { | ||
| Channels []Channel `json:"channels"` | ||
| } | ||
|
|
||
| func GetOpenStateChannelID(jsonData []byte) (string, error) { | ||
| var channels ChannelList | ||
| if err := json.Unmarshal(jsonData, &channels); err != nil { | ||
| return "", err | ||
| } | ||
|
|
||
| for _, channel := range channels.Channels { | ||
| if channel.State == "STATE_OPEN" { | ||
| return channel.Counterparty.ChannelID, nil | ||
| } | ||
| } | ||
| return "", nil | ||
| } |
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| Original file line number | Diff line number | Diff line change |
|---|---|---|
| @@ -0,0 +1,37 @@ | ||
| package start | ||
|
|
||
| import ( | ||
| "fmt" | ||
| "gopkg.in/yaml.v2" | ||
| "io/ioutil" | ||
| ) | ||
|
|
||
| type RelayerConfigFile struct { | ||
| Paths map[string]Path `yaml:"paths"` | ||
| } | ||
|
|
||
| type Path struct { | ||
| Dst Destination `yaml:"dst"` | ||
| } | ||
|
|
||
| type Destination struct { | ||
| ConnectionID string `yaml:"connection-id"` | ||
| } | ||
|
|
||
| // GetDstConnectionIDFromYAMLFile Returns the destination connection ID if it been created already, an empty string otherwise. | ||
| func GetDstConnectionIDFromYAMLFile(filename string) (string, error) { | ||
|
|
||
| data, err := ioutil.ReadFile(filename) | ||
| if err != nil { | ||
| return "", err | ||
| } | ||
| var config RelayerConfigFile | ||
| err = yaml.Unmarshal(data, &config) | ||
| if err != nil { | ||
| return "", err | ||
| } | ||
| for _, path := range config.Paths { | ||
| return path.Dst.ConnectionID, nil | ||
| } | ||
| return "", fmt.Errorf("No paths found in YAML data") | ||
| } |
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
Oops, something went wrong.