Page MenuHomePhabricator
Differential D10615

[services] [web] [2/n] Web code gen changes for KeyserverKeysResponse Identity proto changes
ClosedPublic
Actions

Authored by will on Jan 11 2024, 11:23 AM.
Tags
None
Referenced Files
F6071867: D10615.id35566.diff
Sun, Apr 20, 1:41 PM
Unknown Object (File)
Thu, Apr 17, 2:56 PM
Unknown Object (File)
Thu, Apr 17, 1:39 PM
Unknown Object (File)
Thu, Apr 17, 11:24 AM
Unknown Object (File)
Wed, Apr 16, 2:58 AM
Unknown Object (File)
Wed, Apr 9, 12:45 AM
Unknown Object (File)
Mar 20 2025, 2:58 PM
Unknown Object (File)
Mar 20 2025, 2:58 PM
View All 68 Files
Subscribers
ashoat
tomek

Details

Reviewers
varun
ashoat
Commits
rCOMM6d52ee8dcec2: [services] [web] [2/n] Web code gen changes for KeyserverKeysResponse Identity…
Summary

This introduces the necessary changes to our protobuf code gen from D10586

Depends on D10586

Test Plan

Verified by calling getKeyserverKeys through identity client on web. Received response with identity information

Diff Detail

Repository
rCOMM Comm
Lint
Lint Not Applicable
Unit
Tests Not Applicable

Revision Contents
Changeset List

Diff 35566

View Options

web/protobufs/identity-auth-structs.cjs

