Page MenuHomePhabricator
Differential D9022

[lib][native][web] Use connection from keyserverStore
ClosedPublic
Actions

Authored by inka on Aug 30 2023, 5:32 AM.
Tags
None
Referenced Files
Unknown Object (File)
Wed, Apr 2, 3:32 PM
Unknown Object (File)
Wed, Apr 2, 7:46 AM
Unknown Object (File)
Wed, Apr 2, 7:43 AM
Unknown Object (File)
Tue, Apr 1, 5:47 PM
Unknown Object (File)
Thu, Mar 27, 10:26 AM
Unknown Object (File)
Mar 13 2025, 1:31 PM
Unknown Object (File)
Mar 1 2025, 3:24 PM
Unknown Object (File)
Mar 1 2025, 3:24 PM
View All 90 Files
Subscribers
ashoat
tomek

Details

Reviewers
michal
kamil
Commits
rCOMMa1d0af4669e0: [lib][native][web] Use connection from keyserverStore
Summary

issue: https://linear.app/comm/issue/ENG-4460/refactor-connection-field
This diff is the same as D8931 apart from the fact that we no longer need to introduce any changes in reduceConnectionInfo

Test Plan

ran yarn flow-all. Checked that the app works, and the "Disconnected" bar is not present when app is connected, and is present when keyserver is down.

Diff Detail

Repository
rCOMM Comm
Branch
inka/connection
Lint
No Lint Coverage
Unit
No Test Coverage

Revision Contents
Changeset List

Diff 30545

View Options

lib/hooks/disconnected-bar.js

