feat(admin): downgrade protrial (#2042)

Author: jonaro00

admin/src/args.rs

@@ -117,4 +117,6 @@ pub enum Command {
         /// user id / project id / email
         query: String,
     },
+
+    DowngradeProTrials,
 }

admin/src/client.rs

@@ -167,4 +167,17 @@ impl Client {
 
         Ok(())
     }
+
+    pub async fn get_expired_protrials(&self) -> Result<Vec<String>> {
+        self.inner.get_json("/admin/users/protrial-downgrade").await
+    }
+
+    pub async fn downgrade_protrial(&self, user_id: &str) -> Result<String> {
+        self.inner
+            .put_json(
+                format!("/admin/users/protrial-downgrade/{user_id}"),
+                Option::<()>::None,
+            )
+            .await
+    }
 }

admin/src/lib.rs

@@ -150,6 +150,20 @@ pub async fn run(args: Args) {
             let v = client.get_user_everything(&query).await.unwrap();
             println!("{}", serde_json::to_string_pretty(&v).unwrap());
         }
+        Command::DowngradeProTrials => {
+            let users = client.get_expired_protrials().await.unwrap();
+            eprintln!(
+                "Starting downgrade of {} users in 5 seconds...",
+                users.len()
+            );
+            tokio::time::sleep(tokio::time::Duration::from_millis(5000)).await;
+            for user_id in users {
+                println!("{user_id}");
+                println!("  {:?}", client.downgrade_protrial(&user_id).await);
+                // prevent api rate limiting
+                tokio::time::sleep(tokio::time::Duration::from_millis(1000)).await;
+            }
+        }
     };
 }