Show First 20 Lines • Show All 1,077 Lines • ▼ Show 20 Linesimpl IdentityClientService for AuthenticatedService {
#[tracing::instrument(skip_all)] #[tracing::instrument(skip_all)]
async fn link_farcaster_account( async fn link_farcaster_account(
&self, &self,
request: tonic::Request<LinkFarcasterAccountRequest>, request: tonic::Request<LinkFarcasterAccountRequest>,
) -> Result<Response<Empty>, tonic::Status> { ) -> Result<Response<Empty>, tonic::Status> {
let (user_id, _) = get_user_and_device_id(&request)?; let (user_id, _) = get_user_and_device_id(&request)?;
let message = request.into_inner(); let message = request.into_inner();
info!(
user_id = redact_sensitive_data(&user_id),
fid = redact_sensitive_data(&message.farcaster_id),
"Attempting to link Farcaster account."
);
let mut get_farcaster_users_response = self let mut get_farcaster_users_response = self
.db_client .db_client
.get_farcaster_users(vec![message.farcaster_id.clone()]) .get_farcaster_users(vec![message.farcaster_id.clone()])
.await?; .await?;
if get_farcaster_users_response.len() > 1 { if get_farcaster_users_response.len() > 1 {
error!( error!(
errorType = error_types::GRPC_SERVICES_LOG, errorType = error_types::GRPC_SERVICES_LOG,
"multiple users associated with the same Farcaster ID" "multiple users associated with the same Farcaster ID"
); );
return Err(Status::failed_precondition( return Err(Status::failed_precondition(
tonic_status_messages::CANNOT_LINK_FID, tonic_status_messages::CANNOT_LINK_FID,
)); ));
} }
if let Some(u) = get_farcaster_users_response.pop() { if let Some(u) = get_farcaster_users_response.pop() {
if u.0.user_id == user_id { if u.0.user_id == user_id {
return Ok(Response::new(Empty {})); return Ok(Response::new(Empty {}));
} else { } else {
warn!("FID already assigned to another user!");
return Err(Status::already_exists(tonic_status_messages::FID_TAKEN)); return Err(Status::already_exists(tonic_status_messages::FID_TAKEN));
} }
} }
self self
.db_client .db_client
.add_farcaster_id(user_id, message.farcaster_id) .add_farcaster_id(user_id, message.farcaster_id)
.await?; .await?;
let response = Empty {}; let response = Empty {};
Ok(Response::new(response)) Ok(Response::new(response))
} }
#[tracing::instrument(skip_all)] #[tracing::instrument(skip_all)]
async fn unlink_farcaster_account( async fn unlink_farcaster_account(
&self, &self,
request: tonic::Request<Empty>, request: tonic::Request<Empty>,
) -> Result<Response<Empty>, tonic::Status> { ) -> Result<Response<Empty>, tonic::Status> {
let (user_id, _) = get_user_and_device_id(&request)?; let (user_id, _) = get_user_and_device_id(&request)?;
info!(
user_id = redact_sensitive_data(&user_id),
"Attempting to unlink Farcaster account."
);
self.db_client.remove_farcaster_id(user_id).await?; self.db_client.remove_farcaster_id(user_id).await?;
let response = Empty {}; let response = Empty {};
Ok(Response::new(response)) Ok(Response::new(response))
} }
#[tracing::instrument(skip_all)] #[tracing::instrument(skip_all)]
async fn find_user_identities( async fn find_user_identities(
▲ Show 20 Lines • Show All 199 Lines • Show Last 20 Lines
View Options

web/protobufs/identity-auth-structs.cjs.flow

Show First 20 Lines • Show All 1,077 Lines • ▼ Show 20 Linesimpl IdentityClientService for AuthenticatedService {
#[tracing::instrument(skip_all)] #[tracing::instrument(skip_all)]
async fn link_farcaster_account( async fn link_farcaster_account(
&self, &self,
request: tonic::Request<LinkFarcasterAccountRequest>, request: tonic::Request<LinkFarcasterAccountRequest>,
) -> Result<Response<Empty>, tonic::Status> { ) -> Result<Response<Empty>, tonic::Status> {
let (user_id, _) = get_user_and_device_id(&request)?; let (user_id, _) = get_user_and_device_id(&request)?;
let message = request.into_inner(); let message = request.into_inner();
info!(
user_id = redact_sensitive_data(&user_id),
fid = redact_sensitive_data(&message.farcaster_id),
"Attempting to link Farcaster account."
);
let mut get_farcaster_users_response = self let mut get_farcaster_users_response = self
.db_client .db_client
.get_farcaster_users(vec![message.farcaster_id.clone()]) .get_farcaster_users(vec![message.farcaster_id.clone()])
.await?; .await?;
if get_farcaster_users_response.len() > 1 { if get_farcaster_users_response.len() > 1 {
error!( error!(
errorType = error_types::GRPC_SERVICES_LOG, errorType = error_types::GRPC_SERVICES_LOG,
"multiple users associated with the same Farcaster ID" "multiple users associated with the same Farcaster ID"
); );
return Err(Status::failed_precondition( return Err(Status::failed_precondition(
tonic_status_messages::CANNOT_LINK_FID, tonic_status_messages::CANNOT_LINK_FID,
)); ));
} }
if let Some(u) = get_farcaster_users_response.pop() { if let Some(u) = get_farcaster_users_response.pop() {
if u.0.user_id == user_id { if u.0.user_id == user_id {
return Ok(Response::new(Empty {})); return Ok(Response::new(Empty {}));
} else { } else {
warn!("FID already assigned to another user!");
return Err(Status::already_exists(tonic_status_messages::FID_TAKEN)); return Err(Status::already_exists(tonic_status_messages::FID_TAKEN));
} }
} }
self self
.db_client .db_client
.add_farcaster_id(user_id, message.farcaster_id) .add_farcaster_id(user_id, message.farcaster_id)
.await?; .await?;
let response = Empty {}; let response = Empty {};
Ok(Response::new(response)) Ok(Response::new(response))
} }
#[tracing::instrument(skip_all)] #[tracing::instrument(skip_all)]
async fn unlink_farcaster_account( async fn unlink_farcaster_account(
&self, &self,
request: tonic::Request<Empty>, request: tonic::Request<Empty>,
) -> Result<Response<Empty>, tonic::Status> { ) -> Result<Response<Empty>, tonic::Status> {
let (user_id, _) = get_user_and_device_id(&request)?; let (user_id, _) = get_user_and_device_id(&request)?;
info!(
user_id = redact_sensitive_data(&user_id),
"Attempting to unlink Farcaster account."
);
self.db_client.remove_farcaster_id(user_id).await?; self.db_client.remove_farcaster_id(user_id).await?;
let response = Empty {}; let response = Empty {};
Ok(Response::new(response)) Ok(Response::new(response))
} }
#[tracing::instrument(skip_all)] #[tracing::instrument(skip_all)]
async fn find_user_identities( async fn find_user_identities(
▲ Show 20 Lines • Show All 199 Lines • Show Last 20 Lines