Page MenuHomePhabricator
Differential D12565

[lib/native] lift tagFarcasterChannelErrorMessages into lib
ClosedPublic
Actions

Authored by ginsu on Jun 24 2024, 10:29 PM.
Tags
None
Referenced Files
Unknown Object (File)
Tue, Mar 25, 4:53 AM
Unknown Object (File)
Mar 11 2025, 4:17 PM
Unknown Object (File)
Mar 11 2025, 4:12 PM
Unknown Object (File)
Mar 11 2025, 3:52 PM
Unknown Object (File)
Mar 9 2025, 6:41 AM
Unknown Object (File)
Mar 9 2025, 6:41 AM
Unknown Object (File)
Mar 9 2025, 6:41 AM
Unknown Object (File)
Mar 6 2025, 2:59 AM
View All 84 Files
Subscribers
ashoat
tomek

Details

Reviewers
inka
kamil
Commits
rCOMM44723816bd0f: [lib/native] lift tagFarcasterChannelErrorMessages into lib
Summary

We will need this in web as well

Test Plan

flow

Diff Detail

Repository
rCOMM Comm
Lint
Lint Not Applicable
Unit
Tests Not Applicable

Event Timeline

ginsu created this revision.Jun 24 2024, 10:29 PM
Herald added subscribers: tomek, ashoat. · View Herald TranscriptJun 24 2024, 10:29 PM
ginsu edited the summary of this revision. (Show Details)Jun 24 2024, 10:30 PM
ginsu added reviewers: inka, kamil.
ginsu added a parent revision: D12561: [web] Dropdown component improvements.
Harbormaster completed remote builds in B29912: Diff 41672.Jun 24 2024, 10:45 PM
ginsu requested review of this revision.Jun 24 2024, 10:45 PM
ginsu added a child revision: D12566: [web] introduce CreateFarcasterChannelTagModal.Jun 24 2024, 10:56 PM
inka accepted this revision.Jun 27 2024, 6:30 AM
This revision is now accepted and ready to land.Jun 27 2024, 6:30 AM
ginsu updated this revision to Diff 41813.Jun 28 2024, 11:47 AM

rebase before landing now because I need this to address feedback in subsquent diffs

ginsu edited the summary of this revision. (Show Details)Jun 28 2024, 11:47 AM
ginsu removed a parent revision: D12561: [web] Dropdown component improvements.
This revision was landed with ongoing or failed builds.Jun 28 2024, 11:50 AM
Closed by commit rCOMM44723816bd0f: [lib/native] lift tagFarcasterChannelErrorMessages into lib (authored by ginsu). · Explain Why
This revision was automatically updated to reflect the committed changes.
ginsu added a commit: rCOMM44723816bd0f: [lib/native] lift tagFarcasterChannelErrorMessages into lib.
Harbormaster completed remote builds in B30002: Diff 41813.Jun 28 2024, 12:03 PM
ginsu removed a child revision: D12566: [web] introduce CreateFarcasterChannelTagModal.Jun 28 2024, 12:26 PM

Revision Contents
Changeset List

PathSize
lib/
shared/
6 lines
native/
community-settings/
tag-farcaster-channel/
6 lines
6 lines

Diff 41815

View Options

lib/shared/community-utils.js

