Merge branch 'master' into allow-setting-review-assignment-limit

Cargo.toml

@@ -46,6 +46,7 @@ ignore = "0.4.18"
 postgres-types = { version = "0.2.4", features = ["derive"] }
 cron = { version = "0.12.0" }
 bytes = "1.1.0"
+structopt = "0.3.26"
 
 [dependencies.serde]
 version = "1"

src/bin/project_goals.rs

@@ -0,0 +1,34 @@
+use structopt::StructOpt;
+use triagebot::{github::GithubClient, handlers::project_goals};
+
+/// A basic example
+#[derive(StructOpt, Debug)]
+struct Opt {
+    /// If specified, no messages are sent.
+    #[structopt(long)]
+    dry_run: bool,
+
+    /// Goals with an updated within this threshold will not be pinged.
+    days_threshold: i64,
+
+    /// A string like "on Sep-5" when the update blog post will be written.
+    next_meeting_date: String,
+}
+
+#[tokio::main(flavor = "current_thread")]
+async fn main() -> anyhow::Result<()> {
+    dotenv::dotenv().ok();
+    tracing_subscriber::fmt::init();
+
+    let opt = Opt::from_args();
+    let gh = GithubClient::new_from_env();
+    project_goals::ping_project_goals_owners(
+        &gh,
+        opt.dry_run,
+        opt.days_threshold,
+        &opt.next_meeting_date,
+    )
+    .await?;
+
+    Ok(())
+}

src/db.rs

@@ -151,7 +151,7 @@ fn cert() {
     make_certificates();
 }
 
-pub async fn run_migrations(client: &DbClient) -> anyhow::Result<()> {
+pub async fn run_migrations(client: &mut DbClient) -> anyhow::Result<()> {
     client
         .execute(
             "CREATE TABLE IF NOT EXISTS database_versions (
@@ -182,17 +182,22 @@ pub async fn run_migrations(client: &DbClient) -> anyhow::Result<()> {
 
     for (idx, migration) in MIGRATIONS.iter().enumerate() {
         if idx >= migration_idx {
-            client
-                .execute(*migration, &[])
+            let tx = client
+                .transaction()
+                .await
+                .context("Cannot create migration transactin")?;
+            tx.execute(*migration, &[])
                 .await
                 .with_context(|| format!("executing {}th migration", idx))?;
-            client
-                .execute(
-                    "UPDATE database_versions SET migration_counter = $1",
-                    &[&(idx as i32 + 1)],
-                )
+            tx.execute(
+                "UPDATE database_versions SET migration_counter = $1",
+                &[&(idx as i32 + 1)],
+            )
+            .await
+            .with_context(|| format!("updating migration counter to {}", idx))?;
+            tx.commit()
                 .await
-                .with_context(|| format!("updating migration counter to {}", idx))?;
+                .context("Cannot commit migration transaction")?;
         }
     }