// This file is automatically generated, so please do not edit it. // Generated by `flutter_rust_bridge`@ 2.0.0-dev.28. #![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 )] // Section: imports use flutter_rust_bridge::for_generated::byteorder::{NativeEndian, ReadBytesExt, WriteBytesExt}; use flutter_rust_bridge::for_generated::transform_result_dco; 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, ); const FLUTTER_RUST_BRIDGE_CODEGEN_VERSION: &str = "2.0.0-dev.28"; // Section: executor flutter_rust_bridge::frb_generated_default_handler!(); // Section: wire_funcs fn wire_dns_lookup_ips_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::TaskInfo { debug_name: "dns_lookup_ips", 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_host = ::sse_decode(&mut deserializer); deserializer.end(); move |context| async move { transform_result_sse( (move || async move { crate::api::http_api::dns_lookup_ips(api_host).await })() .await, ) } }, ) } fn wire_dns_lookup_txt_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::TaskInfo { debug_name: "dns_lookup_txt", 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_host = ::sse_decode(&mut deserializer); deserializer.end(); move |context| async move { transform_result_sse( (move || async move { crate::api::http_api::dns_lookup_txt(api_host).await })() .await, ) } }, ) } fn wire_fetch_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::TaskInfo { debug_name: "fetch", 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_method = ::sse_decode(&mut deserializer); let api_url = ::sse_decode(&mut deserializer); let api_headers = >>::sse_decode(&mut deserializer); let api_input_data = >>::sse_decode(&mut deserializer); let api_with_ip_address = >::sse_decode(&mut deserializer); deserializer.end(); move |context| async move { transform_result_sse( (move || async move { crate::api::http_api::fetch( api_method, api_url, api_headers, api_input_data, api_with_ip_address, ) .await })() .await, ) } }, ) } fn wire_set_default_header_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::TaskInfo { debug_name: "set_default_header", 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_headers = >::sse_decode(&mut deserializer); deserializer.end(); move |context| { transform_result_sse((move || { Result::<_, ()>::Ok(crate::api::http_api::set_default_header(api_headers)) })()) } }, ) } fn wire_start_process_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::TaskInfo { debug_name: "start_process", port: Some(port_), mode: flutter_rust_bridge::for_generated::FfiCallMode::Stream, }, 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_executable = ::sse_decode(&mut deserializer); let api_arguments = >::sse_decode(&mut deserializer); let api_working_directory = ::sse_decode(&mut deserializer); deserializer.end(); move |context| async move { transform_result_sse( (move || async move { Result::<_, ()>::Ok( crate::api::process_api::start_process( api_executable, api_arguments, api_working_directory, StreamSink::new( context.rust2dart_context().stream_sink::<_, String>(), ), ) .await, ) })() .await, ) } }, ) } // 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 { unreachable!(""); } } impl SseDecode for std::collections::HashMap { // 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 = >::sse_decode(deserializer); return inner.into_iter().collect(); } } 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 = >::sse_decode(deserializer); return String::from_utf8(inner).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::().unwrap() } } impl SseDecode for Vec { // 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_ = ::sse_decode(deserializer); let mut ans_ = vec![]; for idx_ in 0..len_ { ans_.push(::sse_decode(deserializer)); } return ans_; } } impl SseDecode for Vec { // 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_ = ::sse_decode(deserializer); let mut ans_ = vec![]; for idx_ in 0..len_ { ans_.push(::sse_decode(deserializer)); } return ans_; } } impl SseDecode for Vec<(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 len_ = ::sse_decode(deserializer); let mut ans_ = vec![]; for idx_ in 0..len_ { ans_.push(<(String, String)>::sse_decode(deserializer)); } return ans_; } } impl SseDecode for crate::http_package::MyHttpVersion { // 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 = ::sse_decode(deserializer); return match inner { 0 => crate::http_package::MyHttpVersion::HTTP_09, 1 => crate::http_package::MyHttpVersion::HTTP_10, 2 => crate::http_package::MyHttpVersion::HTTP_11, 3 => crate::http_package::MyHttpVersion::HTTP_2, 4 => crate::http_package::MyHttpVersion::HTTP_3, 5 => crate::http_package::MyHttpVersion::HTTP_UNKNOWN, _ => unreachable!("Invalid variant for MyHttpVersion: {}", inner), }; } } impl SseDecode for crate::api::http_api::MyMethod { // 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 = ::sse_decode(deserializer); return match inner { 0 => crate::api::http_api::MyMethod::Options, 1 => crate::api::http_api::MyMethod::Gets, 2 => crate::api::http_api::MyMethod::Post, 3 => crate::api::http_api::MyMethod::Put, 4 => crate::api::http_api::MyMethod::Delete, 5 => crate::api::http_api::MyMethod::Head, 6 => crate::api::http_api::MyMethod::Trace, 7 => crate::api::http_api::MyMethod::Connect, 8 => crate::api::http_api::MyMethod::Patch, _ => unreachable!("Invalid variant for MyMethod: {}", inner), }; } } impl SseDecode for Option> { // Codec=Sse (Serialization based), see doc to use other codecs fn sse_decode(deserializer: &mut flutter_rust_bridge::for_generated::SseDeserializer) -> Self { if (::sse_decode(deserializer)) { return Some(>::sse_decode( deserializer, )); } else { return None; } } } impl SseDecode for Option { // Codec=Sse (Serialization based), see doc to use other codecs fn sse_decode(deserializer: &mut flutter_rust_bridge::for_generated::SseDeserializer) -> Self { if (::sse_decode(deserializer)) { return Some(::sse_decode(deserializer)); } else { return None; } } } impl SseDecode for Option { // Codec=Sse (Serialization based), see doc to use other codecs fn sse_decode(deserializer: &mut flutter_rust_bridge::for_generated::SseDeserializer) -> Self { if (::sse_decode(deserializer)) { return Some(::sse_decode(deserializer)); } else { return None; } } } impl SseDecode for Option> { // Codec=Sse (Serialization based), see doc to use other codecs fn sse_decode(deserializer: &mut flutter_rust_bridge::for_generated::SseDeserializer) -> Self { if (::sse_decode(deserializer)) { return Some(>::sse_decode(deserializer)); } else { return None; } } } 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 = ::sse_decode(deserializer); let mut var_field1 = ::sse_decode(deserializer); return (var_field0, var_field1); } } impl SseDecode for crate::http_package::RustHttpResponse { // 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_statusCode = ::sse_decode(deserializer); let mut var_headers = >::sse_decode(deserializer); let mut var_url = ::sse_decode(deserializer); let mut var_contentLength = >::sse_decode(deserializer); let mut var_version = ::sse_decode(deserializer); let mut var_remoteAddr = ::sse_decode(deserializer); let mut var_data = >>::sse_decode(deserializer); return crate::http_package::RustHttpResponse { status_code: var_statusCode, headers: var_headers, url: var_url, content_length: var_contentLength, version: var_version, remote_addr: var_remoteAddr, data: var_data, }; } } impl SseDecode for u16 { // 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_u16::().unwrap() } } 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::().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 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 } } 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 { 4 => wire_dns_lookup_ips_impl(port, ptr, rust_vec_len, data_len), 3 => wire_dns_lookup_txt_impl(port, ptr, rust_vec_len, data_len), 2 => wire_fetch_impl(port, ptr, rust_vec_len, data_len), 1 => wire_set_default_header_impl(port, ptr, rust_vec_len, data_len), 5 => wire_start_process_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 crate::http_package::MyHttpVersion { fn into_dart(self) -> flutter_rust_bridge::for_generated::DartAbi { match self { Self::HTTP_09 => 0.into_dart(), Self::HTTP_10 => 1.into_dart(), Self::HTTP_11 => 2.into_dart(), Self::HTTP_2 => 3.into_dart(), Self::HTTP_3 => 4.into_dart(), Self::HTTP_UNKNOWN => 5.into_dart(), } } } impl flutter_rust_bridge::for_generated::IntoDartExceptPrimitive for crate::http_package::MyHttpVersion { } impl flutter_rust_bridge::IntoIntoDart for crate::http_package::MyHttpVersion { fn into_into_dart(self) -> crate::http_package::MyHttpVersion { self } } // Codec=Dco (DartCObject based), see doc to use other codecs impl flutter_rust_bridge::IntoDart for crate::api::http_api::MyMethod { fn into_dart(self) -> flutter_rust_bridge::for_generated::DartAbi { match self { Self::Options => 0.into_dart(), Self::Gets => 1.into_dart(), Self::Post => 2.into_dart(), Self::Put => 3.into_dart(), Self::Delete => 4.into_dart(), Self::Head => 5.into_dart(), Self::Trace => 6.into_dart(), Self::Connect => 7.into_dart(), Self::Patch => 8.into_dart(), } } } impl flutter_rust_bridge::for_generated::IntoDartExceptPrimitive for crate::api::http_api::MyMethod { } impl flutter_rust_bridge::IntoIntoDart for crate::api::http_api::MyMethod { fn into_into_dart(self) -> crate::api::http_api::MyMethod { self } } // Codec=Dco (DartCObject based), see doc to use other codecs impl flutter_rust_bridge::IntoDart for crate::http_package::RustHttpResponse { fn into_dart(self) -> flutter_rust_bridge::for_generated::DartAbi { [ self.status_code.into_into_dart().into_dart(), self.headers.into_into_dart().into_dart(), self.url.into_into_dart().into_dart(), self.content_length.into_into_dart().into_dart(), self.version.into_into_dart().into_dart(), self.remote_addr.into_into_dart().into_dart(), self.data.into_into_dart().into_dart(), ] .into_dart() } } impl flutter_rust_bridge::for_generated::IntoDartExceptPrimitive for crate::http_package::RustHttpResponse { } impl flutter_rust_bridge::IntoIntoDart for crate::http_package::RustHttpResponse { fn into_into_dart(self) -> crate::http_package::RustHttpResponse { 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) { ::sse_encode(format!("{:?}", self), serializer); } } impl SseEncode for std::collections::HashMap { // Codec=Sse (Serialization based), see doc to use other codecs fn sse_encode(self, serializer: &mut flutter_rust_bridge::for_generated::SseSerializer) { >::sse_encode(self.into_iter().collect(), 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) { >::sse_encode(self.into_bytes(), serializer); } } 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::(self).unwrap(); } } impl SseEncode for Vec { // Codec=Sse (Serialization based), see doc to use other codecs fn sse_encode(self, serializer: &mut flutter_rust_bridge::for_generated::SseSerializer) { ::sse_encode(self.len() as _, serializer); for item in self { ::sse_encode(item, serializer); } } } impl SseEncode for Vec { // Codec=Sse (Serialization based), see doc to use other codecs fn sse_encode(self, serializer: &mut flutter_rust_bridge::for_generated::SseSerializer) { ::sse_encode(self.len() as _, serializer); for item in self { ::sse_encode(item, serializer); } } } impl SseEncode for Vec<(String, String)> { // Codec=Sse (Serialization based), see doc to use other codecs fn sse_encode(self, serializer: &mut flutter_rust_bridge::for_generated::SseSerializer) { ::sse_encode(self.len() as _, serializer); for item in self { <(String, String)>::sse_encode(item, serializer); } } } impl SseEncode for crate::http_package::MyHttpVersion { // Codec=Sse (Serialization based), see doc to use other codecs fn sse_encode(self, serializer: &mut flutter_rust_bridge::for_generated::SseSerializer) { ::sse_encode( match self { crate::http_package::MyHttpVersion::HTTP_09 => 0, crate::http_package::MyHttpVersion::HTTP_10 => 1, crate::http_package::MyHttpVersion::HTTP_11 => 2, crate::http_package::MyHttpVersion::HTTP_2 => 3, crate::http_package::MyHttpVersion::HTTP_3 => 4, crate::http_package::MyHttpVersion::HTTP_UNKNOWN => 5, _ => { unimplemented!(""); } }, serializer, ); } } impl SseEncode for crate::api::http_api::MyMethod { // Codec=Sse (Serialization based), see doc to use other codecs fn sse_encode(self, serializer: &mut flutter_rust_bridge::for_generated::SseSerializer) { ::sse_encode( match self { crate::api::http_api::MyMethod::Options => 0, crate::api::http_api::MyMethod::Gets => 1, crate::api::http_api::MyMethod::Post => 2, crate::api::http_api::MyMethod::Put => 3, crate::api::http_api::MyMethod::Delete => 4, crate::api::http_api::MyMethod::Head => 5, crate::api::http_api::MyMethod::Trace => 6, crate::api::http_api::MyMethod::Connect => 7, crate::api::http_api::MyMethod::Patch => 8, _ => { unimplemented!(""); } }, serializer, ); } } impl SseEncode for Option> { // Codec=Sse (Serialization based), see doc to use other codecs fn sse_encode(self, serializer: &mut flutter_rust_bridge::for_generated::SseSerializer) { ::sse_encode(self.is_some(), serializer); if let Some(value) = self { >::sse_encode(value, serializer); } } } impl SseEncode for Option { // Codec=Sse (Serialization based), see doc to use other codecs fn sse_encode(self, serializer: &mut flutter_rust_bridge::for_generated::SseSerializer) { ::sse_encode(self.is_some(), serializer); if let Some(value) = self { ::sse_encode(value, serializer); } } } impl SseEncode for Option { // Codec=Sse (Serialization based), see doc to use other codecs fn sse_encode(self, serializer: &mut flutter_rust_bridge::for_generated::SseSerializer) { ::sse_encode(self.is_some(), serializer); if let Some(value) = self { ::sse_encode(value, serializer); } } } impl SseEncode for Option> { // Codec=Sse (Serialization based), see doc to use other codecs fn sse_encode(self, serializer: &mut flutter_rust_bridge::for_generated::SseSerializer) { ::sse_encode(self.is_some(), serializer); if let Some(value) = self { >::sse_encode(value, 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) { ::sse_encode(self.0, serializer); ::sse_encode(self.1, serializer); } } impl SseEncode for crate::http_package::RustHttpResponse { // Codec=Sse (Serialization based), see doc to use other codecs fn sse_encode(self, serializer: &mut flutter_rust_bridge::for_generated::SseSerializer) { ::sse_encode(self.status_code, serializer); >::sse_encode(self.headers, serializer); ::sse_encode(self.url, serializer); >::sse_encode(self.content_length, serializer); ::sse_encode(self.version, serializer); ::sse_encode(self.remote_addr, serializer); >>::sse_encode(self.data, serializer); } } impl SseEncode for u16 { // 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_u16::(self).unwrap(); } } 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::(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 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(); } } #[cfg(not(target_family = "wasm"))] #[path = "frb_generated.io.rs"] mod io; #[cfg(not(target_family = "wasm"))] pub use io::*; /// cbindgen:ignore #[cfg(target_family = "wasm")] #[path = "frb_generated.web.rs"] mod web; #[cfg(target_family = "wasm")] pub use web::*;