Skip to content

Commit 808b922

Browse files
keithsuekeithsue
committed
update proto
1 parent 2a6ebd8 commit 808b922

File tree

9 files changed

+511
-136
lines changed

9 files changed

+511
-136
lines changed

‎Cargo.lock

Lines changed: 1 addition & 1 deletion
Some generated files are not rendered by default. Learn more about customizing how changed files appear on GitHub.

‎side-proto/Cargo.toml

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -1,6 +1,6 @@
11
[package]
22
name = "side-proto"
3-
version = "2.0.0-alpha.2"
3+
version = "2.0.0-alpha.3"
44
edition = "2021"
55
description = "Rust Client for Side Chain"
66
readme = "README.md"

‎side-proto/src/prost/side/side.dlc.rs

Lines changed: 26 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -309,6 +309,32 @@ impl ::prost::Name for QueryAttestationResponse {
309309
}
310310
#[allow(clippy::derive_partial_eq_without_eq)]
311311
#[derive(Clone, PartialEq, ::prost::Message)]
312+
pub struct QueryAttestationByEventRequest {
313+
#[prost(uint64, tag = "1")]
314+
pub event_id: u64,
315+
}
316+
impl ::prost::Name for QueryAttestationByEventRequest {
317+
const NAME: &'static str = "QueryAttestationByEventRequest";
318+
const PACKAGE: &'static str = "side.dlc";
319+
fn full_name() -> ::prost::alloc::string::String {
320+
::prost::alloc::format!("side.dlc.{}", Self::NAME)
321+
}
322+
}
323+
#[allow(clippy::derive_partial_eq_without_eq)]
324+
#[derive(Clone, PartialEq, ::prost::Message)]
325+
pub struct QueryAttestationByEventResponse {
326+
#[prost(message, optional, tag = "1")]
327+
pub attestation: ::core::option::Option<DlcAttestation>,
328+
}
329+
impl ::prost::Name for QueryAttestationByEventResponse {
330+
const NAME: &'static str = "QueryAttestationByEventResponse";
331+
const PACKAGE: &'static str = "side.dlc";
332+
fn full_name() -> ::prost::alloc::string::String {
333+
::prost::alloc::format!("side.dlc.{}", Self::NAME)
334+
}
335+
}
336+
#[allow(clippy::derive_partial_eq_without_eq)]
337+
#[derive(Clone, PartialEq, ::prost::Message)]
312338
pub struct QueryAttestationsRequest {
313339
#[prost(message, optional, tag = "1")]
314340
pub pagination: ::core::option::Option<super::super::cosmos::base::query::v1beta1::PageRequest>,

‎side-proto/src/prost/side/side.dlc.serde.rs

Lines changed: 213 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -3330,6 +3330,219 @@ impl<'de> serde::Deserialize<'de> for PriceInterval {
33303330
}
33313331
}
33323332
#[cfg(feature = "serde")]
3333+
impl serde::Serialize for QueryAttestationByEventRequest {
3334+
#[allow(deprecated)]
3335+
fn serialize<S>(&self, serializer: S) -> core::result::Result<S::Ok, S::Error>
3336+
where
3337+
S: serde::Serializer,
3338+
{
3339+
use serde::ser::SerializeStruct;
3340+
let mut len = 0;
3341+
if self.event_id != 0 {
3342+
len += 1;
3343+
}
3344+
let mut struct_ser =
3345+
serializer.serialize_struct("side.dlc.QueryAttestationByEventRequest", len)?;
3346+
if self.event_id != 0 {
3347+
#[allow(clippy::needless_borrow)]
3348+
struct_ser.serialize_field(
3349+
"eventId",
3350+
alloc::string::ToString::to_string(&self.event_id).as_str(),
3351+
)?;
3352+
}
3353+
struct_ser.end()
3354+
}
3355+
}
3356+
#[cfg(feature = "serde")]
3357+
impl<'de> serde::Deserialize<'de> for QueryAttestationByEventRequest {
3358+
#[allow(deprecated)]
3359+
fn deserialize<D>(deserializer: D) -> core::result::Result<Self, D::Error>
3360+
where
3361+
D: serde::Deserializer<'de>,
3362+
{
3363+
const FIELDS: &[&str] = &["event_id", "eventId"];
3364+
3365+
#[allow(clippy::enum_variant_names)]
3366+
enum GeneratedField {
3367+
EventId,
3368+
}
3369+
#[cfg(feature = "serde")]
3370+
impl<'de> serde::Deserialize<'de> for GeneratedField {
3371+
fn deserialize<D>(deserializer: D) -> core::result::Result<GeneratedField, D::Error>
3372+
where
3373+
D: serde::Deserializer<'de>,
3374+
{
3375+
struct GeneratedVisitor;
3376+
3377+
impl<'de> serde::de::Visitor<'de> for GeneratedVisitor {
3378+
type Value = GeneratedField;
3379+
3380+
fn expecting(
3381+
&self,
3382+
formatter: &mut core::fmt::Formatter<'_>,
3383+
) -> core::fmt::Result {
3384+
write!(formatter, "expected one of: {:?}", &FIELDS)
3385+
}
3386+
3387+
#[allow(unused_variables)]
3388+
fn visit_str<E>(self, value: &str) -> core::result::Result<GeneratedField, E>
3389+
where
3390+
E: serde::de::Error,
3391+
{
3392+
match value {
3393+
"eventId" | "event_id" => Ok(GeneratedField::EventId),
3394+
_ => Err(serde::de::Error::unknown_field(value, FIELDS)),
3395+
}
3396+
}
3397+
}
3398+
deserializer.deserialize_identifier(GeneratedVisitor)
3399+
}
3400+
}
3401+
struct GeneratedVisitor;
3402+
impl<'de> serde::de::Visitor<'de> for GeneratedVisitor {
3403+
type Value = QueryAttestationByEventRequest;
3404+
3405+
fn expecting(&self, formatter: &mut core::fmt::Formatter<'_>) -> core::fmt::Result {
3406+
formatter.write_str("struct side.dlc.QueryAttestationByEventRequest")
3407+
}
3408+
3409+
fn visit_map<V>(
3410+
self,
3411+
mut map_: V,
3412+
) -> core::result::Result<QueryAttestationByEventRequest, V::Error>
3413+
where
3414+
V: serde::de::MapAccess<'de>,
3415+
{
3416+
let mut event_id__ = None;
3417+
while let Some(k) = map_.next_key()? {
3418+
match k {
3419+
GeneratedField::EventId => {
3420+
if event_id__.is_some() {
3421+
return Err(serde::de::Error::duplicate_field("eventId"));
3422+
}
3423+
event_id__ = Some(
3424+
map_.next_value::<::pbjson::private::NumberDeserialize<_>>()?
3425+
.0,
3426+
);
3427+
}
3428+
}
3429+
}
3430+
Ok(QueryAttestationByEventRequest {
3431+
event_id: event_id__.unwrap_or_default(),
3432+
})
3433+
}
3434+
}
3435+
deserializer.deserialize_struct(
3436+
"side.dlc.QueryAttestationByEventRequest",
3437+
FIELDS,
3438+
GeneratedVisitor,
3439+
)
3440+
}
3441+
}
3442+
#[cfg(feature = "serde")]
3443+
impl serde::Serialize for QueryAttestationByEventResponse {
3444+
#[allow(deprecated)]
3445+
fn serialize<S>(&self, serializer: S) -> core::result::Result<S::Ok, S::Error>
3446+
where
3447+
S: serde::Serializer,
3448+
{
3449+
use serde::ser::SerializeStruct;
3450+
let mut len = 0;
3451+
if self.attestation.is_some() {
3452+
len += 1;
3453+
}
3454+
let mut struct_ser =
3455+
serializer.serialize_struct("side.dlc.QueryAttestationByEventResponse", len)?;
3456+
if let Some(v) = self.attestation.as_ref() {
3457+
struct_ser.serialize_field("attestation", v)?;
3458+
}
3459+
struct_ser.end()
3460+
}
3461+
}
3462+
#[cfg(feature = "serde")]
3463+
impl<'de> serde::Deserialize<'de> for QueryAttestationByEventResponse {
3464+
#[allow(deprecated)]
3465+
fn deserialize<D>(deserializer: D) -> core::result::Result<Self, D::Error>
3466+
where
3467+
D: serde::Deserializer<'de>,
3468+
{
3469+
const FIELDS: &[&str] = &["attestation"];
3470+
3471+
#[allow(clippy::enum_variant_names)]
3472+
enum GeneratedField {
3473+
Attestation,
3474+
}
3475+
#[cfg(feature = "serde")]
3476+
impl<'de> serde::Deserialize<'de> for GeneratedField {
3477+
fn deserialize<D>(deserializer: D) -> core::result::Result<GeneratedField, D::Error>
3478+
where
3479+
D: serde::Deserializer<'de>,
3480+
{
3481+
struct GeneratedVisitor;
3482+
3483+
impl<'de> serde::de::Visitor<'de> for GeneratedVisitor {
3484+
type Value = GeneratedField;
3485+
3486+
fn expecting(
3487+
&self,
3488+
formatter: &mut core::fmt::Formatter<'_>,
3489+
) -> core::fmt::Result {
3490+
write!(formatter, "expected one of: {:?}", &FIELDS)
3491+
}
3492+
3493+
#[allow(unused_variables)]
3494+
fn visit_str<E>(self, value: &str) -> core::result::Result<GeneratedField, E>
3495+
where
3496+
E: serde::de::Error,
3497+
{
3498+
match value {
3499+
"attestation" => Ok(GeneratedField::Attestation),
3500+
_ => Err(serde::de::Error::unknown_field(value, FIELDS)),
3501+
}
3502+
}
3503+
}
3504+
deserializer.deserialize_identifier(GeneratedVisitor)
3505+
}
3506+
}
3507+
struct GeneratedVisitor;
3508+
impl<'de> serde::de::Visitor<'de> for GeneratedVisitor {
3509+
type Value = QueryAttestationByEventResponse;
3510+
3511+
fn expecting(&self, formatter: &mut core::fmt::Formatter<'_>) -> core::fmt::Result {
3512+
formatter.write_str("struct side.dlc.QueryAttestationByEventResponse")
3513+
}
3514+
3515+
fn visit_map<V>(
3516+
self,
3517+
mut map_: V,
3518+
) -> core::result::Result<QueryAttestationByEventResponse, V::Error>
3519+
where
3520+
V: serde::de::MapAccess<'de>,
3521+
{
3522+
let mut attestation__ = None;
3523+
while let Some(k) = map_.next_key()? {
3524+
match k {
3525+
GeneratedField::Attestation => {
3526+
if attestation__.is_some() {
3527+
return Err(serde::de::Error::duplicate_field("attestation"));
3528+
}
3529+
attestation__ = map_.next_value()?;
3530+
}
3531+
}
3532+
}
3533+
Ok(QueryAttestationByEventResponse {
3534+
attestation: attestation__,
3535+
})
3536+
}
3537+
}
3538+
deserializer.deserialize_struct(
3539+
"side.dlc.QueryAttestationByEventResponse",
3540+
FIELDS,
3541+
GeneratedVisitor,
3542+
)
3543+
}
3544+
}
3545+
#[cfg(feature = "serde")]
33333546
impl serde::Serialize for QueryAttestationRequest {
33343547
#[allow(deprecated)]
33353548
fn serialize<S>(&self, serializer: S) -> core::result::Result<S::Ok, S::Error>

‎side-proto/src/prost/side/side.dlc.tonic.rs

Lines changed: 68 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -157,6 +157,26 @@ pub mod query_client {
157157
.insert(GrpcMethod::new("side.dlc.Query", "Attestation"));
158158
self.inner.unary(req, path, codec).await
159159
}
160+
pub async fn attestation_by_event(
161+
&mut self,
162+
request: impl tonic::IntoRequest<super::QueryAttestationByEventRequest>,
163+
) -> core::result::Result<
164+
tonic::Response<super::QueryAttestationByEventResponse>,
165+
tonic::Status,
166+
> {
167+
self.inner.ready().await.map_err(|e| {
168+
tonic::Status::new(
169+
tonic::Code::Unknown,
170+
alloc::format!("Service was not ready: {}", e.into()),
171+
)
172+
})?;
173+
let codec = tonic::codec::ProstCodec::default();
174+
let path = http::uri::PathAndQuery::from_static("/side.dlc.Query/AttestationByEvent");
175+
let mut req = request.into_request();
176+
req.extensions_mut()
177+
.insert(GrpcMethod::new("side.dlc.Query", "AttestationByEvent"));
178+
self.inner.unary(req, path, codec).await
179+
}
160180
pub async fn attestations(
161181
&mut self,
162182
request: impl tonic::IntoRequest<super::QueryAttestationsRequest>,
@@ -309,6 +329,13 @@ pub mod query_server {
309329
&self,
310330
request: tonic::Request<super::QueryAttestationRequest>,
311331
) -> core::result::Result<tonic::Response<super::QueryAttestationResponse>, tonic::Status>;
332+
async fn attestation_by_event(
333+
&self,
334+
request: tonic::Request<super::QueryAttestationByEventRequest>,
335+
) -> core::result::Result<
336+
tonic::Response<super::QueryAttestationByEventResponse>,
337+
tonic::Status,
338+
>;
312339
async fn attestations(
313340
&self,
314341
request: tonic::Request<super::QueryAttestationsRequest>,
@@ -566,6 +593,47 @@ pub mod query_server {
566593
};
567594
Box::pin(fut)
568595
}
596+
"/side.dlc.Query/AttestationByEvent" => {
597+
#[allow(non_camel_case_types)]
598+
struct AttestationByEventSvc<T: Query>(pub Arc<T>);
599+
impl<T: Query>
600+
tonic::server::UnaryService<super::QueryAttestationByEventRequest>
601+
for AttestationByEventSvc<T>
602+
{
603+
type Response = super::QueryAttestationByEventResponse;
604+
type Future = BoxFuture<tonic::Response<Self::Response>, tonic::Status>;
605+
fn call(
606+
&mut self,
607+
request: tonic::Request<super::QueryAttestationByEventRequest>,
608+
) -> Self::Future {
609+
let inner = Arc::clone(&self.0);
610+
let fut = async move { (*inner).attestation_by_event(request).await };
611+
Box::pin(fut)
612+
}
613+
}
614+
let accept_compression_encodings = self.accept_compression_encodings;
615+
let send_compression_encodings = self.send_compression_encodings;
616+
let max_decoding_message_size = self.max_decoding_message_size;
617+
let max_encoding_message_size = self.max_encoding_message_size;
618+
let inner = self.inner.clone();
619+
let fut = async move {
620+
let inner = inner.0;
621+
let method = AttestationByEventSvc(inner);
622+
let codec = tonic::codec::ProstCodec::default();
623+
let mut grpc = tonic::server::Grpc::new(codec)
624+
.apply_compression_config(
625+
accept_compression_encodings,
626+
send_compression_encodings,
627+
)
628+
.apply_max_message_size_config(
629+
max_decoding_message_size,
630+
max_encoding_message_size,
631+
);
632+
let res = grpc.unary(method, req).await;
633+
Ok(res)
634+
};
635+
Box::pin(fut)
636+
}
569637
"/side.dlc.Query/Attestations" => {
570638
#[allow(non_camel_case_types)]
571639
struct AttestationsSvc<T: Query>(pub Arc<T>);

0 commit comments

Comments
 (0)