Page MenuHomePhabricator
Differential D13399

[lib] action for calling fetch all communities with names endpoint
ClosedPublic
Actions

Authored by varun on Sep 20 2024, 1:27 AM.
Tags
None
Referenced Files
Unknown Object (File)
Thu, Apr 3, 1:16 PM
Unknown Object (File)
Thu, Apr 3, 10:40 AM
Unknown Object (File)
Wed, Apr 2, 9:48 PM
Unknown Object (File)
Wed, Apr 2, 12:10 PM
Unknown Object (File)
Fri, Mar 21, 11:17 AM
Unknown Object (File)
Mar 3 2025, 2:14 AM
Unknown Object (File)
Feb 28 2025, 9:26 AM
Unknown Object (File)
Feb 28 2025, 8:12 AM
View All 50 Files
Subscribers
None

Details

Reviewers
ashoat
tomek
Commits
rCOMM021a1c8c6e79: [lib] action for calling fetch all communities with names endpoint
Summary

we'll dispatch this action to call fetch_all_communities_with_names on the authoritative keyserver

Depends on D13398

Test Plan

dispatched action using useLegacyAshoatKeyserverCall. see gist: https://gist.github.com/vdhanan/df461cabc7a954ab1bc169104b98fbbb

saw success in redux and the correct payload

Diff Detail

Repository
rCOMM Comm
Lint
Lint Not Applicable
Unit
Tests Not Applicable

Event Timeline

