start working on cal

src/model/trip.rs

@@ -1,4 +1,5 @@
 use chrono::{Local, NaiveDate};
+use ics::properties::{DtStart, Summary};
 use serde::Serialize;
 use sqlx::SqlitePool;
 
@@ -9,6 +10,7 @@ use super::{
     tripdetails::TripDetails,
     triptype::TripType,
     user::{CoxUser, User},
+    usertrip::UserTrip,
 };
 
 #[derive(Serialize, Clone, Debug)]
@@ -123,6 +125,61 @@ WHERE trip_details.id=?
         .ok()
     }
 
+    pub(crate) async fn get_vevent(self, db: &SqlitePool) -> ics::Event {
+        let mut vevent = ics::Event::new(format!("{}@rudernlinz.at", self.id), "19900101T180000");
+        vevent.push(DtStart::new(format!(
+            "{}T{}00",
+            self.day.replace('-', ""),
+            self.planned_starting_time.replace(':', "")
+        )));
+        let mut name = String::new();
+        if self.is_cancelled() {
+            name.push_str("ABGESAGT");
+            if let Some(notes) = &self.notes {
+                if !notes.is_empty() {
+                    name.push_str(&format!(" (Grund: {notes})"))
+                }
+            }
+
+            name.push_str("! :-( ");
+        }
+        name.push_str(&format!("Ruderausfahrt mit {} ", self.cox_name));
+
+        vevent.push(Summary::new(name));
+        vevent
+    }
+
+    pub async fn all(db: &SqlitePool) -> Vec<Self> {
+        sqlx::query_as!(
+            Self,
+            "
+SELECT trip.id, cox_id, user.name as cox_name, trip_details_id, planned_starting_time, max_people, day, trip_details.notes, allow_guests, trip_type_id, always_show, is_locked
+FROM trip 
+INNER JOIN trip_details ON trip.trip_details_id = trip_details.id
+INNER JOIN user ON trip.cox_id = user.id
+",
+        )
+        .fetch_all(db)
+        .await
+        .unwrap() //TODO: fixme
+    }
+
+    pub async fn all_with_user(db: &SqlitePool, user: &User) -> Vec<Self> {
+        let mut ret = Vec::new();
+        let trips = Self::all(db).await;
+        for trip in trips {
+            if let Some(trip_details_id) = trip.trip_details_id {
+                if UserTrip::find_by_userid_and_trip_detail_id(db, user.id, trip_details_id)
+                    .await
+                    .is_some()
+                {
+                    ret.push(trip);
+                }
+            }
+        }
+        ret
+    }
+
     pub async fn find_by_id(db: &SqlitePool, id: i64) -> Option<Self> {
         sqlx::query_as!(
             Self,
@@ -370,6 +427,10 @@ WHERE day=?
         trips.retain(|e| e.trip.always_show);
         trips
     }
+
+    fn is_cancelled(&self) -> bool {
+        self.max_people == 0
+    }
 }
 
 #[derive(Debug)]