Build a channel

Author: Park Juhyung

ibc.ts/src/common/chain.ts

@@ -130,7 +130,8 @@ export class Chain {
     public async queryChannel(
         blockNumber?: number
     ): Promise<IBCQueryResult<ChannelEnd> | null> {
-        return this.sdk.rpc.sendRpcRequest("", [
+        return this.sdk.rpc.sendRpcRequest("ibc_query_channel_end", [
+            "DEFAULT_PORT",
             this.counterpartyIdentifiers.channel,
             blockNumber
         ]);

ibc.ts/src/common/datagram/index.ts

@@ -2,3 +2,6 @@ export interface Datagram {
     rlpBytes(): Buffer;
     toEncodeObject(): any[];
 }
+
+export const ChannelOrdered = 0;
+export const ChannelUnordered = 1;

ibc.ts/src/relayer/index.ts

@@ -1,6 +1,6 @@
 import Debug from "debug";
 import { Chain } from "../common/chain";
-import { Datagram } from "../common/datagram/index";
+import { Datagram, ChannelOrdered } from "../common/datagram/index";
 import { delay } from "../common/util";
 import { getConfig } from "../common/config";
 import { PlatformAddress } from "codechain-primitives/lib";
@@ -9,6 +9,9 @@ import { strict as assert } from "assert";
 import { ConnOpenTryDatagram } from "../common/datagram/connOpenTry";
 import { ConnOpenAckDatagram } from "../common/datagram/connOpenAck";
 import { ConnOpenConfirmDatagram } from "../common/datagram/connOpenConfirm";
+import { ChanOpenTryDatagram } from "../common/datagram/chanOpenTry";
+import { ChanOpenAckDatagram } from "../common/datagram/chanOpenAck";
+import { ChanOpenConfirmDatagram } from "../common/datagram/chanOpenConfirm";
 
 require("dotenv").config();
 
@@ -127,6 +130,21 @@ async function pendingDatagrams({
         counterpartyDatagramsForConnection
     );
 
+    const {
+        localDatagrams: localDatagramsForChannel,
+        counterpartyDatagrams: counterpartyDatagramsForChannel
+    } = await buildChannel({
+        chain,
+        counterpartyChain,
+        height,
+        counterpartyChainHeight
+    });
+
+    localDatagrams = localDatagrams.concat(localDatagramsForChannel);
+    counterpartyDatagrams = counterpartyDatagrams.concat(
+        counterpartyDatagramsForChannel
+    );
+
     return { localDatagrams, counterpartyDatagrams };
 }
 
@@ -256,3 +274,74 @@ async function buildConnection({
 
     return { localDatagrams, counterpartyDatagrams };
 }
+
+async function buildChannel({
+    chain,
+    counterpartyChain,
+    height,
+    counterpartyChainHeight
+}: {
+    chain: Chain;
+    counterpartyChain: Chain;
+    height: number;
+    counterpartyChainHeight: number;
+}) {
+    const localDatagrams: Datagram[] = [];
+    const counterpartyDatagrams = [];
+
+    const channel = await chain.queryChannel(height);
+    assert.notEqual(channel, null, "Block at height exists");
+
+    const counterpartyChannel = await counterpartyChain.queryChannel(
+        counterpartyChainHeight
+    );
+    assert.notEqual(counterpartyChannel, null, "Block at height exists");
+
+    if (channel!.data?.state === "INIT" && counterpartyChannel!.data == null) {
+        counterpartyDatagrams.push(
+            new ChanOpenTryDatagram({
+                order: ChannelOrdered,
+                connection:
+                    counterpartyChain.counterpartyIdentifiers.connection,
+                channelIdentifier:
+                    counterpartyChain.counterpartyIdentifiers.channel,
+                counterpartyChannelIdentifier:
+                    chain.counterpartyIdentifiers.channel,
+                version: "",
+                counterpartyVersion: "",
+                proofInit: Buffer.from(channel!.proof, "hex"),
+                proofHeight: height
+            })
+        );
+    }
+    if (
+        channel!.data?.state === "INIT" &&
+        counterpartyChannel!.data?.state === "TRYOPEN"
+    ) {
+        localDatagrams.push(
+            new ChanOpenAckDatagram({
+                channelIdentifier: chain.counterpartyIdentifiers.channel,
+                counterpartyVersion: "",
+                proofTry: Buffer.from(counterpartyChannel!.proof, "hex"),
+                proofHeight: counterpartyChainHeight
+            })
+        );
+    }
+    if (
+        channel!.data?.state === "OPEN" &&
+        counterpartyChannel!.data?.state === "TRYOPEN"
+    ) {
+        counterpartyDatagrams.push(
+            new ChanOpenConfirmDatagram({
+                channelIdentifier:
+                    counterpartyChain.counterpartyIdentifiers.channel,
+                proofAck: Buffer.from(channel!.proof, "hex"),
+                proofHeight: height
+            })
+        );
+    }
+    return {
+        localDatagrams,
+        counterpartyDatagrams
+    };
+}