rowt/src/model/log.rs

use chrono::{DateTime, Local, NaiveDateTime, Utc};
use serde::{Deserialize, Serialize};
use sqlx::{FromRow, SqlitePool};

#[derive(FromRow, Debug, Serialize, Deserialize)]
pub struct Log {
    pub msg: String,
    pub created_at: NaiveDateTime,
}

impl Log {
    pub async fn create(db: &SqlitePool, msg: String) -> bool {
        sqlx::query!("INSERT INTO log(msg) VALUES (?)", msg,)
            .execute(db)
            .await
            .is_ok()
    }

    async fn last(db: &SqlitePool) -> Vec<Log> {
        sqlx::query_as!(
            Log,
            "
SELECT msg, created_at
FROM log 
ORDER BY id DESC
LIMIT 1000
    "
        )
        .fetch_all(db)
        .await
        .unwrap()
    }

    pub async fn generate_feed(db: &SqlitePool) -> String {
        let mut ret = String::from(
            r#"<?xml version="1.0" encoding="utf-8"?>
<rss version="2.0">
<channel>
<title>Ruder App Admin Feed</title>
<link>app.rudernlinz.at</link>
<description>An RSS feed with activities from app.rudernlinz.at</description>"#,
        );
        for log in Self::last(db).await {
            let utc_time: DateTime<Utc> = DateTime::from_utc(log.created_at, Utc);
            let local_time = utc_time.with_timezone(&Local);
            ret.push_str("<item><title>");
            ret.push_str(&format!("({}) {}", local_time, log.msg));
            ret.push_str("</title></item>");
        }
        ret.push_str("</channel>");
        ret.push_str("</rss>");
        ret.replace('\n', "")
    }
}