#![feature(iter_collect_into)]
use {
    argon2::{password_hash::SaltString, PasswordVerifier},
    axum::{
        body::Bytes,
        extract::{OriginalUri, Path},
        http::{header::COOKIE, request::Parts},
        response::{AppendHeaders, Html},
    },
    const_format::formatcp,
    core::fmt,
    htmlm::{html, write_html},
    rand_core::OsRng,
    serde::{Deserialize, Serialize},
    std::{
        collections::{HashMap, HashSet},
        fmt::{Display, Write},
        net::Ipv4Addr,
    },
};

const MAX_NAME_LENGTH: usize = 32;
const MAX_POSTNAME_LENGTH: usize = 64;
const MAX_CODE_LENGTH: usize = 1024 * 4;
const SESSION_DURATION_SECS: u64 = 60 * 60;
const MAX_FEED_SIZE: usize = 8 * 1024;

type Redirect<const COUNT: usize = 1> = AppendHeaders<[(&'static str, &'static str); COUNT]>;

macro_rules! static_asset {
    ($mime:literal, $body:literal) => {
        get(|| async {
            axum::http::Response::builder()
                .header("content-type", $mime)
                .header("content-encoding", "gzip")
                .body(axum::body::Body::from(Bytes::from_static(include_bytes!(concat!(
                    $body, ".gz"
                )))))
                .unwrap()
        })
    };
}

async fn amain() {
    use axum::routing::{delete, get, post};

    let debug = cfg!(debug_assertions);

    log::set_logger(&Logger).unwrap();
    log::set_max_level(if debug { log::LevelFilter::Warn } else { log::LevelFilter::Error });

    db::init();

    let router = axum::Router::new()
        .route("/", get(Index::page))
        .route("/index.css", static_asset!("text/css", "index.css"))
        .route("/index.js", static_asset!("text/javascript", "index.js"))
        .route("/hbfmt.wasm", static_asset!("application/wasm", "hbfmt.wasm"))
        .route("/hbc.wasm", static_asset!("application/wasm", "hbc.wasm"))
        .route("/index-view", get(Index::get))
        .route("/feed", get(Feed::page))
        .route("/feed-view", get(Feed::get))
        .route("/feed-more", post(Feed::more))
        .route("/profile", get(Profile::page))
        .route("/profile-view", get(Profile::get))
        .route("/profile/:name", get(Profile::get_other_page))
        .route("/profile-view/:name", get(Profile::get_other))
        .route("/post", get(Post::page))
        .route("/post-view", get(Post::get))
        .route("/post", post(Post::post))
        .route("/code", post(fetch_code))
        .route("/login", get(Login::page))
        .route("/login-view", get(Login::get))
        .route("/login", post(Login::post))
        .route("/login", delete(Login::delete))
        .route("/signup", get(Signup::page))
        .route("/signup-view", get(Signup::get))
        .route("/signup", post(Signup::post))
        .route(
            "/hot-reload",
            get({
                let id = std::time::SystemTime::now()
                    .duration_since(std::time::SystemTime::UNIX_EPOCH)
                    .unwrap()
                    .as_millis();
                move || async move { id.to_string() }
            }),
        );

    #[cfg(feature = "tls")]
    {
        let addr =
            (Ipv4Addr::UNSPECIFIED, std::env::var("DEPELL_PORT").unwrap().parse::<u16>().unwrap());
        let config = axum_server::tls_rustls::RustlsConfig::from_pem_file(
            std::env::var("DEPELL_CERT_PATH").unwrap(),
            std::env::var("DEPELL_KEY_PATH").unwrap(),
        )
        .await
        .unwrap();

        axum_server::bind_rustls(addr.into(), config)
            .serve(router.into_make_service())
            .await
            .unwrap();
    }
    #[cfg(not(feature = "tls"))]
    {
        let addr = (Ipv4Addr::UNSPECIFIED, 8080);
        let socket = tokio::net::TcpListener::bind(addr).await.unwrap();
        axum::serve(socket, router).await.unwrap();
    }
}

