Page MenuHomePhabricator
Differential D10291

[IGNORE] Starting point for parameterizing getRelativeMemberInfos
AbandonedPublic
Actions

Authored by atul on Dec 11 2023, 9:43 AM.
Tags
None
Referenced Files
Unknown Object (File)
Wed, Apr 2, 4:43 AM
Unknown Object (File)
Sun, Mar 23, 9:14 PM
Unknown Object (File)
Sun, Mar 23, 9:14 PM
Unknown Object (File)
Wed, Mar 19, 7:24 PM
Unknown Object (File)
Feb 21 2025, 1:09 PM
Unknown Object (File)
Feb 21 2025, 1:09 PM
Unknown Object (File)
Feb 21 2025, 1:09 PM
Unknown Object (File)
Jan 22 2025, 11:48 AM
View All 51 Files
Subscribers
tomek

Details

Reviewers
ashoat
Summary

Starting point for parameterizing getRelativeMemberInfos

Test Plan

NA

Diff Detail

Repository
rCOMM Comm
Branch
master
Lint
No Lint Coverage
Unit
No Test Coverage

Revision Contents
Changeset List

PathSize
lib/
selectors/
62 lines
shared/
11 lines

Diff 34478

View Options

lib/selectors/user-selectors.js

Show First 20 Lines • Show All 276 Lines • ▼ Show 20 Lines) -> actix_web::Result<HttpResponse> {
) )
} }
#[instrument(skip_all, fields(username = %path))] #[instrument(skip_all, fields(username = %path))]
pub async fn get_latest_backup_id( pub async fn get_latest_backup_id(
path: web::Path<String>, path: web::Path<String>,
db_client: web::Data<DatabaseClient>, db_client: web::Data<DatabaseClient>,
) -> actix_web::Result<impl Responder> { ) -> actix_web::Result<impl Responder> {
let username = path.into_inner(); let user_identifier = path.into_inner();
let user_id = find_user_id(&username).await?; let user_id = find_user_id(&user_identifier).await?;
let Some(backup_item) = db_client let Some(backup_item) = db_client
.find_last_backup_item(&user_id) .find_last_backup_item(&user_id)
.await .await
.map_err(BackupError::from)? .map_err(BackupError::from)?
else { else {
return Err(BackupError::NoBackup.into()); return Err(BackupError::NoBackup.into());
}; };
let response = LatestBackupIDResponse { let response = LatestBackupIDResponse {
backup_id: backup_item.backup_id, backup_id: backup_item.backup_id,
siwe_backup_msg: backup_item.siwe_backup_msg, siwe_backup_msg: backup_item.siwe_backup_msg,
}; };
Ok(web::Json(response)) Ok(web::Json(response))
} }
#[instrument(skip_all, fields(username = %path))] #[instrument(skip_all, fields(username = %path))]
pub async fn download_latest_backup_keys( pub async fn download_latest_backup_keys(
path: web::Path<String>, path: web::Path<String>,
db_client: web::Data<DatabaseClient>, db_client: web::Data<DatabaseClient>,
blob_client: Authenticated<BlobServiceClient>, blob_client: Authenticated<BlobServiceClient>,
) -> actix_web::Result<HttpResponse> { ) -> actix_web::Result<HttpResponse> {
let username = path.into_inner(); let user_identifier = path.into_inner();
let user_id = find_user_id(&username).await?; let user_id = find_user_id(&user_identifier).await?;
let Some(backup_item) = db_client let Some(backup_item) = db_client
.find_last_backup_item(&user_id) .find_last_backup_item(&user_id)
.await .await
.map_err(BackupError::from)? .map_err(BackupError::from)?
else { else {
return Err(BackupError::NoBackup.into()); return Err(BackupError::NoBackup.into());
}; };
Show All 12 Lines
View Options

lib/shared/thread-utils.js

Show First 20 Lines • Show All 276 Lines • ▼ Show 20 Lines) -> actix_web::Result<HttpResponse> {
) )
} }
#[instrument(skip_all, fields(username = %path))] #[instrument(skip_all, fields(username = %path))]
pub async fn get_latest_backup_id( pub async fn get_latest_backup_id(
path: web::Path<String>, path: web::Path<String>,
db_client: web::Data<DatabaseClient>, db_client: web::Data<DatabaseClient>,
) -> actix_web::Result<impl Responder> { ) -> actix_web::Result<impl Responder> {
let username = path.into_inner(); let user_identifier = path.into_inner();
let user_id = find_user_id(&username).await?; let user_id = find_user_id(&user_identifier).await?;
let Some(backup_item) = db_client let Some(backup_item) = db_client
.find_last_backup_item(&user_id) .find_last_backup_item(&user_id)
.await .await
.map_err(BackupError::from)? .map_err(BackupError::from)?
else { else {
return Err(BackupError::NoBackup.into()); return Err(BackupError::NoBackup.into());
}; };
let response = LatestBackupIDResponse { let response = LatestBackupIDResponse {
backup_id: backup_item.backup_id, backup_id: backup_item.backup_id,
siwe_backup_msg: backup_item.siwe_backup_msg, siwe_backup_msg: backup_item.siwe_backup_msg,
}; };
Ok(web::Json(response)) Ok(web::Json(response))
} }
#[instrument(skip_all, fields(username = %path))] #[instrument(skip_all, fields(username = %path))]
pub async fn download_latest_backup_keys( pub async fn download_latest_backup_keys(
path: web::Path<String>, path: web::Path<String>,
db_client: web::Data<DatabaseClient>, db_client: web::Data<DatabaseClient>,
blob_client: Authenticated<BlobServiceClient>, blob_client: Authenticated<BlobServiceClient>,
) -> actix_web::Result<HttpResponse> { ) -> actix_web::Result<HttpResponse> {
let username = path.into_inner(); let user_identifier = path.into_inner();
let user_id = find_user_id(&username).await?; let user_id = find_user_id(&user_identifier).await?;
let Some(backup_item) = db_client let Some(backup_item) = db_client
.find_last_backup_item(&user_id) .find_last_backup_item(&user_id)
.await .await
.map_err(BackupError::from)? .map_err(BackupError::from)?
else { else {
return Err(BackupError::NoBackup.into()); return Err(BackupError::NoBackup.into());
}; };
Show All 12 Lines