ohkami 0.24.9

#[doc(hidden)]
#[macro_export]
macro_rules! INFO {
    ( $( $t:tt )* ) => {{
        #[cfg(feature = "internal-log-tracing")] {
            tracing::info!($($t)*);
        }
        #[cfg(not(feature = "internal-log-tracing"))] {
            #[cfg(not(feature = "rt_worker"))]
            std::println!("[ohkami:INFO] {}", format_args!($($t)*));
            #[cfg(feature="rt_worker")]
            worker::console_info!("[ohkami:INFO] {}", format_args!($($t)*));
        }
    }};
}

#[doc(hidden)]
#[macro_export]
macro_rules! WARNING {
    ( $( $t:tt )* ) => {{
        #[cfg(feature = "internal-log-tracing")] {
            tracing::warn!($($t)*);
        }
        #[cfg(not(feature = "internal-log-tracing"))] {
            #[cfg(not(feature = "rt_worker"))]
            std::println!("[ohkami:WARNING] {}", format_args!($($t)*));
            #[cfg(feature="rt_worker")]
            worker::console_warn!("[ohkami:WARNING] {}", format_args!($($t)*));
        }
    }};
}

#[doc(hidden)]
#[macro_export]
macro_rules! ERROR {
    ( $($t:tt)* ) => {{
        #[cfg(feature = "internal-log-tracing")] {
            tracing::error!($($t)*);
        }
        #[cfg(not(feature = "internal-log-tracing"))] {
            #[cfg(not(feature = "rt_worker"))]
            std::eprintln!("[ohkami:ERROR] {}", format_args!($($t)*));
            #[cfg(feature="rt_worker")]
            worker::console_error!("[ohkami:ERROR] {}", format_args!($($t)*));
        }
    }};
}

#[doc(hidden)]
#[macro_export]
macro_rules! DEBUG {
    ( $( $t:tt )* ) => {
        #[cfg(feature="DEBUG")] {
            #[cfg(feature = "internal-log-tracing")] {
                tracing::debug!($($t)*);
            }
            #[cfg(not(feature = "internal-log-tracing"))] {
                #[cfg(not(feature = "rt_worker"))]
                std::println!("[ohkami:DEBUG] {}:{}:{} {}", file!(), line!(), column!(), format_args!($($t)*));
                #[cfg(feature="rt_worker")]
                worker::console_debug!("[ohkami:DEBUG] {}:{}:{} {}", file!(), line!(), column!(), format_args!($($t)*));
            }
        }
    };
}

#[doc(hidden)]
#[macro_export]
macro_rules! push_unchecked {
    ($buf:ident <- $bytes:expr) => {{
        let (buf_len, bytes_len) = ($buf.len(), $bytes.len());
        std::ptr::copy_nonoverlapping($bytes.as_ptr(), $buf.as_mut_ptr().add(buf_len), bytes_len);
        $buf.set_len(buf_len + bytes_len);
    }};
}

pub use crate::fang::FangAction;

pub use crate::fang::bound::{SendOnThreaded, SendSyncOnThreaded};

pub use ohkami_lib::{percent_decode, percent_decode_utf8, percent_encode};

#[inline]
pub fn base64_decode(input: impl AsRef<[u8]>) -> Result<Vec<u8>, base64::DecodeError> {
    use ::base64::engine::{Engine as _, general_purpose::STANDARD};
    STANDARD.decode(input)
}
pub fn base64_decode_utf8(input: impl AsRef<[u8]>) -> Result<String, base64::DecodeError> {
    use ::base64::engine::{Engine as _, general_purpose::STANDARD};
    let bytes = STANDARD.decode(input)?;
    String::from_utf8(bytes).map_err(|e| {
        let pos = e.utf8_error().valid_up_to();
        base64::DecodeError::InvalidByte(pos, e.as_bytes()[pos + 1])
    })
}
#[inline]
pub fn base64_encode(input: impl AsRef<[u8]>) -> String {
    use ::base64::engine::{Engine as _, general_purpose::STANDARD};
    STANDARD.encode(input)
}
pub fn base64_url_decode(input: impl AsRef<[u8]>) -> Result<Vec<u8>, base64::DecodeError> {
    use ::base64::engine::{Engine as _, general_purpose::URL_SAFE_NO_PAD};
    URL_SAFE_NO_PAD.decode(input)
}
#[inline]
pub fn base64_url_encode(input: impl AsRef<[u8]>) -> String {
    use ::base64::engine::{Engine as _, general_purpose::URL_SAFE_NO_PAD};
    URL_SAFE_NO_PAD.encode(input)
}

