Implementing handle_open_init function

Author: majecty

core/src/ibc/connection_03/manager.rs

@@ -0,0 +1,57 @@
+// Copyright 2020 Kodebox, Inc.
+// This file is part of CodeChain.
+//
+// This program is free software: you can redistribute it and/or modify
+// it under the terms of the GNU Affero General Public License as
+// published by the Free Software Foundation, either version 3 of the
+// License, or (at your option) any later version.
+//
+// This program is distributed in the hope that it will be useful,
+// but WITHOUT ANY WARRANTY; without even the implied warranty of
+// MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
+// GNU Affero General Public License for more details.
+//
+// You should have received a copy of the GNU Affero General Public License
+// along with this program.  If not, see <https://www.gnu.org/licenses/>.
+
+use super::types::{CommitmentPrefix, Identifier};
+use super::{client_connections_path, path as connection_path};
+use crate::ibc;
+use crate::ibc::client_02::ConsensusState;
+use crate::ibc::connection_03::types::{ConnectionEnd, ConnectionState};
+use ibc::commitment_23::Prefix;
+use rlp::Encodable;
+
+#[derive(Default)]
+pub struct Manager {}
+
+impl Manager {
+    pub fn new() -> Self {
+        Manager {}
+    }
+
+    pub fn handle_open_init(
+        ctx: &mut dyn ibc::Context,
+        identifier: Identifier,
+        desired_counterparty_connection_identifier: Identifier,
+        counterparty_prefix: CommitmentPrefix,
+        client_identifier: Identifier,
+        counterparty_client_identifier: Identifier,
+    ) -> Result<(), String> {
+        let kv_store = ctx.get_kv_store();
+        if kv_store.has(&connection_path(&identifier)) {
+            return Err("Connection exist".to_owned())
+        }
+        let state = ConnectionState::INIT;
+        let connection = ConnectionEnd {
+            state,
+            counterparty_connection_identifier: desired_counterparty_connection_identifier,
+            counterparty_prefix,
+            client_identifier,
+            counterparty_client_identifier,
+        };
+        kv_store.set(&connection_path(&identifier), &connection.rlp_bytes());
+        // add connection to client
+        Ok(())
+    }
+}

core/src/ibc/connection_03/mod.rs

@@ -0,0 +1,26 @@
+// Copyright 2020 Kodebox, Inc.
+// This file is part of CodeChain.
+//
+// This program is free software: you can redistribute it and/or modify
+// it under the terms of the GNU Affero General Public License as
+// published by the Free Software Foundation, either version 3 of the
+// License, or (at your option) any later version.
+//
+// This program is distributed in the hope that it will be useful,
+// but WITHOUT ANY WARRANTY; without even the implied warranty of
+// MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
+// GNU Affero General Public License for more details.
+//
+// You should have received a copy of the GNU Affero General Public License
+// along with this program.  If not, see <https://www.gnu.org/licenses/>.
+
+mod manager;
+mod types;
+
+pub fn path(id: &str) -> String {
+    format!("connections/{}", id)
+}
+
+pub fn client_connections_path(client_id: &str) -> String {
+    format!("clients/{}/connections", client_id)
+}

core/src/ibc/connection_03/types.rs

@@ -0,0 +1,47 @@
+// Copyright 2020 Kodebox, Inc.
+// This file is part of CodeChain.
+//
+// This program is free software: you can redistribute it and/or modify
+// it under the terms of the GNU Affero General Public License as
+// published by the Free Software Foundation, either version 3 of the
+// License, or (at your option) any later version.
+//
+// This program is distributed in the hope that it will be useful,
+// but WITHOUT ANY WARRANTY; without even the implied warranty of
+// MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
+// GNU Affero General Public License for more details.
+//
+// You should have received a copy of the GNU Affero General Public License
+// along with this program.  If not, see <https://www.gnu.org/licenses/>.
+
+use rlp;
+
+pub enum ConnectionState {
+    INIT,
+    TRYOPEN,
+    OPEN,
+}
+
+// FIXME: current commitment_23::Prefix is too generic.
+pub type CommitmentPrefix = String;
+pub type Identifier = String;
+
+pub struct ConnectionEnd {
+    state: ConnectionState,
+    counterparty_connection_identifier: Identifier,
+    counterparty_prefix: CommitmentPrefix,
+    client_identifier: Identifier,
+    counterparty_client_identifier: Identifier,
+    // FIXME: implement version
+}
+
+impl rlp::Encodable for ConnectionEnd {
+    fn rlp_append(&self, s: &mut rlp::RlpStream) {
+        s.begin_list(5);
+        s.append(&self.state);
+        s.append(&self.counterparty_connection_identifier);
+        s.append(&self.counterparty_prefix);
+        s.append(&self.client_identifier);
+        s.append(&self.counterparty_client_identifier);
+    }
+}

core/src/ibc/mod.rs

@@ -18,6 +18,7 @@ pub mod client_02;
 #[allow(dead_code)]
 #[allow(unused_variables)]
 mod commitment_23;
+mod connection_03;
 pub mod context;
 mod kv_store;
 mod transaction_handler;