mirror of
https://github.com/twonlyapp/twonly-app.git
synced 2026-05-25 11:32:13 +00:00
1938 lines
93 KiB
Rust
1938 lines
93 KiB
Rust
// This file is automatically generated, so please do not edit it.
|
|
// @generated by `flutter_rust_bridge`@ 2.12.0.
|
|
|
|
#![allow(
|
|
non_camel_case_types,
|
|
unused,
|
|
non_snake_case,
|
|
clippy::needless_return,
|
|
clippy::redundant_closure_call,
|
|
clippy::redundant_closure,
|
|
clippy::useless_conversion,
|
|
clippy::unit_arg,
|
|
clippy::unused_unit,
|
|
clippy::double_parens,
|
|
clippy::let_and_return,
|
|
clippy::too_many_arguments,
|
|
clippy::match_single_binding,
|
|
clippy::clone_on_copy,
|
|
clippy::let_unit_value,
|
|
clippy::deref_addrof,
|
|
clippy::explicit_auto_deref,
|
|
clippy::borrow_deref_ref,
|
|
clippy::uninlined_format_args,
|
|
clippy::needless_borrow
|
|
)]
|
|
|
|
// Section: imports
|
|
|
|
use flutter_rust_bridge::for_generated::byteorder::{NativeEndian, ReadBytesExt, WriteBytesExt};
|
|
use flutter_rust_bridge::for_generated::{transform_result_dco, Lifetimeable, Lockable};
|
|
use flutter_rust_bridge::{Handler, IntoIntoDart};
|
|
|
|
// Section: boilerplate
|
|
|
|
flutter_rust_bridge::frb_generated_boilerplate!(
|
|
default_stream_sink_codec = SseCodec,
|
|
default_rust_opaque = RustOpaqueMoi,
|
|
default_rust_auto_opaque = RustAutoOpaqueMoi,
|
|
);
|
|
pub(crate) const FLUTTER_RUST_BRIDGE_CODEGEN_VERSION: &str = "2.12.0";
|
|
pub(crate) const FLUTTER_RUST_BRIDGE_CODEGEN_CONTENT_HASH: i32 = -1867463121;
|
|
|
|
// Section: executor
|
|
|
|
flutter_rust_bridge::frb_generated_default_handler!();
|
|
|
|
// Section: wire_funcs
|
|
|
|
fn wire__crate__bridge__wrapper__user_discovery__flutter_user_discovery_get_current_version_impl(
|
|
port_: flutter_rust_bridge::for_generated::MessagePort,
|
|
ptr_: flutter_rust_bridge::for_generated::PlatformGeneralizedUint8ListPtr,
|
|
rust_vec_len_: i32,
|
|
data_len_: i32,
|
|
) {
|
|
FLUTTER_RUST_BRIDGE_HANDLER.wrap_async::<flutter_rust_bridge::for_generated::SseCodec,_,_,_>(flutter_rust_bridge::for_generated::TaskInfo{ debug_name: "flutter_user_discovery_get_current_version", port: Some(port_), mode: flutter_rust_bridge::for_generated::FfiCallMode::Normal }, move || {
|
|
let message = unsafe { flutter_rust_bridge::for_generated::Dart2RustMessageSse::from_wire(ptr_, rust_vec_len_, data_len_) };
|
|
let mut deserializer = flutter_rust_bridge::for_generated::SseDeserializer::new(message);
|
|
deserializer.end(); move |context| async move {
|
|
transform_result_sse::<_, flutter_rust_bridge::for_generated::anyhow::Error>((move || async move {
|
|
let output_ok = crate::bridge::wrapper::user_discovery::FlutterUserDiscovery::get_current_version().await?; Ok(output_ok)
|
|
})().await)
|
|
} })
|
|
}
|
|
fn wire__crate__bridge__wrapper__user_discovery__flutter_user_discovery_get_new_messages_impl(
|
|
port_: flutter_rust_bridge::for_generated::MessagePort,
|
|
ptr_: flutter_rust_bridge::for_generated::PlatformGeneralizedUint8ListPtr,
|
|
rust_vec_len_: i32,
|
|
data_len_: i32,
|
|
) {
|
|
FLUTTER_RUST_BRIDGE_HANDLER.wrap_async::<flutter_rust_bridge::for_generated::SseCodec,_,_,_>(flutter_rust_bridge::for_generated::TaskInfo{ debug_name: "flutter_user_discovery_get_new_messages", port: Some(port_), mode: flutter_rust_bridge::for_generated::FfiCallMode::Normal }, move || {
|
|
let message = unsafe { flutter_rust_bridge::for_generated::Dart2RustMessageSse::from_wire(ptr_, rust_vec_len_, data_len_) };
|
|
let mut deserializer = flutter_rust_bridge::for_generated::SseDeserializer::new(message);
|
|
let api_contact_id = <i64>::sse_decode(&mut deserializer);
|
|
let api_received_version = <Vec<u8>>::sse_decode(&mut deserializer);deserializer.end(); move |context| async move {
|
|
transform_result_sse::<_, flutter_rust_bridge::for_generated::anyhow::Error>((move || async move {
|
|
let output_ok = crate::bridge::wrapper::user_discovery::FlutterUserDiscovery::get_new_messages(api_contact_id, &api_received_version).await?; Ok(output_ok)
|
|
})().await)
|
|
} })
|
|
}
|
|
fn wire__crate__bridge__wrapper__user_discovery__flutter_user_discovery_handle_new_messages_impl(
|
|
port_: flutter_rust_bridge::for_generated::MessagePort,
|
|
ptr_: flutter_rust_bridge::for_generated::PlatformGeneralizedUint8ListPtr,
|
|
rust_vec_len_: i32,
|
|
data_len_: i32,
|
|
) {
|
|
FLUTTER_RUST_BRIDGE_HANDLER.wrap_async::<flutter_rust_bridge::for_generated::SseCodec,_,_,_>(flutter_rust_bridge::for_generated::TaskInfo{ debug_name: "flutter_user_discovery_handle_new_messages", port: Some(port_), mode: flutter_rust_bridge::for_generated::FfiCallMode::Normal }, move || {
|
|
let message = unsafe { flutter_rust_bridge::for_generated::Dart2RustMessageSse::from_wire(ptr_, rust_vec_len_, data_len_) };
|
|
let mut deserializer = flutter_rust_bridge::for_generated::SseDeserializer::new(message);
|
|
let api_contact_id = <i64>::sse_decode(&mut deserializer);
|
|
let api_public_key_verified_timestamp = <Option<i64>>::sse_decode(&mut deserializer);
|
|
let api_messages = <Vec<Vec<u8>>>::sse_decode(&mut deserializer);deserializer.end(); move |context| async move {
|
|
transform_result_sse::<_, flutter_rust_bridge::for_generated::anyhow::Error>((move || async move {
|
|
let output_ok = crate::bridge::wrapper::user_discovery::FlutterUserDiscovery::handle_new_messages(api_contact_id, api_public_key_verified_timestamp, api_messages).await?; Ok(output_ok)
|
|
})().await)
|
|
} })
|
|
}
|
|
fn wire__crate__bridge__wrapper__user_discovery__flutter_user_discovery_initialize_or_update_impl(
|
|
port_: flutter_rust_bridge::for_generated::MessagePort,
|
|
ptr_: flutter_rust_bridge::for_generated::PlatformGeneralizedUint8ListPtr,
|
|
rust_vec_len_: i32,
|
|
data_len_: i32,
|
|
) {
|
|
FLUTTER_RUST_BRIDGE_HANDLER.wrap_async::<flutter_rust_bridge::for_generated::SseCodec,_,_,_>(flutter_rust_bridge::for_generated::TaskInfo{ debug_name: "flutter_user_discovery_initialize_or_update", port: Some(port_), mode: flutter_rust_bridge::for_generated::FfiCallMode::Normal }, move || {
|
|
let message = unsafe { flutter_rust_bridge::for_generated::Dart2RustMessageSse::from_wire(ptr_, rust_vec_len_, data_len_) };
|
|
let mut deserializer = flutter_rust_bridge::for_generated::SseDeserializer::new(message);
|
|
let api_threshold = <u8>::sse_decode(&mut deserializer);
|
|
let api_user_id = <i64>::sse_decode(&mut deserializer);
|
|
let api_public_key = <Vec<u8>>::sse_decode(&mut deserializer);
|
|
let api_share_promotion = <bool>::sse_decode(&mut deserializer);deserializer.end(); move |context| async move {
|
|
transform_result_sse::<_, flutter_rust_bridge::for_generated::anyhow::Error>((move || async move {
|
|
let output_ok = crate::bridge::wrapper::user_discovery::FlutterUserDiscovery::initialize_or_update(api_threshold, api_user_id, api_public_key, api_share_promotion).await?; Ok(output_ok)
|
|
})().await)
|
|
} })
|
|
}
|
|
fn wire__crate__bridge__wrapper__user_discovery__flutter_user_discovery_should_request_new_messages_impl(
|
|
port_: flutter_rust_bridge::for_generated::MessagePort,
|
|
ptr_: flutter_rust_bridge::for_generated::PlatformGeneralizedUint8ListPtr,
|
|
rust_vec_len_: i32,
|
|
data_len_: i32,
|
|
) {
|
|
FLUTTER_RUST_BRIDGE_HANDLER.wrap_async::<flutter_rust_bridge::for_generated::SseCodec,_,_,_>(flutter_rust_bridge::for_generated::TaskInfo{ debug_name: "flutter_user_discovery_should_request_new_messages", port: Some(port_), mode: flutter_rust_bridge::for_generated::FfiCallMode::Normal }, move || {
|
|
let message = unsafe { flutter_rust_bridge::for_generated::Dart2RustMessageSse::from_wire(ptr_, rust_vec_len_, data_len_) };
|
|
let mut deserializer = flutter_rust_bridge::for_generated::SseDeserializer::new(message);
|
|
let api_contact_id = <i64>::sse_decode(&mut deserializer);
|
|
let api_version = <Vec<u8>>::sse_decode(&mut deserializer);deserializer.end(); move |context| async move {
|
|
transform_result_sse::<_, flutter_rust_bridge::for_generated::anyhow::Error>((move || async move {
|
|
let output_ok = crate::bridge::wrapper::user_discovery::FlutterUserDiscovery::should_request_new_messages(api_contact_id, &api_version).await?; Ok(output_ok)
|
|
})().await)
|
|
} })
|
|
}
|
|
fn wire__crate__bridge__wrapper__user_discovery__flutter_user_discovery_update_verification_state_for_user_impl(
|
|
port_: flutter_rust_bridge::for_generated::MessagePort,
|
|
ptr_: flutter_rust_bridge::for_generated::PlatformGeneralizedUint8ListPtr,
|
|
rust_vec_len_: i32,
|
|
data_len_: i32,
|
|
) {
|
|
FLUTTER_RUST_BRIDGE_HANDLER.wrap_async::<flutter_rust_bridge::for_generated::SseCodec,_,_,_>(flutter_rust_bridge::for_generated::TaskInfo{ debug_name: "flutter_user_discovery_update_verification_state_for_user", port: Some(port_), mode: flutter_rust_bridge::for_generated::FfiCallMode::Normal }, move || {
|
|
let message = unsafe { flutter_rust_bridge::for_generated::Dart2RustMessageSse::from_wire(ptr_, rust_vec_len_, data_len_) };
|
|
let mut deserializer = flutter_rust_bridge::for_generated::SseDeserializer::new(message);
|
|
let api_contact_id = <i64>::sse_decode(&mut deserializer);
|
|
let api_public_key_verified_timestamp = <Option<i64>>::sse_decode(&mut deserializer);deserializer.end(); move |context| async move {
|
|
transform_result_sse::<_, flutter_rust_bridge::for_generated::anyhow::Error>((move || async move {
|
|
let output_ok = crate::bridge::wrapper::user_discovery::FlutterUserDiscovery::update_verification_state_for_user(api_contact_id, api_public_key_verified_timestamp).await?; Ok(output_ok)
|
|
})().await)
|
|
} })
|
|
}
|
|
fn wire__crate__bridge__callbacks__init_flutter_callbacks_impl(
|
|
port_: flutter_rust_bridge::for_generated::MessagePort,
|
|
ptr_: flutter_rust_bridge::for_generated::PlatformGeneralizedUint8ListPtr,
|
|
rust_vec_len_: i32,
|
|
data_len_: i32,
|
|
) {
|
|
FLUTTER_RUST_BRIDGE_HANDLER.wrap_normal::<flutter_rust_bridge::for_generated::SseCodec,_,_>(flutter_rust_bridge::for_generated::TaskInfo{ debug_name: "init_flutter_callbacks", port: Some(port_), mode: flutter_rust_bridge::for_generated::FfiCallMode::Normal }, move || {
|
|
let message = unsafe { flutter_rust_bridge::for_generated::Dart2RustMessageSse::from_wire(ptr_, rust_vec_len_, data_len_) };
|
|
let mut deserializer = flutter_rust_bridge::for_generated::SseDeserializer::new(message);
|
|
let api_logging_get_stream_sink = decode_DartFn_Inputs__Output_StreamSink_String_Sse_AnyhowException(<flutter_rust_bridge::DartOpaque>::sse_decode(&mut deserializer));
|
|
let api_user_discovery_sign_data = decode_DartFn_Inputs_list_prim_u_8_strict_Output_opt_list_prim_u_8_strict_AnyhowException(<flutter_rust_bridge::DartOpaque>::sse_decode(&mut deserializer));
|
|
let api_user_discovery_verify_signature = decode_DartFn_Inputs_list_prim_u_8_strict_list_prim_u_8_strict_list_prim_u_8_strict_Output_bool_AnyhowException(<flutter_rust_bridge::DartOpaque>::sse_decode(&mut deserializer));
|
|
let api_user_discovery_verify_stored_pubkey = decode_DartFn_Inputs_i_64_list_prim_u_8_strict_Output_bool_AnyhowException(<flutter_rust_bridge::DartOpaque>::sse_decode(&mut deserializer));
|
|
let api_user_discovery_set_shares = decode_DartFn_Inputs_list_list_prim_u_8_strict_Output_bool_AnyhowException(<flutter_rust_bridge::DartOpaque>::sse_decode(&mut deserializer));
|
|
let api_user_discovery_get_share_for_contact = decode_DartFn_Inputs_i_64_Output_opt_list_prim_u_8_strict_AnyhowException(<flutter_rust_bridge::DartOpaque>::sse_decode(&mut deserializer));
|
|
let api_user_discovery_push_own_promotion_and_clear_old_version = decode_DartFn_Inputs_i_64_i_64_list_prim_u_8_strict_Output_bool_AnyhowException(<flutter_rust_bridge::DartOpaque>::sse_decode(&mut deserializer));
|
|
let api_user_discovery_get_own_promotions_after_version = decode_DartFn_Inputs_i_64_Output_opt_list_list_prim_u_8_strict_AnyhowException(<flutter_rust_bridge::DartOpaque>::sse_decode(&mut deserializer));
|
|
let api_user_discovery_store_other_promotion = decode_DartFn_Inputs_other_promotion_Output_bool_AnyhowException(<flutter_rust_bridge::DartOpaque>::sse_decode(&mut deserializer));
|
|
let api_user_discovery_get_other_promotions_by_public_id = decode_DartFn_Inputs_i_64_Output_opt_list_other_promotion_AnyhowException(<flutter_rust_bridge::DartOpaque>::sse_decode(&mut deserializer));
|
|
let api_user_discovery_get_announced_user_by_public_id = decode_DartFn_Inputs_i_64_Output_opt_box_autoadd_announced_user_AnyhowException(<flutter_rust_bridge::DartOpaque>::sse_decode(&mut deserializer));
|
|
let api_user_discovery_get_contact_version = decode_DartFn_Inputs_i_64_Output_opt_list_prim_u_8_strict_AnyhowException(<flutter_rust_bridge::DartOpaque>::sse_decode(&mut deserializer));
|
|
let api_user_discovery_set_contact_version = decode_DartFn_Inputs_i_64_list_prim_u_8_strict_Output_bool_AnyhowException(<flutter_rust_bridge::DartOpaque>::sse_decode(&mut deserializer));
|
|
let api_user_discovery_push_new_user_relation = decode_DartFn_Inputs_i_64_announced_user_opt_box_autoadd_i_64_Output_bool_AnyhowException(<flutter_rust_bridge::DartOpaque>::sse_decode(&mut deserializer));
|
|
let api_user_discovery_get_contact_promotion = decode_DartFn_Inputs_i_64_Output_opt_list_prim_u_8_strict_AnyhowException(<flutter_rust_bridge::DartOpaque>::sse_decode(&mut deserializer));deserializer.end(); move |context| {
|
|
transform_result_sse::<_, ()>((move || {
|
|
let output_ok = Result::<_,()>::Ok({ crate::bridge::callbacks::init_flutter_callbacks(api_logging_get_stream_sink, api_user_discovery_sign_data, api_user_discovery_verify_signature, api_user_discovery_verify_stored_pubkey, api_user_discovery_set_shares, api_user_discovery_get_share_for_contact, api_user_discovery_push_own_promotion_and_clear_old_version, api_user_discovery_get_own_promotions_after_version, api_user_discovery_store_other_promotion, api_user_discovery_get_other_promotions_by_public_id, api_user_discovery_get_announced_user_by_public_id, api_user_discovery_get_contact_version, api_user_discovery_set_contact_version, api_user_discovery_push_new_user_relation, api_user_discovery_get_contact_promotion); })?; Ok(output_ok)
|
|
})())
|
|
} })
|
|
}
|
|
fn wire__crate__bridge__initialize_twonly_flutter_impl(
|
|
port_: flutter_rust_bridge::for_generated::MessagePort,
|
|
ptr_: flutter_rust_bridge::for_generated::PlatformGeneralizedUint8ListPtr,
|
|
rust_vec_len_: i32,
|
|
data_len_: i32,
|
|
) {
|
|
FLUTTER_RUST_BRIDGE_HANDLER.wrap_async::<flutter_rust_bridge::for_generated::SseCodec, _, _, _>(
|
|
flutter_rust_bridge::for_generated::TaskInfo {
|
|
debug_name: "initialize_twonly_flutter",
|
|
port: Some(port_),
|
|
mode: flutter_rust_bridge::for_generated::FfiCallMode::Normal,
|
|
},
|
|
move || {
|
|
let message = unsafe {
|
|
flutter_rust_bridge::for_generated::Dart2RustMessageSse::from_wire(
|
|
ptr_,
|
|
rust_vec_len_,
|
|
data_len_,
|
|
)
|
|
};
|
|
let mut deserializer =
|
|
flutter_rust_bridge::for_generated::SseDeserializer::new(message);
|
|
let api_config = <crate::bridge::InitConfig>::sse_decode(&mut deserializer);
|
|
deserializer.end();
|
|
move |context| async move {
|
|
transform_result_sse::<_, flutter_rust_bridge::for_generated::anyhow::Error>(
|
|
(move || async move {
|
|
let output_ok =
|
|
crate::bridge::initialize_twonly_flutter(api_config).await?;
|
|
Ok(output_ok)
|
|
})()
|
|
.await,
|
|
)
|
|
}
|
|
},
|
|
)
|
|
}
|
|
fn wire__crate__bridge__wrapper__backup__rust_backup_archive_create_backup_archive_impl(
|
|
port_: flutter_rust_bridge::for_generated::MessagePort,
|
|
ptr_: flutter_rust_bridge::for_generated::PlatformGeneralizedUint8ListPtr,
|
|
rust_vec_len_: i32,
|
|
data_len_: i32,
|
|
) {
|
|
FLUTTER_RUST_BRIDGE_HANDLER.wrap_async::<flutter_rust_bridge::for_generated::SseCodec,_,_,_>(flutter_rust_bridge::for_generated::TaskInfo{ debug_name: "rust_backup_archive_create_backup_archive", port: Some(port_), mode: flutter_rust_bridge::for_generated::FfiCallMode::Normal }, move || {
|
|
let message = unsafe { flutter_rust_bridge::for_generated::Dart2RustMessageSse::from_wire(ptr_, rust_vec_len_, data_len_) };
|
|
let mut deserializer = flutter_rust_bridge::for_generated::SseDeserializer::new(message);
|
|
deserializer.end(); move |context| async move {
|
|
transform_result_sse::<_, flutter_rust_bridge::for_generated::anyhow::Error>((move || async move {
|
|
let output_ok = crate::bridge::wrapper::backup::RustBackupArchive::create_backup_archive().await?; Ok(output_ok)
|
|
})().await)
|
|
} })
|
|
}
|
|
fn wire__crate__bridge__wrapper__backup__rust_backup_archive_get_backup_download_token_impl(
|
|
port_: flutter_rust_bridge::for_generated::MessagePort,
|
|
ptr_: flutter_rust_bridge::for_generated::PlatformGeneralizedUint8ListPtr,
|
|
rust_vec_len_: i32,
|
|
data_len_: i32,
|
|
) {
|
|
FLUTTER_RUST_BRIDGE_HANDLER.wrap_async::<flutter_rust_bridge::for_generated::SseCodec,_,_,_>(flutter_rust_bridge::for_generated::TaskInfo{ debug_name: "rust_backup_archive_get_backup_download_token", port: Some(port_), mode: flutter_rust_bridge::for_generated::FfiCallMode::Normal }, move || {
|
|
let message = unsafe { flutter_rust_bridge::for_generated::Dart2RustMessageSse::from_wire(ptr_, rust_vec_len_, data_len_) };
|
|
let mut deserializer = flutter_rust_bridge::for_generated::SseDeserializer::new(message);
|
|
deserializer.end(); move |context| async move {
|
|
transform_result_sse::<_, ()>((move || async move {
|
|
let output_ok = Result::<_,()>::Ok(crate::bridge::wrapper::backup::RustBackupArchive::get_backup_download_token().await)?; Ok(output_ok)
|
|
})().await)
|
|
} })
|
|
}
|
|
fn wire__crate__bridge__wrapper__backup__rust_backup_archive_restore_backup_archive_impl(
|
|
port_: flutter_rust_bridge::for_generated::MessagePort,
|
|
ptr_: flutter_rust_bridge::for_generated::PlatformGeneralizedUint8ListPtr,
|
|
rust_vec_len_: i32,
|
|
data_len_: i32,
|
|
) {
|
|
FLUTTER_RUST_BRIDGE_HANDLER.wrap_async::<flutter_rust_bridge::for_generated::SseCodec,_,_,_>(flutter_rust_bridge::for_generated::TaskInfo{ debug_name: "rust_backup_archive_restore_backup_archive", port: Some(port_), mode: flutter_rust_bridge::for_generated::FfiCallMode::Normal }, move || {
|
|
let message = unsafe { flutter_rust_bridge::for_generated::Dart2RustMessageSse::from_wire(ptr_, rust_vec_len_, data_len_) };
|
|
let mut deserializer = flutter_rust_bridge::for_generated::SseDeserializer::new(message);
|
|
let api_file_path = <String>::sse_decode(&mut deserializer);deserializer.end(); move |context| async move {
|
|
transform_result_sse::<_, flutter_rust_bridge::for_generated::anyhow::Error>((move || async move {
|
|
let output_ok = crate::bridge::wrapper::backup::RustBackupArchive::restore_backup_archive(api_file_path).await?; Ok(output_ok)
|
|
})().await)
|
|
} })
|
|
}
|
|
fn wire__crate__bridge__wrapper__backup__rust_backup_identity_get_backup_id_impl(
|
|
port_: flutter_rust_bridge::for_generated::MessagePort,
|
|
ptr_: flutter_rust_bridge::for_generated::PlatformGeneralizedUint8ListPtr,
|
|
rust_vec_len_: i32,
|
|
data_len_: i32,
|
|
) {
|
|
FLUTTER_RUST_BRIDGE_HANDLER.wrap_async::<flutter_rust_bridge::for_generated::SseCodec, _, _, _>(
|
|
flutter_rust_bridge::for_generated::TaskInfo {
|
|
debug_name: "rust_backup_identity_get_backup_id",
|
|
port: Some(port_),
|
|
mode: flutter_rust_bridge::for_generated::FfiCallMode::Normal,
|
|
},
|
|
move || {
|
|
let message = unsafe {
|
|
flutter_rust_bridge::for_generated::Dart2RustMessageSse::from_wire(
|
|
ptr_,
|
|
rust_vec_len_,
|
|
data_len_,
|
|
)
|
|
};
|
|
let mut deserializer =
|
|
flutter_rust_bridge::for_generated::SseDeserializer::new(message);
|
|
deserializer.end();
|
|
move |context| async move {
|
|
transform_result_sse::<_, ()>(
|
|
(move || async move {
|
|
let output_ok = Result::<_, ()>::Ok(
|
|
crate::bridge::wrapper::backup::RustBackupIdentity::get_backup_id()
|
|
.await,
|
|
)?;
|
|
Ok(output_ok)
|
|
})()
|
|
.await,
|
|
)
|
|
}
|
|
},
|
|
)
|
|
}
|
|
fn wire__crate__bridge__wrapper__backup__rust_backup_identity_get_backup_password_keys_impl(
|
|
port_: flutter_rust_bridge::for_generated::MessagePort,
|
|
ptr_: flutter_rust_bridge::for_generated::PlatformGeneralizedUint8ListPtr,
|
|
rust_vec_len_: i32,
|
|
data_len_: i32,
|
|
) {
|
|
FLUTTER_RUST_BRIDGE_HANDLER.wrap_async::<flutter_rust_bridge::for_generated::SseCodec,_,_,_>(flutter_rust_bridge::for_generated::TaskInfo{ debug_name: "rust_backup_identity_get_backup_password_keys", port: Some(port_), mode: flutter_rust_bridge::for_generated::FfiCallMode::Normal }, move || {
|
|
let message = unsafe { flutter_rust_bridge::for_generated::Dart2RustMessageSse::from_wire(ptr_, rust_vec_len_, data_len_) };
|
|
let mut deserializer = flutter_rust_bridge::for_generated::SseDeserializer::new(message);
|
|
let api_user_id = <i64>::sse_decode(&mut deserializer);
|
|
let api_password = <String>::sse_decode(&mut deserializer);deserializer.end(); move |context| async move {
|
|
transform_result_sse::<_, flutter_rust_bridge::for_generated::anyhow::Error>((move || async move {
|
|
let output_ok = crate::bridge::wrapper::backup::RustBackupIdentity::get_backup_password_keys(api_user_id, api_password).await?; Ok(output_ok)
|
|
})().await)
|
|
} })
|
|
}
|
|
fn wire__crate__bridge__wrapper__backup__rust_backup_identity_get_identity_backup_bytes_impl(
|
|
port_: flutter_rust_bridge::for_generated::MessagePort,
|
|
ptr_: flutter_rust_bridge::for_generated::PlatformGeneralizedUint8ListPtr,
|
|
rust_vec_len_: i32,
|
|
data_len_: i32,
|
|
) {
|
|
FLUTTER_RUST_BRIDGE_HANDLER.wrap_async::<flutter_rust_bridge::for_generated::SseCodec,_,_,_>(flutter_rust_bridge::for_generated::TaskInfo{ debug_name: "rust_backup_identity_get_identity_backup_bytes", port: Some(port_), mode: flutter_rust_bridge::for_generated::FfiCallMode::Normal }, move || {
|
|
let message = unsafe { flutter_rust_bridge::for_generated::Dart2RustMessageSse::from_wire(ptr_, rust_vec_len_, data_len_) };
|
|
let mut deserializer = flutter_rust_bridge::for_generated::SseDeserializer::new(message);
|
|
deserializer.end(); move |context| async move {
|
|
transform_result_sse::<_, flutter_rust_bridge::for_generated::anyhow::Error>((move || async move {
|
|
let output_ok = crate::bridge::wrapper::backup::RustBackupIdentity::get_identity_backup_bytes().await?; Ok(output_ok)
|
|
})().await)
|
|
} })
|
|
}
|
|
fn wire__crate__bridge__wrapper__backup__rust_backup_identity_import_backup_password_keys_impl(
|
|
port_: flutter_rust_bridge::for_generated::MessagePort,
|
|
ptr_: flutter_rust_bridge::for_generated::PlatformGeneralizedUint8ListPtr,
|
|
rust_vec_len_: i32,
|
|
data_len_: i32,
|
|
) {
|
|
FLUTTER_RUST_BRIDGE_HANDLER.wrap_async::<flutter_rust_bridge::for_generated::SseCodec,_,_,_>(flutter_rust_bridge::for_generated::TaskInfo{ debug_name: "rust_backup_identity_import_backup_password_keys", port: Some(port_), mode: flutter_rust_bridge::for_generated::FfiCallMode::Normal }, move || {
|
|
let message = unsafe { flutter_rust_bridge::for_generated::Dart2RustMessageSse::from_wire(ptr_, rust_vec_len_, data_len_) };
|
|
let mut deserializer = flutter_rust_bridge::for_generated::SseDeserializer::new(message);
|
|
let api_backup_id = <Vec<u8>>::sse_decode(&mut deserializer);
|
|
let api_encryption_key = <Vec<u8>>::sse_decode(&mut deserializer);deserializer.end(); move |context| async move {
|
|
transform_result_sse::<_, flutter_rust_bridge::for_generated::anyhow::Error>((move || async move {
|
|
let output_ok = crate::bridge::wrapper::backup::RustBackupIdentity::import_backup_password_keys(api_backup_id, api_encryption_key).await?; Ok(output_ok)
|
|
})().await)
|
|
} })
|
|
}
|
|
fn wire__crate__bridge__wrapper__backup__rust_backup_identity_restore_identity_backup_impl(
|
|
port_: flutter_rust_bridge::for_generated::MessagePort,
|
|
ptr_: flutter_rust_bridge::for_generated::PlatformGeneralizedUint8ListPtr,
|
|
rust_vec_len_: i32,
|
|
data_len_: i32,
|
|
) {
|
|
FLUTTER_RUST_BRIDGE_HANDLER.wrap_async::<flutter_rust_bridge::for_generated::SseCodec,_,_,_>(flutter_rust_bridge::for_generated::TaskInfo{ debug_name: "rust_backup_identity_restore_identity_backup", port: Some(port_), mode: flutter_rust_bridge::for_generated::FfiCallMode::Normal }, move || {
|
|
let message = unsafe { flutter_rust_bridge::for_generated::Dart2RustMessageSse::from_wire(ptr_, rust_vec_len_, data_len_) };
|
|
let mut deserializer = flutter_rust_bridge::for_generated::SseDeserializer::new(message);
|
|
let api_keys = <crate::keys::backup_password_keys::BackupPasswordKeys>::sse_decode(&mut deserializer);
|
|
let api_encrypted_bytes = <Vec<u8>>::sse_decode(&mut deserializer);deserializer.end(); move |context| async move {
|
|
transform_result_sse::<_, flutter_rust_bridge::for_generated::anyhow::Error>((move || async move {
|
|
let output_ok = crate::bridge::wrapper::backup::RustBackupIdentity::restore_identity_backup(api_keys, api_encrypted_bytes).await?; Ok(output_ok)
|
|
})().await)
|
|
} })
|
|
}
|
|
fn wire__crate__bridge__wrapper__backup__rust_backup_identity_set_backup_password_keys_impl(
|
|
port_: flutter_rust_bridge::for_generated::MessagePort,
|
|
ptr_: flutter_rust_bridge::for_generated::PlatformGeneralizedUint8ListPtr,
|
|
rust_vec_len_: i32,
|
|
data_len_: i32,
|
|
) {
|
|
FLUTTER_RUST_BRIDGE_HANDLER.wrap_async::<flutter_rust_bridge::for_generated::SseCodec,_,_,_>(flutter_rust_bridge::for_generated::TaskInfo{ debug_name: "rust_backup_identity_set_backup_password_keys", port: Some(port_), mode: flutter_rust_bridge::for_generated::FfiCallMode::Normal }, move || {
|
|
let message = unsafe { flutter_rust_bridge::for_generated::Dart2RustMessageSse::from_wire(ptr_, rust_vec_len_, data_len_) };
|
|
let mut deserializer = flutter_rust_bridge::for_generated::SseDeserializer::new(message);
|
|
let api_user_id = <i64>::sse_decode(&mut deserializer);
|
|
let api_password = <String>::sse_decode(&mut deserializer);deserializer.end(); move |context| async move {
|
|
transform_result_sse::<_, flutter_rust_bridge::for_generated::anyhow::Error>((move || async move {
|
|
let output_ok = crate::bridge::wrapper::backup::RustBackupIdentity::set_backup_password_keys(api_user_id, api_password).await?; Ok(output_ok)
|
|
})().await)
|
|
} })
|
|
}
|
|
fn wire__crate__bridge__wrapper__key_manager__rust_key_manager_get_login_token_impl(
|
|
port_: flutter_rust_bridge::for_generated::MessagePort,
|
|
ptr_: flutter_rust_bridge::for_generated::PlatformGeneralizedUint8ListPtr,
|
|
rust_vec_len_: i32,
|
|
data_len_: i32,
|
|
) {
|
|
FLUTTER_RUST_BRIDGE_HANDLER.wrap_async::<flutter_rust_bridge::for_generated::SseCodec, _, _, _>(
|
|
flutter_rust_bridge::for_generated::TaskInfo {
|
|
debug_name: "rust_key_manager_get_login_token",
|
|
port: Some(port_),
|
|
mode: flutter_rust_bridge::for_generated::FfiCallMode::Normal,
|
|
},
|
|
move || {
|
|
let message = unsafe {
|
|
flutter_rust_bridge::for_generated::Dart2RustMessageSse::from_wire(
|
|
ptr_,
|
|
rust_vec_len_,
|
|
data_len_,
|
|
)
|
|
};
|
|
let mut deserializer =
|
|
flutter_rust_bridge::for_generated::SseDeserializer::new(message);
|
|
deserializer.end();
|
|
move |context| async move {
|
|
transform_result_sse::<_, flutter_rust_bridge::for_generated::anyhow::Error>(
|
|
(move || async move {
|
|
let output_ok =
|
|
crate::bridge::wrapper::key_manager::RustKeyManager::get_login_token()
|
|
.await?;
|
|
Ok(output_ok)
|
|
})()
|
|
.await,
|
|
)
|
|
}
|
|
},
|
|
)
|
|
}
|
|
fn wire__crate__bridge__wrapper__key_manager__rust_key_manager_get_signal_identity_impl(
|
|
port_: flutter_rust_bridge::for_generated::MessagePort,
|
|
ptr_: flutter_rust_bridge::for_generated::PlatformGeneralizedUint8ListPtr,
|
|
rust_vec_len_: i32,
|
|
data_len_: i32,
|
|
) {
|
|
FLUTTER_RUST_BRIDGE_HANDLER.wrap_async::<flutter_rust_bridge::for_generated::SseCodec,_,_,_>(flutter_rust_bridge::for_generated::TaskInfo{ debug_name: "rust_key_manager_get_signal_identity", port: Some(port_), mode: flutter_rust_bridge::for_generated::FfiCallMode::Normal }, move || {
|
|
let message = unsafe { flutter_rust_bridge::for_generated::Dart2RustMessageSse::from_wire(ptr_, rust_vec_len_, data_len_) };
|
|
let mut deserializer = flutter_rust_bridge::for_generated::SseDeserializer::new(message);
|
|
deserializer.end(); move |context| async move {
|
|
transform_result_sse::<_, flutter_rust_bridge::for_generated::anyhow::Error>((move || async move {
|
|
let output_ok = crate::bridge::wrapper::key_manager::RustKeyManager::get_signal_identity().await?; Ok(output_ok)
|
|
})().await)
|
|
} })
|
|
}
|
|
fn wire__crate__bridge__wrapper__key_manager__rust_key_manager_get_user_id_impl(
|
|
port_: flutter_rust_bridge::for_generated::MessagePort,
|
|
ptr_: flutter_rust_bridge::for_generated::PlatformGeneralizedUint8ListPtr,
|
|
rust_vec_len_: i32,
|
|
data_len_: i32,
|
|
) {
|
|
FLUTTER_RUST_BRIDGE_HANDLER.wrap_async::<flutter_rust_bridge::for_generated::SseCodec, _, _, _>(
|
|
flutter_rust_bridge::for_generated::TaskInfo {
|
|
debug_name: "rust_key_manager_get_user_id",
|
|
port: Some(port_),
|
|
mode: flutter_rust_bridge::for_generated::FfiCallMode::Normal,
|
|
},
|
|
move || {
|
|
let message = unsafe {
|
|
flutter_rust_bridge::for_generated::Dart2RustMessageSse::from_wire(
|
|
ptr_,
|
|
rust_vec_len_,
|
|
data_len_,
|
|
)
|
|
};
|
|
let mut deserializer =
|
|
flutter_rust_bridge::for_generated::SseDeserializer::new(message);
|
|
deserializer.end();
|
|
move |context| async move {
|
|
transform_result_sse::<_, flutter_rust_bridge::for_generated::anyhow::Error>(
|
|
(move || async move {
|
|
let output_ok =
|
|
crate::bridge::wrapper::key_manager::RustKeyManager::get_user_id()
|
|
.await?;
|
|
Ok(output_ok)
|
|
})()
|
|
.await,
|
|
)
|
|
}
|
|
},
|
|
)
|
|
}
|
|
fn wire__crate__bridge__wrapper__key_manager__rust_key_manager_import_signal_identity_impl(
|
|
port_: flutter_rust_bridge::for_generated::MessagePort,
|
|
ptr_: flutter_rust_bridge::for_generated::PlatformGeneralizedUint8ListPtr,
|
|
rust_vec_len_: i32,
|
|
data_len_: i32,
|
|
) {
|
|
FLUTTER_RUST_BRIDGE_HANDLER.wrap_async::<flutter_rust_bridge::for_generated::SseCodec,_,_,_>(flutter_rust_bridge::for_generated::TaskInfo{ debug_name: "rust_key_manager_import_signal_identity", port: Some(port_), mode: flutter_rust_bridge::for_generated::FfiCallMode::Normal }, move || {
|
|
let message = unsafe { flutter_rust_bridge::for_generated::Dart2RustMessageSse::from_wire(ptr_, rust_vec_len_, data_len_) };
|
|
let mut deserializer = flutter_rust_bridge::for_generated::SseDeserializer::new(message);
|
|
let api_identity_key_pair_structure = <Vec<u8>>::sse_decode(&mut deserializer);
|
|
let api_registration_id = <i64>::sse_decode(&mut deserializer);
|
|
let api_signed_pre_key_store = <std::collections::HashMap<i64, Vec<u8>>>::sse_decode(&mut deserializer);deserializer.end(); move |context| async move {
|
|
transform_result_sse::<_, flutter_rust_bridge::for_generated::anyhow::Error>((move || async move {
|
|
let output_ok = crate::bridge::wrapper::key_manager::RustKeyManager::import_signal_identity(api_identity_key_pair_structure, api_registration_id, api_signed_pre_key_store).await?; Ok(output_ok)
|
|
})().await)
|
|
} })
|
|
}
|
|
fn wire__crate__bridge__wrapper__key_manager__rust_key_manager_load_signed_prekey_impl(
|
|
port_: flutter_rust_bridge::for_generated::MessagePort,
|
|
ptr_: flutter_rust_bridge::for_generated::PlatformGeneralizedUint8ListPtr,
|
|
rust_vec_len_: i32,
|
|
data_len_: i32,
|
|
) {
|
|
FLUTTER_RUST_BRIDGE_HANDLER.wrap_async::<flutter_rust_bridge::for_generated::SseCodec,_,_,_>(flutter_rust_bridge::for_generated::TaskInfo{ debug_name: "rust_key_manager_load_signed_prekey", port: Some(port_), mode: flutter_rust_bridge::for_generated::FfiCallMode::Normal }, move || {
|
|
let message = unsafe { flutter_rust_bridge::for_generated::Dart2RustMessageSse::from_wire(ptr_, rust_vec_len_, data_len_) };
|
|
let mut deserializer = flutter_rust_bridge::for_generated::SseDeserializer::new(message);
|
|
let api_signed_pre_key_id = <i64>::sse_decode(&mut deserializer);deserializer.end(); move |context| async move {
|
|
transform_result_sse::<_, flutter_rust_bridge::for_generated::anyhow::Error>((move || async move {
|
|
let output_ok = crate::bridge::wrapper::key_manager::RustKeyManager::load_signed_prekey(api_signed_pre_key_id).await?; Ok(output_ok)
|
|
})().await)
|
|
} })
|
|
}
|
|
fn wire__crate__bridge__wrapper__key_manager__rust_key_manager_load_signed_prekeys_impl(
|
|
port_: flutter_rust_bridge::for_generated::MessagePort,
|
|
ptr_: flutter_rust_bridge::for_generated::PlatformGeneralizedUint8ListPtr,
|
|
rust_vec_len_: i32,
|
|
data_len_: i32,
|
|
) {
|
|
FLUTTER_RUST_BRIDGE_HANDLER.wrap_async::<flutter_rust_bridge::for_generated::SseCodec,_,_,_>(flutter_rust_bridge::for_generated::TaskInfo{ debug_name: "rust_key_manager_load_signed_prekeys", port: Some(port_), mode: flutter_rust_bridge::for_generated::FfiCallMode::Normal }, move || {
|
|
let message = unsafe { flutter_rust_bridge::for_generated::Dart2RustMessageSse::from_wire(ptr_, rust_vec_len_, data_len_) };
|
|
let mut deserializer = flutter_rust_bridge::for_generated::SseDeserializer::new(message);
|
|
deserializer.end(); move |context| async move {
|
|
transform_result_sse::<_, flutter_rust_bridge::for_generated::anyhow::Error>((move || async move {
|
|
let output_ok = crate::bridge::wrapper::key_manager::RustKeyManager::load_signed_prekeys().await?; Ok(output_ok)
|
|
})().await)
|
|
} })
|
|
}
|
|
fn wire__crate__bridge__wrapper__key_manager__rust_key_manager_remove_key_manager_impl(
|
|
port_: flutter_rust_bridge::for_generated::MessagePort,
|
|
ptr_: flutter_rust_bridge::for_generated::PlatformGeneralizedUint8ListPtr,
|
|
rust_vec_len_: i32,
|
|
data_len_: i32,
|
|
) {
|
|
FLUTTER_RUST_BRIDGE_HANDLER.wrap_async::<flutter_rust_bridge::for_generated::SseCodec,_,_,_>(flutter_rust_bridge::for_generated::TaskInfo{ debug_name: "rust_key_manager_remove_key_manager", port: Some(port_), mode: flutter_rust_bridge::for_generated::FfiCallMode::Normal }, move || {
|
|
let message = unsafe { flutter_rust_bridge::for_generated::Dart2RustMessageSse::from_wire(ptr_, rust_vec_len_, data_len_) };
|
|
let mut deserializer = flutter_rust_bridge::for_generated::SseDeserializer::new(message);
|
|
deserializer.end(); move |context| async move {
|
|
transform_result_sse::<_, flutter_rust_bridge::for_generated::anyhow::Error>((move || async move {
|
|
let output_ok = crate::bridge::wrapper::key_manager::RustKeyManager::remove_key_manager().await?; Ok(output_ok)
|
|
})().await)
|
|
} })
|
|
}
|
|
fn wire__crate__bridge__wrapper__key_manager__rust_key_manager_remove_signed_prekey_impl(
|
|
port_: flutter_rust_bridge::for_generated::MessagePort,
|
|
ptr_: flutter_rust_bridge::for_generated::PlatformGeneralizedUint8ListPtr,
|
|
rust_vec_len_: i32,
|
|
data_len_: i32,
|
|
) {
|
|
FLUTTER_RUST_BRIDGE_HANDLER.wrap_async::<flutter_rust_bridge::for_generated::SseCodec,_,_,_>(flutter_rust_bridge::for_generated::TaskInfo{ debug_name: "rust_key_manager_remove_signed_prekey", port: Some(port_), mode: flutter_rust_bridge::for_generated::FfiCallMode::Normal }, move || {
|
|
let message = unsafe { flutter_rust_bridge::for_generated::Dart2RustMessageSse::from_wire(ptr_, rust_vec_len_, data_len_) };
|
|
let mut deserializer = flutter_rust_bridge::for_generated::SseDeserializer::new(message);
|
|
let api_signed_pre_key_id = <i64>::sse_decode(&mut deserializer);deserializer.end(); move |context| async move {
|
|
transform_result_sse::<_, flutter_rust_bridge::for_generated::anyhow::Error>((move || async move {
|
|
let output_ok = crate::bridge::wrapper::key_manager::RustKeyManager::remove_signed_prekey(api_signed_pre_key_id).await?; Ok(output_ok)
|
|
})().await)
|
|
} })
|
|
}
|
|
fn wire__crate__bridge__wrapper__key_manager__rust_key_manager_set_user_id_impl(
|
|
port_: flutter_rust_bridge::for_generated::MessagePort,
|
|
ptr_: flutter_rust_bridge::for_generated::PlatformGeneralizedUint8ListPtr,
|
|
rust_vec_len_: i32,
|
|
data_len_: i32,
|
|
) {
|
|
FLUTTER_RUST_BRIDGE_HANDLER.wrap_async::<flutter_rust_bridge::for_generated::SseCodec, _, _, _>(
|
|
flutter_rust_bridge::for_generated::TaskInfo {
|
|
debug_name: "rust_key_manager_set_user_id",
|
|
port: Some(port_),
|
|
mode: flutter_rust_bridge::for_generated::FfiCallMode::Normal,
|
|
},
|
|
move || {
|
|
let message = unsafe {
|
|
flutter_rust_bridge::for_generated::Dart2RustMessageSse::from_wire(
|
|
ptr_,
|
|
rust_vec_len_,
|
|
data_len_,
|
|
)
|
|
};
|
|
let mut deserializer =
|
|
flutter_rust_bridge::for_generated::SseDeserializer::new(message);
|
|
let api_user_id = <i64>::sse_decode(&mut deserializer);
|
|
deserializer.end();
|
|
move |context| async move {
|
|
transform_result_sse::<_, flutter_rust_bridge::for_generated::anyhow::Error>(
|
|
(move || async move {
|
|
let output_ok =
|
|
crate::bridge::wrapper::key_manager::RustKeyManager::set_user_id(
|
|
api_user_id,
|
|
)
|
|
.await?;
|
|
Ok(output_ok)
|
|
})()
|
|
.await,
|
|
)
|
|
}
|
|
},
|
|
)
|
|
}
|
|
fn wire__crate__bridge__wrapper__key_manager__rust_key_manager_store_signed_prekey_impl(
|
|
port_: flutter_rust_bridge::for_generated::MessagePort,
|
|
ptr_: flutter_rust_bridge::for_generated::PlatformGeneralizedUint8ListPtr,
|
|
rust_vec_len_: i32,
|
|
data_len_: i32,
|
|
) {
|
|
FLUTTER_RUST_BRIDGE_HANDLER.wrap_async::<flutter_rust_bridge::for_generated::SseCodec,_,_,_>(flutter_rust_bridge::for_generated::TaskInfo{ debug_name: "rust_key_manager_store_signed_prekey", port: Some(port_), mode: flutter_rust_bridge::for_generated::FfiCallMode::Normal }, move || {
|
|
let message = unsafe { flutter_rust_bridge::for_generated::Dart2RustMessageSse::from_wire(ptr_, rust_vec_len_, data_len_) };
|
|
let mut deserializer = flutter_rust_bridge::for_generated::SseDeserializer::new(message);
|
|
let api_signed_pre_key_id = <i64>::sse_decode(&mut deserializer);
|
|
let api_record = <Vec<u8>>::sse_decode(&mut deserializer);deserializer.end(); move |context| async move {
|
|
transform_result_sse::<_, flutter_rust_bridge::for_generated::anyhow::Error>((move || async move {
|
|
let output_ok = crate::bridge::wrapper::key_manager::RustKeyManager::store_signed_prekey(api_signed_pre_key_id, api_record).await?; Ok(output_ok)
|
|
})().await)
|
|
} })
|
|
}
|
|
|
|
// Section: static_checks
|
|
|
|
#[allow(clippy::unnecessary_literal_unwrap)]
|
|
const _: fn() = || {
|
|
{
|
|
let AnnouncedUser = None::<crate::bridge::AnnouncedUser>.unwrap();
|
|
let _: i64 = AnnouncedUser.user_id;
|
|
let _: Vec<u8> = AnnouncedUser.public_key;
|
|
let _: i64 = AnnouncedUser.public_id;
|
|
}
|
|
{
|
|
let OtherPromotion = None::<crate::bridge::OtherPromotion>.unwrap();
|
|
let _: u32 = OtherPromotion.promotion_id;
|
|
let _: i64 = OtherPromotion.public_id;
|
|
let _: i64 = OtherPromotion.from_contact_id;
|
|
let _: u8 = OtherPromotion.threshold;
|
|
let _: Vec<u8> = OtherPromotion.announcement_share;
|
|
let _: Option<i64> = OtherPromotion.public_key_verified_timestamp;
|
|
}
|
|
};
|
|
|
|
// Section: related_funcs
|
|
|
|
fn decode_DartFn_Inputs__Output_StreamSink_String_Sse_AnyhowException(
|
|
dart_opaque: flutter_rust_bridge::DartOpaque,
|
|
) -> impl Fn() -> flutter_rust_bridge::DartFnFuture<
|
|
StreamSink<String, flutter_rust_bridge::for_generated::SseCodec>,
|
|
> {
|
|
use flutter_rust_bridge::IntoDart;
|
|
|
|
async fn body(
|
|
dart_opaque: flutter_rust_bridge::DartOpaque,
|
|
) -> StreamSink<String, flutter_rust_bridge::for_generated::SseCodec> {
|
|
let args = vec![];
|
|
let message = FLUTTER_RUST_BRIDGE_HANDLER
|
|
.dart_fn_invoke(dart_opaque, args)
|
|
.await;
|
|
|
|
let mut deserializer = flutter_rust_bridge::for_generated::SseDeserializer::new(message);
|
|
let action = deserializer.cursor.read_u8().unwrap();
|
|
let ans = match action {
|
|
0 => std::result::Result::Ok(<StreamSink<
|
|
String,
|
|
flutter_rust_bridge::for_generated::SseCodec,
|
|
>>::sse_decode(&mut deserializer)),
|
|
1 => std::result::Result::Err(
|
|
<flutter_rust_bridge::for_generated::anyhow::Error>::sse_decode(&mut deserializer),
|
|
),
|
|
_ => unreachable!(),
|
|
};
|
|
deserializer.end();
|
|
let ans = ans.expect("Dart throws exception but Rust side assume it is not failable");
|
|
ans
|
|
}
|
|
|
|
move || {
|
|
flutter_rust_bridge::for_generated::convert_into_dart_fn_future(body(dart_opaque.clone()))
|
|
}
|
|
}
|
|
fn decode_DartFn_Inputs_i_64_Output_opt_box_autoadd_announced_user_AnyhowException(
|
|
dart_opaque: flutter_rust_bridge::DartOpaque,
|
|
) -> impl Fn(i64) -> flutter_rust_bridge::DartFnFuture<Option<crate::bridge::AnnouncedUser>> {
|
|
use flutter_rust_bridge::IntoDart;
|
|
|
|
async fn body(
|
|
dart_opaque: flutter_rust_bridge::DartOpaque,
|
|
arg0: i64,
|
|
) -> Option<crate::bridge::AnnouncedUser> {
|
|
let args = vec![arg0.into_into_dart().into_dart()];
|
|
let message = FLUTTER_RUST_BRIDGE_HANDLER
|
|
.dart_fn_invoke(dart_opaque, args)
|
|
.await;
|
|
|
|
let mut deserializer = flutter_rust_bridge::for_generated::SseDeserializer::new(message);
|
|
let action = deserializer.cursor.read_u8().unwrap();
|
|
let ans = match action {
|
|
0 => std::result::Result::Ok(<Option<crate::bridge::AnnouncedUser>>::sse_decode(
|
|
&mut deserializer,
|
|
)),
|
|
1 => std::result::Result::Err(
|
|
<flutter_rust_bridge::for_generated::anyhow::Error>::sse_decode(&mut deserializer),
|
|
),
|
|
_ => unreachable!(),
|
|
};
|
|
deserializer.end();
|
|
let ans = ans.expect("Dart throws exception but Rust side assume it is not failable");
|
|
ans
|
|
}
|
|
|
|
move |arg0: i64| {
|
|
flutter_rust_bridge::for_generated::convert_into_dart_fn_future(body(
|
|
dart_opaque.clone(),
|
|
arg0,
|
|
))
|
|
}
|
|
}
|
|
fn decode_DartFn_Inputs_i_64_Output_opt_list_list_prim_u_8_strict_AnyhowException(
|
|
dart_opaque: flutter_rust_bridge::DartOpaque,
|
|
) -> impl Fn(i64) -> flutter_rust_bridge::DartFnFuture<Option<Vec<Vec<u8>>>> {
|
|
use flutter_rust_bridge::IntoDart;
|
|
|
|
async fn body(dart_opaque: flutter_rust_bridge::DartOpaque, arg0: i64) -> Option<Vec<Vec<u8>>> {
|
|
let args = vec![arg0.into_into_dart().into_dart()];
|
|
let message = FLUTTER_RUST_BRIDGE_HANDLER
|
|
.dart_fn_invoke(dart_opaque, args)
|
|
.await;
|
|
|
|
let mut deserializer = flutter_rust_bridge::for_generated::SseDeserializer::new(message);
|
|
let action = deserializer.cursor.read_u8().unwrap();
|
|
let ans = match action {
|
|
0 => std::result::Result::Ok(<Option<Vec<Vec<u8>>>>::sse_decode(&mut deserializer)),
|
|
1 => std::result::Result::Err(
|
|
<flutter_rust_bridge::for_generated::anyhow::Error>::sse_decode(&mut deserializer),
|
|
),
|
|
_ => unreachable!(),
|
|
};
|
|
deserializer.end();
|
|
let ans = ans.expect("Dart throws exception but Rust side assume it is not failable");
|
|
ans
|
|
}
|
|
|
|
move |arg0: i64| {
|
|
flutter_rust_bridge::for_generated::convert_into_dart_fn_future(body(
|
|
dart_opaque.clone(),
|
|
arg0,
|
|
))
|
|
}
|
|
}
|
|
fn decode_DartFn_Inputs_i_64_Output_opt_list_other_promotion_AnyhowException(
|
|
dart_opaque: flutter_rust_bridge::DartOpaque,
|
|
) -> impl Fn(i64) -> flutter_rust_bridge::DartFnFuture<Option<Vec<crate::bridge::OtherPromotion>>> {
|
|
use flutter_rust_bridge::IntoDart;
|
|
|
|
async fn body(
|
|
dart_opaque: flutter_rust_bridge::DartOpaque,
|
|
arg0: i64,
|
|
) -> Option<Vec<crate::bridge::OtherPromotion>> {
|
|
let args = vec![arg0.into_into_dart().into_dart()];
|
|
let message = FLUTTER_RUST_BRIDGE_HANDLER
|
|
.dart_fn_invoke(dart_opaque, args)
|
|
.await;
|
|
|
|
let mut deserializer = flutter_rust_bridge::for_generated::SseDeserializer::new(message);
|
|
let action = deserializer.cursor.read_u8().unwrap();
|
|
let ans = match action {
|
|
0 => std::result::Result::Ok(<Option<Vec<crate::bridge::OtherPromotion>>>::sse_decode(
|
|
&mut deserializer,
|
|
)),
|
|
1 => std::result::Result::Err(
|
|
<flutter_rust_bridge::for_generated::anyhow::Error>::sse_decode(&mut deserializer),
|
|
),
|
|
_ => unreachable!(),
|
|
};
|
|
deserializer.end();
|
|
let ans = ans.expect("Dart throws exception but Rust side assume it is not failable");
|
|
ans
|
|
}
|
|
|
|
move |arg0: i64| {
|
|
flutter_rust_bridge::for_generated::convert_into_dart_fn_future(body(
|
|
dart_opaque.clone(),
|
|
arg0,
|
|
))
|
|
}
|
|
}
|
|
fn decode_DartFn_Inputs_i_64_Output_opt_list_prim_u_8_strict_AnyhowException(
|
|
dart_opaque: flutter_rust_bridge::DartOpaque,
|
|
) -> impl Fn(i64) -> flutter_rust_bridge::DartFnFuture<Option<Vec<u8>>> {
|
|
use flutter_rust_bridge::IntoDart;
|
|
|
|
async fn body(dart_opaque: flutter_rust_bridge::DartOpaque, arg0: i64) -> Option<Vec<u8>> {
|
|
let args = vec![arg0.into_into_dart().into_dart()];
|
|
let message = FLUTTER_RUST_BRIDGE_HANDLER
|
|
.dart_fn_invoke(dart_opaque, args)
|
|
.await;
|
|
|
|
let mut deserializer = flutter_rust_bridge::for_generated::SseDeserializer::new(message);
|
|
let action = deserializer.cursor.read_u8().unwrap();
|
|
let ans = match action {
|
|
0 => std::result::Result::Ok(<Option<Vec<u8>>>::sse_decode(&mut deserializer)),
|
|
1 => std::result::Result::Err(
|
|
<flutter_rust_bridge::for_generated::anyhow::Error>::sse_decode(&mut deserializer),
|
|
),
|
|
_ => unreachable!(),
|
|
};
|
|
deserializer.end();
|
|
let ans = ans.expect("Dart throws exception but Rust side assume it is not failable");
|
|
ans
|
|
}
|
|
|
|
move |arg0: i64| {
|
|
flutter_rust_bridge::for_generated::convert_into_dart_fn_future(body(
|
|
dart_opaque.clone(),
|
|
arg0,
|
|
))
|
|
}
|
|
}
|
|
fn decode_DartFn_Inputs_i_64_announced_user_opt_box_autoadd_i_64_Output_bool_AnyhowException(
|
|
dart_opaque: flutter_rust_bridge::DartOpaque,
|
|
) -> impl Fn(i64, crate::bridge::AnnouncedUser, Option<i64>) -> flutter_rust_bridge::DartFnFuture<bool>
|
|
{
|
|
use flutter_rust_bridge::IntoDart;
|
|
|
|
async fn body(
|
|
dart_opaque: flutter_rust_bridge::DartOpaque,
|
|
arg0: i64,
|
|
arg1: crate::bridge::AnnouncedUser,
|
|
arg2: Option<i64>,
|
|
) -> bool {
|
|
let args = vec![
|
|
arg0.into_into_dart().into_dart(),
|
|
arg1.into_into_dart().into_dart(),
|
|
arg2.into_into_dart().into_dart(),
|
|
];
|
|
let message = FLUTTER_RUST_BRIDGE_HANDLER
|
|
.dart_fn_invoke(dart_opaque, args)
|
|
.await;
|
|
|
|
let mut deserializer = flutter_rust_bridge::for_generated::SseDeserializer::new(message);
|
|
let action = deserializer.cursor.read_u8().unwrap();
|
|
let ans = match action {
|
|
0 => std::result::Result::Ok(<bool>::sse_decode(&mut deserializer)),
|
|
1 => std::result::Result::Err(
|
|
<flutter_rust_bridge::for_generated::anyhow::Error>::sse_decode(&mut deserializer),
|
|
),
|
|
_ => unreachable!(),
|
|
};
|
|
deserializer.end();
|
|
let ans = ans.expect("Dart throws exception but Rust side assume it is not failable");
|
|
ans
|
|
}
|
|
|
|
move |arg0: i64, arg1: crate::bridge::AnnouncedUser, arg2: Option<i64>| {
|
|
flutter_rust_bridge::for_generated::convert_into_dart_fn_future(body(
|
|
dart_opaque.clone(),
|
|
arg0,
|
|
arg1,
|
|
arg2,
|
|
))
|
|
}
|
|
}
|
|
fn decode_DartFn_Inputs_i_64_i_64_list_prim_u_8_strict_Output_bool_AnyhowException(
|
|
dart_opaque: flutter_rust_bridge::DartOpaque,
|
|
) -> impl Fn(i64, i64, Vec<u8>) -> flutter_rust_bridge::DartFnFuture<bool> {
|
|
use flutter_rust_bridge::IntoDart;
|
|
|
|
async fn body(
|
|
dart_opaque: flutter_rust_bridge::DartOpaque,
|
|
arg0: i64,
|
|
arg1: i64,
|
|
arg2: Vec<u8>,
|
|
) -> bool {
|
|
let args = vec![
|
|
arg0.into_into_dart().into_dart(),
|
|
arg1.into_into_dart().into_dart(),
|
|
arg2.into_into_dart().into_dart(),
|
|
];
|
|
let message = FLUTTER_RUST_BRIDGE_HANDLER
|
|
.dart_fn_invoke(dart_opaque, args)
|
|
.await;
|
|
|
|
let mut deserializer = flutter_rust_bridge::for_generated::SseDeserializer::new(message);
|
|
let action = deserializer.cursor.read_u8().unwrap();
|
|
let ans = match action {
|
|
0 => std::result::Result::Ok(<bool>::sse_decode(&mut deserializer)),
|
|
1 => std::result::Result::Err(
|
|
<flutter_rust_bridge::for_generated::anyhow::Error>::sse_decode(&mut deserializer),
|
|
),
|
|
_ => unreachable!(),
|
|
};
|
|
deserializer.end();
|
|
let ans = ans.expect("Dart throws exception but Rust side assume it is not failable");
|
|
ans
|
|
}
|
|
|
|
move |arg0: i64, arg1: i64, arg2: Vec<u8>| {
|
|
flutter_rust_bridge::for_generated::convert_into_dart_fn_future(body(
|
|
dart_opaque.clone(),
|
|
arg0,
|
|
arg1,
|
|
arg2,
|
|
))
|
|
}
|
|
}
|
|
fn decode_DartFn_Inputs_i_64_list_prim_u_8_strict_Output_bool_AnyhowException(
|
|
dart_opaque: flutter_rust_bridge::DartOpaque,
|
|
) -> impl Fn(i64, Vec<u8>) -> flutter_rust_bridge::DartFnFuture<bool> {
|
|
use flutter_rust_bridge::IntoDart;
|
|
|
|
async fn body(dart_opaque: flutter_rust_bridge::DartOpaque, arg0: i64, arg1: Vec<u8>) -> bool {
|
|
let args = vec![
|
|
arg0.into_into_dart().into_dart(),
|
|
arg1.into_into_dart().into_dart(),
|
|
];
|
|
let message = FLUTTER_RUST_BRIDGE_HANDLER
|
|
.dart_fn_invoke(dart_opaque, args)
|
|
.await;
|
|
|
|
let mut deserializer = flutter_rust_bridge::for_generated::SseDeserializer::new(message);
|
|
let action = deserializer.cursor.read_u8().unwrap();
|
|
let ans = match action {
|
|
0 => std::result::Result::Ok(<bool>::sse_decode(&mut deserializer)),
|
|
1 => std::result::Result::Err(
|
|
<flutter_rust_bridge::for_generated::anyhow::Error>::sse_decode(&mut deserializer),
|
|
),
|
|
_ => unreachable!(),
|
|
};
|
|
deserializer.end();
|
|
let ans = ans.expect("Dart throws exception but Rust side assume it is not failable");
|
|
ans
|
|
}
|
|
|
|
move |arg0: i64, arg1: Vec<u8>| {
|
|
flutter_rust_bridge::for_generated::convert_into_dart_fn_future(body(
|
|
dart_opaque.clone(),
|
|
arg0,
|
|
arg1,
|
|
))
|
|
}
|
|
}
|
|
fn decode_DartFn_Inputs_list_list_prim_u_8_strict_Output_bool_AnyhowException(
|
|
dart_opaque: flutter_rust_bridge::DartOpaque,
|
|
) -> impl Fn(Vec<Vec<u8>>) -> flutter_rust_bridge::DartFnFuture<bool> {
|
|
use flutter_rust_bridge::IntoDart;
|
|
|
|
async fn body(dart_opaque: flutter_rust_bridge::DartOpaque, arg0: Vec<Vec<u8>>) -> bool {
|
|
let args = vec![arg0.into_into_dart().into_dart()];
|
|
let message = FLUTTER_RUST_BRIDGE_HANDLER
|
|
.dart_fn_invoke(dart_opaque, args)
|
|
.await;
|
|
|
|
let mut deserializer = flutter_rust_bridge::for_generated::SseDeserializer::new(message);
|
|
let action = deserializer.cursor.read_u8().unwrap();
|
|
let ans = match action {
|
|
0 => std::result::Result::Ok(<bool>::sse_decode(&mut deserializer)),
|
|
1 => std::result::Result::Err(
|
|
<flutter_rust_bridge::for_generated::anyhow::Error>::sse_decode(&mut deserializer),
|
|
),
|
|
_ => unreachable!(),
|
|
};
|
|
deserializer.end();
|
|
let ans = ans.expect("Dart throws exception but Rust side assume it is not failable");
|
|
ans
|
|
}
|
|
|
|
move |arg0: Vec<Vec<u8>>| {
|
|
flutter_rust_bridge::for_generated::convert_into_dart_fn_future(body(
|
|
dart_opaque.clone(),
|
|
arg0,
|
|
))
|
|
}
|
|
}
|
|
fn decode_DartFn_Inputs_list_prim_u_8_strict_Output_opt_list_prim_u_8_strict_AnyhowException(
|
|
dart_opaque: flutter_rust_bridge::DartOpaque,
|
|
) -> impl Fn(Vec<u8>) -> flutter_rust_bridge::DartFnFuture<Option<Vec<u8>>> {
|
|
use flutter_rust_bridge::IntoDart;
|
|
|
|
async fn body(dart_opaque: flutter_rust_bridge::DartOpaque, arg0: Vec<u8>) -> Option<Vec<u8>> {
|
|
let args = vec![arg0.into_into_dart().into_dart()];
|
|
let message = FLUTTER_RUST_BRIDGE_HANDLER
|
|
.dart_fn_invoke(dart_opaque, args)
|
|
.await;
|
|
|
|
let mut deserializer = flutter_rust_bridge::for_generated::SseDeserializer::new(message);
|
|
let action = deserializer.cursor.read_u8().unwrap();
|
|
let ans = match action {
|
|
0 => std::result::Result::Ok(<Option<Vec<u8>>>::sse_decode(&mut deserializer)),
|
|
1 => std::result::Result::Err(
|
|
<flutter_rust_bridge::for_generated::anyhow::Error>::sse_decode(&mut deserializer),
|
|
),
|
|
_ => unreachable!(),
|
|
};
|
|
deserializer.end();
|
|
let ans = ans.expect("Dart throws exception but Rust side assume it is not failable");
|
|
ans
|
|
}
|
|
|
|
move |arg0: Vec<u8>| {
|
|
flutter_rust_bridge::for_generated::convert_into_dart_fn_future(body(
|
|
dart_opaque.clone(),
|
|
arg0,
|
|
))
|
|
}
|
|
}
|
|
fn decode_DartFn_Inputs_list_prim_u_8_strict_list_prim_u_8_strict_list_prim_u_8_strict_Output_bool_AnyhowException(
|
|
dart_opaque: flutter_rust_bridge::DartOpaque,
|
|
) -> impl Fn(Vec<u8>, Vec<u8>, Vec<u8>) -> flutter_rust_bridge::DartFnFuture<bool> {
|
|
use flutter_rust_bridge::IntoDart;
|
|
|
|
async fn body(
|
|
dart_opaque: flutter_rust_bridge::DartOpaque,
|
|
arg0: Vec<u8>,
|
|
arg1: Vec<u8>,
|
|
arg2: Vec<u8>,
|
|
) -> bool {
|
|
let args = vec![
|
|
arg0.into_into_dart().into_dart(),
|
|
arg1.into_into_dart().into_dart(),
|
|
arg2.into_into_dart().into_dart(),
|
|
];
|
|
let message = FLUTTER_RUST_BRIDGE_HANDLER
|
|
.dart_fn_invoke(dart_opaque, args)
|
|
.await;
|
|
|
|
let mut deserializer = flutter_rust_bridge::for_generated::SseDeserializer::new(message);
|
|
let action = deserializer.cursor.read_u8().unwrap();
|
|
let ans = match action {
|
|
0 => std::result::Result::Ok(<bool>::sse_decode(&mut deserializer)),
|
|
1 => std::result::Result::Err(
|
|
<flutter_rust_bridge::for_generated::anyhow::Error>::sse_decode(&mut deserializer),
|
|
),
|
|
_ => unreachable!(),
|
|
};
|
|
deserializer.end();
|
|
let ans = ans.expect("Dart throws exception but Rust side assume it is not failable");
|
|
ans
|
|
}
|
|
|
|
move |arg0: Vec<u8>, arg1: Vec<u8>, arg2: Vec<u8>| {
|
|
flutter_rust_bridge::for_generated::convert_into_dart_fn_future(body(
|
|
dart_opaque.clone(),
|
|
arg0,
|
|
arg1,
|
|
arg2,
|
|
))
|
|
}
|
|
}
|
|
fn decode_DartFn_Inputs_other_promotion_Output_bool_AnyhowException(
|
|
dart_opaque: flutter_rust_bridge::DartOpaque,
|
|
) -> impl Fn(crate::bridge::OtherPromotion) -> flutter_rust_bridge::DartFnFuture<bool> {
|
|
use flutter_rust_bridge::IntoDart;
|
|
|
|
async fn body(
|
|
dart_opaque: flutter_rust_bridge::DartOpaque,
|
|
arg0: crate::bridge::OtherPromotion,
|
|
) -> bool {
|
|
let args = vec![arg0.into_into_dart().into_dart()];
|
|
let message = FLUTTER_RUST_BRIDGE_HANDLER
|
|
.dart_fn_invoke(dart_opaque, args)
|
|
.await;
|
|
|
|
let mut deserializer = flutter_rust_bridge::for_generated::SseDeserializer::new(message);
|
|
let action = deserializer.cursor.read_u8().unwrap();
|
|
let ans = match action {
|
|
0 => std::result::Result::Ok(<bool>::sse_decode(&mut deserializer)),
|
|
1 => std::result::Result::Err(
|
|
<flutter_rust_bridge::for_generated::anyhow::Error>::sse_decode(&mut deserializer),
|
|
),
|
|
_ => unreachable!(),
|
|
};
|
|
deserializer.end();
|
|
let ans = ans.expect("Dart throws exception but Rust side assume it is not failable");
|
|
ans
|
|
}
|
|
|
|
move |arg0: crate::bridge::OtherPromotion| {
|
|
flutter_rust_bridge::for_generated::convert_into_dart_fn_future(body(
|
|
dart_opaque.clone(),
|
|
arg0,
|
|
))
|
|
}
|
|
}
|
|
|
|
// Section: dart2rust
|
|
|
|
impl SseDecode for flutter_rust_bridge::for_generated::anyhow::Error {
|
|
// Codec=Sse (Serialization based), see doc to use other codecs
|
|
fn sse_decode(deserializer: &mut flutter_rust_bridge::for_generated::SseDeserializer) -> Self {
|
|
let mut inner = <String>::sse_decode(deserializer);
|
|
return flutter_rust_bridge::for_generated::anyhow::anyhow!("{}", inner);
|
|
}
|
|
}
|
|
|
|
impl SseDecode for flutter_rust_bridge::DartOpaque {
|
|
// Codec=Sse (Serialization based), see doc to use other codecs
|
|
fn sse_decode(deserializer: &mut flutter_rust_bridge::for_generated::SseDeserializer) -> Self {
|
|
let mut inner = <usize>::sse_decode(deserializer);
|
|
return unsafe { flutter_rust_bridge::for_generated::sse_decode_dart_opaque(inner) };
|
|
}
|
|
}
|
|
|
|
impl SseDecode for std::collections::HashMap<i64, Vec<u8>> {
|
|
// Codec=Sse (Serialization based), see doc to use other codecs
|
|
fn sse_decode(deserializer: &mut flutter_rust_bridge::for_generated::SseDeserializer) -> Self {
|
|
let mut inner = <Vec<(i64, Vec<u8>)>>::sse_decode(deserializer);
|
|
return inner.into_iter().collect();
|
|
}
|
|
}
|
|
|
|
impl SseDecode for StreamSink<String, flutter_rust_bridge::for_generated::SseCodec> {
|
|
// Codec=Sse (Serialization based), see doc to use other codecs
|
|
fn sse_decode(deserializer: &mut flutter_rust_bridge::for_generated::SseDeserializer) -> Self {
|
|
let mut inner = <String>::sse_decode(deserializer);
|
|
return StreamSink::deserialize(inner);
|
|
}
|
|
}
|
|
|
|
impl SseDecode for String {
|
|
// Codec=Sse (Serialization based), see doc to use other codecs
|
|
fn sse_decode(deserializer: &mut flutter_rust_bridge::for_generated::SseDeserializer) -> Self {
|
|
let mut inner = <Vec<u8>>::sse_decode(deserializer);
|
|
return String::from_utf8(inner).unwrap();
|
|
}
|
|
}
|
|
|
|
impl SseDecode for crate::bridge::AnnouncedUser {
|
|
// Codec=Sse (Serialization based), see doc to use other codecs
|
|
fn sse_decode(deserializer: &mut flutter_rust_bridge::for_generated::SseDeserializer) -> Self {
|
|
let mut var_userId = <i64>::sse_decode(deserializer);
|
|
let mut var_publicKey = <Vec<u8>>::sse_decode(deserializer);
|
|
let mut var_publicId = <i64>::sse_decode(deserializer);
|
|
return crate::bridge::AnnouncedUser {
|
|
user_id: var_userId,
|
|
public_key: var_publicKey,
|
|
public_id: var_publicId,
|
|
};
|
|
}
|
|
}
|
|
|
|
impl SseDecode for crate::keys::backup_password_keys::BackupPasswordKeys {
|
|
// Codec=Sse (Serialization based), see doc to use other codecs
|
|
fn sse_decode(deserializer: &mut flutter_rust_bridge::for_generated::SseDeserializer) -> Self {
|
|
let mut var_backupId = <[u8; 32]>::sse_decode(deserializer);
|
|
let mut var_encryptionKey = <[u8; 32]>::sse_decode(deserializer);
|
|
return crate::keys::backup_password_keys::BackupPasswordKeys {
|
|
backup_id: var_backupId,
|
|
encryption_key: var_encryptionKey,
|
|
};
|
|
}
|
|
}
|
|
|
|
impl SseDecode for bool {
|
|
// Codec=Sse (Serialization based), see doc to use other codecs
|
|
fn sse_decode(deserializer: &mut flutter_rust_bridge::for_generated::SseDeserializer) -> Self {
|
|
deserializer.cursor.read_u8().unwrap() != 0
|
|
}
|
|
}
|
|
|
|
impl SseDecode for crate::bridge::wrapper::user_discovery::FlutterUserDiscovery {
|
|
// Codec=Sse (Serialization based), see doc to use other codecs
|
|
fn sse_decode(deserializer: &mut flutter_rust_bridge::for_generated::SseDeserializer) -> Self {
|
|
return crate::bridge::wrapper::user_discovery::FlutterUserDiscovery {};
|
|
}
|
|
}
|
|
|
|
impl SseDecode for i64 {
|
|
// Codec=Sse (Serialization based), see doc to use other codecs
|
|
fn sse_decode(deserializer: &mut flutter_rust_bridge::for_generated::SseDeserializer) -> Self {
|
|
deserializer.cursor.read_i64::<NativeEndian>().unwrap()
|
|
}
|
|
}
|
|
|
|
impl SseDecode for crate::bridge::InitConfig {
|
|
// Codec=Sse (Serialization based), see doc to use other codecs
|
|
fn sse_decode(deserializer: &mut flutter_rust_bridge::for_generated::SseDeserializer) -> Self {
|
|
let mut var_databaseDir = <String>::sse_decode(deserializer);
|
|
let mut var_dataDir = <String>::sse_decode(deserializer);
|
|
return crate::bridge::InitConfig {
|
|
database_dir: var_databaseDir,
|
|
data_dir: var_dataDir,
|
|
};
|
|
}
|
|
}
|
|
|
|
impl SseDecode for isize {
|
|
// Codec=Sse (Serialization based), see doc to use other codecs
|
|
fn sse_decode(deserializer: &mut flutter_rust_bridge::for_generated::SseDeserializer) -> Self {
|
|
deserializer.cursor.read_i64::<NativeEndian>().unwrap() as _
|
|
}
|
|
}
|
|
|
|
impl SseDecode for Vec<Vec<u8>> {
|
|
// Codec=Sse (Serialization based), see doc to use other codecs
|
|
fn sse_decode(deserializer: &mut flutter_rust_bridge::for_generated::SseDeserializer) -> Self {
|
|
let mut len_ = <i32>::sse_decode(deserializer);
|
|
let mut ans_ = Vec::with_capacity(len_ as usize);
|
|
for idx_ in 0..len_ {
|
|
ans_.push(<Vec<u8>>::sse_decode(deserializer));
|
|
}
|
|
return ans_;
|
|
}
|
|
}
|
|
|
|
impl SseDecode for Vec<crate::bridge::OtherPromotion> {
|
|
// Codec=Sse (Serialization based), see doc to use other codecs
|
|
fn sse_decode(deserializer: &mut flutter_rust_bridge::for_generated::SseDeserializer) -> Self {
|
|
let mut len_ = <i32>::sse_decode(deserializer);
|
|
let mut ans_ = Vec::with_capacity(len_ as usize);
|
|
for idx_ in 0..len_ {
|
|
ans_.push(<crate::bridge::OtherPromotion>::sse_decode(deserializer));
|
|
}
|
|
return ans_;
|
|
}
|
|
}
|
|
|
|
impl SseDecode for Vec<u8> {
|
|
// Codec=Sse (Serialization based), see doc to use other codecs
|
|
fn sse_decode(deserializer: &mut flutter_rust_bridge::for_generated::SseDeserializer) -> Self {
|
|
let mut len_ = <i32>::sse_decode(deserializer);
|
|
let mut ans_ = Vec::with_capacity(len_ as usize);
|
|
for idx_ in 0..len_ {
|
|
ans_.push(<u8>::sse_decode(deserializer));
|
|
}
|
|
return ans_;
|
|
}
|
|
}
|
|
|
|
impl SseDecode for Vec<(i64, Vec<u8>)> {
|
|
// Codec=Sse (Serialization based), see doc to use other codecs
|
|
fn sse_decode(deserializer: &mut flutter_rust_bridge::for_generated::SseDeserializer) -> Self {
|
|
let mut len_ = <i32>::sse_decode(deserializer);
|
|
let mut ans_ = Vec::with_capacity(len_ as usize);
|
|
for idx_ in 0..len_ {
|
|
ans_.push(<(i64, Vec<u8>)>::sse_decode(deserializer));
|
|
}
|
|
return ans_;
|
|
}
|
|
}
|
|
|
|
impl SseDecode for Option<String> {
|
|
// Codec=Sse (Serialization based), see doc to use other codecs
|
|
fn sse_decode(deserializer: &mut flutter_rust_bridge::for_generated::SseDeserializer) -> Self {
|
|
if (<bool>::sse_decode(deserializer)) {
|
|
return Some(<String>::sse_decode(deserializer));
|
|
} else {
|
|
return None;
|
|
}
|
|
}
|
|
}
|
|
|
|
impl SseDecode for Option<crate::bridge::AnnouncedUser> {
|
|
// Codec=Sse (Serialization based), see doc to use other codecs
|
|
fn sse_decode(deserializer: &mut flutter_rust_bridge::for_generated::SseDeserializer) -> Self {
|
|
if (<bool>::sse_decode(deserializer)) {
|
|
return Some(<crate::bridge::AnnouncedUser>::sse_decode(deserializer));
|
|
} else {
|
|
return None;
|
|
}
|
|
}
|
|
}
|
|
|
|
impl SseDecode for Option<i64> {
|
|
// Codec=Sse (Serialization based), see doc to use other codecs
|
|
fn sse_decode(deserializer: &mut flutter_rust_bridge::for_generated::SseDeserializer) -> Self {
|
|
if (<bool>::sse_decode(deserializer)) {
|
|
return Some(<i64>::sse_decode(deserializer));
|
|
} else {
|
|
return None;
|
|
}
|
|
}
|
|
}
|
|
|
|
impl SseDecode for Option<Vec<Vec<u8>>> {
|
|
// Codec=Sse (Serialization based), see doc to use other codecs
|
|
fn sse_decode(deserializer: &mut flutter_rust_bridge::for_generated::SseDeserializer) -> Self {
|
|
if (<bool>::sse_decode(deserializer)) {
|
|
return Some(<Vec<Vec<u8>>>::sse_decode(deserializer));
|
|
} else {
|
|
return None;
|
|
}
|
|
}
|
|
}
|
|
|
|
impl SseDecode for Option<Vec<crate::bridge::OtherPromotion>> {
|
|
// Codec=Sse (Serialization based), see doc to use other codecs
|
|
fn sse_decode(deserializer: &mut flutter_rust_bridge::for_generated::SseDeserializer) -> Self {
|
|
if (<bool>::sse_decode(deserializer)) {
|
|
return Some(<Vec<crate::bridge::OtherPromotion>>::sse_decode(
|
|
deserializer,
|
|
));
|
|
} else {
|
|
return None;
|
|
}
|
|
}
|
|
}
|
|
|
|
impl SseDecode for Option<Vec<u8>> {
|
|
// Codec=Sse (Serialization based), see doc to use other codecs
|
|
fn sse_decode(deserializer: &mut flutter_rust_bridge::for_generated::SseDeserializer) -> Self {
|
|
if (<bool>::sse_decode(deserializer)) {
|
|
return Some(<Vec<u8>>::sse_decode(deserializer));
|
|
} else {
|
|
return None;
|
|
}
|
|
}
|
|
}
|
|
|
|
impl SseDecode for crate::bridge::OtherPromotion {
|
|
// Codec=Sse (Serialization based), see doc to use other codecs
|
|
fn sse_decode(deserializer: &mut flutter_rust_bridge::for_generated::SseDeserializer) -> Self {
|
|
let mut var_promotionId = <u32>::sse_decode(deserializer);
|
|
let mut var_publicId = <i64>::sse_decode(deserializer);
|
|
let mut var_fromContactId = <i64>::sse_decode(deserializer);
|
|
let mut var_threshold = <u8>::sse_decode(deserializer);
|
|
let mut var_announcementShare = <Vec<u8>>::sse_decode(deserializer);
|
|
let mut var_publicKeyVerifiedTimestamp = <Option<i64>>::sse_decode(deserializer);
|
|
return crate::bridge::OtherPromotion {
|
|
promotion_id: var_promotionId,
|
|
public_id: var_publicId,
|
|
from_contact_id: var_fromContactId,
|
|
threshold: var_threshold,
|
|
announcement_share: var_announcementShare,
|
|
public_key_verified_timestamp: var_publicKeyVerifiedTimestamp,
|
|
};
|
|
}
|
|
}
|
|
|
|
impl SseDecode for (i64, Vec<u8>) {
|
|
// Codec=Sse (Serialization based), see doc to use other codecs
|
|
fn sse_decode(deserializer: &mut flutter_rust_bridge::for_generated::SseDeserializer) -> Self {
|
|
let mut var_field0 = <i64>::sse_decode(deserializer);
|
|
let mut var_field1 = <Vec<u8>>::sse_decode(deserializer);
|
|
return (var_field0, var_field1);
|
|
}
|
|
}
|
|
|
|
impl SseDecode for (Vec<u8>, i64) {
|
|
// Codec=Sse (Serialization based), see doc to use other codecs
|
|
fn sse_decode(deserializer: &mut flutter_rust_bridge::for_generated::SseDeserializer) -> Self {
|
|
let mut var_field0 = <Vec<u8>>::sse_decode(deserializer);
|
|
let mut var_field1 = <i64>::sse_decode(deserializer);
|
|
return (var_field0, var_field1);
|
|
}
|
|
}
|
|
|
|
impl SseDecode for (String, String) {
|
|
// Codec=Sse (Serialization based), see doc to use other codecs
|
|
fn sse_decode(deserializer: &mut flutter_rust_bridge::for_generated::SseDeserializer) -> Self {
|
|
let mut var_field0 = <String>::sse_decode(deserializer);
|
|
let mut var_field1 = <String>::sse_decode(deserializer);
|
|
return (var_field0, var_field1);
|
|
}
|
|
}
|
|
|
|
impl SseDecode for crate::bridge::wrapper::backup::RustBackupArchive {
|
|
// Codec=Sse (Serialization based), see doc to use other codecs
|
|
fn sse_decode(deserializer: &mut flutter_rust_bridge::for_generated::SseDeserializer) -> Self {
|
|
return crate::bridge::wrapper::backup::RustBackupArchive();
|
|
}
|
|
}
|
|
|
|
impl SseDecode for crate::bridge::wrapper::backup::RustBackupIdentity {
|
|
// Codec=Sse (Serialization based), see doc to use other codecs
|
|
fn sse_decode(deserializer: &mut flutter_rust_bridge::for_generated::SseDeserializer) -> Self {
|
|
return crate::bridge::wrapper::backup::RustBackupIdentity();
|
|
}
|
|
}
|
|
|
|
impl SseDecode for crate::bridge::wrapper::key_manager::RustKeyManager {
|
|
// Codec=Sse (Serialization based), see doc to use other codecs
|
|
fn sse_decode(deserializer: &mut flutter_rust_bridge::for_generated::SseDeserializer) -> Self {
|
|
return crate::bridge::wrapper::key_manager::RustKeyManager {};
|
|
}
|
|
}
|
|
|
|
impl SseDecode for u32 {
|
|
// Codec=Sse (Serialization based), see doc to use other codecs
|
|
fn sse_decode(deserializer: &mut flutter_rust_bridge::for_generated::SseDeserializer) -> Self {
|
|
deserializer.cursor.read_u32::<NativeEndian>().unwrap()
|
|
}
|
|
}
|
|
|
|
impl SseDecode for u8 {
|
|
// Codec=Sse (Serialization based), see doc to use other codecs
|
|
fn sse_decode(deserializer: &mut flutter_rust_bridge::for_generated::SseDeserializer) -> Self {
|
|
deserializer.cursor.read_u8().unwrap()
|
|
}
|
|
}
|
|
|
|
impl SseDecode for [u8; 32] {
|
|
// Codec=Sse (Serialization based), see doc to use other codecs
|
|
fn sse_decode(deserializer: &mut flutter_rust_bridge::for_generated::SseDeserializer) -> Self {
|
|
let mut inner = <Vec<u8>>::sse_decode(deserializer);
|
|
return flutter_rust_bridge::for_generated::from_vec_to_array(inner);
|
|
}
|
|
}
|
|
|
|
impl SseDecode for () {
|
|
// Codec=Sse (Serialization based), see doc to use other codecs
|
|
fn sse_decode(deserializer: &mut flutter_rust_bridge::for_generated::SseDeserializer) -> Self {}
|
|
}
|
|
|
|
impl SseDecode for usize {
|
|
// Codec=Sse (Serialization based), see doc to use other codecs
|
|
fn sse_decode(deserializer: &mut flutter_rust_bridge::for_generated::SseDeserializer) -> Self {
|
|
deserializer.cursor.read_u64::<NativeEndian>().unwrap() as _
|
|
}
|
|
}
|
|
|
|
impl SseDecode for i32 {
|
|
// Codec=Sse (Serialization based), see doc to use other codecs
|
|
fn sse_decode(deserializer: &mut flutter_rust_bridge::for_generated::SseDeserializer) -> Self {
|
|
deserializer.cursor.read_i32::<NativeEndian>().unwrap()
|
|
}
|
|
}
|
|
|
|
fn pde_ffi_dispatcher_primary_impl(
|
|
func_id: i32,
|
|
port: flutter_rust_bridge::for_generated::MessagePort,
|
|
ptr: flutter_rust_bridge::for_generated::PlatformGeneralizedUint8ListPtr,
|
|
rust_vec_len: i32,
|
|
data_len: i32,
|
|
) {
|
|
// Codec=Pde (Serialization + dispatch), see doc to use other codecs
|
|
match func_id {
|
|
1 => wire__crate__bridge__wrapper__user_discovery__flutter_user_discovery_get_current_version_impl(port, ptr, rust_vec_len, data_len),
|
|
2 => wire__crate__bridge__wrapper__user_discovery__flutter_user_discovery_get_new_messages_impl(port, ptr, rust_vec_len, data_len),
|
|
3 => wire__crate__bridge__wrapper__user_discovery__flutter_user_discovery_handle_new_messages_impl(port, ptr, rust_vec_len, data_len),
|
|
4 => wire__crate__bridge__wrapper__user_discovery__flutter_user_discovery_initialize_or_update_impl(port, ptr, rust_vec_len, data_len),
|
|
5 => wire__crate__bridge__wrapper__user_discovery__flutter_user_discovery_should_request_new_messages_impl(port, ptr, rust_vec_len, data_len),
|
|
6 => wire__crate__bridge__wrapper__user_discovery__flutter_user_discovery_update_verification_state_for_user_impl(port, ptr, rust_vec_len, data_len),
|
|
7 => wire__crate__bridge__callbacks__init_flutter_callbacks_impl(port, ptr, rust_vec_len, data_len),
|
|
8 => wire__crate__bridge__initialize_twonly_flutter_impl(port, ptr, rust_vec_len, data_len),
|
|
9 => wire__crate__bridge__wrapper__backup__rust_backup_archive_create_backup_archive_impl(port, ptr, rust_vec_len, data_len),
|
|
10 => wire__crate__bridge__wrapper__backup__rust_backup_archive_get_backup_download_token_impl(port, ptr, rust_vec_len, data_len),
|
|
11 => wire__crate__bridge__wrapper__backup__rust_backup_archive_restore_backup_archive_impl(port, ptr, rust_vec_len, data_len),
|
|
12 => wire__crate__bridge__wrapper__backup__rust_backup_identity_get_backup_id_impl(port, ptr, rust_vec_len, data_len),
|
|
13 => wire__crate__bridge__wrapper__backup__rust_backup_identity_get_backup_password_keys_impl(port, ptr, rust_vec_len, data_len),
|
|
14 => wire__crate__bridge__wrapper__backup__rust_backup_identity_get_identity_backup_bytes_impl(port, ptr, rust_vec_len, data_len),
|
|
15 => wire__crate__bridge__wrapper__backup__rust_backup_identity_import_backup_password_keys_impl(port, ptr, rust_vec_len, data_len),
|
|
16 => wire__crate__bridge__wrapper__backup__rust_backup_identity_restore_identity_backup_impl(port, ptr, rust_vec_len, data_len),
|
|
17 => wire__crate__bridge__wrapper__backup__rust_backup_identity_set_backup_password_keys_impl(port, ptr, rust_vec_len, data_len),
|
|
18 => wire__crate__bridge__wrapper__key_manager__rust_key_manager_get_login_token_impl(port, ptr, rust_vec_len, data_len),
|
|
19 => wire__crate__bridge__wrapper__key_manager__rust_key_manager_get_signal_identity_impl(port, ptr, rust_vec_len, data_len),
|
|
20 => wire__crate__bridge__wrapper__key_manager__rust_key_manager_get_user_id_impl(port, ptr, rust_vec_len, data_len),
|
|
21 => wire__crate__bridge__wrapper__key_manager__rust_key_manager_import_signal_identity_impl(port, ptr, rust_vec_len, data_len),
|
|
22 => wire__crate__bridge__wrapper__key_manager__rust_key_manager_load_signed_prekey_impl(port, ptr, rust_vec_len, data_len),
|
|
23 => wire__crate__bridge__wrapper__key_manager__rust_key_manager_load_signed_prekeys_impl(port, ptr, rust_vec_len, data_len),
|
|
24 => wire__crate__bridge__wrapper__key_manager__rust_key_manager_remove_key_manager_impl(port, ptr, rust_vec_len, data_len),
|
|
25 => wire__crate__bridge__wrapper__key_manager__rust_key_manager_remove_signed_prekey_impl(port, ptr, rust_vec_len, data_len),
|
|
26 => wire__crate__bridge__wrapper__key_manager__rust_key_manager_set_user_id_impl(port, ptr, rust_vec_len, data_len),
|
|
27 => wire__crate__bridge__wrapper__key_manager__rust_key_manager_store_signed_prekey_impl(port, ptr, rust_vec_len, data_len),
|
|
_ => unreachable!(),
|
|
}
|
|
}
|
|
|
|
fn pde_ffi_dispatcher_sync_impl(
|
|
func_id: i32,
|
|
ptr: flutter_rust_bridge::for_generated::PlatformGeneralizedUint8ListPtr,
|
|
rust_vec_len: i32,
|
|
data_len: i32,
|
|
) -> flutter_rust_bridge::for_generated::WireSyncRust2DartSse {
|
|
// Codec=Pde (Serialization + dispatch), see doc to use other codecs
|
|
match func_id {
|
|
_ => unreachable!(),
|
|
}
|
|
}
|
|
|
|
// Section: rust2dart
|
|
|
|
// Codec=Dco (DartCObject based), see doc to use other codecs
|
|
impl flutter_rust_bridge::IntoDart for FrbWrapper<crate::bridge::AnnouncedUser> {
|
|
fn into_dart(self) -> flutter_rust_bridge::for_generated::DartAbi {
|
|
[
|
|
self.0.user_id.into_into_dart().into_dart(),
|
|
self.0.public_key.into_into_dart().into_dart(),
|
|
self.0.public_id.into_into_dart().into_dart(),
|
|
]
|
|
.into_dart()
|
|
}
|
|
}
|
|
impl flutter_rust_bridge::for_generated::IntoDartExceptPrimitive
|
|
for FrbWrapper<crate::bridge::AnnouncedUser>
|
|
{
|
|
}
|
|
impl flutter_rust_bridge::IntoIntoDart<FrbWrapper<crate::bridge::AnnouncedUser>>
|
|
for crate::bridge::AnnouncedUser
|
|
{
|
|
fn into_into_dart(self) -> FrbWrapper<crate::bridge::AnnouncedUser> {
|
|
self.into()
|
|
}
|
|
}
|
|
// Codec=Dco (DartCObject based), see doc to use other codecs
|
|
impl flutter_rust_bridge::IntoDart for crate::keys::backup_password_keys::BackupPasswordKeys {
|
|
fn into_dart(self) -> flutter_rust_bridge::for_generated::DartAbi {
|
|
[
|
|
self.backup_id.into_into_dart().into_dart(),
|
|
self.encryption_key.into_into_dart().into_dart(),
|
|
]
|
|
.into_dart()
|
|
}
|
|
}
|
|
impl flutter_rust_bridge::for_generated::IntoDartExceptPrimitive
|
|
for crate::keys::backup_password_keys::BackupPasswordKeys
|
|
{
|
|
}
|
|
impl flutter_rust_bridge::IntoIntoDart<crate::keys::backup_password_keys::BackupPasswordKeys>
|
|
for crate::keys::backup_password_keys::BackupPasswordKeys
|
|
{
|
|
fn into_into_dart(self) -> crate::keys::backup_password_keys::BackupPasswordKeys {
|
|
self
|
|
}
|
|
}
|
|
// Codec=Dco (DartCObject based), see doc to use other codecs
|
|
impl flutter_rust_bridge::IntoDart
|
|
for crate::bridge::wrapper::user_discovery::FlutterUserDiscovery
|
|
{
|
|
fn into_dart(self) -> flutter_rust_bridge::for_generated::DartAbi {
|
|
Vec::<u8>::new().into_dart()
|
|
}
|
|
}
|
|
impl flutter_rust_bridge::for_generated::IntoDartExceptPrimitive
|
|
for crate::bridge::wrapper::user_discovery::FlutterUserDiscovery
|
|
{
|
|
}
|
|
impl flutter_rust_bridge::IntoIntoDart<crate::bridge::wrapper::user_discovery::FlutterUserDiscovery>
|
|
for crate::bridge::wrapper::user_discovery::FlutterUserDiscovery
|
|
{
|
|
fn into_into_dart(self) -> crate::bridge::wrapper::user_discovery::FlutterUserDiscovery {
|
|
self
|
|
}
|
|
}
|
|
// Codec=Dco (DartCObject based), see doc to use other codecs
|
|
impl flutter_rust_bridge::IntoDart for crate::bridge::InitConfig {
|
|
fn into_dart(self) -> flutter_rust_bridge::for_generated::DartAbi {
|
|
[
|
|
self.database_dir.into_into_dart().into_dart(),
|
|
self.data_dir.into_into_dart().into_dart(),
|
|
]
|
|
.into_dart()
|
|
}
|
|
}
|
|
impl flutter_rust_bridge::for_generated::IntoDartExceptPrimitive for crate::bridge::InitConfig {}
|
|
impl flutter_rust_bridge::IntoIntoDart<crate::bridge::InitConfig> for crate::bridge::InitConfig {
|
|
fn into_into_dart(self) -> crate::bridge::InitConfig {
|
|
self
|
|
}
|
|
}
|
|
// Codec=Dco (DartCObject based), see doc to use other codecs
|
|
impl flutter_rust_bridge::IntoDart for FrbWrapper<crate::bridge::OtherPromotion> {
|
|
fn into_dart(self) -> flutter_rust_bridge::for_generated::DartAbi {
|
|
[
|
|
self.0.promotion_id.into_into_dart().into_dart(),
|
|
self.0.public_id.into_into_dart().into_dart(),
|
|
self.0.from_contact_id.into_into_dart().into_dart(),
|
|
self.0.threshold.into_into_dart().into_dart(),
|
|
self.0.announcement_share.into_into_dart().into_dart(),
|
|
self.0
|
|
.public_key_verified_timestamp
|
|
.into_into_dart()
|
|
.into_dart(),
|
|
]
|
|
.into_dart()
|
|
}
|
|
}
|
|
impl flutter_rust_bridge::for_generated::IntoDartExceptPrimitive
|
|
for FrbWrapper<crate::bridge::OtherPromotion>
|
|
{
|
|
}
|
|
impl flutter_rust_bridge::IntoIntoDart<FrbWrapper<crate::bridge::OtherPromotion>>
|
|
for crate::bridge::OtherPromotion
|
|
{
|
|
fn into_into_dart(self) -> FrbWrapper<crate::bridge::OtherPromotion> {
|
|
self.into()
|
|
}
|
|
}
|
|
// Codec=Dco (DartCObject based), see doc to use other codecs
|
|
impl flutter_rust_bridge::IntoDart for crate::bridge::wrapper::backup::RustBackupArchive {
|
|
fn into_dart(self) -> flutter_rust_bridge::for_generated::DartAbi {
|
|
Vec::<u8>::new().into_dart()
|
|
}
|
|
}
|
|
impl flutter_rust_bridge::for_generated::IntoDartExceptPrimitive
|
|
for crate::bridge::wrapper::backup::RustBackupArchive
|
|
{
|
|
}
|
|
impl flutter_rust_bridge::IntoIntoDart<crate::bridge::wrapper::backup::RustBackupArchive>
|
|
for crate::bridge::wrapper::backup::RustBackupArchive
|
|
{
|
|
fn into_into_dart(self) -> crate::bridge::wrapper::backup::RustBackupArchive {
|
|
self
|
|
}
|
|
}
|
|
// Codec=Dco (DartCObject based), see doc to use other codecs
|
|
impl flutter_rust_bridge::IntoDart for crate::bridge::wrapper::backup::RustBackupIdentity {
|
|
fn into_dart(self) -> flutter_rust_bridge::for_generated::DartAbi {
|
|
Vec::<u8>::new().into_dart()
|
|
}
|
|
}
|
|
impl flutter_rust_bridge::for_generated::IntoDartExceptPrimitive
|
|
for crate::bridge::wrapper::backup::RustBackupIdentity
|
|
{
|
|
}
|
|
impl flutter_rust_bridge::IntoIntoDart<crate::bridge::wrapper::backup::RustBackupIdentity>
|
|
for crate::bridge::wrapper::backup::RustBackupIdentity
|
|
{
|
|
fn into_into_dart(self) -> crate::bridge::wrapper::backup::RustBackupIdentity {
|
|
self
|
|
}
|
|
}
|
|
// Codec=Dco (DartCObject based), see doc to use other codecs
|
|
impl flutter_rust_bridge::IntoDart for crate::bridge::wrapper::key_manager::RustKeyManager {
|
|
fn into_dart(self) -> flutter_rust_bridge::for_generated::DartAbi {
|
|
Vec::<u8>::new().into_dart()
|
|
}
|
|
}
|
|
impl flutter_rust_bridge::for_generated::IntoDartExceptPrimitive
|
|
for crate::bridge::wrapper::key_manager::RustKeyManager
|
|
{
|
|
}
|
|
impl flutter_rust_bridge::IntoIntoDart<crate::bridge::wrapper::key_manager::RustKeyManager>
|
|
for crate::bridge::wrapper::key_manager::RustKeyManager
|
|
{
|
|
fn into_into_dart(self) -> crate::bridge::wrapper::key_manager::RustKeyManager {
|
|
self
|
|
}
|
|
}
|
|
|
|
impl SseEncode for flutter_rust_bridge::for_generated::anyhow::Error {
|
|
// Codec=Sse (Serialization based), see doc to use other codecs
|
|
fn sse_encode(self, serializer: &mut flutter_rust_bridge::for_generated::SseSerializer) {
|
|
<String>::sse_encode(format!("{:?}", self), serializer);
|
|
}
|
|
}
|
|
|
|
impl SseEncode for flutter_rust_bridge::DartOpaque {
|
|
// Codec=Sse (Serialization based), see doc to use other codecs
|
|
fn sse_encode(self, serializer: &mut flutter_rust_bridge::for_generated::SseSerializer) {
|
|
<usize>::sse_encode(self.encode(), serializer);
|
|
}
|
|
}
|
|
|
|
impl SseEncode for std::collections::HashMap<i64, Vec<u8>> {
|
|
// Codec=Sse (Serialization based), see doc to use other codecs
|
|
fn sse_encode(self, serializer: &mut flutter_rust_bridge::for_generated::SseSerializer) {
|
|
<Vec<(i64, Vec<u8>)>>::sse_encode(self.into_iter().collect(), serializer);
|
|
}
|
|
}
|
|
|
|
impl SseEncode for StreamSink<String, flutter_rust_bridge::for_generated::SseCodec> {
|
|
// Codec=Sse (Serialization based), see doc to use other codecs
|
|
fn sse_encode(self, serializer: &mut flutter_rust_bridge::for_generated::SseSerializer) {
|
|
unimplemented!("")
|
|
}
|
|
}
|
|
|
|
impl SseEncode for String {
|
|
// Codec=Sse (Serialization based), see doc to use other codecs
|
|
fn sse_encode(self, serializer: &mut flutter_rust_bridge::for_generated::SseSerializer) {
|
|
<Vec<u8>>::sse_encode(self.into_bytes(), serializer);
|
|
}
|
|
}
|
|
|
|
impl SseEncode for crate::bridge::AnnouncedUser {
|
|
// Codec=Sse (Serialization based), see doc to use other codecs
|
|
fn sse_encode(self, serializer: &mut flutter_rust_bridge::for_generated::SseSerializer) {
|
|
<i64>::sse_encode(self.user_id, serializer);
|
|
<Vec<u8>>::sse_encode(self.public_key, serializer);
|
|
<i64>::sse_encode(self.public_id, serializer);
|
|
}
|
|
}
|
|
|
|
impl SseEncode for crate::keys::backup_password_keys::BackupPasswordKeys {
|
|
// Codec=Sse (Serialization based), see doc to use other codecs
|
|
fn sse_encode(self, serializer: &mut flutter_rust_bridge::for_generated::SseSerializer) {
|
|
<[u8; 32]>::sse_encode(self.backup_id, serializer);
|
|
<[u8; 32]>::sse_encode(self.encryption_key, serializer);
|
|
}
|
|
}
|
|
|
|
impl SseEncode for bool {
|
|
// Codec=Sse (Serialization based), see doc to use other codecs
|
|
fn sse_encode(self, serializer: &mut flutter_rust_bridge::for_generated::SseSerializer) {
|
|
serializer.cursor.write_u8(self as _).unwrap();
|
|
}
|
|
}
|
|
|
|
impl SseEncode for crate::bridge::wrapper::user_discovery::FlutterUserDiscovery {
|
|
// Codec=Sse (Serialization based), see doc to use other codecs
|
|
fn sse_encode(self, serializer: &mut flutter_rust_bridge::for_generated::SseSerializer) {}
|
|
}
|
|
|
|
impl SseEncode for i64 {
|
|
// Codec=Sse (Serialization based), see doc to use other codecs
|
|
fn sse_encode(self, serializer: &mut flutter_rust_bridge::for_generated::SseSerializer) {
|
|
serializer.cursor.write_i64::<NativeEndian>(self).unwrap();
|
|
}
|
|
}
|
|
|
|
impl SseEncode for crate::bridge::InitConfig {
|
|
// Codec=Sse (Serialization based), see doc to use other codecs
|
|
fn sse_encode(self, serializer: &mut flutter_rust_bridge::for_generated::SseSerializer) {
|
|
<String>::sse_encode(self.database_dir, serializer);
|
|
<String>::sse_encode(self.data_dir, serializer);
|
|
}
|
|
}
|
|
|
|
impl SseEncode for isize {
|
|
// Codec=Sse (Serialization based), see doc to use other codecs
|
|
fn sse_encode(self, serializer: &mut flutter_rust_bridge::for_generated::SseSerializer) {
|
|
serializer
|
|
.cursor
|
|
.write_i64::<NativeEndian>(self as _)
|
|
.unwrap();
|
|
}
|
|
}
|
|
|
|
impl SseEncode for Vec<Vec<u8>> {
|
|
// Codec=Sse (Serialization based), see doc to use other codecs
|
|
fn sse_encode(self, serializer: &mut flutter_rust_bridge::for_generated::SseSerializer) {
|
|
<i32>::sse_encode(self.len() as _, serializer);
|
|
for item in self {
|
|
<Vec<u8>>::sse_encode(item, serializer);
|
|
}
|
|
}
|
|
}
|
|
|
|
impl SseEncode for Vec<crate::bridge::OtherPromotion> {
|
|
// Codec=Sse (Serialization based), see doc to use other codecs
|
|
fn sse_encode(self, serializer: &mut flutter_rust_bridge::for_generated::SseSerializer) {
|
|
<i32>::sse_encode(self.len() as _, serializer);
|
|
for item in self {
|
|
<crate::bridge::OtherPromotion>::sse_encode(item, serializer);
|
|
}
|
|
}
|
|
}
|
|
|
|
impl SseEncode for Vec<u8> {
|
|
// Codec=Sse (Serialization based), see doc to use other codecs
|
|
fn sse_encode(self, serializer: &mut flutter_rust_bridge::for_generated::SseSerializer) {
|
|
<i32>::sse_encode(self.len() as _, serializer);
|
|
for item in self {
|
|
<u8>::sse_encode(item, serializer);
|
|
}
|
|
}
|
|
}
|
|
|
|
impl SseEncode for Vec<(i64, Vec<u8>)> {
|
|
// Codec=Sse (Serialization based), see doc to use other codecs
|
|
fn sse_encode(self, serializer: &mut flutter_rust_bridge::for_generated::SseSerializer) {
|
|
<i32>::sse_encode(self.len() as _, serializer);
|
|
for item in self {
|
|
<(i64, Vec<u8>)>::sse_encode(item, serializer);
|
|
}
|
|
}
|
|
}
|
|
|
|
impl SseEncode for Option<String> {
|
|
// Codec=Sse (Serialization based), see doc to use other codecs
|
|
fn sse_encode(self, serializer: &mut flutter_rust_bridge::for_generated::SseSerializer) {
|
|
<bool>::sse_encode(self.is_some(), serializer);
|
|
if let Some(value) = self {
|
|
<String>::sse_encode(value, serializer);
|
|
}
|
|
}
|
|
}
|
|
|
|
impl SseEncode for Option<crate::bridge::AnnouncedUser> {
|
|
// Codec=Sse (Serialization based), see doc to use other codecs
|
|
fn sse_encode(self, serializer: &mut flutter_rust_bridge::for_generated::SseSerializer) {
|
|
<bool>::sse_encode(self.is_some(), serializer);
|
|
if let Some(value) = self {
|
|
<crate::bridge::AnnouncedUser>::sse_encode(value, serializer);
|
|
}
|
|
}
|
|
}
|
|
|
|
impl SseEncode for Option<i64> {
|
|
// Codec=Sse (Serialization based), see doc to use other codecs
|
|
fn sse_encode(self, serializer: &mut flutter_rust_bridge::for_generated::SseSerializer) {
|
|
<bool>::sse_encode(self.is_some(), serializer);
|
|
if let Some(value) = self {
|
|
<i64>::sse_encode(value, serializer);
|
|
}
|
|
}
|
|
}
|
|
|
|
impl SseEncode for Option<Vec<Vec<u8>>> {
|
|
// Codec=Sse (Serialization based), see doc to use other codecs
|
|
fn sse_encode(self, serializer: &mut flutter_rust_bridge::for_generated::SseSerializer) {
|
|
<bool>::sse_encode(self.is_some(), serializer);
|
|
if let Some(value) = self {
|
|
<Vec<Vec<u8>>>::sse_encode(value, serializer);
|
|
}
|
|
}
|
|
}
|
|
|
|
impl SseEncode for Option<Vec<crate::bridge::OtherPromotion>> {
|
|
// Codec=Sse (Serialization based), see doc to use other codecs
|
|
fn sse_encode(self, serializer: &mut flutter_rust_bridge::for_generated::SseSerializer) {
|
|
<bool>::sse_encode(self.is_some(), serializer);
|
|
if let Some(value) = self {
|
|
<Vec<crate::bridge::OtherPromotion>>::sse_encode(value, serializer);
|
|
}
|
|
}
|
|
}
|
|
|
|
impl SseEncode for Option<Vec<u8>> {
|
|
// Codec=Sse (Serialization based), see doc to use other codecs
|
|
fn sse_encode(self, serializer: &mut flutter_rust_bridge::for_generated::SseSerializer) {
|
|
<bool>::sse_encode(self.is_some(), serializer);
|
|
if let Some(value) = self {
|
|
<Vec<u8>>::sse_encode(value, serializer);
|
|
}
|
|
}
|
|
}
|
|
|
|
impl SseEncode for crate::bridge::OtherPromotion {
|
|
// Codec=Sse (Serialization based), see doc to use other codecs
|
|
fn sse_encode(self, serializer: &mut flutter_rust_bridge::for_generated::SseSerializer) {
|
|
<u32>::sse_encode(self.promotion_id, serializer);
|
|
<i64>::sse_encode(self.public_id, serializer);
|
|
<i64>::sse_encode(self.from_contact_id, serializer);
|
|
<u8>::sse_encode(self.threshold, serializer);
|
|
<Vec<u8>>::sse_encode(self.announcement_share, serializer);
|
|
<Option<i64>>::sse_encode(self.public_key_verified_timestamp, serializer);
|
|
}
|
|
}
|
|
|
|
impl SseEncode for (i64, Vec<u8>) {
|
|
// Codec=Sse (Serialization based), see doc to use other codecs
|
|
fn sse_encode(self, serializer: &mut flutter_rust_bridge::for_generated::SseSerializer) {
|
|
<i64>::sse_encode(self.0, serializer);
|
|
<Vec<u8>>::sse_encode(self.1, serializer);
|
|
}
|
|
}
|
|
|
|
impl SseEncode for (Vec<u8>, i64) {
|
|
// Codec=Sse (Serialization based), see doc to use other codecs
|
|
fn sse_encode(self, serializer: &mut flutter_rust_bridge::for_generated::SseSerializer) {
|
|
<Vec<u8>>::sse_encode(self.0, serializer);
|
|
<i64>::sse_encode(self.1, serializer);
|
|
}
|
|
}
|
|
|
|
impl SseEncode for (String, String) {
|
|
// Codec=Sse (Serialization based), see doc to use other codecs
|
|
fn sse_encode(self, serializer: &mut flutter_rust_bridge::for_generated::SseSerializer) {
|
|
<String>::sse_encode(self.0, serializer);
|
|
<String>::sse_encode(self.1, serializer);
|
|
}
|
|
}
|
|
|
|
impl SseEncode for crate::bridge::wrapper::backup::RustBackupArchive {
|
|
// Codec=Sse (Serialization based), see doc to use other codecs
|
|
fn sse_encode(self, serializer: &mut flutter_rust_bridge::for_generated::SseSerializer) {}
|
|
}
|
|
|
|
impl SseEncode for crate::bridge::wrapper::backup::RustBackupIdentity {
|
|
// Codec=Sse (Serialization based), see doc to use other codecs
|
|
fn sse_encode(self, serializer: &mut flutter_rust_bridge::for_generated::SseSerializer) {}
|
|
}
|
|
|
|
impl SseEncode for crate::bridge::wrapper::key_manager::RustKeyManager {
|
|
// Codec=Sse (Serialization based), see doc to use other codecs
|
|
fn sse_encode(self, serializer: &mut flutter_rust_bridge::for_generated::SseSerializer) {}
|
|
}
|
|
|
|
impl SseEncode for u32 {
|
|
// Codec=Sse (Serialization based), see doc to use other codecs
|
|
fn sse_encode(self, serializer: &mut flutter_rust_bridge::for_generated::SseSerializer) {
|
|
serializer.cursor.write_u32::<NativeEndian>(self).unwrap();
|
|
}
|
|
}
|
|
|
|
impl SseEncode for u8 {
|
|
// Codec=Sse (Serialization based), see doc to use other codecs
|
|
fn sse_encode(self, serializer: &mut flutter_rust_bridge::for_generated::SseSerializer) {
|
|
serializer.cursor.write_u8(self).unwrap();
|
|
}
|
|
}
|
|
|
|
impl SseEncode for [u8; 32] {
|
|
// Codec=Sse (Serialization based), see doc to use other codecs
|
|
fn sse_encode(self, serializer: &mut flutter_rust_bridge::for_generated::SseSerializer) {
|
|
<Vec<u8>>::sse_encode(
|
|
{
|
|
let boxed: Box<[_]> = Box::new(self);
|
|
boxed.into_vec()
|
|
},
|
|
serializer,
|
|
);
|
|
}
|
|
}
|
|
|
|
impl SseEncode for () {
|
|
// Codec=Sse (Serialization based), see doc to use other codecs
|
|
fn sse_encode(self, serializer: &mut flutter_rust_bridge::for_generated::SseSerializer) {}
|
|
}
|
|
|
|
impl SseEncode for usize {
|
|
// Codec=Sse (Serialization based), see doc to use other codecs
|
|
fn sse_encode(self, serializer: &mut flutter_rust_bridge::for_generated::SseSerializer) {
|
|
serializer
|
|
.cursor
|
|
.write_u64::<NativeEndian>(self as _)
|
|
.unwrap();
|
|
}
|
|
}
|
|
|
|
impl SseEncode for i32 {
|
|
// Codec=Sse (Serialization based), see doc to use other codecs
|
|
fn sse_encode(self, serializer: &mut flutter_rust_bridge::for_generated::SseSerializer) {
|
|
serializer.cursor.write_i32::<NativeEndian>(self).unwrap();
|
|
}
|
|
}
|
|
|
|
#[cfg(not(target_family = "wasm"))]
|
|
mod io {
|
|
// This file is automatically generated, so please do not edit it.
|
|
// @generated by `flutter_rust_bridge`@ 2.12.0.
|
|
|
|
// Section: imports
|
|
|
|
use super::*;
|
|
use flutter_rust_bridge::for_generated::byteorder::{
|
|
NativeEndian, ReadBytesExt, WriteBytesExt,
|
|
};
|
|
use flutter_rust_bridge::for_generated::{transform_result_dco, Lifetimeable, Lockable};
|
|
use flutter_rust_bridge::{Handler, IntoIntoDart};
|
|
|
|
// Section: boilerplate
|
|
|
|
flutter_rust_bridge::frb_generated_boilerplate_io!();
|
|
}
|
|
#[cfg(not(target_family = "wasm"))]
|
|
pub use io::*;
|
|
|
|
/// cbindgen:ignore
|
|
#[cfg(target_family = "wasm")]
|
|
mod web {
|
|
// This file is automatically generated, so please do not edit it.
|
|
// @generated by `flutter_rust_bridge`@ 2.12.0.
|
|
|
|
// Section: imports
|
|
|
|
use super::*;
|
|
use flutter_rust_bridge::for_generated::byteorder::{
|
|
NativeEndian, ReadBytesExt, WriteBytesExt,
|
|
};
|
|
use flutter_rust_bridge::for_generated::wasm_bindgen;
|
|
use flutter_rust_bridge::for_generated::wasm_bindgen::prelude::*;
|
|
use flutter_rust_bridge::for_generated::{transform_result_dco, Lifetimeable, Lockable};
|
|
use flutter_rust_bridge::{Handler, IntoIntoDart};
|
|
|
|
// Section: boilerplate
|
|
|
|
flutter_rust_bridge::frb_generated_boilerplate_web!();
|
|
}
|
|
#[cfg(target_family = "wasm")]
|
|
pub use web::*;
|