Page MenuHomePhabricator
Differential D12804

[native][web] Rename P2P messages methods
ClosedPublic
Actions

Authored by tomek on Jul 19 2024, 8:37 AM.
Tags
None
Referenced Files
Unknown Object (File)
Wed, Apr 9, 11:57 AM
Unknown Object (File)
Mon, Apr 7, 3:55 PM
Unknown Object (File)
Mon, Apr 7, 1:01 AM
Unknown Object (File)
Sun, Apr 6, 11:44 PM
Unknown Object (File)
Sun, Apr 6, 1:48 PM
Unknown Object (File)
Feb 26 2025, 6:03 AM
Unknown Object (File)
Feb 26 2025, 6:03 AM
Unknown Object (File)
Feb 26 2025, 6:01 AM
View All 62 Files
Subscribers
ashoat

Details

Reviewers
kamil
marcin
Commits
rCOMMed98e4a6ebd2: [native][web] Rename P2P messages methods
Summary

Their names were inconsistent.

Test Plan

Flow, build native app.

Diff Detail

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

Revision Contents
Changeset List

PathSize
lib/
tunnelbroker/
2 lines
types/
4 lines
utils/
__mocks__/
4 lines
native/
cpp/
CommonCpp/
NativeModules/
4 lines
4 lines
_generated/
database/
4 lines
schema/
4 lines
web/
database/
4 lines

Diff 42549

View Options

lib/tunnelbroker/peer-to-peer-context.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

lib/types/sqlite-types.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

lib/utils/__mocks__/config.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

native/cpp/CommonCpp/NativeModules/CommCoreModule.h

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

native/cpp/CommonCpp/NativeModules/CommCoreModule.cpp

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

native/cpp/CommonCpp/_generated/commJSI-generated.cpp

Loading...
View Options

native/cpp/CommonCpp/_generated/commJSI.h

Loading...
View Options

native/database/sqlite-api.js

Loading...
View Options

native/schema/CommCoreModuleSchema.js

Loading...
View Options

web/database/sqlite-api.js

Loading...