Page Menu
Home
Phabricator
Search
Configure Global Search
Log In
Files
F3728567
D11825.id39604.diff
No One
Temporary
Actions
View File
Edit File
Delete File
View Transforms
Subscribe
Mute Notifications
Award Token
Flag For Later
Size
7 KB
Referenced Files
None
Subscribers
None
D11825.id39604.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
@@ -99,6 +99,7 @@
#[tonic::async_trait]
impl IdentityClientService for ClientService {
+ #[tracing::instrument(skip_all)]
async fn register_password_user_start(
&self,
request: tonic::Request<RegistrationStartRequest>,
@@ -160,6 +161,7 @@
Ok(Response::new(response))
}
+ #[tracing::instrument(skip_all)]
async fn register_reserved_password_user_start(
&self,
request: tonic::Request<ReservedRegistrationStartRequest>,
@@ -216,6 +218,7 @@
Ok(Response::new(response))
}
+ #[tracing::instrument(skip_all)]
async fn register_password_user_finish(
&self,
request: tonic::Request<RegistrationFinishRequest>,
@@ -274,6 +277,7 @@
}
}
+ #[tracing::instrument(skip_all)]
async fn log_in_password_user_start(
&self,
request: tonic::Request<OpaqueLoginStartRequest>,
@@ -353,6 +357,7 @@
Ok(response)
}
+ #[tracing::instrument(skip_all)]
async fn log_in_password_user_finish(
&self,
request: tonic::Request<OpaqueLoginFinishRequest>,
@@ -418,6 +423,7 @@
}
}
+ #[tracing::instrument(skip_all)]
async fn log_in_wallet_user(
&self,
request: tonic::Request<WalletAuthRequest>,
@@ -499,6 +505,7 @@
Ok(Response::new(response))
}
+ #[tracing::instrument(skip_all)]
async fn register_wallet_user(
&self,
request: tonic::Request<WalletAuthRequest>,
@@ -595,6 +602,7 @@
Ok(Response::new(response))
}
+ #[tracing::instrument(skip_all)]
async fn register_reserved_wallet_user(
&self,
request: tonic::Request<ReservedWalletRegistrationRequest>,
@@ -675,6 +683,7 @@
Ok(Response::new(response))
}
+ #[tracing::instrument(skip_all)]
async fn upload_keys_for_registered_device_and_log_in(
&self,
request: tonic::Request<SecondaryDeviceKeysUploadRequest>,
@@ -748,6 +757,7 @@
Ok(Response::new(response))
}
+ #[tracing::instrument(skip_all)]
async fn log_in_existing_device(
&self,
request: tonic::Request<ExistingDeviceLoginRequest>,
@@ -804,6 +814,7 @@
Ok(Response::new(response))
}
+ #[tracing::instrument(skip_all)]
async fn generate_nonce(
&self,
_request: tonic::Request<Empty>,
@@ -821,6 +832,7 @@
}
}
+ #[tracing::instrument(skip_all)]
async fn verify_user_access_token(
&self,
request: tonic::Request<VerifyUserAccessTokenRequest>,
@@ -846,6 +858,7 @@
Ok(response)
}
+ #[tracing::instrument(skip_all)]
async fn add_reserved_usernames(
&self,
request: tonic::Request<AddReservedUsernamesRequest>,
@@ -873,6 +886,7 @@
Ok(response)
}
+ #[tracing::instrument(skip_all)]
async fn remove_reserved_username(
&self,
request: tonic::Request<RemoveReservedUsernameRequest>,
@@ -894,6 +908,7 @@
Ok(response)
}
+ #[tracing::instrument(skip_all)]
async fn ping(
&self,
_request: tonic::Request<Empty>,
@@ -902,6 +917,7 @@
Ok(response)
}
+ #[tracing::instrument(skip_all)]
async fn find_user_id(
&self,
request: tonic::Request<FindUserIdRequest>,
@@ -934,6 +950,7 @@
}))
}
+ #[tracing::instrument(skip_all)]
async fn get_farcaster_users(
&self,
request: tonic::Request<GetFarcasterUsersRequest>,
@@ -1068,6 +1085,7 @@
}
}
+#[tracing::instrument(skip_all)]
pub fn handle_db_error(db_error: DBError) -> tonic::Status {
match db_error {
DBError::AwsSdk(DynamoDBError::InternalServerError(_))
diff --git a/services/identity/src/grpc_services/authenticated.rs b/services/identity/src/grpc_services/authenticated.rs
--- a/services/identity/src/grpc_services/authenticated.rs
+++ b/services/identity/src/grpc_services/authenticated.rs
@@ -87,6 +87,7 @@
#[tonic::async_trait]
impl IdentityClientService for AuthenticatedService {
+ #[tracing::instrument(skip_all)]
async fn refresh_user_prekeys(
&self,
request: Request<RefreshUserPrekeysRequest>,
@@ -118,6 +119,7 @@
Ok(response)
}
+ #[tracing::instrument(skip_all)]
async fn get_outbound_keys_for_user(
&self,
request: tonic::Request<OutboundKeysForUserRequest>,
@@ -142,6 +144,7 @@
}))
}
+ #[tracing::instrument(skip_all)]
async fn get_inbound_keys_for_user(
&self,
request: tonic::Request<InboundKeysForUserRequest>,
@@ -174,6 +177,7 @@
}))
}
+ #[tracing::instrument(skip_all)]
async fn get_keyserver_keys(
&self,
request: Request<OutboundKeysForUserRequest>,
@@ -212,6 +216,7 @@
return Ok(response);
}
+ #[tracing::instrument(skip_all)]
async fn upload_one_time_keys(
&self,
request: tonic::Request<UploadOneTimeKeysRequest>,
@@ -234,6 +239,7 @@
Ok(tonic::Response::new(Empty {}))
}
+ #[tracing::instrument(skip_all)]
async fn update_user_password_start(
&self,
request: tonic::Request<UpdateUserPasswordStartRequest>,
@@ -265,6 +271,7 @@
Ok(Response::new(response))
}
+ #[tracing::instrument(skip_all)]
async fn update_user_password_finish(
&self,
request: tonic::Request<UpdateUserPasswordFinishRequest>,
@@ -295,6 +302,7 @@
Ok(Response::new(response))
}
+ #[tracing::instrument(skip_all)]
async fn log_out_user(
&self,
request: tonic::Request<Empty>,
@@ -323,6 +331,7 @@
Ok(Response::new(response))
}
+ #[tracing::instrument(skip_all)]
async fn delete_wallet_user(
&self,
request: tonic::Request<Empty>,
@@ -341,6 +350,7 @@
Ok(Response::new(response))
}
+ #[tracing::instrument(skip_all)]
async fn delete_password_user_start(
&self,
request: tonic::Request<DeletePasswordUserStartRequest>,
@@ -389,6 +399,7 @@
Ok(response)
}
+ #[tracing::instrument(skip_all)]
async fn delete_password_user_finish(
&self,
request: tonic::Request<DeletePasswordUserFinishRequest>,
@@ -421,6 +432,7 @@
Ok(Response::new(response))
}
+ #[tracing::instrument(skip_all)]
async fn get_device_list_for_user(
&self,
request: tonic::Request<GetDeviceListRequest>,
@@ -462,6 +474,7 @@
}))
}
+ #[tracing::instrument(skip_all)]
async fn get_device_lists_for_users(
&self,
request: tonic::Request<PeersDeviceListsRequest>,
@@ -510,6 +523,7 @@
Ok(Response::new(response))
}
+ #[tracing::instrument(skip_all)]
async fn update_device_list(
&self,
request: tonic::Request<UpdateDeviceListRequest>,
@@ -533,6 +547,7 @@
Ok(Response::new(Empty {}))
}
+ #[tracing::instrument(skip_all)]
async fn link_farcaster_account(
&self,
request: tonic::Request<LinkFarcasterAccountRequest>,
@@ -571,6 +586,7 @@
Ok(Response::new(response))
}
+ #[tracing::instrument(skip_all)]
async fn unlink_farcaster_account(
&self,
request: tonic::Request<Empty>,
@@ -587,6 +603,7 @@
Ok(Response::new(response))
}
+ #[tracing::instrument(skip_all)]
async fn find_user_identity(
&self,
request: tonic::Request<UserIdentityRequest>,
File Metadata
Details
Attached
Mime Type
text/plain
Expires
Thu, Jan 9, 10:03 PM (12 h, 36 m)
Storage Engine
blob
Storage Format
Raw Data
Storage Handle
2826183
Default Alt Text
D11825.id39604.diff (7 KB)
Attached To
Mode
D11825: [identity] Add span tracing to grpc handlers
Attached
Detach File
Event Timeline
Log In to Comment