#[derive(serde::Serialize, serde::Deserialize)] #[derive(Clone, PartialEq, ::prost::Message)] pub struct User { /// User's uid generated by firebase auth #[prost(string, tag = "1")] pub uid: ::prost::alloc::string::String, /// User's email #[prost(string, tag = "2")] pub email: ::prost::alloc::string::String, /// User's account type - source of truth for subscription status #[prost(enumeration = "AccountType", tag = "3")] pub account_type: i32, /// User's push token(s) #[prost(string, repeated, tag = "4")] pub push_tokens: ::prost::alloc::vec::Vec<::prost::alloc::string::String>, /// User's name #[prost(string, tag = "5")] pub name: ::prost::alloc::string::String, } /// Possible account type a user can have #[derive(serde::Serialize, serde::Deserialize)] #[derive(async_graphql::Enum)] #[derive(Clone, Copy, Debug, PartialEq, Eq, Hash, PartialOrd, Ord, ::prost::Enumeration)] #[repr(i32)] pub enum AccountType { /// Unspecified account type Unspecified = 0, /// Free account Free = 1, /// Paid account - subscription Premium = 2, } impl AccountType { /// String value of the enum field names used in the ProtoBuf definition. /// /// The values are not transformed in any way and thus are considered stable /// (if the ProtoBuf definition does not change) and safe for programmatic use. pub fn as_str_name(&self) -> &'static str { match self { AccountType::Unspecified => "ACCOUNT_TYPE_UNSPECIFIED", AccountType::Free => "ACCOUNT_TYPE_FREE", AccountType::Premium => "ACCOUNT_TYPE_PREMIUM", } } } /// TODO: Where to store this data? /// Possible reasons for account deletion #[derive(serde::Serialize, serde::Deserialize)] #[derive(Clone, Copy, Debug, PartialEq, Eq, Hash, PartialOrd, Ord, ::prost::Enumeration)] #[repr(i32)] pub enum DeleteReason { Unspecified = 0, } impl DeleteReason { /// String value of the enum field names used in the ProtoBuf definition. /// /// The values are not transformed in any way and thus are considered stable /// (if the ProtoBuf definition does not change) and safe for programmatic use. pub fn as_str_name(&self) -> &'static str { match self { DeleteReason::Unspecified => "DELETE_REASON_UNSPECIFIED", } } } /// Input to create a user #[derive(serde::Serialize, serde::Deserialize)] #[derive(Clone, PartialEq, ::prost::Message)] pub struct CreateUserRequest { #[prost(string, tag = "1")] pub uid: ::prost::alloc::string::String, #[prost(string, tag = "2")] pub email: ::prost::alloc::string::String, #[prost(string, tag = "3")] pub name: ::prost::alloc::string::String, } /// Response from creating a user #[derive(serde::Serialize, serde::Deserialize)] #[derive(Clone, PartialEq, ::prost::Message)] pub struct CreateUserResponse { #[prost(message, optional, tag = "1")] pub user: ::core::option::Option, } /// Request details of a user fetch #[derive(serde::Serialize, serde::Deserialize)] #[derive(Clone, PartialEq, ::prost::Message)] pub struct GetUserRequest { #[prost(string, tag = "1")] pub uid: ::prost::alloc::string::String, } /// Response details of a user fetch #[derive(serde::Serialize, serde::Deserialize)] #[derive(Clone, PartialEq, ::prost::Message)] pub struct GetUserResponse { #[prost(message, optional, tag = "1")] pub user: ::core::option::Option, } /// Request details of an account delete #[derive(serde::Serialize, serde::Deserialize)] #[derive(Clone, PartialEq, ::prost::Message)] pub struct DeleteUserRequest { #[prost(string, tag = "1")] pub uid: ::prost::alloc::string::String, #[prost(enumeration = "DeleteReason", tag = "2")] pub reason: i32, } /// Response details of an account delete request #[derive(serde::Serialize, serde::Deserialize)] #[derive(Clone, PartialEq, ::prost::Message)] pub struct DeleteUserResponse {} /// Request to store new push token #[derive(serde::Serialize, serde::Deserialize)] #[derive(Clone, PartialEq, ::prost::Message)] pub struct SavePushTokenRequest { #[prost(string, tag = "1")] pub uid: ::prost::alloc::string::String, #[prost(string, tag = "2")] pub push_token: ::prost::alloc::string::String, } /// Response from storing push token #[derive(serde::Serialize, serde::Deserialize)] #[derive(Clone, PartialEq, ::prost::Message)] pub struct SavePushTokenResponse {} /// Request to update users account type #[derive(serde::Serialize, serde::Deserialize)] #[derive(Clone, PartialEq, ::prost::Message)] pub struct UpdateAccountTypeRequest { #[prost(string, tag = "1")] pub uid: ::prost::alloc::string::String, #[prost(enumeration = "AccountType", tag = "2")] pub account_type: i32, } /// Response from updating users account type #[derive(serde::Serialize, serde::Deserialize)] #[derive(Clone, PartialEq, ::prost::Message)] pub struct UpdateAccountTypeResponse {} /// Generated client implementations. pub mod user_api_client { #![allow(unused_variables, dead_code, missing_docs, clippy::let_unit_value)] use tonic::codegen::*; use tonic::codegen::http::Uri; #[derive(Debug, Clone)] pub struct UserApiClient { inner: tonic::client::Grpc, } impl UserApiClient { /// Attempt to create a new client by connecting to a given endpoint. pub async fn connect(dst: D) -> Result where D: std::convert::TryInto, D::Error: Into, { let conn = tonic::transport::Endpoint::new(dst)?.connect().await?; Ok(Self::new(conn)) } } impl UserApiClient where T: tonic::client::GrpcService, T::Error: Into, T::ResponseBody: Body + Send + 'static, ::Error: Into + 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( inner: T, interceptor: F, ) -> UserApiClient> where F: tonic::service::Interceptor, T::ResponseBody: Default, T: tonic::codegen::Service< http::Request, Response = http::Response< >::ResponseBody, >, >, , >>::Error: Into + Send + Sync, { UserApiClient::new(InterceptedService::new(inner, interceptor)) } /// Compress requests with the given encoding. /// /// This requires the server to support it otherwise it might respond with an /// error. #[must_use] pub fn send_compressed(mut self, encoding: CompressionEncoding) -> Self { self.inner = self.inner.send_compressed(encoding); self } /// Enable decompressing responses. #[must_use] pub fn accept_compressed(mut self, encoding: CompressionEncoding) -> Self { self.inner = self.inner.accept_compressed(encoding); self } /// Create a User - compares uid against existing users + Authorization header pub async fn create_user( &mut self, request: impl tonic::IntoRequest, ) -> Result, tonic::Status> { self.inner .ready() .await .map_err(|e| { tonic::Status::new( tonic::Code::Unknown, format!("Service was not ready: {}", e.into()), ) })?; let codec = tonic::codec::ProstCodec::default(); let path = http::uri::PathAndQuery::from_static( "/user.v1.UserAPI/CreateUser", ); self.inner.unary(request.into_request(), path, codec).await } /// Retrieve a User - based on Authorization header pub async fn get_user( &mut self, request: impl tonic::IntoRequest, ) -> Result, tonic::Status> { self.inner .ready() .await .map_err(|e| { tonic::Status::new( tonic::Code::Unknown, format!("Service was not ready: {}", e.into()), ) })?; let codec = tonic::codec::ProstCodec::default(); let path = http::uri::PathAndQuery::from_static("/user.v1.UserAPI/GetUser"); self.inner.unary(request.into_request(), path, codec).await } /// Delete a User - based on Authorization header pub async fn delete_user( &mut self, request: impl tonic::IntoRequest, ) -> Result, tonic::Status> { self.inner .ready() .await .map_err(|e| { tonic::Status::new( tonic::Code::Unknown, format!("Service was not ready: {}", e.into()), ) })?; let codec = tonic::codec::ProstCodec::default(); let path = http::uri::PathAndQuery::from_static( "/user.v1.UserAPI/DeleteUser", ); self.inner.unary(request.into_request(), path, codec).await } /// Add a push token to users existing push token(s) pub async fn save_push_token( &mut self, request: impl tonic::IntoRequest, ) -> Result, tonic::Status> { self.inner .ready() .await .map_err(|e| { tonic::Status::new( tonic::Code::Unknown, format!("Service was not ready: {}", e.into()), ) })?; let codec = tonic::codec::ProstCodec::default(); let path = http::uri::PathAndQuery::from_static( "/user.v1.UserAPI/SavePushToken", ); self.inner.unary(request.into_request(), path, codec).await } /// Update user's account type - called by revenue cat lambda pub async fn update_account_type( &mut self, request: impl tonic::IntoRequest, ) -> Result, tonic::Status> { self.inner .ready() .await .map_err(|e| { tonic::Status::new( tonic::Code::Unknown, format!("Service was not ready: {}", e.into()), ) })?; let codec = tonic::codec::ProstCodec::default(); let path = http::uri::PathAndQuery::from_static( "/user.v1.UserAPI/UpdateAccountType", ); self.inner.unary(request.into_request(), path, codec).await } } } /// Generated server implementations. pub mod user_api_server { #![allow(unused_variables, dead_code, missing_docs, clippy::let_unit_value)] use tonic::codegen::*; ///Generated trait containing gRPC methods that should be implemented for use with UserApiServer. #[async_trait] pub trait UserApi: Send + Sync + 'static { /// Create a User - compares uid against existing users + Authorization header async fn create_user( &self, request: tonic::Request, ) -> Result, tonic::Status>; /// Retrieve a User - based on Authorization header async fn get_user( &self, request: tonic::Request, ) -> Result, tonic::Status>; /// Delete a User - based on Authorization header async fn delete_user( &self, request: tonic::Request, ) -> Result, tonic::Status>; /// Add a push token to users existing push token(s) async fn save_push_token( &self, request: tonic::Request, ) -> Result, tonic::Status>; /// Update user's account type - called by revenue cat lambda async fn update_account_type( &self, request: tonic::Request, ) -> Result, tonic::Status>; } #[derive(Debug)] pub struct UserApiServer { inner: _Inner, accept_compression_encodings: EnabledCompressionEncodings, send_compression_encodings: EnabledCompressionEncodings, } struct _Inner(Arc); impl UserApiServer { pub fn new(inner: T) -> Self { Self::from_arc(Arc::new(inner)) } pub fn from_arc(inner: Arc) -> Self { let inner = _Inner(inner); Self { inner, accept_compression_encodings: Default::default(), send_compression_encodings: Default::default(), } } pub fn with_interceptor( inner: T, interceptor: F, ) -> InterceptedService where F: tonic::service::Interceptor, { InterceptedService::new(Self::new(inner), interceptor) } /// Enable decompressing requests with the given encoding. #[must_use] pub fn accept_compressed(mut self, encoding: CompressionEncoding) -> Self { self.accept_compression_encodings.enable(encoding); self } /// Compress responses with the given encoding, if the client supports it. #[must_use] pub fn send_compressed(mut self, encoding: CompressionEncoding) -> Self { self.send_compression_encodings.enable(encoding); self } } impl tonic::codegen::Service> for UserApiServer where T: UserApi, B: Body + Send + 'static, B::Error: Into + Send + 'static, { type Response = http::Response; type Error = std::convert::Infallible; type Future = BoxFuture; fn poll_ready( &mut self, _cx: &mut Context<'_>, ) -> Poll> { Poll::Ready(Ok(())) } fn call(&mut self, req: http::Request) -> Self::Future { let inner = self.inner.clone(); match req.uri().path() { "/user.v1.UserAPI/CreateUser" => { #[allow(non_camel_case_types)] struct CreateUserSvc(pub Arc); impl< T: UserApi, > tonic::server::UnaryService for CreateUserSvc { type Response = super::CreateUserResponse; type Future = BoxFuture< tonic::Response, tonic::Status, >; fn call( &mut self, request: tonic::Request, ) -> Self::Future { let inner = self.0.clone(); let fut = async move { (*inner).create_user(request).await }; Box::pin(fut) } } let accept_compression_encodings = self.accept_compression_encodings; let send_compression_encodings = self.send_compression_encodings; let inner = self.inner.clone(); let fut = async move { let inner = inner.0; let method = CreateUserSvc(inner); let codec = tonic::codec::ProstCodec::default(); let mut grpc = tonic::server::Grpc::new(codec) .apply_compression_config( accept_compression_encodings, send_compression_encodings, ); let res = grpc.unary(method, req).await; Ok(res) }; Box::pin(fut) } "/user.v1.UserAPI/GetUser" => { #[allow(non_camel_case_types)] struct GetUserSvc(pub Arc); impl tonic::server::UnaryService for GetUserSvc { type Response = super::GetUserResponse; type Future = BoxFuture< tonic::Response, tonic::Status, >; fn call( &mut self, request: tonic::Request, ) -> Self::Future { let inner = self.0.clone(); let fut = async move { (*inner).get_user(request).await }; Box::pin(fut) } } let accept_compression_encodings = self.accept_compression_encodings; let send_compression_encodings = self.send_compression_encodings; let inner = self.inner.clone(); let fut = async move { let inner = inner.0; let method = GetUserSvc(inner); let codec = tonic::codec::ProstCodec::default(); let mut grpc = tonic::server::Grpc::new(codec) .apply_compression_config( accept_compression_encodings, send_compression_encodings, ); let res = grpc.unary(method, req).await; Ok(res) }; Box::pin(fut) } "/user.v1.UserAPI/DeleteUser" => { #[allow(non_camel_case_types)] struct DeleteUserSvc(pub Arc); impl< T: UserApi, > tonic::server::UnaryService for DeleteUserSvc { type Response = super::DeleteUserResponse; type Future = BoxFuture< tonic::Response, tonic::Status, >; fn call( &mut self, request: tonic::Request, ) -> Self::Future { let inner = self.0.clone(); let fut = async move { (*inner).delete_user(request).await }; Box::pin(fut) } } let accept_compression_encodings = self.accept_compression_encodings; let send_compression_encodings = self.send_compression_encodings; let inner = self.inner.clone(); let fut = async move { let inner = inner.0; let method = DeleteUserSvc(inner); let codec = tonic::codec::ProstCodec::default(); let mut grpc = tonic::server::Grpc::new(codec) .apply_compression_config( accept_compression_encodings, send_compression_encodings, ); let res = grpc.unary(method, req).await; Ok(res) }; Box::pin(fut) } "/user.v1.UserAPI/SavePushToken" => { #[allow(non_camel_case_types)] struct SavePushTokenSvc(pub Arc); impl< T: UserApi, > tonic::server::UnaryService for SavePushTokenSvc { type Response = super::SavePushTokenResponse; type Future = BoxFuture< tonic::Response, tonic::Status, >; fn call( &mut self, request: tonic::Request, ) -> Self::Future { let inner = self.0.clone(); let fut = async move { (*inner).save_push_token(request).await }; Box::pin(fut) } } let accept_compression_encodings = self.accept_compression_encodings; let send_compression_encodings = self.send_compression_encodings; let inner = self.inner.clone(); let fut = async move { let inner = inner.0; let method = SavePushTokenSvc(inner); let codec = tonic::codec::ProstCodec::default(); let mut grpc = tonic::server::Grpc::new(codec) .apply_compression_config( accept_compression_encodings, send_compression_encodings, ); let res = grpc.unary(method, req).await; Ok(res) }; Box::pin(fut) } "/user.v1.UserAPI/UpdateAccountType" => { #[allow(non_camel_case_types)] struct UpdateAccountTypeSvc(pub Arc); impl< T: UserApi, > tonic::server::UnaryService for UpdateAccountTypeSvc { type Response = super::UpdateAccountTypeResponse; type Future = BoxFuture< tonic::Response, tonic::Status, >; fn call( &mut self, request: tonic::Request, ) -> Self::Future { let inner = self.0.clone(); let fut = async move { (*inner).update_account_type(request).await }; Box::pin(fut) } } let accept_compression_encodings = self.accept_compression_encodings; let send_compression_encodings = self.send_compression_encodings; let inner = self.inner.clone(); let fut = async move { let inner = inner.0; let method = UpdateAccountTypeSvc(inner); let codec = tonic::codec::ProstCodec::default(); let mut grpc = tonic::server::Grpc::new(codec) .apply_compression_config( accept_compression_encodings, send_compression_encodings, ); let res = grpc.unary(method, req).await; Ok(res) }; Box::pin(fut) } _ => { Box::pin(async move { Ok( http::Response::builder() .status(200) .header("grpc-status", "12") .header("content-type", "application/grpc") .body(empty_body()) .unwrap(), ) }) } } } } impl Clone for UserApiServer { 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, } } } impl Clone for _Inner { fn clone(&self) -> Self { Self(self.0.clone()) } } impl std::fmt::Debug for _Inner { fn fmt(&self, f: &mut std::fmt::Formatter<'_>) -> std::fmt::Result { write!(f, "{:?}", self.0) } } impl tonic::server::NamedService for UserApiServer { const NAME: &'static str = "user.v1.UserAPI"; } }