varun created this revision.Sep 20 2024, 1:27 AM
Harbormaster completed remote builds in B31727: Diff 44357.Sep 20 2024, 1:42 AM
varun requested review of this revision.Sep 20 2024, 1:42 AM
ashoat accepted this revision.Sep 20 2024, 5:45 AM
ashoat added inline comments.
lib/actions/community-actions.js
73–77 ↗(On Diff #44357)
This revision is now accepted and ready to land.Sep 20 2024, 5:45 AM
Closed by commit rCOMM021a1c8c6e79: [lib] action for calling fetch all communities with names endpoint (authored by varun). · Explain WhySep 24 2024, 10:57 AM
This revision was automatically updated to reflect the committed changes.
varun added a commit: rCOMM021a1c8c6e79: [lib] action for calling fetch all communities with names endpoint.

Revision Contents
Changeset List

PathSize
lib/
actions/
15 lines
types/
17 lines

Diff 44492

View Options

lib/actions/community-actions.js

use backup_client::{ use backup_client::{
BackupClient, BackupData, BackupDescriptor, RequestedData, BackupClient, BackupData, BackupDescriptor, RequestedData,
}; };
use bytesize::ByteSize; use bytesize::ByteSize;
use comm_lib::{auth::UserIdentity, backup::LatestBackupIDResponse}; use comm_lib::{auth::UserIdentity, backup::LatestBackupIDResponse};
use commtest::identity::device::register_user_device;
use commtest::{ use commtest::{
service_addr, service_addr,
tools::{generate_stable_nbytes, obtain_number_of_threads, Error}, tools::{generate_stable_nbytes, obtain_number_of_threads, Error},
}; };
use grpc_clients::identity::DeviceType;
use tokio::{runtime::Runtime, task::JoinSet}; use tokio::{runtime::Runtime, task::JoinSet};
#[tokio::test] #[tokio::test]
async fn backup_performance_test() -> Result<(), Error> { async fn backup_performance_test() -> Result<(), Error> {
let backup_client = BackupClient::new(service_addr::BACKUP_SERVICE_HTTP)?; let backup_client = BackupClient::new(service_addr::BACKUP_SERVICE_HTTP)?;
let number_of_threads = obtain_number_of_threads(); let number_of_threads = obtain_number_of_threads();
Show All 16 Lines backup_data.push(BackupData {
ByteSize::mib(4).as_u64() as usize, ByteSize::mib(4).as_u64() as usize,
Some(i as u8), Some(i as u8),
), ),
attachments: vec![], attachments: vec![],
siwe_backup_msg: None, siwe_backup_msg: None,
}); });
} }
let device_info_1 = register_user_device(None, Some(DeviceType::Ios)).await;
let device_info_2 = register_user_device(None, Some(DeviceType::Ios)).await;
let user_identities = [ let user_identities = [
UserIdentity { UserIdentity {
user_id: "1".to_string(), user_id: device_info_1.user_id.clone(),
access_token: "dummy access token".to_string(), access_token: device_info_1.access_token,
device_id: "dummy device_id".to_string(), device_id: device_info_1.device_id,
}, },
UserIdentity { UserIdentity {
user_id: "2".to_string(), user_id: device_info_2.user_id.clone(),
access_token: "dummy access token".to_string(), access_token: device_info_2.access_token,
device_id: "dummy device_id".to_string(), device_id: device_info_2.device_id,
}, },
]; ];
tokio::task::spawn_blocking(move || { tokio::task::spawn_blocking(move || {
println!("Creating new backups"); println!("Creating new backups");
rt.block_on(async { rt.block_on(async {
let mut set = JoinSet::new(); let mut set = JoinSet::new();
for (i, item) in backup_data.iter().cloned().enumerate() { for (i, item) in backup_data.iter().cloned().enumerate() {
▲ Show 20 Lines • Show All 113 Lines • Show Last 20 Lines
View Options

lib/types/redux-types.js

use backup_client::{ use backup_client::{
BackupClient, BackupData, BackupDescriptor, RequestedData, BackupClient, BackupData, BackupDescriptor, RequestedData,
}; };
use bytesize::ByteSize; use bytesize::ByteSize;
use comm_lib::{auth::UserIdentity, backup::LatestBackupIDResponse}; use comm_lib::{auth::UserIdentity, backup::LatestBackupIDResponse};
use commtest::identity::device::register_user_device;
use commtest::{ use commtest::{
service_addr, service_addr,
tools::{generate_stable_nbytes, obtain_number_of_threads, Error}, tools::{generate_stable_nbytes, obtain_number_of_threads, Error},
}; };
use grpc_clients::identity::DeviceType;
use tokio::{runtime::Runtime, task::JoinSet}; use tokio::{runtime::Runtime, task::JoinSet};
#[tokio::test] #[tokio::test]
async fn backup_performance_test() -> Result<(), Error> { async fn backup_performance_test() -> Result<(), Error> {
let backup_client = BackupClient::new(service_addr::BACKUP_SERVICE_HTTP)?; let backup_client = BackupClient::new(service_addr::BACKUP_SERVICE_HTTP)?;
let number_of_threads = obtain_number_of_threads(); let number_of_threads = obtain_number_of_threads();
Show All 16 Lines backup_data.push(BackupData {
ByteSize::mib(4).as_u64() as usize, ByteSize::mib(4).as_u64() as usize,
Some(i as u8), Some(i as u8),
), ),
attachments: vec![], attachments: vec![],
siwe_backup_msg: None, siwe_backup_msg: None,
}); });
} }
let device_info_1 = register_user_device(None, Some(DeviceType::Ios)).await;
let device_info_2 = register_user_device(None, Some(DeviceType::Ios)).await;
let user_identities = [ let user_identities = [
UserIdentity { UserIdentity {
user_id: "1".to_string(), user_id: device_info_1.user_id.clone(),
access_token: "dummy access token".to_string(), access_token: device_info_1.access_token,
device_id: "dummy device_id".to_string(), device_id: device_info_1.device_id,
}, },
UserIdentity { UserIdentity {
user_id: "2".to_string(), user_id: device_info_2.user_id.clone(),
access_token: "dummy access token".to_string(), access_token: device_info_2.access_token,
device_id: "dummy device_id".to_string(), device_id: device_info_2.device_id,
}, },
]; ];
tokio::task::spawn_blocking(move || { tokio::task::spawn_blocking(move || {
println!("Creating new backups"); println!("Creating new backups");
rt.block_on(async { rt.block_on(async {
let mut set = JoinSet::new(); let mut set = JoinSet::new();
for (i, item) in backup_data.iter().cloned().enumerate() { for (i, item) in backup_data.iter().cloned().enumerate() {
▲ Show 20 Lines • Show All 113 Lines • Show Last 20 Lines