feat: add contract

Author: ibrizsabin

Cargo.lock

@@ -1,10 +1,9 @@
 # @generated by Move, please check-in and do not edit manually.
 
 [move]
-version = 0
-manifest_digest = "FC695334648B2D90E72AE20AA924725F9BF44A6CFE2FD05A222822451A044FD2"
+version = 2
+manifest_digest = "AACE86AFC3B29B8DB151AF23459046CD2B9449DBFD44B0015FB4207404832674"
 deps_digest = "3C4103934B1E040BB6B23F1D610B4EF9F2F1166A50A104EADCF77467C004C600"
-
 dependencies = [
   { name = "Sui" },
   { name = "sui_rlp" },
@@ -31,14 +30,14 @@ dependencies = [
 ]
 
 [move.toolchain-version]
-compiler-version = "1.26.1"
-edition = "2024.alpha"
+compiler-version = "1.33.2"
+edition = "2024.beta"
 flavor = "sui"
 
 [env]
 
 [env.testnet]
 chain-id = "4c78adac"
-original-published-id = "0xba481bcd34c4c236b1ccda9d8cb549f03a80260d794285f2b2a6798170d8375d"
-latest-published-id = "0xba481bcd34c4c236b1ccda9d8cb549f03a80260d794285f2b2a6798170d8375d"
+original-published-id = "0x468fb4326302ec28df8812a41e400f3a6be4a94d9fcedf51e5935c9ac2a44226"
+latest-published-id = "0x468fb4326302ec28df8812a41e400f3a6be4a94d9fcedf51e5935c9ac2a44226"
 published-version = "1"

contracts/sui/xcall/Move.lock contracts/sui/intent_v1/Move.lock

@@ -0,0 +1,38 @@
+[package]
+name = "intents_v1"
+edition = "2024.beta" # edition = "legacy" to use legacy (pre-2024) Move
+# license = ""           # e.g., "MIT", "GPL", "Apache 2.0"
+# authors = ["..."]      # e.g., ["Joe Smith (joesmith@noemail.com)", "John Snow (johnsnow@noemail.com)"]
+
+[dependencies]
+Sui = { git = "https://github.com/MystenLabs/sui.git", subdir = "crates/sui-framework/packages/sui-framework", rev = "framework/testnet" }
+[dependencies.sui_rlp]
+local = '../libs/sui_rlp'
+# For remote import, use the `{ git = "...", subdir = "...", rev = "..." }`.
+# Revision can be a branch, a tag, and a commit hash.
+# MyRemotePackage = { git = "https://some.remote/host.git", subdir = "remote/path", rev = "main" }
+
+# For local dependencies use `local = path`. Path is relative to the package root
+# Local = { local = "../path/to" }
+
+# To resolve a version conflict and force a specific version for dependency
+# override use `override = true`
+# Override = { local = "../conflicting/version", override = true }
+
+[addresses]
+intents_v1 = "0x0"
+
+# Named addresses will be accessible in Move as `@name`. They're also exported:
+# for example, `std = "0x1"` is exported by the Standard Library.
+# alice = "0xA11CE"
+
+[dev-dependencies]
+# The dev-dependencies section allows overriding dependencies for `--test` and
+# `--dev` modes. You can introduce test-only dependencies here.
+# Local = { local = "../path/to/dev-build" }
+
+[dev-addresses]
+# The dev-addresses section allows overwriting named addresses for the `--test`
+# and `--dev` modes.
+# alice = "0xB0B"
+

contracts/sui/intent_v1/Move.lock:Zone.Identifier

@@ -0,0 +1,72 @@
+module intents_v1::cluster_connection {
+    use std::string::{String, Self};
+    use sui::table::{Table, Self};
+    use intents_v1::order_message::{OrderMessage, Self};
+    use sui::event::{ Self };
+
+    public struct Receipt has drop, copy, store {
+        src_nid: String,
+        conn_sn: u128,
+    }
+
+    public struct ConnectionState has store {
+        conn_sn: u128,
+        relayer: address, // Address of the relayer
+        receipts: Table<Receipt, bool>, // Mapping of receipts for tracking
+    }
+
+    public struct Message has copy, drop {
+        to: String,
+        conn_sn: u128,
+        msg: vector<u8>,
+    }
+
+    public(package) fun new(relayer: address, ctx: &mut TxContext): ConnectionState {
+        ConnectionState {
+            conn_sn: 0,
+            relayer: relayer,
+            receipts: table::new(ctx),
+        }
+    }
+
+    public fun get_relayer(self: &ConnectionState): address {
+        self.relayer
+    }
+
+    public(package) fun receive_message(
+        self: &mut ConnectionState,
+        srcNid: String,
+        conn_sn: u128,
+        msg: vector<u8>,
+        ctx: &TxContext
+    ): OrderMessage {
+      //  assert!(self.relayer == ctx.sender());
+        let key = Receipt {src_nid: srcNid, conn_sn};
+        assert!(!self.receipts.contains(key));
+        self.receipts.add(key, true);
+        order_message::decode(&msg)
+    }
+
+    public(package) fun send_message(
+        self: &mut ConnectionState,
+        toNid: String,
+        msg: vector<u8>
+    ) {
+        let conn_sn = get_next_conn_sn(self);
+        event::emit(Message {to: toNid, conn_sn, msg,})
+
+    }
+
+    public(package) fun set_relayer(
+        self: &mut ConnectionState,
+        relayer: address
+    ) {
+        self.relayer = relayer;
+    }
+
+    fun get_next_conn_sn(self: &mut ConnectionState): u128 {
+        let sn = self.conn_sn + 1;
+        self.conn_sn = sn;
+        sn
+    }
+}