Deferred calls

Cargo.toml

@@ -76,6 +76,7 @@ massa_consensus_exports = { path = "./massa-consensus-exports" }
 massa_consensus_worker = { path = "./massa-consensus-worker" }
 massa_db_exports = { path = "./massa-db-exports" }
 massa_db_worker = { path = "./massa-db-worker" }
+massa_deferred_calls = { path = "./massa-deferred-calls" }
 massa_executed_ops = { path = "./massa-executed-ops" }
 massa_execution_exports = { path = "./massa-execution-exports" }
 massa_execution_worker = { path = "./massa-execution-worker" }
@@ -106,8 +107,10 @@ massa_versioning = { path = "./massa-versioning" }
 massa_wallet = { path = "./massa-wallet" }
 
 # Massa projects dependencies
-massa-proto-rs = { git = "https://github.com/massalabs/massa-proto-rs", "rev" = "38950875a7aa406fedc4f0b8336864e5ff290f2c" }
-massa-sc-runtime = { git = "https://github.com/massalabs/massa-sc-runtime", "rev" = "80352eb9f2a6b90a441cd64433d8874c33fb384f" }
+massa-proto-rs = { git = "https://github.com/massalabs/massa-proto-rs", "rev" = "67c331c10a1a3f0a9985b3b16c50e31d63074b83" }
+massa-sc-runtime = { git = "https://github.com/massalabs/massa-sc-runtime", "rev" = "7289367b2cb490ae1c6c74190d6d36b8d65b30cf" }
+
+
 peernet = { git = "https://github.com/massalabs/PeerNet", "rev" = "04b05ddd320fbe76cc858115af7b5fc28bdb8310" }
 
 # Common dependencies

massa-api-exports/Cargo.toml

@@ -22,6 +22,7 @@ massa_final_state = {workspace = true}
 massa_hash = {workspace = true}
 massa_wallet = {workspace = true}
 massa_versioning = {workspace = true}
+massa_deferred_calls = { workspace = true }
 
 [dev-dependencies]
 serial_test = {workspace = true}

massa-api-exports/src/config.rs

@@ -1,5 +1,6 @@
 // Copyright (c) 2022 MASSA LABS <info@massa.net>
 
+use massa_deferred_calls::config::DeferredCallsConfig;
 use massa_models::amount::Amount;
 use massa_signature::KeyPair;
 use massa_time::MassaTime;
@@ -84,4 +85,6 @@ pub struct APIConfig {
     pub deferred_credits_delta: MassaTime,
     /// minimal fees to include an operation in a block
     pub minimal_fees: Amount,
+    /// deferred calls config
+    pub deferred_calls_config: DeferredCallsConfig,
 }

massa-api-exports/src/execution.rs

@@ -1,5 +1,6 @@
 // Copyright (c) 2022 MASSA LABS <info@massa.net>
 
