Initial implementation of payback loan

tee-worker/omni-executor/executor-storage/src/loan_record.rs

@@ -21,6 +21,9 @@ pub struct LoanRecord {
 	pub usdc_loaned: String,
 	pub spot_sell_cloid: String,
 	pub hedge_open_cloid: String,
+	/// Actual position size that was opened for this loan (filled or partially filled)
+	/// This should be set after the hedge order completes in request_loan
+	pub position_size: String,
 }
 
 pub struct LoanRecordStorage {

tee-worker/omni-executor/heima/authentication/src/auth_token.rs

@@ -112,7 +112,6 @@ mod tests {
 	use super::*;
 	use chrono::{Days, Utc};
 	use executor_primitives::{utils::hex::hex_encode, Identity, Web2IdentityType};
-	use parity_scale_codec::Encode;
 	use rsa::{pkcs1::EncodeRsaPrivateKey, RsaPrivateKey};
 
 	#[derive(PartialEq, Debug, Serialize, Deserialize)]

tee-worker/omni-executor/hyperliquid/src/corewriter.rs

@@ -120,3 +120,57 @@ pub fn encode_usd_class_transfer_action(ntl: u64, to_perp: bool) -> Vec<u8> {
 pub fn build_usd_class_transfer_to_perp(ntl: u64) -> Vec<u8> {
 	encode_usd_class_transfer_action(ntl, true)
 }
+
+pub fn build_usd_class_transfer_to_spot(ntl: u64) -> Vec<u8> {
+	encode_usd_class_transfer_action(ntl, false)
+}
+
+pub fn build_perp_close_order(asset_id: u32, size: u64, price: u64, cloid: u128) -> Vec<u8> {
+	// Close position by selling (is_buy = false) with reduce_only = true
+	// Note: For long positions, we need to sell to close
+	// The size should match the position size we want to close
+	encode_limit_order_action_with_reduce_only(asset_id, false, price, size, cloid, true)
+}
+
+pub fn build_spot_buy_order(asset_id: u32, size: u64, price: u64, cloid: u128) -> Vec<u8> {
+	let is_buy = true;
+	encode_limit_order_action(asset_id, is_buy, price, size, cloid)
+}
+
+pub fn build_cancel_order_by_cloid(asset_id: u32, cloid: u128) -> Vec<u8> {
+	let encoded =
+		ethabi::encode(&[ethabi::Token::Uint(asset_id.into()), ethabi::Token::Uint(cloid.into())]);
+
+	let mut data = Vec::new();
+	data.push(0x01); // version
+	data.extend_from_slice(&[0x00, 0x00, 0x0b]); // action_id = 11 (cancel order by cloid)
+	data.extend_from_slice(&encoded);
+	data
+}
+
+fn encode_limit_order_action_with_reduce_only(
+	asset: u32,
+	is_buy: bool,
+	limit_px: u64,
+	sz: u64,
+	cloid: u128,
+	reduce_only: bool,
+) -> Vec<u8> {
+	let encoded_tif: u8 = 2; // Gtc
+
+	let encoded = ethabi::encode(&[
+		ethabi::Token::Uint(asset.into()),
+		ethabi::Token::Bool(is_buy),
+		ethabi::Token::Uint(limit_px.into()),
+		ethabi::Token::Uint(sz.into()),
+		ethabi::Token::Bool(reduce_only),
+		ethabi::Token::Uint(encoded_tif.into()),
+		ethabi::Token::Uint(cloid.into()),
+	]);
+
+	let mut data = Vec::new();
+	data.push(0x01); // version
+	data.extend_from_slice(&[0x00, 0x00, 0x01]); // action_id = 1
+	data.extend_from_slice(&encoded);
+	data
+}