Page MenuHomePhorge
Files F32518853

D11402.1767127370.diff
No OneTemporary
Actions

Size
1 KB
Referenced Files
None
Subscribers
None

D11402.1767127370.diff
View Options

diff --git a/services/identity/src/client_service.rs b/services/identity/src/client_service.rs
--- a/services/identity/src/client_service.rs
+++ b/services/identity/src/client_service.rs
@@ -875,9 +875,20 @@
async fn get_farcaster_users(
&self,
- _request: tonic::Request<GetFarcasterUsersRequest>,
+ request: tonic::Request<GetFarcasterUsersRequest>,
) -> 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 }))
}
}
diff --git a/services/identity/src/database/farcaster.rs b/services/identity/src/database/farcaster.rs
--- a/services/identity/src/database/farcaster.rs
+++ b/services/identity/src/database/farcaster.rs
@@ -5,7 +5,6 @@
use comm_lib::database::DBItemError;
use comm_lib::database::TryFromAttribute;
use comm_lib::database::Value;
-use grpc_clients::identity::protos::unauth::FarcasterUser;
use tracing::error;
use crate::constants::USERS_TABLE;
@@ -14,14 +13,15 @@
use crate::constants::USERS_TABLE_PARTITION_KEY;
use crate::constants::USERS_TABLE_USERNAME_ATTRIBUTE;
use crate::constants::USERS_TABLE_WALLET_ADDRESS_ATTRIBUTE;
+use crate::grpc_services::protos::unauth::FarcasterUser;
use super::DatabaseClient;
use super::Error;
-struct FarcasterUserData(FarcasterUser);
+pub struct FarcasterUserData(pub FarcasterUser);
impl DatabaseClient {
- async fn get_farcaster_users(
+ pub async fn get_farcaster_users(
&self,
farcaster_ids: Vec<String>,
) -> Result<Vec<FarcasterUserData>, Error> {

File Metadata

Mime Type
text/plain
Expires
Tue, Dec 30, 8:42 PM (14 h, 8 m)
Storage Engine
blob
Storage Format
Raw Data
Storage Handle
5869893
Default Alt Text
D11402.1767127370.diff (1 KB)

Event Timeline