+use massa_deferred_calls::DeferredCall;
 use massa_final_state::StateChanges;
 use massa_models::{
     address::Address, amount::Amount, block_id::BlockId, operation::OperationId,
@@ -121,3 +122,45 @@ pub struct Transfer {
     /// Context
     pub context: TransferContext,
 }
+
+/// request for deferred call quote
+#[derive(Clone, Debug, Deserialize, Serialize)]
+pub struct DeferredCallsQuoteRequest {
+    /// The slot at which the deferred call is to be executed.
+    pub target_slot: Slot,
+    /// The maximum gas requested.
+    pub max_gas_request: u64,
+    /// Size of parameters
+    pub params_size: u64,
+}
+
+/// The response to a request for a deferred call quote.
+#[derive(Clone, Debug, Deserialize, Serialize)]
+pub struct DeferredCallsQuoteResponse {
+    /// The slot at which the deferred call is to be executed.
+    pub target_slot: Slot,
+    /// The maximum gas requested.
+    pub max_gas_request: u64,
+    /// if the slot is bookable
+    pub available: bool,
+    /// the cost for booking the call
+    pub price: Amount,
+}
+
+/// response for deferred call
+#[derive(Clone, Debug, Deserialize, Serialize)]
+pub struct DeferredCallResponse {
+    /// deferred call id
+    pub call_id: String,
+    /// deferred call
+    pub call: DeferredCall,
+}
+
+/// response for deferred calls by slot
+#[derive(Clone, Debug, Deserialize, Serialize)]
+pub struct DeferredCallsSlotResponse {
+    /// deferred calls
+    pub slot: Slot,
+    /// deferred calls
+    pub call_ids: Vec<String>,
+}

massa-api/src/lib.rs

@@ -11,7 +11,10 @@ use jsonrpsee::proc_macros::rpc;
 use jsonrpsee::server::middleware::HostFilterLayer;
 use jsonrpsee::server::{BatchRequestConfig, ServerBuilder, ServerHandle};
 use jsonrpsee::RpcModule;
-use massa_api_exports::execution::Transfer;
+use massa_api_exports::execution::{
+    DeferredCallResponse, DeferredCallsQuoteRequest, DeferredCallsQuoteResponse,
+    DeferredCallsSlotResponse, Transfer,
+};
 use massa_api_exports::{
     address::{AddressFilter, AddressInfo},
     block::{BlockInfo, BlockSummary},
@@ -400,6 +403,27 @@ pub trait MassaRpc {
     /// Get OpenRPC specification.
     #[method(name = "rpc.discover")]
     async fn get_openrpc_spec(&self) -> RpcResult<Value>;
+
+    /// DeferredCall quote
+    #[method(name = "get_deferred_call_quote")]
+    async fn get_deferred_call_quote(
+        &self,
+        arg: Vec<DeferredCallsQuoteRequest>,
+    ) -> RpcResult<Vec<DeferredCallsQuoteResponse>>;
+
+    /// DeferredCall get info
+    #[method(name = "get_deferred_call_info")]
+    async fn get_deferred_call_info(
+        &self,
+        arg: Vec<String>,
+    ) -> RpcResult<Vec<DeferredCallResponse>>;
+
+    /// List deferred calls for given slot
+    #[method(name = "get_deferred_call_ids_by_slot")]
+    async fn get_deferred_call_ids_by_slot(
+        &self,
+        arg: Vec<Slot>,
+    ) -> RpcResult<Vec<DeferredCallsSlotResponse>>;
 }
 
 fn wrong_api<T>() -> RpcResult<T> {

massa-api/src/private.rs

@@ -11,7 +11,11 @@ use massa_api_exports::{
     datastore::{DatastoreEntryInput, DatastoreEntryOutput},
     endorsement::EndorsementInfo,
     error::ApiError,
-    execution::{ExecuteReadOnlyResponse, ReadOnlyBytecodeExecution, ReadOnlyCall, Transfer},
+    execution::{
+        DeferredCallResponse, DeferredCallsQuoteRequest, DeferredCallsQuoteResponse,
+        DeferredCallsSlotResponse, ExecuteReadOnlyResponse, ReadOnlyBytecodeExecution,
+        ReadOnlyCall, Transfer,
+    },
     node::NodeStatus,
     operation::{OperationInfo, OperationInput},
     page::{PageRequest, PagedVec},
@@ -351,6 +355,26 @@ impl MassaRpcServer for API<Private> {
         )
     }
 
+    async fn get_deferred_call_quote(
+        &self,
+        _req: Vec<DeferredCallsQuoteRequest>,
+    ) -> RpcResult<Vec<DeferredCallsQuoteResponse>> {
+        crate::wrong_api::<Vec<DeferredCallsQuoteResponse>>()
+    }
+    async fn get_deferred_call_info(
+        &self,
+        _arg: Vec<String>,
+    ) -> RpcResult<Vec<DeferredCallResponse>> {
+        crate::wrong_api::<Vec<DeferredCallResponse>>()
+    }
+
+    async fn get_deferred_call_ids_by_slot(
+        &self,
+        _slot: Vec<Slot>,
+    ) -> RpcResult<Vec<DeferredCallsSlotResponse>> {
+        crate::wrong_api::<Vec<DeferredCallsSlotResponse>>()
+    }
+
     async fn get_openrpc_spec(&self) -> RpcResult<Value> {
         crate::wrong_api::<Value>()
     }