async fn fetch_code(
    axum::Json(paths): axum::Json<Vec<String>>,
) -> axum::Json<HashMap<String, String>> {
    let mut deps = HashMap::<String, String>::new();
    db::with(|db| {
        for path in &paths {
            let Some((author, name)) = path.split_once('/') else { continue };
            db.fetch_deps
                .query_map((name, author), |r| {
                    Ok((
                        r.get::<_, String>(1)? + "/" + r.get_ref(0)?.as_str()?,
                        r.get::<_, String>(2)?,
                    ))
                })
                .log("fetch deps query")
                .into_iter()
                .flatten()
                .filter_map(|r| r.log("deps row"))
                .collect_into(&mut deps);
        }
    });
    axum::Json(deps)
}

#[derive(Deserialize)]
#[serde(untagged)]
enum Feed {
    Before { before_timestamp: u64 },
}

#[derive(Deserialize)]
struct Before {
    before_timestamp: u64,
}

impl Feed {
    async fn more(session: Session, axum::Form(data): axum::Form<Before>) -> Html<String> {
        Self::Before { before_timestamp: data.before_timestamp }.render(&session)
    }
}

impl Default for Feed {
    fn default() -> Self {
        Self::Before { before_timestamp: now() + 3600 }
    }
}

impl Page for Feed {
    fn render_to_buf(self, _: &Session, buf: &mut String) {
        db::with(|db| {
            let cursor = match self {
                Feed::Before { before_timestamp } => db
                    .get_pots_before
                    .query_map((before_timestamp,), Post::from_row)
                    .log("fetch before posts query")
                    .into_iter()
                    .flatten()
                    .filter_map(|r| r.log("fetch before posts row")),
            };

            let base_len = buf.len();
            let mut last_timestamp = None;
            for post in cursor {
                write!(buf, "{}", post).unwrap();
                if buf.len() - base_len > MAX_FEED_SIZE {
                    last_timestamp = Some(post.timestamp);
                    break;
                }
            }

            write_html!((*buf)
                if let Some(last_timestamp) = last_timestamp {
                    <div "hx-post"="/feed-more"
                        "hx-trigger"="intersect once"
                        "hx-swap"="outerHTML"
                        "hx-vals"={format_args!("{{\"before_timestamp\":{last_timestamp}}}")}
                    >"there might be more"</div>
                } else {
                    "no more stuff"
                }
            );
        });
    }
}

#[derive(Default)]
struct Index;

impl PublicPage for Index {
    fn render_to_buf(self, buf: &mut String) {
        buf.push_str(include_str!("welcome-page.html"));
    }
}

#[derive(Deserialize, Default)]
struct Post {
    author: String,
    name: String,
    #[serde(skip)]
    timestamp: u64,
    #[serde(skip)]
    imports: usize,
    #[serde(skip)]
    runs: usize,
    #[serde(skip)]
    dependencies: usize,
    code: String,
    #[serde(skip)]
    error: Option<&'static str>,
}

impl Page for Post {
    fn render_to_buf(self, session: &Session, buf: &mut String) {
        let Self { name, code, error, .. } = self;
        write_html! { (buf)
            <form id="postForm" "hx-post"="/post" "hx-swap"="outerHTML">
                if let Some(e) = error { <div class="error">e</div> }
                <input name="author" type="text" value={session.name} hidden>
                <input name="name" type="text" placeholder="name" value=name
                    required maxlength=MAX_POSTNAME_LENGTH>
                <div id="code-editor">
                    <textarea id="code-edit" name="code" placeholder="code" rows=1
                        required>code</textarea>
                    <span id="code-size">MAX_CODE_LENGTH</span>
                </div>
                <input type="submit" value="submit">
                <pre id="compiler-output"></pre>
            </form>
            !{include_str!("post-page.html")}
        }
    }
}

impl Post {
    pub fn from_row(r: &rusqlite::Row) -> rusqlite::Result<Self> {
        Ok(Post {
            author: r.get(0)?,
            name: r.get(1)?,
            timestamp: r.get(2)?,
            code: r.get(3)?,
            ..Default::default()
        })
    }

