Page MenuHomePhabricator
Differential D9955

[web] refactor processing store ops to separate function
ClosedPublic
Actions

Authored by kamil on Nov 22 2023, 8:28 AM.
Tags
None
Referenced Files
Unknown Object (File)
Tue, Apr 1, 6:30 PM
Unknown Object (File)
Tue, Apr 1, 8:47 AM
Unknown Object (File)
Wed, Mar 19, 11:34 AM
Unknown Object (File)
Mon, Mar 17, 8:06 PM
Unknown Object (File)
Mon, Mar 17, 8:06 PM
Unknown Object (File)
Mon, Mar 17, 8:06 PM
Unknown Object (File)
Mon, Mar 17, 8:06 PM
Unknown Object (File)
Mon, Mar 17, 8:00 PM
View All Files
Subscribers
ashoat

Details

Reviewers
tomek
michal
Commits
rCOMMe0fc738fb7ca: [web] refactor processing store ops to separate function
Summary

Refactor to make code cleaner

Depends on D9954

Test Plan

Make sure processing ops still works

Diff Detail

Repository
rCOMM Comm
Branch
publish-web-persistence
Lint
No Lint Coverage
Unit
No Test Coverage

Revision Contents
Changeset List

PathSize
web/
database/
utils/
33 lines
redux/
38 lines

Diff 33515

View Options

web/database/utils/store.js

Show All 12 Lines
use lazy_static::lazy_static; use lazy_static::lazy_static;
use serde::Serialize; use serde::Serialize;
use std::sync::Arc; use std::sync::Arc;
use tokio::runtime::{Builder, Runtime}; use tokio::runtime::{Builder, Runtime};
use tonic::Status; use tonic::Status;
use tracing::instrument; use tracing::instrument;
mod argon2_tools; mod argon2_tools;
mod backup;
mod constants; mod constants;
use argon2_tools::compute_backup_key_str; use argon2_tools::compute_backup_key_str;
mod generated { mod generated {
// We get the CODE_VERSION from this generated file // We get the CODE_VERSION from this generated file
include!(concat!(env!("OUT_DIR"), "/version.rs")); include!(concat!(env!("OUT_DIR"), "/version.rs"));
} }
Show All 11 Lines Builder::new_multi_thread()
.worker_threads(1) .worker_threads(1)
.max_blocking_threads(1) .max_blocking_threads(1)
.enable_all() .enable_all()
.build() .build()
.unwrap() .unwrap()
); );
} }
use backup::ffi::*;
#[cxx::bridge] #[cxx::bridge]
mod ffi { mod ffi {
extern "Rust" { extern "Rust" {
#[cxx_name = "identityRegisterUser"] #[cxx_name = "identityRegisterUser"]
fn register_user( fn register_user(
username: String, username: String,
password: String, password: String,
▲ Show 20 Lines • Show All 117 Lines • ▼ Show 20 Lines unsafe extern "C++" {
#[allow(unused)] #[allow(unused)]
#[cxx_name = "aesDecrypt"] #[cxx_name = "aesDecrypt"]
fn decrypt( fn decrypt(
key: &mut [u8], key: &mut [u8],
sealed_data: &mut [u8], sealed_data: &mut [u8],
plaintext: &mut [u8], plaintext: &mut [u8],
) -> Result<()>; ) -> Result<()>;
} }
// Backup
extern "Rust" {
#[cxx_name = "createBackup"]
fn create_backup_sync(
backup_id: String,
backup_secret: String,
pickle_key: String,
pickled_account: String,
user_data: String,
promise_id: u32,
);
#[cxx_name = "restoreBackup"]
fn restore_backup_sync(
backup_id: String,
backup_secret: String,
encrypted_user_keys: String,
encrypted_user_data: String,
promise_id: u32,
);
}
} }
fn handle_string_result_as_callback<E>( fn handle_string_result_as_callback<E>(
result: Result<String, E>, result: Result<String, E>,
promise_id: u32, promise_id: u32,
) where ) where
E: std::fmt::Display, E: std::fmt::Display,
{ {
▲ Show 20 Lines • Show All 634 Lines • Show Last 20 Lines
View Options

web/redux/redux-setup.js

Show All 12 Lines
use lazy_static::lazy_static; use lazy_static::lazy_static;
use serde::Serialize; use serde::Serialize;
use std::sync::Arc; use std::sync::Arc;
use tokio::runtime::{Builder, Runtime}; use tokio::runtime::{Builder, Runtime};
use tonic::Status; use tonic::Status;
use tracing::instrument; use tracing::instrument;
mod argon2_tools; mod argon2_tools;
mod backup;
mod constants; mod constants;
use argon2_tools::compute_backup_key_str; use argon2_tools::compute_backup_key_str;
mod generated { mod generated {
// We get the CODE_VERSION from this generated file // We get the CODE_VERSION from this generated file
include!(concat!(env!("OUT_DIR"), "/version.rs")); include!(concat!(env!("OUT_DIR"), "/version.rs"));
} }
Show All 11 Lines Builder::new_multi_thread()
.worker_threads(1) .worker_threads(1)
.max_blocking_threads(1) .max_blocking_threads(1)
.enable_all() .enable_all()
.build() .build()
.unwrap() .unwrap()
); );
} }
use backup::ffi::*;
#[cxx::bridge] #[cxx::bridge]
mod ffi { mod ffi {
extern "Rust" { extern "Rust" {
#[cxx_name = "identityRegisterUser"] #[cxx_name = "identityRegisterUser"]
fn register_user( fn register_user(
username: String, username: String,
password: String, password: String,
▲ Show 20 Lines • Show All 117 Lines • ▼ Show 20 Lines unsafe extern "C++" {
#[allow(unused)] #[allow(unused)]
#[cxx_name = "aesDecrypt"] #[cxx_name = "aesDecrypt"]
fn decrypt( fn decrypt(
key: &mut [u8], key: &mut [u8],
sealed_data: &mut [u8], sealed_data: &mut [u8],
plaintext: &mut [u8], plaintext: &mut [u8],
) -> Result<()>; ) -> Result<()>;
} }
// Backup
extern "Rust" {
#[cxx_name = "createBackup"]
fn create_backup_sync(
backup_id: String,
backup_secret: String,
pickle_key: String,
pickled_account: String,
user_data: String,
promise_id: u32,
);
#[cxx_name = "restoreBackup"]
fn restore_backup_sync(
backup_id: String,
backup_secret: String,
encrypted_user_keys: String,
encrypted_user_data: String,
promise_id: u32,
);
}
} }
fn handle_string_result_as_callback<E>( fn handle_string_result_as_callback<E>(
result: Result<String, E>, result: Result<String, E>,
promise_id: u32, promise_id: u32,
) where ) where
E: std::fmt::Display, E: std::fmt::Display,
{ {
▲ Show 20 Lines • Show All 634 Lines • Show Last 20 Lines