use std::collections::{HashMap, HashSet}; use std::collections::{HashMap, HashSet};
use crate::comm_service::{backup, blob, tunnelbroker}; use crate::comm_service::{backup, blob, tunnelbroker};
use crate::config::CONFIG; use crate::config::CONFIG;
use crate::constants::staff::AUTHORITATIVE_KEYSERVER_OWNER_USER_ID;
use crate::database::{DeviceListRow, DeviceListUpdate, PlatformDetails}; use crate::database::{DeviceListRow, DeviceListUpdate, PlatformDetails};
use crate::device_list::validation::DeviceListValidator; use crate::device_list::validation::DeviceListValidator;
use crate::device_list::SignedDeviceList; use crate::device_list::SignedDeviceList;
use crate::error::consume_error; use crate::error::consume_error;
use crate::log::redact_sensitive_data; use crate::log::redact_sensitive_data;
use crate::token::AuthType; use crate::token::AuthType;
use crate::{ use crate::{
client_service::{handle_db_error, WorkflowInProgress}, client_service::{handle_db_error, WorkflowInProgress},
Show All 20 Linesuse super::protos::auth::{
PrivilegedResetUserPasswordFinishRequest, PrivilegedResetUserPasswordFinishRequest,
PrivilegedResetUserPasswordStartRequest, PrivilegedResetUserPasswordStartRequest,
PrivilegedResetUserPasswordStartResponse, RefreshUserPrekeysRequest, PrivilegedResetUserPasswordStartResponse, RefreshUserPrekeysRequest,
UpdateDeviceListRequest, UpdateUserPasswordFinishRequest, UpdateDeviceListRequest, UpdateUserPasswordFinishRequest,
UpdateUserPasswordStartRequest, UpdateUserPasswordStartResponse, UpdateUserPasswordStartRequest, UpdateUserPasswordStartResponse,
UploadOneTimeKeysRequest, UserDevicesPlatformDetails, UserIdentitiesRequest, UploadOneTimeKeysRequest, UserDevicesPlatformDetails, UserIdentitiesRequest,
UserIdentitiesResponse, UserIdentitiesResponse,
}; };
use super::protos::unauth::{DeviceType, Empty}; use super::protos::unauth::Empty;
#[derive(derive_more::Constructor)] #[derive(derive_more::Constructor)]
pub struct AuthenticatedService { pub struct AuthenticatedService {
db_client: DatabaseClient, db_client: DatabaseClient,
blob_client: BlobServiceClient, blob_client: BlobServiceClient,
comm_auth_service: AuthService, comm_auth_service: AuthService,
} }
▲ Show 20 Lines • Show All 489 Lines • ▼ Show 20 Lines ) -> Result<tonic::Response<Empty>, tonic::Status> {
self self
.verify_device_on_device_list( .verify_device_on_device_list(
&user_id, &user_id,
&device_id, &device_id,
DeviceListItemKind::Primary, DeviceListItemKind::Primary,
) )
.await?; .await?;
if user_id == AUTHORITATIVE_KEYSERVER_OWNER_USER_ID {
self.log_out_authoritative_keyserver_owner().await?;
return Ok(Response::new(Empty {}));
}
// Get and verify singleton device list // Get and verify singleton device list
let parsed_device_list: SignedDeviceList = let parsed_device_list: SignedDeviceList =
message.signed_device_list.parse()?; message.signed_device_list.parse()?;
let maybe_keyserver_device_id = self let maybe_keyserver_device_id = self
.db_client .db_client
.get_keyserver_device_id_for_user(&user_id) .get_keyserver_device_id_for_user(&user_id)
.await?; .await?;
▲ Show 20 Lines • Show All 715 Lines • ▼ Show 20 Lines let s2s_token =
"Failed to retrieve service-to-service token: {err:?}", "Failed to retrieve service-to-service token: {err:?}",
); );
tonic::Status::aborted(tonic_status_messages::UNEXPECTED_ERROR) tonic::Status::aborted(tonic_status_messages::UNEXPECTED_ERROR)
})?; })?;
let blob_client = self.blob_client.with_authentication(s2s_token.into()); let blob_client = self.blob_client.with_authentication(s2s_token.into());
Ok(blob_client) Ok(blob_client)
} }
/// for authoritatative keyserver owner, instead of primary device logout,
/// we should remove all devices but keyserver, remove backup
/// and create an unsigned device list update, effectively downgrading
/// the user back to v1 flows
async fn log_out_authoritative_keyserver_owner(
&self,
) -> Result<(), tonic::Status> {
let user_id = AUTHORITATIVE_KEYSERVER_OWNER_USER_ID;
info!(
user_id = redact_sensitive_data(user_id),
"Performing authoritative keyserver owner logout."
);
let devices = self.db_client.get_current_devices(user_id).await?;
let keyserver_device_id = devices
.iter()
.find(|it| matches!(it.device_type(), DeviceType::Keyserver))
.map(|keyserver| &keyserver.device_id);
let new_device_list = if let Some(keyserver_id) = keyserver_device_id {
vec![keyserver_id.to_string()]
} else {
Vec::new()
};
let device_list_update = DeviceListUpdate::new_unsigned(new_device_list)?;
let validator = None::<DeviceListValidator>;
self
.db_client
.apply_devicelist_update(user_id, device_list_update, validator, true)
.await?;
backup::delete_backup_user_data(user_id, &self.comm_auth_service).await?;
Ok(())
}
async fn get_current_device_list( async fn get_current_device_list(
&self, &self,
user_id: &str, user_id: &str,
) -> Result<DeviceListRow, tonic::Status> { ) -> Result<DeviceListRow, tonic::Status> {
let device_list = self let device_list = self
.db_client .db_client
.get_current_device_list(user_id) .get_current_device_list(user_id)
.await .await
▲ Show 20 Lines • Show All 46 Lines • Show Last 20 Lines
View Options

native/community-settings/tag-farcaster-channel/tag-farcaster-channel-by-name.react.js

use std::collections::{HashMap, HashSet}; use std::collections::{HashMap, HashSet};
use crate::comm_service::{backup, blob, tunnelbroker}; use crate::comm_service::{backup, blob, tunnelbroker};
use crate::config::CONFIG; use crate::config::CONFIG;
use crate::constants::staff::AUTHORITATIVE_KEYSERVER_OWNER_USER_ID;
use crate::database::{DeviceListRow, DeviceListUpdate, PlatformDetails}; use crate::database::{DeviceListRow, DeviceListUpdate, PlatformDetails};
use crate::device_list::validation::DeviceListValidator; use crate::device_list::validation::DeviceListValidator;
use crate::device_list::SignedDeviceList; use crate::device_list::SignedDeviceList;
use crate::error::consume_error; use crate::error::consume_error;
use crate::log::redact_sensitive_data; use crate::log::redact_sensitive_data;
use crate::token::AuthType; use crate::token::AuthType;
use crate::{ use crate::{
client_service::{handle_db_error, WorkflowInProgress}, client_service::{handle_db_error, WorkflowInProgress},
Show All 20 Linesuse super::protos::auth::{
PrivilegedResetUserPasswordFinishRequest, PrivilegedResetUserPasswordFinishRequest,
PrivilegedResetUserPasswordStartRequest, PrivilegedResetUserPasswordStartRequest,
PrivilegedResetUserPasswordStartResponse, RefreshUserPrekeysRequest, PrivilegedResetUserPasswordStartResponse, RefreshUserPrekeysRequest,
UpdateDeviceListRequest, UpdateUserPasswordFinishRequest, UpdateDeviceListRequest, UpdateUserPasswordFinishRequest,
UpdateUserPasswordStartRequest, UpdateUserPasswordStartResponse, UpdateUserPasswordStartRequest, UpdateUserPasswordStartResponse,
UploadOneTimeKeysRequest, UserDevicesPlatformDetails, UserIdentitiesRequest, UploadOneTimeKeysRequest, UserDevicesPlatformDetails, UserIdentitiesRequest,
UserIdentitiesResponse, UserIdentitiesResponse,
}; };
use super::protos::unauth::{DeviceType, Empty}; use super::protos::unauth::Empty;
#[derive(derive_more::Constructor)] #[derive(derive_more::Constructor)]
pub struct AuthenticatedService { pub struct AuthenticatedService {
db_client: DatabaseClient, db_client: DatabaseClient,
blob_client: BlobServiceClient, blob_client: BlobServiceClient,
comm_auth_service: AuthService, comm_auth_service: AuthService,
} }
▲ Show 20 Lines • Show All 489 Lines • ▼ Show 20 Lines ) -> Result<tonic::Response<Empty>, tonic::Status> {
self self
.verify_device_on_device_list( .verify_device_on_device_list(
&user_id, &user_id,
&device_id, &device_id,
DeviceListItemKind::Primary, DeviceListItemKind::Primary,
) )
.await?; .await?;
if user_id == AUTHORITATIVE_KEYSERVER_OWNER_USER_ID {
self.log_out_authoritative_keyserver_owner().await?;
return Ok(Response::new(Empty {}));
}
// Get and verify singleton device list // Get and verify singleton device list
let parsed_device_list: SignedDeviceList = let parsed_device_list: SignedDeviceList =
message.signed_device_list.parse()?; message.signed_device_list.parse()?;
let maybe_keyserver_device_id = self let maybe_keyserver_device_id = self
.db_client .db_client
.get_keyserver_device_id_for_user(&user_id) .get_keyserver_device_id_for_user(&user_id)
.await?; .await?;
▲ Show 20 Lines • Show All 715 Lines • ▼ Show 20 Lines let s2s_token =
"Failed to retrieve service-to-service token: {err:?}", "Failed to retrieve service-to-service token: {err:?}",
); );
tonic::Status::aborted(tonic_status_messages::UNEXPECTED_ERROR) tonic::Status::aborted(tonic_status_messages::UNEXPECTED_ERROR)
})?; })?;
let blob_client = self.blob_client.with_authentication(s2s_token.into()); let blob_client = self.blob_client.with_authentication(s2s_token.into());
Ok(blob_client) Ok(blob_client)
} }
/// for authoritatative keyserver owner, instead of primary device logout,
/// we should remove all devices but keyserver, remove backup
/// and create an unsigned device list update, effectively downgrading
/// the user back to v1 flows
async fn log_out_authoritative_keyserver_owner(
&self,
) -> Result<(), tonic::Status> {
let user_id = AUTHORITATIVE_KEYSERVER_OWNER_USER_ID;
info!(
user_id = redact_sensitive_data(user_id),
"Performing authoritative keyserver owner logout."
);
let devices = self.db_client.get_current_devices(user_id).await?;
let keyserver_device_id = devices
.iter()
.find(|it| matches!(it.device_type(), DeviceType::Keyserver))
.map(|keyserver| &keyserver.device_id);
let new_device_list = if let Some(keyserver_id) = keyserver_device_id {
vec![keyserver_id.to_string()]
} else {
Vec::new()
};
let device_list_update = DeviceListUpdate::new_unsigned(new_device_list)?;
let validator = None::<DeviceListValidator>;
self
.db_client
.apply_devicelist_update(user_id, device_list_update, validator, true)
.await?;
backup::delete_backup_user_data(user_id, &self.comm_auth_service).await?;
Ok(())
}
async fn get_current_device_list( async fn get_current_device_list(
&self, &self,
user_id: &str, user_id: &str,
) -> Result<DeviceListRow, tonic::Status> { ) -> Result<DeviceListRow, tonic::Status> {
let device_list = self let device_list = self
.db_client .db_client
.get_current_device_list(user_id) .get_current_device_list(user_id)
.await .await
▲ Show 20 Lines • Show All 46 Lines • Show Last 20 Lines
View Options

native/community-settings/tag-farcaster-channel/tag-farcaster-channel-utils.js

use std::collections::{HashMap, HashSet}; use std::collections::{HashMap, HashSet};
use crate::comm_service::{backup, blob, tunnelbroker}; use crate::comm_service::{backup, blob, tunnelbroker};
use crate::config::CONFIG; use crate::config::CONFIG;
use crate::constants::staff::AUTHORITATIVE_KEYSERVER_OWNER_USER_ID;
use crate::database::{DeviceListRow, DeviceListUpdate, PlatformDetails}; use crate::database::{DeviceListRow, DeviceListUpdate, PlatformDetails};
use crate::device_list::validation::DeviceListValidator; use crate::device_list::validation::DeviceListValidator;
use crate::device_list::SignedDeviceList; use crate::device_list::SignedDeviceList;
use crate::error::consume_error; use crate::error::consume_error;
use crate::log::redact_sensitive_data; use crate::log::redact_sensitive_data;
use crate::token::AuthType; use crate::token::AuthType;
use crate::{ use crate::{
client_service::{handle_db_error, WorkflowInProgress}, client_service::{handle_db_error, WorkflowInProgress},
Show All 20 Linesuse super::protos::auth::{
PrivilegedResetUserPasswordFinishRequest, PrivilegedResetUserPasswordFinishRequest,
PrivilegedResetUserPasswordStartRequest, PrivilegedResetUserPasswordStartRequest,
PrivilegedResetUserPasswordStartResponse, RefreshUserPrekeysRequest, PrivilegedResetUserPasswordStartResponse, RefreshUserPrekeysRequest,
UpdateDeviceListRequest, UpdateUserPasswordFinishRequest, UpdateDeviceListRequest, UpdateUserPasswordFinishRequest,
UpdateUserPasswordStartRequest, UpdateUserPasswordStartResponse, UpdateUserPasswordStartRequest, UpdateUserPasswordStartResponse,
UploadOneTimeKeysRequest, UserDevicesPlatformDetails, UserIdentitiesRequest, UploadOneTimeKeysRequest, UserDevicesPlatformDetails, UserIdentitiesRequest,
UserIdentitiesResponse, UserIdentitiesResponse,
}; };
use super::protos::unauth::{DeviceType, Empty}; use super::protos::unauth::Empty;
#[derive(derive_more::Constructor)] #[derive(derive_more::Constructor)]
pub struct AuthenticatedService { pub struct AuthenticatedService {
db_client: DatabaseClient, db_client: DatabaseClient,
blob_client: BlobServiceClient, blob_client: BlobServiceClient,
comm_auth_service: AuthService, comm_auth_service: AuthService,
} }
▲ Show 20 Lines • Show All 489 Lines • ▼ Show 20 Lines ) -> Result<tonic::Response<Empty>, tonic::Status> {
self self
.verify_device_on_device_list( .verify_device_on_device_list(
&user_id, &user_id,
&device_id, &device_id,
DeviceListItemKind::Primary, DeviceListItemKind::Primary,
) )
.await?; .await?;
if user_id == AUTHORITATIVE_KEYSERVER_OWNER_USER_ID {
self.log_out_authoritative_keyserver_owner().await?;
return Ok(Response::new(Empty {}));
}
// Get and verify singleton device list // Get and verify singleton device list
let parsed_device_list: SignedDeviceList = let parsed_device_list: SignedDeviceList =
message.signed_device_list.parse()?; message.signed_device_list.parse()?;
let maybe_keyserver_device_id = self let maybe_keyserver_device_id = self
.db_client .db_client
.get_keyserver_device_id_for_user(&user_id) .get_keyserver_device_id_for_user(&user_id)
.await?; .await?;
▲ Show 20 Lines • Show All 715 Lines • ▼ Show 20 Lines let s2s_token =
"Failed to retrieve service-to-service token: {err:?}", "Failed to retrieve service-to-service token: {err:?}",
); );
tonic::Status::aborted(tonic_status_messages::UNEXPECTED_ERROR) tonic::Status::aborted(tonic_status_messages::UNEXPECTED_ERROR)
})?; })?;
let blob_client = self.blob_client.with_authentication(s2s_token.into()); let blob_client = self.blob_client.with_authentication(s2s_token.into());
Ok(blob_client) Ok(blob_client)
} }
/// for authoritatative keyserver owner, instead of primary device logout,
/// we should remove all devices but keyserver, remove backup
/// and create an unsigned device list update, effectively downgrading
/// the user back to v1 flows
async fn log_out_authoritative_keyserver_owner(
&self,
) -> Result<(), tonic::Status> {
let user_id = AUTHORITATIVE_KEYSERVER_OWNER_USER_ID;
info!(
user_id = redact_sensitive_data(user_id),
"Performing authoritative keyserver owner logout."
);
let devices = self.db_client.get_current_devices(user_id).await?;
let keyserver_device_id = devices
.iter()
.find(|it| matches!(it.device_type(), DeviceType::Keyserver))
.map(|keyserver| &keyserver.device_id);
let new_device_list = if let Some(keyserver_id) = keyserver_device_id {
vec![keyserver_id.to_string()]
} else {
Vec::new()
};
let device_list_update = DeviceListUpdate::new_unsigned(new_device_list)?;
let validator = None::<DeviceListValidator>;
self
.db_client
.apply_devicelist_update(user_id, device_list_update, validator, true)
.await?;
backup::delete_backup_user_data(user_id, &self.comm_auth_service).await?;
Ok(())
}
async fn get_current_device_list( async fn get_current_device_list(
&self, &self,
user_id: &str, user_id: &str,
) -> Result<DeviceListRow, tonic::Status> { ) -> Result<DeviceListRow, tonic::Status> {
let device_list = self let device_list = self
.db_client .db_client
.get_current_device_list(user_id) .get_current_device_list(user_id)
.await .await
▲ Show 20 Lines • Show All 46 Lines • Show Last 20 Lines
View Options

native/community-settings/tag-farcaster-channel/tag-farcaster-channel.react.js

use std::collections::{HashMap, HashSet}; use std::collections::{HashMap, HashSet};
use crate::comm_service::{backup, blob, tunnelbroker}; use crate::comm_service::{backup, blob, tunnelbroker};
use crate::config::CONFIG; use crate::config::CONFIG;
use crate::constants::staff::AUTHORITATIVE_KEYSERVER_OWNER_USER_ID;
use crate::database::{DeviceListRow, DeviceListUpdate, PlatformDetails}; use crate::database::{DeviceListRow, DeviceListUpdate, PlatformDetails};
use crate::device_list::validation::DeviceListValidator; use crate::device_list::validation::DeviceListValidator;
use crate::device_list::SignedDeviceList; use crate::device_list::SignedDeviceList;
use crate::error::consume_error; use crate::error::consume_error;
use crate::log::redact_sensitive_data; use crate::log::redact_sensitive_data;
use crate::token::AuthType; use crate::token::AuthType;
use crate::{ use crate::{
client_service::{handle_db_error, WorkflowInProgress}, client_service::{handle_db_error, WorkflowInProgress},
Show All 20 Linesuse super::protos::auth::{
PrivilegedResetUserPasswordFinishRequest, PrivilegedResetUserPasswordFinishRequest,
PrivilegedResetUserPasswordStartRequest, PrivilegedResetUserPasswordStartRequest,
PrivilegedResetUserPasswordStartResponse, RefreshUserPrekeysRequest, PrivilegedResetUserPasswordStartResponse, RefreshUserPrekeysRequest,
UpdateDeviceListRequest, UpdateUserPasswordFinishRequest, UpdateDeviceListRequest, UpdateUserPasswordFinishRequest,
UpdateUserPasswordStartRequest, UpdateUserPasswordStartResponse, UpdateUserPasswordStartRequest, UpdateUserPasswordStartResponse,
UploadOneTimeKeysRequest, UserDevicesPlatformDetails, UserIdentitiesRequest, UploadOneTimeKeysRequest, UserDevicesPlatformDetails, UserIdentitiesRequest,
UserIdentitiesResponse, UserIdentitiesResponse,
}; };
use super::protos::unauth::{DeviceType, Empty}; use super::protos::unauth::Empty;
#[derive(derive_more::Constructor)] #[derive(derive_more::Constructor)]
pub struct AuthenticatedService { pub struct AuthenticatedService {
db_client: DatabaseClient, db_client: DatabaseClient,
blob_client: BlobServiceClient, blob_client: BlobServiceClient,
comm_auth_service: AuthService, comm_auth_service: AuthService,
} }
▲ Show 20 Lines • Show All 489 Lines • ▼ Show 20 Lines ) -> Result<tonic::Response<Empty>, tonic::Status> {
self self
.verify_device_on_device_list( .verify_device_on_device_list(
&user_id, &user_id,
&device_id, &device_id,
DeviceListItemKind::Primary, DeviceListItemKind::Primary,
) )
.await?; .await?;
if user_id == AUTHORITATIVE_KEYSERVER_OWNER_USER_ID {
self.log_out_authoritative_keyserver_owner().await?;
return Ok(Response::new(Empty {}));
}
// Get and verify singleton device list // Get and verify singleton device list
let parsed_device_list: SignedDeviceList = let parsed_device_list: SignedDeviceList =
message.signed_device_list.parse()?; message.signed_device_list.parse()?;
let maybe_keyserver_device_id = self let maybe_keyserver_device_id = self
.db_client .db_client
.get_keyserver_device_id_for_user(&user_id) .get_keyserver_device_id_for_user(&user_id)
.await?; .await?;
▲ Show 20 Lines • Show All 715 Lines • ▼ Show 20 Lines let s2s_token =
"Failed to retrieve service-to-service token: {err:?}", "Failed to retrieve service-to-service token: {err:?}",
); );
tonic::Status::aborted(tonic_status_messages::UNEXPECTED_ERROR) tonic::Status::aborted(tonic_status_messages::UNEXPECTED_ERROR)
})?; })?;
let blob_client = self.blob_client.with_authentication(s2s_token.into()); let blob_client = self.blob_client.with_authentication(s2s_token.into());
Ok(blob_client) Ok(blob_client)
} }
/// for authoritatative keyserver owner, instead of primary device logout,
/// we should remove all devices but keyserver, remove backup
/// and create an unsigned device list update, effectively downgrading
/// the user back to v1 flows
async fn log_out_authoritative_keyserver_owner(
&self,
) -> Result<(), tonic::Status> {
let user_id = AUTHORITATIVE_KEYSERVER_OWNER_USER_ID;
info!(
user_id = redact_sensitive_data(user_id),
"Performing authoritative keyserver owner logout."
);
let devices = self.db_client.get_current_devices(user_id).await?;
let keyserver_device_id = devices
.iter()
.find(|it| matches!(it.device_type(), DeviceType::Keyserver))
.map(|keyserver| &keyserver.device_id);
let new_device_list = if let Some(keyserver_id) = keyserver_device_id {
vec![keyserver_id.to_string()]
} else {
Vec::new()
};
let device_list_update = DeviceListUpdate::new_unsigned(new_device_list)?;
let validator = None::<DeviceListValidator>;
self
.db_client
.apply_devicelist_update(user_id, device_list_update, validator, true)
.await?;
backup::delete_backup_user_data(user_id, &self.comm_auth_service).await?;
Ok(())
}
async fn get_current_device_list( async fn get_current_device_list(
&self, &self,
user_id: &str, user_id: &str,
) -> Result<DeviceListRow, tonic::Status> { ) -> Result<DeviceListRow, tonic::Status> {
let device_list = self let device_list = self
.db_client .db_client
.get_current_device_list(user_id) .get_current_device_list(user_id)
.await .await
▲ Show 20 Lines • Show All 46 Lines • Show Last 20 Lines