#[cfg(feature = "sse")]
pub use ohkami_lib::stream::{self, Stream, StreamExt};

#[cfg(not(feature = "rt_worker"))]
/// ```
/// # let _ =
/// {
///     std::time::SystemTime::now()
///         .duration_since(std::time::UNIX_EPOCH)
///         .unwrap()
///         .as_secs()
/// }
/// # ;
/// ```
#[inline]
pub fn unix_timestamp() -> u64 {
    std::time::SystemTime::now()
        .duration_since(std::time::UNIX_EPOCH)
        .unwrap()
        .as_secs()
}
#[cfg(feature = "rt_worker")]
/// JavaScript `Date.now() / 1000` --as--> Rust `u64`
#[inline]
pub fn unix_timestamp() -> u64 {
    (worker::js_sys::Date::now() / 1000.) as _
}

/// Parse semicolon-separated Cookies into an iterator of`(name, value)`.
///
/// ## Note
///
/// Invalid Cookie that doesn't contain `=` or contains multiple `=`s is just ignored.
///
/// ## Example
///
/// ```
/// # fn main() {
/// let mut cookies = ohkami::util::iter_cookies(
///     "PHPSESSID=298zf09hf012fh2; csrftoken=u32t4o3tb3gg43; _gat=1"
/// );
///
/// assert_eq!(cookies.next(), Some(("PHPSESSID", "298zf09hf012fh2")));
/// assert_eq!(cookies.next(), Some(("csrftoken", "u32t4o3tb3gg43")));
/// assert_eq!(cookies.next(), Some(("_gat", "1")));
/// assert_eq!(cookies.next(), None);
/// # }
/// ```
pub fn iter_cookies(raw: &str) -> impl Iterator<Item = (&str, &str)> {
    raw.split("; ").filter_map(|key_value| {
        let mut key_value = key_value.split('=');
        let key = key_value.next()?;
        let value = key_value.next()?;
        key_value.next().is_none().then_some((key, value))
    })
}

pub struct ErrorMessage(pub String);
const _: () = {
    impl std::fmt::Debug for ErrorMessage {
        fn fmt(&self, f: &mut std::fmt::Formatter<'_>) -> std::fmt::Result {
            f.write_str(&self.0)
        }
    }
    impl std::fmt::Display for ErrorMessage {
        fn fmt(&self, f: &mut std::fmt::Formatter<'_>) -> std::fmt::Result {
            f.write_str(&self.0)
        }
    }
    impl std::error::Error for ErrorMessage {}
    impl super::IntoResponse for ErrorMessage {
        fn into_response(self) -> crate::Response {
            crate::Response::InternalServerError().with_text(self.0)
        }

        #[cfg(feature = "openapi")]
        fn openapi_responses() -> crate::openapi::Responses {
            crate::openapi::Responses::new([(
                500,
                crate::openapi::Response::when("Something went wrong")
                    .content("text/plain", crate::openapi::string()),
            )])
        }
    }
};

#[cfg(feature = "__rt_native__")]
pub fn with_timeout<T>(
    duration: std::time::Duration,
    proc: impl std::future::Future<Output = T>,
) -> impl std::future::Future<Output = Option<T>> {
    use std::pin::Pin;
    use std::task::Poll;

    struct Timeout<Sleep, Proc> {
        sleep: Sleep,
        proc: Proc,
    }

    impl<Sleep, Proc, T> std::future::Future for Timeout<Sleep, Proc>
    where
        Sleep: std::future::Future<Output = ()>,
        Proc: std::future::Future<Output = T>,
    {
        type Output = Option<T>;

        #[inline]
        fn poll(self: Pin<&mut Self>, cx: &mut std::task::Context<'_>) -> Poll<Self::Output> {
            let Timeout { sleep, proc } = unsafe { self.get_unchecked_mut() };
            match unsafe { Pin::new_unchecked(proc) }.poll(cx) {
                Poll::Ready(t) => Poll::Ready(Some(t)),
                Poll::Pending => unsafe { Pin::new_unchecked(sleep) }.poll(cx).map(|_| None),
            }
        }
    }

    Timeout {
        proc,
        sleep: crate::__rt__::sleep(duration),
    }
}

pub const IP_0000: std::net::IpAddr = std::net::IpAddr::V4(std::net::Ipv4Addr::new(0, 0, 0, 0));