Page MenuHomePhabricator
Differential D11407

[native_rust_library] implement link_farcaster_account client method
ClosedPublic
Actions

Authored by varun on Mar 27 2024, 12:58 PM.
Tags
None
Referenced Files
Unknown Object (File)
Thu, Apr 3, 1:37 AM
Unknown Object (File)
Sun, Mar 30, 2:31 PM
Unknown Object (File)
Sun, Mar 30, 11:34 AM
Unknown Object (File)
Sun, Mar 30, 12:54 AM
Unknown Object (File)
Sat, Mar 29, 2:44 AM
Unknown Object (File)
Feb 18 2025, 7:22 PM
Unknown Object (File)
Feb 18 2025, 7:22 PM
Unknown Object (File)
Feb 18 2025, 7:22 PM
View All 62 Files
Subscribers
ashoat
tomek

Details

Reviewers
bartek
Commits
rCOMM607b65279825: [native_rust_library] implement link_farcaster_account client method
Summary

client method which calls the LinkFarcasterAccount RPC. this is an auth RPC so we need the userID, deviceID, and CSAT

Depends on D11406

Test Plan

Later in the stack we call this rust client method from JS and successfully add a farcasterID to an existing user

Diff Detail

Repository
rCOMM Comm
Lint
No Lint Coverage
Unit
No Test Coverage

Revision Contents
Changeset List

PathSize
native/
native_rust_library/
src/
53 lines
13 lines

Diff 38385

View Options

native/native_rust_library/src/farcaster.rs

