use crate::{DataBaseRo, WebData};

use crate::{DataBaseRo, DataBaseRw, WebData};

    data_rw: web::Data<DataBaseRw>,

    let dbclient_rw = match data_rw.0.get().await {
        Ok(c) => c,
        Err(e) => {
            log::error!("Pool RW error {}", e);
            return HttpResponse::ServiceUnavailable().body(actix_web::body::None::new());
        }
    };

    // Try to register on Mastodon

    let stmt = match dbclient_rw
        .prepare(
            "INSERT INTO auth.mastodon_apps (domain, refresh_ts) VALUES ($1, $2)
            ON CONFLICT (domain) DO UPDATE SET refresh_ts = $2
            RETURNING client_id, client_secret;",
        )
        .await
    {
        Ok(stmt) => stmt,
        Err(e) => {
            log::error!("Pool RW statement error {}", e);
            return HttpResponse::ServiceUnavailable().body(actix_web::body::None::new());
        }
    };
    let ts = chrono::Utc::now().naive_utc();
    let rows = match dbclient_rw.query_opt(&stmt, &[&domain, &ts]).await {
        Ok(rows) => rows,
        Err(e) => {
            log::error!("Pool RW query error {}", e);
            return HttpResponse::ServiceUnavailable().body(actix_web::body::None::new());
        }
    };
    let row = match rows {
        Some(row) => row,
        None => {
            log::error!("Pool RW query error");
            return HttpResponse::ServiceUnavailable().body(actix_web::body::None::new());
        }
    };

    let opt_client_id = row.get::<_, Option<&str>>(0);
    let opt_client_secret = row.get::<_, Option<&str>>(1);
    // Try to register on Mastodon domain

-- Create table to store client_id and client_secret for mastodon instances
CREATE TABLE IF NOT EXISTS auth.mastodon_apps (
 domain VARCHAR(100) NOT NULL,
 refresh_ts TIMESTAMP WITHOUT TIME ZONE NOT NULL,
 client_id VARCHAR(255) NULL,
 client_secret VARCHAR(255) NULL,
 CONSTRAINT pk_domain PRIMARY KEY (domain)
);
GRANT SELECT, INSERT, UPDATE ON auth.mastodon_apps TO freeorion_test;