Move max room duration into config (#244)

src/app/endpoint/rtc.rs

@@ -35,8 +35,6 @@ pub(crate) type ConnectResponse = OutgoingResponse<ConnectResponseData>;
 
 ////////////////////////////////////////////////////////////////////////////////
 
-const MAX_WEBINAR_DURATION: i64 = 7;
-
 #[derive(Debug, Deserialize)]
 pub(crate) struct CreateRequest {
     room_id: Uuid,
@@ -79,15 +77,17 @@ impl RequestHandler for CreateHandler {
             let conn = context.get_conn()?;
 
             conn.transaction::<_, diesel::result::Error, _>(|| {
-                if let (start, Bound::Unbounded) = room.time() {
-                    let new_time = (
-                        *start,
-                        Bound::Excluded(Utc::now() + Duration::hours(MAX_WEBINAR_DURATION)),
-                    );
+                if let Some(max_room_duration) = context.config().max_room_duration {
+                    if let (start, Bound::Unbounded) = room.time() {
+                        let new_time = (
+                            *start,
+                            Bound::Excluded(Utc::now() + Duration::hours(max_room_duration)),
+                        );
 
-                    db::room::UpdateQuery::new(room.id())
-                        .time(Some(new_time))
-                        .execute(&conn)?;
+                        db::room::UpdateQuery::new(room.id())
+                            .time(Some(new_time))
+                            .execute(&conn)?;
+                    }
                 }
 
                 let rtc =

src/config.rs

@@ -22,6 +22,7 @@ pub(crate) struct Config {
     #[serde(default)]
     pub(crate) kruonis: KruonisConfig,
     pub(crate) metrics: Option<MetricsConfig>,
+    pub(crate) max_room_duration: Option<i64>,
 }
 
 #[derive(Clone, Debug, Deserialize)]

src/test_helpers/context.rs

@@ -56,7 +56,8 @@ fn build_config() -> Config {
                     "bucket": format!("origin.minigroup.{}", USR_AUDIENCE),
                 }
             }
-        }
+        },
+        "max_room_duration": 7,
     });
 
     serde_json::from_value::<Config>(config).expect("Failed to parse test config")