pub mod atom_turns;

    pub base_url: String,

use crate::WebData;
use actix_web::{web, HttpResponse};
#[derive(serde_derive::Serialize)]
struct FeedData {
    gameuid: String,
    gameuidenc: String,
    upddatetime: String,
    entries: Vec<EntriesData>,
    selflink: String,
}
#[derive(serde_derive::Serialize)]
struct EntriesData {
    new: bool,
    turn: i32,
    turn_ts_str: String,
    turn_ts: i64,
}
#[actix_web::get("/atoms/{path}.xml")]
pub async fn atom_turns(path: web::Path<String>, data: web::Data<WebData<'_>>) -> HttpResponse {
    let gameuid = path.into_inner();
    let gameuid = match gameuid.char_indices().nth(128) {
        None => gameuid,
        Some((idx, _)) => (&gameuid[..idx]).to_string(),
    };
    let dbclient = match data.pool_ro.get().await {
        Ok(client) => client,
        Err(e) => {
            log::error!("{}", e);
            return HttpResponse::ServiceUnavailable().body(actix_web::body::None::new());
        }
    };
    let stmt = match dbclient.prepare("select g.game_uid, t.turn, t.turn_ts from games.games g left join games.turns t on t.game_uid = g.game_uid where g.game_uid = $1 order by t.turn_ts desc limit 50;").await {
        Ok(stmt) => stmt,
        Err(e) => {
            log::error!("{}", e);
            return HttpResponse::ServiceUnavailable().body(actix_web::body::None::new());
        }
    };
    let rows = match dbclient.query(&stmt, &[&gameuid]).await {
        Ok(rows) => rows,
        Err(e) => {
            log::error!("{}", e);
            return HttpResponse::ServiceUnavailable().body(actix_web::body::None::new());
        }
    };
    if rows.is_empty() {
        log::info!("Empty data for {}", gameuid);
        return HttpResponse::NotFound().body(actix_web::body::None::new());
    }
    let mut upd_date_time = None;
    let mut entries = Vec::with_capacity(rows.len());
    for row in rows {
        if let Some(turn) = row.get::<_, Option<i32>>(1) {
            if let Some(turn_ts) = row.get::<_, Option<chrono::NaiveDateTime>>(2) {
                let entry_ts = chrono::DateTime::from_utc(turn_ts, chrono::Utc);
                entries.insert(
                    0,
                    EntriesData {
                        new: turn <= 0,
                        turn,
                        turn_ts_str: entry_ts.to_rfc3339_opts(chrono::SecondsFormat::Secs, true),
                        turn_ts: entry_ts.timestamp(),
                    },
                );
                upd_date_time.get_or_insert(entry_ts);
            }
        }
    }
    let upd_date_time = upd_date_time.unwrap_or_else(chrono::Utc::now);
    let body = match data.handlebars.render(
        "turns",
        &FeedData {
            gameuid: gameuid.to_string(),
            gameuidenc: pct_str::PctString::encode(gameuid.chars(), pct_str::URIReserved)
                .into_string(),
            entries,
            upddatetime: upd_date_time.to_rfc3339_opts(chrono::SecondsFormat::Secs, true),
            selflink: data.base_url.to_string(),
        },
    ) {
        Ok(b) => b,
        Err(e) => {
            log::error!("{}", e);
            return HttpResponse::ServiceUnavailable().body(actix_web::body::None::new());
        }
    };
    HttpResponse::Ok()
        .insert_header(("Content-Type", "application/atom+xml"))
        .insert_header((
            "Date",
            upd_date_time
                .format("%a, %d %b %Y %H:%M:%S GMT")
                .to_string(),
        ))
        .body(body)
}

use pages::atom_turns::atom_turns;

        base_url,

    handlebars
        .register_template_string("atom-games", include_str!("templates/games.xml"))
        .expect("atom games template");
    handlebars
        .register_template_string("atom-turns", include_str!("templates/turns.xml"))
        .expect("atom games template");

        base_url,

            .service(post_reset_game_pwd);

            .service(post_reset_game_pwd)
            .service(atom_turns);

    pub base_url: String,

chrono = "0.4"
pct-str = "1.1"

features = ["with-uuid-0_8"]

features = ["with-uuid-0_8", "with-chrono-0_4"]

 "time",

 "time 0.3.7",

[[package]]
name = "chrono"
version = "0.4.19"
source = "registry+https://github.com/rust-lang/crates.io-index"
checksum = "670ad68c9088c2a963aaa298cb369688cf3f9465ce5e2d4ca10e6e0098a1ce73"
dependencies = [
 "libc",
 "num-integer",
 "num-traits",
 "time 0.1.43",
 "winapi",
]

 "time",

 "time 0.3.7",

 "chrono",

 "pct-str",

name = "num-integer"
version = "0.1.44"
source = "registry+https://github.com/rust-lang/crates.io-index"
checksum = "d2cc698a63b549a70bc047073d2949cce27cd1c7b0a4a862d08a8031bc2801db"
dependencies = [
 "autocfg",
 "num-traits",
]
[[package]]
name = "num-traits"
version = "0.2.14"
source = "registry+https://github.com/rust-lang/crates.io-index"
checksum = "9a64b1ec5cda2586e284722486d802acf1f7dbdc623e2bfc57e65ca1cd099290"
dependencies = [
 "autocfg",
]
[[package]]

name = "pct-str"
version = "1.1.0"
source = "registry+https://github.com/rust-lang/crates.io-index"
checksum = "1240e3e7bfdde5660ba0fc3e9e3565d3b30c2ae1973e218e93b869da771ff2e9"
[[package]]

 "chrono",

version = "0.1.43"
source = "registry+https://github.com/rust-lang/crates.io-index"
checksum = "ca8a50ef2360fbd1eeb0ecd46795a87a19024eb4b53c5dc916ca1fd95fe62438"
dependencies = [
 "libc",
 "winapi",
]
[[package]]
name = "time"