    async fn post(
        session: Session,
        axum::Form(mut data): axum::Form<Self>,
    ) -> Result<Redirect, Html<String>> {
        if data.name.len() > MAX_POSTNAME_LENGTH {
            data.error = Some(formatcp!("name too long, max length is {MAX_POSTNAME_LENGTH}"));
            return Err(data.render(&session));
        }

        if data.code.len() > MAX_CODE_LENGTH {
            data.error = Some(formatcp!("code too long, max length is {MAX_CODE_LENGTH}"));
            return Err(data.render(&session));
        }

        db::with(|db| {
            if let Err(e) = db.create_post.insert((&data.name, &session.name, now(), &data.code)) {
                if let rusqlite::Error::SqliteFailure(e, _) = e {
                    if e.code == rusqlite::ErrorCode::ConstraintViolation {
                        data.error = Some("this name is already used");
                    }
                }
                data.error = data.error.or_else(|| {
                    log::error!("create post error: {e}");
                    Some("internal server error")
                });
                return;
            }

            for (author, name) in hblang::lexer::Lexer::uses(&data.code)
                .filter_map(|v| v.split_once('/'))
                .collect::<HashSet<_>>()
            {
                if db
                    .create_import
                    .insert((author, name, &session.name, &data.name))
                    .log("create import query")
                    .is_none()
                {
                    data.error = Some("internal server error");
                    return;
                };
            }
        });

        if data.error.is_some() {
            Err(data.render(&session))
        } else {
            Ok(redirect("/profile"))
        }
    }
}

impl fmt::Display for Post {
    fn fmt(&self, f: &mut std::fmt::Formatter<'_>) -> std::fmt::Result {
        let Self { author, name, timestamp, imports, runs, dependencies, code, .. } = self;
        write_html! { f <div class="preview">
            <div class="info">
                <span>
                    <a "hx-get"={format_args!("/profile-view/{author}")} href="" "hx-target"="main"
                        "hx-push-url"={format_args!("/profile/{author}")}
                        "hx-swam"="innerHTML">author</a>
                    "/"
                    name
                </span>
                <span apply="timestamp">timestamp</span>
            </div>
            <div class="stats">
                for (name, count) in "inps runs deps".split(' ')
                    .zip([imports, runs, dependencies])
                    .filter(|(_, &c)| c != 0)
                {
                    name ": "<span>count</span>
                }
            </div>
            <pre apply="fmt">code</pre>
            if *timestamp == 0 {
                <button "hx-get"="/post" "hx-swap"="outerHTML"
                    "hx-target"="[preview]">"edit"</button>
            }
        </div> }
        Ok(())
    }
}

#[derive(Default)]
struct Profile {
    other: Option<String>,
}

impl Profile {
    async fn get_other(session: Session, Path(name): Path<String>) -> Html<String> {
        Profile { other: Some(name) }.render(&session)
    }

    async fn get_other_page(
        session: Session,
        path: axum::extract::OriginalUri,
        Path(name): Path<String>,
    ) -> Html<String> {
        base(
            |b| Profile { other: Some(name) }.render_to_buf(&session, b),
            path.path(),
            Some(&session),
        )
    }
}

impl Page for Profile {
    fn render_to_buf(self, session: &Session, buf: &mut String) {
        db::with(|db| {
            let iter = db
                .get_user_posts
                .query_map((self.other.as_ref().unwrap_or(&session.name),), Post::from_row)
                .log("get user posts query")
                .into_iter()
                .flatten()
                .filter_map(|p| p.log("user post row"));
            write_html! { (buf)
                for post in iter {
                    !{post}
                } else {
                    "no posts"
                }
                !{include_str!("profile-page.html")}
            }
        })
    }
}

fn hash_password(password: &str) -> String {
    use argon2::PasswordHasher;
    argon2::Argon2::default()
        .hash_password(password.as_bytes(), &SaltString::generate(&mut OsRng))
        .unwrap()
        .to_string()
}

fn verify_password(hash: &str, password: &str) -> Result<(), argon2::password_hash::Error> {
    argon2::Argon2::default()
        .verify_password(password.as_bytes(), &argon2::PasswordHash::new(hash)?)
}

#[derive(Serialize, Deserialize, Default, Debug)]
struct Login {
    name: String,
    password: String,
    #[serde(skip)]
    error: Option<&'static str>,
}

impl PublicPage for Login {
    fn render_to_buf(self, buf: &mut String) {
        let Login { name, password, error } = self;
        write_html! { (buf)
            <form "hx-post"="/login" "hx-swap"="outerHTML">
                if let Some(e) = error { <div class="error">e</div> }
                <input name="name" type="text" autocomplete="name" placeholder="name" value=name
                    required maxlength=MAX_NAME_LENGTH>
                <input name="password" type="password" autocomplete="current-password" placeholder="password"
                    value=password>
                <input type="submit" value="submit">
            </form>
        }
    }
}

