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
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
132
133
134
135
136
137
138
139
140
141
142
143
144
145
146
147
148
149
150
151
152
153
154
155
156
157
158
159
160
161
162
163
164
165
166
167
168
169
170
171
172
173
174
175
176
177
178
179
180
181
182
183
184
185
186
187
188
189
190
191
192
193
194
195
196
197
198
199
200
201
202
203
204
205
206
207
208
209
210
211
212
213
214
215
216
217
218
219
220
221
222
223
224
225
226
227
228
229
230
231
232
233
234
235
236
237
238
239
240
241
242
243
244
245
246
247
248
249
250
251
252
253
254
255
256
257
258
259
260
261
262
263
264
265
266
267
268
269
270
271
272
273
274
275
276
277
278
279
280
281
282
283
284
285
286
287
288
289
290
291
292
293
294
295
296
297
298
299
300
301
302
303
304
305
306
307
308
309
310
311
312
313
314
315
316
317
318
319
320
321
322
323
324
325
326
327
328
329
330
331
332
333
334
335
336
337
338
339
340
341
342
343
344
345
346
347
348
349
350
351
352
353
354
355
356
357
358
359
360
361
362
363
364
365
366
367
368
369
370
371
372
373
374
375
376
377
378
379
380
381
382
383
384
385
386
387
388
389
390
391
392
393
394
395
396
397
398
399
400
401
402
403
404
405
406
407
408
409
410
411
412
413
414
415
416
417
418
419
420
421
422
423
/// AppDescriptor describes a cosmos-sdk based application
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct AppDescriptor {
/// AuthnDescriptor provides information on how to authenticate transactions on the application
/// NOTE: experimental and subject to change in future releases.
#[prost(message, optional, tag="1")]
pub authn: ::core::option::Option<AuthnDescriptor>,
/// chain provides the chain descriptor
#[prost(message, optional, tag="2")]
pub chain: ::core::option::Option<ChainDescriptor>,
/// codec provides metadata information regarding codec related types
#[prost(message, optional, tag="3")]
pub codec: ::core::option::Option<CodecDescriptor>,
/// configuration provides metadata information regarding the sdk.Config type
#[prost(message, optional, tag="4")]
pub configuration: ::core::option::Option<ConfigurationDescriptor>,
/// query_services provides metadata information regarding the available queriable endpoints
#[prost(message, optional, tag="5")]
pub query_services: ::core::option::Option<QueryServicesDescriptor>,
/// tx provides metadata information regarding how to send transactions to the given application
#[prost(message, optional, tag="6")]
pub tx: ::core::option::Option<TxDescriptor>,
}
/// TxDescriptor describes the accepted transaction type
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct TxDescriptor {
/// fullname is the protobuf fullname of the raw transaction type (for instance the tx.Tx type)
/// it is not meant to support polymorphism of transaction types, it is supposed to be used by
/// reflection clients to understand if they can handle a specific transaction type in an application.
#[prost(string, tag="1")]
pub fullname: ::prost::alloc::string::String,
/// msgs lists the accepted application messages (sdk.Msg)
#[prost(message, repeated, tag="2")]
pub msgs: ::prost::alloc::vec::Vec<MsgDescriptor>,
}
/// AuthnDescriptor provides information on how to sign transactions without relying
/// on the online RPCs GetTxMetadata and CombineUnsignedTxAndSignatures
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct AuthnDescriptor {
/// sign_modes defines the supported signature algorithm
#[prost(message, repeated, tag="1")]
pub sign_modes: ::prost::alloc::vec::Vec<SigningModeDescriptor>,
}
/// SigningModeDescriptor provides information on a signing flow of the application
/// NOTE(fdymylja): here we could go as far as providing an entire flow on how
/// to sign a message given a SigningModeDescriptor, but it's better to think about
/// this another time
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct SigningModeDescriptor {
/// name defines the unique name of the signing mode
#[prost(string, tag="1")]
pub name: ::prost::alloc::string::String,
/// number is the unique int32 identifier for the sign_mode enum
#[prost(int32, tag="2")]
pub number: i32,
/// authn_info_provider_method_fullname defines the fullname of the method to call to get
/// the metadata required to authenticate using the provided sign_modes
#[prost(string, tag="3")]
pub authn_info_provider_method_fullname: ::prost::alloc::string::String,
}
/// ChainDescriptor describes chain information of the application
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct ChainDescriptor {
/// id is the chain id
#[prost(string, tag="1")]
pub id: ::prost::alloc::string::String,
}
/// CodecDescriptor describes the registered interfaces and provides metadata information on the types
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct CodecDescriptor {
/// interfaces is a list of the registerted interfaces descriptors
#[prost(message, repeated, tag="1")]
pub interfaces: ::prost::alloc::vec::Vec<InterfaceDescriptor>,
}
/// InterfaceDescriptor describes the implementation of an interface
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct InterfaceDescriptor {
/// fullname is the name of the interface
#[prost(string, tag="1")]
pub fullname: ::prost::alloc::string::String,
/// interface_accepting_messages contains information regarding the proto messages which contain the interface as
/// google.protobuf.Any field
#[prost(message, repeated, tag="2")]
pub interface_accepting_messages: ::prost::alloc::vec::Vec<InterfaceAcceptingMessageDescriptor>,
/// interface_implementers is a list of the descriptors of the interface implementers
#[prost(message, repeated, tag="3")]
pub interface_implementers: ::prost::alloc::vec::Vec<InterfaceImplementerDescriptor>,
}
/// InterfaceImplementerDescriptor describes an interface implementer
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct InterfaceImplementerDescriptor {
/// fullname is the protobuf queryable name of the interface implementer
#[prost(string, tag="1")]
pub fullname: ::prost::alloc::string::String,
/// type_url defines the type URL used when marshalling the type as any
/// this is required so we can provide type safe google.protobuf.Any marshalling and
/// unmarshalling, making sure that we don't accept just 'any' type
/// in our interface fields
#[prost(string, tag="2")]
pub type_url: ::prost::alloc::string::String,
}
/// InterfaceAcceptingMessageDescriptor describes a protobuf message which contains
/// an interface represented as a google.protobuf.Any
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct InterfaceAcceptingMessageDescriptor {
/// fullname is the protobuf fullname of the type containing the interface
#[prost(string, tag="1")]
pub fullname: ::prost::alloc::string::String,
/// field_descriptor_names is a list of the protobuf name (not fullname) of the field
/// which contains the interface as google.protobuf.Any (the interface is the same, but
/// it can be in multiple fields of the same proto message)
#[prost(string, repeated, tag="2")]
pub field_descriptor_names: ::prost::alloc::vec::Vec<::prost::alloc::string::String>,
}
/// ConfigurationDescriptor contains metadata information on the sdk.Config
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct ConfigurationDescriptor {
/// bech32_account_address_prefix is the account address prefix
#[prost(string, tag="1")]
pub bech32_account_address_prefix: ::prost::alloc::string::String,
}
/// MsgDescriptor describes a cosmos-sdk message that can be delivered with a transaction
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct MsgDescriptor {
/// msg_type_url contains the TypeURL of a sdk.Msg.
#[prost(string, tag="1")]
pub msg_type_url: ::prost::alloc::string::String,
}
/// GetAuthnDescriptorRequest is the request used for the GetAuthnDescriptor RPC
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct GetAuthnDescriptorRequest {
}
/// GetAuthnDescriptorResponse is the response returned by the GetAuthnDescriptor RPC
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct GetAuthnDescriptorResponse {
/// authn describes how to authenticate to the application when sending transactions
#[prost(message, optional, tag="1")]
pub authn: ::core::option::Option<AuthnDescriptor>,
}
/// GetChainDescriptorRequest is the request used for the GetChainDescriptor RPC
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct GetChainDescriptorRequest {
}
/// GetChainDescriptorResponse is the response returned by the GetChainDescriptor RPC
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct GetChainDescriptorResponse {
/// chain describes application chain information
#[prost(message, optional, tag="1")]
pub chain: ::core::option::Option<ChainDescriptor>,
}
/// GetCodecDescriptorRequest is the request used for the GetCodecDescriptor RPC
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct GetCodecDescriptorRequest {
}
/// GetCodecDescriptorResponse is the response returned by the GetCodecDescriptor RPC
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct GetCodecDescriptorResponse {
/// codec describes the application codec such as registered interfaces and implementations
#[prost(message, optional, tag="1")]
pub codec: ::core::option::Option<CodecDescriptor>,
}
/// GetConfigurationDescriptorRequest is the request used for the GetConfigurationDescriptor RPC
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct GetConfigurationDescriptorRequest {
}
/// GetConfigurationDescriptorResponse is the response returned by the GetConfigurationDescriptor RPC
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct GetConfigurationDescriptorResponse {
/// config describes the application's sdk.Config
#[prost(message, optional, tag="1")]
pub config: ::core::option::Option<ConfigurationDescriptor>,
}
/// GetQueryServicesDescriptorRequest is the request used for the GetQueryServicesDescriptor RPC
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct GetQueryServicesDescriptorRequest {
}
/// GetQueryServicesDescriptorResponse is the response returned by the GetQueryServicesDescriptor RPC
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct GetQueryServicesDescriptorResponse {
/// queries provides information on the available queryable services
#[prost(message, optional, tag="1")]
pub queries: ::core::option::Option<QueryServicesDescriptor>,
}
/// GetTxDescriptorRequest is the request used for the GetTxDescriptor RPC
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct GetTxDescriptorRequest {
}
/// GetTxDescriptorResponse is the response returned by the GetTxDescriptor RPC
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct GetTxDescriptorResponse {
/// tx provides information on msgs that can be forwarded to the application
/// alongside the accepted transaction protobuf type
#[prost(message, optional, tag="1")]
pub tx: ::core::option::Option<TxDescriptor>,
}
/// QueryServicesDescriptor contains the list of cosmos-sdk queriable services
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct QueryServicesDescriptor {
/// query_services is a list of cosmos-sdk QueryServiceDescriptor
#[prost(message, repeated, tag="1")]
pub query_services: ::prost::alloc::vec::Vec<QueryServiceDescriptor>,
}
/// QueryServiceDescriptor describes a cosmos-sdk queryable service
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct QueryServiceDescriptor {
/// fullname is the protobuf fullname of the service descriptor
#[prost(string, tag="1")]
pub fullname: ::prost::alloc::string::String,
/// is_module describes if this service is actually exposed by an application's module
#[prost(bool, tag="2")]
pub is_module: bool,
/// methods provides a list of query service methods
#[prost(message, repeated, tag="3")]
pub methods: ::prost::alloc::vec::Vec<QueryMethodDescriptor>,
}
/// QueryMethodDescriptor describes a queryable method of a query service
/// no other info is provided beside method name and tendermint queryable path
/// because it would be redundant with the grpc reflection service
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct QueryMethodDescriptor {
/// name is the protobuf name (not fullname) of the method
#[prost(string, tag="1")]
pub name: ::prost::alloc::string::String,
/// full_query_path is the path that can be used to query
/// this method via tendermint abci.Query
#[prost(string, tag="2")]
pub full_query_path: ::prost::alloc::string::String,
}
/// Generated client implementations.
pub mod reflection_service_client {
#![allow(unused_variables, dead_code, missing_docs, clippy::let_unit_value)]
use tonic::codegen::*;
/// ReflectionService defines a service for application reflection.
#[derive(Debug, Clone)]
pub struct ReflectionServiceClient<T> {
inner: tonic::client::Grpc<T>,
}
impl ReflectionServiceClient<tonic::transport::Channel> {
/// Attempt to create a new client by connecting to a given endpoint.
pub async fn connect<D>(dst: D) -> Result<Self, tonic::transport::Error>
where
D: std::convert::TryInto<tonic::transport::Endpoint>,
D::Error: Into<StdError>,
{
let conn = tonic::transport::Endpoint::new(dst)?.connect().await?;
Ok(Self::new(conn))
}
}
impl<T> ReflectionServiceClient<T>
where
T: tonic::client::GrpcService<tonic::body::BoxBody>,
T::Error: Into<StdError>,
T::ResponseBody: Body<Data = Bytes> + Send + 'static,
<T::ResponseBody as Body>::Error: Into<StdError> + Send,
{
pub fn new(inner: T) -> Self {
let inner = tonic::client::Grpc::new(inner);
Self { inner }
}
pub fn with_interceptor<F>(
inner: T,
interceptor: F,
) -> ReflectionServiceClient<InterceptedService<T, F>>
where
F: tonic::service::Interceptor,
T::ResponseBody: Default,
T: tonic::codegen::Service<
http::Request<tonic::body::BoxBody>,
Response = http::Response<
<T as tonic::client::GrpcService<tonic::body::BoxBody>>::ResponseBody,
>,
>,
<T as tonic::codegen::Service<
http::Request<tonic::body::BoxBody>,
>>::Error: Into<StdError> + Send + Sync,
{
ReflectionServiceClient::new(InterceptedService::new(inner, interceptor))
}
/// Compress requests with `gzip`.
///
/// This requires the server to support it otherwise it might respond with an
/// error.
#[must_use]
pub fn send_gzip(mut self) -> Self {
self.inner = self.inner.send_gzip();
self
}
/// Enable decompressing responses with `gzip`.
#[must_use]
pub fn accept_gzip(mut self) -> Self {
self.inner = self.inner.accept_gzip();
self
}
/// GetAuthnDescriptor returns information on how to authenticate transactions in the application
/// NOTE: this RPC is still experimental and might be subject to breaking changes or removal in
/// future releases of the cosmos-sdk.
pub async fn get_authn_descriptor(
&mut self,
request: impl tonic::IntoRequest<super::GetAuthnDescriptorRequest>,
) -> Result<tonic::Response<super::GetAuthnDescriptorResponse>, 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(
"/cosmos.base.reflection.v2alpha1.ReflectionService/GetAuthnDescriptor",
);
self.inner.unary(request.into_request(), path, codec).await
}
/// GetChainDescriptor returns the description of the chain
pub async fn get_chain_descriptor(
&mut self,
request: impl tonic::IntoRequest<super::GetChainDescriptorRequest>,
) -> Result<tonic::Response<super::GetChainDescriptorResponse>, 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(
"/cosmos.base.reflection.v2alpha1.ReflectionService/GetChainDescriptor",
);
self.inner.unary(request.into_request(), path, codec).await
}
/// GetCodecDescriptor returns the descriptor of the codec of the application
pub async fn get_codec_descriptor(
&mut self,
request: impl tonic::IntoRequest<super::GetCodecDescriptorRequest>,
) -> Result<tonic::Response<super::GetCodecDescriptorResponse>, 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(
"/cosmos.base.reflection.v2alpha1.ReflectionService/GetCodecDescriptor",
);
self.inner.unary(request.into_request(), path, codec).await
}
/// GetConfigurationDescriptor returns the descriptor for the sdk.Config of the application
pub async fn get_configuration_descriptor(
&mut self,
request: impl tonic::IntoRequest<super::GetConfigurationDescriptorRequest>,
) -> Result<
tonic::Response<super::GetConfigurationDescriptorResponse>,
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(
"/cosmos.base.reflection.v2alpha1.ReflectionService/GetConfigurationDescriptor",
);
self.inner.unary(request.into_request(), path, codec).await
}
/// GetQueryServicesDescriptor returns the available gRPC queryable services of the application
pub async fn get_query_services_descriptor(
&mut self,
request: impl tonic::IntoRequest<super::GetQueryServicesDescriptorRequest>,
) -> Result<
tonic::Response<super::GetQueryServicesDescriptorResponse>,
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(
"/cosmos.base.reflection.v2alpha1.ReflectionService/GetQueryServicesDescriptor",
);
self.inner.unary(request.into_request(), path, codec).await
}
/// GetTxDescriptor returns information on the used transaction object and available msgs that can be used
pub async fn get_tx_descriptor(
&mut self,
request: impl tonic::IntoRequest<super::GetTxDescriptorRequest>,
) -> Result<tonic::Response<super::GetTxDescriptorResponse>, 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(
"/cosmos.base.reflection.v2alpha1.ReflectionService/GetTxDescriptor",
);
self.inner.unary(request.into_request(), path, codec).await
}
}
}