pub mod button_led_session_service_client {
#![allow(
unused_variables,
dead_code,
missing_docs,
clippy::wildcard_imports,
clippy::let_unit_value,
)]
use tonic::codegen::*;
use tonic::codegen::http::Uri;
#[derive(Debug, Clone)]
pub struct ButtonLedSessionServiceClient<T> {
inner: tonic::client::Grpc<T>,
}
impl<T> ButtonLedSessionServiceClient<T>
where
T: tonic::client::GrpcService<tonic::body::Body>,
T::Error: Into<StdError>,
T::ResponseBody: Body<Data = Bytes> + std::marker::Send + 'static,
<T::ResponseBody as Body>::Error: Into<StdError> + std::marker::Send,
{
pub fn new(inner: T) -> Self {
let inner = tonic::client::Grpc::new(inner);
Self { inner }
}
pub fn with_origin(inner: T, origin: Uri) -> Self {
let inner = tonic::client::Grpc::with_origin(inner, origin);
Self { inner }
}
pub fn with_interceptor<F>(
inner: T,
interceptor: F,
) -> ButtonLedSessionServiceClient<InterceptedService<T, F>>
where
F: tonic::service::Interceptor,
T::ResponseBody: Default,
T: tonic::codegen::Service<
http::Request<tonic::body::Body>,
Response = http::Response<
<T as tonic::client::GrpcService<tonic::body::Body>>::ResponseBody,
>,
>,
<T as tonic::codegen::Service<
http::Request<tonic::body::Body>,
>>::Error: Into<StdError> + std::marker::Send + std::marker::Sync,
{
ButtonLedSessionServiceClient::new(
InterceptedService::new(inner, interceptor),
)
}
#[must_use]
pub fn send_compressed(mut self, encoding: CompressionEncoding) -> Self {
self.inner = self.inner.send_compressed(encoding);
self
}
#[must_use]
pub fn accept_compressed(mut self, encoding: CompressionEncoding) -> Self {
self.inner = self.inner.accept_compressed(encoding);
self
}
#[must_use]
pub fn max_decoding_message_size(mut self, limit: usize) -> Self {
self.inner = self.inner.max_decoding_message_size(limit);
self
}
#[must_use]
pub fn max_encoding_message_size(mut self, limit: usize) -> Self {
self.inner = self.inner.max_encoding_message_size(limit);
self
}
pub async fn connect(
&mut self,
request: impl tonic::IntoStreamingRequest<Message = super::LedStream>,
) -> std::result::Result<
tonic::Response<tonic::codec::Streaming<super::ButtonStream>>,
tonic::Status,
> {
self.inner
.ready()
.await
.map_err(|e| {
tonic::Status::unknown(
format!("Service was not ready: {}", e.into()),
)
})?;
let codec = tonic_prost::ProstCodec::default();
let path = http::uri::PathAndQuery::from_static(
"/cloud.lazycat.apis.sys.ButtonLedSessionService/Connect",
);
let mut req = request.into_streaming_request();
req.extensions_mut()
.insert(
GrpcMethod::new(
"cloud.lazycat.apis.sys.ButtonLedSessionService",
"Connect",
),
);
self.inner.streaming(req, path, codec).await
}
}
}
pub mod button_led_session_service_server {
#![allow(
unused_variables,
dead_code,
missing_docs,
clippy::wildcard_imports,
clippy::let_unit_value,
)]
use tonic::codegen::*;
#[async_trait]
pub trait ButtonLedSessionService: std::marker::Send + std::marker::Sync + 'static {
type ConnectStream: tonic::codegen::tokio_stream::Stream<
Item = std::result::Result<super::ButtonStream, tonic::Status>,
>
+ std::marker::Send
+ 'static;
async fn connect(
&self,
request: tonic::Request<tonic::Streaming<super::LedStream>>,
) -> std::result::Result<tonic::Response<Self::ConnectStream>, tonic::Status>;
}
#[derive(Debug)]
pub struct ButtonLedSessionServiceServer<T> {
inner: Arc<T>,
accept_compression_encodings: EnabledCompressionEncodings,
send_compression_encodings: EnabledCompressionEncodings,
max_decoding_message_size: Option<usize>,
max_encoding_message_size: Option<usize>,
}
impl<T> ButtonLedSessionServiceServer<T> {
pub fn new(inner: T) -> Self {
Self::from_arc(Arc::new(inner))
}
pub fn from_arc(inner: Arc<T>) -> Self {
Self {
inner,
accept_compression_encodings: Default::default(),
send_compression_encodings: Default::default(),
max_decoding_message_size: None,
max_encoding_message_size: None,
}
}
pub fn with_interceptor<F>(
inner: T,
interceptor: F,
) -> InterceptedService<Self, F>
where
F: tonic::service::Interceptor,
{
InterceptedService::new(Self::new(inner), interceptor)
}
#[must_use]
pub fn accept_compressed(mut self, encoding: CompressionEncoding) -> Self {
self.accept_compression_encodings.enable(encoding);
self
}
#[must_use]
pub fn send_compressed(mut self, encoding: CompressionEncoding) -> Self {
self.send_compression_encodings.enable(encoding);
self
}
#[must_use]
pub fn max_decoding_message_size(mut self, limit: usize) -> Self {
self.max_decoding_message_size = Some(limit);
self
}
#[must_use]
pub fn max_encoding_message_size(mut self, limit: usize) -> Self {
self.max_encoding_message_size = Some(limit);
self
}
}
impl<T, B> tonic::codegen::Service<http::Request<B>>
for ButtonLedSessionServiceServer<T>
where
T: ButtonLedSessionService,
B: Body + std::marker::Send + 'static,
B::Error: Into<StdError> + std::marker::Send + 'static,
{
type Response = http::Response<tonic::body::Body>;
type Error = std::convert::Infallible;
type Future = BoxFuture<Self::Response, Self::Error>;
fn poll_ready(
&mut self,
_cx: &mut Context<'_>,
) -> Poll<std::result::Result<(), Self::Error>> {
Poll::Ready(Ok(()))
}
fn call(&mut self, req: http::Request<B>) -> Self::Future {
match req.uri().path() {
"/cloud.lazycat.apis.sys.ButtonLedSessionService/Connect" => {
#[allow(non_camel_case_types)]
struct ConnectSvc<T: ButtonLedSessionService>(pub Arc<T>);
impl<
T: ButtonLedSessionService,
> tonic::server::StreamingService<super::LedStream>
for ConnectSvc<T> {
type Response = super::ButtonStream;
type ResponseStream = T::ConnectStream;
type Future = BoxFuture<
tonic::Response<Self::ResponseStream>,
tonic::Status,
>;
fn call(
&mut self,
request: tonic::Request<tonic::Streaming<super::LedStream>>,
) -> Self::Future {
let inner = Arc::clone(&self.0);
let fut = async move {
<T as ButtonLedSessionService>::connect(&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 method = ConnectSvc(inner);
let codec = tonic_prost::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.streaming(method, req).await;
Ok(res)
};
Box::pin(fut)
}
_ => {
Box::pin(async move {
let mut response = http::Response::new(
tonic::body::Body::default(),
);
let headers = response.headers_mut();
headers
.insert(
tonic::Status::GRPC_STATUS,
(tonic::Code::Unimplemented as i32).into(),
);
headers
.insert(
http::header::CONTENT_TYPE,
tonic::metadata::GRPC_CONTENT_TYPE,
);
Ok(response)
})
}
}
}
}
impl<T> Clone for ButtonLedSessionServiceServer<T> {
fn clone(&self) -> Self {
let inner = self.inner.clone();
Self {
inner,
accept_compression_encodings: self.accept_compression_encodings,
send_compression_encodings: self.send_compression_encodings,
max_decoding_message_size: self.max_decoding_message_size,
max_encoding_message_size: self.max_encoding_message_size,
}
}
}
pub const SERVICE_NAME: &str = "cloud.lazycat.apis.sys.ButtonLedSessionService";
impl<T> tonic::server::NamedService for ButtonLedSessionServiceServer<T> {
const NAME: &'static str = SERVICE_NAME;
}
}
pub mod btrfs_util_client {
#![allow(
unused_variables,
dead_code,
missing_docs,
clippy::wildcard_imports,
clippy::let_unit_value,
)]
use tonic::codegen::*;
use tonic::codegen::http::Uri;
#[derive(Debug, Clone)]
pub struct BtrfsUtilClient<T> {
inner: tonic::client::Grpc<T>,
}
impl<T> BtrfsUtilClient<T>
where
T: tonic::client::GrpcService<tonic::body::Body>,
T::Error: Into<StdError>,
T::ResponseBody: Body<Data = Bytes> + std::marker::Send + 'static,
<T::ResponseBody as Body>::Error: Into<StdError> + std::marker::Send,
{
pub fn new(inner: T) -> Self {
let inner = tonic::client::Grpc::new(inner);
Self { inner }
}
pub fn with_origin(inner: T, origin: Uri) -> Self {
let inner = tonic::client::Grpc::with_origin(inner, origin);
Self { inner }
}
pub fn with_interceptor<F>(
inner: T,
interceptor: F,
) -> BtrfsUtilClient<InterceptedService<T, F>>
where
F: tonic::service::Interceptor,
T::ResponseBody: Default,
T: tonic::codegen::Service<
http::Request<tonic::body::Body>,
Response = http::Response<
<T as tonic::client::GrpcService<tonic::body::Body>>::ResponseBody,
>,
>,
<T as tonic::codegen::Service<
http::Request<tonic::body::Body>,
>>::Error: Into<StdError> + std::marker::Send + std::marker::Sync,
{
BtrfsUtilClient::new(InterceptedService::new(inner, interceptor))
}
#[must_use]
pub fn send_compressed(mut self, encoding: CompressionEncoding) -> Self {
self.inner = self.inner.send_compressed(encoding);
self
}
#[must_use]
pub fn accept_compressed(mut self, encoding: CompressionEncoding) -> Self {
self.inner = self.inner.accept_compressed(encoding);
self
}
#[must_use]
pub fn max_decoding_message_size(mut self, limit: usize) -> Self {
self.inner = self.inner.max_decoding_message_size(limit);
self
}
#[must_use]
pub fn max_encoding_message_size(mut self, limit: usize) -> Self {
self.inner = self.inner.max_encoding_message_size(limit);
self
}
pub async fn subvol_create(
&mut self,
request: impl tonic::IntoRequest<super::BtrfsSubvolCreateRequest>,
) -> std::result::Result<tonic::Response<()>, tonic::Status> {
self.inner
.ready()
.await
.map_err(|e| {
tonic::Status::unknown(
format!("Service was not ready: {}", e.into()),
)
})?;
let codec = tonic_prost::ProstCodec::default();
let path = http::uri::PathAndQuery::from_static(
"/cloud.lazycat.apis.sys.BtrfsUtil/SubvolCreate",
);
let mut req = request.into_request();
req.extensions_mut()
.insert(
GrpcMethod::new("cloud.lazycat.apis.sys.BtrfsUtil", "SubvolCreate"),
);
self.inner.unary(req, path, codec).await
}
pub async fn subvol_info(
&mut self,
request: impl tonic::IntoRequest<super::BtrfsSubvolInfoRequest>,
) -> std::result::Result<
tonic::Response<super::BtrfsSubvolInfoResponse>,
tonic::Status,
> {
self.inner
.ready()
.await
.map_err(|e| {
tonic::Status::unknown(
format!("Service was not ready: {}", e.into()),
)
})?;
let codec = tonic_prost::ProstCodec::default();
let path = http::uri::PathAndQuery::from_static(
"/cloud.lazycat.apis.sys.BtrfsUtil/SubvolInfo",
);
let mut req = request.into_request();
req.extensions_mut()
.insert(
GrpcMethod::new("cloud.lazycat.apis.sys.BtrfsUtil", "SubvolInfo"),
);
self.inner.unary(req, path, codec).await
}
pub async fn subvol_find_new(
&mut self,
request: impl tonic::IntoRequest<super::BtrfsSubvolFindNewRequest>,
) -> std::result::Result<
tonic::Response<super::BtrfsSubvolFindNewResponse>,
tonic::Status,
> {
self.inner
.ready()
.await
.map_err(|e| {
tonic::Status::unknown(
format!("Service was not ready: {}", e.into()),
)
})?;
let codec = tonic_prost::ProstCodec::default();
let path = http::uri::PathAndQuery::from_static(
"/cloud.lazycat.apis.sys.BtrfsUtil/SubvolFindNew",
);
let mut req = request.into_request();
req.extensions_mut()
.insert(
GrpcMethod::new("cloud.lazycat.apis.sys.BtrfsUtil", "SubvolFindNew"),
);
self.inner.unary(req, path, codec).await
}
pub async fn rename(
&mut self,
request: impl tonic::IntoRequest<super::BtrfsRenameRequest>,
) -> std::result::Result<tonic::Response<()>, tonic::Status> {
self.inner
.ready()
.await
.map_err(|e| {
tonic::Status::unknown(
format!("Service was not ready: {}", e.into()),
)
})?;
let codec = tonic_prost::ProstCodec::default();
let path = http::uri::PathAndQuery::from_static(
"/cloud.lazycat.apis.sys.BtrfsUtil/Rename",
);
let mut req = request.into_request();
req.extensions_mut()
.insert(GrpcMethod::new("cloud.lazycat.apis.sys.BtrfsUtil", "Rename"));
self.inner.unary(req, path, codec).await
}
}
}
pub mod btrfs_util_server {
#![allow(
unused_variables,
dead_code,
missing_docs,
clippy::wildcard_imports,
clippy::let_unit_value,
)]
use tonic::codegen::*;
#[async_trait]
pub trait BtrfsUtil: std::marker::Send + std::marker::Sync + 'static {
async fn subvol_create(
&self,
request: tonic::Request<super::BtrfsSubvolCreateRequest>,
) -> std::result::Result<tonic::Response<()>, tonic::Status>;
async fn subvol_info(
&self,
request: tonic::Request<super::BtrfsSubvolInfoRequest>,
) -> std::result::Result<
tonic::Response<super::BtrfsSubvolInfoResponse>,
tonic::Status,
>;
async fn subvol_find_new(
&self,
request: tonic::Request<super::BtrfsSubvolFindNewRequest>,
) -> std::result::Result<
tonic::Response<super::BtrfsSubvolFindNewResponse>,
tonic::Status,
>;
async fn rename(
&self,
request: tonic::Request<super::BtrfsRenameRequest>,
) -> std::result::Result<tonic::Response<()>, tonic::Status>;
}
#[derive(Debug)]
pub struct BtrfsUtilServer<T> {
inner: Arc<T>,
accept_compression_encodings: EnabledCompressionEncodings,
send_compression_encodings: EnabledCompressionEncodings,
max_decoding_message_size: Option<usize>,
max_encoding_message_size: Option<usize>,
}
impl<T> BtrfsUtilServer<T> {
pub fn new(inner: T) -> Self {
Self::from_arc(Arc::new(inner))
}
pub fn from_arc(inner: Arc<T>) -> Self {
Self {
inner,
accept_compression_encodings: Default::default(),
send_compression_encodings: Default::default(),
max_decoding_message_size: None,
max_encoding_message_size: None,
}
}
pub fn with_interceptor<F>(
inner: T,
interceptor: F,
) -> InterceptedService<Self, F>
where
F: tonic::service::Interceptor,
{
InterceptedService::new(Self::new(inner), interceptor)
}
#[must_use]
pub fn accept_compressed(mut self, encoding: CompressionEncoding) -> Self {
self.accept_compression_encodings.enable(encoding);
self
}
#[must_use]
pub fn send_compressed(mut self, encoding: CompressionEncoding) -> Self {
self.send_compression_encodings.enable(encoding);
self
}
#[must_use]
pub fn max_decoding_message_size(mut self, limit: usize) -> Self {
self.max_decoding_message_size = Some(limit);
self
}
#[must_use]
pub fn max_encoding_message_size(mut self, limit: usize) -> Self {
self.max_encoding_message_size = Some(limit);
self
}
}
impl<T, B> tonic::codegen::Service<http::Request<B>> for BtrfsUtilServer<T>
where
T: BtrfsUtil,
B: Body + std::marker::Send + 'static,
B::Error: Into<StdError> + std::marker::Send + 'static,
{
type Response = http::Response<tonic::body::Body>;
type Error = std::convert::Infallible;
type Future = BoxFuture<Self::Response, Self::Error>;
fn poll_ready(
&mut self,
_cx: &mut Context<'_>,
) -> Poll<std::result::Result<(), Self::Error>> {
Poll::Ready(Ok(()))
}
fn call(&mut self, req: http::Request<B>) -> Self::Future {
match req.uri().path() {
"/cloud.lazycat.apis.sys.BtrfsUtil/SubvolCreate" => {
#[allow(non_camel_case_types)]
struct SubvolCreateSvc<T: BtrfsUtil>(pub Arc<T>);
impl<
T: BtrfsUtil,
> tonic::server::UnaryService<super::BtrfsSubvolCreateRequest>
for SubvolCreateSvc<T> {
type Response = ();
type Future = BoxFuture<
tonic::Response<Self::Response>,
tonic::Status,
>;
fn call(
&mut self,
request: tonic::Request<super::BtrfsSubvolCreateRequest>,
) -> Self::Future {
let inner = Arc::clone(&self.0);
let fut = async move {
<T as BtrfsUtil>::subvol_create(&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 method = SubvolCreateSvc(inner);
let codec = tonic_prost::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)
}
"/cloud.lazycat.apis.sys.BtrfsUtil/SubvolInfo" => {
#[allow(non_camel_case_types)]
struct SubvolInfoSvc<T: BtrfsUtil>(pub Arc<T>);
impl<
T: BtrfsUtil,
> tonic::server::UnaryService<super::BtrfsSubvolInfoRequest>
for SubvolInfoSvc<T> {
type Response = super::BtrfsSubvolInfoResponse;
type Future = BoxFuture<
tonic::Response<Self::Response>,
tonic::Status,
>;
fn call(
&mut self,
request: tonic::Request<super::BtrfsSubvolInfoRequest>,
) -> Self::Future {
let inner = Arc::clone(&self.0);
let fut = async move {
<T as BtrfsUtil>::subvol_info(&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 method = SubvolInfoSvc(inner);
let codec = tonic_prost::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)
}
"/cloud.lazycat.apis.sys.BtrfsUtil/SubvolFindNew" => {
#[allow(non_camel_case_types)]
struct SubvolFindNewSvc<T: BtrfsUtil>(pub Arc<T>);
impl<
T: BtrfsUtil,
> tonic::server::UnaryService<super::BtrfsSubvolFindNewRequest>
for SubvolFindNewSvc<T> {
type Response = super::BtrfsSubvolFindNewResponse;
type Future = BoxFuture<
tonic::Response<Self::Response>,
tonic::Status,
>;
fn call(
&mut self,
request: tonic::Request<super::BtrfsSubvolFindNewRequest>,
) -> Self::Future {
let inner = Arc::clone(&self.0);
let fut = async move {
<T as BtrfsUtil>::subvol_find_new(&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 method = SubvolFindNewSvc(inner);
let codec = tonic_prost::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)
}
"/cloud.lazycat.apis.sys.BtrfsUtil/Rename" => {
#[allow(non_camel_case_types)]
struct RenameSvc<T: BtrfsUtil>(pub Arc<T>);
impl<
T: BtrfsUtil,
> tonic::server::UnaryService<super::BtrfsRenameRequest>
for RenameSvc<T> {
type Response = ();
type Future = BoxFuture<
tonic::Response<Self::Response>,
tonic::Status,
>;
fn call(
&mut self,
request: tonic::Request<super::BtrfsRenameRequest>,
) -> Self::Future {
let inner = Arc::clone(&self.0);
let fut = async move {
<T as BtrfsUtil>::rename(&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 method = RenameSvc(inner);
let codec = tonic_prost::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 {
let mut response = http::Response::new(
tonic::body::Body::default(),
);
let headers = response.headers_mut();
headers
.insert(
tonic::Status::GRPC_STATUS,
(tonic::Code::Unimplemented as i32).into(),
);
headers
.insert(
http::header::CONTENT_TYPE,
tonic::metadata::GRPC_CONTENT_TYPE,
);
Ok(response)
})
}
}
}
}
impl<T> Clone for BtrfsUtilServer<T> {
fn clone(&self) -> Self {
let inner = self.inner.clone();
Self {
inner,
accept_compression_encodings: self.accept_compression_encodings,
send_compression_encodings: self.send_compression_encodings,
max_decoding_message_size: self.max_decoding_message_size,
max_encoding_message_size: self.max_encoding_message_size,
}
}
}
pub const SERVICE_NAME: &str = "cloud.lazycat.apis.sys.BtrfsUtil";
impl<T> tonic::server::NamedService for BtrfsUtilServer<T> {
const NAME: &'static str = SERVICE_NAME;
}
}
pub mod dev_opt_service_client {
#![allow(
unused_variables,
dead_code,
missing_docs,
clippy::wildcard_imports,
clippy::let_unit_value,
)]
use tonic::codegen::*;
use tonic::codegen::http::Uri;
#[derive(Debug, Clone)]
pub struct DevOptServiceClient<T> {
inner: tonic::client::Grpc<T>,
}
impl<T> DevOptServiceClient<T>
where
T: tonic::client::GrpcService<tonic::body::Body>,
T::Error: Into<StdError>,
T::ResponseBody: Body<Data = Bytes> + std::marker::Send + 'static,
<T::ResponseBody as Body>::Error: Into<StdError> + std::marker::Send,
{
pub fn new(inner: T) -> Self {
let inner = tonic::client::Grpc::new(inner);
Self { inner }
}
pub fn with_origin(inner: T, origin: Uri) -> Self {
let inner = tonic::client::Grpc::with_origin(inner, origin);
Self { inner }
}
pub fn with_interceptor<F>(
inner: T,
interceptor: F,
) -> DevOptServiceClient<InterceptedService<T, F>>
where
F: tonic::service::Interceptor,
T::ResponseBody: Default,
T: tonic::codegen::Service<
http::Request<tonic::body::Body>,
Response = http::Response<
<T as tonic::client::GrpcService<tonic::body::Body>>::ResponseBody,
>,
>,
<T as tonic::codegen::Service<
http::Request<tonic::body::Body>,
>>::Error: Into<StdError> + std::marker::Send + std::marker::Sync,
{
DevOptServiceClient::new(InterceptedService::new(inner, interceptor))
}
#[must_use]
pub fn send_compressed(mut self, encoding: CompressionEncoding) -> Self {
self.inner = self.inner.send_compressed(encoding);
self
}
#[must_use]
pub fn accept_compressed(mut self, encoding: CompressionEncoding) -> Self {
self.inner = self.inner.accept_compressed(encoding);
self
}
#[must_use]
pub fn max_decoding_message_size(mut self, limit: usize) -> Self {
self.inner = self.inner.max_decoding_message_size(limit);
self
}
#[must_use]
pub fn max_encoding_message_size(mut self, limit: usize) -> Self {
self.inner = self.inner.max_encoding_message_size(limit);
self
}
pub async fn sshd_enable(
&mut self,
request: impl tonic::IntoRequest<super::SshdEnableRequest>,
) -> std::result::Result<tonic::Response<()>, tonic::Status> {
self.inner
.ready()
.await
.map_err(|e| {
tonic::Status::unknown(
format!("Service was not ready: {}", e.into()),
)
})?;
let codec = tonic_prost::ProstCodec::default();
let path = http::uri::PathAndQuery::from_static(
"/cloud.lazycat.apis.sys.DevOptService/SshdEnable",
);
let mut req = request.into_request();
req.extensions_mut()
.insert(
GrpcMethod::new("cloud.lazycat.apis.sys.DevOptService", "SshdEnable"),
);
self.inner.unary(req, path, codec).await
}
pub async fn sshd_enabled(
&mut self,
request: impl tonic::IntoRequest<()>,
) -> std::result::Result<
tonic::Response<super::EnableSshdResponse>,
tonic::Status,
> {
self.inner
.ready()
.await
.map_err(|e| {
tonic::Status::unknown(
format!("Service was not ready: {}", e.into()),
)
})?;
let codec = tonic_prost::ProstCodec::default();
let path = http::uri::PathAndQuery::from_static(
"/cloud.lazycat.apis.sys.DevOptService/SshdEnabled",
);
let mut req = request.into_request();
req.extensions_mut()
.insert(
GrpcMethod::new(
"cloud.lazycat.apis.sys.DevOptService",
"SshdEnabled",
),
);
self.inner.unary(req, path, codec).await
}
}
}
pub mod dev_opt_service_server {
#![allow(
unused_variables,
dead_code,
missing_docs,
clippy::wildcard_imports,
clippy::let_unit_value,
)]
use tonic::codegen::*;
#[async_trait]
pub trait DevOptService: std::marker::Send + std::marker::Sync + 'static {
async fn sshd_enable(
&self,
request: tonic::Request<super::SshdEnableRequest>,
) -> std::result::Result<tonic::Response<()>, tonic::Status>;
async fn sshd_enabled(
&self,
request: tonic::Request<()>,
) -> std::result::Result<
tonic::Response<super::EnableSshdResponse>,
tonic::Status,
>;
}
#[derive(Debug)]
pub struct DevOptServiceServer<T> {
inner: Arc<T>,
accept_compression_encodings: EnabledCompressionEncodings,
send_compression_encodings: EnabledCompressionEncodings,
max_decoding_message_size: Option<usize>,
max_encoding_message_size: Option<usize>,
}
impl<T> DevOptServiceServer<T> {
pub fn new(inner: T) -> Self {
Self::from_arc(Arc::new(inner))
}
pub fn from_arc(inner: Arc<T>) -> Self {
Self {
inner,
accept_compression_encodings: Default::default(),
send_compression_encodings: Default::default(),
max_decoding_message_size: None,
max_encoding_message_size: None,
}
}
pub fn with_interceptor<F>(
inner: T,
interceptor: F,
) -> InterceptedService<Self, F>
where
F: tonic::service::Interceptor,
{
InterceptedService::new(Self::new(inner), interceptor)
}
#[must_use]
pub fn accept_compressed(mut self, encoding: CompressionEncoding) -> Self {
self.accept_compression_encodings.enable(encoding);
self
}
#[must_use]
pub fn send_compressed(mut self, encoding: CompressionEncoding) -> Self {
self.send_compression_encodings.enable(encoding);
self
}
#[must_use]
pub fn max_decoding_message_size(mut self, limit: usize) -> Self {
self.max_decoding_message_size = Some(limit);
self
}
#[must_use]
pub fn max_encoding_message_size(mut self, limit: usize) -> Self {
self.max_encoding_message_size = Some(limit);
self
}
}
impl<T, B> tonic::codegen::Service<http::Request<B>> for DevOptServiceServer<T>
where
T: DevOptService,
B: Body + std::marker::Send + 'static,
B::Error: Into<StdError> + std::marker::Send + 'static,
{
type Response = http::Response<tonic::body::Body>;
type Error = std::convert::Infallible;
type Future = BoxFuture<Self::Response, Self::Error>;
fn poll_ready(
&mut self,
_cx: &mut Context<'_>,
) -> Poll<std::result::Result<(), Self::Error>> {
Poll::Ready(Ok(()))
}
fn call(&mut self, req: http::Request<B>) -> Self::Future {
match req.uri().path() {
"/cloud.lazycat.apis.sys.DevOptService/SshdEnable" => {
#[allow(non_camel_case_types)]
struct SshdEnableSvc<T: DevOptService>(pub Arc<T>);
impl<
T: DevOptService,
> tonic::server::UnaryService<super::SshdEnableRequest>
for SshdEnableSvc<T> {
type Response = ();
type Future = BoxFuture<
tonic::Response<Self::Response>,
tonic::Status,
>;
fn call(
&mut self,
request: tonic::Request<super::SshdEnableRequest>,
) -> Self::Future {
let inner = Arc::clone(&self.0);
let fut = async move {
<T as DevOptService>::sshd_enable(&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 method = SshdEnableSvc(inner);
let codec = tonic_prost::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)
}
"/cloud.lazycat.apis.sys.DevOptService/SshdEnabled" => {
#[allow(non_camel_case_types)]
struct SshdEnabledSvc<T: DevOptService>(pub Arc<T>);
impl<T: DevOptService> tonic::server::UnaryService<()>
for SshdEnabledSvc<T> {
type Response = super::EnableSshdResponse;
type Future = BoxFuture<
tonic::Response<Self::Response>,
tonic::Status,
>;
fn call(&mut self, request: tonic::Request<()>) -> Self::Future {
let inner = Arc::clone(&self.0);
let fut = async move {
<T as DevOptService>::sshd_enabled(&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 method = SshdEnabledSvc(inner);
let codec = tonic_prost::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 {
let mut response = http::Response::new(
tonic::body::Body::default(),
);
let headers = response.headers_mut();
headers
.insert(
tonic::Status::GRPC_STATUS,
(tonic::Code::Unimplemented as i32).into(),
);
headers
.insert(
http::header::CONTENT_TYPE,
tonic::metadata::GRPC_CONTENT_TYPE,
);
Ok(response)
})
}
}
}
}
impl<T> Clone for DevOptServiceServer<T> {
fn clone(&self) -> Self {
let inner = self.inner.clone();
Self {
inner,
accept_compression_encodings: self.accept_compression_encodings,
send_compression_encodings: self.send_compression_encodings,
max_decoding_message_size: self.max_decoding_message_size,
max_encoding_message_size: self.max_encoding_message_size,
}
}
}
pub const SERVICE_NAME: &str = "cloud.lazycat.apis.sys.DevOptService";
impl<T> tonic::server::NamedService for DevOptServiceServer<T> {
const NAME: &'static str = SERVICE_NAME;
}
}
pub mod dir_monitor_client {
#![allow(
unused_variables,
dead_code,
missing_docs,
clippy::wildcard_imports,
clippy::let_unit_value,
)]
use tonic::codegen::*;
use tonic::codegen::http::Uri;
#[derive(Debug, Clone)]
pub struct DirMonitorClient<T> {
inner: tonic::client::Grpc<T>,
}
impl<T> DirMonitorClient<T>
where
T: tonic::client::GrpcService<tonic::body::Body>,
T::Error: Into<StdError>,
T::ResponseBody: Body<Data = Bytes> + std::marker::Send + 'static,
<T::ResponseBody as Body>::Error: Into<StdError> + std::marker::Send,
{
pub fn new(inner: T) -> Self {
let inner = tonic::client::Grpc::new(inner);
Self { inner }
}
pub fn with_origin(inner: T, origin: Uri) -> Self {
let inner = tonic::client::Grpc::with_origin(inner, origin);
Self { inner }
}
pub fn with_interceptor<F>(
inner: T,
interceptor: F,
) -> DirMonitorClient<InterceptedService<T, F>>
where
F: tonic::service::Interceptor,
T::ResponseBody: Default,
T: tonic::codegen::Service<
http::Request<tonic::body::Body>,
Response = http::Response<
<T as tonic::client::GrpcService<tonic::body::Body>>::ResponseBody,
>,
>,
<T as tonic::codegen::Service<
http::Request<tonic::body::Body>,
>>::Error: Into<StdError> + std::marker::Send + std::marker::Sync,
{
DirMonitorClient::new(InterceptedService::new(inner, interceptor))
}
#[must_use]
pub fn send_compressed(mut self, encoding: CompressionEncoding) -> Self {
self.inner = self.inner.send_compressed(encoding);
self
}
#[must_use]
pub fn accept_compressed(mut self, encoding: CompressionEncoding) -> Self {
self.inner = self.inner.accept_compressed(encoding);
self
}
#[must_use]
pub fn max_decoding_message_size(mut self, limit: usize) -> Self {
self.inner = self.inner.max_decoding_message_size(limit);
self
}
#[must_use]
pub fn max_encoding_message_size(mut self, limit: usize) -> Self {
self.inner = self.inner.max_encoding_message_size(limit);
self
}
pub async fn find_new(
&mut self,
request: impl tonic::IntoRequest<super::DirMonitorFindNewRequest>,
) -> std::result::Result<
tonic::Response<super::DirMonitorFindNewResponse>,
tonic::Status,
> {
self.inner
.ready()
.await
.map_err(|e| {
tonic::Status::unknown(
format!("Service was not ready: {}", e.into()),
)
})?;
let codec = tonic_prost::ProstCodec::default();
let path = http::uri::PathAndQuery::from_static(
"/cloud.lazycat.apis.sys.DirMonitor/FindNew",
);
let mut req = request.into_request();
req.extensions_mut()
.insert(GrpcMethod::new("cloud.lazycat.apis.sys.DirMonitor", "FindNew"));
self.inner.unary(req, path, codec).await
}
pub async fn find_new_stream(
&mut self,
request: impl tonic::IntoRequest<super::DirMonitorFindNewRequest>,
) -> std::result::Result<
tonic::Response<tonic::codec::Streaming<super::StreamDirMonitorFindNewResp>>,
tonic::Status,
> {
self.inner
.ready()
.await
.map_err(|e| {
tonic::Status::unknown(
format!("Service was not ready: {}", e.into()),
)
})?;
let codec = tonic_prost::ProstCodec::default();
let path = http::uri::PathAndQuery::from_static(
"/cloud.lazycat.apis.sys.DirMonitor/FindNewStream",
);
let mut req = request.into_request();
req.extensions_mut()
.insert(
GrpcMethod::new("cloud.lazycat.apis.sys.DirMonitor", "FindNewStream"),
);
self.inner.server_streaming(req, path, codec).await
}
}
}
pub mod dir_monitor_server {
#![allow(
unused_variables,
dead_code,
missing_docs,
clippy::wildcard_imports,
clippy::let_unit_value,
)]
use tonic::codegen::*;
#[async_trait]
pub trait DirMonitor: std::marker::Send + std::marker::Sync + 'static {
async fn find_new(
&self,
request: tonic::Request<super::DirMonitorFindNewRequest>,
) -> std::result::Result<
tonic::Response<super::DirMonitorFindNewResponse>,
tonic::Status,
>;
type FindNewStreamStream: tonic::codegen::tokio_stream::Stream<
Item = std::result::Result<
super::StreamDirMonitorFindNewResp,
tonic::Status,
>,
>
+ std::marker::Send
+ 'static;
async fn find_new_stream(
&self,
request: tonic::Request<super::DirMonitorFindNewRequest>,
) -> std::result::Result<
tonic::Response<Self::FindNewStreamStream>,
tonic::Status,
>;
}
#[derive(Debug)]
pub struct DirMonitorServer<T> {
inner: Arc<T>,
accept_compression_encodings: EnabledCompressionEncodings,
send_compression_encodings: EnabledCompressionEncodings,
max_decoding_message_size: Option<usize>,
max_encoding_message_size: Option<usize>,
}
impl<T> DirMonitorServer<T> {
pub fn new(inner: T) -> Self {
Self::from_arc(Arc::new(inner))
}
pub fn from_arc(inner: Arc<T>) -> Self {
Self {
inner,
accept_compression_encodings: Default::default(),
send_compression_encodings: Default::default(),
max_decoding_message_size: None,
max_encoding_message_size: None,
}
}
pub fn with_interceptor<F>(
inner: T,
interceptor: F,
) -> InterceptedService<Self, F>
where
F: tonic::service::Interceptor,
{
InterceptedService::new(Self::new(inner), interceptor)
}
#[must_use]
pub fn accept_compressed(mut self, encoding: CompressionEncoding) -> Self {
self.accept_compression_encodings.enable(encoding);
self
}
#[must_use]
pub fn send_compressed(mut self, encoding: CompressionEncoding) -> Self {
self.send_compression_encodings.enable(encoding);
self
}
#[must_use]
pub fn max_decoding_message_size(mut self, limit: usize) -> Self {
self.max_decoding_message_size = Some(limit);
self
}
#[must_use]
pub fn max_encoding_message_size(mut self, limit: usize) -> Self {
self.max_encoding_message_size = Some(limit);
self
}
}
impl<T, B> tonic::codegen::Service<http::Request<B>> for DirMonitorServer<T>
where
T: DirMonitor,
B: Body + std::marker::Send + 'static,
B::Error: Into<StdError> + std::marker::Send + 'static,
{
type Response = http::Response<tonic::body::Body>;
type Error = std::convert::Infallible;
type Future = BoxFuture<Self::Response, Self::Error>;
fn poll_ready(
&mut self,
_cx: &mut Context<'_>,
) -> Poll<std::result::Result<(), Self::Error>> {
Poll::Ready(Ok(()))
}
fn call(&mut self, req: http::Request<B>) -> Self::Future {
match req.uri().path() {
"/cloud.lazycat.apis.sys.DirMonitor/FindNew" => {
#[allow(non_camel_case_types)]
struct FindNewSvc<T: DirMonitor>(pub Arc<T>);
impl<
T: DirMonitor,
> tonic::server::UnaryService<super::DirMonitorFindNewRequest>
for FindNewSvc<T> {
type Response = super::DirMonitorFindNewResponse;
type Future = BoxFuture<
tonic::Response<Self::Response>,
tonic::Status,
>;
fn call(
&mut self,
request: tonic::Request<super::DirMonitorFindNewRequest>,
) -> Self::Future {
let inner = Arc::clone(&self.0);
let fut = async move {
<T as DirMonitor>::find_new(&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 method = FindNewSvc(inner);
let codec = tonic_prost::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)
}
"/cloud.lazycat.apis.sys.DirMonitor/FindNewStream" => {
#[allow(non_camel_case_types)]
struct FindNewStreamSvc<T: DirMonitor>(pub Arc<T>);
impl<
T: DirMonitor,
> tonic::server::ServerStreamingService<
super::DirMonitorFindNewRequest,
> for FindNewStreamSvc<T> {
type Response = super::StreamDirMonitorFindNewResp;
type ResponseStream = T::FindNewStreamStream;
type Future = BoxFuture<
tonic::Response<Self::ResponseStream>,
tonic::Status,
>;
fn call(
&mut self,
request: tonic::Request<super::DirMonitorFindNewRequest>,
) -> Self::Future {
let inner = Arc::clone(&self.0);
let fut = async move {
<T as DirMonitor>::find_new_stream(&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 method = FindNewStreamSvc(inner);
let codec = tonic_prost::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.server_streaming(method, req).await;
Ok(res)
};
Box::pin(fut)
}
_ => {
Box::pin(async move {
let mut response = http::Response::new(
tonic::body::Body::default(),
);
let headers = response.headers_mut();
headers
.insert(
tonic::Status::GRPC_STATUS,
(tonic::Code::Unimplemented as i32).into(),
);
headers
.insert(
http::header::CONTENT_TYPE,
tonic::metadata::GRPC_CONTENT_TYPE,
);
Ok(response)
})
}
}
}
}
impl<T> Clone for DirMonitorServer<T> {
fn clone(&self) -> Self {
let inner = self.inner.clone();
Self {
inner,
accept_compression_encodings: self.accept_compression_encodings,
send_compression_encodings: self.send_compression_encodings,
max_decoding_message_size: self.max_decoding_message_size,
max_encoding_message_size: self.max_encoding_message_size,
}
}
}
pub const SERVICE_NAME: &str = "cloud.lazycat.apis.sys.DirMonitor";
impl<T> tonic::server::NamedService for DirMonitorServer<T> {
const NAME: &'static str = SERVICE_NAME;
}
}
pub mod event_service_client {
#![allow(
unused_variables,
dead_code,
missing_docs,
clippy::wildcard_imports,
clippy::let_unit_value,
)]
use tonic::codegen::*;
use tonic::codegen::http::Uri;
#[derive(Debug, Clone)]
pub struct EventServiceClient<T> {
inner: tonic::client::Grpc<T>,
}
impl<T> EventServiceClient<T>
where
T: tonic::client::GrpcService<tonic::body::Body>,
T::Error: Into<StdError>,
T::ResponseBody: Body<Data = Bytes> + std::marker::Send + 'static,
<T::ResponseBody as Body>::Error: Into<StdError> + std::marker::Send,
{
pub fn new(inner: T) -> Self {
let inner = tonic::client::Grpc::new(inner);
Self { inner }
}
pub fn with_origin(inner: T, origin: Uri) -> Self {
let inner = tonic::client::Grpc::with_origin(inner, origin);
Self { inner }
}
pub fn with_interceptor<F>(
inner: T,
interceptor: F,
) -> EventServiceClient<InterceptedService<T, F>>
where
F: tonic::service::Interceptor,
T::ResponseBody: Default,
T: tonic::codegen::Service<
http::Request<tonic::body::Body>,
Response = http::Response<
<T as tonic::client::GrpcService<tonic::body::Body>>::ResponseBody,
>,
>,
<T as tonic::codegen::Service<
http::Request<tonic::body::Body>,
>>::Error: Into<StdError> + std::marker::Send + std::marker::Sync,
{
EventServiceClient::new(InterceptedService::new(inner, interceptor))
}
#[must_use]
pub fn send_compressed(mut self, encoding: CompressionEncoding) -> Self {
self.inner = self.inner.send_compressed(encoding);
self
}
#[must_use]
pub fn accept_compressed(mut self, encoding: CompressionEncoding) -> Self {
self.inner = self.inner.accept_compressed(encoding);
self
}
#[must_use]
pub fn max_decoding_message_size(mut self, limit: usize) -> Self {
self.inner = self.inner.max_decoding_message_size(limit);
self
}
#[must_use]
pub fn max_encoding_message_size(mut self, limit: usize) -> Self {
self.inner = self.inner.max_encoding_message_size(limit);
self
}
pub async fn subscribe(
&mut self,
request: impl tonic::IntoRequest<super::SubscribeRequest>,
) -> std::result::Result<
tonic::Response<tonic::codec::Streaming<super::Event>>,
tonic::Status,
> {
self.inner
.ready()
.await
.map_err(|e| {
tonic::Status::unknown(
format!("Service was not ready: {}", e.into()),
)
})?;
let codec = tonic_prost::ProstCodec::default();
let path = http::uri::PathAndQuery::from_static(
"/cloud.lazycat.apis.sys.EventService/Subscribe",
);
let mut req = request.into_request();
req.extensions_mut()
.insert(
GrpcMethod::new("cloud.lazycat.apis.sys.EventService", "Subscribe"),
);
self.inner.server_streaming(req, path, codec).await
}
pub async fn send(
&mut self,
request: impl tonic::IntoRequest<super::SendRequest>,
) -> std::result::Result<tonic::Response<()>, tonic::Status> {
self.inner
.ready()
.await
.map_err(|e| {
tonic::Status::unknown(
format!("Service was not ready: {}", e.into()),
)
})?;
let codec = tonic_prost::ProstCodec::default();
let path = http::uri::PathAndQuery::from_static(
"/cloud.lazycat.apis.sys.EventService/Send",
);
let mut req = request.into_request();
req.extensions_mut()
.insert(GrpcMethod::new("cloud.lazycat.apis.sys.EventService", "Send"));
self.inner.unary(req, path, codec).await
}
}
}
pub mod event_service_server {
#![allow(
unused_variables,
dead_code,
missing_docs,
clippy::wildcard_imports,
clippy::let_unit_value,
)]
use tonic::codegen::*;
#[async_trait]
pub trait EventService: std::marker::Send + std::marker::Sync + 'static {
type SubscribeStream: tonic::codegen::tokio_stream::Stream<
Item = std::result::Result<super::Event, tonic::Status>,
>
+ std::marker::Send
+ 'static;
async fn subscribe(
&self,
request: tonic::Request<super::SubscribeRequest>,
) -> std::result::Result<tonic::Response<Self::SubscribeStream>, tonic::Status>;
async fn send(
&self,
request: tonic::Request<super::SendRequest>,
) -> std::result::Result<tonic::Response<()>, tonic::Status>;
}
#[derive(Debug)]
pub struct EventServiceServer<T> {
inner: Arc<T>,
accept_compression_encodings: EnabledCompressionEncodings,
send_compression_encodings: EnabledCompressionEncodings,
max_decoding_message_size: Option<usize>,
max_encoding_message_size: Option<usize>,
}
impl<T> EventServiceServer<T> {
pub fn new(inner: T) -> Self {
Self::from_arc(Arc::new(inner))
}
pub fn from_arc(inner: Arc<T>) -> Self {
Self {
inner,
accept_compression_encodings: Default::default(),
send_compression_encodings: Default::default(),
max_decoding_message_size: None,
max_encoding_message_size: None,
}
}
pub fn with_interceptor<F>(
inner: T,
interceptor: F,
) -> InterceptedService<Self, F>
where
F: tonic::service::Interceptor,
{
InterceptedService::new(Self::new(inner), interceptor)
}
#[must_use]
pub fn accept_compressed(mut self, encoding: CompressionEncoding) -> Self {
self.accept_compression_encodings.enable(encoding);
self
}
#[must_use]
pub fn send_compressed(mut self, encoding: CompressionEncoding) -> Self {
self.send_compression_encodings.enable(encoding);
self
}
#[must_use]
pub fn max_decoding_message_size(mut self, limit: usize) -> Self {
self.max_decoding_message_size = Some(limit);
self
}
#[must_use]
pub fn max_encoding_message_size(mut self, limit: usize) -> Self {
self.max_encoding_message_size = Some(limit);
self
}
}
impl<T, B> tonic::codegen::Service<http::Request<B>> for EventServiceServer<T>
where
T: EventService,
B: Body + std::marker::Send + 'static,
B::Error: Into<StdError> + std::marker::Send + 'static,
{
type Response = http::Response<tonic::body::Body>;
type Error = std::convert::Infallible;
type Future = BoxFuture<Self::Response, Self::Error>;
fn poll_ready(
&mut self,
_cx: &mut Context<'_>,
) -> Poll<std::result::Result<(), Self::Error>> {
Poll::Ready(Ok(()))
}
fn call(&mut self, req: http::Request<B>) -> Self::Future {
match req.uri().path() {
"/cloud.lazycat.apis.sys.EventService/Subscribe" => {
#[allow(non_camel_case_types)]
struct SubscribeSvc<T: EventService>(pub Arc<T>);
impl<
T: EventService,
> tonic::server::ServerStreamingService<super::SubscribeRequest>
for SubscribeSvc<T> {
type Response = super::Event;
type ResponseStream = T::SubscribeStream;
type Future = BoxFuture<
tonic::Response<Self::ResponseStream>,
tonic::Status,
>;
fn call(
&mut self,
request: tonic::Request<super::SubscribeRequest>,
) -> Self::Future {
let inner = Arc::clone(&self.0);
let fut = async move {
<T as EventService>::subscribe(&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 method = SubscribeSvc(inner);
let codec = tonic_prost::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.server_streaming(method, req).await;
Ok(res)
};
Box::pin(fut)
}
"/cloud.lazycat.apis.sys.EventService/Send" => {
#[allow(non_camel_case_types)]
struct SendSvc<T: EventService>(pub Arc<T>);
impl<T: EventService> tonic::server::UnaryService<super::SendRequest>
for SendSvc<T> {
type Response = ();
type Future = BoxFuture<
tonic::Response<Self::Response>,
tonic::Status,
>;
fn call(
&mut self,
request: tonic::Request<super::SendRequest>,
) -> Self::Future {
let inner = Arc::clone(&self.0);
let fut = async move {
<T as EventService>::send(&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 method = SendSvc(inner);
let codec = tonic_prost::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 {
let mut response = http::Response::new(
tonic::body::Body::default(),
);
let headers = response.headers_mut();
headers
.insert(
tonic::Status::GRPC_STATUS,
(tonic::Code::Unimplemented as i32).into(),
);
headers
.insert(
http::header::CONTENT_TYPE,
tonic::metadata::GRPC_CONTENT_TYPE,
);
Ok(response)
})
}
}
}
}
impl<T> Clone for EventServiceServer<T> {
fn clone(&self) -> Self {
let inner = self.inner.clone();
Self {
inner,
accept_compression_encodings: self.accept_compression_encodings,
send_compression_encodings: self.send_compression_encodings,
max_decoding_message_size: self.max_decoding_message_size,
max_encoding_message_size: self.max_encoding_message_size,
}
}
}
pub const SERVICE_NAME: &str = "cloud.lazycat.apis.sys.EventService";
impl<T> tonic::server::NamedService for EventServiceServer<T> {
const NAME: &'static str = SERVICE_NAME;
}
}
pub mod hal_service_client {
#![allow(
unused_variables,
dead_code,
missing_docs,
clippy::wildcard_imports,
clippy::let_unit_value,
)]
use tonic::codegen::*;
use tonic::codegen::http::Uri;
#[derive(Debug, Clone)]
pub struct HalServiceClient<T> {
inner: tonic::client::Grpc<T>,
}
impl<T> HalServiceClient<T>
where
T: tonic::client::GrpcService<tonic::body::Body>,
T::Error: Into<StdError>,
T::ResponseBody: Body<Data = Bytes> + std::marker::Send + 'static,
<T::ResponseBody as Body>::Error: Into<StdError> + std::marker::Send,
{
pub fn new(inner: T) -> Self {
let inner = tonic::client::Grpc::new(inner);
Self { inner }
}
pub fn with_origin(inner: T, origin: Uri) -> Self {
let inner = tonic::client::Grpc::with_origin(inner, origin);
Self { inner }
}
pub fn with_interceptor<F>(
inner: T,
interceptor: F,
) -> HalServiceClient<InterceptedService<T, F>>
where
F: tonic::service::Interceptor,
T::ResponseBody: Default,
T: tonic::codegen::Service<
http::Request<tonic::body::Body>,
Response = http::Response<
<T as tonic::client::GrpcService<tonic::body::Body>>::ResponseBody,
>,
>,
<T as tonic::codegen::Service<
http::Request<tonic::body::Body>,
>>::Error: Into<StdError> + std::marker::Send + std::marker::Sync,
{
HalServiceClient::new(InterceptedService::new(inner, interceptor))
}
#[must_use]
pub fn send_compressed(mut self, encoding: CompressionEncoding) -> Self {
self.inner = self.inner.send_compressed(encoding);
self
}
#[must_use]
pub fn accept_compressed(mut self, encoding: CompressionEncoding) -> Self {
self.inner = self.inner.accept_compressed(encoding);
self
}
#[must_use]
pub fn max_decoding_message_size(mut self, limit: usize) -> Self {
self.inner = self.inner.max_decoding_message_size(limit);
self
}
#[must_use]
pub fn max_encoding_message_size(mut self, limit: usize) -> Self {
self.inner = self.inner.max_encoding_message_size(limit);
self
}
pub async fn set_p_led(
&mut self,
request: impl tonic::IntoRequest<super::PLedState>,
) -> std::result::Result<tonic::Response<()>, tonic::Status> {
self.inner
.ready()
.await
.map_err(|e| {
tonic::Status::unknown(
format!("Service was not ready: {}", e.into()),
)
})?;
let codec = tonic_prost::ProstCodec::default();
let path = http::uri::PathAndQuery::from_static(
"/cloud.lazycat.apis.sys.HalService/SetPLed",
);
let mut req = request.into_request();
req.extensions_mut()
.insert(GrpcMethod::new("cloud.lazycat.apis.sys.HalService", "SetPLed"));
self.inner.unary(req, path, codec).await
}
pub async fn get_p_led(
&mut self,
request: impl tonic::IntoRequest<()>,
) -> std::result::Result<tonic::Response<super::PLedState>, tonic::Status> {
self.inner
.ready()
.await
.map_err(|e| {
tonic::Status::unknown(
format!("Service was not ready: {}", e.into()),
)
})?;
let codec = tonic_prost::ProstCodec::default();
let path = http::uri::PathAndQuery::from_static(
"/cloud.lazycat.apis.sys.HalService/GetPLed",
);
let mut req = request.into_request();
req.extensions_mut()
.insert(GrpcMethod::new("cloud.lazycat.apis.sys.HalService", "GetPLed"));
self.inner.unary(req, path, codec).await
}
pub async fn set_s_led(
&mut self,
request: impl tonic::IntoRequest<super::SLedState>,
) -> std::result::Result<tonic::Response<()>, tonic::Status> {
self.inner
.ready()
.await
.map_err(|e| {
tonic::Status::unknown(
format!("Service was not ready: {}", e.into()),
)
})?;
let codec = tonic_prost::ProstCodec::default();
let path = http::uri::PathAndQuery::from_static(
"/cloud.lazycat.apis.sys.HalService/SetSLed",
);
let mut req = request.into_request();
req.extensions_mut()
.insert(GrpcMethod::new("cloud.lazycat.apis.sys.HalService", "SetSLed"));
self.inner.unary(req, path, codec).await
}
pub async fn get_button_event_queue(
&mut self,
request: impl tonic::IntoRequest<()>,
) -> std::result::Result<
tonic::Response<super::ButtonEventQueue>,
tonic::Status,
> {
self.inner
.ready()
.await
.map_err(|e| {
tonic::Status::unknown(
format!("Service was not ready: {}", e.into()),
)
})?;
let codec = tonic_prost::ProstCodec::default();
let path = http::uri::PathAndQuery::from_static(
"/cloud.lazycat.apis.sys.HalService/GetButtonEventQueue",
);
let mut req = request.into_request();
req.extensions_mut()
.insert(
GrpcMethod::new(
"cloud.lazycat.apis.sys.HalService",
"GetButtonEventQueue",
),
);
self.inner.unary(req, path, codec).await
}
pub async fn get_raw_button_event(
&mut self,
request: impl tonic::IntoRequest<super::GetButtonEventRequest>,
) -> std::result::Result<
tonic::Response<tonic::codec::Streaming<super::RawButtonEvent>>,
tonic::Status,
> {
self.inner
.ready()
.await
.map_err(|e| {
tonic::Status::unknown(
format!("Service was not ready: {}", e.into()),
)
})?;
let codec = tonic_prost::ProstCodec::default();
let path = http::uri::PathAndQuery::from_static(
"/cloud.lazycat.apis.sys.HalService/GetRawButtonEvent",
);
let mut req = request.into_request();
req.extensions_mut()
.insert(
GrpcMethod::new(
"cloud.lazycat.apis.sys.HalService",
"GetRawButtonEvent",
),
);
self.inner.server_streaming(req, path, codec).await
}
pub async fn trigger_with_button_event(
&mut self,
request: impl tonic::IntoRequest<super::TriggerBtnRequest>,
) -> std::result::Result<tonic::Response<super::HiButtonEvent>, tonic::Status> {
self.inner
.ready()
.await
.map_err(|e| {
tonic::Status::unknown(
format!("Service was not ready: {}", e.into()),
)
})?;
let codec = tonic_prost::ProstCodec::default();
let path = http::uri::PathAndQuery::from_static(
"/cloud.lazycat.apis.sys.HalService/TriggerWithButtonEvent",
);
let mut req = request.into_request();
req.extensions_mut()
.insert(
GrpcMethod::new(
"cloud.lazycat.apis.sys.HalService",
"TriggerWithButtonEvent",
),
);
self.inner.unary(req, path, codec).await
}
pub async fn set_p_led_effect(
&mut self,
request: impl tonic::IntoRequest<super::PLedEffect>,
) -> std::result::Result<
tonic::Response<tonic::codec::Streaming<()>>,
tonic::Status,
> {
self.inner
.ready()
.await
.map_err(|e| {
tonic::Status::unknown(
format!("Service was not ready: {}", e.into()),
)
})?;
let codec = tonic_prost::ProstCodec::default();
let path = http::uri::PathAndQuery::from_static(
"/cloud.lazycat.apis.sys.HalService/SetPLedEffect",
);
let mut req = request.into_request();
req.extensions_mut()
.insert(
GrpcMethod::new("cloud.lazycat.apis.sys.HalService", "SetPLedEffect"),
);
self.inner.server_streaming(req, path, codec).await
}
pub async fn get_fan_info(
&mut self,
request: impl tonic::IntoRequest<()>,
) -> std::result::Result<
tonic::Response<super::FanInfoResponse>,
tonic::Status,
> {
self.inner
.ready()
.await
.map_err(|e| {
tonic::Status::unknown(
format!("Service was not ready: {}", e.into()),
)
})?;
let codec = tonic_prost::ProstCodec::default();
let path = http::uri::PathAndQuery::from_static(
"/cloud.lazycat.apis.sys.HalService/GetFanInfo",
);
let mut req = request.into_request();
req.extensions_mut()
.insert(
GrpcMethod::new("cloud.lazycat.apis.sys.HalService", "GetFanInfo"),
);
self.inner.unary(req, path, codec).await
}
pub async fn get_fan_rpm(
&mut self,
request: impl tonic::IntoRequest<()>,
) -> std::result::Result<tonic::Response<super::FanRpm>, tonic::Status> {
self.inner
.ready()
.await
.map_err(|e| {
tonic::Status::unknown(
format!("Service was not ready: {}", e.into()),
)
})?;
let codec = tonic_prost::ProstCodec::default();
let path = http::uri::PathAndQuery::from_static(
"/cloud.lazycat.apis.sys.HalService/GetFanRpm",
);
let mut req = request.into_request();
req.extensions_mut()
.insert(
GrpcMethod::new("cloud.lazycat.apis.sys.HalService", "GetFanRpm"),
);
self.inner.unary(req, path, codec).await
}
pub async fn set_fan_config(
&mut self,
request: impl tonic::IntoRequest<super::SetFanConfigReq>,
) -> std::result::Result<
tonic::Response<super::SetFanConfigResp>,
tonic::Status,
> {
self.inner
.ready()
.await
.map_err(|e| {
tonic::Status::unknown(
format!("Service was not ready: {}", e.into()),
)
})?;
let codec = tonic_prost::ProstCodec::default();
let path = http::uri::PathAndQuery::from_static(
"/cloud.lazycat.apis.sys.HalService/SetFanConfig",
);
let mut req = request.into_request();
req.extensions_mut()
.insert(
GrpcMethod::new("cloud.lazycat.apis.sys.HalService", "SetFanConfig"),
);
self.inner.unary(req, path, codec).await
}
pub async fn get_fan_config(
&mut self,
request: impl tonic::IntoRequest<super::GetFanConfigReq>,
) -> std::result::Result<
tonic::Response<super::GetFanConfigResp>,
tonic::Status,
> {
self.inner
.ready()
.await
.map_err(|e| {
tonic::Status::unknown(
format!("Service was not ready: {}", e.into()),
)
})?;
let codec = tonic_prost::ProstCodec::default();
let path = http::uri::PathAndQuery::from_static(
"/cloud.lazycat.apis.sys.HalService/GetFanConfig",
);
let mut req = request.into_request();
req.extensions_mut()
.insert(
GrpcMethod::new("cloud.lazycat.apis.sys.HalService", "GetFanConfig"),
);
self.inner.unary(req, path, codec).await
}
}
}
pub mod hal_service_server {
#![allow(
unused_variables,
dead_code,
missing_docs,
clippy::wildcard_imports,
clippy::let_unit_value,
)]
use tonic::codegen::*;
#[async_trait]
pub trait HalService: std::marker::Send + std::marker::Sync + 'static {
async fn set_p_led(
&self,
request: tonic::Request<super::PLedState>,
) -> std::result::Result<tonic::Response<()>, tonic::Status>;
async fn get_p_led(
&self,
request: tonic::Request<()>,
) -> std::result::Result<tonic::Response<super::PLedState>, tonic::Status>;
async fn set_s_led(
&self,
request: tonic::Request<super::SLedState>,
) -> std::result::Result<tonic::Response<()>, tonic::Status>;
async fn get_button_event_queue(
&self,
request: tonic::Request<()>,
) -> std::result::Result<
tonic::Response<super::ButtonEventQueue>,
tonic::Status,
>;
type GetRawButtonEventStream: tonic::codegen::tokio_stream::Stream<
Item = std::result::Result<super::RawButtonEvent, tonic::Status>,
>
+ std::marker::Send
+ 'static;
async fn get_raw_button_event(
&self,
request: tonic::Request<super::GetButtonEventRequest>,
) -> std::result::Result<
tonic::Response<Self::GetRawButtonEventStream>,
tonic::Status,
>;
async fn trigger_with_button_event(
&self,
request: tonic::Request<super::TriggerBtnRequest>,
) -> std::result::Result<tonic::Response<super::HiButtonEvent>, tonic::Status>;
type SetPLedEffectStream: tonic::codegen::tokio_stream::Stream<
Item = std::result::Result<(), tonic::Status>,
>
+ std::marker::Send
+ 'static;
async fn set_p_led_effect(
&self,
request: tonic::Request<super::PLedEffect>,
) -> std::result::Result<
tonic::Response<Self::SetPLedEffectStream>,
tonic::Status,
>;
async fn get_fan_info(
&self,
request: tonic::Request<()>,
) -> std::result::Result<tonic::Response<super::FanInfoResponse>, tonic::Status>;
async fn get_fan_rpm(
&self,
request: tonic::Request<()>,
) -> std::result::Result<tonic::Response<super::FanRpm>, tonic::Status>;
async fn set_fan_config(
&self,
request: tonic::Request<super::SetFanConfigReq>,
) -> std::result::Result<
tonic::Response<super::SetFanConfigResp>,
tonic::Status,
>;
async fn get_fan_config(
&self,
request: tonic::Request<super::GetFanConfigReq>,
) -> std::result::Result<
tonic::Response<super::GetFanConfigResp>,
tonic::Status,
>;
}
#[derive(Debug)]
pub struct HalServiceServer<T> {
inner: Arc<T>,
accept_compression_encodings: EnabledCompressionEncodings,
send_compression_encodings: EnabledCompressionEncodings,
max_decoding_message_size: Option<usize>,
max_encoding_message_size: Option<usize>,
}
impl<T> HalServiceServer<T> {
pub fn new(inner: T) -> Self {
Self::from_arc(Arc::new(inner))
}
pub fn from_arc(inner: Arc<T>) -> Self {
Self {
inner,
accept_compression_encodings: Default::default(),
send_compression_encodings: Default::default(),
max_decoding_message_size: None,
max_encoding_message_size: None,
}
}
pub fn with_interceptor<F>(
inner: T,
interceptor: F,
) -> InterceptedService<Self, F>
where
F: tonic::service::Interceptor,
{
InterceptedService::new(Self::new(inner), interceptor)
}
#[must_use]
pub fn accept_compressed(mut self, encoding: CompressionEncoding) -> Self {
self.accept_compression_encodings.enable(encoding);
self
}
#[must_use]
pub fn send_compressed(mut self, encoding: CompressionEncoding) -> Self {
self.send_compression_encodings.enable(encoding);
self
}
#[must_use]
pub fn max_decoding_message_size(mut self, limit: usize) -> Self {
self.max_decoding_message_size = Some(limit);
self
}
#[must_use]
pub fn max_encoding_message_size(mut self, limit: usize) -> Self {
self.max_encoding_message_size = Some(limit);
self
}
}
impl<T, B> tonic::codegen::Service<http::Request<B>> for HalServiceServer<T>
where
T: HalService,
B: Body + std::marker::Send + 'static,
B::Error: Into<StdError> + std::marker::Send + 'static,
{
type Response = http::Response<tonic::body::Body>;
type Error = std::convert::Infallible;
type Future = BoxFuture<Self::Response, Self::Error>;
fn poll_ready(
&mut self,
_cx: &mut Context<'_>,
) -> Poll<std::result::Result<(), Self::Error>> {
Poll::Ready(Ok(()))
}
fn call(&mut self, req: http::Request<B>) -> Self::Future {
match req.uri().path() {
"/cloud.lazycat.apis.sys.HalService/SetPLed" => {
#[allow(non_camel_case_types)]
struct SetPLedSvc<T: HalService>(pub Arc<T>);
impl<T: HalService> tonic::server::UnaryService<super::PLedState>
for SetPLedSvc<T> {
type Response = ();
type Future = BoxFuture<
tonic::Response<Self::Response>,
tonic::Status,
>;
fn call(
&mut self,
request: tonic::Request<super::PLedState>,
) -> Self::Future {
let inner = Arc::clone(&self.0);
let fut = async move {
<T as HalService>::set_p_led(&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 method = SetPLedSvc(inner);
let codec = tonic_prost::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)
}
"/cloud.lazycat.apis.sys.HalService/GetPLed" => {
#[allow(non_camel_case_types)]
struct GetPLedSvc<T: HalService>(pub Arc<T>);
impl<T: HalService> tonic::server::UnaryService<()>
for GetPLedSvc<T> {
type Response = super::PLedState;
type Future = BoxFuture<
tonic::Response<Self::Response>,
tonic::Status,
>;
fn call(&mut self, request: tonic::Request<()>) -> Self::Future {
let inner = Arc::clone(&self.0);
let fut = async move {
<T as HalService>::get_p_led(&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 method = GetPLedSvc(inner);
let codec = tonic_prost::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)
}
"/cloud.lazycat.apis.sys.HalService/SetSLed" => {
#[allow(non_camel_case_types)]
struct SetSLedSvc<T: HalService>(pub Arc<T>);
impl<T: HalService> tonic::server::UnaryService<super::SLedState>
for SetSLedSvc<T> {
type Response = ();
type Future = BoxFuture<
tonic::Response<Self::Response>,
tonic::Status,
>;
fn call(
&mut self,
request: tonic::Request<super::SLedState>,
) -> Self::Future {
let inner = Arc::clone(&self.0);
let fut = async move {
<T as HalService>::set_s_led(&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 method = SetSLedSvc(inner);
let codec = tonic_prost::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)
}
"/cloud.lazycat.apis.sys.HalService/GetButtonEventQueue" => {
#[allow(non_camel_case_types)]
struct GetButtonEventQueueSvc<T: HalService>(pub Arc<T>);
impl<T: HalService> tonic::server::UnaryService<()>
for GetButtonEventQueueSvc<T> {
type Response = super::ButtonEventQueue;
type Future = BoxFuture<
tonic::Response<Self::Response>,
tonic::Status,
>;
fn call(&mut self, request: tonic::Request<()>) -> Self::Future {
let inner = Arc::clone(&self.0);
let fut = async move {
<T as HalService>::get_button_event_queue(&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 method = GetButtonEventQueueSvc(inner);
let codec = tonic_prost::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)
}
"/cloud.lazycat.apis.sys.HalService/GetRawButtonEvent" => {
#[allow(non_camel_case_types)]
struct GetRawButtonEventSvc<T: HalService>(pub Arc<T>);
impl<
T: HalService,
> tonic::server::ServerStreamingService<super::GetButtonEventRequest>
for GetRawButtonEventSvc<T> {
type Response = super::RawButtonEvent;
type ResponseStream = T::GetRawButtonEventStream;
type Future = BoxFuture<
tonic::Response<Self::ResponseStream>,
tonic::Status,
>;
fn call(
&mut self,
request: tonic::Request<super::GetButtonEventRequest>,
) -> Self::Future {
let inner = Arc::clone(&self.0);
let fut = async move {
<T as HalService>::get_raw_button_event(&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 method = GetRawButtonEventSvc(inner);
let codec = tonic_prost::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.server_streaming(method, req).await;
Ok(res)
};
Box::pin(fut)
}
"/cloud.lazycat.apis.sys.HalService/TriggerWithButtonEvent" => {
#[allow(non_camel_case_types)]
struct TriggerWithButtonEventSvc<T: HalService>(pub Arc<T>);
impl<
T: HalService,
> tonic::server::UnaryService<super::TriggerBtnRequest>
for TriggerWithButtonEventSvc<T> {
type Response = super::HiButtonEvent;
type Future = BoxFuture<
tonic::Response<Self::Response>,
tonic::Status,
>;
fn call(
&mut self,
request: tonic::Request<super::TriggerBtnRequest>,
) -> Self::Future {
let inner = Arc::clone(&self.0);
let fut = async move {
<T as HalService>::trigger_with_button_event(
&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 method = TriggerWithButtonEventSvc(inner);
let codec = tonic_prost::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)
}
"/cloud.lazycat.apis.sys.HalService/SetPLedEffect" => {
#[allow(non_camel_case_types)]
struct SetPLedEffectSvc<T: HalService>(pub Arc<T>);
impl<
T: HalService,
> tonic::server::ServerStreamingService<super::PLedEffect>
for SetPLedEffectSvc<T> {
type Response = ();
type ResponseStream = T::SetPLedEffectStream;
type Future = BoxFuture<
tonic::Response<Self::ResponseStream>,
tonic::Status,
>;
fn call(
&mut self,
request: tonic::Request<super::PLedEffect>,
) -> Self::Future {
let inner = Arc::clone(&self.0);
let fut = async move {
<T as HalService>::set_p_led_effect(&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 method = SetPLedEffectSvc(inner);
let codec = tonic_prost::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.server_streaming(method, req).await;
Ok(res)
};
Box::pin(fut)
}
"/cloud.lazycat.apis.sys.HalService/GetFanInfo" => {
#[allow(non_camel_case_types)]
struct GetFanInfoSvc<T: HalService>(pub Arc<T>);
impl<T: HalService> tonic::server::UnaryService<()>
for GetFanInfoSvc<T> {
type Response = super::FanInfoResponse;
type Future = BoxFuture<
tonic::Response<Self::Response>,
tonic::Status,
>;
fn call(&mut self, request: tonic::Request<()>) -> Self::Future {
let inner = Arc::clone(&self.0);
let fut = async move {
<T as HalService>::get_fan_info(&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 method = GetFanInfoSvc(inner);
let codec = tonic_prost::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)
}
"/cloud.lazycat.apis.sys.HalService/GetFanRpm" => {
#[allow(non_camel_case_types)]
struct GetFanRpmSvc<T: HalService>(pub Arc<T>);
impl<T: HalService> tonic::server::UnaryService<()>
for GetFanRpmSvc<T> {
type Response = super::FanRpm;
type Future = BoxFuture<
tonic::Response<Self::Response>,
tonic::Status,
>;
fn call(&mut self, request: tonic::Request<()>) -> Self::Future {
let inner = Arc::clone(&self.0);
let fut = async move {
<T as HalService>::get_fan_rpm(&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 method = GetFanRpmSvc(inner);
let codec = tonic_prost::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)
}
"/cloud.lazycat.apis.sys.HalService/SetFanConfig" => {
#[allow(non_camel_case_types)]
struct SetFanConfigSvc<T: HalService>(pub Arc<T>);
impl<
T: HalService,
> tonic::server::UnaryService<super::SetFanConfigReq>
for SetFanConfigSvc<T> {
type Response = super::SetFanConfigResp;
type Future = BoxFuture<
tonic::Response<Self::Response>,
tonic::Status,
>;
fn call(
&mut self,
request: tonic::Request<super::SetFanConfigReq>,
) -> Self::Future {
let inner = Arc::clone(&self.0);
let fut = async move {
<T as HalService>::set_fan_config(&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 method = SetFanConfigSvc(inner);
let codec = tonic_prost::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)
}
"/cloud.lazycat.apis.sys.HalService/GetFanConfig" => {
#[allow(non_camel_case_types)]
struct GetFanConfigSvc<T: HalService>(pub Arc<T>);
impl<
T: HalService,
> tonic::server::UnaryService<super::GetFanConfigReq>
for GetFanConfigSvc<T> {
type Response = super::GetFanConfigResp;
type Future = BoxFuture<
tonic::Response<Self::Response>,
tonic::Status,
>;
fn call(
&mut self,
request: tonic::Request<super::GetFanConfigReq>,
) -> Self::Future {
let inner = Arc::clone(&self.0);
let fut = async move {
<T as HalService>::get_fan_config(&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 method = GetFanConfigSvc(inner);
let codec = tonic_prost::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 {
let mut response = http::Response::new(
tonic::body::Body::default(),
);
let headers = response.headers_mut();
headers
.insert(
tonic::Status::GRPC_STATUS,
(tonic::Code::Unimplemented as i32).into(),
);
headers
.insert(
http::header::CONTENT_TYPE,
tonic::metadata::GRPC_CONTENT_TYPE,
);
Ok(response)
})
}
}
}
}
impl<T> Clone for HalServiceServer<T> {
fn clone(&self) -> Self {
let inner = self.inner.clone();
Self {
inner,
accept_compression_encodings: self.accept_compression_encodings,
send_compression_encodings: self.send_compression_encodings,
max_decoding_message_size: self.max_decoding_message_size,
max_encoding_message_size: self.max_encoding_message_size,
}
}
}
pub const SERVICE_NAME: &str = "cloud.lazycat.apis.sys.HalService";
impl<T> tonic::server::NamedService for HalServiceServer<T> {
const NAME: &'static str = SERVICE_NAME;
}
}
pub mod fan_service_client {
#![allow(
unused_variables,
dead_code,
missing_docs,
clippy::wildcard_imports,
clippy::let_unit_value,
)]
use tonic::codegen::*;
use tonic::codegen::http::Uri;
#[derive(Debug, Clone)]
pub struct FanServiceClient<T> {
inner: tonic::client::Grpc<T>,
}
impl<T> FanServiceClient<T>
where
T: tonic::client::GrpcService<tonic::body::Body>,
T::Error: Into<StdError>,
T::ResponseBody: Body<Data = Bytes> + std::marker::Send + 'static,
<T::ResponseBody as Body>::Error: Into<StdError> + std::marker::Send,
{
pub fn new(inner: T) -> Self {
let inner = tonic::client::Grpc::new(inner);
Self { inner }
}
pub fn with_origin(inner: T, origin: Uri) -> Self {
let inner = tonic::client::Grpc::with_origin(inner, origin);
Self { inner }
}
pub fn with_interceptor<F>(
inner: T,
interceptor: F,
) -> FanServiceClient<InterceptedService<T, F>>
where
F: tonic::service::Interceptor,
T::ResponseBody: Default,
T: tonic::codegen::Service<
http::Request<tonic::body::Body>,
Response = http::Response<
<T as tonic::client::GrpcService<tonic::body::Body>>::ResponseBody,
>,
>,
<T as tonic::codegen::Service<
http::Request<tonic::body::Body>,
>>::Error: Into<StdError> + std::marker::Send + std::marker::Sync,
{
FanServiceClient::new(InterceptedService::new(inner, interceptor))
}
#[must_use]
pub fn send_compressed(mut self, encoding: CompressionEncoding) -> Self {
self.inner = self.inner.send_compressed(encoding);
self
}
#[must_use]
pub fn accept_compressed(mut self, encoding: CompressionEncoding) -> Self {
self.inner = self.inner.accept_compressed(encoding);
self
}
#[must_use]
pub fn max_decoding_message_size(mut self, limit: usize) -> Self {
self.inner = self.inner.max_decoding_message_size(limit);
self
}
#[must_use]
pub fn max_encoding_message_size(mut self, limit: usize) -> Self {
self.inner = self.inner.max_encoding_message_size(limit);
self
}
pub async fn set_fan_config(
&mut self,
request: impl tonic::IntoRequest<super::SetFanConfigReq>,
) -> std::result::Result<
tonic::Response<super::SetFanConfigResp>,
tonic::Status,
> {
self.inner
.ready()
.await
.map_err(|e| {
tonic::Status::unknown(
format!("Service was not ready: {}", e.into()),
)
})?;
let codec = tonic_prost::ProstCodec::default();
let path = http::uri::PathAndQuery::from_static(
"/cloud.lazycat.apis.sys.FanService/SetFanConfig",
);
let mut req = request.into_request();
req.extensions_mut()
.insert(
GrpcMethod::new("cloud.lazycat.apis.sys.FanService", "SetFanConfig"),
);
self.inner.unary(req, path, codec).await
}
pub async fn get_fan_config(
&mut self,
request: impl tonic::IntoRequest<super::GetFanConfigReq>,
) -> std::result::Result<
tonic::Response<super::GetFanConfigResp>,
tonic::Status,
> {
self.inner
.ready()
.await
.map_err(|e| {
tonic::Status::unknown(
format!("Service was not ready: {}", e.into()),
)
})?;
let codec = tonic_prost::ProstCodec::default();
let path = http::uri::PathAndQuery::from_static(
"/cloud.lazycat.apis.sys.FanService/GetFanConfig",
);
let mut req = request.into_request();
req.extensions_mut()
.insert(
GrpcMethod::new("cloud.lazycat.apis.sys.FanService", "GetFanConfig"),
);
self.inner.unary(req, path, codec).await
}
}
}
pub mod fan_service_server {
#![allow(
unused_variables,
dead_code,
missing_docs,
clippy::wildcard_imports,
clippy::let_unit_value,
)]
use tonic::codegen::*;
#[async_trait]
pub trait FanService: std::marker::Send + std::marker::Sync + 'static {
async fn set_fan_config(
&self,
request: tonic::Request<super::SetFanConfigReq>,
) -> std::result::Result<
tonic::Response<super::SetFanConfigResp>,
tonic::Status,
>;
async fn get_fan_config(
&self,
request: tonic::Request<super::GetFanConfigReq>,
) -> std::result::Result<
tonic::Response<super::GetFanConfigResp>,
tonic::Status,
>;
}
#[derive(Debug)]
pub struct FanServiceServer<T> {
inner: Arc<T>,
accept_compression_encodings: EnabledCompressionEncodings,
send_compression_encodings: EnabledCompressionEncodings,
max_decoding_message_size: Option<usize>,
max_encoding_message_size: Option<usize>,
}
impl<T> FanServiceServer<T> {
pub fn new(inner: T) -> Self {
Self::from_arc(Arc::new(inner))
}
pub fn from_arc(inner: Arc<T>) -> Self {
Self {
inner,
accept_compression_encodings: Default::default(),
send_compression_encodings: Default::default(),
max_decoding_message_size: None,
max_encoding_message_size: None,
}
}
pub fn with_interceptor<F>(
inner: T,
interceptor: F,
) -> InterceptedService<Self, F>
where
F: tonic::service::Interceptor,
{
InterceptedService::new(Self::new(inner), interceptor)
}
#[must_use]
pub fn accept_compressed(mut self, encoding: CompressionEncoding) -> Self {
self.accept_compression_encodings.enable(encoding);
self
}
#[must_use]
pub fn send_compressed(mut self, encoding: CompressionEncoding) -> Self {
self.send_compression_encodings.enable(encoding);
self
}
#[must_use]
pub fn max_decoding_message_size(mut self, limit: usize) -> Self {
self.max_decoding_message_size = Some(limit);
self
}
#[must_use]
pub fn max_encoding_message_size(mut self, limit: usize) -> Self {
self.max_encoding_message_size = Some(limit);
self
}
}
impl<T, B> tonic::codegen::Service<http::Request<B>> for FanServiceServer<T>
where
T: FanService,
B: Body + std::marker::Send + 'static,
B::Error: Into<StdError> + std::marker::Send + 'static,
{
type Response = http::Response<tonic::body::Body>;
type Error = std::convert::Infallible;
type Future = BoxFuture<Self::Response, Self::Error>;
fn poll_ready(
&mut self,
_cx: &mut Context<'_>,
) -> Poll<std::result::Result<(), Self::Error>> {
Poll::Ready(Ok(()))
}
fn call(&mut self, req: http::Request<B>) -> Self::Future {
match req.uri().path() {
"/cloud.lazycat.apis.sys.FanService/SetFanConfig" => {
#[allow(non_camel_case_types)]
struct SetFanConfigSvc<T: FanService>(pub Arc<T>);
impl<
T: FanService,
> tonic::server::UnaryService<super::SetFanConfigReq>
for SetFanConfigSvc<T> {
type Response = super::SetFanConfigResp;
type Future = BoxFuture<
tonic::Response<Self::Response>,
tonic::Status,
>;
fn call(
&mut self,
request: tonic::Request<super::SetFanConfigReq>,
) -> Self::Future {
let inner = Arc::clone(&self.0);
let fut = async move {
<T as FanService>::set_fan_config(&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 method = SetFanConfigSvc(inner);
let codec = tonic_prost::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)
}
"/cloud.lazycat.apis.sys.FanService/GetFanConfig" => {
#[allow(non_camel_case_types)]
struct GetFanConfigSvc<T: FanService>(pub Arc<T>);
impl<
T: FanService,
> tonic::server::UnaryService<super::GetFanConfigReq>
for GetFanConfigSvc<T> {
type Response = super::GetFanConfigResp;
type Future = BoxFuture<
tonic::Response<Self::Response>,
tonic::Status,
>;
fn call(
&mut self,
request: tonic::Request<super::GetFanConfigReq>,
) -> Self::Future {
let inner = Arc::clone(&self.0);
let fut = async move {
<T as FanService>::get_fan_config(&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 method = GetFanConfigSvc(inner);
let codec = tonic_prost::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 {
let mut response = http::Response::new(
tonic::body::Body::default(),
);
let headers = response.headers_mut();
headers
.insert(
tonic::Status::GRPC_STATUS,
(tonic::Code::Unimplemented as i32).into(),
);
headers
.insert(
http::header::CONTENT_TYPE,
tonic::metadata::GRPC_CONTENT_TYPE,
);
Ok(response)
})
}
}
}
}
impl<T> Clone for FanServiceServer<T> {
fn clone(&self) -> Self {
let inner = self.inner.clone();
Self {
inner,
accept_compression_encodings: self.accept_compression_encodings,
send_compression_encodings: self.send_compression_encodings,
max_decoding_message_size: self.max_decoding_message_size,
max_encoding_message_size: self.max_encoding_message_size,
}
}
}
pub const SERVICE_NAME: &str = "cloud.lazycat.apis.sys.FanService";
impl<T> tonic::server::NamedService for FanServiceServer<T> {
const NAME: &'static str = SERVICE_NAME;
}
}
pub mod h_portal_sys_client {
#![allow(
unused_variables,
dead_code,
missing_docs,
clippy::wildcard_imports,
clippy::let_unit_value,
)]
use tonic::codegen::*;
use tonic::codegen::http::Uri;
#[derive(Debug, Clone)]
pub struct HPortalSysClient<T> {
inner: tonic::client::Grpc<T>,
}
impl<T> HPortalSysClient<T>
where
T: tonic::client::GrpcService<tonic::body::Body>,
T::Error: Into<StdError>,
T::ResponseBody: Body<Data = Bytes> + std::marker::Send + 'static,
<T::ResponseBody as Body>::Error: Into<StdError> + std::marker::Send,
{
pub fn new(inner: T) -> Self {
let inner = tonic::client::Grpc::new(inner);
Self { inner }
}
pub fn with_origin(inner: T, origin: Uri) -> Self {
let inner = tonic::client::Grpc::with_origin(inner, origin);
Self { inner }
}
pub fn with_interceptor<F>(
inner: T,
interceptor: F,
) -> HPortalSysClient<InterceptedService<T, F>>
where
F: tonic::service::Interceptor,
T::ResponseBody: Default,
T: tonic::codegen::Service<
http::Request<tonic::body::Body>,
Response = http::Response<
<T as tonic::client::GrpcService<tonic::body::Body>>::ResponseBody,
>,
>,
<T as tonic::codegen::Service<
http::Request<tonic::body::Body>,
>>::Error: Into<StdError> + std::marker::Send + std::marker::Sync,
{
HPortalSysClient::new(InterceptedService::new(inner, interceptor))
}
#[must_use]
pub fn send_compressed(mut self, encoding: CompressionEncoding) -> Self {
self.inner = self.inner.send_compressed(encoding);
self
}
#[must_use]
pub fn accept_compressed(mut self, encoding: CompressionEncoding) -> Self {
self.inner = self.inner.accept_compressed(encoding);
self
}
#[must_use]
pub fn max_decoding_message_size(mut self, limit: usize) -> Self {
self.inner = self.inner.max_decoding_message_size(limit);
self
}
#[must_use]
pub fn max_encoding_message_size(mut self, limit: usize) -> Self {
self.inner = self.inner.max_encoding_message_size(limit);
self
}
pub async fn query_h_server_info(
&mut self,
request: impl tonic::IntoRequest<()>,
) -> std::result::Result<tonic::Response<super::HServerInfo>, tonic::Status> {
self.inner
.ready()
.await
.map_err(|e| {
tonic::Status::unknown(
format!("Service was not ready: {}", e.into()),
)
})?;
let codec = tonic_prost::ProstCodec::default();
let path = http::uri::PathAndQuery::from_static(
"/cloud.lazycat.apis.sys.HPortalSys/QueryHServerInfo",
);
let mut req = request.into_request();
req.extensions_mut()
.insert(
GrpcMethod::new(
"cloud.lazycat.apis.sys.HPortalSys",
"QueryHServerInfo",
),
);
self.inner.unary(req, path, codec).await
}
pub async fn list_users(
&mut self,
request: impl tonic::IntoRequest<()>,
) -> std::result::Result<tonic::Response<super::ListUsersReply>, tonic::Status> {
self.inner
.ready()
.await
.map_err(|e| {
tonic::Status::unknown(
format!("Service was not ready: {}", e.into()),
)
})?;
let codec = tonic_prost::ProstCodec::default();
let path = http::uri::PathAndQuery::from_static(
"/cloud.lazycat.apis.sys.HPortalSys/ListUsers",
);
let mut req = request.into_request();
req.extensions_mut()
.insert(
GrpcMethod::new("cloud.lazycat.apis.sys.HPortalSys", "ListUsers"),
);
self.inner.unary(req, path, codec).await
}
pub async fn create_user(
&mut self,
request: impl tonic::IntoRequest<super::CreateUserRequest>,
) -> std::result::Result<tonic::Response<()>, tonic::Status> {
self.inner
.ready()
.await
.map_err(|e| {
tonic::Status::unknown(
format!("Service was not ready: {}", e.into()),
)
})?;
let codec = tonic_prost::ProstCodec::default();
let path = http::uri::PathAndQuery::from_static(
"/cloud.lazycat.apis.sys.HPortalSys/CreateUser",
);
let mut req = request.into_request();
req.extensions_mut()
.insert(
GrpcMethod::new("cloud.lazycat.apis.sys.HPortalSys", "CreateUser"),
);
self.inner.unary(req, path, codec).await
}
pub async fn delete_user(
&mut self,
request: impl tonic::IntoRequest<super::DeleteUserRequest>,
) -> std::result::Result<tonic::Response<()>, tonic::Status> {
self.inner
.ready()
.await
.map_err(|e| {
tonic::Status::unknown(
format!("Service was not ready: {}", e.into()),
)
})?;
let codec = tonic_prost::ProstCodec::default();
let path = http::uri::PathAndQuery::from_static(
"/cloud.lazycat.apis.sys.HPortalSys/DeleteUser",
);
let mut req = request.into_request();
req.extensions_mut()
.insert(
GrpcMethod::new("cloud.lazycat.apis.sys.HPortalSys", "DeleteUser"),
);
self.inner.unary(req, path, codec).await
}
pub async fn reset_password(
&mut self,
request: impl tonic::IntoRequest<super::ResetPasswordRequest>,
) -> std::result::Result<tonic::Response<()>, tonic::Status> {
self.inner
.ready()
.await
.map_err(|e| {
tonic::Status::unknown(
format!("Service was not ready: {}", e.into()),
)
})?;
let codec = tonic_prost::ProstCodec::default();
let path = http::uri::PathAndQuery::from_static(
"/cloud.lazycat.apis.sys.HPortalSys/ResetPassword",
);
let mut req = request.into_request();
req.extensions_mut()
.insert(
GrpcMethod::new("cloud.lazycat.apis.sys.HPortalSys", "ResetPassword"),
);
self.inner.unary(req, path, codec).await
}
pub async fn check_password(
&mut self,
request: impl tonic::IntoRequest<super::CheckPasswordRequest>,
) -> std::result::Result<tonic::Response<()>, tonic::Status> {
self.inner
.ready()
.await
.map_err(|e| {
tonic::Status::unknown(
format!("Service was not ready: {}", e.into()),
)
})?;
let codec = tonic_prost::ProstCodec::default();
let path = http::uri::PathAndQuery::from_static(
"/cloud.lazycat.apis.sys.HPortalSys/CheckPassword",
);
let mut req = request.into_request();
req.extensions_mut()
.insert(
GrpcMethod::new("cloud.lazycat.apis.sys.HPortalSys", "CheckPassword"),
);
self.inner.unary(req, path, codec).await
}
pub async fn get_password_hash(
&mut self,
request: impl tonic::IntoRequest<super::GetPasswordHashRequest>,
) -> std::result::Result<
tonic::Response<super::GetPasswordHashResponse>,
tonic::Status,
> {
self.inner
.ready()
.await
.map_err(|e| {
tonic::Status::unknown(
format!("Service was not ready: {}", e.into()),
)
})?;
let codec = tonic_prost::ProstCodec::default();
let path = http::uri::PathAndQuery::from_static(
"/cloud.lazycat.apis.sys.HPortalSys/GetPasswordHash",
);
let mut req = request.into_request();
req.extensions_mut()
.insert(
GrpcMethod::new(
"cloud.lazycat.apis.sys.HPortalSys",
"GetPasswordHash",
),
);
self.inner.unary(req, path, codec).await
}
pub async fn set_password_hash(
&mut self,
request: impl tonic::IntoRequest<super::SetPasswordHashRequest>,
) -> std::result::Result<tonic::Response<()>, tonic::Status> {
self.inner
.ready()
.await
.map_err(|e| {
tonic::Status::unknown(
format!("Service was not ready: {}", e.into()),
)
})?;
let codec = tonic_prost::ProstCodec::default();
let path = http::uri::PathAndQuery::from_static(
"/cloud.lazycat.apis.sys.HPortalSys/SetPasswordHash",
);
let mut req = request.into_request();
req.extensions_mut()
.insert(
GrpcMethod::new(
"cloud.lazycat.apis.sys.HPortalSys",
"SetPasswordHash",
),
);
self.inner.unary(req, path, codec).await
}
pub async fn query_role(
&mut self,
request: impl tonic::IntoRequest<super::UserId>,
) -> std::result::Result<tonic::Response<super::QueryRoleReply>, tonic::Status> {
self.inner
.ready()
.await
.map_err(|e| {
tonic::Status::unknown(
format!("Service was not ready: {}", e.into()),
)
})?;
let codec = tonic_prost::ProstCodec::default();
let path = http::uri::PathAndQuery::from_static(
"/cloud.lazycat.apis.sys.HPortalSys/QueryRole",
);
let mut req = request.into_request();
req.extensions_mut()
.insert(
GrpcMethod::new("cloud.lazycat.apis.sys.HPortalSys", "QueryRole"),
);
self.inner.unary(req, path, codec).await
}
pub async fn change_role(
&mut self,
request: impl tonic::IntoRequest<super::ChangeRoleReqeust>,
) -> std::result::Result<tonic::Response<()>, tonic::Status> {
self.inner
.ready()
.await
.map_err(|e| {
tonic::Status::unknown(
format!("Service was not ready: {}", e.into()),
)
})?;
let codec = tonic_prost::ProstCodec::default();
let path = http::uri::PathAndQuery::from_static(
"/cloud.lazycat.apis.sys.HPortalSys/ChangeRole",
);
let mut req = request.into_request();
req.extensions_mut()
.insert(
GrpcMethod::new("cloud.lazycat.apis.sys.HPortalSys", "ChangeRole"),
);
self.inner.unary(req, path, codec).await
}
pub async fn change_trust_end_device(
&mut self,
request: impl tonic::IntoRequest<super::ChangeTrustEndDeviceRequest>,
) -> std::result::Result<
tonic::Response<super::ChangeTrustEndDeviceReply>,
tonic::Status,
> {
self.inner
.ready()
.await
.map_err(|e| {
tonic::Status::unknown(
format!("Service was not ready: {}", e.into()),
)
})?;
let codec = tonic_prost::ProstCodec::default();
let path = http::uri::PathAndQuery::from_static(
"/cloud.lazycat.apis.sys.HPortalSys/ChangeTrustEndDevice",
);
let mut req = request.into_request();
req.extensions_mut()
.insert(
GrpcMethod::new(
"cloud.lazycat.apis.sys.HPortalSys",
"ChangeTrustEndDevice",
),
);
self.inner.unary(req, path, codec).await
}
pub async fn list_end_devices(
&mut self,
request: impl tonic::IntoRequest<super::ListEndDeviceRequest>,
) -> std::result::Result<
tonic::Response<super::ListEndDeviceReply>,
tonic::Status,
> {
self.inner
.ready()
.await
.map_err(|e| {
tonic::Status::unknown(
format!("Service was not ready: {}", e.into()),
)
})?;
let codec = tonic_prost::ProstCodec::default();
let path = http::uri::PathAndQuery::from_static(
"/cloud.lazycat.apis.sys.HPortalSys/ListEndDevices",
);
let mut req = request.into_request();
req.extensions_mut()
.insert(
GrpcMethod::new(
"cloud.lazycat.apis.sys.HPortalSys",
"ListEndDevices",
),
);
self.inner.unary(req, path, codec).await
}
pub async fn remote_socks(
&mut self,
request: impl tonic::IntoRequest<super::RemoteSocksRequest>,
) -> std::result::Result<
tonic::Response<super::RemoteSocksReply>,
tonic::Status,
> {
self.inner
.ready()
.await
.map_err(|e| {
tonic::Status::unknown(
format!("Service was not ready: {}", e.into()),
)
})?;
let codec = tonic_prost::ProstCodec::default();
let path = http::uri::PathAndQuery::from_static(
"/cloud.lazycat.apis.sys.HPortalSys/RemoteSocks",
);
let mut req = request.into_request();
req.extensions_mut()
.insert(
GrpcMethod::new("cloud.lazycat.apis.sys.HPortalSys", "RemoteSocks"),
);
self.inner.unary(req, path, codec).await
}
pub async fn setup_h_server(
&mut self,
request: impl tonic::IntoRequest<super::SetupHServerRequest>,
) -> std::result::Result<
tonic::Response<super::SetupHServerReply>,
tonic::Status,
> {
self.inner
.ready()
.await
.map_err(|e| {
tonic::Status::unknown(
format!("Service was not ready: {}", e.into()),
)
})?;
let codec = tonic_prost::ProstCodec::default();
let path = http::uri::PathAndQuery::from_static(
"/cloud.lazycat.apis.sys.HPortalSys/SetupHServer",
);
let mut req = request.into_request();
req.extensions_mut()
.insert(
GrpcMethod::new("cloud.lazycat.apis.sys.HPortalSys", "SetupHServer"),
);
self.inner.unary(req, path, codec).await
}
pub async fn reset_h_server(
&mut self,
request: impl tonic::IntoRequest<super::ResetHServerRequest>,
) -> std::result::Result<
tonic::Response<super::ResetHServerReply>,
tonic::Status,
> {
self.inner
.ready()
.await
.map_err(|e| {
tonic::Status::unknown(
format!("Service was not ready: {}", e.into()),
)
})?;
let codec = tonic_prost::ProstCodec::default();
let path = http::uri::PathAndQuery::from_static(
"/cloud.lazycat.apis.sys.HPortalSys/ResetHServer",
);
let mut req = request.into_request();
req.extensions_mut()
.insert(
GrpcMethod::new("cloud.lazycat.apis.sys.HPortalSys", "ResetHServer"),
);
self.inner.unary(req, path, codec).await
}
pub async fn register_box_service(
&mut self,
request: impl tonic::IntoRequest<super::RegisterBoxServiceRequest>,
) -> std::result::Result<
tonic::Response<tonic::codec::Streaming<super::RegisterBoxServiceReply>>,
tonic::Status,
> {
self.inner
.ready()
.await
.map_err(|e| {
tonic::Status::unknown(
format!("Service was not ready: {}", e.into()),
)
})?;
let codec = tonic_prost::ProstCodec::default();
let path = http::uri::PathAndQuery::from_static(
"/cloud.lazycat.apis.sys.HPortalSys/RegisterBoxService",
);
let mut req = request.into_request();
req.extensions_mut()
.insert(
GrpcMethod::new(
"cloud.lazycat.apis.sys.HPortalSys",
"RegisterBoxService",
),
);
self.inner.server_streaming(req, path, codec).await
}
pub async fn emit_box_service_changed(
&mut self,
request: impl tonic::IntoRequest<super::EmitBoxServiceChangedRequest>,
) -> std::result::Result<tonic::Response<()>, tonic::Status> {
self.inner
.ready()
.await
.map_err(|e| {
tonic::Status::unknown(
format!("Service was not ready: {}", e.into()),
)
})?;
let codec = tonic_prost::ProstCodec::default();
let path = http::uri::PathAndQuery::from_static(
"/cloud.lazycat.apis.sys.HPortalSys/EmitBoxServiceChanged",
);
let mut req = request.into_request();
req.extensions_mut()
.insert(
GrpcMethod::new(
"cloud.lazycat.apis.sys.HPortalSys",
"EmitBoxServiceChanged",
),
);
self.inner.unary(req, path, codec).await
}
pub async fn query_box_service_peer_cred(
&mut self,
request: impl tonic::IntoRequest<super::QueryBoxServicePeerCredRequest>,
) -> std::result::Result<
tonic::Response<super::QueryBoxServicePeerCredResponse>,
tonic::Status,
> {
self.inner
.ready()
.await
.map_err(|e| {
tonic::Status::unknown(
format!("Service was not ready: {}", e.into()),
)
})?;
let codec = tonic_prost::ProstCodec::default();
let path = http::uri::PathAndQuery::from_static(
"/cloud.lazycat.apis.sys.HPortalSys/QueryBoxServicePeerCred",
);
let mut req = request.into_request();
req.extensions_mut()
.insert(
GrpcMethod::new(
"cloud.lazycat.apis.sys.HPortalSys",
"QueryBoxServicePeerCred",
),
);
self.inner.unary(req, path, codec).await
}
pub async fn set_relay(
&mut self,
request: impl tonic::IntoRequest<super::SetRelayRequest>,
) -> std::result::Result<tonic::Response<()>, tonic::Status> {
self.inner
.ready()
.await
.map_err(|e| {
tonic::Status::unknown(
format!("Service was not ready: {}", e.into()),
)
})?;
let codec = tonic_prost::ProstCodec::default();
let path = http::uri::PathAndQuery::from_static(
"/cloud.lazycat.apis.sys.HPortalSys/SetRelay",
);
let mut req = request.into_request();
req.extensions_mut()
.insert(
GrpcMethod::new("cloud.lazycat.apis.sys.HPortalSys", "SetRelay"),
);
self.inner.unary(req, path, codec).await
}
pub async fn dump_peers(
&mut self,
request: impl tonic::IntoRequest<()>,
) -> std::result::Result<tonic::Response<super::PeersInfo>, tonic::Status> {
self.inner
.ready()
.await
.map_err(|e| {
tonic::Status::unknown(
format!("Service was not ready: {}", e.into()),
)
})?;
let codec = tonic_prost::ProstCodec::default();
let path = http::uri::PathAndQuery::from_static(
"/cloud.lazycat.apis.sys.HPortalSys/DumpPeers",
);
let mut req = request.into_request();
req.extensions_mut()
.insert(
GrpcMethod::new("cloud.lazycat.apis.sys.HPortalSys", "DumpPeers"),
);
self.inner.unary(req, path, codec).await
}
}
}
pub mod h_portal_sys_server {
#![allow(
unused_variables,
dead_code,
missing_docs,
clippy::wildcard_imports,
clippy::let_unit_value,
)]
use tonic::codegen::*;
#[async_trait]
pub trait HPortalSys: std::marker::Send + std::marker::Sync + 'static {
async fn query_h_server_info(
&self,
request: tonic::Request<()>,
) -> std::result::Result<tonic::Response<super::HServerInfo>, tonic::Status>;
async fn list_users(
&self,
request: tonic::Request<()>,
) -> std::result::Result<tonic::Response<super::ListUsersReply>, tonic::Status>;
async fn create_user(
&self,
request: tonic::Request<super::CreateUserRequest>,
) -> std::result::Result<tonic::Response<()>, tonic::Status>;
async fn delete_user(
&self,
request: tonic::Request<super::DeleteUserRequest>,
) -> std::result::Result<tonic::Response<()>, tonic::Status>;
async fn reset_password(
&self,
request: tonic::Request<super::ResetPasswordRequest>,
) -> std::result::Result<tonic::Response<()>, tonic::Status>;
async fn check_password(
&self,
request: tonic::Request<super::CheckPasswordRequest>,
) -> std::result::Result<tonic::Response<()>, tonic::Status>;
async fn get_password_hash(
&self,
request: tonic::Request<super::GetPasswordHashRequest>,
) -> std::result::Result<
tonic::Response<super::GetPasswordHashResponse>,
tonic::Status,
>;
async fn set_password_hash(
&self,
request: tonic::Request<super::SetPasswordHashRequest>,
) -> std::result::Result<tonic::Response<()>, tonic::Status>;
async fn query_role(
&self,
request: tonic::Request<super::UserId>,
) -> std::result::Result<tonic::Response<super::QueryRoleReply>, tonic::Status>;
async fn change_role(
&self,
request: tonic::Request<super::ChangeRoleReqeust>,
) -> std::result::Result<tonic::Response<()>, tonic::Status>;
async fn change_trust_end_device(
&self,
request: tonic::Request<super::ChangeTrustEndDeviceRequest>,
) -> std::result::Result<
tonic::Response<super::ChangeTrustEndDeviceReply>,
tonic::Status,
>;
async fn list_end_devices(
&self,
request: tonic::Request<super::ListEndDeviceRequest>,
) -> std::result::Result<
tonic::Response<super::ListEndDeviceReply>,
tonic::Status,
>;
async fn remote_socks(
&self,
request: tonic::Request<super::RemoteSocksRequest>,
) -> std::result::Result<
tonic::Response<super::RemoteSocksReply>,
tonic::Status,
>;
async fn setup_h_server(
&self,
request: tonic::Request<super::SetupHServerRequest>,
) -> std::result::Result<
tonic::Response<super::SetupHServerReply>,
tonic::Status,
>;
async fn reset_h_server(
&self,
request: tonic::Request<super::ResetHServerRequest>,
) -> std::result::Result<
tonic::Response<super::ResetHServerReply>,
tonic::Status,
>;
type RegisterBoxServiceStream: tonic::codegen::tokio_stream::Stream<
Item = std::result::Result<super::RegisterBoxServiceReply, tonic::Status>,
>
+ std::marker::Send
+ 'static;
async fn register_box_service(
&self,
request: tonic::Request<super::RegisterBoxServiceRequest>,
) -> std::result::Result<
tonic::Response<Self::RegisterBoxServiceStream>,
tonic::Status,
>;
async fn emit_box_service_changed(
&self,
request: tonic::Request<super::EmitBoxServiceChangedRequest>,
) -> std::result::Result<tonic::Response<()>, tonic::Status>;
async fn query_box_service_peer_cred(
&self,
request: tonic::Request<super::QueryBoxServicePeerCredRequest>,
) -> std::result::Result<
tonic::Response<super::QueryBoxServicePeerCredResponse>,
tonic::Status,
>;
async fn set_relay(
&self,
request: tonic::Request<super::SetRelayRequest>,
) -> std::result::Result<tonic::Response<()>, tonic::Status>;
async fn dump_peers(
&self,
request: tonic::Request<()>,
) -> std::result::Result<tonic::Response<super::PeersInfo>, tonic::Status>;
}
#[derive(Debug)]
pub struct HPortalSysServer<T> {
inner: Arc<T>,
accept_compression_encodings: EnabledCompressionEncodings,
send_compression_encodings: EnabledCompressionEncodings,
max_decoding_message_size: Option<usize>,
max_encoding_message_size: Option<usize>,
}
impl<T> HPortalSysServer<T> {
pub fn new(inner: T) -> Self {
Self::from_arc(Arc::new(inner))
}
pub fn from_arc(inner: Arc<T>) -> Self {
Self {
inner,
accept_compression_encodings: Default::default(),
send_compression_encodings: Default::default(),
max_decoding_message_size: None,
max_encoding_message_size: None,
}
}
pub fn with_interceptor<F>(
inner: T,
interceptor: F,
) -> InterceptedService<Self, F>
where
F: tonic::service::Interceptor,
{
InterceptedService::new(Self::new(inner), interceptor)
}
#[must_use]
pub fn accept_compressed(mut self, encoding: CompressionEncoding) -> Self {
self.accept_compression_encodings.enable(encoding);
self
}
#[must_use]
pub fn send_compressed(mut self, encoding: CompressionEncoding) -> Self {
self.send_compression_encodings.enable(encoding);
self
}
#[must_use]
pub fn max_decoding_message_size(mut self, limit: usize) -> Self {
self.max_decoding_message_size = Some(limit);
self
}
#[must_use]
pub fn max_encoding_message_size(mut self, limit: usize) -> Self {
self.max_encoding_message_size = Some(limit);
self
}
}
impl<T, B> tonic::codegen::Service<http::Request<B>> for HPortalSysServer<T>
where
T: HPortalSys,
B: Body + std::marker::Send + 'static,
B::Error: Into<StdError> + std::marker::Send + 'static,
{
type Response = http::Response<tonic::body::Body>;
type Error = std::convert::Infallible;
type Future = BoxFuture<Self::Response, Self::Error>;
fn poll_ready(
&mut self,
_cx: &mut Context<'_>,
) -> Poll<std::result::Result<(), Self::Error>> {
Poll::Ready(Ok(()))
}
fn call(&mut self, req: http::Request<B>) -> Self::Future {
match req.uri().path() {
"/cloud.lazycat.apis.sys.HPortalSys/QueryHServerInfo" => {
#[allow(non_camel_case_types)]
struct QueryHServerInfoSvc<T: HPortalSys>(pub Arc<T>);
impl<T: HPortalSys> tonic::server::UnaryService<()>
for QueryHServerInfoSvc<T> {
type Response = super::HServerInfo;
type Future = BoxFuture<
tonic::Response<Self::Response>,
tonic::Status,
>;
fn call(&mut self, request: tonic::Request<()>) -> Self::Future {
let inner = Arc::clone(&self.0);
let fut = async move {
<T as HPortalSys>::query_h_server_info(&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 method = QueryHServerInfoSvc(inner);
let codec = tonic_prost::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)
}
"/cloud.lazycat.apis.sys.HPortalSys/ListUsers" => {
#[allow(non_camel_case_types)]
struct ListUsersSvc<T: HPortalSys>(pub Arc<T>);
impl<T: HPortalSys> tonic::server::UnaryService<()>
for ListUsersSvc<T> {
type Response = super::ListUsersReply;
type Future = BoxFuture<
tonic::Response<Self::Response>,
tonic::Status,
>;
fn call(&mut self, request: tonic::Request<()>) -> Self::Future {
let inner = Arc::clone(&self.0);
let fut = async move {
<T as HPortalSys>::list_users(&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 method = ListUsersSvc(inner);
let codec = tonic_prost::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)
}
"/cloud.lazycat.apis.sys.HPortalSys/CreateUser" => {
#[allow(non_camel_case_types)]
struct CreateUserSvc<T: HPortalSys>(pub Arc<T>);
impl<
T: HPortalSys,
> tonic::server::UnaryService<super::CreateUserRequest>
for CreateUserSvc<T> {
type Response = ();
type Future = BoxFuture<
tonic::Response<Self::Response>,
tonic::Status,
>;
fn call(
&mut self,
request: tonic::Request<super::CreateUserRequest>,
) -> Self::Future {
let inner = Arc::clone(&self.0);
let fut = async move {
<T as HPortalSys>::create_user(&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 method = CreateUserSvc(inner);
let codec = tonic_prost::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)
}
"/cloud.lazycat.apis.sys.HPortalSys/DeleteUser" => {
#[allow(non_camel_case_types)]
struct DeleteUserSvc<T: HPortalSys>(pub Arc<T>);
impl<
T: HPortalSys,
> tonic::server::UnaryService<super::DeleteUserRequest>
for DeleteUserSvc<T> {
type Response = ();
type Future = BoxFuture<
tonic::Response<Self::Response>,
tonic::Status,
>;
fn call(
&mut self,
request: tonic::Request<super::DeleteUserRequest>,
) -> Self::Future {
let inner = Arc::clone(&self.0);
let fut = async move {
<T as HPortalSys>::delete_user(&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 method = DeleteUserSvc(inner);
let codec = tonic_prost::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)
}
"/cloud.lazycat.apis.sys.HPortalSys/ResetPassword" => {
#[allow(non_camel_case_types)]
struct ResetPasswordSvc<T: HPortalSys>(pub Arc<T>);
impl<
T: HPortalSys,
> tonic::server::UnaryService<super::ResetPasswordRequest>
for ResetPasswordSvc<T> {
type Response = ();
type Future = BoxFuture<
tonic::Response<Self::Response>,
tonic::Status,
>;
fn call(
&mut self,
request: tonic::Request<super::ResetPasswordRequest>,
) -> Self::Future {
let inner = Arc::clone(&self.0);
let fut = async move {
<T as HPortalSys>::reset_password(&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 method = ResetPasswordSvc(inner);
let codec = tonic_prost::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)
}
"/cloud.lazycat.apis.sys.HPortalSys/CheckPassword" => {
#[allow(non_camel_case_types)]
struct CheckPasswordSvc<T: HPortalSys>(pub Arc<T>);
impl<
T: HPortalSys,
> tonic::server::UnaryService<super::CheckPasswordRequest>
for CheckPasswordSvc<T> {
type Response = ();
type Future = BoxFuture<
tonic::Response<Self::Response>,
tonic::Status,
>;
fn call(
&mut self,
request: tonic::Request<super::CheckPasswordRequest>,
) -> Self::Future {
let inner = Arc::clone(&self.0);
let fut = async move {
<T as HPortalSys>::check_password(&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 method = CheckPasswordSvc(inner);
let codec = tonic_prost::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)
}
"/cloud.lazycat.apis.sys.HPortalSys/GetPasswordHash" => {
#[allow(non_camel_case_types)]
struct GetPasswordHashSvc<T: HPortalSys>(pub Arc<T>);
impl<
T: HPortalSys,
> tonic::server::UnaryService<super::GetPasswordHashRequest>
for GetPasswordHashSvc<T> {
type Response = super::GetPasswordHashResponse;
type Future = BoxFuture<
tonic::Response<Self::Response>,
tonic::Status,
>;
fn call(
&mut self,
request: tonic::Request<super::GetPasswordHashRequest>,
) -> Self::Future {
let inner = Arc::clone(&self.0);
let fut = async move {
<T as HPortalSys>::get_password_hash(&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 method = GetPasswordHashSvc(inner);
let codec = tonic_prost::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)
}
"/cloud.lazycat.apis.sys.HPortalSys/SetPasswordHash" => {
#[allow(non_camel_case_types)]
struct SetPasswordHashSvc<T: HPortalSys>(pub Arc<T>);
impl<
T: HPortalSys,
> tonic::server::UnaryService<super::SetPasswordHashRequest>
for SetPasswordHashSvc<T> {
type Response = ();
type Future = BoxFuture<
tonic::Response<Self::Response>,
tonic::Status,
>;
fn call(
&mut self,
request: tonic::Request<super::SetPasswordHashRequest>,
) -> Self::Future {
let inner = Arc::clone(&self.0);
let fut = async move {
<T as HPortalSys>::set_password_hash(&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 method = SetPasswordHashSvc(inner);
let codec = tonic_prost::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)
}
"/cloud.lazycat.apis.sys.HPortalSys/QueryRole" => {
#[allow(non_camel_case_types)]
struct QueryRoleSvc<T: HPortalSys>(pub Arc<T>);
impl<T: HPortalSys> tonic::server::UnaryService<super::UserId>
for QueryRoleSvc<T> {
type Response = super::QueryRoleReply;
type Future = BoxFuture<
tonic::Response<Self::Response>,
tonic::Status,
>;
fn call(
&mut self,
request: tonic::Request<super::UserId>,
) -> Self::Future {
let inner = Arc::clone(&self.0);
let fut = async move {
<T as HPortalSys>::query_role(&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 method = QueryRoleSvc(inner);
let codec = tonic_prost::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)
}
"/cloud.lazycat.apis.sys.HPortalSys/ChangeRole" => {
#[allow(non_camel_case_types)]
struct ChangeRoleSvc<T: HPortalSys>(pub Arc<T>);
impl<
T: HPortalSys,
> tonic::server::UnaryService<super::ChangeRoleReqeust>
for ChangeRoleSvc<T> {
type Response = ();
type Future = BoxFuture<
tonic::Response<Self::Response>,
tonic::Status,
>;
fn call(
&mut self,
request: tonic::Request<super::ChangeRoleReqeust>,
) -> Self::Future {
let inner = Arc::clone(&self.0);
let fut = async move {
<T as HPortalSys>::change_role(&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 method = ChangeRoleSvc(inner);
let codec = tonic_prost::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)
}
"/cloud.lazycat.apis.sys.HPortalSys/ChangeTrustEndDevice" => {
#[allow(non_camel_case_types)]
struct ChangeTrustEndDeviceSvc<T: HPortalSys>(pub Arc<T>);
impl<
T: HPortalSys,
> tonic::server::UnaryService<super::ChangeTrustEndDeviceRequest>
for ChangeTrustEndDeviceSvc<T> {
type Response = super::ChangeTrustEndDeviceReply;
type Future = BoxFuture<
tonic::Response<Self::Response>,
tonic::Status,
>;
fn call(
&mut self,
request: tonic::Request<super::ChangeTrustEndDeviceRequest>,
) -> Self::Future {
let inner = Arc::clone(&self.0);
let fut = async move {
<T as HPortalSys>::change_trust_end_device(&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 method = ChangeTrustEndDeviceSvc(inner);
let codec = tonic_prost::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)
}
"/cloud.lazycat.apis.sys.HPortalSys/ListEndDevices" => {
#[allow(non_camel_case_types)]
struct ListEndDevicesSvc<T: HPortalSys>(pub Arc<T>);
impl<
T: HPortalSys,
> tonic::server::UnaryService<super::ListEndDeviceRequest>
for ListEndDevicesSvc<T> {
type Response = super::ListEndDeviceReply;
type Future = BoxFuture<
tonic::Response<Self::Response>,
tonic::Status,
>;
fn call(
&mut self,
request: tonic::Request<super::ListEndDeviceRequest>,
) -> Self::Future {
let inner = Arc::clone(&self.0);
let fut = async move {
<T as HPortalSys>::list_end_devices(&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 method = ListEndDevicesSvc(inner);
let codec = tonic_prost::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)
}
"/cloud.lazycat.apis.sys.HPortalSys/RemoteSocks" => {
#[allow(non_camel_case_types)]
struct RemoteSocksSvc<T: HPortalSys>(pub Arc<T>);
impl<
T: HPortalSys,
> tonic::server::UnaryService<super::RemoteSocksRequest>
for RemoteSocksSvc<T> {
type Response = super::RemoteSocksReply;
type Future = BoxFuture<
tonic::Response<Self::Response>,
tonic::Status,
>;
fn call(
&mut self,
request: tonic::Request<super::RemoteSocksRequest>,
) -> Self::Future {
let inner = Arc::clone(&self.0);
let fut = async move {
<T as HPortalSys>::remote_socks(&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 method = RemoteSocksSvc(inner);
let codec = tonic_prost::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)
}
"/cloud.lazycat.apis.sys.HPortalSys/SetupHServer" => {
#[allow(non_camel_case_types)]
struct SetupHServerSvc<T: HPortalSys>(pub Arc<T>);
impl<
T: HPortalSys,
> tonic::server::UnaryService<super::SetupHServerRequest>
for SetupHServerSvc<T> {
type Response = super::SetupHServerReply;
type Future = BoxFuture<
tonic::Response<Self::Response>,
tonic::Status,
>;
fn call(
&mut self,
request: tonic::Request<super::SetupHServerRequest>,
) -> Self::Future {
let inner = Arc::clone(&self.0);
let fut = async move {
<T as HPortalSys>::setup_h_server(&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 method = SetupHServerSvc(inner);
let codec = tonic_prost::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)
}
"/cloud.lazycat.apis.sys.HPortalSys/ResetHServer" => {
#[allow(non_camel_case_types)]
struct ResetHServerSvc<T: HPortalSys>(pub Arc<T>);
impl<
T: HPortalSys,
> tonic::server::UnaryService<super::ResetHServerRequest>
for ResetHServerSvc<T> {
type Response = super::ResetHServerReply;
type Future = BoxFuture<
tonic::Response<Self::Response>,
tonic::Status,
>;
fn call(
&mut self,
request: tonic::Request<super::ResetHServerRequest>,
) -> Self::Future {
let inner = Arc::clone(&self.0);
let fut = async move {
<T as HPortalSys>::reset_h_server(&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 method = ResetHServerSvc(inner);
let codec = tonic_prost::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)
}
"/cloud.lazycat.apis.sys.HPortalSys/RegisterBoxService" => {
#[allow(non_camel_case_types)]
struct RegisterBoxServiceSvc<T: HPortalSys>(pub Arc<T>);
impl<
T: HPortalSys,
> tonic::server::ServerStreamingService<
super::RegisterBoxServiceRequest,
> for RegisterBoxServiceSvc<T> {
type Response = super::RegisterBoxServiceReply;
type ResponseStream = T::RegisterBoxServiceStream;
type Future = BoxFuture<
tonic::Response<Self::ResponseStream>,
tonic::Status,
>;
fn call(
&mut self,
request: tonic::Request<super::RegisterBoxServiceRequest>,
) -> Self::Future {
let inner = Arc::clone(&self.0);
let fut = async move {
<T as HPortalSys>::register_box_service(&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 method = RegisterBoxServiceSvc(inner);
let codec = tonic_prost::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.server_streaming(method, req).await;
Ok(res)
};
Box::pin(fut)
}
"/cloud.lazycat.apis.sys.HPortalSys/EmitBoxServiceChanged" => {
#[allow(non_camel_case_types)]
struct EmitBoxServiceChangedSvc<T: HPortalSys>(pub Arc<T>);
impl<
T: HPortalSys,
> tonic::server::UnaryService<super::EmitBoxServiceChangedRequest>
for EmitBoxServiceChangedSvc<T> {
type Response = ();
type Future = BoxFuture<
tonic::Response<Self::Response>,
tonic::Status,
>;
fn call(
&mut self,
request: tonic::Request<super::EmitBoxServiceChangedRequest>,
) -> Self::Future {
let inner = Arc::clone(&self.0);
let fut = async move {
<T as HPortalSys>::emit_box_service_changed(&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 method = EmitBoxServiceChangedSvc(inner);
let codec = tonic_prost::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)
}
"/cloud.lazycat.apis.sys.HPortalSys/QueryBoxServicePeerCred" => {
#[allow(non_camel_case_types)]
struct QueryBoxServicePeerCredSvc<T: HPortalSys>(pub Arc<T>);
impl<
T: HPortalSys,
> tonic::server::UnaryService<super::QueryBoxServicePeerCredRequest>
for QueryBoxServicePeerCredSvc<T> {
type Response = super::QueryBoxServicePeerCredResponse;
type Future = BoxFuture<
tonic::Response<Self::Response>,
tonic::Status,
>;
fn call(
&mut self,
request: tonic::Request<
super::QueryBoxServicePeerCredRequest,
>,
) -> Self::Future {
let inner = Arc::clone(&self.0);
let fut = async move {
<T as HPortalSys>::query_box_service_peer_cred(
&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 method = QueryBoxServicePeerCredSvc(inner);
let codec = tonic_prost::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)
}
"/cloud.lazycat.apis.sys.HPortalSys/SetRelay" => {
#[allow(non_camel_case_types)]
struct SetRelaySvc<T: HPortalSys>(pub Arc<T>);
impl<
T: HPortalSys,
> tonic::server::UnaryService<super::SetRelayRequest>
for SetRelaySvc<T> {
type Response = ();
type Future = BoxFuture<
tonic::Response<Self::Response>,
tonic::Status,
>;
fn call(
&mut self,
request: tonic::Request<super::SetRelayRequest>,
) -> Self::Future {
let inner = Arc::clone(&self.0);
let fut = async move {
<T as HPortalSys>::set_relay(&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 method = SetRelaySvc(inner);
let codec = tonic_prost::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)
}
"/cloud.lazycat.apis.sys.HPortalSys/DumpPeers" => {
#[allow(non_camel_case_types)]
struct DumpPeersSvc<T: HPortalSys>(pub Arc<T>);
impl<T: HPortalSys> tonic::server::UnaryService<()>
for DumpPeersSvc<T> {
type Response = super::PeersInfo;
type Future = BoxFuture<
tonic::Response<Self::Response>,
tonic::Status,
>;
fn call(&mut self, request: tonic::Request<()>) -> Self::Future {
let inner = Arc::clone(&self.0);
let fut = async move {
<T as HPortalSys>::dump_peers(&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 method = DumpPeersSvc(inner);
let codec = tonic_prost::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 {
let mut response = http::Response::new(
tonic::body::Body::default(),
);
let headers = response.headers_mut();
headers
.insert(
tonic::Status::GRPC_STATUS,
(tonic::Code::Unimplemented as i32).into(),
);
headers
.insert(
http::header::CONTENT_TYPE,
tonic::metadata::GRPC_CONTENT_TYPE,
);
Ok(response)
})
}
}
}
}
impl<T> Clone for HPortalSysServer<T> {
fn clone(&self) -> Self {
let inner = self.inner.clone();
Self {
inner,
accept_compression_encodings: self.accept_compression_encodings,
send_compression_encodings: self.send_compression_encodings,
max_decoding_message_size: self.max_decoding_message_size,
max_encoding_message_size: self.max_encoding_message_size,
}
}
}
pub const SERVICE_NAME: &str = "cloud.lazycat.apis.sys.HPortalSys";
impl<T> tonic::server::NamedService for HPortalSysServer<T> {
const NAME: &'static str = SERVICE_NAME;
}
}
pub mod access_controler_service_client {
#![allow(
unused_variables,
dead_code,
missing_docs,
clippy::wildcard_imports,
clippy::let_unit_value,
)]
use tonic::codegen::*;
use tonic::codegen::http::Uri;
#[derive(Debug, Clone)]
pub struct AccessControlerServiceClient<T> {
inner: tonic::client::Grpc<T>,
}
impl<T> AccessControlerServiceClient<T>
where
T: tonic::client::GrpcService<tonic::body::Body>,
T::Error: Into<StdError>,
T::ResponseBody: Body<Data = Bytes> + std::marker::Send + 'static,
<T::ResponseBody as Body>::Error: Into<StdError> + std::marker::Send,
{
pub fn new(inner: T) -> Self {
let inner = tonic::client::Grpc::new(inner);
Self { inner }
}
pub fn with_origin(inner: T, origin: Uri) -> Self {
let inner = tonic::client::Grpc::with_origin(inner, origin);
Self { inner }
}
pub fn with_interceptor<F>(
inner: T,
interceptor: F,
) -> AccessControlerServiceClient<InterceptedService<T, F>>
where
F: tonic::service::Interceptor,
T::ResponseBody: Default,
T: tonic::codegen::Service<
http::Request<tonic::body::Body>,
Response = http::Response<
<T as tonic::client::GrpcService<tonic::body::Body>>::ResponseBody,
>,
>,
<T as tonic::codegen::Service<
http::Request<tonic::body::Body>,
>>::Error: Into<StdError> + std::marker::Send + std::marker::Sync,
{
AccessControlerServiceClient::new(
InterceptedService::new(inner, interceptor),
)
}
#[must_use]
pub fn send_compressed(mut self, encoding: CompressionEncoding) -> Self {
self.inner = self.inner.send_compressed(encoding);
self
}
#[must_use]
pub fn accept_compressed(mut self, encoding: CompressionEncoding) -> Self {
self.inner = self.inner.accept_compressed(encoding);
self
}
#[must_use]
pub fn max_decoding_message_size(mut self, limit: usize) -> Self {
self.inner = self.inner.max_decoding_message_size(limit);
self
}
#[must_use]
pub fn max_encoding_message_size(mut self, limit: usize) -> Self {
self.inner = self.inner.max_encoding_message_size(limit);
self
}
pub async fn set_app_access_policy(
&mut self,
request: impl tonic::IntoRequest<super::AppAccessPolicyRequest>,
) -> std::result::Result<tonic::Response<()>, tonic::Status> {
self.inner
.ready()
.await
.map_err(|e| {
tonic::Status::unknown(
format!("Service was not ready: {}", e.into()),
)
})?;
let codec = tonic_prost::ProstCodec::default();
let path = http::uri::PathAndQuery::from_static(
"/cloud.lazycat.apis.sys.AccessControlerService/SetAppAccessPolicy",
);
let mut req = request.into_request();
req.extensions_mut()
.insert(
GrpcMethod::new(
"cloud.lazycat.apis.sys.AccessControlerService",
"SetAppAccessPolicy",
),
);
self.inner.unary(req, path, codec).await
}
pub async fn query_app_access_policy(
&mut self,
request: impl tonic::IntoRequest<super::AppAccessPolicyRequest>,
) -> std::result::Result<
tonic::Response<super::AppAccessPolicy>,
tonic::Status,
> {
self.inner
.ready()
.await
.map_err(|e| {
tonic::Status::unknown(
format!("Service was not ready: {}", e.into()),
)
})?;
let codec = tonic_prost::ProstCodec::default();
let path = http::uri::PathAndQuery::from_static(
"/cloud.lazycat.apis.sys.AccessControlerService/QueryAppAccessPolicy",
);
let mut req = request.into_request();
req.extensions_mut()
.insert(
GrpcMethod::new(
"cloud.lazycat.apis.sys.AccessControlerService",
"QueryAppAccessPolicy",
),
);
self.inner.unary(req, path, codec).await
}
pub async fn get_app_last_access_time(
&mut self,
request: impl tonic::IntoRequest<super::IngressAppLastAccessTimeRequest>,
) -> std::result::Result<
tonic::Response<super::IngressAppLastAccessTimeResponse>,
tonic::Status,
> {
self.inner
.ready()
.await
.map_err(|e| {
tonic::Status::unknown(
format!("Service was not ready: {}", e.into()),
)
})?;
let codec = tonic_prost::ProstCodec::default();
let path = http::uri::PathAndQuery::from_static(
"/cloud.lazycat.apis.sys.AccessControlerService/GetAppLastAccessTime",
);
let mut req = request.into_request();
req.extensions_mut()
.insert(
GrpcMethod::new(
"cloud.lazycat.apis.sys.AccessControlerService",
"GetAppLastAccessTime",
),
);
self.inner.unary(req, path, codec).await
}
}
}
pub mod access_controler_service_server {
#![allow(
unused_variables,
dead_code,
missing_docs,
clippy::wildcard_imports,
clippy::let_unit_value,
)]
use tonic::codegen::*;
#[async_trait]
pub trait AccessControlerService: std::marker::Send + std::marker::Sync + 'static {
async fn set_app_access_policy(
&self,
request: tonic::Request<super::AppAccessPolicyRequest>,
) -> std::result::Result<tonic::Response<()>, tonic::Status>;
async fn query_app_access_policy(
&self,
request: tonic::Request<super::AppAccessPolicyRequest>,
) -> std::result::Result<tonic::Response<super::AppAccessPolicy>, tonic::Status>;
async fn get_app_last_access_time(
&self,
request: tonic::Request<super::IngressAppLastAccessTimeRequest>,
) -> std::result::Result<
tonic::Response<super::IngressAppLastAccessTimeResponse>,
tonic::Status,
>;
}
#[derive(Debug)]
pub struct AccessControlerServiceServer<T> {
inner: Arc<T>,
accept_compression_encodings: EnabledCompressionEncodings,
send_compression_encodings: EnabledCompressionEncodings,
max_decoding_message_size: Option<usize>,
max_encoding_message_size: Option<usize>,
}
impl<T> AccessControlerServiceServer<T> {
pub fn new(inner: T) -> Self {
Self::from_arc(Arc::new(inner))
}
pub fn from_arc(inner: Arc<T>) -> Self {
Self {
inner,
accept_compression_encodings: Default::default(),
send_compression_encodings: Default::default(),
max_decoding_message_size: None,
max_encoding_message_size: None,
}
}
pub fn with_interceptor<F>(
inner: T,
interceptor: F,
) -> InterceptedService<Self, F>
where
F: tonic::service::Interceptor,
{
InterceptedService::new(Self::new(inner), interceptor)
}
#[must_use]
pub fn accept_compressed(mut self, encoding: CompressionEncoding) -> Self {
self.accept_compression_encodings.enable(encoding);
self
}
#[must_use]
pub fn send_compressed(mut self, encoding: CompressionEncoding) -> Self {
self.send_compression_encodings.enable(encoding);
self
}
#[must_use]
pub fn max_decoding_message_size(mut self, limit: usize) -> Self {
self.max_decoding_message_size = Some(limit);
self
}
#[must_use]
pub fn max_encoding_message_size(mut self, limit: usize) -> Self {
self.max_encoding_message_size = Some(limit);
self
}
}
impl<T, B> tonic::codegen::Service<http::Request<B>>
for AccessControlerServiceServer<T>
where
T: AccessControlerService,
B: Body + std::marker::Send + 'static,
B::Error: Into<StdError> + std::marker::Send + 'static,
{
type Response = http::Response<tonic::body::Body>;
type Error = std::convert::Infallible;
type Future = BoxFuture<Self::Response, Self::Error>;
fn poll_ready(
&mut self,
_cx: &mut Context<'_>,
) -> Poll<std::result::Result<(), Self::Error>> {
Poll::Ready(Ok(()))
}
fn call(&mut self, req: http::Request<B>) -> Self::Future {
match req.uri().path() {
"/cloud.lazycat.apis.sys.AccessControlerService/SetAppAccessPolicy" => {
#[allow(non_camel_case_types)]
struct SetAppAccessPolicySvc<T: AccessControlerService>(pub Arc<T>);
impl<
T: AccessControlerService,
> tonic::server::UnaryService<super::AppAccessPolicyRequest>
for SetAppAccessPolicySvc<T> {
type Response = ();
type Future = BoxFuture<
tonic::Response<Self::Response>,
tonic::Status,
>;
fn call(
&mut self,
request: tonic::Request<super::AppAccessPolicyRequest>,
) -> Self::Future {
let inner = Arc::clone(&self.0);
let fut = async move {
<T as AccessControlerService>::set_app_access_policy(
&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 method = SetAppAccessPolicySvc(inner);
let codec = tonic_prost::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)
}
"/cloud.lazycat.apis.sys.AccessControlerService/QueryAppAccessPolicy" => {
#[allow(non_camel_case_types)]
struct QueryAppAccessPolicySvc<T: AccessControlerService>(
pub Arc<T>,
);
impl<
T: AccessControlerService,
> tonic::server::UnaryService<super::AppAccessPolicyRequest>
for QueryAppAccessPolicySvc<T> {
type Response = super::AppAccessPolicy;
type Future = BoxFuture<
tonic::Response<Self::Response>,
tonic::Status,
>;
fn call(
&mut self,
request: tonic::Request<super::AppAccessPolicyRequest>,
) -> Self::Future {
let inner = Arc::clone(&self.0);
let fut = async move {
<T as AccessControlerService>::query_app_access_policy(
&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 method = QueryAppAccessPolicySvc(inner);
let codec = tonic_prost::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)
}
"/cloud.lazycat.apis.sys.AccessControlerService/GetAppLastAccessTime" => {
#[allow(non_camel_case_types)]
struct GetAppLastAccessTimeSvc<T: AccessControlerService>(
pub Arc<T>,
);
impl<
T: AccessControlerService,
> tonic::server::UnaryService<super::IngressAppLastAccessTimeRequest>
for GetAppLastAccessTimeSvc<T> {
type Response = super::IngressAppLastAccessTimeResponse;
type Future = BoxFuture<
tonic::Response<Self::Response>,
tonic::Status,
>;
fn call(
&mut self,
request: tonic::Request<
super::IngressAppLastAccessTimeRequest,
>,
) -> Self::Future {
let inner = Arc::clone(&self.0);
let fut = async move {
<T as AccessControlerService>::get_app_last_access_time(
&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 method = GetAppLastAccessTimeSvc(inner);
let codec = tonic_prost::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 {
let mut response = http::Response::new(
tonic::body::Body::default(),
);
let headers = response.headers_mut();
headers
.insert(
tonic::Status::GRPC_STATUS,
(tonic::Code::Unimplemented as i32).into(),
);
headers
.insert(
http::header::CONTENT_TYPE,
tonic::metadata::GRPC_CONTENT_TYPE,
);
Ok(response)
})
}
}
}
}
impl<T> Clone for AccessControlerServiceServer<T> {
fn clone(&self) -> Self {
let inner = self.inner.clone();
Self {
inner,
accept_compression_encodings: self.accept_compression_encodings,
send_compression_encodings: self.send_compression_encodings,
max_decoding_message_size: self.max_decoding_message_size,
max_encoding_message_size: self.max_encoding_message_size,
}
}
}
pub const SERVICE_NAME: &str = "cloud.lazycat.apis.sys.AccessControlerService";
impl<T> tonic::server::NamedService for AccessControlerServiceServer<T> {
const NAME: &'static str = SERVICE_NAME;
}
}
pub mod user_session_service_client {
#![allow(
unused_variables,
dead_code,
missing_docs,
clippy::wildcard_imports,
clippy::let_unit_value,
)]
use tonic::codegen::*;
use tonic::codegen::http::Uri;
#[derive(Debug, Clone)]
pub struct UserSessionServiceClient<T> {
inner: tonic::client::Grpc<T>,
}
impl<T> UserSessionServiceClient<T>
where
T: tonic::client::GrpcService<tonic::body::Body>,
T::Error: Into<StdError>,
T::ResponseBody: Body<Data = Bytes> + std::marker::Send + 'static,
<T::ResponseBody as Body>::Error: Into<StdError> + std::marker::Send,
{
pub fn new(inner: T) -> Self {
let inner = tonic::client::Grpc::new(inner);
Self { inner }
}
pub fn with_origin(inner: T, origin: Uri) -> Self {
let inner = tonic::client::Grpc::with_origin(inner, origin);
Self { inner }
}
pub fn with_interceptor<F>(
inner: T,
interceptor: F,
) -> UserSessionServiceClient<InterceptedService<T, F>>
where
F: tonic::service::Interceptor,
T::ResponseBody: Default,
T: tonic::codegen::Service<
http::Request<tonic::body::Body>,
Response = http::Response<
<T as tonic::client::GrpcService<tonic::body::Body>>::ResponseBody,
>,
>,
<T as tonic::codegen::Service<
http::Request<tonic::body::Body>,
>>::Error: Into<StdError> + std::marker::Send + std::marker::Sync,
{
UserSessionServiceClient::new(InterceptedService::new(inner, interceptor))
}
#[must_use]
pub fn send_compressed(mut self, encoding: CompressionEncoding) -> Self {
self.inner = self.inner.send_compressed(encoding);
self
}
#[must_use]
pub fn accept_compressed(mut self, encoding: CompressionEncoding) -> Self {
self.inner = self.inner.accept_compressed(encoding);
self
}
#[must_use]
pub fn max_decoding_message_size(mut self, limit: usize) -> Self {
self.inner = self.inner.max_decoding_message_size(limit);
self
}
#[must_use]
pub fn max_encoding_message_size(mut self, limit: usize) -> Self {
self.inner = self.inner.max_encoding_message_size(limit);
self
}
pub async fn subscribe_event(
&mut self,
request: impl tonic::IntoRequest<super::SubscribeEventRequest>,
) -> std::result::Result<
tonic::Response<tonic::codec::Streaming<super::SubscribeEventResponse>>,
tonic::Status,
> {
self.inner
.ready()
.await
.map_err(|e| {
tonic::Status::unknown(
format!("Service was not ready: {}", e.into()),
)
})?;
let codec = tonic_prost::ProstCodec::default();
let path = http::uri::PathAndQuery::from_static(
"/cloud.lazycat.apis.sys.UserSessionService/SubscribeEvent",
);
let mut req = request.into_request();
req.extensions_mut()
.insert(
GrpcMethod::new(
"cloud.lazycat.apis.sys.UserSessionService",
"SubscribeEvent",
),
);
self.inner.server_streaming(req, path, codec).await
}
}
}
pub mod user_session_service_server {
#![allow(
unused_variables,
dead_code,
missing_docs,
clippy::wildcard_imports,
clippy::let_unit_value,
)]
use tonic::codegen::*;
#[async_trait]
pub trait UserSessionService: std::marker::Send + std::marker::Sync + 'static {
type SubscribeEventStream: tonic::codegen::tokio_stream::Stream<
Item = std::result::Result<super::SubscribeEventResponse, tonic::Status>,
>
+ std::marker::Send
+ 'static;
async fn subscribe_event(
&self,
request: tonic::Request<super::SubscribeEventRequest>,
) -> std::result::Result<
tonic::Response<Self::SubscribeEventStream>,
tonic::Status,
>;
}
#[derive(Debug)]
pub struct UserSessionServiceServer<T> {
inner: Arc<T>,
accept_compression_encodings: EnabledCompressionEncodings,
send_compression_encodings: EnabledCompressionEncodings,
max_decoding_message_size: Option<usize>,
max_encoding_message_size: Option<usize>,
}
impl<T> UserSessionServiceServer<T> {
pub fn new(inner: T) -> Self {
Self::from_arc(Arc::new(inner))
}
pub fn from_arc(inner: Arc<T>) -> Self {
Self {
inner,
accept_compression_encodings: Default::default(),
send_compression_encodings: Default::default(),
max_decoding_message_size: None,
max_encoding_message_size: None,
}
}
pub fn with_interceptor<F>(
inner: T,
interceptor: F,
) -> InterceptedService<Self, F>
where
F: tonic::service::Interceptor,
{
InterceptedService::new(Self::new(inner), interceptor)
}
#[must_use]
pub fn accept_compressed(mut self, encoding: CompressionEncoding) -> Self {
self.accept_compression_encodings.enable(encoding);
self
}
#[must_use]
pub fn send_compressed(mut self, encoding: CompressionEncoding) -> Self {
self.send_compression_encodings.enable(encoding);
self
}
#[must_use]
pub fn max_decoding_message_size(mut self, limit: usize) -> Self {
self.max_decoding_message_size = Some(limit);
self
}
#[must_use]
pub fn max_encoding_message_size(mut self, limit: usize) -> Self {
self.max_encoding_message_size = Some(limit);
self
}
}
impl<T, B> tonic::codegen::Service<http::Request<B>> for UserSessionServiceServer<T>
where
T: UserSessionService,
B: Body + std::marker::Send + 'static,
B::Error: Into<StdError> + std::marker::Send + 'static,
{
type Response = http::Response<tonic::body::Body>;
type Error = std::convert::Infallible;
type Future = BoxFuture<Self::Response, Self::Error>;
fn poll_ready(
&mut self,
_cx: &mut Context<'_>,
) -> Poll<std::result::Result<(), Self::Error>> {
Poll::Ready(Ok(()))
}
fn call(&mut self, req: http::Request<B>) -> Self::Future {
match req.uri().path() {
"/cloud.lazycat.apis.sys.UserSessionService/SubscribeEvent" => {
#[allow(non_camel_case_types)]
struct SubscribeEventSvc<T: UserSessionService>(pub Arc<T>);
impl<
T: UserSessionService,
> tonic::server::ServerStreamingService<super::SubscribeEventRequest>
for SubscribeEventSvc<T> {
type Response = super::SubscribeEventResponse;
type ResponseStream = T::SubscribeEventStream;
type Future = BoxFuture<
tonic::Response<Self::ResponseStream>,
tonic::Status,
>;
fn call(
&mut self,
request: tonic::Request<super::SubscribeEventRequest>,
) -> Self::Future {
let inner = Arc::clone(&self.0);
let fut = async move {
<T as UserSessionService>::subscribe_event(&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 method = SubscribeEventSvc(inner);
let codec = tonic_prost::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.server_streaming(method, req).await;
Ok(res)
};
Box::pin(fut)
}
_ => {
Box::pin(async move {
let mut response = http::Response::new(
tonic::body::Body::default(),
);
let headers = response.headers_mut();
headers
.insert(
tonic::Status::GRPC_STATUS,
(tonic::Code::Unimplemented as i32).into(),
);
headers
.insert(
http::header::CONTENT_TYPE,
tonic::metadata::GRPC_CONTENT_TYPE,
);
Ok(response)
})
}
}
}
}
impl<T> Clone for UserSessionServiceServer<T> {
fn clone(&self) -> Self {
let inner = self.inner.clone();
Self {
inner,
accept_compression_encodings: self.accept_compression_encodings,
send_compression_encodings: self.send_compression_encodings,
max_decoding_message_size: self.max_decoding_message_size,
max_encoding_message_size: self.max_encoding_message_size,
}
}
}
pub const SERVICE_NAME: &str = "cloud.lazycat.apis.sys.UserSessionService";
impl<T> tonic::server::NamedService for UserSessionServiceServer<T> {
const NAME: &'static str = SERVICE_NAME;
}
}
pub mod network_manager_client {
#![allow(
unused_variables,
dead_code,
missing_docs,
clippy::wildcard_imports,
clippy::let_unit_value,
)]
use tonic::codegen::*;
use tonic::codegen::http::Uri;
#[derive(Debug, Clone)]
pub struct NetworkManagerClient<T> {
inner: tonic::client::Grpc<T>,
}
impl<T> NetworkManagerClient<T>
where
T: tonic::client::GrpcService<tonic::body::Body>,
T::Error: Into<StdError>,
T::ResponseBody: Body<Data = Bytes> + std::marker::Send + 'static,
<T::ResponseBody as Body>::Error: Into<StdError> + std::marker::Send,
{
pub fn new(inner: T) -> Self {
let inner = tonic::client::Grpc::new(inner);
Self { inner }
}
pub fn with_origin(inner: T, origin: Uri) -> Self {
let inner = tonic::client::Grpc::with_origin(inner, origin);
Self { inner }
}
pub fn with_interceptor<F>(
inner: T,
interceptor: F,
) -> NetworkManagerClient<InterceptedService<T, F>>
where
F: tonic::service::Interceptor,
T::ResponseBody: Default,
T: tonic::codegen::Service<
http::Request<tonic::body::Body>,
Response = http::Response<
<T as tonic::client::GrpcService<tonic::body::Body>>::ResponseBody,
>,
>,
<T as tonic::codegen::Service<
http::Request<tonic::body::Body>,
>>::Error: Into<StdError> + std::marker::Send + std::marker::Sync,
{
NetworkManagerClient::new(InterceptedService::new(inner, interceptor))
}
#[must_use]
pub fn send_compressed(mut self, encoding: CompressionEncoding) -> Self {
self.inner = self.inner.send_compressed(encoding);
self
}
#[must_use]
pub fn accept_compressed(mut self, encoding: CompressionEncoding) -> Self {
self.inner = self.inner.accept_compressed(encoding);
self
}
#[must_use]
pub fn max_decoding_message_size(mut self, limit: usize) -> Self {
self.inner = self.inner.max_decoding_message_size(limit);
self
}
#[must_use]
pub fn max_encoding_message_size(mut self, limit: usize) -> Self {
self.inner = self.inner.max_encoding_message_size(limit);
self
}
pub async fn status(
&mut self,
request: impl tonic::IntoRequest<()>,
) -> std::result::Result<
tonic::Response<super::NetworkDeviceStatusInfo>,
tonic::Status,
> {
self.inner
.ready()
.await
.map_err(|e| {
tonic::Status::unknown(
format!("Service was not ready: {}", e.into()),
)
})?;
let codec = tonic_prost::ProstCodec::default();
let path = http::uri::PathAndQuery::from_static(
"/cloud.lazycat.apis.sys.NetworkManager/Status",
);
let mut req = request.into_request();
req.extensions_mut()
.insert(
GrpcMethod::new("cloud.lazycat.apis.sys.NetworkManager", "Status"),
);
self.inner.unary(req, path, codec).await
}
pub async fn wifi_scan(
&mut self,
request: impl tonic::IntoRequest<()>,
) -> std::result::Result<tonic::Response<()>, tonic::Status> {
self.inner
.ready()
.await
.map_err(|e| {
tonic::Status::unknown(
format!("Service was not ready: {}", e.into()),
)
})?;
let codec = tonic_prost::ProstCodec::default();
let path = http::uri::PathAndQuery::from_static(
"/cloud.lazycat.apis.sys.NetworkManager/WifiScan",
);
let mut req = request.into_request();
req.extensions_mut()
.insert(
GrpcMethod::new("cloud.lazycat.apis.sys.NetworkManager", "WifiScan"),
);
self.inner.unary(req, path, codec).await
}
pub async fn wifi_list(
&mut self,
request: impl tonic::IntoRequest<()>,
) -> std::result::Result<
tonic::Response<super::AccessPointInfoList>,
tonic::Status,
> {
self.inner
.ready()
.await
.map_err(|e| {
tonic::Status::unknown(
format!("Service was not ready: {}", e.into()),
)
})?;
let codec = tonic_prost::ProstCodec::default();
let path = http::uri::PathAndQuery::from_static(
"/cloud.lazycat.apis.sys.NetworkManager/WifiList",
);
let mut req = request.into_request();
req.extensions_mut()
.insert(
GrpcMethod::new("cloud.lazycat.apis.sys.NetworkManager", "WifiList"),
);
self.inner.unary(req, path, codec).await
}
pub async fn wifi_connect(
&mut self,
request: impl tonic::IntoRequest<super::WifiConnectInfo>,
) -> std::result::Result<
tonic::Response<super::WifiConnectReply>,
tonic::Status,
> {
self.inner
.ready()
.await
.map_err(|e| {
tonic::Status::unknown(
format!("Service was not ready: {}", e.into()),
)
})?;
let codec = tonic_prost::ProstCodec::default();
let path = http::uri::PathAndQuery::from_static(
"/cloud.lazycat.apis.sys.NetworkManager/WifiConnect",
);
let mut req = request.into_request();
req.extensions_mut()
.insert(
GrpcMethod::new(
"cloud.lazycat.apis.sys.NetworkManager",
"WifiConnect",
),
);
self.inner.unary(req, path, codec).await
}
pub async fn wifi_connect_temp(
&mut self,
request: impl tonic::IntoRequest<super::WifiConnectTempInfo>,
) -> std::result::Result<
tonic::Response<super::WifiConnectReply>,
tonic::Status,
> {
self.inner
.ready()
.await
.map_err(|e| {
tonic::Status::unknown(
format!("Service was not ready: {}", e.into()),
)
})?;
let codec = tonic_prost::ProstCodec::default();
let path = http::uri::PathAndQuery::from_static(
"/cloud.lazycat.apis.sys.NetworkManager/WifiConnectTemp",
);
let mut req = request.into_request();
req.extensions_mut()
.insert(
GrpcMethod::new(
"cloud.lazycat.apis.sys.NetworkManager",
"WifiConnectTemp",
),
);
self.inner.unary(req, path, codec).await
}
pub async fn wifi_forget(
&mut self,
request: impl tonic::IntoRequest<super::WifiForgetInfo>,
) -> std::result::Result<tonic::Response<()>, tonic::Status> {
self.inner
.ready()
.await
.map_err(|e| {
tonic::Status::unknown(
format!("Service was not ready: {}", e.into()),
)
})?;
let codec = tonic_prost::ProstCodec::default();
let path = http::uri::PathAndQuery::from_static(
"/cloud.lazycat.apis.sys.NetworkManager/WifiForget",
);
let mut req = request.into_request();
req.extensions_mut()
.insert(
GrpcMethod::new(
"cloud.lazycat.apis.sys.NetworkManager",
"WifiForget",
),
);
self.inner.unary(req, path, codec).await
}
pub async fn wifi_config_add(
&mut self,
request: impl tonic::IntoRequest<super::WifiConfigInfo>,
) -> std::result::Result<
tonic::Response<super::WifiConnectReply>,
tonic::Status,
> {
self.inner
.ready()
.await
.map_err(|e| {
tonic::Status::unknown(
format!("Service was not ready: {}", e.into()),
)
})?;
let codec = tonic_prost::ProstCodec::default();
let path = http::uri::PathAndQuery::from_static(
"/cloud.lazycat.apis.sys.NetworkManager/WifiConfigAdd",
);
let mut req = request.into_request();
req.extensions_mut()
.insert(
GrpcMethod::new(
"cloud.lazycat.apis.sys.NetworkManager",
"WifiConfigAdd",
),
);
self.inner.unary(req, path, codec).await
}
pub async fn get_connectivity(
&mut self,
request: impl tonic::IntoRequest<()>,
) -> std::result::Result<
tonic::Response<super::GetConnectivityReply>,
tonic::Status,
> {
self.inner
.ready()
.await
.map_err(|e| {
tonic::Status::unknown(
format!("Service was not ready: {}", e.into()),
)
})?;
let codec = tonic_prost::ProstCodec::default();
let path = http::uri::PathAndQuery::from_static(
"/cloud.lazycat.apis.sys.NetworkManager/GetConnectivity",
);
let mut req = request.into_request();
req.extensions_mut()
.insert(
GrpcMethod::new(
"cloud.lazycat.apis.sys.NetworkManager",
"GetConnectivity",
),
);
self.inner.unary(req, path, codec).await
}
pub async fn connectivity(
&mut self,
request: impl tonic::IntoRequest<super::ConnectivityRequest>,
) -> std::result::Result<
tonic::Response<super::ConnectivityReply>,
tonic::Status,
> {
self.inner
.ready()
.await
.map_err(|e| {
tonic::Status::unknown(
format!("Service was not ready: {}", e.into()),
)
})?;
let codec = tonic_prost::ProstCodec::default();
let path = http::uri::PathAndQuery::from_static(
"/cloud.lazycat.apis.sys.NetworkManager/Connectivity",
);
let mut req = request.into_request();
req.extensions_mut()
.insert(
GrpcMethod::new(
"cloud.lazycat.apis.sys.NetworkManager",
"Connectivity",
),
);
self.inner.unary(req, path, codec).await
}
pub async fn nmcli_call(
&mut self,
request: impl tonic::IntoRequest<super::NmcliCallRequest>,
) -> std::result::Result<tonic::Response<super::NmcliCallReply>, tonic::Status> {
self.inner
.ready()
.await
.map_err(|e| {
tonic::Status::unknown(
format!("Service was not ready: {}", e.into()),
)
})?;
let codec = tonic_prost::ProstCodec::default();
let path = http::uri::PathAndQuery::from_static(
"/cloud.lazycat.apis.sys.NetworkManager/NmcliCall",
);
let mut req = request.into_request();
req.extensions_mut()
.insert(
GrpcMethod::new("cloud.lazycat.apis.sys.NetworkManager", "NmcliCall"),
);
self.inner.unary(req, path, codec).await
}
}
}
pub mod network_manager_server {
#![allow(
unused_variables,
dead_code,
missing_docs,
clippy::wildcard_imports,
clippy::let_unit_value,
)]
use tonic::codegen::*;
#[async_trait]
pub trait NetworkManager: std::marker::Send + std::marker::Sync + 'static {
async fn status(
&self,
request: tonic::Request<()>,
) -> std::result::Result<
tonic::Response<super::NetworkDeviceStatusInfo>,
tonic::Status,
>;
async fn wifi_scan(
&self,
request: tonic::Request<()>,
) -> std::result::Result<tonic::Response<()>, tonic::Status>;
async fn wifi_list(
&self,
request: tonic::Request<()>,
) -> std::result::Result<
tonic::Response<super::AccessPointInfoList>,
tonic::Status,
>;
async fn wifi_connect(
&self,
request: tonic::Request<super::WifiConnectInfo>,
) -> std::result::Result<
tonic::Response<super::WifiConnectReply>,
tonic::Status,
>;
async fn wifi_connect_temp(
&self,
request: tonic::Request<super::WifiConnectTempInfo>,
) -> std::result::Result<
tonic::Response<super::WifiConnectReply>,
tonic::Status,
>;
async fn wifi_forget(
&self,
request: tonic::Request<super::WifiForgetInfo>,
) -> std::result::Result<tonic::Response<()>, tonic::Status>;
async fn wifi_config_add(
&self,
request: tonic::Request<super::WifiConfigInfo>,
) -> std::result::Result<
tonic::Response<super::WifiConnectReply>,
tonic::Status,
>;
async fn get_connectivity(
&self,
request: tonic::Request<()>,
) -> std::result::Result<
tonic::Response<super::GetConnectivityReply>,
tonic::Status,
>;
async fn connectivity(
&self,
request: tonic::Request<super::ConnectivityRequest>,
) -> std::result::Result<
tonic::Response<super::ConnectivityReply>,
tonic::Status,
>;
async fn nmcli_call(
&self,
request: tonic::Request<super::NmcliCallRequest>,
) -> std::result::Result<tonic::Response<super::NmcliCallReply>, tonic::Status>;
}
#[derive(Debug)]
pub struct NetworkManagerServer<T> {
inner: Arc<T>,
accept_compression_encodings: EnabledCompressionEncodings,
send_compression_encodings: EnabledCompressionEncodings,
max_decoding_message_size: Option<usize>,
max_encoding_message_size: Option<usize>,
}
impl<T> NetworkManagerServer<T> {
pub fn new(inner: T) -> Self {
Self::from_arc(Arc::new(inner))
}
pub fn from_arc(inner: Arc<T>) -> Self {
Self {
inner,
accept_compression_encodings: Default::default(),
send_compression_encodings: Default::default(),
max_decoding_message_size: None,
max_encoding_message_size: None,
}
}
pub fn with_interceptor<F>(
inner: T,
interceptor: F,
) -> InterceptedService<Self, F>
where
F: tonic::service::Interceptor,
{
InterceptedService::new(Self::new(inner), interceptor)
}
#[must_use]
pub fn accept_compressed(mut self, encoding: CompressionEncoding) -> Self {
self.accept_compression_encodings.enable(encoding);
self
}
#[must_use]
pub fn send_compressed(mut self, encoding: CompressionEncoding) -> Self {
self.send_compression_encodings.enable(encoding);
self
}
#[must_use]
pub fn max_decoding_message_size(mut self, limit: usize) -> Self {
self.max_decoding_message_size = Some(limit);
self
}
#[must_use]
pub fn max_encoding_message_size(mut self, limit: usize) -> Self {
self.max_encoding_message_size = Some(limit);
self
}
}
impl<T, B> tonic::codegen::Service<http::Request<B>> for NetworkManagerServer<T>
where
T: NetworkManager,
B: Body + std::marker::Send + 'static,
B::Error: Into<StdError> + std::marker::Send + 'static,
{
type Response = http::Response<tonic::body::Body>;
type Error = std::convert::Infallible;
type Future = BoxFuture<Self::Response, Self::Error>;
fn poll_ready(
&mut self,
_cx: &mut Context<'_>,
) -> Poll<std::result::Result<(), Self::Error>> {
Poll::Ready(Ok(()))
}
fn call(&mut self, req: http::Request<B>) -> Self::Future {
match req.uri().path() {
"/cloud.lazycat.apis.sys.NetworkManager/Status" => {
#[allow(non_camel_case_types)]
struct StatusSvc<T: NetworkManager>(pub Arc<T>);
impl<T: NetworkManager> tonic::server::UnaryService<()>
for StatusSvc<T> {
type Response = super::NetworkDeviceStatusInfo;
type Future = BoxFuture<
tonic::Response<Self::Response>,
tonic::Status,
>;
fn call(&mut self, request: tonic::Request<()>) -> Self::Future {
let inner = Arc::clone(&self.0);
let fut = async move {
<T as NetworkManager>::status(&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 method = StatusSvc(inner);
let codec = tonic_prost::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)
}
"/cloud.lazycat.apis.sys.NetworkManager/WifiScan" => {
#[allow(non_camel_case_types)]
struct WifiScanSvc<T: NetworkManager>(pub Arc<T>);
impl<T: NetworkManager> tonic::server::UnaryService<()>
for WifiScanSvc<T> {
type Response = ();
type Future = BoxFuture<
tonic::Response<Self::Response>,
tonic::Status,
>;
fn call(&mut self, request: tonic::Request<()>) -> Self::Future {
let inner = Arc::clone(&self.0);
let fut = async move {
<T as NetworkManager>::wifi_scan(&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 method = WifiScanSvc(inner);
let codec = tonic_prost::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)
}
"/cloud.lazycat.apis.sys.NetworkManager/WifiList" => {
#[allow(non_camel_case_types)]
struct WifiListSvc<T: NetworkManager>(pub Arc<T>);
impl<T: NetworkManager> tonic::server::UnaryService<()>
for WifiListSvc<T> {
type Response = super::AccessPointInfoList;
type Future = BoxFuture<
tonic::Response<Self::Response>,
tonic::Status,
>;
fn call(&mut self, request: tonic::Request<()>) -> Self::Future {
let inner = Arc::clone(&self.0);
let fut = async move {
<T as NetworkManager>::wifi_list(&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 method = WifiListSvc(inner);
let codec = tonic_prost::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)
}
"/cloud.lazycat.apis.sys.NetworkManager/WifiConnect" => {
#[allow(non_camel_case_types)]
struct WifiConnectSvc<T: NetworkManager>(pub Arc<T>);
impl<
T: NetworkManager,
> tonic::server::UnaryService<super::WifiConnectInfo>
for WifiConnectSvc<T> {
type Response = super::WifiConnectReply;
type Future = BoxFuture<
tonic::Response<Self::Response>,
tonic::Status,
>;
fn call(
&mut self,
request: tonic::Request<super::WifiConnectInfo>,
) -> Self::Future {
let inner = Arc::clone(&self.0);
let fut = async move {
<T as NetworkManager>::wifi_connect(&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 method = WifiConnectSvc(inner);
let codec = tonic_prost::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)
}
"/cloud.lazycat.apis.sys.NetworkManager/WifiConnectTemp" => {
#[allow(non_camel_case_types)]
struct WifiConnectTempSvc<T: NetworkManager>(pub Arc<T>);
impl<
T: NetworkManager,
> tonic::server::UnaryService<super::WifiConnectTempInfo>
for WifiConnectTempSvc<T> {
type Response = super::WifiConnectReply;
type Future = BoxFuture<
tonic::Response<Self::Response>,
tonic::Status,
>;
fn call(
&mut self,
request: tonic::Request<super::WifiConnectTempInfo>,
) -> Self::Future {
let inner = Arc::clone(&self.0);
let fut = async move {
<T as NetworkManager>::wifi_connect_temp(&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 method = WifiConnectTempSvc(inner);
let codec = tonic_prost::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)
}
"/cloud.lazycat.apis.sys.NetworkManager/WifiForget" => {
#[allow(non_camel_case_types)]
struct WifiForgetSvc<T: NetworkManager>(pub Arc<T>);
impl<
T: NetworkManager,
> tonic::server::UnaryService<super::WifiForgetInfo>
for WifiForgetSvc<T> {
type Response = ();
type Future = BoxFuture<
tonic::Response<Self::Response>,
tonic::Status,
>;
fn call(
&mut self,
request: tonic::Request<super::WifiForgetInfo>,
) -> Self::Future {
let inner = Arc::clone(&self.0);
let fut = async move {
<T as NetworkManager>::wifi_forget(&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 method = WifiForgetSvc(inner);
let codec = tonic_prost::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)
}
"/cloud.lazycat.apis.sys.NetworkManager/WifiConfigAdd" => {
#[allow(non_camel_case_types)]
struct WifiConfigAddSvc<T: NetworkManager>(pub Arc<T>);
impl<
T: NetworkManager,
> tonic::server::UnaryService<super::WifiConfigInfo>
for WifiConfigAddSvc<T> {
type Response = super::WifiConnectReply;
type Future = BoxFuture<
tonic::Response<Self::Response>,
tonic::Status,
>;
fn call(
&mut self,
request: tonic::Request<super::WifiConfigInfo>,
) -> Self::Future {
let inner = Arc::clone(&self.0);
let fut = async move {
<T as NetworkManager>::wifi_config_add(&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 method = WifiConfigAddSvc(inner);
let codec = tonic_prost::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)
}
"/cloud.lazycat.apis.sys.NetworkManager/GetConnectivity" => {
#[allow(non_camel_case_types)]
struct GetConnectivitySvc<T: NetworkManager>(pub Arc<T>);
impl<T: NetworkManager> tonic::server::UnaryService<()>
for GetConnectivitySvc<T> {
type Response = super::GetConnectivityReply;
type Future = BoxFuture<
tonic::Response<Self::Response>,
tonic::Status,
>;
fn call(&mut self, request: tonic::Request<()>) -> Self::Future {
let inner = Arc::clone(&self.0);
let fut = async move {
<T as NetworkManager>::get_connectivity(&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 method = GetConnectivitySvc(inner);
let codec = tonic_prost::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)
}
"/cloud.lazycat.apis.sys.NetworkManager/Connectivity" => {
#[allow(non_camel_case_types)]
struct ConnectivitySvc<T: NetworkManager>(pub Arc<T>);
impl<
T: NetworkManager,
> tonic::server::UnaryService<super::ConnectivityRequest>
for ConnectivitySvc<T> {
type Response = super::ConnectivityReply;
type Future = BoxFuture<
tonic::Response<Self::Response>,
tonic::Status,
>;
fn call(
&mut self,
request: tonic::Request<super::ConnectivityRequest>,
) -> Self::Future {
let inner = Arc::clone(&self.0);
let fut = async move {
<T as NetworkManager>::connectivity(&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 method = ConnectivitySvc(inner);
let codec = tonic_prost::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)
}
"/cloud.lazycat.apis.sys.NetworkManager/NmcliCall" => {
#[allow(non_camel_case_types)]
struct NmcliCallSvc<T: NetworkManager>(pub Arc<T>);
impl<
T: NetworkManager,
> tonic::server::UnaryService<super::NmcliCallRequest>
for NmcliCallSvc<T> {
type Response = super::NmcliCallReply;
type Future = BoxFuture<
tonic::Response<Self::Response>,
tonic::Status,
>;
fn call(
&mut self,
request: tonic::Request<super::NmcliCallRequest>,
) -> Self::Future {
let inner = Arc::clone(&self.0);
let fut = async move {
<T as NetworkManager>::nmcli_call(&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 method = NmcliCallSvc(inner);
let codec = tonic_prost::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 {
let mut response = http::Response::new(
tonic::body::Body::default(),
);
let headers = response.headers_mut();
headers
.insert(
tonic::Status::GRPC_STATUS,
(tonic::Code::Unimplemented as i32).into(),
);
headers
.insert(
http::header::CONTENT_TYPE,
tonic::metadata::GRPC_CONTENT_TYPE,
);
Ok(response)
})
}
}
}
}
impl<T> Clone for NetworkManagerServer<T> {
fn clone(&self) -> Self {
let inner = self.inner.clone();
Self {
inner,
accept_compression_encodings: self.accept_compression_encodings,
send_compression_encodings: self.send_compression_encodings,
max_decoding_message_size: self.max_decoding_message_size,
max_encoding_message_size: self.max_encoding_message_size,
}
}
}
pub const SERVICE_NAME: &str = "cloud.lazycat.apis.sys.NetworkManager";
impl<T> tonic::server::NamedService for NetworkManagerServer<T> {
const NAME: &'static str = SERVICE_NAME;
}
}
pub mod package_manager_client {
#![allow(
unused_variables,
dead_code,
missing_docs,
clippy::wildcard_imports,
clippy::let_unit_value,
)]
use tonic::codegen::*;
use tonic::codegen::http::Uri;
#[derive(Debug, Clone)]
pub struct PackageManagerClient<T> {
inner: tonic::client::Grpc<T>,
}
impl<T> PackageManagerClient<T>
where
T: tonic::client::GrpcService<tonic::body::Body>,
T::Error: Into<StdError>,
T::ResponseBody: Body<Data = Bytes> + std::marker::Send + 'static,
<T::ResponseBody as Body>::Error: Into<StdError> + std::marker::Send,
{
pub fn new(inner: T) -> Self {
let inner = tonic::client::Grpc::new(inner);
Self { inner }
}
pub fn with_origin(inner: T, origin: Uri) -> Self {
let inner = tonic::client::Grpc::with_origin(inner, origin);
Self { inner }
}
pub fn with_interceptor<F>(
inner: T,
interceptor: F,
) -> PackageManagerClient<InterceptedService<T, F>>
where
F: tonic::service::Interceptor,
T::ResponseBody: Default,
T: tonic::codegen::Service<
http::Request<tonic::body::Body>,
Response = http::Response<
<T as tonic::client::GrpcService<tonic::body::Body>>::ResponseBody,
>,
>,
<T as tonic::codegen::Service<
http::Request<tonic::body::Body>,
>>::Error: Into<StdError> + std::marker::Send + std::marker::Sync,
{
PackageManagerClient::new(InterceptedService::new(inner, interceptor))
}
#[must_use]
pub fn send_compressed(mut self, encoding: CompressionEncoding) -> Self {
self.inner = self.inner.send_compressed(encoding);
self
}
#[must_use]
pub fn accept_compressed(mut self, encoding: CompressionEncoding) -> Self {
self.inner = self.inner.accept_compressed(encoding);
self
}
#[must_use]
pub fn max_decoding_message_size(mut self, limit: usize) -> Self {
self.inner = self.inner.max_decoding_message_size(limit);
self
}
#[must_use]
pub fn max_encoding_message_size(mut self, limit: usize) -> Self {
self.inner = self.inner.max_encoding_message_size(limit);
self
}
pub async fn install_lpk(
&mut self,
request: impl tonic::IntoRequest<super::InstallLpkRequest>,
) -> std::result::Result<
tonic::Response<super::InstallLpkResponse>,
tonic::Status,
> {
self.inner
.ready()
.await
.map_err(|e| {
tonic::Status::unknown(
format!("Service was not ready: {}", e.into()),
)
})?;
let codec = tonic_prost::ProstCodec::default();
let path = http::uri::PathAndQuery::from_static(
"/cloud.lazycat.apis.sys.PackageManager/InstallLPK",
);
let mut req = request.into_request();
req.extensions_mut()
.insert(
GrpcMethod::new(
"cloud.lazycat.apis.sys.PackageManager",
"InstallLPK",
),
);
self.inner.unary(req, path, codec).await
}
pub async fn list_lpk(
&mut self,
request: impl tonic::IntoRequest<super::ListLpkRequest>,
) -> std::result::Result<
tonic::Response<super::ListLpkResponse>,
tonic::Status,
> {
self.inner
.ready()
.await
.map_err(|e| {
tonic::Status::unknown(
format!("Service was not ready: {}", e.into()),
)
})?;
let codec = tonic_prost::ProstCodec::default();
let path = http::uri::PathAndQuery::from_static(
"/cloud.lazycat.apis.sys.PackageManager/ListLPK",
);
let mut req = request.into_request();
req.extensions_mut()
.insert(
GrpcMethod::new("cloud.lazycat.apis.sys.PackageManager", "ListLPK"),
);
self.inner.unary(req, path, codec).await
}
pub async fn uninstall(
&mut self,
request: impl tonic::IntoRequest<super::UninstallRequest>,
) -> std::result::Result<tonic::Response<()>, tonic::Status> {
self.inner
.ready()
.await
.map_err(|e| {
tonic::Status::unknown(
format!("Service was not ready: {}", e.into()),
)
})?;
let codec = tonic_prost::ProstCodec::default();
let path = http::uri::PathAndQuery::from_static(
"/cloud.lazycat.apis.sys.PackageManager/Uninstall",
);
let mut req = request.into_request();
req.extensions_mut()
.insert(
GrpcMethod::new("cloud.lazycat.apis.sys.PackageManager", "Uninstall"),
);
self.inner.unary(req, path, codec).await
}
pub async fn pause(
&mut self,
request: impl tonic::IntoRequest<super::AppInstance>,
) -> std::result::Result<tonic::Response<()>, tonic::Status> {
self.inner
.ready()
.await
.map_err(|e| {
tonic::Status::unknown(
format!("Service was not ready: {}", e.into()),
)
})?;
let codec = tonic_prost::ProstCodec::default();
let path = http::uri::PathAndQuery::from_static(
"/cloud.lazycat.apis.sys.PackageManager/Pause",
);
let mut req = request.into_request();
req.extensions_mut()
.insert(
GrpcMethod::new("cloud.lazycat.apis.sys.PackageManager", "Pause"),
);
self.inner.unary(req, path, codec).await
}
pub async fn resume(
&mut self,
request: impl tonic::IntoRequest<super::AppInstance>,
) -> std::result::Result<tonic::Response<()>, tonic::Status> {
self.inner
.ready()
.await
.map_err(|e| {
tonic::Status::unknown(
format!("Service was not ready: {}", e.into()),
)
})?;
let codec = tonic_prost::ProstCodec::default();
let path = http::uri::PathAndQuery::from_static(
"/cloud.lazycat.apis.sys.PackageManager/Resume",
);
let mut req = request.into_request();
req.extensions_mut()
.insert(
GrpcMethod::new("cloud.lazycat.apis.sys.PackageManager", "Resume"),
);
self.inner.unary(req, path, codec).await
}
pub async fn clear_cache(
&mut self,
request: impl tonic::IntoRequest<super::AppInstance>,
) -> std::result::Result<tonic::Response<()>, tonic::Status> {
self.inner
.ready()
.await
.map_err(|e| {
tonic::Status::unknown(
format!("Service was not ready: {}", e.into()),
)
})?;
let codec = tonic_prost::ProstCodec::default();
let path = http::uri::PathAndQuery::from_static(
"/cloud.lazycat.apis.sys.PackageManager/ClearCache",
);
let mut req = request.into_request();
req.extensions_mut()
.insert(
GrpcMethod::new(
"cloud.lazycat.apis.sys.PackageManager",
"ClearCache",
),
);
self.inner.unary(req, path, codec).await
}
pub async fn change_deploy_cfg(
&mut self,
request: impl tonic::IntoRequest<super::ChangeDeployCfgRequest>,
) -> std::result::Result<
tonic::Response<super::ChangeDeployCfgResponse>,
tonic::Status,
> {
self.inner
.ready()
.await
.map_err(|e| {
tonic::Status::unknown(
format!("Service was not ready: {}", e.into()),
)
})?;
let codec = tonic_prost::ProstCodec::default();
let path = http::uri::PathAndQuery::from_static(
"/cloud.lazycat.apis.sys.PackageManager/ChangeDeployCfg",
);
let mut req = request.into_request();
req.extensions_mut()
.insert(
GrpcMethod::new(
"cloud.lazycat.apis.sys.PackageManager",
"ChangeDeployCfg",
),
);
self.inner.unary(req, path, codec).await
}
pub async fn query_application(
&mut self,
request: impl tonic::IntoRequest<super::QueryApplicationRequest>,
) -> std::result::Result<
tonic::Response<super::QueryApplicationResponse>,
tonic::Status,
> {
self.inner
.ready()
.await
.map_err(|e| {
tonic::Status::unknown(
format!("Service was not ready: {}", e.into()),
)
})?;
let codec = tonic_prost::ProstCodec::default();
let path = http::uri::PathAndQuery::from_static(
"/cloud.lazycat.apis.sys.PackageManager/QueryApplication",
);
let mut req = request.into_request();
req.extensions_mut()
.insert(
GrpcMethod::new(
"cloud.lazycat.apis.sys.PackageManager",
"QueryApplication",
),
);
self.inner.unary(req, path, codec).await
}
pub async fn query_pending_task(
&mut self,
request: impl tonic::IntoRequest<super::QueryPendingTaskRequest>,
) -> std::result::Result<
tonic::Response<super::QueryPendingTaskResponse>,
tonic::Status,
> {
self.inner
.ready()
.await
.map_err(|e| {
tonic::Status::unknown(
format!("Service was not ready: {}", e.into()),
)
})?;
let codec = tonic_prost::ProstCodec::default();
let path = http::uri::PathAndQuery::from_static(
"/cloud.lazycat.apis.sys.PackageManager/QueryPendingTask",
);
let mut req = request.into_request();
req.extensions_mut()
.insert(
GrpcMethod::new(
"cloud.lazycat.apis.sys.PackageManager",
"QueryPendingTask",
),
);
self.inner.unary(req, path, codec).await
}
pub async fn cancel_pending_task(
&mut self,
request: impl tonic::IntoRequest<super::CancelPendingTaskRequest>,
) -> std::result::Result<
tonic::Response<super::CancelPendingTaskResponse>,
tonic::Status,
> {
self.inner
.ready()
.await
.map_err(|e| {
tonic::Status::unknown(
format!("Service was not ready: {}", e.into()),
)
})?;
let codec = tonic_prost::ProstCodec::default();
let path = http::uri::PathAndQuery::from_static(
"/cloud.lazycat.apis.sys.PackageManager/CancelPendingTask",
);
let mut req = request.into_request();
req.extensions_mut()
.insert(
GrpcMethod::new(
"cloud.lazycat.apis.sys.PackageManager",
"CancelPendingTask",
),
);
self.inner.unary(req, path, codec).await
}
pub async fn subscribe_app_change(
&mut self,
request: impl tonic::IntoRequest<super::SubscribeAppChangeRequest>,
) -> std::result::Result<
tonic::Response<tonic::codec::Streaming<super::SubscribeAppChangeResponse>>,
tonic::Status,
> {
self.inner
.ready()
.await
.map_err(|e| {
tonic::Status::unknown(
format!("Service was not ready: {}", e.into()),
)
})?;
let codec = tonic_prost::ProstCodec::default();
let path = http::uri::PathAndQuery::from_static(
"/cloud.lazycat.apis.sys.PackageManager/SubscribeAppChange",
);
let mut req = request.into_request();
req.extensions_mut()
.insert(
GrpcMethod::new(
"cloud.lazycat.apis.sys.PackageManager",
"SubscribeAppChange",
),
);
self.inner.server_streaming(req, path, codec).await
}
pub async fn query_app_resource(
&mut self,
request: impl tonic::IntoRequest<super::QueryAppResourceRequest>,
) -> std::result::Result<
tonic::Response<super::QueryAppResourceResponse>,
tonic::Status,
> {
self.inner
.ready()
.await
.map_err(|e| {
tonic::Status::unknown(
format!("Service was not ready: {}", e.into()),
)
})?;
let codec = tonic_prost::ProstCodec::default();
let path = http::uri::PathAndQuery::from_static(
"/cloud.lazycat.apis.sys.PackageManager/QueryAppResource",
);
let mut req = request.into_request();
req.extensions_mut()
.insert(
GrpcMethod::new(
"cloud.lazycat.apis.sys.PackageManager",
"QueryAppResource",
),
);
self.inner.unary(req, path, codec).await
}
pub async fn query_app_storage_usage(
&mut self,
request: impl tonic::IntoRequest<super::QueryAppStorageUsageRequest>,
) -> std::result::Result<
tonic::Response<super::AppStorageUsage>,
tonic::Status,
> {
self.inner
.ready()
.await
.map_err(|e| {
tonic::Status::unknown(
format!("Service was not ready: {}", e.into()),
)
})?;
let codec = tonic_prost::ProstCodec::default();
let path = http::uri::PathAndQuery::from_static(
"/cloud.lazycat.apis.sys.PackageManager/QueryAppStorageUsage",
);
let mut req = request.into_request();
req.extensions_mut()
.insert(
GrpcMethod::new(
"cloud.lazycat.apis.sys.PackageManager",
"QueryAppStorageUsage",
),
);
self.inner.unary(req, path, codec).await
}
pub async fn get_app_cfg(
&mut self,
request: impl tonic::IntoRequest<super::GetAppCfgRequest>,
) -> std::result::Result<
tonic::Response<super::GetAppCfgResponse>,
tonic::Status,
> {
self.inner
.ready()
.await
.map_err(|e| {
tonic::Status::unknown(
format!("Service was not ready: {}", e.into()),
)
})?;
let codec = tonic_prost::ProstCodec::default();
let path = http::uri::PathAndQuery::from_static(
"/cloud.lazycat.apis.sys.PackageManager/GetAppCfg",
);
let mut req = request.into_request();
req.extensions_mut()
.insert(
GrpcMethod::new("cloud.lazycat.apis.sys.PackageManager", "GetAppCfg"),
);
self.inner.unary(req, path, codec).await
}
pub async fn set_user_permissions(
&mut self,
request: impl tonic::IntoRequest<super::UserPermission>,
) -> std::result::Result<tonic::Response<()>, tonic::Status> {
self.inner
.ready()
.await
.map_err(|e| {
tonic::Status::unknown(
format!("Service was not ready: {}", e.into()),
)
})?;
let codec = tonic_prost::ProstCodec::default();
let path = http::uri::PathAndQuery::from_static(
"/cloud.lazycat.apis.sys.PackageManager/SetUserPermissions",
);
let mut req = request.into_request();
req.extensions_mut()
.insert(
GrpcMethod::new(
"cloud.lazycat.apis.sys.PackageManager",
"SetUserPermissions",
),
);
self.inner.unary(req, path, codec).await
}
pub async fn get_user_permissions(
&mut self,
request: impl tonic::IntoRequest<super::GetUserPermissionsRequest>,
) -> std::result::Result<tonic::Response<super::UserPermission>, tonic::Status> {
self.inner
.ready()
.await
.map_err(|e| {
tonic::Status::unknown(
format!("Service was not ready: {}", e.into()),
)
})?;
let codec = tonic_prost::ProstCodec::default();
let path = http::uri::PathAndQuery::from_static(
"/cloud.lazycat.apis.sys.PackageManager/GetUserPermissions",
);
let mut req = request.into_request();
req.extensions_mut()
.insert(
GrpcMethod::new(
"cloud.lazycat.apis.sys.PackageManager",
"GetUserPermissions",
),
);
self.inner.unary(req, path, codec).await
}
pub async fn get_action_url(
&mut self,
request: impl tonic::IntoRequest<super::GetActionUrlRequest>,
) -> std::result::Result<
tonic::Response<super::GetActionUrlResponse>,
tonic::Status,
> {
self.inner
.ready()
.await
.map_err(|e| {
tonic::Status::unknown(
format!("Service was not ready: {}", e.into()),
)
})?;
let codec = tonic_prost::ProstCodec::default();
let path = http::uri::PathAndQuery::from_static(
"/cloud.lazycat.apis.sys.PackageManager/GetActionURL",
);
let mut req = request.into_request();
req.extensions_mut()
.insert(
GrpcMethod::new(
"cloud.lazycat.apis.sys.PackageManager",
"GetActionURL",
),
);
self.inner.unary(req, path, codec).await
}
pub async fn list_file_handler(
&mut self,
request: impl tonic::IntoRequest<super::ListFileHandlerRequest>,
) -> std::result::Result<
tonic::Response<super::ListFileHandlerResponse>,
tonic::Status,
> {
self.inner
.ready()
.await
.map_err(|e| {
tonic::Status::unknown(
format!("Service was not ready: {}", e.into()),
)
})?;
let codec = tonic_prost::ProstCodec::default();
let path = http::uri::PathAndQuery::from_static(
"/cloud.lazycat.apis.sys.PackageManager/ListFileHandler",
);
let mut req = request.into_request();
req.extensions_mut()
.insert(
GrpcMethod::new(
"cloud.lazycat.apis.sys.PackageManager",
"ListFileHandler",
),
);
self.inner.unary(req, path, codec).await
}
pub async fn stop_my_self(
&mut self,
request: impl tonic::IntoRequest<super::StopMySelfRequest>,
) -> std::result::Result<
tonic::Response<super::RestartMySelfResponse>,
tonic::Status,
> {
self.inner
.ready()
.await
.map_err(|e| {
tonic::Status::unknown(
format!("Service was not ready: {}", e.into()),
)
})?;
let codec = tonic_prost::ProstCodec::default();
let path = http::uri::PathAndQuery::from_static(
"/cloud.lazycat.apis.sys.PackageManager/StopMySelf",
);
let mut req = request.into_request();
req.extensions_mut()
.insert(
GrpcMethod::new(
"cloud.lazycat.apis.sys.PackageManager",
"StopMySelf",
),
);
self.inner.unary(req, path, codec).await
}
pub async fn inhibit_stop(
&mut self,
request: impl tonic::IntoStreamingRequest<Message = super::StopProgress>,
) -> std::result::Result<
tonic::Response<tonic::codec::Streaming<super::PrepareStop>>,
tonic::Status,
> {
self.inner
.ready()
.await
.map_err(|e| {
tonic::Status::unknown(
format!("Service was not ready: {}", e.into()),
)
})?;
let codec = tonic_prost::ProstCodec::default();
let path = http::uri::PathAndQuery::from_static(
"/cloud.lazycat.apis.sys.PackageManager/InhibitStop",
);
let mut req = request.into_streaming_request();
req.extensions_mut()
.insert(
GrpcMethod::new(
"cloud.lazycat.apis.sys.PackageManager",
"InhibitStop",
),
);
self.inner.streaming(req, path, codec).await
}
pub async fn pause_app_download(
&mut self,
request: impl tonic::IntoRequest<super::Appid>,
) -> std::result::Result<tonic::Response<()>, tonic::Status> {
self.inner
.ready()
.await
.map_err(|e| {
tonic::Status::unknown(
format!("Service was not ready: {}", e.into()),
)
})?;
let codec = tonic_prost::ProstCodec::default();
let path = http::uri::PathAndQuery::from_static(
"/cloud.lazycat.apis.sys.PackageManager/PauseAppDownload",
);
let mut req = request.into_request();
req.extensions_mut()
.insert(
GrpcMethod::new(
"cloud.lazycat.apis.sys.PackageManager",
"PauseAppDownload",
),
);
self.inner.unary(req, path, codec).await
}
pub async fn install(
&mut self,
request: impl tonic::IntoRequest<super::InstallRequest>,
) -> std::result::Result<tonic::Response<()>, tonic::Status> {
self.inner
.ready()
.await
.map_err(|e| {
tonic::Status::unknown(
format!("Service was not ready: {}", e.into()),
)
})?;
let codec = tonic_prost::ProstCodec::default();
let path = http::uri::PathAndQuery::from_static(
"/cloud.lazycat.apis.sys.PackageManager/Install",
);
let mut req = request.into_request();
req.extensions_mut()
.insert(
GrpcMethod::new("cloud.lazycat.apis.sys.PackageManager", "Install"),
);
self.inner.unary(req, path, codec).await
}
}
}
pub mod package_manager_server {
#![allow(
unused_variables,
dead_code,
missing_docs,
clippy::wildcard_imports,
clippy::let_unit_value,
)]
use tonic::codegen::*;
#[async_trait]
pub trait PackageManager: std::marker::Send + std::marker::Sync + 'static {
async fn install_lpk(
&self,
request: tonic::Request<super::InstallLpkRequest>,
) -> std::result::Result<
tonic::Response<super::InstallLpkResponse>,
tonic::Status,
>;
async fn list_lpk(
&self,
request: tonic::Request<super::ListLpkRequest>,
) -> std::result::Result<tonic::Response<super::ListLpkResponse>, tonic::Status>;
async fn uninstall(
&self,
request: tonic::Request<super::UninstallRequest>,
) -> std::result::Result<tonic::Response<()>, tonic::Status>;
async fn pause(
&self,
request: tonic::Request<super::AppInstance>,
) -> std::result::Result<tonic::Response<()>, tonic::Status>;
async fn resume(
&self,
request: tonic::Request<super::AppInstance>,
) -> std::result::Result<tonic::Response<()>, tonic::Status>;
async fn clear_cache(
&self,
request: tonic::Request<super::AppInstance>,
) -> std::result::Result<tonic::Response<()>, tonic::Status>;
async fn change_deploy_cfg(
&self,
request: tonic::Request<super::ChangeDeployCfgRequest>,
) -> std::result::Result<
tonic::Response<super::ChangeDeployCfgResponse>,
tonic::Status,
>;
async fn query_application(
&self,
request: tonic::Request<super::QueryApplicationRequest>,
) -> std::result::Result<
tonic::Response<super::QueryApplicationResponse>,
tonic::Status,
>;
async fn query_pending_task(
&self,
request: tonic::Request<super::QueryPendingTaskRequest>,
) -> std::result::Result<
tonic::Response<super::QueryPendingTaskResponse>,
tonic::Status,
>;
async fn cancel_pending_task(
&self,
request: tonic::Request<super::CancelPendingTaskRequest>,
) -> std::result::Result<
tonic::Response<super::CancelPendingTaskResponse>,
tonic::Status,
>;
type SubscribeAppChangeStream: tonic::codegen::tokio_stream::Stream<
Item = std::result::Result<
super::SubscribeAppChangeResponse,
tonic::Status,
>,
>
+ std::marker::Send
+ 'static;
async fn subscribe_app_change(
&self,
request: tonic::Request<super::SubscribeAppChangeRequest>,
) -> std::result::Result<
tonic::Response<Self::SubscribeAppChangeStream>,
tonic::Status,
>;
async fn query_app_resource(
&self,
request: tonic::Request<super::QueryAppResourceRequest>,
) -> std::result::Result<
tonic::Response<super::QueryAppResourceResponse>,
tonic::Status,
>;
async fn query_app_storage_usage(
&self,
request: tonic::Request<super::QueryAppStorageUsageRequest>,
) -> std::result::Result<tonic::Response<super::AppStorageUsage>, tonic::Status>;
async fn get_app_cfg(
&self,
request: tonic::Request<super::GetAppCfgRequest>,
) -> std::result::Result<
tonic::Response<super::GetAppCfgResponse>,
tonic::Status,
>;
async fn set_user_permissions(
&self,
request: tonic::Request<super::UserPermission>,
) -> std::result::Result<tonic::Response<()>, tonic::Status>;
async fn get_user_permissions(
&self,
request: tonic::Request<super::GetUserPermissionsRequest>,
) -> std::result::Result<tonic::Response<super::UserPermission>, tonic::Status>;
async fn get_action_url(
&self,
request: tonic::Request<super::GetActionUrlRequest>,
) -> std::result::Result<
tonic::Response<super::GetActionUrlResponse>,
tonic::Status,
>;
async fn list_file_handler(
&self,
request: tonic::Request<super::ListFileHandlerRequest>,
) -> std::result::Result<
tonic::Response<super::ListFileHandlerResponse>,
tonic::Status,
>;
async fn stop_my_self(
&self,
request: tonic::Request<super::StopMySelfRequest>,
) -> std::result::Result<
tonic::Response<super::RestartMySelfResponse>,
tonic::Status,
>;
type InhibitStopStream: tonic::codegen::tokio_stream::Stream<
Item = std::result::Result<super::PrepareStop, tonic::Status>,
>
+ std::marker::Send
+ 'static;
async fn inhibit_stop(
&self,
request: tonic::Request<tonic::Streaming<super::StopProgress>>,
) -> std::result::Result<
tonic::Response<Self::InhibitStopStream>,
tonic::Status,
>;
async fn pause_app_download(
&self,
request: tonic::Request<super::Appid>,
) -> std::result::Result<tonic::Response<()>, tonic::Status>;
async fn install(
&self,
request: tonic::Request<super::InstallRequest>,
) -> std::result::Result<tonic::Response<()>, tonic::Status>;
}
#[derive(Debug)]
pub struct PackageManagerServer<T> {
inner: Arc<T>,
accept_compression_encodings: EnabledCompressionEncodings,
send_compression_encodings: EnabledCompressionEncodings,
max_decoding_message_size: Option<usize>,
max_encoding_message_size: Option<usize>,
}
impl<T> PackageManagerServer<T> {
pub fn new(inner: T) -> Self {
Self::from_arc(Arc::new(inner))
}
pub fn from_arc(inner: Arc<T>) -> Self {
Self {
inner,
accept_compression_encodings: Default::default(),
send_compression_encodings: Default::default(),
max_decoding_message_size: None,
max_encoding_message_size: None,
}
}
pub fn with_interceptor<F>(
inner: T,
interceptor: F,
) -> InterceptedService<Self, F>
where
F: tonic::service::Interceptor,
{
InterceptedService::new(Self::new(inner), interceptor)
}
#[must_use]
pub fn accept_compressed(mut self, encoding: CompressionEncoding) -> Self {
self.accept_compression_encodings.enable(encoding);
self
}
#[must_use]
pub fn send_compressed(mut self, encoding: CompressionEncoding) -> Self {
self.send_compression_encodings.enable(encoding);
self
}
#[must_use]
pub fn max_decoding_message_size(mut self, limit: usize) -> Self {
self.max_decoding_message_size = Some(limit);
self
}
#[must_use]
pub fn max_encoding_message_size(mut self, limit: usize) -> Self {
self.max_encoding_message_size = Some(limit);
self
}
}
impl<T, B> tonic::codegen::Service<http::Request<B>> for PackageManagerServer<T>
where
T: PackageManager,
B: Body + std::marker::Send + 'static,
B::Error: Into<StdError> + std::marker::Send + 'static,
{
type Response = http::Response<tonic::body::Body>;
type Error = std::convert::Infallible;
type Future = BoxFuture<Self::Response, Self::Error>;
fn poll_ready(
&mut self,
_cx: &mut Context<'_>,
) -> Poll<std::result::Result<(), Self::Error>> {
Poll::Ready(Ok(()))
}
fn call(&mut self, req: http::Request<B>) -> Self::Future {
match req.uri().path() {
"/cloud.lazycat.apis.sys.PackageManager/InstallLPK" => {
#[allow(non_camel_case_types)]
struct InstallLPKSvc<T: PackageManager>(pub Arc<T>);
impl<
T: PackageManager,
> tonic::server::UnaryService<super::InstallLpkRequest>
for InstallLPKSvc<T> {
type Response = super::InstallLpkResponse;
type Future = BoxFuture<
tonic::Response<Self::Response>,
tonic::Status,
>;
fn call(
&mut self,
request: tonic::Request<super::InstallLpkRequest>,
) -> Self::Future {
let inner = Arc::clone(&self.0);
let fut = async move {
<T as PackageManager>::install_lpk(&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 method = InstallLPKSvc(inner);
let codec = tonic_prost::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)
}
"/cloud.lazycat.apis.sys.PackageManager/ListLPK" => {
#[allow(non_camel_case_types)]
struct ListLPKSvc<T: PackageManager>(pub Arc<T>);
impl<
T: PackageManager,
> tonic::server::UnaryService<super::ListLpkRequest>
for ListLPKSvc<T> {
type Response = super::ListLpkResponse;
type Future = BoxFuture<
tonic::Response<Self::Response>,
tonic::Status,
>;
fn call(
&mut self,
request: tonic::Request<super::ListLpkRequest>,
) -> Self::Future {
let inner = Arc::clone(&self.0);
let fut = async move {
<T as PackageManager>::list_lpk(&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 method = ListLPKSvc(inner);
let codec = tonic_prost::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)
}
"/cloud.lazycat.apis.sys.PackageManager/Uninstall" => {
#[allow(non_camel_case_types)]
struct UninstallSvc<T: PackageManager>(pub Arc<T>);
impl<
T: PackageManager,
> tonic::server::UnaryService<super::UninstallRequest>
for UninstallSvc<T> {
type Response = ();
type Future = BoxFuture<
tonic::Response<Self::Response>,
tonic::Status,
>;
fn call(
&mut self,
request: tonic::Request<super::UninstallRequest>,
) -> Self::Future {
let inner = Arc::clone(&self.0);
let fut = async move {
<T as PackageManager>::uninstall(&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 method = UninstallSvc(inner);
let codec = tonic_prost::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)
}
"/cloud.lazycat.apis.sys.PackageManager/Pause" => {
#[allow(non_camel_case_types)]
struct PauseSvc<T: PackageManager>(pub Arc<T>);
impl<
T: PackageManager,
> tonic::server::UnaryService<super::AppInstance> for PauseSvc<T> {
type Response = ();
type Future = BoxFuture<
tonic::Response<Self::Response>,
tonic::Status,
>;
fn call(
&mut self,
request: tonic::Request<super::AppInstance>,
) -> Self::Future {
let inner = Arc::clone(&self.0);
let fut = async move {
<T as PackageManager>::pause(&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 method = PauseSvc(inner);
let codec = tonic_prost::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)
}
"/cloud.lazycat.apis.sys.PackageManager/Resume" => {
#[allow(non_camel_case_types)]
struct ResumeSvc<T: PackageManager>(pub Arc<T>);
impl<
T: PackageManager,
> tonic::server::UnaryService<super::AppInstance> for ResumeSvc<T> {
type Response = ();
type Future = BoxFuture<
tonic::Response<Self::Response>,
tonic::Status,
>;
fn call(
&mut self,
request: tonic::Request<super::AppInstance>,
) -> Self::Future {
let inner = Arc::clone(&self.0);
let fut = async move {
<T as PackageManager>::resume(&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 method = ResumeSvc(inner);
let codec = tonic_prost::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)
}
"/cloud.lazycat.apis.sys.PackageManager/ClearCache" => {
#[allow(non_camel_case_types)]
struct ClearCacheSvc<T: PackageManager>(pub Arc<T>);
impl<
T: PackageManager,
> tonic::server::UnaryService<super::AppInstance>
for ClearCacheSvc<T> {
type Response = ();
type Future = BoxFuture<
tonic::Response<Self::Response>,
tonic::Status,
>;
fn call(
&mut self,
request: tonic::Request<super::AppInstance>,
) -> Self::Future {
let inner = Arc::clone(&self.0);
let fut = async move {
<T as PackageManager>::clear_cache(&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 method = ClearCacheSvc(inner);
let codec = tonic_prost::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)
}
"/cloud.lazycat.apis.sys.PackageManager/ChangeDeployCfg" => {
#[allow(non_camel_case_types)]
struct ChangeDeployCfgSvc<T: PackageManager>(pub Arc<T>);
impl<
T: PackageManager,
> tonic::server::UnaryService<super::ChangeDeployCfgRequest>
for ChangeDeployCfgSvc<T> {
type Response = super::ChangeDeployCfgResponse;
type Future = BoxFuture<
tonic::Response<Self::Response>,
tonic::Status,
>;
fn call(
&mut self,
request: tonic::Request<super::ChangeDeployCfgRequest>,
) -> Self::Future {
let inner = Arc::clone(&self.0);
let fut = async move {
<T as PackageManager>::change_deploy_cfg(&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 method = ChangeDeployCfgSvc(inner);
let codec = tonic_prost::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)
}
"/cloud.lazycat.apis.sys.PackageManager/QueryApplication" => {
#[allow(non_camel_case_types)]
struct QueryApplicationSvc<T: PackageManager>(pub Arc<T>);
impl<
T: PackageManager,
> tonic::server::UnaryService<super::QueryApplicationRequest>
for QueryApplicationSvc<T> {
type Response = super::QueryApplicationResponse;
type Future = BoxFuture<
tonic::Response<Self::Response>,
tonic::Status,
>;
fn call(
&mut self,
request: tonic::Request<super::QueryApplicationRequest>,
) -> Self::Future {
let inner = Arc::clone(&self.0);
let fut = async move {
<T as PackageManager>::query_application(&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 method = QueryApplicationSvc(inner);
let codec = tonic_prost::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)
}
"/cloud.lazycat.apis.sys.PackageManager/QueryPendingTask" => {
#[allow(non_camel_case_types)]
struct QueryPendingTaskSvc<T: PackageManager>(pub Arc<T>);
impl<
T: PackageManager,
> tonic::server::UnaryService<super::QueryPendingTaskRequest>
for QueryPendingTaskSvc<T> {
type Response = super::QueryPendingTaskResponse;
type Future = BoxFuture<
tonic::Response<Self::Response>,
tonic::Status,
>;
fn call(
&mut self,
request: tonic::Request<super::QueryPendingTaskRequest>,
) -> Self::Future {
let inner = Arc::clone(&self.0);
let fut = async move {
<T as PackageManager>::query_pending_task(&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 method = QueryPendingTaskSvc(inner);
let codec = tonic_prost::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)
}
"/cloud.lazycat.apis.sys.PackageManager/CancelPendingTask" => {
#[allow(non_camel_case_types)]
struct CancelPendingTaskSvc<T: PackageManager>(pub Arc<T>);
impl<
T: PackageManager,
> tonic::server::UnaryService<super::CancelPendingTaskRequest>
for CancelPendingTaskSvc<T> {
type Response = super::CancelPendingTaskResponse;
type Future = BoxFuture<
tonic::Response<Self::Response>,
tonic::Status,
>;
fn call(
&mut self,
request: tonic::Request<super::CancelPendingTaskRequest>,
) -> Self::Future {
let inner = Arc::clone(&self.0);
let fut = async move {
<T as PackageManager>::cancel_pending_task(&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 method = CancelPendingTaskSvc(inner);
let codec = tonic_prost::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)
}
"/cloud.lazycat.apis.sys.PackageManager/SubscribeAppChange" => {
#[allow(non_camel_case_types)]
struct SubscribeAppChangeSvc<T: PackageManager>(pub Arc<T>);
impl<
T: PackageManager,
> tonic::server::ServerStreamingService<
super::SubscribeAppChangeRequest,
> for SubscribeAppChangeSvc<T> {
type Response = super::SubscribeAppChangeResponse;
type ResponseStream = T::SubscribeAppChangeStream;
type Future = BoxFuture<
tonic::Response<Self::ResponseStream>,
tonic::Status,
>;
fn call(
&mut self,
request: tonic::Request<super::SubscribeAppChangeRequest>,
) -> Self::Future {
let inner = Arc::clone(&self.0);
let fut = async move {
<T as PackageManager>::subscribe_app_change(&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 method = SubscribeAppChangeSvc(inner);
let codec = tonic_prost::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.server_streaming(method, req).await;
Ok(res)
};
Box::pin(fut)
}
"/cloud.lazycat.apis.sys.PackageManager/QueryAppResource" => {
#[allow(non_camel_case_types)]
struct QueryAppResourceSvc<T: PackageManager>(pub Arc<T>);
impl<
T: PackageManager,
> tonic::server::UnaryService<super::QueryAppResourceRequest>
for QueryAppResourceSvc<T> {
type Response = super::QueryAppResourceResponse;
type Future = BoxFuture<
tonic::Response<Self::Response>,
tonic::Status,
>;
fn call(
&mut self,
request: tonic::Request<super::QueryAppResourceRequest>,
) -> Self::Future {
let inner = Arc::clone(&self.0);
let fut = async move {
<T as PackageManager>::query_app_resource(&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 method = QueryAppResourceSvc(inner);
let codec = tonic_prost::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)
}
"/cloud.lazycat.apis.sys.PackageManager/QueryAppStorageUsage" => {
#[allow(non_camel_case_types)]
struct QueryAppStorageUsageSvc<T: PackageManager>(pub Arc<T>);
impl<
T: PackageManager,
> tonic::server::UnaryService<super::QueryAppStorageUsageRequest>
for QueryAppStorageUsageSvc<T> {
type Response = super::AppStorageUsage;
type Future = BoxFuture<
tonic::Response<Self::Response>,
tonic::Status,
>;
fn call(
&mut self,
request: tonic::Request<super::QueryAppStorageUsageRequest>,
) -> Self::Future {
let inner = Arc::clone(&self.0);
let fut = async move {
<T as PackageManager>::query_app_storage_usage(
&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 method = QueryAppStorageUsageSvc(inner);
let codec = tonic_prost::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)
}
"/cloud.lazycat.apis.sys.PackageManager/GetAppCfg" => {
#[allow(non_camel_case_types)]
struct GetAppCfgSvc<T: PackageManager>(pub Arc<T>);
impl<
T: PackageManager,
> tonic::server::UnaryService<super::GetAppCfgRequest>
for GetAppCfgSvc<T> {
type Response = super::GetAppCfgResponse;
type Future = BoxFuture<
tonic::Response<Self::Response>,
tonic::Status,
>;
fn call(
&mut self,
request: tonic::Request<super::GetAppCfgRequest>,
) -> Self::Future {
let inner = Arc::clone(&self.0);
let fut = async move {
<T as PackageManager>::get_app_cfg(&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 method = GetAppCfgSvc(inner);
let codec = tonic_prost::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)
}
"/cloud.lazycat.apis.sys.PackageManager/SetUserPermissions" => {
#[allow(non_camel_case_types)]
struct SetUserPermissionsSvc<T: PackageManager>(pub Arc<T>);
impl<
T: PackageManager,
> tonic::server::UnaryService<super::UserPermission>
for SetUserPermissionsSvc<T> {
type Response = ();
type Future = BoxFuture<
tonic::Response<Self::Response>,
tonic::Status,
>;
fn call(
&mut self,
request: tonic::Request<super::UserPermission>,
) -> Self::Future {
let inner = Arc::clone(&self.0);
let fut = async move {
<T as PackageManager>::set_user_permissions(&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 method = SetUserPermissionsSvc(inner);
let codec = tonic_prost::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)
}
"/cloud.lazycat.apis.sys.PackageManager/GetUserPermissions" => {
#[allow(non_camel_case_types)]
struct GetUserPermissionsSvc<T: PackageManager>(pub Arc<T>);
impl<
T: PackageManager,
> tonic::server::UnaryService<super::GetUserPermissionsRequest>
for GetUserPermissionsSvc<T> {
type Response = super::UserPermission;
type Future = BoxFuture<
tonic::Response<Self::Response>,
tonic::Status,
>;
fn call(
&mut self,
request: tonic::Request<super::GetUserPermissionsRequest>,
) -> Self::Future {
let inner = Arc::clone(&self.0);
let fut = async move {
<T as PackageManager>::get_user_permissions(&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 method = GetUserPermissionsSvc(inner);
let codec = tonic_prost::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)
}
"/cloud.lazycat.apis.sys.PackageManager/GetActionURL" => {
#[allow(non_camel_case_types)]
struct GetActionURLSvc<T: PackageManager>(pub Arc<T>);
impl<
T: PackageManager,
> tonic::server::UnaryService<super::GetActionUrlRequest>
for GetActionURLSvc<T> {
type Response = super::GetActionUrlResponse;
type Future = BoxFuture<
tonic::Response<Self::Response>,
tonic::Status,
>;
fn call(
&mut self,
request: tonic::Request<super::GetActionUrlRequest>,
) -> Self::Future {
let inner = Arc::clone(&self.0);
let fut = async move {
<T as PackageManager>::get_action_url(&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 method = GetActionURLSvc(inner);
let codec = tonic_prost::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)
}
"/cloud.lazycat.apis.sys.PackageManager/ListFileHandler" => {
#[allow(non_camel_case_types)]
struct ListFileHandlerSvc<T: PackageManager>(pub Arc<T>);
impl<
T: PackageManager,
> tonic::server::UnaryService<super::ListFileHandlerRequest>
for ListFileHandlerSvc<T> {
type Response = super::ListFileHandlerResponse;
type Future = BoxFuture<
tonic::Response<Self::Response>,
tonic::Status,
>;
fn call(
&mut self,
request: tonic::Request<super::ListFileHandlerRequest>,
) -> Self::Future {
let inner = Arc::clone(&self.0);
let fut = async move {
<T as PackageManager>::list_file_handler(&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 method = ListFileHandlerSvc(inner);
let codec = tonic_prost::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)
}
"/cloud.lazycat.apis.sys.PackageManager/StopMySelf" => {
#[allow(non_camel_case_types)]
struct StopMySelfSvc<T: PackageManager>(pub Arc<T>);
impl<
T: PackageManager,
> tonic::server::UnaryService<super::StopMySelfRequest>
for StopMySelfSvc<T> {
type Response = super::RestartMySelfResponse;
type Future = BoxFuture<
tonic::Response<Self::Response>,
tonic::Status,
>;
fn call(
&mut self,
request: tonic::Request<super::StopMySelfRequest>,
) -> Self::Future {
let inner = Arc::clone(&self.0);
let fut = async move {
<T as PackageManager>::stop_my_self(&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 method = StopMySelfSvc(inner);
let codec = tonic_prost::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)
}
"/cloud.lazycat.apis.sys.PackageManager/InhibitStop" => {
#[allow(non_camel_case_types)]
struct InhibitStopSvc<T: PackageManager>(pub Arc<T>);
impl<
T: PackageManager,
> tonic::server::StreamingService<super::StopProgress>
for InhibitStopSvc<T> {
type Response = super::PrepareStop;
type ResponseStream = T::InhibitStopStream;
type Future = BoxFuture<
tonic::Response<Self::ResponseStream>,
tonic::Status,
>;
fn call(
&mut self,
request: tonic::Request<
tonic::Streaming<super::StopProgress>,
>,
) -> Self::Future {
let inner = Arc::clone(&self.0);
let fut = async move {
<T as PackageManager>::inhibit_stop(&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 method = InhibitStopSvc(inner);
let codec = tonic_prost::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.streaming(method, req).await;
Ok(res)
};
Box::pin(fut)
}
"/cloud.lazycat.apis.sys.PackageManager/PauseAppDownload" => {
#[allow(non_camel_case_types)]
struct PauseAppDownloadSvc<T: PackageManager>(pub Arc<T>);
impl<T: PackageManager> tonic::server::UnaryService<super::Appid>
for PauseAppDownloadSvc<T> {
type Response = ();
type Future = BoxFuture<
tonic::Response<Self::Response>,
tonic::Status,
>;
fn call(
&mut self,
request: tonic::Request<super::Appid>,
) -> Self::Future {
let inner = Arc::clone(&self.0);
let fut = async move {
<T as PackageManager>::pause_app_download(&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 method = PauseAppDownloadSvc(inner);
let codec = tonic_prost::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)
}
"/cloud.lazycat.apis.sys.PackageManager/Install" => {
#[allow(non_camel_case_types)]
struct InstallSvc<T: PackageManager>(pub Arc<T>);
impl<
T: PackageManager,
> tonic::server::UnaryService<super::InstallRequest>
for InstallSvc<T> {
type Response = ();
type Future = BoxFuture<
tonic::Response<Self::Response>,
tonic::Status,
>;
fn call(
&mut self,
request: tonic::Request<super::InstallRequest>,
) -> Self::Future {
let inner = Arc::clone(&self.0);
let fut = async move {
<T as PackageManager>::install(&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 method = InstallSvc(inner);
let codec = tonic_prost::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 {
let mut response = http::Response::new(
tonic::body::Body::default(),
);
let headers = response.headers_mut();
headers
.insert(
tonic::Status::GRPC_STATUS,
(tonic::Code::Unimplemented as i32).into(),
);
headers
.insert(
http::header::CONTENT_TYPE,
tonic::metadata::GRPC_CONTENT_TYPE,
);
Ok(response)
})
}
}
}
}
impl<T> Clone for PackageManagerServer<T> {
fn clone(&self) -> Self {
let inner = self.inner.clone();
Self {
inner,
accept_compression_encodings: self.accept_compression_encodings,
send_compression_encodings: self.send_compression_encodings,
max_decoding_message_size: self.max_decoding_message_size,
max_encoding_message_size: self.max_encoding_message_size,
}
}
}
pub const SERVICE_NAME: &str = "cloud.lazycat.apis.sys.PackageManager";
impl<T> tonic::server::NamedService for PackageManagerServer<T> {
const NAME: &'static str = SERVICE_NAME;
}
}
pub mod tv_os_client {
#![allow(
unused_variables,
dead_code,
missing_docs,
clippy::wildcard_imports,
clippy::let_unit_value,
)]
use tonic::codegen::*;
use tonic::codegen::http::Uri;
#[derive(Debug, Clone)]
pub struct TvOsClient<T> {
inner: tonic::client::Grpc<T>,
}
impl<T> TvOsClient<T>
where
T: tonic::client::GrpcService<tonic::body::Body>,
T::Error: Into<StdError>,
T::ResponseBody: Body<Data = Bytes> + std::marker::Send + 'static,
<T::ResponseBody as Body>::Error: Into<StdError> + std::marker::Send,
{
pub fn new(inner: T) -> Self {
let inner = tonic::client::Grpc::new(inner);
Self { inner }
}
pub fn with_origin(inner: T, origin: Uri) -> Self {
let inner = tonic::client::Grpc::with_origin(inner, origin);
Self { inner }
}
pub fn with_interceptor<F>(
inner: T,
interceptor: F,
) -> TvOsClient<InterceptedService<T, F>>
where
F: tonic::service::Interceptor,
T::ResponseBody: Default,
T: tonic::codegen::Service<
http::Request<tonic::body::Body>,
Response = http::Response<
<T as tonic::client::GrpcService<tonic::body::Body>>::ResponseBody,
>,
>,
<T as tonic::codegen::Service<
http::Request<tonic::body::Body>,
>>::Error: Into<StdError> + std::marker::Send + std::marker::Sync,
{
TvOsClient::new(InterceptedService::new(inner, interceptor))
}
#[must_use]
pub fn send_compressed(mut self, encoding: CompressionEncoding) -> Self {
self.inner = self.inner.send_compressed(encoding);
self
}
#[must_use]
pub fn accept_compressed(mut self, encoding: CompressionEncoding) -> Self {
self.inner = self.inner.accept_compressed(encoding);
self
}
#[must_use]
pub fn max_decoding_message_size(mut self, limit: usize) -> Self {
self.inner = self.inner.max_decoding_message_size(limit);
self
}
#[must_use]
pub fn max_encoding_message_size(mut self, limit: usize) -> Self {
self.inner = self.inner.max_encoding_message_size(limit);
self
}
pub async fn run(
&mut self,
request: impl tonic::IntoRequest<super::RunRequest>,
) -> std::result::Result<tonic::Response<()>, tonic::Status> {
self.inner
.ready()
.await
.map_err(|e| {
tonic::Status::unknown(
format!("Service was not ready: {}", e.into()),
)
})?;
let codec = tonic_prost::ProstCodec::default();
let path = http::uri::PathAndQuery::from_static(
"/cloud.lazycat.apis.sys.TvOS/Run",
);
let mut req = request.into_request();
req.extensions_mut()
.insert(GrpcMethod::new("cloud.lazycat.apis.sys.TvOS", "Run"));
self.inner.unary(req, path, codec).await
}
pub async fn status(
&mut self,
request: impl tonic::IntoRequest<()>,
) -> std::result::Result<tonic::Response<super::StatusResponse>, tonic::Status> {
self.inner
.ready()
.await
.map_err(|e| {
tonic::Status::unknown(
format!("Service was not ready: {}", e.into()),
)
})?;
let codec = tonic_prost::ProstCodec::default();
let path = http::uri::PathAndQuery::from_static(
"/cloud.lazycat.apis.sys.TvOS/Status",
);
let mut req = request.into_request();
req.extensions_mut()
.insert(GrpcMethod::new("cloud.lazycat.apis.sys.TvOS", "Status"));
self.inner.unary(req, path, codec).await
}
pub async fn stop(
&mut self,
request: impl tonic::IntoRequest<()>,
) -> std::result::Result<tonic::Response<()>, tonic::Status> {
self.inner
.ready()
.await
.map_err(|e| {
tonic::Status::unknown(
format!("Service was not ready: {}", e.into()),
)
})?;
let codec = tonic_prost::ProstCodec::default();
let path = http::uri::PathAndQuery::from_static(
"/cloud.lazycat.apis.sys.TvOS/Stop",
);
let mut req = request.into_request();
req.extensions_mut()
.insert(GrpcMethod::new("cloud.lazycat.apis.sys.TvOS", "Stop"));
self.inner.unary(req, path, codec).await
}
pub async fn is_hdmi_connected(
&mut self,
request: impl tonic::IntoRequest<()>,
) -> std::result::Result<
tonic::Response<super::IsHdmiConnectedResponse>,
tonic::Status,
> {
self.inner
.ready()
.await
.map_err(|e| {
tonic::Status::unknown(
format!("Service was not ready: {}", e.into()),
)
})?;
let codec = tonic_prost::ProstCodec::default();
let path = http::uri::PathAndQuery::from_static(
"/cloud.lazycat.apis.sys.TvOS/IsHDMIConnected",
);
let mut req = request.into_request();
req.extensions_mut()
.insert(
GrpcMethod::new("cloud.lazycat.apis.sys.TvOS", "IsHDMIConnected"),
);
self.inner.unary(req, path, codec).await
}
pub async fn is_logged_in(
&mut self,
request: impl tonic::IntoRequest<()>,
) -> std::result::Result<
tonic::Response<super::IsLoggedInResponse>,
tonic::Status,
> {
self.inner
.ready()
.await
.map_err(|e| {
tonic::Status::unknown(
format!("Service was not ready: {}", e.into()),
)
})?;
let codec = tonic_prost::ProstCodec::default();
let path = http::uri::PathAndQuery::from_static(
"/cloud.lazycat.apis.sys.TvOS/IsLoggedIn",
);
let mut req = request.into_request();
req.extensions_mut()
.insert(GrpcMethod::new("cloud.lazycat.apis.sys.TvOS", "IsLoggedIn"));
self.inner.unary(req, path, codec).await
}
pub async fn add_bookmark(
&mut self,
request: impl tonic::IntoRequest<super::AddBookmarkRequest>,
) -> std::result::Result<tonic::Response<()>, tonic::Status> {
self.inner
.ready()
.await
.map_err(|e| {
tonic::Status::unknown(
format!("Service was not ready: {}", e.into()),
)
})?;
let codec = tonic_prost::ProstCodec::default();
let path = http::uri::PathAndQuery::from_static(
"/cloud.lazycat.apis.sys.TvOS/AddBookmark",
);
let mut req = request.into_request();
req.extensions_mut()
.insert(GrpcMethod::new("cloud.lazycat.apis.sys.TvOS", "AddBookmark"));
self.inner.unary(req, path, codec).await
}
pub async fn list_bookmark(
&mut self,
request: impl tonic::IntoRequest<()>,
) -> std::result::Result<
tonic::Response<super::ListBookmarkResponse>,
tonic::Status,
> {
self.inner
.ready()
.await
.map_err(|e| {
tonic::Status::unknown(
format!("Service was not ready: {}", e.into()),
)
})?;
let codec = tonic_prost::ProstCodec::default();
let path = http::uri::PathAndQuery::from_static(
"/cloud.lazycat.apis.sys.TvOS/ListBookmark",
);
let mut req = request.into_request();
req.extensions_mut()
.insert(GrpcMethod::new("cloud.lazycat.apis.sys.TvOS", "ListBookmark"));
self.inner.unary(req, path, codec).await
}
pub async fn del_bookmark(
&mut self,
request: impl tonic::IntoRequest<super::DelBookmarkRequest>,
) -> std::result::Result<tonic::Response<()>, tonic::Status> {
self.inner
.ready()
.await
.map_err(|e| {
tonic::Status::unknown(
format!("Service was not ready: {}", e.into()),
)
})?;
let codec = tonic_prost::ProstCodec::default();
let path = http::uri::PathAndQuery::from_static(
"/cloud.lazycat.apis.sys.TvOS/DelBookmark",
);
let mut req = request.into_request();
req.extensions_mut()
.insert(GrpcMethod::new("cloud.lazycat.apis.sys.TvOS", "DelBookmark"));
self.inner.unary(req, path, codec).await
}
pub async fn list_bookmark_icon(
&mut self,
request: impl tonic::IntoRequest<super::ListBookmarkIconRequest>,
) -> std::result::Result<
tonic::Response<super::ListBookmarkIconResponse>,
tonic::Status,
> {
self.inner
.ready()
.await
.map_err(|e| {
tonic::Status::unknown(
format!("Service was not ready: {}", e.into()),
)
})?;
let codec = tonic_prost::ProstCodec::default();
let path = http::uri::PathAndQuery::from_static(
"/cloud.lazycat.apis.sys.TvOS/ListBookmarkIcon",
);
let mut req = request.into_request();
req.extensions_mut()
.insert(
GrpcMethod::new("cloud.lazycat.apis.sys.TvOS", "ListBookmarkIcon"),
);
self.inner.unary(req, path, codec).await
}
pub async fn kick_logged_in(
&mut self,
request: impl tonic::IntoRequest<()>,
) -> std::result::Result<tonic::Response<()>, tonic::Status> {
self.inner
.ready()
.await
.map_err(|e| {
tonic::Status::unknown(
format!("Service was not ready: {}", e.into()),
)
})?;
let codec = tonic_prost::ProstCodec::default();
let path = http::uri::PathAndQuery::from_static(
"/cloud.lazycat.apis.sys.TvOS/KickLoggedIn",
);
let mut req = request.into_request();
req.extensions_mut()
.insert(GrpcMethod::new("cloud.lazycat.apis.sys.TvOS", "KickLoggedIn"));
self.inner.unary(req, path, codec).await
}
}
}
pub mod tv_os_server {
#![allow(
unused_variables,
dead_code,
missing_docs,
clippy::wildcard_imports,
clippy::let_unit_value,
)]
use tonic::codegen::*;
#[async_trait]
pub trait TvOs: std::marker::Send + std::marker::Sync + 'static {
async fn run(
&self,
request: tonic::Request<super::RunRequest>,
) -> std::result::Result<tonic::Response<()>, tonic::Status>;
async fn status(
&self,
request: tonic::Request<()>,
) -> std::result::Result<tonic::Response<super::StatusResponse>, tonic::Status>;
async fn stop(
&self,
request: tonic::Request<()>,
) -> std::result::Result<tonic::Response<()>, tonic::Status>;
async fn is_hdmi_connected(
&self,
request: tonic::Request<()>,
) -> std::result::Result<
tonic::Response<super::IsHdmiConnectedResponse>,
tonic::Status,
>;
async fn is_logged_in(
&self,
request: tonic::Request<()>,
) -> std::result::Result<
tonic::Response<super::IsLoggedInResponse>,
tonic::Status,
>;
async fn add_bookmark(
&self,
request: tonic::Request<super::AddBookmarkRequest>,
) -> std::result::Result<tonic::Response<()>, tonic::Status>;
async fn list_bookmark(
&self,
request: tonic::Request<()>,
) -> std::result::Result<
tonic::Response<super::ListBookmarkResponse>,
tonic::Status,
>;
async fn del_bookmark(
&self,
request: tonic::Request<super::DelBookmarkRequest>,
) -> std::result::Result<tonic::Response<()>, tonic::Status>;
async fn list_bookmark_icon(
&self,
request: tonic::Request<super::ListBookmarkIconRequest>,
) -> std::result::Result<
tonic::Response<super::ListBookmarkIconResponse>,
tonic::Status,
>;
async fn kick_logged_in(
&self,
request: tonic::Request<()>,
) -> std::result::Result<tonic::Response<()>, tonic::Status>;
}
#[derive(Debug)]
pub struct TvOsServer<T> {
inner: Arc<T>,
accept_compression_encodings: EnabledCompressionEncodings,
send_compression_encodings: EnabledCompressionEncodings,
max_decoding_message_size: Option<usize>,
max_encoding_message_size: Option<usize>,
}
impl<T> TvOsServer<T> {
pub fn new(inner: T) -> Self {
Self::from_arc(Arc::new(inner))
}
pub fn from_arc(inner: Arc<T>) -> Self {
Self {
inner,
accept_compression_encodings: Default::default(),
send_compression_encodings: Default::default(),
max_decoding_message_size: None,
max_encoding_message_size: None,
}
}
pub fn with_interceptor<F>(
inner: T,
interceptor: F,
) -> InterceptedService<Self, F>
where
F: tonic::service::Interceptor,
{
InterceptedService::new(Self::new(inner), interceptor)
}
#[must_use]
pub fn accept_compressed(mut self, encoding: CompressionEncoding) -> Self {
self.accept_compression_encodings.enable(encoding);
self
}
#[must_use]
pub fn send_compressed(mut self, encoding: CompressionEncoding) -> Self {
self.send_compression_encodings.enable(encoding);
self
}
#[must_use]
pub fn max_decoding_message_size(mut self, limit: usize) -> Self {
self.max_decoding_message_size = Some(limit);
self
}
#[must_use]
pub fn max_encoding_message_size(mut self, limit: usize) -> Self {
self.max_encoding_message_size = Some(limit);
self
}
}
impl<T, B> tonic::codegen::Service<http::Request<B>> for TvOsServer<T>
where
T: TvOs,
B: Body + std::marker::Send + 'static,
B::Error: Into<StdError> + std::marker::Send + 'static,
{
type Response = http::Response<tonic::body::Body>;
type Error = std::convert::Infallible;
type Future = BoxFuture<Self::Response, Self::Error>;
fn poll_ready(
&mut self,
_cx: &mut Context<'_>,
) -> Poll<std::result::Result<(), Self::Error>> {
Poll::Ready(Ok(()))
}
fn call(&mut self, req: http::Request<B>) -> Self::Future {
match req.uri().path() {
"/cloud.lazycat.apis.sys.TvOS/Run" => {
#[allow(non_camel_case_types)]
struct RunSvc<T: TvOs>(pub Arc<T>);
impl<T: TvOs> tonic::server::UnaryService<super::RunRequest>
for RunSvc<T> {
type Response = ();
type Future = BoxFuture<
tonic::Response<Self::Response>,
tonic::Status,
>;
fn call(
&mut self,
request: tonic::Request<super::RunRequest>,
) -> Self::Future {
let inner = Arc::clone(&self.0);
let fut = async move {
<T as TvOs>::run(&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 method = RunSvc(inner);
let codec = tonic_prost::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)
}
"/cloud.lazycat.apis.sys.TvOS/Status" => {
#[allow(non_camel_case_types)]
struct StatusSvc<T: TvOs>(pub Arc<T>);
impl<T: TvOs> tonic::server::UnaryService<()> for StatusSvc<T> {
type Response = super::StatusResponse;
type Future = BoxFuture<
tonic::Response<Self::Response>,
tonic::Status,
>;
fn call(&mut self, request: tonic::Request<()>) -> Self::Future {
let inner = Arc::clone(&self.0);
let fut = async move {
<T as TvOs>::status(&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 method = StatusSvc(inner);
let codec = tonic_prost::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)
}
"/cloud.lazycat.apis.sys.TvOS/Stop" => {
#[allow(non_camel_case_types)]
struct StopSvc<T: TvOs>(pub Arc<T>);
impl<T: TvOs> tonic::server::UnaryService<()> for StopSvc<T> {
type Response = ();
type Future = BoxFuture<
tonic::Response<Self::Response>,
tonic::Status,
>;
fn call(&mut self, request: tonic::Request<()>) -> Self::Future {
let inner = Arc::clone(&self.0);
let fut = async move {
<T as TvOs>::stop(&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 method = StopSvc(inner);
let codec = tonic_prost::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)
}
"/cloud.lazycat.apis.sys.TvOS/IsHDMIConnected" => {
#[allow(non_camel_case_types)]
struct IsHDMIConnectedSvc<T: TvOs>(pub Arc<T>);
impl<T: TvOs> tonic::server::UnaryService<()>
for IsHDMIConnectedSvc<T> {
type Response = super::IsHdmiConnectedResponse;
type Future = BoxFuture<
tonic::Response<Self::Response>,
tonic::Status,
>;
fn call(&mut self, request: tonic::Request<()>) -> Self::Future {
let inner = Arc::clone(&self.0);
let fut = async move {
<T as TvOs>::is_hdmi_connected(&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 method = IsHDMIConnectedSvc(inner);
let codec = tonic_prost::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)
}
"/cloud.lazycat.apis.sys.TvOS/IsLoggedIn" => {
#[allow(non_camel_case_types)]
struct IsLoggedInSvc<T: TvOs>(pub Arc<T>);
impl<T: TvOs> tonic::server::UnaryService<()> for IsLoggedInSvc<T> {
type Response = super::IsLoggedInResponse;
type Future = BoxFuture<
tonic::Response<Self::Response>,
tonic::Status,
>;
fn call(&mut self, request: tonic::Request<()>) -> Self::Future {
let inner = Arc::clone(&self.0);
let fut = async move {
<T as TvOs>::is_logged_in(&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 method = IsLoggedInSvc(inner);
let codec = tonic_prost::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)
}
"/cloud.lazycat.apis.sys.TvOS/AddBookmark" => {
#[allow(non_camel_case_types)]
struct AddBookmarkSvc<T: TvOs>(pub Arc<T>);
impl<T: TvOs> tonic::server::UnaryService<super::AddBookmarkRequest>
for AddBookmarkSvc<T> {
type Response = ();
type Future = BoxFuture<
tonic::Response<Self::Response>,
tonic::Status,
>;
fn call(
&mut self,
request: tonic::Request<super::AddBookmarkRequest>,
) -> Self::Future {
let inner = Arc::clone(&self.0);
let fut = async move {
<T as TvOs>::add_bookmark(&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 method = AddBookmarkSvc(inner);
let codec = tonic_prost::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)
}
"/cloud.lazycat.apis.sys.TvOS/ListBookmark" => {
#[allow(non_camel_case_types)]
struct ListBookmarkSvc<T: TvOs>(pub Arc<T>);
impl<T: TvOs> tonic::server::UnaryService<()>
for ListBookmarkSvc<T> {
type Response = super::ListBookmarkResponse;
type Future = BoxFuture<
tonic::Response<Self::Response>,
tonic::Status,
>;
fn call(&mut self, request: tonic::Request<()>) -> Self::Future {
let inner = Arc::clone(&self.0);
let fut = async move {
<T as TvOs>::list_bookmark(&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 method = ListBookmarkSvc(inner);
let codec = tonic_prost::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)
}
"/cloud.lazycat.apis.sys.TvOS/DelBookmark" => {
#[allow(non_camel_case_types)]
struct DelBookmarkSvc<T: TvOs>(pub Arc<T>);
impl<T: TvOs> tonic::server::UnaryService<super::DelBookmarkRequest>
for DelBookmarkSvc<T> {
type Response = ();
type Future = BoxFuture<
tonic::Response<Self::Response>,
tonic::Status,
>;
fn call(
&mut self,
request: tonic::Request<super::DelBookmarkRequest>,
) -> Self::Future {
let inner = Arc::clone(&self.0);
let fut = async move {
<T as TvOs>::del_bookmark(&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 method = DelBookmarkSvc(inner);
let codec = tonic_prost::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)
}
"/cloud.lazycat.apis.sys.TvOS/ListBookmarkIcon" => {
#[allow(non_camel_case_types)]
struct ListBookmarkIconSvc<T: TvOs>(pub Arc<T>);
impl<
T: TvOs,
> tonic::server::UnaryService<super::ListBookmarkIconRequest>
for ListBookmarkIconSvc<T> {
type Response = super::ListBookmarkIconResponse;
type Future = BoxFuture<
tonic::Response<Self::Response>,
tonic::Status,
>;
fn call(
&mut self,
request: tonic::Request<super::ListBookmarkIconRequest>,
) -> Self::Future {
let inner = Arc::clone(&self.0);
let fut = async move {
<T as TvOs>::list_bookmark_icon(&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 method = ListBookmarkIconSvc(inner);
let codec = tonic_prost::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)
}
"/cloud.lazycat.apis.sys.TvOS/KickLoggedIn" => {
#[allow(non_camel_case_types)]
struct KickLoggedInSvc<T: TvOs>(pub Arc<T>);
impl<T: TvOs> tonic::server::UnaryService<()>
for KickLoggedInSvc<T> {
type Response = ();
type Future = BoxFuture<
tonic::Response<Self::Response>,
tonic::Status,
>;
fn call(&mut self, request: tonic::Request<()>) -> Self::Future {
let inner = Arc::clone(&self.0);
let fut = async move {
<T as TvOs>::kick_logged_in(&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 method = KickLoggedInSvc(inner);
let codec = tonic_prost::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 {
let mut response = http::Response::new(
tonic::body::Body::default(),
);
let headers = response.headers_mut();
headers
.insert(
tonic::Status::GRPC_STATUS,
(tonic::Code::Unimplemented as i32).into(),
);
headers
.insert(
http::header::CONTENT_TYPE,
tonic::metadata::GRPC_CONTENT_TYPE,
);
Ok(response)
})
}
}
}
}
impl<T> Clone for TvOsServer<T> {
fn clone(&self) -> Self {
let inner = self.inner.clone();
Self {
inner,
accept_compression_encodings: self.accept_compression_encodings,
send_compression_encodings: self.send_compression_encodings,
max_decoding_message_size: self.max_decoding_message_size,
max_encoding_message_size: self.max_encoding_message_size,
}
}
}
pub const SERVICE_NAME: &str = "cloud.lazycat.apis.sys.TvOS";
impl<T> tonic::server::NamedService for TvOsServer<T> {
const NAME: &'static str = SERVICE_NAME;
}
}
pub mod version_info_service_client {
#![allow(
unused_variables,
dead_code,
missing_docs,
clippy::wildcard_imports,
clippy::let_unit_value,
)]
use tonic::codegen::*;
use tonic::codegen::http::Uri;
#[derive(Debug, Clone)]
pub struct VersionInfoServiceClient<T> {
inner: tonic::client::Grpc<T>,
}
impl<T> VersionInfoServiceClient<T>
where
T: tonic::client::GrpcService<tonic::body::Body>,
T::Error: Into<StdError>,
T::ResponseBody: Body<Data = Bytes> + std::marker::Send + 'static,
<T::ResponseBody as Body>::Error: Into<StdError> + std::marker::Send,
{
pub fn new(inner: T) -> Self {
let inner = tonic::client::Grpc::new(inner);
Self { inner }
}
pub fn with_origin(inner: T, origin: Uri) -> Self {
let inner = tonic::client::Grpc::with_origin(inner, origin);
Self { inner }
}
pub fn with_interceptor<F>(
inner: T,
interceptor: F,
) -> VersionInfoServiceClient<InterceptedService<T, F>>
where
F: tonic::service::Interceptor,
T::ResponseBody: Default,
T: tonic::codegen::Service<
http::Request<tonic::body::Body>,
Response = http::Response<
<T as tonic::client::GrpcService<tonic::body::Body>>::ResponseBody,
>,
>,
<T as tonic::codegen::Service<
http::Request<tonic::body::Body>,
>>::Error: Into<StdError> + std::marker::Send + std::marker::Sync,
{
VersionInfoServiceClient::new(InterceptedService::new(inner, interceptor))
}
#[must_use]
pub fn send_compressed(mut self, encoding: CompressionEncoding) -> Self {
self.inner = self.inner.send_compressed(encoding);
self
}
#[must_use]
pub fn accept_compressed(mut self, encoding: CompressionEncoding) -> Self {
self.inner = self.inner.accept_compressed(encoding);
self
}
#[must_use]
pub fn max_decoding_message_size(mut self, limit: usize) -> Self {
self.inner = self.inner.max_decoding_message_size(limit);
self
}
#[must_use]
pub fn max_encoding_message_size(mut self, limit: usize) -> Self {
self.inner = self.inner.max_encoding_message_size(limit);
self
}
pub async fn get(
&mut self,
request: impl tonic::IntoRequest<()>,
) -> std::result::Result<tonic::Response<super::VersionInfo>, tonic::Status> {
self.inner
.ready()
.await
.map_err(|e| {
tonic::Status::unknown(
format!("Service was not ready: {}", e.into()),
)
})?;
let codec = tonic_prost::ProstCodec::default();
let path = http::uri::PathAndQuery::from_static(
"/cloud.lazycat.apis.sys.VersionInfoService/Get",
);
let mut req = request.into_request();
req.extensions_mut()
.insert(
GrpcMethod::new("cloud.lazycat.apis.sys.VersionInfoService", "Get"),
);
self.inner.unary(req, path, codec).await
}
}
}
pub mod version_info_service_server {
#![allow(
unused_variables,
dead_code,
missing_docs,
clippy::wildcard_imports,
clippy::let_unit_value,
)]
use tonic::codegen::*;
#[async_trait]
pub trait VersionInfoService: std::marker::Send + std::marker::Sync + 'static {
async fn get(
&self,
request: tonic::Request<()>,
) -> std::result::Result<tonic::Response<super::VersionInfo>, tonic::Status>;
}
#[derive(Debug)]
pub struct VersionInfoServiceServer<T> {
inner: Arc<T>,
accept_compression_encodings: EnabledCompressionEncodings,
send_compression_encodings: EnabledCompressionEncodings,
max_decoding_message_size: Option<usize>,
max_encoding_message_size: Option<usize>,
}
impl<T> VersionInfoServiceServer<T> {
pub fn new(inner: T) -> Self {
Self::from_arc(Arc::new(inner))
}
pub fn from_arc(inner: Arc<T>) -> Self {
Self {
inner,
accept_compression_encodings: Default::default(),
send_compression_encodings: Default::default(),
max_decoding_message_size: None,
max_encoding_message_size: None,
}
}
pub fn with_interceptor<F>(
inner: T,
interceptor: F,
) -> InterceptedService<Self, F>
where
F: tonic::service::Interceptor,
{
InterceptedService::new(Self::new(inner), interceptor)
}
#[must_use]
pub fn accept_compressed(mut self, encoding: CompressionEncoding) -> Self {
self.accept_compression_encodings.enable(encoding);
self
}
#[must_use]
pub fn send_compressed(mut self, encoding: CompressionEncoding) -> Self {
self.send_compression_encodings.enable(encoding);
self
}
#[must_use]
pub fn max_decoding_message_size(mut self, limit: usize) -> Self {
self.max_decoding_message_size = Some(limit);
self
}
#[must_use]
pub fn max_encoding_message_size(mut self, limit: usize) -> Self {
self.max_encoding_message_size = Some(limit);
self
}
}
impl<T, B> tonic::codegen::Service<http::Request<B>> for VersionInfoServiceServer<T>
where
T: VersionInfoService,
B: Body + std::marker::Send + 'static,
B::Error: Into<StdError> + std::marker::Send + 'static,
{
type Response = http::Response<tonic::body::Body>;
type Error = std::convert::Infallible;
type Future = BoxFuture<Self::Response, Self::Error>;
fn poll_ready(
&mut self,
_cx: &mut Context<'_>,
) -> Poll<std::result::Result<(), Self::Error>> {
Poll::Ready(Ok(()))
}
fn call(&mut self, req: http::Request<B>) -> Self::Future {
match req.uri().path() {
"/cloud.lazycat.apis.sys.VersionInfoService/Get" => {
#[allow(non_camel_case_types)]
struct GetSvc<T: VersionInfoService>(pub Arc<T>);
impl<T: VersionInfoService> tonic::server::UnaryService<()>
for GetSvc<T> {
type Response = super::VersionInfo;
type Future = BoxFuture<
tonic::Response<Self::Response>,
tonic::Status,
>;
fn call(&mut self, request: tonic::Request<()>) -> Self::Future {
let inner = Arc::clone(&self.0);
let fut = async move {
<T as VersionInfoService>::get(&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 method = GetSvc(inner);
let codec = tonic_prost::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 {
let mut response = http::Response::new(
tonic::body::Body::default(),
);
let headers = response.headers_mut();
headers
.insert(
tonic::Status::GRPC_STATUS,
(tonic::Code::Unimplemented as i32).into(),
);
headers
.insert(
http::header::CONTENT_TYPE,
tonic::metadata::GRPC_CONTENT_TYPE,
);
Ok(response)
})
}
}
}
}
impl<T> Clone for VersionInfoServiceServer<T> {
fn clone(&self) -> Self {
let inner = self.inner.clone();
Self {
inner,
accept_compression_encodings: self.accept_compression_encodings,
send_compression_encodings: self.send_compression_encodings,
max_decoding_message_size: self.max_decoding_message_size,
max_encoding_message_size: self.max_encoding_message_size,
}
}
}
pub const SERVICE_NAME: &str = "cloud.lazycat.apis.sys.VersionInfoService";
impl<T> tonic::server::NamedService for VersionInfoServiceServer<T> {
const NAME: &'static str = SERVICE_NAME;
}
}