impl Login {
    async fn post(
        axum::Form(mut data): axum::Form<Self>,
    ) -> Result<AppendHeaders<[(&'static str, String); 2]>, Html<String>> {
        // TODO: hash password
        let mut id = [0u8; 32];
        db::with(|db| match db.authenticate.query_row((&data.name,), |r| r.get::<_, String>(1)) {
            Ok(hash) => {
                if verify_password(&hash, &data.password).is_err() {
                    data.error = Some("invalid credentials");
                } else {
                    getrandom::getrandom(&mut id).unwrap();
                    if db
                        .login
                        .insert((id, &data.name, now() + SESSION_DURATION_SECS))
                        .log("create session query")
                        .is_none()
                    {
                        data.error = Some("internal server error");
                    }
                }
            }
            Err(rusqlite::Error::QueryReturnedNoRows) => {
                data.error = Some("invalid credentials");
            }
            Err(e) => {
                log::error!("foo {e}");
                data.error = Some("internal server error");
            }
        });

        if data.error.is_some() {
            log::error!("what {:?}", data);
            Err(data.render())
        } else {
            Ok(AppendHeaders([
                ("hx-location", "/feed".into()),
                (
                    "set-cookie",
                    format!(
                        "id={}; SameSite=Strict; Secure; Max-Age={SESSION_DURATION_SECS}",
                        to_hex(&id)
                    ),
                ),
            ]))
        }
    }

    async fn delete(session: Session) -> Redirect {
        _ = db::with(|q| q.logout.execute((session.id,)).log("delete session query"));
        redirect("/login")
    }
}

#[derive(Serialize, Deserialize, Default)]
struct Signup {
    name: String,
    new_password: String,
    confirm_password: String,
    #[serde(default)]
    confirm_no_password: bool,
    #[serde(skip)]
    error: Option<&'static str>,
}

impl PublicPage for Signup {
    fn render_to_buf(self, buf: &mut String) {
        let Signup { name, new_password, confirm_password, confirm_no_password, error } = self;
        let vals = if confirm_no_password { "{\"confirm_no_password\":true}" } else { "{}" };
        write_html! { (buf)
            <form "hx-post"="/signup" "hx-swap"="outerHTML" "hx-vals"=vals>
                if let Some(e) = error { <div class="error">e</div> }
                <input name="name" type="text" autocomplete="name" placeholder="name" value=name
                    maxlength=MAX_NAME_LENGTH required>
                <input name="new_password" type="password" autocomplete="new-password" placeholder="new password"
                    value=new_password>
                <input name="confirm_password" type="password" autocomplete="confirm-password"
                    placeholder="confirm password" value=confirm_password>
                <input type="submit" value="submit">
            </form>
        }
    }
}

impl Signup {
    async fn post(axum::Form(mut data): axum::Form<Self>) -> Result<Redirect, Html<String>> {
        if data.name.len() > MAX_NAME_LENGTH {
            data.error = Some(formatcp!("name too long, max length is {MAX_NAME_LENGTH}"));
            return Err(data.render());
        }

        if !data.confirm_no_password && data.new_password.is_empty() {
            data.confirm_no_password = true;
            data.error = Some("Are you sure you don't want to use a password? (then submit again)");
            return Err(data.render());
        }

        db::with(|db| {
            // TODO: hash passwords
            match db.register.insert((&data.name, hash_password(&data.new_password))) {
                Ok(_) => {}
                Err(rusqlite::Error::SqliteFailure(e, _))
                    if e.code == rusqlite::ErrorCode::ConstraintViolation =>
                {
                    data.error = Some("username already taken");
                }
                Err(e) => {
                    log::error!("create user query: {e}");
                    data.error = Some("internal server error");
                }
            };
        });

        if data.error.is_some() {
            Err(data.render())
        } else {
            Ok(redirect("/login"))
        }
    }
}

fn base(body: impl FnOnce(&mut String), path: &str, session: Option<&Session>) -> Html<String> {
    let username = session.map(|s| &s.name);

    let nav_button = |f: &mut String, name: &str| {
        write_html! {(f)
            <button "hx-push-url"={format_args!("/{name}")}
                "hx-get"={format_args!("/{name}-view")}
                "hx-target"="main"
                "hx-swap"="innerHTML">name</button>
        }
    };

    Html(html! {
        "<!DOCTYPE html>"
        <html lang="en">
            <head>
                <meta name="charset" content="UTF-8">
                <meta name="viewport" content="width=device-width, initial-scale=1">
                <link rel="stylesheet" href="/index.css">
            </head>
            <body>
                <nav>
                    <button "hx-push-url"="/" "hx-get"="/index-view" "hx-target"="main" "hx-swap"="innerHTML">"depell"</button>
                    <section>
                        if let Some(username) = username {
                            <button "hx-push-url"="/profile" "hx-get"="/profile-view" "hx-target"="main"
                                "hx-swap"="innerHTML">username</button>
                            |f|{nav_button(f, "feed"); nav_button(f, "post")}
                            <button "hx-delete"="/login">"logout"</button>
                        } else {
                            |f|{nav_button(f, "login"); nav_button(f, "signup")}
                        }
                    </section>
                </nav>
                <section id="post-form"></section>
                <main>|f|{body(f)}</main>
            </body>
            <script src="https://unpkg.com/htmx.org@2.0.3/dist/htmx.min.js" integrity="sha384-0895/pl2MU10Hqc6jd4RvrthNlDiE9U1tWmX7WRESftEDRosgxNsQG/Ze9YMRzHq" crossorigin="anonymous"></script>
            <script type="module" src="/index.js"></script>
        </html>
    })
}

struct Session {
    name: String,
    id: [u8; 32],
}

#[axum::async_trait]
impl<S> axum::extract::FromRequestParts<S> for Session {
    /// If the extractor fails it'll use this "rejection" type. A rejection is
    /// a kind of error that can be converted into a response.
    type Rejection = Redirect;