Show First 20 Lines • Show All 132 Lines • ▼ Show 20 Lines RUNTIME.spawn(async move {
return; return;
} }
trigger_backup_file_upload(); trigger_backup_file_upload();
// The promise will be resolved when the backup is uploaded // The promise will be resolved when the backup is uploaded
}); });
} }
pub fn retrieve_backup_keys( pub fn get_backup_user_keys(
user_identifier: String,
backup_secret: String, backup_secret: String,
backup_id: String, backup_id: String,
promise_id: u32, promise_id: u32,
) { ) {
RUNTIME.spawn(async move { RUNTIME.spawn(async move {
let result = download_backup_keys(backup_id, backup_secret) let result =
download_backup_keys(user_identifier, backup_secret, backup_id)
.await .await
.map_err(|err| err.to_string()); .map_err(|err| err.to_string());
let result = match result { let result = match result {
Ok(result) => result, Ok(result) => result,
Err(error) => { Err(error) => {
string_callback(error, promise_id, "".to_string()); string_callback(error, promise_id, "".to_string());
return; return;
} }
}; };
▲ Show 20 Lines • Show All 179 Lines • ▼ Show 20 Lines) -> Result<LatestBackupInfoResponse, Box<dyn Error>> {
Ok(LatestBackupInfoResponse { Ok(LatestBackupInfoResponse {
backup_id, backup_id,
user_id, user_id,
siwe_backup_msg, siwe_backup_msg,
}) })
} }
async fn download_backup_keys( async fn download_backup_keys(
backup_id: String, user_identifier: String,
backup_secret: String, backup_secret: String,
backup_id: String,
) -> Result<UserKeys, Box<dyn Error>> { ) -> Result<UserKeys, Box<dyn Error>> {
let backup_client = BackupClient::new(BACKUP_SOCKET_ADDR)?; let backup_client = BackupClient::new(BACKUP_SOCKET_ADDR)?;
let user_identity = get_user_identity_from_secure_store()?;
let backup_descriptor = BackupDescriptor::BackupID { let backup_descriptor = BackupDescriptor::Latest { user_identifier };
backup_id: backup_id.clone(),
user_identity: user_identity.clone(),
};
let mut encrypted_user_keys = backup_client let mut encrypted_user_keys = backup_client
.download_backup_data(&backup_descriptor, RequestedData::UserKeys) .download_backup_data(&backup_descriptor, RequestedData::UserKeys)
.await?; .await?;
let mut backup_key = compute_backup_key_str(&backup_secret, &backup_id)?; let mut backup_key = compute_backup_key_str(&backup_secret, &backup_id)?;
UserKeys::from_encrypted(&mut encrypted_user_keys, &mut backup_key) UserKeys::from_encrypted(&mut encrypted_user_keys, &mut backup_key)
} }
▲ Show 20 Lines • Show All 82 Lines • ▼ Show 20 Lines
} }
/// Stores the Olm account in `pickled_account`. However, Olm account /// Stores the Olm account in `pickled_account`. However, Olm account
/// information might be out of date. We have decided we don't need /// information might be out of date. We have decided we don't need
/// to update this when one-time keys (OTKs) or prekeys change. /// to update this when one-time keys (OTKs) or prekeys change.
/// The reasoning behind this decision is that the backed-up Olm account /// The reasoning behind this decision is that the backed-up Olm account
/// is primarily used for signing an update to the device list. For these /// is primarily used for signing an update to the device list. For these
/// operations only the identity signing key is necessary. /// operations only the identity signing key is necessary.
// This struct should match `UserKeys` in `lib/types/backup-types.js`
#[derive(Debug, Serialize, Deserialize)] #[derive(Debug, Serialize, Deserialize)]
#[serde(rename_all = "camelCase")]
struct UserKeys { struct UserKeys {
backup_data_key: String, backup_data_key: String,
backup_log_data_key: String, backup_log_data_key: String,
pickle_key: String, pickle_key: String,
pickled_account: String, pickled_account: String,
} }
impl UserKeys { impl UserKeys {
Show All 31 Lines
View Options

native/native_rust_library/src/lib.rs

Show First 20 Lines • Show All 132 Lines • ▼ Show 20 Lines RUNTIME.spawn(async move {
return; return;
} }
trigger_backup_file_upload(); trigger_backup_file_upload();
// The promise will be resolved when the backup is uploaded // The promise will be resolved when the backup is uploaded
}); });
} }
pub fn retrieve_backup_keys( pub fn get_backup_user_keys(
user_identifier: String,
backup_secret: String, backup_secret: String,
backup_id: String, backup_id: String,
promise_id: u32, promise_id: u32,
) { ) {
RUNTIME.spawn(async move { RUNTIME.spawn(async move {
let result = download_backup_keys(backup_id, backup_secret) let result =
download_backup_keys(user_identifier, backup_secret, backup_id)
.await .await
.map_err(|err| err.to_string()); .map_err(|err| err.to_string());
let result = match result { let result = match result {
Ok(result) => result, Ok(result) => result,
Err(error) => { Err(error) => {
string_callback(error, promise_id, "".to_string()); string_callback(error, promise_id, "".to_string());
return; return;
} }
}; };
▲ Show 20 Lines • Show All 179 Lines • ▼ Show 20 Lines) -> Result<LatestBackupInfoResponse, Box<dyn Error>> {
Ok(LatestBackupInfoResponse { Ok(LatestBackupInfoResponse {
backup_id, backup_id,
user_id, user_id,
siwe_backup_msg, siwe_backup_msg,
}) })
} }
async fn download_backup_keys( async fn download_backup_keys(
backup_id: String, user_identifier: String,
backup_secret: String, backup_secret: String,
backup_id: String,
) -> Result<UserKeys, Box<dyn Error>> { ) -> Result<UserKeys, Box<dyn Error>> {
let backup_client = BackupClient::new(BACKUP_SOCKET_ADDR)?; let backup_client = BackupClient::new(BACKUP_SOCKET_ADDR)?;
let user_identity = get_user_identity_from_secure_store()?;
let backup_descriptor = BackupDescriptor::BackupID { let backup_descriptor = BackupDescriptor::Latest { user_identifier };
backup_id: backup_id.clone(),
user_identity: user_identity.clone(),
};
let mut encrypted_user_keys = backup_client let mut encrypted_user_keys = backup_client
.download_backup_data(&backup_descriptor, RequestedData::UserKeys) .download_backup_data(&backup_descriptor, RequestedData::UserKeys)
.await?; .await?;
let mut backup_key = compute_backup_key_str(&backup_secret, &backup_id)?; let mut backup_key = compute_backup_key_str(&backup_secret, &backup_id)?;
UserKeys::from_encrypted(&mut encrypted_user_keys, &mut backup_key) UserKeys::from_encrypted(&mut encrypted_user_keys, &mut backup_key)
} }
▲ Show 20 Lines • Show All 82 Lines • ▼ Show 20 Lines
} }
/// Stores the Olm account in `pickled_account`. However, Olm account /// Stores the Olm account in `pickled_account`. However, Olm account
/// information might be out of date. We have decided we don't need /// information might be out of date. We have decided we don't need
/// to update this when one-time keys (OTKs) or prekeys change. /// to update this when one-time keys (OTKs) or prekeys change.
/// The reasoning behind this decision is that the backed-up Olm account /// The reasoning behind this decision is that the backed-up Olm account
/// is primarily used for signing an update to the device list. For these /// is primarily used for signing an update to the device list. For these
/// operations only the identity signing key is necessary. /// operations only the identity signing key is necessary.
// This struct should match `UserKeys` in `lib/types/backup-types.js`
#[derive(Debug, Serialize, Deserialize)] #[derive(Debug, Serialize, Deserialize)]
#[serde(rename_all = "camelCase")]
struct UserKeys { struct UserKeys {
backup_data_key: String, backup_data_key: String,
backup_log_data_key: String, backup_log_data_key: String,
pickle_key: String, pickle_key: String,
pickled_account: String, pickled_account: String,
} }
impl UserKeys { impl UserKeys {
Show All 31 Lines