taskter 0.1.0

use anyhow::Result;
use lettre::{transport::smtp::authentication::Credentials, Message, SmtpTransport, Transport};
use serde::Deserialize;
use serde_json::Value;
use std::fs;
use std::path::Path;

use crate::agent::FunctionDeclaration;

#[derive(Deserialize)]
struct EmailConfig {
    smtp_server: String,
    smtp_port: u16,
    username: String,
    password: String,
}

const DECL_JSON: &str = include_str!("../../tools/send_email.json");

pub fn declaration() -> FunctionDeclaration {
    serde_json::from_str(DECL_JSON).expect("invalid send_email.json")
}

pub fn execute(args: &Value) -> Result<String> {
    let to = args["to"].as_str().unwrap_or_default();
    let subject = args["subject"].as_str().unwrap_or_default();
    let body = args["body"].as_str().unwrap_or_default();
    match send_email(to, subject, body) {
        Ok(_) => Ok(format!(
            "Email sent to {to} with subject '{subject}' and body '{body}'"
        )),
        Err(e) => Ok(format!("Failed to send email: {e}")),
    }
}

fn send_email(to: &str, subject: &str, body: &str) -> Result<()> {
    let config_path = Path::new(".taskter/email_config.json");
    let config_str = match fs::read_to_string(config_path) {
        Ok(content) => content,
        Err(_) => return Err(anyhow::anyhow!("Email configuration not found")),
    };

    let config: EmailConfig = serde_json::from_str(&config_str)?;

    let email = Message::builder()
        .from(config.username.parse()?)
        .to(to.parse()?)
        .subject(subject)
        .body(body.to_string())?;

    let creds = Credentials::new(config.username, config.password);

    let mailer = SmtpTransport::relay(&config.smtp_server)?
        .port(config.smtp_port)
        .credentials(creds)
        .build();

    mailer.send(&email).map(|_| ()).map_err(|e| e.into())
}