ows-lib 1.3.2

High-level library API for the Open Wallet Standard
Documentation 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110

use crate::error::OwsLibError;

// Hand-written prost message types matching the Sui gRPC proto definitions
// from https://github.com/MystenLabs/sui-apis/tree/main/proto/sui/rpc/v2
//
// Only the minimal types needed for transaction execution are defined here.

#[derive(Clone, PartialEq, prost::Message)]
pub struct Bcs {
    #[prost(string, optional, tag = "1")]
    pub name: ::core::option::Option<String>,
    #[prost(bytes = "vec", optional, tag = "2")]
    pub value: ::core::option::Option<Vec<u8>>,
}

#[derive(Clone, PartialEq, prost::Message)]
pub struct Transaction {
    #[prost(message, optional, tag = "1")]
    pub bcs: ::core::option::Option<Bcs>,
}

#[derive(Clone, PartialEq, prost::Message)]
pub struct UserSignature {
    #[prost(message, optional, tag = "1")]
    pub bcs: ::core::option::Option<Bcs>,
}

#[derive(Clone, PartialEq, prost::Message)]
pub struct ExecuteTransactionRequest {
    #[prost(message, optional, tag = "1")]
    pub transaction: ::core::option::Option<Transaction>,
    #[prost(message, repeated, tag = "2")]
    pub signatures: Vec<UserSignature>,
}

#[derive(Clone, PartialEq, prost::Message)]
pub struct ExecutedTransaction {
    #[prost(string, optional, tag = "1")]
    pub digest: ::core::option::Option<String>,
}

#[derive(Clone, PartialEq, prost::Message)]
pub struct ExecuteTransactionResponse {
    #[prost(message, optional, tag = "1")]
    pub transaction: ::core::option::Option<ExecutedTransaction>,
}

/// Execute a signed Sui transaction via gRPC.
///
/// `endpoint` is the gRPC endpoint URL (e.g. `https://fullnode.mainnet.sui.io:443`).
/// `tx_bcs` is the BCS-encoded transaction bytes.
/// `sig_bcs` is the Sui wire signature (flag || sig || pubkey).
///
/// Returns the transaction digest on success.
pub fn execute_transaction(
    endpoint: &str,
    tx_bcs: &[u8],
    sig_bcs: &[u8],
) -> Result<String, OwsLibError> {
    let rt = tokio::runtime::Builder::new_current_thread()
        .enable_all()
        .build()
        .map_err(|e| OwsLibError::BroadcastFailed(format!("failed to create runtime: {e}")))?;

    rt.block_on(async {
        let channel = tonic::transport::Channel::from_shared(endpoint.to_string())
            .map_err(|e| OwsLibError::BroadcastFailed(format!("invalid endpoint: {e}")))?
            .connect()
            .await
            .map_err(|e| OwsLibError::BroadcastFailed(format!("gRPC connect failed: {e}")))?;

        let mut client = tonic::client::Grpc::new(channel);

        client
            .ready()
            .await
            .map_err(|e| OwsLibError::BroadcastFailed(format!("gRPC not ready: {e}")))?;

        let request = ExecuteTransactionRequest {
            transaction: Some(Transaction {
                bcs: Some(Bcs {
                    name: None,
                    value: Some(tx_bcs.to_vec()),
                }),
            }),
            signatures: vec![UserSignature {
                bcs: Some(Bcs {
                    name: None,
                    value: Some(sig_bcs.to_vec()),
                }),
            }],
        };

        let path = tonic::codegen::http::uri::PathAndQuery::from_static(
            "/sui.rpc.v2.TransactionExecutionService/ExecuteTransaction",
        );
        let codec = tonic::codec::ProstCodec::default();

        let response: tonic::Response<ExecuteTransactionResponse> = client
            .unary(tonic::Request::new(request), path, codec)
            .await
            .map_err(|e| OwsLibError::BroadcastFailed(format!("gRPC error: {e}")))?;

        response
            .into_inner()
            .transaction
            .and_then(|t| t.digest)
            .ok_or_else(|| OwsLibError::BroadcastFailed("no digest in gRPC response".into()))
    })
}