    /// Perform the extraction.
    async fn from_request_parts(parts: &mut Parts, _: &S) -> Result<Self, Self::Rejection> {
        let err = redirect("/login");

        let value = parts
            .headers
            .get_all(COOKIE)
            .into_iter()
            .find_map(|c| c.to_str().ok()?.trim().strip_prefix("id="))
            .map(|c| c.split_once(';').unwrap_or((c, "")).0)
            .ok_or(err)?;
        let mut id = [0u8; 32];
        parse_hex(value, &mut id).ok_or(err)?;

        let (name, expiration) = db::with(|db| {
            db.get_session
                .query_row((id,), |r| Ok((r.get::<_, String>(0)?, r.get::<_, u64>(1)?)))
                .log("fetching session")
                .ok_or(err)
        })?;

        if expiration < now() {
            return Err(err);
        }

        Ok(Self { name, id })
    }
}

fn now() -> u64 {
    std::time::SystemTime::now()
        .duration_since(std::time::SystemTime::UNIX_EPOCH)
        .unwrap()
        .as_secs()
}

fn parse_hex(hex: &str, dst: &mut [u8]) -> Option<()> {
    fn hex_to_nibble(b: u8) -> Option<u8> {
        Some(match b {
            b'a'..=b'f' => b - b'a' + 10,
            b'A'..=b'F' => b - b'A' + 10,
            b'0'..=b'9' => b - b'0',
            _ => return None,
        })
    }

    if hex.len() != dst.len() * 2 {
        return None;
    }

    for (d, p) in dst.iter_mut().zip(hex.as_bytes().chunks_exact(2)) {
        *d = (hex_to_nibble(p[0])? << 4) | hex_to_nibble(p[1])?;
    }

    Some(())
}

fn to_hex(src: &[u8]) -> String {
    use std::fmt::Write;
    let mut buf = String::new();
    for &b in src {
        write!(buf, "{b:02x}").unwrap()
    }
    buf
}

fn main() {
    tokio::runtime::Builder::new_current_thread().enable_all().build().unwrap().block_on(amain());
}

mod db {
    use std::cell::RefCell;

    macro_rules! gen_queries {
        ($vis:vis struct $name:ident {
            $($qname:ident: $code:expr,)*
        }) => {
            #[allow(dead_code)]
            $vis struct $name<'a> {
                $($vis $qname: rusqlite::Statement<'a>,)*
            }

            impl<'a> $name<'a> {
                fn new(db: &'a rusqlite::Connection) -> Self {
                    Self {
                        $($qname: db.prepare($code).unwrap(),)*
                    }
                }
            }
        };
    }

