Changeset View
Changeset View
Standalone View
Standalone View
services/identity/src/client_service.rs
Show First 20 Lines • Show All 869 Lines • ▼ Show 20 Lines | ) -> Result<tonic::Response<FindUserIdResponse>, tonic::Status> { | ||||
Ok(Response::new(FindUserIdResponse { | Ok(Response::new(FindUserIdResponse { | ||||
user_id, | user_id, | ||||
is_reserved, | is_reserved, | ||||
})) | })) | ||||
} | } | ||||
async fn get_farcaster_users( | async fn get_farcaster_users( | ||||
&self, | &self, | ||||
_request: tonic::Request<GetFarcasterUsersRequest>, | request: tonic::Request<GetFarcasterUsersRequest>, | ||||
) -> Result<tonic::Response<GetFarcasterUsersResponse>, tonic::Status> { | ) -> Result<tonic::Response<GetFarcasterUsersResponse>, tonic::Status> { | ||||
unimplemented!(); | let message = request.into_inner(); | ||||
let farcaster_users = self | |||||
.client | |||||
.get_farcaster_users(message.farcaster_ids) | |||||
.await | |||||
.map_err(handle_db_error)? | |||||
.into_iter() | |||||
.map(|d| d.0) | |||||
.collect(); | |||||
Ok(Response::new(GetFarcasterUsersResponse { farcaster_users })) | |||||
} | } | ||||
} | } | ||||
impl ClientService { | impl ClientService { | ||||
async fn check_username_taken( | async fn check_username_taken( | ||||
&self, | &self, | ||||
username: &str, | username: &str, | ||||
) -> Result<(), tonic::Status> { | ) -> Result<(), tonic::Status> { | ||||
▲ Show 20 Lines • Show All 175 Lines • Show Last 20 Lines |