use super::models::*;
use diesel::prelude::*;
use diesel::result::Error;

type DBConn = SqliteConnection;

pub fn read_photos(conn: &DBConn) -> Result<Vec<Photo>, Error> {
    use crate::schema::photos::dsl::*;
    let results = photos.load::<Photo>(conn)?;
    Ok(results)
}

fn read_photos_by_path(conn: &DBConn, path: &str) -> Result<Vec<Photo>, Error> {
    use crate::schema::photos::dsl::*;
    let results = photos.filter(path.eq(path)).load::<Photo>(conn)?;
    Ok(results)
}

pub fn read_photo_by_path(conn: &DBConn, path: &str) -> Result<Option<Photo>, Error> {
    use crate::schema::photos::dsl::*;
    let results = photos.filter(path.eq(path)).limit(1).load::<Photo>(conn)?;
    Ok(results.first().cloned())
}

pub fn read_photo_by_id(conn: &DBConn, id: i32) -> Result<Option<Photo>, Error> {
    use crate::schema::photos::dsl::*;
    let results = photos.filter(id.eq(id)).limit(1).load::<Photo>(conn)?;
    Ok(results.first().cloned())
}

pub fn create_photo(conn: &DBConn, new_photo: NewPhoto) -> Result<Option<Photo>, Error> {
    use super::schema::photos;
    diesel::insert_into(photos::table)
        .values(&new_photo)
        .execute(conn)?;
    read_photo_by_path(conn, &new_photo.path)
}

pub fn update_photo() {
    todo!()
}