Cron improvements

packages/neutron-sdk/src/bindings/msg.rs

@@ -1,6 +1,7 @@
 use crate::{
     bindings::types::{KVKey, ProtobufAny},
     interchain_queries::types::{QueryPayload, QueryType, TransactionFilterItem},
+    proto_types::neutron::cron::ExecutionStage,
     sudo::msg::RequestPacketTimeoutHeight,
     NeutronResult,
 };
@@ -228,6 +229,8 @@ pub enum NeutronMsg {
         period: u64,
         /// list of cosmwasm messages to be executed
         msgs: Vec<MsgExecuteContract>,
+        /// execution stage where schedule will be executed
+        execution_stage: String,
     },
 
     /// RemoveSchedule removes the schedule with a given `name`.
@@ -511,8 +514,19 @@ impl NeutronMsg {
     /// * **name** is a name of the schedule;
     /// * **period** is a period of schedule execution in blocks;
     /// * **msgs** is the messages that will be executed.
-    pub fn submit_add_schedule(name: String, period: u64, msgs: Vec<MsgExecuteContract>) -> Self {
-        NeutronMsg::AddSchedule { name, period, msgs }
+    /// * **execution_stage** is the stage where schedule will be executed.
+    pub fn submit_add_schedule(
+        name: String,
+        period: u64,
+        msgs: Vec<MsgExecuteContract>,
+        execution_stage: ExecutionStage,
+    ) -> Self {
+        NeutronMsg::AddSchedule {
+            name,
+            period,
+            msgs,
+            execution_stage: execution_stage.as_str_name().to_string(),
+        }
     }
 
     /// Basic helper to define remove schedule passed to Cron module:

packages/neutron-sdk/src/proto_types/NEUTRON_COMMIT

@@ -1 +1 @@
-ba1b1d6dc91370d81e7125962e02aee01274eac
+1bf83371924e7f3f5a756c8a9ea35e2d607a984e

packages/neutron-sdk/src/proto_types/neutron/contractmanager/mod.rs

@@ -132,10 +132,34 @@ pub struct QueryParamsResponse {
 )]
 #[proto_message(type_url = "/neutron.contractmanager.QueryFailuresRequest")]
 #[proto_query(
-    path = "/neutron.contractmanager.Query/AddressFailure",
+    path = "/neutron.contractmanager.Query/AddressFailures",
     response_type = QueryFailuresResponse
 )]
 pub struct QueryFailuresRequest {
+    /// address of the contract which Sudo call failed.
+    #[prost(string, tag = "1")]
+    pub address: ::prost::alloc::string::String,
+    #[prost(message, optional, tag = "3")]
+    pub pagination: ::core::option::Option<super::super::cosmos::base::query::v1beta1::PageRequest>,
+}
+/// QueryFailureRequest is request type for the Query/Failures RPC method.
+#[allow(clippy::derive_partial_eq_without_eq)]
+#[derive(
+    Clone,
+    PartialEq,
+    Eq,
+    ::prost::Message,
+    ::serde::Serialize,
+    ::serde::Deserialize,
+    ::schemars::JsonSchema,
+    CosmwasmExt,
+)]
+#[proto_message(type_url = "/neutron.contractmanager.QueryFailureRequest")]
+#[proto_query(
+    path = "/neutron.contractmanager.Query/AddressFailure",
+    response_type = QueryFailureResponse
+)]
+pub struct QueryFailureRequest {
     /// address of the contract which Sudo call failed.
     #[prost(string, tag = "1")]
     pub address: ::prost::alloc::string::String,
@@ -147,8 +171,23 @@ pub struct QueryFailuresRequest {
         deserialize_with = "crate::serde::as_str::deserialize"
     )]
     pub failure_id: u64,
-    #[prost(message, optional, tag = "3")]
-    pub pagination: ::core::option::Option<super::super::cosmos::base::query::v1beta1::PageRequest>,
+}
+/// QueryFailureResponse is response type for the Query/Failure RPC method.
+#[allow(clippy::derive_partial_eq_without_eq)]
+#[derive(
+    Clone,
+    PartialEq,
+    Eq,
+    ::prost::Message,
+    ::serde::Serialize,
+    ::serde::Deserialize,
+    ::schemars::JsonSchema,
+    CosmwasmExt,
+)]
+#[proto_message(type_url = "/neutron.contractmanager.QueryFailureResponse")]
+pub struct QueryFailureResponse {
+    #[prost(message, optional, tag = "1")]
+    pub failure: ::core::option::Option<Failure>,
 }
 /// QueryFailuresResponse is response type for the Query/Failures RPC method.
 #[allow(clippy::derive_partial_eq_without_eq)]
@@ -226,37 +265,31 @@ impl<'a, Q: cosmwasm_std::CustomQuery> ContractmanagerQuerier<'a, Q> {
         &self,
         address: ::prost::alloc::string::String,
         failure_id: u64,
-        pagination: ::core::option::Option<super::super::cosmos::base::query::v1beta1::PageRequest>,
-    ) -> Result<QueryFailuresResponse, cosmwasm_std::StdError> {
-        QueryFailuresRequest {
+    ) -> Result<QueryFailureResponse, cosmwasm_std::StdError> {
+        QueryFailureRequest {
             address,
             failure_id,
-            pagination,
         }
         .query(self.querier)
     }
     pub fn address_failures(
         &self,
         address: ::prost::alloc::string::String,
-        failure_id: u64,
         pagination: ::core::option::Option<super::super::cosmos::base::query::v1beta1::PageRequest>,
     ) -> Result<QueryFailuresResponse, cosmwasm_std::StdError> {
         QueryFailuresRequest {
             address,
-            failure_id,
             pagination,
         }
         .query(self.querier)
     }
     pub fn failures(
         &self,
         address: ::prost::alloc::string::String,
-        failure_id: u64,
         pagination: ::core::option::Option<super::super::cosmos::base::query::v1beta1::PageRequest>,
     ) -> Result<QueryFailuresResponse, cosmwasm_std::StdError> {
         QueryFailuresRequest {
             address,
-            failure_id,
             pagination,
         }
         .query(self.querier)