path: root/src/models/event.rs

/*
    Social program for Ramaskrik.
    Copyright (C) 2019, 2020  Harald Eilertsen <haraldei@anduin.net>

    This program is free software: you can redistribute it and/or modify
    it under the terms of the GNU Affero General Public License as published by
    the Free Software Foundation, either version 3 of the License, or
    (at your option) any later version.

    This program is distributed in the hope that it will be useful,
    but WITHOUT ANY WARRANTY; without even the implied warranty of
    MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
    GNU Affero General Public License for more details.

    You should have received a copy of the GNU Affero General Public License
    along with this program.  If not, see <https://www.gnu.org/licenses/>.
*/

use crate::db;
use crate::schema::*;
use diesel::prelude::*;
use serde::Serialize;

#[derive(Identifiable, Queryable, Serialize)]
#[table_name = "event"]
pub struct Event {
    pub id: i32,
    pub name: String,
    pub description: Option<String>,
}

impl Event {
    pub async fn get(db: &db::Connection) -> QueryResult<Event> {
        db.run(|conn| {
            use crate::schema::event::dsl::*;
            event.first(conn)
        }).await
    }

    pub async fn get_event(db: &db::Connection, eventid: i32) -> QueryResult<Event> {
        db.run(move |conn| {
            use crate::schema::event::dsl::*;
            event.filter(id.eq(eventid)).first(conn)
        }).await
    }

    pub async fn get_all_events(db: &db::Connection) -> QueryResult<Vec<Event>> {
        db.run(|conn| {
            use crate::schema::event::dsl::*;
            event.load(conn)
        }).await
    }

    pub async fn create(db: &db::Connection, eventname: String, desc: String) -> QueryResult<Event> {
        db.run(move |conn| {
            use crate::schema::event::dsl::*;
            let new_event = (name.eq(&eventname), description.eq(&desc));
            diesel::insert_into(event)
                .values(&new_event)
                .get_result(conn)
        }).await
    }
}