mirror of
https://github.com/aljazceru/turso.git
synced 2025-12-31 06:54:21 +01:00
1906 lines
75 KiB
Rust
1906 lines
75 KiB
Rust
// This file is automatically generated, so please do not edit it.
|
|
// @generated by `flutter_rust_bridge`@ 2.10.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::needless_borrow
|
|
)]
|
|
|
|
// Section: imports
|
|
|
|
use crate::api::connection::*;
|
|
use crate::api::statement::*;
|
|
use crate::helpers::wrapper::*;
|
|
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.10.0";
|
|
pub(crate) const FLUTTER_RUST_BRIDGE_CODEGEN_CONTENT_HASH: i32 = -2084080956;
|
|
|
|
// Section: executor
|
|
|
|
flutter_rust_bridge::frb_generated_default_handler!();
|
|
|
|
// Section: wire_funcs
|
|
|
|
fn wire__crate__api__connection__RustConnection_execute_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: "RustConnection_execute",
|
|
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_that = <RustOpaqueMoi<
|
|
flutter_rust_bridge::for_generated::RustAutoOpaqueInner<RustConnection>,
|
|
>>::sse_decode(&mut deserializer);
|
|
let api_sql = <String>::sse_decode(&mut deserializer);
|
|
let api_params = <crate::helpers::params::Params>::sse_decode(&mut deserializer);
|
|
deserializer.end();
|
|
move |context| async move {
|
|
transform_result_sse::<_, ()>(
|
|
(move || async move {
|
|
let mut api_that_guard = None;
|
|
let decode_indices_ =
|
|
flutter_rust_bridge::for_generated::lockable_compute_decode_order(
|
|
vec![flutter_rust_bridge::for_generated::LockableOrderInfo::new(
|
|
&api_that, 0, false,
|
|
)],
|
|
);
|
|
for i in decode_indices_ {
|
|
match i {
|
|
0 => {
|
|
api_that_guard =
|
|
Some(api_that.lockable_decode_async_ref().await)
|
|
}
|
|
_ => unreachable!(),
|
|
}
|
|
}
|
|
let api_that_guard = api_that_guard.unwrap();
|
|
let output_ok = Result::<_, ()>::Ok(
|
|
crate::api::connection::RustConnection::execute(
|
|
&*api_that_guard,
|
|
api_sql,
|
|
api_params,
|
|
)
|
|
.await,
|
|
)?;
|
|
Ok(output_ok)
|
|
})()
|
|
.await,
|
|
)
|
|
}
|
|
},
|
|
)
|
|
}
|
|
fn wire__crate__api__connection__RustConnection_new_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: "RustConnection_new",
|
|
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_connection = <Wrapper<Arc<Connection>>>::sse_decode(&mut deserializer);
|
|
deserializer.end();
|
|
move |context| {
|
|
transform_result_sse::<_, ()>((move || {
|
|
let output_ok = Result::<_, ()>::Ok(
|
|
crate::api::connection::RustConnection::new(api_connection),
|
|
)?;
|
|
Ok(output_ok)
|
|
})())
|
|
}
|
|
},
|
|
)
|
|
}
|
|
fn wire__crate__api__connection__RustConnection_prepare_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: "RustConnection_prepare",
|
|
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_that = <RustOpaqueMoi<
|
|
flutter_rust_bridge::for_generated::RustAutoOpaqueInner<RustConnection>,
|
|
>>::sse_decode(&mut deserializer);
|
|
let api_sql = <String>::sse_decode(&mut deserializer);
|
|
deserializer.end();
|
|
move |context| async move {
|
|
transform_result_sse::<_, ()>(
|
|
(move || async move {
|
|
let mut api_that_guard = None;
|
|
let decode_indices_ =
|
|
flutter_rust_bridge::for_generated::lockable_compute_decode_order(
|
|
vec![flutter_rust_bridge::for_generated::LockableOrderInfo::new(
|
|
&api_that, 0, false,
|
|
)],
|
|
);
|
|
for i in decode_indices_ {
|
|
match i {
|
|
0 => {
|
|
api_that_guard =
|
|
Some(api_that.lockable_decode_async_ref().await)
|
|
}
|
|
_ => unreachable!(),
|
|
}
|
|
}
|
|
let api_that_guard = api_that_guard.unwrap();
|
|
let output_ok = Result::<_, ()>::Ok(
|
|
crate::api::connection::RustConnection::prepare(
|
|
&*api_that_guard,
|
|
api_sql,
|
|
)
|
|
.await,
|
|
)?;
|
|
Ok(output_ok)
|
|
})()
|
|
.await,
|
|
)
|
|
}
|
|
},
|
|
)
|
|
}
|
|
fn wire__crate__api__connection__RustConnection_query_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: "RustConnection_query",
|
|
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_that = <RustOpaqueMoi<
|
|
flutter_rust_bridge::for_generated::RustAutoOpaqueInner<RustConnection>,
|
|
>>::sse_decode(&mut deserializer);
|
|
let api_sql = <String>::sse_decode(&mut deserializer);
|
|
let api_params = <crate::helpers::params::Params>::sse_decode(&mut deserializer);
|
|
deserializer.end();
|
|
move |context| async move {
|
|
transform_result_sse::<_, ()>(
|
|
(move || async move {
|
|
let mut api_that_guard = None;
|
|
let decode_indices_ =
|
|
flutter_rust_bridge::for_generated::lockable_compute_decode_order(
|
|
vec![flutter_rust_bridge::for_generated::LockableOrderInfo::new(
|
|
&api_that, 0, false,
|
|
)],
|
|
);
|
|
for i in decode_indices_ {
|
|
match i {
|
|
0 => {
|
|
api_that_guard =
|
|
Some(api_that.lockable_decode_async_ref().await)
|
|
}
|
|
_ => unreachable!(),
|
|
}
|
|
}
|
|
let api_that_guard = api_that_guard.unwrap();
|
|
let output_ok = Result::<_, ()>::Ok(
|
|
crate::api::connection::RustConnection::query(
|
|
&*api_that_guard,
|
|
api_sql,
|
|
api_params,
|
|
)
|
|
.await,
|
|
)?;
|
|
Ok(output_ok)
|
|
})()
|
|
.await,
|
|
)
|
|
}
|
|
},
|
|
)
|
|
}
|
|
fn wire__crate__api__statement__RustStatement_execute_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: "RustStatement_execute",
|
|
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_that = <RustOpaqueMoi<
|
|
flutter_rust_bridge::for_generated::RustAutoOpaqueInner<RustStatement>,
|
|
>>::sse_decode(&mut deserializer);
|
|
let api_params = <crate::helpers::params::Params>::sse_decode(&mut deserializer);
|
|
deserializer.end();
|
|
move |context| async move {
|
|
transform_result_sse::<_, ()>(
|
|
(move || async move {
|
|
let mut api_that_guard = None;
|
|
let decode_indices_ =
|
|
flutter_rust_bridge::for_generated::lockable_compute_decode_order(
|
|
vec![flutter_rust_bridge::for_generated::LockableOrderInfo::new(
|
|
&api_that, 0, true,
|
|
)],
|
|
);
|
|
for i in decode_indices_ {
|
|
match i {
|
|
0 => {
|
|
api_that_guard =
|
|
Some(api_that.lockable_decode_async_ref_mut().await)
|
|
}
|
|
_ => unreachable!(),
|
|
}
|
|
}
|
|
let mut api_that_guard = api_that_guard.unwrap();
|
|
let output_ok = Result::<_, ()>::Ok(
|
|
crate::api::statement::RustStatement::execute(
|
|
&mut *api_that_guard,
|
|
api_params,
|
|
)
|
|
.await,
|
|
)?;
|
|
Ok(output_ok)
|
|
})()
|
|
.await,
|
|
)
|
|
}
|
|
},
|
|
)
|
|
}
|
|
fn wire__crate__api__statement__RustStatement_new_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: "RustStatement_new",
|
|
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_statement = <Wrapper<Statement>>::sse_decode(&mut deserializer);
|
|
let api_connection = <Wrapper<Arc<Connection>>>::sse_decode(&mut deserializer);
|
|
deserializer.end();
|
|
move |context| {
|
|
transform_result_sse::<_, ()>((move || {
|
|
let output_ok = Result::<_, ()>::Ok(
|
|
crate::api::statement::RustStatement::new(api_statement, api_connection),
|
|
)?;
|
|
Ok(output_ok)
|
|
})())
|
|
}
|
|
},
|
|
)
|
|
}
|
|
fn wire__crate__api__statement__RustStatement_query_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: "RustStatement_query",
|
|
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_that = <RustOpaqueMoi<
|
|
flutter_rust_bridge::for_generated::RustAutoOpaqueInner<RustStatement>,
|
|
>>::sse_decode(&mut deserializer);
|
|
let api_params = <crate::helpers::params::Params>::sse_decode(&mut deserializer);
|
|
deserializer.end();
|
|
move |context| async move {
|
|
transform_result_sse::<_, ()>(
|
|
(move || async move {
|
|
let mut api_that_guard = None;
|
|
let decode_indices_ =
|
|
flutter_rust_bridge::for_generated::lockable_compute_decode_order(
|
|
vec![flutter_rust_bridge::for_generated::LockableOrderInfo::new(
|
|
&api_that, 0, true,
|
|
)],
|
|
);
|
|
for i in decode_indices_ {
|
|
match i {
|
|
0 => {
|
|
api_that_guard =
|
|
Some(api_that.lockable_decode_async_ref_mut().await)
|
|
}
|
|
_ => unreachable!(),
|
|
}
|
|
}
|
|
let mut api_that_guard = api_that_guard.unwrap();
|
|
let output_ok = Result::<_, ()>::Ok(
|
|
crate::api::statement::RustStatement::query(
|
|
&mut *api_that_guard,
|
|
api_params,
|
|
)
|
|
.await,
|
|
)?;
|
|
Ok(output_ok)
|
|
})()
|
|
.await,
|
|
)
|
|
}
|
|
},
|
|
)
|
|
}
|
|
fn wire__crate__api__statement__RustStatement_reset_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: "RustStatement_reset",
|
|
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_that = <RustOpaqueMoi<
|
|
flutter_rust_bridge::for_generated::RustAutoOpaqueInner<RustStatement>,
|
|
>>::sse_decode(&mut deserializer);
|
|
deserializer.end();
|
|
move |context| async move {
|
|
transform_result_sse::<_, ()>(
|
|
(move || async move {
|
|
let mut api_that_guard = None;
|
|
let decode_indices_ =
|
|
flutter_rust_bridge::for_generated::lockable_compute_decode_order(
|
|
vec![flutter_rust_bridge::for_generated::LockableOrderInfo::new(
|
|
&api_that, 0, true,
|
|
)],
|
|
);
|
|
for i in decode_indices_ {
|
|
match i {
|
|
0 => {
|
|
api_that_guard =
|
|
Some(api_that.lockable_decode_async_ref_mut().await)
|
|
}
|
|
_ => unreachable!(),
|
|
}
|
|
}
|
|
let mut api_that_guard = api_that_guard.unwrap();
|
|
let output_ok = Result::<_, ()>::Ok({
|
|
crate::api::statement::RustStatement::reset(&mut *api_that_guard).await;
|
|
})?;
|
|
Ok(output_ok)
|
|
})()
|
|
.await,
|
|
)
|
|
}
|
|
},
|
|
)
|
|
}
|
|
fn wire__crate__api__connect__connect_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: "connect",
|
|
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_args = <crate::api::connect::ConnectArgs>::sse_decode(&mut deserializer);
|
|
deserializer.end();
|
|
move |context| async move {
|
|
transform_result_sse::<_, ()>(
|
|
(move || async move {
|
|
let output_ok =
|
|
Result::<_, ()>::Ok(crate::api::connect::connect(api_args).await)?;
|
|
Ok(output_ok)
|
|
})()
|
|
.await,
|
|
)
|
|
}
|
|
},
|
|
)
|
|
}
|
|
fn wire__crate__api__init__init_app_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_app",
|
|
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| {
|
|
transform_result_sse::<_, ()>((move || {
|
|
let output_ok = Result::<_, ()>::Ok({
|
|
crate::api::init::init_app();
|
|
})?;
|
|
Ok(output_ok)
|
|
})())
|
|
}
|
|
},
|
|
)
|
|
}
|
|
|
|
// Section: related_funcs
|
|
|
|
flutter_rust_bridge::frb_generated_moi_arc_impl_value!(
|
|
flutter_rust_bridge::for_generated::RustAutoOpaqueInner<RustConnection>
|
|
);
|
|
flutter_rust_bridge::frb_generated_moi_arc_impl_value!(
|
|
flutter_rust_bridge::for_generated::RustAutoOpaqueInner<RustStatement>
|
|
);
|
|
flutter_rust_bridge::frb_generated_moi_arc_impl_value!(
|
|
flutter_rust_bridge::for_generated::RustAutoOpaqueInner<Wrapper<Arc<Connection>>>
|
|
);
|
|
flutter_rust_bridge::frb_generated_moi_arc_impl_value!(
|
|
flutter_rust_bridge::for_generated::RustAutoOpaqueInner<Wrapper<Statement>>
|
|
);
|
|
|
|
// Section: dart2rust
|
|
|
|
impl SseDecode for RustConnection {
|
|
// 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 = <RustOpaqueMoi<
|
|
flutter_rust_bridge::for_generated::RustAutoOpaqueInner<RustConnection>,
|
|
>>::sse_decode(deserializer);
|
|
return flutter_rust_bridge::for_generated::rust_auto_opaque_decode_owned(inner);
|
|
}
|
|
}
|
|
|
|
impl SseDecode for RustStatement {
|
|
// 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 = <RustOpaqueMoi<
|
|
flutter_rust_bridge::for_generated::RustAutoOpaqueInner<RustStatement>,
|
|
>>::sse_decode(deserializer);
|
|
return flutter_rust_bridge::for_generated::rust_auto_opaque_decode_owned(inner);
|
|
}
|
|
}
|
|
|
|
impl SseDecode for Wrapper<Arc<Connection>> {
|
|
// 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 = <RustOpaqueMoi<
|
|
flutter_rust_bridge::for_generated::RustAutoOpaqueInner<Wrapper<Arc<Connection>>>,
|
|
>>::sse_decode(deserializer);
|
|
return flutter_rust_bridge::for_generated::rust_auto_opaque_decode_owned(inner);
|
|
}
|
|
}
|
|
|
|
impl SseDecode for Wrapper<Statement> {
|
|
// 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 = <RustOpaqueMoi<
|
|
flutter_rust_bridge::for_generated::RustAutoOpaqueInner<Wrapper<Statement>>,
|
|
>>::sse_decode(deserializer);
|
|
return flutter_rust_bridge::for_generated::rust_auto_opaque_decode_owned(inner);
|
|
}
|
|
}
|
|
|
|
impl SseDecode for std::collections::HashMap<String, crate::helpers::return_value::ReturnValue> {
|
|
// 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<(String, crate::helpers::return_value::ReturnValue)>>::sse_decode(deserializer);
|
|
return inner.into_iter().collect();
|
|
}
|
|
}
|
|
|
|
impl SseDecode
|
|
for RustOpaqueMoi<flutter_rust_bridge::for_generated::RustAutoOpaqueInner<RustConnection>>
|
|
{
|
|
// 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 decode_rust_opaque_moi(inner);
|
|
}
|
|
}
|
|
|
|
impl SseDecode
|
|
for RustOpaqueMoi<flutter_rust_bridge::for_generated::RustAutoOpaqueInner<RustStatement>>
|
|
{
|
|
// 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 decode_rust_opaque_moi(inner);
|
|
}
|
|
}
|
|
|
|
impl SseDecode
|
|
for RustOpaqueMoi<
|
|
flutter_rust_bridge::for_generated::RustAutoOpaqueInner<Wrapper<Arc<Connection>>>,
|
|
>
|
|
{
|
|
// 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 decode_rust_opaque_moi(inner);
|
|
}
|
|
}
|
|
|
|
impl SseDecode
|
|
for RustOpaqueMoi<flutter_rust_bridge::for_generated::RustAutoOpaqueInner<Wrapper<Statement>>>
|
|
{
|
|
// 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 decode_rust_opaque_moi(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 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::api::connect::ConnectArgs {
|
|
// 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_url = <String>::sse_decode(deserializer);
|
|
let mut var_authToken = <Option<String>>::sse_decode(deserializer);
|
|
let mut var_syncUrl = <Option<String>>::sse_decode(deserializer);
|
|
let mut var_syncIntervalSeconds = <Option<u64>>::sse_decode(deserializer);
|
|
let mut var_encryptionKey = <Option<String>>::sse_decode(deserializer);
|
|
let mut var_readYourWrites = <Option<bool>>::sse_decode(deserializer);
|
|
let mut var_openFlags = <Option<crate::api::connect::OpenFlags>>::sse_decode(deserializer);
|
|
let mut var_offline = <Option<bool>>::sse_decode(deserializer);
|
|
return crate::api::connect::ConnectArgs {
|
|
url: var_url,
|
|
auth_token: var_authToken,
|
|
sync_url: var_syncUrl,
|
|
sync_interval_seconds: var_syncIntervalSeconds,
|
|
encryption_key: var_encryptionKey,
|
|
read_your_writes: var_readYourWrites,
|
|
open_flags: var_openFlags,
|
|
offline: var_offline,
|
|
};
|
|
}
|
|
}
|
|
|
|
impl SseDecode for crate::helpers::result::ExecuteResult {
|
|
// 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_rowsAffected = <u64>::sse_decode(deserializer);
|
|
return crate::helpers::result::ExecuteResult {
|
|
rows_affected: var_rowsAffected,
|
|
};
|
|
}
|
|
}
|
|
|
|
impl SseDecode for f64 {
|
|
// 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_f64::<NativeEndian>().unwrap()
|
|
}
|
|
}
|
|
|
|
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()
|
|
}
|
|
}
|
|
|
|
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 Vec<std::collections::HashMap<String, crate::helpers::return_value::ReturnValue>>
|
|
{
|
|
// 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![];
|
|
for idx_ in 0..len_ {
|
|
ans_.push(<std::collections::HashMap<
|
|
String,
|
|
crate::helpers::return_value::ReturnValue,
|
|
>>::sse_decode(deserializer));
|
|
}
|
|
return ans_;
|
|
}
|
|
}
|
|
|
|
impl SseDecode for Vec<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 len_ = <i32>::sse_decode(deserializer);
|
|
let mut ans_ = vec![];
|
|
for idx_ in 0..len_ {
|
|
ans_.push(<String>::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![];
|
|
for idx_ in 0..len_ {
|
|
ans_.push(<u8>::sse_decode(deserializer));
|
|
}
|
|
return ans_;
|
|
}
|
|
}
|
|
|
|
impl SseDecode for Vec<(String, crate::helpers::return_value::ReturnValue)> {
|
|
// 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![];
|
|
for idx_ in 0..len_ {
|
|
ans_.push(
|
|
<(String, crate::helpers::return_value::ReturnValue)>::sse_decode(deserializer),
|
|
);
|
|
}
|
|
return ans_;
|
|
}
|
|
}
|
|
|
|
impl SseDecode for Vec<(String, crate::helpers::value::Value)> {
|
|
// 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![];
|
|
for idx_ in 0..len_ {
|
|
ans_.push(<(String, crate::helpers::value::Value)>::sse_decode(
|
|
deserializer,
|
|
));
|
|
}
|
|
return ans_;
|
|
}
|
|
}
|
|
|
|
impl SseDecode for Vec<crate::helpers::value::Value> {
|
|
// 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![];
|
|
for idx_ in 0..len_ {
|
|
ans_.push(<crate::helpers::value::Value>::sse_decode(deserializer));
|
|
}
|
|
return ans_;
|
|
}
|
|
}
|
|
|
|
impl SseDecode for crate::api::connect::OpenFlags {
|
|
// 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 = <i32>::sse_decode(deserializer);
|
|
return match inner {
|
|
0 => crate::api::connect::OpenFlags::ReadOnly,
|
|
1 => crate::api::connect::OpenFlags::ReadWrite,
|
|
2 => crate::api::connect::OpenFlags::Create,
|
|
_ => unreachable!("Invalid variant for OpenFlags: {}", inner),
|
|
};
|
|
}
|
|
}
|
|
|
|
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<bool> {
|
|
// 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(<bool>::sse_decode(deserializer));
|
|
} else {
|
|
return None;
|
|
}
|
|
}
|
|
}
|
|
|
|
impl SseDecode for Option<crate::api::connect::OpenFlags> {
|
|
// 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::api::connect::OpenFlags>::sse_decode(deserializer));
|
|
} else {
|
|
return None;
|
|
}
|
|
}
|
|
}
|
|
|
|
impl SseDecode for Option<u64> {
|
|
// 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(<u64>::sse_decode(deserializer));
|
|
} else {
|
|
return None;
|
|
}
|
|
}
|
|
}
|
|
|
|
impl SseDecode for crate::helpers::params::Params {
|
|
// Codec=Sse (Serialization based), see doc to use other codecs
|
|
fn sse_decode(deserializer: &mut flutter_rust_bridge::for_generated::SseDeserializer) -> Self {
|
|
let mut tag_ = <i32>::sse_decode(deserializer);
|
|
match tag_ {
|
|
0 => {
|
|
return crate::helpers::params::Params::None;
|
|
}
|
|
1 => {
|
|
let mut var_field0 = <Vec<crate::helpers::value::Value>>::sse_decode(deserializer);
|
|
return crate::helpers::params::Params::Positional(var_field0);
|
|
}
|
|
2 => {
|
|
let mut var_field0 =
|
|
<Vec<(String, crate::helpers::value::Value)>>::sse_decode(deserializer);
|
|
return crate::helpers::params::Params::Named(var_field0);
|
|
}
|
|
_ => {
|
|
unimplemented!("");
|
|
}
|
|
}
|
|
}
|
|
}
|
|
|
|
impl SseDecode for crate::helpers::result::QueryResult {
|
|
// 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_rows = <Vec<
|
|
std::collections::HashMap<String, crate::helpers::return_value::ReturnValue>,
|
|
>>::sse_decode(deserializer);
|
|
let mut var_columns = <Vec<String>>::sse_decode(deserializer);
|
|
let mut var_rowsAffected = <u64>::sse_decode(deserializer);
|
|
let mut var_lastInsertRowid = <i64>::sse_decode(deserializer);
|
|
return crate::helpers::result::QueryResult {
|
|
rows: var_rows,
|
|
columns: var_columns,
|
|
rows_affected: var_rowsAffected,
|
|
last_insert_rowid: var_lastInsertRowid,
|
|
};
|
|
}
|
|
}
|
|
|
|
impl SseDecode for (String, crate::helpers::return_value::ReturnValue) {
|
|
// 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 = <crate::helpers::return_value::ReturnValue>::sse_decode(deserializer);
|
|
return (var_field0, var_field1);
|
|
}
|
|
}
|
|
|
|
impl SseDecode for (String, crate::helpers::value::Value) {
|
|
// 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 = <crate::helpers::value::Value>::sse_decode(deserializer);
|
|
return (var_field0, var_field1);
|
|
}
|
|
}
|
|
|
|
impl SseDecode for crate::helpers::return_value::ReturnValue {
|
|
// Codec=Sse (Serialization based), see doc to use other codecs
|
|
fn sse_decode(deserializer: &mut flutter_rust_bridge::for_generated::SseDeserializer) -> Self {
|
|
let mut tag_ = <i32>::sse_decode(deserializer);
|
|
match tag_ {
|
|
0 => {
|
|
let mut var_field0 = <i64>::sse_decode(deserializer);
|
|
return crate::helpers::return_value::ReturnValue::Integer(var_field0);
|
|
}
|
|
1 => {
|
|
let mut var_field0 = <f64>::sse_decode(deserializer);
|
|
return crate::helpers::return_value::ReturnValue::Real(var_field0);
|
|
}
|
|
2 => {
|
|
let mut var_field0 = <String>::sse_decode(deserializer);
|
|
return crate::helpers::return_value::ReturnValue::Text(var_field0);
|
|
}
|
|
3 => {
|
|
let mut var_field0 = <Vec<u8>>::sse_decode(deserializer);
|
|
return crate::helpers::return_value::ReturnValue::Blob(var_field0);
|
|
}
|
|
4 => {
|
|
return crate::helpers::return_value::ReturnValue::Null;
|
|
}
|
|
_ => {
|
|
unimplemented!("");
|
|
}
|
|
}
|
|
}
|
|
}
|
|
|
|
impl SseDecode for u64 {
|
|
// 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()
|
|
}
|
|
}
|
|
|
|
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 () {
|
|
// 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 crate::helpers::value::Value {
|
|
// Codec=Sse (Serialization based), see doc to use other codecs
|
|
fn sse_decode(deserializer: &mut flutter_rust_bridge::for_generated::SseDeserializer) -> Self {
|
|
let mut tag_ = <i32>::sse_decode(deserializer);
|
|
match tag_ {
|
|
0 => {
|
|
let mut var_field0 = <i64>::sse_decode(deserializer);
|
|
return crate::helpers::value::Value::Integer(var_field0);
|
|
}
|
|
1 => {
|
|
let mut var_field0 = <f64>::sse_decode(deserializer);
|
|
return crate::helpers::value::Value::Real(var_field0);
|
|
}
|
|
2 => {
|
|
let mut var_field0 = <String>::sse_decode(deserializer);
|
|
return crate::helpers::value::Value::Text(var_field0);
|
|
}
|
|
3 => {
|
|
let mut var_field0 = <Vec<u8>>::sse_decode(deserializer);
|
|
return crate::helpers::value::Value::Blob(var_field0);
|
|
}
|
|
4 => {
|
|
return crate::helpers::value::Value::Null;
|
|
}
|
|
_ => {
|
|
unimplemented!("");
|
|
}
|
|
}
|
|
}
|
|
}
|
|
|
|
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__api__connection__RustConnection_execute_impl(
|
|
port,
|
|
ptr,
|
|
rust_vec_len,
|
|
data_len,
|
|
),
|
|
2 => {
|
|
wire__crate__api__connection__RustConnection_new_impl(port, ptr, rust_vec_len, data_len)
|
|
}
|
|
3 => wire__crate__api__connection__RustConnection_prepare_impl(
|
|
port,
|
|
ptr,
|
|
rust_vec_len,
|
|
data_len,
|
|
),
|
|
4 => wire__crate__api__connection__RustConnection_query_impl(
|
|
port,
|
|
ptr,
|
|
rust_vec_len,
|
|
data_len,
|
|
),
|
|
5 => wire__crate__api__statement__RustStatement_execute_impl(
|
|
port,
|
|
ptr,
|
|
rust_vec_len,
|
|
data_len,
|
|
),
|
|
6 => wire__crate__api__statement__RustStatement_new_impl(port, ptr, rust_vec_len, data_len),
|
|
7 => {
|
|
wire__crate__api__statement__RustStatement_query_impl(port, ptr, rust_vec_len, data_len)
|
|
}
|
|
8 => {
|
|
wire__crate__api__statement__RustStatement_reset_impl(port, ptr, rust_vec_len, data_len)
|
|
}
|
|
9 => wire__crate__api__connect__connect_impl(port, ptr, rust_vec_len, data_len),
|
|
10 => wire__crate__api__init__init_app_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<RustConnection> {
|
|
fn into_dart(self) -> flutter_rust_bridge::for_generated::DartAbi {
|
|
flutter_rust_bridge::for_generated::rust_auto_opaque_encode::<_, MoiArc<_>>(self.0)
|
|
.into_dart()
|
|
}
|
|
}
|
|
impl flutter_rust_bridge::for_generated::IntoDartExceptPrimitive for FrbWrapper<RustConnection> {}
|
|
|
|
impl flutter_rust_bridge::IntoIntoDart<FrbWrapper<RustConnection>> for RustConnection {
|
|
fn into_into_dart(self) -> FrbWrapper<RustConnection> {
|
|
self.into()
|
|
}
|
|
}
|
|
|
|
// Codec=Dco (DartCObject based), see doc to use other codecs
|
|
impl flutter_rust_bridge::IntoDart for FrbWrapper<RustStatement> {
|
|
fn into_dart(self) -> flutter_rust_bridge::for_generated::DartAbi {
|
|
flutter_rust_bridge::for_generated::rust_auto_opaque_encode::<_, MoiArc<_>>(self.0)
|
|
.into_dart()
|
|
}
|
|
}
|
|
impl flutter_rust_bridge::for_generated::IntoDartExceptPrimitive for FrbWrapper<RustStatement> {}
|
|
|
|
impl flutter_rust_bridge::IntoIntoDart<FrbWrapper<RustStatement>> for RustStatement {
|
|
fn into_into_dart(self) -> FrbWrapper<RustStatement> {
|
|
self.into()
|
|
}
|
|
}
|
|
|
|
// Codec=Dco (DartCObject based), see doc to use other codecs
|
|
impl flutter_rust_bridge::IntoDart for FrbWrapper<Wrapper<Arc<Connection>>> {
|
|
fn into_dart(self) -> flutter_rust_bridge::for_generated::DartAbi {
|
|
flutter_rust_bridge::for_generated::rust_auto_opaque_encode::<_, MoiArc<_>>(self.0)
|
|
.into_dart()
|
|
}
|
|
}
|
|
impl flutter_rust_bridge::for_generated::IntoDartExceptPrimitive
|
|
for FrbWrapper<Wrapper<Arc<Connection>>>
|
|
{
|
|
}
|
|
|
|
impl flutter_rust_bridge::IntoIntoDart<FrbWrapper<Wrapper<Arc<Connection>>>>
|
|
for Wrapper<Arc<Connection>>
|
|
{
|
|
fn into_into_dart(self) -> FrbWrapper<Wrapper<Arc<Connection>>> {
|
|
self.into()
|
|
}
|
|
}
|
|
|
|
// Codec=Dco (DartCObject based), see doc to use other codecs
|
|
impl flutter_rust_bridge::IntoDart for FrbWrapper<Wrapper<Statement>> {
|
|
fn into_dart(self) -> flutter_rust_bridge::for_generated::DartAbi {
|
|
flutter_rust_bridge::for_generated::rust_auto_opaque_encode::<_, MoiArc<_>>(self.0)
|
|
.into_dart()
|
|
}
|
|
}
|
|
impl flutter_rust_bridge::for_generated::IntoDartExceptPrimitive
|
|
for FrbWrapper<Wrapper<Statement>>
|
|
{
|
|
}
|
|
|
|
impl flutter_rust_bridge::IntoIntoDart<FrbWrapper<Wrapper<Statement>>> for Wrapper<Statement> {
|
|
fn into_into_dart(self) -> FrbWrapper<Wrapper<Statement>> {
|
|
self.into()
|
|
}
|
|
}
|
|
|
|
// Codec=Dco (DartCObject based), see doc to use other codecs
|
|
impl flutter_rust_bridge::IntoDart for crate::api::connect::ConnectArgs {
|
|
fn into_dart(self) -> flutter_rust_bridge::for_generated::DartAbi {
|
|
[
|
|
self.url.into_into_dart().into_dart(),
|
|
self.auth_token.into_into_dart().into_dart(),
|
|
self.sync_url.into_into_dart().into_dart(),
|
|
self.sync_interval_seconds.into_into_dart().into_dart(),
|
|
self.encryption_key.into_into_dart().into_dart(),
|
|
self.read_your_writes.into_into_dart().into_dart(),
|
|
self.open_flags.into_into_dart().into_dart(),
|
|
self.offline.into_into_dart().into_dart(),
|
|
]
|
|
.into_dart()
|
|
}
|
|
}
|
|
impl flutter_rust_bridge::for_generated::IntoDartExceptPrimitive
|
|
for crate::api::connect::ConnectArgs
|
|
{
|
|
}
|
|
impl flutter_rust_bridge::IntoIntoDart<crate::api::connect::ConnectArgs>
|
|
for crate::api::connect::ConnectArgs
|
|
{
|
|
fn into_into_dart(self) -> crate::api::connect::ConnectArgs {
|
|
self
|
|
}
|
|
}
|
|
// Codec=Dco (DartCObject based), see doc to use other codecs
|
|
impl flutter_rust_bridge::IntoDart for crate::helpers::result::ExecuteResult {
|
|
fn into_dart(self) -> flutter_rust_bridge::for_generated::DartAbi {
|
|
[self.rows_affected.into_into_dart().into_dart()].into_dart()
|
|
}
|
|
}
|
|
impl flutter_rust_bridge::for_generated::IntoDartExceptPrimitive
|
|
for crate::helpers::result::ExecuteResult
|
|
{
|
|
}
|
|
impl flutter_rust_bridge::IntoIntoDart<crate::helpers::result::ExecuteResult>
|
|
for crate::helpers::result::ExecuteResult
|
|
{
|
|
fn into_into_dart(self) -> crate::helpers::result::ExecuteResult {
|
|
self
|
|
}
|
|
}
|
|
// Codec=Dco (DartCObject based), see doc to use other codecs
|
|
impl flutter_rust_bridge::IntoDart for crate::api::connect::OpenFlags {
|
|
fn into_dart(self) -> flutter_rust_bridge::for_generated::DartAbi {
|
|
match self {
|
|
Self::ReadOnly => 0.into_dart(),
|
|
Self::ReadWrite => 1.into_dart(),
|
|
Self::Create => 2.into_dart(),
|
|
_ => unreachable!(),
|
|
}
|
|
}
|
|
}
|
|
impl flutter_rust_bridge::for_generated::IntoDartExceptPrimitive
|
|
for crate::api::connect::OpenFlags
|
|
{
|
|
}
|
|
impl flutter_rust_bridge::IntoIntoDart<crate::api::connect::OpenFlags>
|
|
for crate::api::connect::OpenFlags
|
|
{
|
|
fn into_into_dart(self) -> crate::api::connect::OpenFlags {
|
|
self
|
|
}
|
|
}
|
|
// Codec=Dco (DartCObject based), see doc to use other codecs
|
|
impl flutter_rust_bridge::IntoDart for crate::helpers::params::Params {
|
|
fn into_dart(self) -> flutter_rust_bridge::for_generated::DartAbi {
|
|
match self {
|
|
crate::helpers::params::Params::None => [0.into_dart()].into_dart(),
|
|
crate::helpers::params::Params::Positional(field0) => {
|
|
[1.into_dart(), field0.into_into_dart().into_dart()].into_dart()
|
|
}
|
|
crate::helpers::params::Params::Named(field0) => {
|
|
[2.into_dart(), field0.into_into_dart().into_dart()].into_dart()
|
|
}
|
|
_ => {
|
|
unimplemented!("");
|
|
}
|
|
}
|
|
}
|
|
}
|
|
impl flutter_rust_bridge::for_generated::IntoDartExceptPrimitive
|
|
for crate::helpers::params::Params
|
|
{
|
|
}
|
|
impl flutter_rust_bridge::IntoIntoDart<crate::helpers::params::Params>
|
|
for crate::helpers::params::Params
|
|
{
|
|
fn into_into_dart(self) -> crate::helpers::params::Params {
|
|
self
|
|
}
|
|
}
|
|
// Codec=Dco (DartCObject based), see doc to use other codecs
|
|
impl flutter_rust_bridge::IntoDart for crate::helpers::result::QueryResult {
|
|
fn into_dart(self) -> flutter_rust_bridge::for_generated::DartAbi {
|
|
[
|
|
self.rows.into_into_dart().into_dart(),
|
|
self.columns.into_into_dart().into_dart(),
|
|
self.rows_affected.into_into_dart().into_dart(),
|
|
self.last_insert_rowid.into_into_dart().into_dart(),
|
|
]
|
|
.into_dart()
|
|
}
|
|
}
|
|
impl flutter_rust_bridge::for_generated::IntoDartExceptPrimitive
|
|
for crate::helpers::result::QueryResult
|
|
{
|
|
}
|
|
impl flutter_rust_bridge::IntoIntoDart<crate::helpers::result::QueryResult>
|
|
for crate::helpers::result::QueryResult
|
|
{
|
|
fn into_into_dart(self) -> crate::helpers::result::QueryResult {
|
|
self
|
|
}
|
|
}
|
|
// Codec=Dco (DartCObject based), see doc to use other codecs
|
|
impl flutter_rust_bridge::IntoDart for crate::helpers::return_value::ReturnValue {
|
|
fn into_dart(self) -> flutter_rust_bridge::for_generated::DartAbi {
|
|
match self {
|
|
crate::helpers::return_value::ReturnValue::Integer(field0) => {
|
|
[0.into_dart(), field0.into_into_dart().into_dart()].into_dart()
|
|
}
|
|
crate::helpers::return_value::ReturnValue::Real(field0) => {
|
|
[1.into_dart(), field0.into_into_dart().into_dart()].into_dart()
|
|
}
|
|
crate::helpers::return_value::ReturnValue::Text(field0) => {
|
|
[2.into_dart(), field0.into_into_dart().into_dart()].into_dart()
|
|
}
|
|
crate::helpers::return_value::ReturnValue::Blob(field0) => {
|
|
[3.into_dart(), field0.into_into_dart().into_dart()].into_dart()
|
|
}
|
|
crate::helpers::return_value::ReturnValue::Null => [4.into_dart()].into_dart(),
|
|
_ => {
|
|
unimplemented!("");
|
|
}
|
|
}
|
|
}
|
|
}
|
|
impl flutter_rust_bridge::for_generated::IntoDartExceptPrimitive
|
|
for crate::helpers::return_value::ReturnValue
|
|
{
|
|
}
|
|
impl flutter_rust_bridge::IntoIntoDart<crate::helpers::return_value::ReturnValue>
|
|
for crate::helpers::return_value::ReturnValue
|
|
{
|
|
fn into_into_dart(self) -> crate::helpers::return_value::ReturnValue {
|
|
self
|
|
}
|
|
}
|
|
// Codec=Dco (DartCObject based), see doc to use other codecs
|
|
impl flutter_rust_bridge::IntoDart for crate::helpers::value::Value {
|
|
fn into_dart(self) -> flutter_rust_bridge::for_generated::DartAbi {
|
|
match self {
|
|
crate::helpers::value::Value::Integer(field0) => {
|
|
[0.into_dart(), field0.into_into_dart().into_dart()].into_dart()
|
|
}
|
|
crate::helpers::value::Value::Real(field0) => {
|
|
[1.into_dart(), field0.into_into_dart().into_dart()].into_dart()
|
|
}
|
|
crate::helpers::value::Value::Text(field0) => {
|
|
[2.into_dart(), field0.into_into_dart().into_dart()].into_dart()
|
|
}
|
|
crate::helpers::value::Value::Blob(field0) => {
|
|
[3.into_dart(), field0.into_into_dart().into_dart()].into_dart()
|
|
}
|
|
crate::helpers::value::Value::Null => [4.into_dart()].into_dart(),
|
|
_ => {
|
|
unimplemented!("");
|
|
}
|
|
}
|
|
}
|
|
}
|
|
impl flutter_rust_bridge::for_generated::IntoDartExceptPrimitive for crate::helpers::value::Value {}
|
|
impl flutter_rust_bridge::IntoIntoDart<crate::helpers::value::Value>
|
|
for crate::helpers::value::Value
|
|
{
|
|
fn into_into_dart(self) -> crate::helpers::value::Value {
|
|
self
|
|
}
|
|
}
|
|
|
|
impl SseEncode for RustConnection {
|
|
// Codec=Sse (Serialization based), see doc to use other codecs
|
|
fn sse_encode(self, serializer: &mut flutter_rust_bridge::for_generated::SseSerializer) {
|
|
<RustOpaqueMoi<flutter_rust_bridge::for_generated::RustAutoOpaqueInner<RustConnection>>>::sse_encode(flutter_rust_bridge::for_generated::rust_auto_opaque_encode::<_, MoiArc<_>>(self), serializer);
|
|
}
|
|
}
|
|
|
|
impl SseEncode for RustStatement {
|
|
// Codec=Sse (Serialization based), see doc to use other codecs
|
|
fn sse_encode(self, serializer: &mut flutter_rust_bridge::for_generated::SseSerializer) {
|
|
<RustOpaqueMoi<flutter_rust_bridge::for_generated::RustAutoOpaqueInner<RustStatement>>>::sse_encode(flutter_rust_bridge::for_generated::rust_auto_opaque_encode::<_, MoiArc<_>>(self), serializer);
|
|
}
|
|
}
|
|
|
|
impl SseEncode for Wrapper<Arc<Connection>> {
|
|
// Codec=Sse (Serialization based), see doc to use other codecs
|
|
fn sse_encode(self, serializer: &mut flutter_rust_bridge::for_generated::SseSerializer) {
|
|
<RustOpaqueMoi<
|
|
flutter_rust_bridge::for_generated::RustAutoOpaqueInner<Wrapper<Arc<Connection>>>,
|
|
>>::sse_encode(
|
|
flutter_rust_bridge::for_generated::rust_auto_opaque_encode::<_, MoiArc<_>>(self),
|
|
serializer,
|
|
);
|
|
}
|
|
}
|
|
|
|
impl SseEncode for Wrapper<Statement> {
|
|
// Codec=Sse (Serialization based), see doc to use other codecs
|
|
fn sse_encode(self, serializer: &mut flutter_rust_bridge::for_generated::SseSerializer) {
|
|
<RustOpaqueMoi<flutter_rust_bridge::for_generated::RustAutoOpaqueInner<Wrapper < Statement >>>>::sse_encode(flutter_rust_bridge::for_generated::rust_auto_opaque_encode::<_, MoiArc<_>>(self), serializer);
|
|
}
|
|
}
|
|
|
|
impl SseEncode for std::collections::HashMap<String, crate::helpers::return_value::ReturnValue> {
|
|
// Codec=Sse (Serialization based), see doc to use other codecs
|
|
fn sse_encode(self, serializer: &mut flutter_rust_bridge::for_generated::SseSerializer) {
|
|
<Vec<(String, crate::helpers::return_value::ReturnValue)>>::sse_encode(
|
|
self.into_iter().collect(),
|
|
serializer,
|
|
);
|
|
}
|
|
}
|
|
|
|
impl SseEncode
|
|
for RustOpaqueMoi<flutter_rust_bridge::for_generated::RustAutoOpaqueInner<RustConnection>>
|
|
{
|
|
// Codec=Sse (Serialization based), see doc to use other codecs
|
|
fn sse_encode(self, serializer: &mut flutter_rust_bridge::for_generated::SseSerializer) {
|
|
let (ptr, size) = self.sse_encode_raw();
|
|
<usize>::sse_encode(ptr, serializer);
|
|
<i32>::sse_encode(size, serializer);
|
|
}
|
|
}
|
|
|
|
impl SseEncode
|
|
for RustOpaqueMoi<flutter_rust_bridge::for_generated::RustAutoOpaqueInner<RustStatement>>
|
|
{
|
|
// Codec=Sse (Serialization based), see doc to use other codecs
|
|
fn sse_encode(self, serializer: &mut flutter_rust_bridge::for_generated::SseSerializer) {
|
|
let (ptr, size) = self.sse_encode_raw();
|
|
<usize>::sse_encode(ptr, serializer);
|
|
<i32>::sse_encode(size, serializer);
|
|
}
|
|
}
|
|
|
|
impl SseEncode
|
|
for RustOpaqueMoi<
|
|
flutter_rust_bridge::for_generated::RustAutoOpaqueInner<Wrapper<Arc<Connection>>>,
|
|
>
|
|
{
|
|
// Codec=Sse (Serialization based), see doc to use other codecs
|
|
fn sse_encode(self, serializer: &mut flutter_rust_bridge::for_generated::SseSerializer) {
|
|
let (ptr, size) = self.sse_encode_raw();
|
|
<usize>::sse_encode(ptr, serializer);
|
|
<i32>::sse_encode(size, serializer);
|
|
}
|
|
}
|
|
|
|
impl SseEncode
|
|
for RustOpaqueMoi<flutter_rust_bridge::for_generated::RustAutoOpaqueInner<Wrapper<Statement>>>
|
|
{
|
|
// Codec=Sse (Serialization based), see doc to use other codecs
|
|
fn sse_encode(self, serializer: &mut flutter_rust_bridge::for_generated::SseSerializer) {
|
|
let (ptr, size) = self.sse_encode_raw();
|
|
<usize>::sse_encode(ptr, serializer);
|
|
<i32>::sse_encode(size, serializer);
|
|
}
|
|
}
|
|
|
|
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 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::api::connect::ConnectArgs {
|
|
// 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.url, serializer);
|
|
<Option<String>>::sse_encode(self.auth_token, serializer);
|
|
<Option<String>>::sse_encode(self.sync_url, serializer);
|
|
<Option<u64>>::sse_encode(self.sync_interval_seconds, serializer);
|
|
<Option<String>>::sse_encode(self.encryption_key, serializer);
|
|
<Option<bool>>::sse_encode(self.read_your_writes, serializer);
|
|
<Option<crate::api::connect::OpenFlags>>::sse_encode(self.open_flags, serializer);
|
|
<Option<bool>>::sse_encode(self.offline, serializer);
|
|
}
|
|
}
|
|
|
|
impl SseEncode for crate::helpers::result::ExecuteResult {
|
|
// Codec=Sse (Serialization based), see doc to use other codecs
|
|
fn sse_encode(self, serializer: &mut flutter_rust_bridge::for_generated::SseSerializer) {
|
|
<u64>::sse_encode(self.rows_affected, serializer);
|
|
}
|
|
}
|
|
|
|
impl SseEncode for f64 {
|
|
// 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_f64::<NativeEndian>(self).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();
|
|
}
|
|
}
|
|
|
|
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 Vec<std::collections::HashMap<String, crate::helpers::return_value::ReturnValue>>
|
|
{
|
|
// 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 {
|
|
<std::collections::HashMap<String, crate::helpers::return_value::ReturnValue>>::sse_encode(item, serializer);
|
|
}
|
|
}
|
|
}
|
|
|
|
impl SseEncode for Vec<String> {
|
|
// 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 {
|
|
<String>::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<(String, crate::helpers::return_value::ReturnValue)> {
|
|
// 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 {
|
|
<(String, crate::helpers::return_value::ReturnValue)>::sse_encode(item, serializer);
|
|
}
|
|
}
|
|
}
|
|
|
|
impl SseEncode for Vec<(String, crate::helpers::value::Value)> {
|
|
// 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 {
|
|
<(String, crate::helpers::value::Value)>::sse_encode(item, serializer);
|
|
}
|
|
}
|
|
}
|
|
|
|
impl SseEncode for Vec<crate::helpers::value::Value> {
|
|
// 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::helpers::value::Value>::sse_encode(item, serializer);
|
|
}
|
|
}
|
|
}
|
|
|
|
impl SseEncode for crate::api::connect::OpenFlags {
|
|
// 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(
|
|
match self {
|
|
crate::api::connect::OpenFlags::ReadOnly => 0,
|
|
crate::api::connect::OpenFlags::ReadWrite => 1,
|
|
crate::api::connect::OpenFlags::Create => 2,
|
|
_ => {
|
|
unimplemented!("");
|
|
}
|
|
},
|
|
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<bool> {
|
|
// 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 {
|
|
<bool>::sse_encode(value, serializer);
|
|
}
|
|
}
|
|
}
|
|
|
|
impl SseEncode for Option<crate::api::connect::OpenFlags> {
|
|
// 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::api::connect::OpenFlags>::sse_encode(value, serializer);
|
|
}
|
|
}
|
|
}
|
|
|
|
impl SseEncode for Option<u64> {
|
|
// 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 {
|
|
<u64>::sse_encode(value, serializer);
|
|
}
|
|
}
|
|
}
|
|
|
|
impl SseEncode for crate::helpers::params::Params {
|
|
// Codec=Sse (Serialization based), see doc to use other codecs
|
|
fn sse_encode(self, serializer: &mut flutter_rust_bridge::for_generated::SseSerializer) {
|
|
match self {
|
|
crate::helpers::params::Params::None => {
|
|
<i32>::sse_encode(0, serializer);
|
|
}
|
|
crate::helpers::params::Params::Positional(field0) => {
|
|
<i32>::sse_encode(1, serializer);
|
|
<Vec<crate::helpers::value::Value>>::sse_encode(field0, serializer);
|
|
}
|
|
crate::helpers::params::Params::Named(field0) => {
|
|
<i32>::sse_encode(2, serializer);
|
|
<Vec<(String, crate::helpers::value::Value)>>::sse_encode(field0, serializer);
|
|
}
|
|
_ => {
|
|
unimplemented!("");
|
|
}
|
|
}
|
|
}
|
|
}
|
|
|
|
impl SseEncode for crate::helpers::result::QueryResult {
|
|
// Codec=Sse (Serialization based), see doc to use other codecs
|
|
fn sse_encode(self, serializer: &mut flutter_rust_bridge::for_generated::SseSerializer) {
|
|
<Vec<std::collections::HashMap<String, crate::helpers::return_value::ReturnValue>>>::sse_encode(self.rows, serializer);
|
|
<Vec<String>>::sse_encode(self.columns, serializer);
|
|
<u64>::sse_encode(self.rows_affected, serializer);
|
|
<i64>::sse_encode(self.last_insert_rowid, serializer);
|
|
}
|
|
}
|
|
|
|
impl SseEncode for (String, crate::helpers::return_value::ReturnValue) {
|
|
// 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);
|
|
<crate::helpers::return_value::ReturnValue>::sse_encode(self.1, serializer);
|
|
}
|
|
}
|
|
|
|
impl SseEncode for (String, crate::helpers::value::Value) {
|
|
// 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);
|
|
<crate::helpers::value::Value>::sse_encode(self.1, serializer);
|
|
}
|
|
}
|
|
|
|
impl SseEncode for crate::helpers::return_value::ReturnValue {
|
|
// Codec=Sse (Serialization based), see doc to use other codecs
|
|
fn sse_encode(self, serializer: &mut flutter_rust_bridge::for_generated::SseSerializer) {
|
|
match self {
|
|
crate::helpers::return_value::ReturnValue::Integer(field0) => {
|
|
<i32>::sse_encode(0, serializer);
|
|
<i64>::sse_encode(field0, serializer);
|
|
}
|
|
crate::helpers::return_value::ReturnValue::Real(field0) => {
|
|
<i32>::sse_encode(1, serializer);
|
|
<f64>::sse_encode(field0, serializer);
|
|
}
|
|
crate::helpers::return_value::ReturnValue::Text(field0) => {
|
|
<i32>::sse_encode(2, serializer);
|
|
<String>::sse_encode(field0, serializer);
|
|
}
|
|
crate::helpers::return_value::ReturnValue::Blob(field0) => {
|
|
<i32>::sse_encode(3, serializer);
|
|
<Vec<u8>>::sse_encode(field0, serializer);
|
|
}
|
|
crate::helpers::return_value::ReturnValue::Null => {
|
|
<i32>::sse_encode(4, serializer);
|
|
}
|
|
_ => {
|
|
unimplemented!("");
|
|
}
|
|
}
|
|
}
|
|
}
|
|
|
|
impl SseEncode for u64 {
|
|
// 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).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 () {
|
|
// 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 crate::helpers::value::Value {
|
|
// Codec=Sse (Serialization based), see doc to use other codecs
|
|
fn sse_encode(self, serializer: &mut flutter_rust_bridge::for_generated::SseSerializer) {
|
|
match self {
|
|
crate::helpers::value::Value::Integer(field0) => {
|
|
<i32>::sse_encode(0, serializer);
|
|
<i64>::sse_encode(field0, serializer);
|
|
}
|
|
crate::helpers::value::Value::Real(field0) => {
|
|
<i32>::sse_encode(1, serializer);
|
|
<f64>::sse_encode(field0, serializer);
|
|
}
|
|
crate::helpers::value::Value::Text(field0) => {
|
|
<i32>::sse_encode(2, serializer);
|
|
<String>::sse_encode(field0, serializer);
|
|
}
|
|
crate::helpers::value::Value::Blob(field0) => {
|
|
<i32>::sse_encode(3, serializer);
|
|
<Vec<u8>>::sse_encode(field0, serializer);
|
|
}
|
|
crate::helpers::value::Value::Null => {
|
|
<i32>::sse_encode(4, serializer);
|
|
}
|
|
_ => {
|
|
unimplemented!("");
|
|
}
|
|
}
|
|
}
|
|
}
|
|
|
|
#[cfg(not(target_family = "wasm"))]
|
|
mod io {
|
|
// This file is automatically generated, so please do not edit it.
|
|
// @generated by `flutter_rust_bridge`@ 2.10.0.
|
|
|
|
// Section: imports
|
|
|
|
use super::*;
|
|
use crate::api::connection::*;
|
|
use crate::api::statement::*;
|
|
use crate::helpers::wrapper::*;
|
|
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!();
|
|
|
|
#[unsafe(no_mangle)]
|
|
pub extern "C" fn frbgen_turso_dart_rust_arc_increment_strong_count_RustOpaque_flutter_rust_bridgefor_generatedRustAutoOpaqueInnerRustConnection(
|
|
ptr: *const std::ffi::c_void,
|
|
) {
|
|
MoiArc::<flutter_rust_bridge::for_generated::RustAutoOpaqueInner<RustConnection>>::increment_strong_count(ptr as _);
|
|
}
|
|
|
|
#[unsafe(no_mangle)]
|
|
pub extern "C" fn frbgen_turso_dart_rust_arc_decrement_strong_count_RustOpaque_flutter_rust_bridgefor_generatedRustAutoOpaqueInnerRustConnection(
|
|
ptr: *const std::ffi::c_void,
|
|
) {
|
|
MoiArc::<flutter_rust_bridge::for_generated::RustAutoOpaqueInner<RustConnection>>::decrement_strong_count(ptr as _);
|
|
}
|
|
|
|
#[unsafe(no_mangle)]
|
|
pub extern "C" fn frbgen_turso_dart_rust_arc_increment_strong_count_RustOpaque_flutter_rust_bridgefor_generatedRustAutoOpaqueInnerRustStatement(
|
|
ptr: *const std::ffi::c_void,
|
|
) {
|
|
MoiArc::<flutter_rust_bridge::for_generated::RustAutoOpaqueInner<RustStatement>>::increment_strong_count(ptr as _);
|
|
}
|
|
|
|
#[unsafe(no_mangle)]
|
|
pub extern "C" fn frbgen_turso_dart_rust_arc_decrement_strong_count_RustOpaque_flutter_rust_bridgefor_generatedRustAutoOpaqueInnerRustStatement(
|
|
ptr: *const std::ffi::c_void,
|
|
) {
|
|
MoiArc::<flutter_rust_bridge::for_generated::RustAutoOpaqueInner<RustStatement>>::decrement_strong_count(ptr as _);
|
|
}
|
|
|
|
#[unsafe(no_mangle)]
|
|
pub extern "C" fn frbgen_turso_dart_rust_arc_increment_strong_count_RustOpaque_flutter_rust_bridgefor_generatedRustAutoOpaqueInnerWrapperArcConnection(
|
|
ptr: *const std::ffi::c_void,
|
|
) {
|
|
MoiArc::<flutter_rust_bridge::for_generated::RustAutoOpaqueInner<Wrapper < Arc < Connection > >>>::increment_strong_count(ptr as _);
|
|
}
|
|
|
|
#[unsafe(no_mangle)]
|
|
pub extern "C" fn frbgen_turso_dart_rust_arc_decrement_strong_count_RustOpaque_flutter_rust_bridgefor_generatedRustAutoOpaqueInnerWrapperArcConnection(
|
|
ptr: *const std::ffi::c_void,
|
|
) {
|
|
MoiArc::<flutter_rust_bridge::for_generated::RustAutoOpaqueInner<Wrapper < Arc < Connection > >>>::decrement_strong_count(ptr as _);
|
|
}
|
|
|
|
#[unsafe(no_mangle)]
|
|
pub extern "C" fn frbgen_turso_dart_rust_arc_increment_strong_count_RustOpaque_flutter_rust_bridgefor_generatedRustAutoOpaqueInnerWrapperStatement(
|
|
ptr: *const std::ffi::c_void,
|
|
) {
|
|
MoiArc::<flutter_rust_bridge::for_generated::RustAutoOpaqueInner<Wrapper < Statement >>>::increment_strong_count(ptr as _);
|
|
}
|
|
|
|
#[unsafe(no_mangle)]
|
|
pub extern "C" fn frbgen_turso_dart_rust_arc_decrement_strong_count_RustOpaque_flutter_rust_bridgefor_generatedRustAutoOpaqueInnerWrapperStatement(
|
|
ptr: *const std::ffi::c_void,
|
|
) {
|
|
MoiArc::<flutter_rust_bridge::for_generated::RustAutoOpaqueInner<Wrapper < Statement >>>::decrement_strong_count(ptr as _);
|
|
}
|
|
}
|
|
#[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.10.0.
|
|
|
|
// Section: imports
|
|
|
|
use super::*;
|
|
use crate::api::connection::*;
|
|
use crate::api::statement::*;
|
|
use crate::helpers::wrapper::*;
|
|
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!();
|
|
|
|
#[wasm_bindgen]
|
|
pub fn rust_arc_increment_strong_count_RustOpaque_flutter_rust_bridgefor_generatedRustAutoOpaqueInnerRustConnection(
|
|
ptr: *const std::ffi::c_void,
|
|
) {
|
|
MoiArc::<flutter_rust_bridge::for_generated::RustAutoOpaqueInner<RustConnection>>::increment_strong_count(ptr as _);
|
|
}
|
|
|
|
#[wasm_bindgen]
|
|
pub fn rust_arc_decrement_strong_count_RustOpaque_flutter_rust_bridgefor_generatedRustAutoOpaqueInnerRustConnection(
|
|
ptr: *const std::ffi::c_void,
|
|
) {
|
|
MoiArc::<flutter_rust_bridge::for_generated::RustAutoOpaqueInner<RustConnection>>::decrement_strong_count(ptr as _);
|
|
}
|
|
|
|
#[wasm_bindgen]
|
|
pub fn rust_arc_increment_strong_count_RustOpaque_flutter_rust_bridgefor_generatedRustAutoOpaqueInnerRustStatement(
|
|
ptr: *const std::ffi::c_void,
|
|
) {
|
|
MoiArc::<flutter_rust_bridge::for_generated::RustAutoOpaqueInner<RustStatement>>::increment_strong_count(ptr as _);
|
|
}
|
|
|
|
#[wasm_bindgen]
|
|
pub fn rust_arc_decrement_strong_count_RustOpaque_flutter_rust_bridgefor_generatedRustAutoOpaqueInnerRustStatement(
|
|
ptr: *const std::ffi::c_void,
|
|
) {
|
|
MoiArc::<flutter_rust_bridge::for_generated::RustAutoOpaqueInner<RustStatement>>::decrement_strong_count(ptr as _);
|
|
}
|
|
|
|
#[wasm_bindgen]
|
|
pub fn rust_arc_increment_strong_count_RustOpaque_flutter_rust_bridgefor_generatedRustAutoOpaqueInnerWrapperArcConnection(
|
|
ptr: *const std::ffi::c_void,
|
|
) {
|
|
MoiArc::<flutter_rust_bridge::for_generated::RustAutoOpaqueInner<Wrapper < Arc < Connection > >>>::increment_strong_count(ptr as _);
|
|
}
|
|
|
|
#[wasm_bindgen]
|
|
pub fn rust_arc_decrement_strong_count_RustOpaque_flutter_rust_bridgefor_generatedRustAutoOpaqueInnerWrapperArcConnection(
|
|
ptr: *const std::ffi::c_void,
|
|
) {
|
|
MoiArc::<flutter_rust_bridge::for_generated::RustAutoOpaqueInner<Wrapper < Arc < Connection > >>>::decrement_strong_count(ptr as _);
|
|
}
|
|
|
|
#[wasm_bindgen]
|
|
pub fn rust_arc_increment_strong_count_RustOpaque_flutter_rust_bridgefor_generatedRustAutoOpaqueInnerWrapperStatement(
|
|
ptr: *const std::ffi::c_void,
|
|
) {
|
|
MoiArc::<flutter_rust_bridge::for_generated::RustAutoOpaqueInner<Wrapper < Statement >>>::increment_strong_count(ptr as _);
|
|
}
|
|
|
|
#[wasm_bindgen]
|
|
pub fn rust_arc_decrement_strong_count_RustOpaque_flutter_rust_bridgefor_generatedRustAutoOpaqueInnerWrapperStatement(
|
|
ptr: *const std::ffi::c_void,
|
|
) {
|
|
MoiArc::<flutter_rust_bridge::for_generated::RustAutoOpaqueInner<Wrapper < Statement >>>::decrement_strong_count(ptr as _);
|
|
}
|
|
}
|
|
#[cfg(target_family = "wasm")]
|
|
pub use web::*;
|