Skip to content

Commit

Permalink
Add all updated protos for ibc-go 'v8.0.0'
Browse files Browse the repository at this point in the history
  • Loading branch information
ljoss17 committed Nov 14, 2023
1 parent ed4eb27 commit 3ef7d18
Show file tree
Hide file tree
Showing 8 changed files with 991 additions and 816 deletions.
886 changes: 147 additions & 739 deletions src/prost/google.protobuf.rs

Large diffs are not rendered by default.

15 changes: 15 additions & 0 deletions src/prost/ibc.applications.fee.v1.rs
Original file line number Diff line number Diff line change
Expand Up @@ -817,6 +817,11 @@ pub struct QueryIncentivizedPacketsResponse {
/// list of identified fees for incentivized packets
#[prost(message, repeated, tag = "1")]
pub incentivized_packets: ::prost::alloc::vec::Vec<IdentifiedPacketFees>,
/// pagination defines the pagination in the response.
#[prost(message, optional, tag = "2")]
pub pagination: ::core::option::Option<
super::super::super::super::cosmos::base::query::v1beta1::PageResponse,
>,
}
/// QueryIncentivizedPacketRequest defines the request type for the IncentivizedPacket rpc
#[allow(clippy::derive_partial_eq_without_eq)]
Expand Down Expand Up @@ -864,6 +869,11 @@ pub struct QueryIncentivizedPacketsForChannelResponse {
/// Map of all incentivized_packets
#[prost(message, repeated, tag = "1")]
pub incentivized_packets: ::prost::alloc::vec::Vec<IdentifiedPacketFees>,
/// pagination defines the pagination in the response.
#[prost(message, optional, tag = "2")]
pub pagination: ::core::option::Option<
super::super::super::super::cosmos::base::query::v1beta1::PageResponse,
>,
}
/// QueryTotalRecvFeesRequest defines the request type for the TotalRecvFees rpc
#[allow(clippy::derive_partial_eq_without_eq)]
Expand Down Expand Up @@ -983,6 +993,11 @@ pub struct QueryFeeEnabledChannelsResponse {
/// list of fee enabled channels
#[prost(message, repeated, tag = "1")]
pub fee_enabled_channels: ::prost::alloc::vec::Vec<FeeEnabledChannel>,
/// pagination defines the pagination in the response.
#[prost(message, optional, tag = "2")]
pub pagination: ::core::option::Option<
super::super::super::super::cosmos::base::query::v1beta1::PageResponse,
>,
}
/// QueryFeeEnabledChannelRequest defines the request type for the FeeEnabledChannel rpc
#[allow(clippy::derive_partial_eq_without_eq)]
Expand Down
122 changes: 112 additions & 10 deletions src/prost/ibc.applications.interchain_accounts.controller.v1.rs
Original file line number Diff line number Diff line change
@@ -1,3 +1,13 @@
/// Params defines the set of on-chain interchain accounts parameters.
/// The following parameters may be used to disable the controller submodule.
#[cfg_attr(feature = "serde", derive(::serde::Serialize, ::serde::Deserialize))]
#[allow(clippy::derive_partial_eq_without_eq)]
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct Params {
/// controller_enabled enables or disables the controller submodule.
#[prost(bool, tag = "1")]
pub controller_enabled: bool,
}
/// MsgRegisterInterchainAccount defines the payload for Msg/RegisterAccount
#[cfg_attr(feature = "serde", derive(::serde::Serialize, ::serde::Deserialize))]
#[allow(clippy::derive_partial_eq_without_eq)]
Expand Down Expand Up @@ -46,6 +56,25 @@ pub struct MsgSendTxResponse {
#[prost(uint64, tag = "1")]
pub sequence: u64,
}
/// MsgUpdateParams defines the payload for Msg/UpdateParams
#[cfg_attr(feature = "serde", derive(::serde::Serialize, ::serde::Deserialize))]
#[allow(clippy::derive_partial_eq_without_eq)]
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct MsgUpdateParams {
/// signer address
#[prost(string, tag = "1")]
pub signer: ::prost::alloc::string::String,
/// params defines the 27-interchain-accounts/controller parameters to update.
///
/// NOTE: All parameters must be supplied.
#[prost(message, optional, tag = "2")]
pub params: ::core::option::Option<Params>,
}
/// MsgUpdateParamsResponse defines the response for Msg/UpdateParams
#[cfg_attr(feature = "serde", derive(::serde::Serialize, ::serde::Deserialize))]
#[allow(clippy::derive_partial_eq_without_eq)]
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct MsgUpdateParamsResponse {}
/// Generated client implementations.
#[cfg(feature = "client")]
pub mod msg_client {
Expand Down Expand Up @@ -195,6 +224,37 @@ pub mod msg_client {
);
self.inner.unary(req, path, codec).await
}
/// UpdateParams defines a rpc handler for MsgUpdateParams.
pub async fn update_params(
&mut self,
request: impl tonic::IntoRequest<super::MsgUpdateParams>,
) -> std::result::Result<
tonic::Response<super::MsgUpdateParamsResponse>,
tonic::Status,
> {
self.inner
.ready()
.await
.map_err(|e| {
tonic::Status::new(
tonic::Code::Unknown,
format!("Service was not ready: {}", e.into()),
)
})?;
let codec = tonic::codec::ProstCodec::default();
let path = http::uri::PathAndQuery::from_static(
"/ibc.applications.interchain_accounts.controller.v1.Msg/UpdateParams",
);
let mut req = request.into_request();
req.extensions_mut()
.insert(
GrpcMethod::new(
"ibc.applications.interchain_accounts.controller.v1.Msg",
"UpdateParams",
),
);
self.inner.unary(req, path, codec).await
}
}
}
/// Generated server implementations.
Expand All @@ -221,6 +281,14 @@ pub mod msg_server {
tonic::Response<super::MsgSendTxResponse>,
tonic::Status,
>;
/// UpdateParams defines a rpc handler for MsgUpdateParams.
async fn update_params(
&self,
request: tonic::Request<super::MsgUpdateParams>,
) -> std::result::Result<
tonic::Response<super::MsgUpdateParamsResponse>,
tonic::Status,
>;
}
/// Msg defines the 27-interchain-accounts/controller Msg service.
#[derive(Debug)]
Expand Down Expand Up @@ -393,6 +461,50 @@ pub mod msg_server {
};
Box::pin(fut)
}
"/ibc.applications.interchain_accounts.controller.v1.Msg/UpdateParams" => {
#[allow(non_camel_case_types)]
struct UpdateParamsSvc<T: Msg>(pub Arc<T>);
impl<T: Msg> tonic::server::UnaryService<super::MsgUpdateParams>
for UpdateParamsSvc<T> {
type Response = super::MsgUpdateParamsResponse;
type Future = BoxFuture<
tonic::Response<Self::Response>,
tonic::Status,
>;
fn call(
&mut self,
request: tonic::Request<super::MsgUpdateParams>,
) -> Self::Future {
let inner = Arc::clone(&self.0);
let fut = async move {
<T as Msg>::update_params(&inner, request).await
};
Box::pin(fut)
}
}
let accept_compression_encodings = self.accept_compression_encodings;
let send_compression_encodings = self.send_compression_encodings;
let max_decoding_message_size = self.max_decoding_message_size;
let max_encoding_message_size = self.max_encoding_message_size;
let inner = self.inner.clone();
let fut = async move {
let inner = inner.0;
let method = UpdateParamsSvc(inner);
let codec = tonic::codec::ProstCodec::default();
let mut grpc = tonic::server::Grpc::new(codec)
.apply_compression_config(
accept_compression_encodings,
send_compression_encodings,
)
.apply_max_message_size_config(
max_decoding_message_size,
max_encoding_message_size,
);
let res = grpc.unary(method, req).await;
Ok(res)
};
Box::pin(fut)
}
_ => {
Box::pin(async move {
Ok(
Expand Down Expand Up @@ -434,16 +546,6 @@ pub mod msg_server {
const NAME: &'static str = "ibc.applications.interchain_accounts.controller.v1.Msg";
}
}
/// Params defines the set of on-chain interchain accounts parameters.
/// The following parameters may be used to disable the controller submodule.
#[cfg_attr(feature = "serde", derive(::serde::Serialize, ::serde::Deserialize))]
#[allow(clippy::derive_partial_eq_without_eq)]
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct Params {
/// controller_enabled enables or disables the controller submodule.
#[prost(bool, tag = "1")]
pub controller_enabled: bool,
}
/// QueryInterchainAccountRequest is the request type for the Query/InterchainAccount RPC method.
#[cfg_attr(feature = "serde", derive(::serde::Serialize, ::serde::Deserialize))]
#[allow(clippy::derive_partial_eq_without_eq)]
Expand Down
Loading

0 comments on commit 3ef7d18

Please sign in to comment.