use windmill_common::{
    audit::AuditAuthor,
    db::{Authable, DbWithOptAuthed},
};

#[cfg(feature = "private")]
#[allow(unused)]
pub use crate::audit_ee::*;

/*
 * Author: Ruben Fiszel
 * Copyright: Windmill Labs, Inc 2022
 * This file and its contents are licensed under the AGPLv3 License.
 * Please see the included NOTICE for copyright information and
 * LICENSE-AGPL for a copy of the license.
 */
#[cfg(not(feature = "private"))]
use {
    crate::{ActionKind, AuditLog, ListAuditLogQuery},
    sqlx::{Postgres, Transaction},
    std::collections::HashMap,
    windmill_common::{
        error::{Error, Result},
        utils::Pagination,
    },
};

impl<'a, T: Authable + AuditAuthorable + Sync> AuditAuthorable for DbWithOptAuthed<'a, T> {
    fn email(&self) -> &str {
        match self {
            DbWithOptAuthed::UserDB { authed, .. } => AuditAuthorable::email(*authed),
            DbWithOptAuthed::DB { audit_author, .. } => audit_author.email(),
        }
    }
    fn username(&self) -> &str {
        match self {
            DbWithOptAuthed::UserDB { authed, .. } => AuditAuthorable::username(*authed),
            DbWithOptAuthed::DB { audit_author, .. } => audit_author.username(),
        }
    }
    fn username_override(&self) -> Option<&str> {
        match self {
            DbWithOptAuthed::UserDB { authed, .. } => AuditAuthorable::username_override(*authed),
            DbWithOptAuthed::DB { .. } => None,
        }
    }
}

impl AuditAuthorable for AuditAuthor {
    fn email(&self) -> &str {
        &self.email
    }

    fn username(&self) -> &str {
        &self.username
    }

    fn username_override(&self) -> Option<&str> {
        self.username_override.as_deref()
    }

    fn token_prefix(&self) -> Option<&str> {
        self.token_prefix.as_deref()
    }
}

pub trait AuditAuthorable {
    fn username(&self) -> &str;
    fn email(&self) -> &str;
    fn username_override(&self) -> Option<&str>;
    fn token_prefix(&self) -> Option<&str> {
        None
    }
}

#[cfg(not(feature = "private"))]
#[tracing::instrument(level = "trace", skip_all)]
pub async fn audit_log<'c, E: sqlx::Executor<'c, Database = Postgres>>(
    _db: E,
    _author: &impl AuditAuthorable,
    mut _operation: &str,
    _action_kind: ActionKind,
    _w_id: &str,
    mut _resource: Option<&str>,
    _parameters: Option<HashMap<&str, &str>>,
) -> Result<()> {
    // Implementation is not open source as Audit logs is a Windmill Enterprise Edition feature
    Ok(())
}

#[cfg(not(feature = "private"))]
pub async fn list_audit(
    _tx: Transaction<'_, Postgres>,
    _w_id: String,
    _pagination: Pagination,
    _lq: ListAuditLogQuery,
) -> Result<Vec<AuditLog>> {
    // Implementation is not open source as Audit logs is a Windmill Enterprise Edition feature
    return Ok(vec![]);
}

#[cfg(not(feature = "private"))]
pub async fn get_audit(tx: Transaction<'_, Postgres>, _id: i32, _w_id: &str) -> Result<AuditLog> {
    // Implementation is not open source as Audit logs is a Windmill Enterprise Edition feature
    tx.commit().await?;
    Err(Error::NotFound(
        "Audit log not not available in Windmill Community edition".to_string(),
    ))
}