Show First 20 Lines • Show All 53 Lines • ▼ Show 20 Linespub enum WorkflowInProgress {
Update(UpdateState), Update(UpdateState),
} }
#[derive(Clone, Serialize, Deserialize)] #[derive(Clone, Serialize, Deserialize)]
pub struct UserRegistrationInfo { pub struct UserRegistrationInfo {
pub username: String, pub username: String,
pub flattened_device_key_upload: FlattenedDeviceKeyUpload, pub flattened_device_key_upload: FlattenedDeviceKeyUpload,
pub user_id: Option<String>, pub user_id: Option<String>,
pub farcaster_id: Option<String>,
} }
#[derive(Clone, Serialize, Deserialize)] #[derive(Clone, Serialize, Deserialize)]
pub struct UserLoginInfo { pub struct UserLoginInfo {
pub user_id: String, pub user_id: String,
pub flattened_device_key_upload: FlattenedDeviceKeyUpload, pub flattened_device_key_upload: FlattenedDeviceKeyUpload,
pub opaque_server_login: comm_opaque2::server::Login, pub opaque_server_login: comm_opaque2::server::Login,
pub device_to_remove: Option<String>, pub device_to_remove: Option<String>,
▲ Show 20 Lines • Show All 52 Lines • ▼ Show 20 Lines ) -> Result<tonic::Response<RegistrationStartResponse>, tonic::Status> {
if RESERVED_USERNAME_SET.contains(&message.username) { if RESERVED_USERNAME_SET.contains(&message.username) {
return Err(tonic::Status::invalid_argument("username reserved")); return Err(tonic::Status::invalid_argument("username reserved"));
} }
let registration_state = construct_user_registration_info( let registration_state = construct_user_registration_info(
&message, &message,
None, None,
message.username.clone(), message.username.clone(),
message.farcaster_id.clone(),
)?; )?;
let server_registration = comm_opaque2::server::Registration::new(); let server_registration = comm_opaque2::server::Registration::new();
let server_message = server_registration let server_message = server_registration
.start( .start(
&CONFIG.server_setup, &CONFIG.server_setup,
&message.opaque_registration_request, &message.opaque_registration_request,
message.username.as_bytes(), message.username.as_bytes(),
) )
Show All 38 Lines let user_id = validate_account_ownership_message_and_get_user_id(
&message.keyserver_message, &message.keyserver_message,
&message.keyserver_signature, &message.keyserver_signature,
)?; )?;
let registration_state = construct_user_registration_info( let registration_state = construct_user_registration_info(
&message, &message,
Some(user_id), Some(user_id),
message.username.clone(), message.username.clone(),
None,
)?; )?;
let server_registration = comm_opaque2::server::Registration::new(); let server_registration = comm_opaque2::server::Registration::new();
let server_message = server_registration let server_message = server_registration
.start( .start(
&CONFIG.server_setup, &CONFIG.server_setup,
&message.opaque_registration_request, &message.opaque_registration_request,
message.username.as_bytes(), message.username.as_bytes(),
) )
▲ Show 20 Lines • Show All 357 Lines • ▼ Show 20 Lines let user_id = self
.client .client
.add_wallet_user_to_users_table( .add_wallet_user_to_users_table(
flattened_device_key_upload.clone(), flattened_device_key_upload.clone(),
wallet_address, wallet_address,
serialized_social_proof, serialized_social_proof,
None, None,
code_version, code_version,
login_time, login_time,
message.farcaster_id,
) )
.await .await
.map_err(handle_db_error)?; .map_err(handle_db_error)?;
// Create access token // Create access token
let token = AccessTokenData::with_created_time( let token = AccessTokenData::with_created_time(
user_id.clone(), user_id.clone(),
flattened_device_key_upload.device_id_key, flattened_device_key_upload.device_id_key,
▲ Show 20 Lines • Show All 65 Lines • ▼ Show 20 Lines self
.client .client
.add_wallet_user_to_users_table( .add_wallet_user_to_users_table(
flattened_device_key_upload.clone(), flattened_device_key_upload.clone(),
wallet_address, wallet_address,
serialized_social_proof, serialized_social_proof,
Some(user_id.clone()), Some(user_id.clone()),
code_version, code_version,
login_time, login_time,
None,
) )
.await .await
.map_err(handle_db_error)?; .map_err(handle_db_error)?;
let token = AccessTokenData::with_created_time( let token = AccessTokenData::with_created_time(
user_id.clone(), user_id.clone(),
flattened_device_key_upload.device_id_key, flattened_device_key_upload.device_id_key,
login_time, login_time,
▲ Show 20 Lines • Show All 337 Lines • ▼ Show 20 Lines match db_error {
} }
} }
} }
fn construct_user_registration_info( fn construct_user_registration_info(
message: &impl DeviceKeyUploadActions, message: &impl DeviceKeyUploadActions,
user_id: Option<String>, user_id: Option<String>,
username: String, username: String,
farcaster_id: Option<String>,
) -> Result<UserRegistrationInfo, tonic::Status> { ) -> Result<UserRegistrationInfo, tonic::Status> {
Ok(UserRegistrationInfo { Ok(UserRegistrationInfo {
username, username,
flattened_device_key_upload: construct_flattened_device_key_upload( flattened_device_key_upload: construct_flattened_device_key_upload(
message, message,
)?, )?,
user_id, user_id,
farcaster_id,
}) })
} }
fn construct_user_login_info( fn construct_user_login_info(
user_id: String, user_id: String,
opaque_server_login: comm_opaque2::server::Login, opaque_server_login: comm_opaque2::server::Login,
flattened_device_key_upload: FlattenedDeviceKeyUpload, flattened_device_key_upload: FlattenedDeviceKeyUpload,
device_to_remove: Option<String>, device_to_remove: Option<String>,
▲ Show 20 Lines • Show All 43 Lines • Show Last 20 Lines
View Options

lib/reducers/master-reducer.js

Show First 20 Lines • Show All 53 Lines • ▼ Show 20 Linespub enum WorkflowInProgress {
Update(UpdateState), Update(UpdateState),
} }
#[derive(Clone, Serialize, Deserialize)] #[derive(Clone, Serialize, Deserialize)]
pub struct UserRegistrationInfo { pub struct UserRegistrationInfo {
pub username: String, pub username: String,
pub flattened_device_key_upload: FlattenedDeviceKeyUpload, pub flattened_device_key_upload: FlattenedDeviceKeyUpload,
pub user_id: Option<String>, pub user_id: Option<String>,
pub farcaster_id: Option<String>,
} }
#[derive(Clone, Serialize, Deserialize)] #[derive(Clone, Serialize, Deserialize)]
pub struct UserLoginInfo { pub struct UserLoginInfo {
pub user_id: String, pub user_id: String,
pub flattened_device_key_upload: FlattenedDeviceKeyUpload, pub flattened_device_key_upload: FlattenedDeviceKeyUpload,
pub opaque_server_login: comm_opaque2::server::Login, pub opaque_server_login: comm_opaque2::server::Login,
pub device_to_remove: Option<String>, pub device_to_remove: Option<String>,
▲ Show 20 Lines • Show All 52 Lines • ▼ Show 20 Lines ) -> Result<tonic::Response<RegistrationStartResponse>, tonic::Status> {
if RESERVED_USERNAME_SET.contains(&message.username) { if RESERVED_USERNAME_SET.contains(&message.username) {
return Err(tonic::Status::invalid_argument("username reserved")); return Err(tonic::Status::invalid_argument("username reserved"));
} }
let registration_state = construct_user_registration_info( let registration_state = construct_user_registration_info(
&message, &message,
None, None,
message.username.clone(), message.username.clone(),
message.farcaster_id.clone(),
)?; )?;
let server_registration = comm_opaque2::server::Registration::new(); let server_registration = comm_opaque2::server::Registration::new();
let server_message = server_registration let server_message = server_registration
.start( .start(
&CONFIG.server_setup, &CONFIG.server_setup,
&message.opaque_registration_request, &message.opaque_registration_request,
message.username.as_bytes(), message.username.as_bytes(),
) )
Show All 38 Lines let user_id = validate_account_ownership_message_and_get_user_id(
&message.keyserver_message, &message.keyserver_message,
&message.keyserver_signature, &message.keyserver_signature,
)?; )?;
let registration_state = construct_user_registration_info( let registration_state = construct_user_registration_info(
&message, &message,
Some(user_id), Some(user_id),
message.username.clone(), message.username.clone(),
None,
)?; )?;
let server_registration = comm_opaque2::server::Registration::new(); let server_registration = comm_opaque2::server::Registration::new();
let server_message = server_registration let server_message = server_registration
.start( .start(
&CONFIG.server_setup, &CONFIG.server_setup,
&message.opaque_registration_request, &message.opaque_registration_request,
message.username.as_bytes(), message.username.as_bytes(),
) )
▲ Show 20 Lines • Show All 357 Lines • ▼ Show 20 Lines let user_id = self
.client .client
.add_wallet_user_to_users_table( .add_wallet_user_to_users_table(
flattened_device_key_upload.clone(), flattened_device_key_upload.clone(),
wallet_address, wallet_address,
serialized_social_proof, serialized_social_proof,
None, None,
code_version, code_version,
login_time, login_time,
message.farcaster_id,
) )
.await .await
.map_err(handle_db_error)?; .map_err(handle_db_error)?;
// Create access token // Create access token
let token = AccessTokenData::with_created_time( let token = AccessTokenData::with_created_time(
user_id.clone(), user_id.clone(),
flattened_device_key_upload.device_id_key, flattened_device_key_upload.device_id_key,
▲ Show 20 Lines • Show All 65 Lines • ▼ Show 20 Lines self
.client .client
.add_wallet_user_to_users_table( .add_wallet_user_to_users_table(
flattened_device_key_upload.clone(), flattened_device_key_upload.clone(),
wallet_address, wallet_address,
serialized_social_proof, serialized_social_proof,
Some(user_id.clone()), Some(user_id.clone()),
code_version, code_version,
login_time, login_time,
None,
) )
.await .await
.map_err(handle_db_error)?; .map_err(handle_db_error)?;
let token = AccessTokenData::with_created_time( let token = AccessTokenData::with_created_time(
user_id.clone(), user_id.clone(),
flattened_device_key_upload.device_id_key, flattened_device_key_upload.device_id_key,
login_time, login_time,
▲ Show 20 Lines • Show All 337 Lines • ▼ Show 20 Lines match db_error {
} }
} }
} }
fn construct_user_registration_info( fn construct_user_registration_info(
message: &impl DeviceKeyUploadActions, message: &impl DeviceKeyUploadActions,
user_id: Option<String>, user_id: Option<String>,
username: String, username: String,
farcaster_id: Option<String>,
) -> Result<UserRegistrationInfo, tonic::Status> { ) -> Result<UserRegistrationInfo, tonic::Status> {
Ok(UserRegistrationInfo { Ok(UserRegistrationInfo {
username, username,
flattened_device_key_upload: construct_flattened_device_key_upload( flattened_device_key_upload: construct_flattened_device_key_upload(
message, message,
)?, )?,
user_id, user_id,
farcaster_id,
}) })
} }
fn construct_user_login_info( fn construct_user_login_info(
user_id: String, user_id: String,
opaque_server_login: comm_opaque2::server::Login, opaque_server_login: comm_opaque2::server::Login,
flattened_device_key_upload: FlattenedDeviceKeyUpload, flattened_device_key_upload: FlattenedDeviceKeyUpload,
device_to_remove: Option<String>, device_to_remove: Option<String>,
▲ Show 20 Lines • Show All 43 Lines • Show Last 20 Lines
View Options

lib/selectors/keyserver-selectors.js

Show First 20 Lines • Show All 53 Lines • ▼ Show 20 Linespub enum WorkflowInProgress {
Update(UpdateState), Update(UpdateState),
} }
#[derive(Clone, Serialize, Deserialize)] #[derive(Clone, Serialize, Deserialize)]
pub struct UserRegistrationInfo { pub struct UserRegistrationInfo {
pub username: String, pub username: String,
pub flattened_device_key_upload: FlattenedDeviceKeyUpload, pub flattened_device_key_upload: FlattenedDeviceKeyUpload,
pub user_id: Option<String>, pub user_id: Option<String>,
pub farcaster_id: Option<String>,
} }
#[derive(Clone, Serialize, Deserialize)] #[derive(Clone, Serialize, Deserialize)]
pub struct UserLoginInfo { pub struct UserLoginInfo {
pub user_id: String, pub user_id: String,
pub flattened_device_key_upload: FlattenedDeviceKeyUpload, pub flattened_device_key_upload: FlattenedDeviceKeyUpload,
pub opaque_server_login: comm_opaque2::server::Login, pub opaque_server_login: comm_opaque2::server::Login,
pub device_to_remove: Option<String>, pub device_to_remove: Option<String>,
▲ Show 20 Lines • Show All 52 Lines • ▼ Show 20 Lines ) -> Result<tonic::Response<RegistrationStartResponse>, tonic::Status> {
if RESERVED_USERNAME_SET.contains(&message.username) { if RESERVED_USERNAME_SET.contains(&message.username) {
return Err(tonic::Status::invalid_argument("username reserved")); return Err(tonic::Status::invalid_argument("username reserved"));
} }
let registration_state = construct_user_registration_info( let registration_state = construct_user_registration_info(
&message, &message,
None, None,
message.username.clone(), message.username.clone(),
message.farcaster_id.clone(),
)?; )?;
let server_registration = comm_opaque2::server::Registration::new(); let server_registration = comm_opaque2::server::Registration::new();
let server_message = server_registration let server_message = server_registration
.start( .start(
&CONFIG.server_setup, &CONFIG.server_setup,
&message.opaque_registration_request, &message.opaque_registration_request,
message.username.as_bytes(), message.username.as_bytes(),
) )
Show All 38 Lines let user_id = validate_account_ownership_message_and_get_user_id(
&message.keyserver_message, &message.keyserver_message,
&message.keyserver_signature, &message.keyserver_signature,
)?; )?;
let registration_state = construct_user_registration_info( let registration_state = construct_user_registration_info(
&message, &message,
Some(user_id), Some(user_id),
message.username.clone(), message.username.clone(),
None,
)?; )?;
let server_registration = comm_opaque2::server::Registration::new(); let server_registration = comm_opaque2::server::Registration::new();
let server_message = server_registration let server_message = server_registration
.start( .start(
&CONFIG.server_setup, &CONFIG.server_setup,
&message.opaque_registration_request, &message.opaque_registration_request,
message.username.as_bytes(), message.username.as_bytes(),
) )
▲ Show 20 Lines • Show All 357 Lines • ▼ Show 20 Lines let user_id = self
.client .client
.add_wallet_user_to_users_table( .add_wallet_user_to_users_table(
flattened_device_key_upload.clone(), flattened_device_key_upload.clone(),
wallet_address, wallet_address,
serialized_social_proof, serialized_social_proof,
None, None,
code_version, code_version,
login_time, login_time,
message.farcaster_id,
) )
.await .await
.map_err(handle_db_error)?; .map_err(handle_db_error)?;
// Create access token // Create access token
let token = AccessTokenData::with_created_time( let token = AccessTokenData::with_created_time(
user_id.clone(), user_id.clone(),
flattened_device_key_upload.device_id_key, flattened_device_key_upload.device_id_key,
▲ Show 20 Lines • Show All 65 Lines • ▼ Show 20 Lines self
.client .client
.add_wallet_user_to_users_table( .add_wallet_user_to_users_table(
flattened_device_key_upload.clone(), flattened_device_key_upload.clone(),
wallet_address, wallet_address,
serialized_social_proof, serialized_social_proof,
Some(user_id.clone()), Some(user_id.clone()),
code_version, code_version,
login_time, login_time,
None,
) )
.await .await
.map_err(handle_db_error)?; .map_err(handle_db_error)?;
let token = AccessTokenData::with_created_time( let token = AccessTokenData::with_created_time(
user_id.clone(), user_id.clone(),
flattened_device_key_upload.device_id_key, flattened_device_key_upload.device_id_key,
login_time, login_time,
▲ Show 20 Lines • Show All 337 Lines • ▼ Show 20 Lines match db_error {
} }
} }
} }
fn construct_user_registration_info( fn construct_user_registration_info(
message: &impl DeviceKeyUploadActions, message: &impl DeviceKeyUploadActions,
user_id: Option<String>, user_id: Option<String>,
username: String, username: String,
farcaster_id: Option<String>,
) -> Result<UserRegistrationInfo, tonic::Status> { ) -> Result<UserRegistrationInfo, tonic::Status> {
Ok(UserRegistrationInfo { Ok(UserRegistrationInfo {
username, username,
flattened_device_key_upload: construct_flattened_device_key_upload( flattened_device_key_upload: construct_flattened_device_key_upload(
message, message,
)?, )?,
user_id, user_id,
farcaster_id,
}) })
} }
fn construct_user_login_info( fn construct_user_login_info(
user_id: String, user_id: String,
opaque_server_login: comm_opaque2::server::Login, opaque_server_login: comm_opaque2::server::Login,
flattened_device_key_upload: FlattenedDeviceKeyUpload, flattened_device_key_upload: FlattenedDeviceKeyUpload,
device_to_remove: Option<String>, device_to_remove: Option<String>,
▲ Show 20 Lines • Show All 43 Lines • Show Last 20 Lines
View Options

lib/selectors/server-calls.js

Show First 20 Lines • Show All 53 Lines • ▼ Show 20 Linespub enum WorkflowInProgress {
Update(UpdateState), Update(UpdateState),
} }
#[derive(Clone, Serialize, Deserialize)] #[derive(Clone, Serialize, Deserialize)]
pub struct UserRegistrationInfo { pub struct UserRegistrationInfo {
pub username: String, pub username: String,
pub flattened_device_key_upload: FlattenedDeviceKeyUpload, pub flattened_device_key_upload: FlattenedDeviceKeyUpload,
pub user_id: Option<String>, pub user_id: Option<String>,
pub farcaster_id: Option<String>,
} }
#[derive(Clone, Serialize, Deserialize)] #[derive(Clone, Serialize, Deserialize)]
pub struct UserLoginInfo { pub struct UserLoginInfo {
pub user_id: String, pub user_id: String,
pub flattened_device_key_upload: FlattenedDeviceKeyUpload, pub flattened_device_key_upload: FlattenedDeviceKeyUpload,
pub opaque_server_login: comm_opaque2::server::Login, pub opaque_server_login: comm_opaque2::server::Login,
pub device_to_remove: Option<String>, pub device_to_remove: Option<String>,
▲ Show 20 Lines • Show All 52 Lines • ▼ Show 20 Lines ) -> Result<tonic::Response<RegistrationStartResponse>, tonic::Status> {
if RESERVED_USERNAME_SET.contains(&message.username) { if RESERVED_USERNAME_SET.contains(&message.username) {
return Err(tonic::Status::invalid_argument("username reserved")); return Err(tonic::Status::invalid_argument("username reserved"));
} }
let registration_state = construct_user_registration_info( let registration_state = construct_user_registration_info(
&message, &message,
None, None,
message.username.clone(), message.username.clone(),
message.farcaster_id.clone(),
)?; )?;
let server_registration = comm_opaque2::server::Registration::new(); let server_registration = comm_opaque2::server::Registration::new();
let server_message = server_registration let server_message = server_registration
.start( .start(
&CONFIG.server_setup, &CONFIG.server_setup,
&message.opaque_registration_request, &message.opaque_registration_request,
message.username.as_bytes(), message.username.as_bytes(),
) )
Show All 38 Lines let user_id = validate_account_ownership_message_and_get_user_id(
&message.keyserver_message, &message.keyserver_message,
&message.keyserver_signature, &message.keyserver_signature,
)?; )?;
let registration_state = construct_user_registration_info( let registration_state = construct_user_registration_info(
&message, &message,
Some(user_id), Some(user_id),
message.username.clone(), message.username.clone(),
None,
)?; )?;
let server_registration = comm_opaque2::server::Registration::new(); let server_registration = comm_opaque2::server::Registration::new();
let server_message = server_registration let server_message = server_registration
.start( .start(
&CONFIG.server_setup, &CONFIG.server_setup,
&message.opaque_registration_request, &message.opaque_registration_request,
message.username.as_bytes(), message.username.as_bytes(),
) )
▲ Show 20 Lines • Show All 357 Lines • ▼ Show 20 Lines let user_id = self
.client .client
.add_wallet_user_to_users_table( .add_wallet_user_to_users_table(
flattened_device_key_upload.clone(), flattened_device_key_upload.clone(),
wallet_address, wallet_address,
serialized_social_proof, serialized_social_proof,
None, None,
code_version, code_version,
login_time, login_time,
message.farcaster_id,
) )
.await .await
.map_err(handle_db_error)?; .map_err(handle_db_error)?;
// Create access token // Create access token
let token = AccessTokenData::with_created_time( let token = AccessTokenData::with_created_time(
user_id.clone(), user_id.clone(),
flattened_device_key_upload.device_id_key, flattened_device_key_upload.device_id_key,
▲ Show 20 Lines • Show All 65 Lines • ▼ Show 20 Lines self
.client .client
.add_wallet_user_to_users_table( .add_wallet_user_to_users_table(
flattened_device_key_upload.clone(), flattened_device_key_upload.clone(),
wallet_address, wallet_address,
serialized_social_proof, serialized_social_proof,
Some(user_id.clone()), Some(user_id.clone()),
code_version, code_version,
login_time, login_time,
None,
) )
.await .await
.map_err(handle_db_error)?; .map_err(handle_db_error)?;
let token = AccessTokenData::with_created_time( let token = AccessTokenData::with_created_time(
user_id.clone(), user_id.clone(),
flattened_device_key_upload.device_id_key, flattened_device_key_upload.device_id_key,
login_time, login_time,
▲ Show 20 Lines • Show All 337 Lines • ▼ Show 20 Lines match db_error {
} }
} }
} }
fn construct_user_registration_info( fn construct_user_registration_info(
message: &impl DeviceKeyUploadActions, message: &impl DeviceKeyUploadActions,
user_id: Option<String>, user_id: Option<String>,
username: String, username: String,
farcaster_id: Option<String>,
) -> Result<UserRegistrationInfo, tonic::Status> { ) -> Result<UserRegistrationInfo, tonic::Status> {
Ok(UserRegistrationInfo { Ok(UserRegistrationInfo {
username, username,
flattened_device_key_upload: construct_flattened_device_key_upload( flattened_device_key_upload: construct_flattened_device_key_upload(
message, message,
)?, )?,
user_id, user_id,
farcaster_id,
}) })
} }
fn construct_user_login_info( fn construct_user_login_info(
user_id: String, user_id: String,
opaque_server_login: comm_opaque2::server::Login, opaque_server_login: comm_opaque2::server::Login,
flattened_device_key_upload: FlattenedDeviceKeyUpload, flattened_device_key_upload: FlattenedDeviceKeyUpload,
device_to_remove: Option<String>, device_to_remove: Option<String>,
▲ Show 20 Lines • Show All 43 Lines • Show Last 20 Lines
View Options

lib/socket/activity-handler.react.js

Show First 20 Lines • Show All 53 Lines • ▼ Show 20 Linespub enum WorkflowInProgress {
Update(UpdateState), Update(UpdateState),
} }
#[derive(Clone, Serialize, Deserialize)] #[derive(Clone, Serialize, Deserialize)]
pub struct UserRegistrationInfo { pub struct UserRegistrationInfo {
pub username: String, pub username: String,
pub flattened_device_key_upload: FlattenedDeviceKeyUpload, pub flattened_device_key_upload: FlattenedDeviceKeyUpload,
pub user_id: Option<String>, pub user_id: Option<String>,
pub farcaster_id: Option<String>,
} }
#[derive(Clone, Serialize, Deserialize)] #[derive(Clone, Serialize, Deserialize)]
pub struct UserLoginInfo { pub struct UserLoginInfo {
pub user_id: String, pub user_id: String,
pub flattened_device_key_upload: FlattenedDeviceKeyUpload, pub flattened_device_key_upload: FlattenedDeviceKeyUpload,
pub opaque_server_login: comm_opaque2::server::Login, pub opaque_server_login: comm_opaque2::server::Login,
pub device_to_remove: Option<String>, pub device_to_remove: Option<String>,
▲ Show 20 Lines • Show All 52 Lines • ▼ Show 20 Lines ) -> Result<tonic::Response<RegistrationStartResponse>, tonic::Status> {
if RESERVED_USERNAME_SET.contains(&message.username) { if RESERVED_USERNAME_SET.contains(&message.username) {
return Err(tonic::Status::invalid_argument("username reserved")); return Err(tonic::Status::invalid_argument("username reserved"));
} }
let registration_state = construct_user_registration_info( let registration_state = construct_user_registration_info(
&message, &message,
None, None,
message.username.clone(), message.username.clone(),
message.farcaster_id.clone(),
)?; )?;
let server_registration = comm_opaque2::server::Registration::new(); let server_registration = comm_opaque2::server::Registration::new();
let server_message = server_registration let server_message = server_registration
.start( .start(
&CONFIG.server_setup, &CONFIG.server_setup,
&message.opaque_registration_request, &message.opaque_registration_request,
message.username.as_bytes(), message.username.as_bytes(),
) )
Show All 38 Lines let user_id = validate_account_ownership_message_and_get_user_id(
&message.keyserver_message, &message.keyserver_message,
&message.keyserver_signature, &message.keyserver_signature,
)?; )?;
let registration_state = construct_user_registration_info( let registration_state = construct_user_registration_info(
&message, &message,
Some(user_id), Some(user_id),
message.username.clone(), message.username.clone(),
None,
)?; )?;
let server_registration = comm_opaque2::server::Registration::new(); let server_registration = comm_opaque2::server::Registration::new();
let server_message = server_registration let server_message = server_registration
.start( .start(
&CONFIG.server_setup, &CONFIG.server_setup,
&message.opaque_registration_request, &message.opaque_registration_request,
message.username.as_bytes(), message.username.as_bytes(),
) )
▲ Show 20 Lines • Show All 357 Lines • ▼ Show 20 Lines let user_id = self
.client .client
.add_wallet_user_to_users_table( .add_wallet_user_to_users_table(
flattened_device_key_upload.clone(), flattened_device_key_upload.clone(),
wallet_address, wallet_address,
serialized_social_proof, serialized_social_proof,
None, None,
code_version, code_version,
login_time, login_time,
message.farcaster_id,
) )
.await .await
.map_err(handle_db_error)?; .map_err(handle_db_error)?;
// Create access token // Create access token
let token = AccessTokenData::with_created_time( let token = AccessTokenData::with_created_time(
user_id.clone(), user_id.clone(),
flattened_device_key_upload.device_id_key, flattened_device_key_upload.device_id_key,
▲ Show 20 Lines • Show All 65 Lines • ▼ Show 20 Lines self
.client .client
.add_wallet_user_to_users_table( .add_wallet_user_to_users_table(
flattened_device_key_upload.clone(), flattened_device_key_upload.clone(),
wallet_address, wallet_address,
serialized_social_proof, serialized_social_proof,
Some(user_id.clone()), Some(user_id.clone()),
code_version, code_version,
login_time, login_time,
None,
) )
.await .await
.map_err(handle_db_error)?; .map_err(handle_db_error)?;
let token = AccessTokenData::with_created_time( let token = AccessTokenData::with_created_time(
user_id.clone(), user_id.clone(),
flattened_device_key_upload.device_id_key, flattened_device_key_upload.device_id_key,
login_time, login_time,
▲ Show 20 Lines • Show All 337 Lines • ▼ Show 20 Lines match db_error {
} }
} }
} }
fn construct_user_registration_info( fn construct_user_registration_info(
message: &impl DeviceKeyUploadActions, message: &impl DeviceKeyUploadActions,
user_id: Option<String>, user_id: Option<String>,
username: String, username: String,
farcaster_id: Option<String>,
) -> Result<UserRegistrationInfo, tonic::Status> { ) -> Result<UserRegistrationInfo, tonic::Status> {
Ok(UserRegistrationInfo { Ok(UserRegistrationInfo {
username, username,
flattened_device_key_upload: construct_flattened_device_key_upload( flattened_device_key_upload: construct_flattened_device_key_upload(
message, message,
)?, )?,
user_id, user_id,
farcaster_id,
}) })
} }
fn construct_user_login_info( fn construct_user_login_info(
user_id: String, user_id: String,
opaque_server_login: comm_opaque2::server::Login, opaque_server_login: comm_opaque2::server::Login,
flattened_device_key_upload: FlattenedDeviceKeyUpload, flattened_device_key_upload: FlattenedDeviceKeyUpload,
device_to_remove: Option<String>, device_to_remove: Option<String>,
▲ Show 20 Lines • Show All 43 Lines • Show Last 20 Lines
View Options

lib/socket/api-request-handler.react.js

Loading...
View Options

lib/socket/calendar-query-handler.react.js

Loading...
View Options

lib/socket/request-response-handler.react.js

Loading...
View Options

lib/socket/update-handler.react.js

Loading...
View Options

lib/utils/action-utils.js

Loading...
View Options

native/calendar/calendar.react.js

Loading...
View Options

native/calendar/entry.react.js

Loading...
View Options

native/media/encrypted-image.react.js

Loading...
View Options

native/media/remote-image.react.js

Loading...
View Options

native/push/push-handler.react.js

Loading...
View Options

native/socket.react.js

Loading...
View Options

web/calendar/entry.react.js

Loading...
View Options

web/socket.react.js

Loading...