Fix description cache

.env

@@ -23,6 +23,7 @@ S3_SECRET=none
 S3_URL=none
 S3_REGION=none
 S3_BUCKET_NAME=none
+S3_PROVIDER=none
 
 # 1 hour
 LOCAL_INDEX_INTERVAL=3600

src/file_hosting/s3_host.rs

@@ -49,6 +49,29 @@ impl FileHost for S3Host {
             )
             .await?;
 
+        let provider = &*dotenv::var("S3_PROVIDER").unwrap();
+
+        if provider == "do" {
+            reqwest::Client::new()
+                .delete(format!(
+                    "https://api.digitalocean.com/v2/cdn/endpoints/{}/cache",
+                    self.bucket.name
+                ))
+                .header(reqwest::header::CONTENT_TYPE, "application/json")
+                .header(
+                    reqwest::header::AUTHORIZATION,
+                    &self.bucket.credentials.secret_key,
+                )
+                .body(
+                    serde_json::json!({
+                        "files": vec![file_name],
+                    })
+                    .to_string(),
+                )
+                .send()
+                .await?;
+        }
+
         Ok(UploadFileData {
             file_id: file_name.to_string(),
             file_name: file_name.to_string(),

src/main.rs

@@ -334,6 +334,7 @@ fn check_env_vars() -> bool {
         failed |= check_var::<String>("S3_URL");
         failed |= check_var::<String>("S3_REGION");
         failed |= check_var::<String>("S3_BUCKET_NAME");
+        failed |= check_var::<String>("S3_PROVIDER");
     } else if storage_backend.as_deref() == Some("local") {
         failed |= check_var::<String>("MOCK_FILE_PATH");
     } else if let Some(backend) = storage_backend {

src/routes/teams.rs

@@ -42,14 +42,12 @@ pub async fn team_members_get(
 
     for team_member in members_data {
         if team_member.accepted {
-            team_members.push(
-                crate::models::teams::TeamMember {
-                    user_id: team_member.user_id.into(),
-                    role: team_member.role,
-                    permissions: None,
-                    accepted: team_member.accepted
-                }
-            )
+            team_members.push(crate::models::teams::TeamMember {
+                user_id: team_member.user_id.into(),
+                role: team_member.role,
+                permissions: None,
+                accepted: team_member.accepted,
+            })
         }
     }
 

src/routes/users.rs

@@ -182,7 +182,7 @@ pub async fn teams(
             } else {
                 None
             },
-            accepted: data.accepted
+            accepted: data.accepted,
         })
         .collect();