instead channel and semaphore queue + upgrade to rust 1.99

@@ -182,3 +188,1 @@
-            info!(queued = rx.len(), active = tasks.len(), "Webhook received");
-            let permit = sem.clone().acquire_owned().await?;
-            let self_clone = self.clone();
+            let permit = semaphore.clone().acquire_owned().await?;

@@ -184,1 +188,3 @@
-            let self_clone = self.clone();
+            let permit = semaphore.clone().acquire_owned().await?;
+
+            if let Err(err) = self.queue.mark_processing(job.id).await {

@@ -204,0 +255,4 @@
+            duration_ms,
+        };
+
+        if let Err(err) = self.dedup.mark_reviewed(record).await {

@@ -0,0 +12,4 @@
+pub async fn connect(url: &str) -> toasty::Result<Db> {
+    let mut db = open(url).await?;
+
+    Job::update_by_status(JobStatus::Processing)

@@ -0,0 +65,4 @@
+                        return Some((job, buffer));
+                    }
+
+                    match Job::filter_by_status(JobStatus::Pending)

@@ -184,1 +188,3 @@
-            let self_clone = self.clone();
+            let permit = semaphore.clone().acquire_owned().await?;
+
+            if let Err(err) = self.queue.mark_processing(job.id).await {

@@ -204,0 +259,4 @@
+            error!(%err, "failed to record review");
+        }
+
+        if let Err(err) = self.queue.remove(job.id).await {

@@ -0,0 +65,4 @@
+                        return Some((job, buffer));
+                    }
+
+                    match Job::filter_by_status(JobStatus::Pending)

@@ -182,3 +188,1 @@
-            info!(queued = rx.len(), active = tasks.len(), "Webhook received");
-            let permit = sem.clone().acquire_owned().await?;
-            let self_clone = self.clone();
+            let permit = semaphore.clone().acquire_owned().await?;

@@ -0,0 +12,4 @@
+pub async fn connect(url: &str) -> toasty::Result<Db> {
+    let mut db = open(url).await?;
+
+    Job::update_by_status(JobStatus::Processing)

@@ -0,0 +65,4 @@
+                        return Some((job, buffer));
+                    }
+
+                    match Job::filter_by_status(JobStatus::Pending)

@@ -0,0 +551,4 @@
+                <strong>Configure every required setting</strong>
+                <pre>cp .env.example .env
+$EDITOR .env</pre>
+                <p>Set all nine required variables:</p>

@@ -27,2 +40,3 @@
-        .route("/", get(root))
         .route("/webhook", post(webhook))
+        .route("/dedup", get(dedup_list))
+        .route("/jobs", get(jobs_list))

@@ -64,3 +146,1 @@
-    if app_state.bot.check_and_mark(event_id).await {
-        metrics::webhook_duplicate(event_type);
-        return Err(AppError::AlreadyProcessedErr);
+    match app_state.dedup.is_known(event_id).await {

@@ -184,1 +193,3 @@
-            let self_clone = self.clone();
+            let permit = semaphore.clone().acquire_owned().await?;
+
+            if let Err(err) = self.queue.mark_processing(job.id).await {

@@ -0,0 +73,4 @@
+
+    pub async fn list_reviews(&self) -> toasty::Result<Vec<Review>> {
+        let mut db = self.db.clone();
+        let reviews = Review::all().exec(&mut db).await?;

@@ -0,0 +57,4 @@
+                        return Some((job, buffer));
+                    }
+
+                    match Job::filter_by_status(JobStatus::Pending)

@@ -0,0 +23,4 @@
+    this._selectedId = null;
+
+    this.render();
+    this.refresh();

@@ -0,0 +52,4 @@
+      // Un `error` survient aussi quand le serveur ferme le flux (job terminé).
+      // On ferme alors la source pour éviter la boucle de reconnexion (le job
+      // n'est plus en cours, la route renverrait 404).
+      onError: () => {

@@ -20,2 +20,4 @@
     "workspaceMount": "source=${localWorkspaceFolder},target=/workspaces/steep,type=bind",
     "workspaceFolder": "/workspaces/steep",
+    "mounts": [
+        "source=/run/user/1000/podman/podman.sock,target=/var/run/docker.sock,type=bind"

@@ -20,2 +27,3 @@
+      image: rust:1.99
       commands:
-          - cargo test --workspace --all-targets
+          - cargo install cargo-deny --locked --version 0.18.9

@@ -26,3 +39,3 @@
     let app = Router::new()
-        .route("/", get(root))
         .route("/webhook", post(webhook))
+        .route("/reviews", get(reviews_list))

@@ -71,3 +158,1 @@
-        metrics::webhook_channel_full(event_type);
-        return Err(AppError::ChannelFullErr);
-    }
+    let job = match app_state.queue.push(wb).await {

@@ -0,0 +218,4 @@
+            iteration,
+            name: name.to_string(),
+            truncated,
+            output: output.to_string(),

@@ -0,0 +59,4 @@
+
+    pub async fn list(&self) -> toasty::Result<Vec<Review>> {
+        let mut db = self.db.clone();
+        let reviews = Review::all().exec(&mut db).await?;

@@ -0,0 +52,4 @@
+    this._source = subscribe(endpoints.lifecycle, {
+      onLifecycle: (event) => this.applyLifecycle(event),
+      // En cas de gap (évènements ratés), on recharge l'état depuis le REST.
+      onGap: () => this.refresh(),

@@ -0,0 +43,4 @@
+            ${job.event_id != null ? `<div><dt>Event</dt><dd>${job.event_id}</dd></div>` : ""}
+            <div><dt>Created</dt><dd>${escapeHtml(relativeTime(job.created_at))}</dd></div>
+          </dl>
+          <button class="button button-secondary job-watch" type="button">Watch activity</button>

@@ -0,0 +51,4 @@
+      this.append(card);
+    }
+
+    for (const card of known.values()) card.remove();