    gen_queries! {
        pub struct Queries {
            register: "INSERT INTO user (name, password_hash) VALUES(?, ?)",
            authenticate: "SELECT name, password_hash FROM user WHERE name = ?",
            login: "INSERT OR REPLACE INTO session (id, username, expiration) VALUES(?, ?, ?)",
            logout: "DELETE FROM session WHERE id = ?",
            get_session: "SELECT username, expiration FROM session WHERE id = ?",
            get_user_posts: "SELECT author, name, timestamp, code FROM post WHERE author = ?
                ORDER BY timestamp DESC",
            get_pots_before: "SELECT author, name, timestamp, code FROM post WHERE timestamp < ?",
            create_post: "INSERT INTO post (name, author, timestamp, code) VALUES(?, ?, ?, ?)",
            fetch_deps: "
                WITH RECURSIVE roots(name, author, code) AS (
                    SELECT name, author, code FROM post WHERE name = ? AND author = ?
                    UNION ALL
                    SELECT post.name, post.author, post.code FROM
                        post JOIN import ON post.name = import.to_name
                            AND post.author = import.to_author
                        JOIN roots ON import.from_name = roots.name
                            AND import.from_author = roots.author
                ) SELECT * FROM roots;
            ",
            create_import: "INSERT INTO import(to_author, to_name, from_author, from_name)
                VALUES(?, ?, ?, ?)",
        }
    }

    struct Db {
        queries: Queries<'static>,
        _db: Box<rusqlite::Connection>,
    }

    impl Db {
        fn new() -> Self {
            let db = Box::new(rusqlite::Connection::open("db.sqlite").unwrap());
            Self {
                queries: Queries::new(unsafe {
                    std::mem::transmute::<&rusqlite::Connection, &rusqlite::Connection>(&db)
                }),
                _db: db,
            }
        }
    }

    pub fn with<T>(with: impl FnOnce(&mut Queries) -> T) -> T {
        thread_local! { static DB_CONN: RefCell<Db> = RefCell::new(Db::new()); }
        DB_CONN.with_borrow_mut(|q| with(&mut q.queries))
    }

    pub fn init() {
        let db = rusqlite::Connection::open("db.sqlite").unwrap();
        db.execute_batch(include_str!("schema.sql")).unwrap();
        Queries::new(&db);
    }
}

fn redirect(to: &'static str) -> Redirect {
    AppendHeaders([("hx-location", to)])
}

trait PublicPage: Default {
    fn render_to_buf(self, buf: &mut String);

    fn render(self) -> Html<String> {
        let mut str = String::new();
        self.render_to_buf(&mut str);
        Html(str)
    }

    async fn get() -> Html<String> {
        Self::default().render()
    }

    async fn page(uri: OriginalUri, session: Option<Session>) -> Html<String> {
        base(|s| Self::default().render_to_buf(s), uri.path(), session.as_ref())
    }
}

trait Page: Default {
    fn render_to_buf(self, session: &Session, buf: &mut String);

    fn render(self, session: &Session) -> Html<String> {
        let mut str = String::new();
        self.render_to_buf(session, &mut str);
        Html(str)
    }

    async fn get(session: Session) -> Html<String> {
        Self::default().render(&session)
    }

    async fn page(
        uri: OriginalUri,
        session: Option<Session>,
    ) -> Result<Html<String>, axum::response::Redirect> {
        match session {
            Some(session) => {
                Ok(base(|f| Self::default().render_to_buf(&session, f), uri.path(), Some(&session)))
            }
            None => Err(axum::response::Redirect::permanent("/login")),
        }
    }
}

trait ResultExt<O, E> {
    fn log(self, prefix: impl Display) -> Option<O>;
}

impl<O, E: Display> ResultExt<O, E> for Result<O, E> {
    fn log(self, prefix: impl Display) -> Option<O> {
        match self {
            Ok(v) => Some(v),
            Err(e) => {
                log::error!("{prefix}: {e}");
                None
            }
        }
    }
}

struct Logger;

impl log::Log for Logger {
    fn enabled(&self, _: &log::Metadata) -> bool {
        true
    }

    fn log(&self, record: &log::Record) {
        if self.enabled(record.metadata()) {
            eprintln!("{} - {}", record.module_path().unwrap_or("=="), record.args());
        }
    }

    fn flush(&self) {}
}