claw-store/src/claw_cargo.rs

@@ -279,6 +279,24 @@ struct BuildArgs {
     /// (WAN, tunneled links).
     #[arg(long, default_value_t = 1)]
     parallel_restore: usize,
+    /// Phase 7f (2026-07-14): on cache-put, record `(fingerprint,
+    /// repo, git_ref)` locally so a later cluster-ref-sweep can
+    /// reap cache entries whose refs are gone upstream. Defaults
+    /// from CI env: `GITEA_REPOSITORY` / `GITHUB_REPOSITORY`.
+    /// Silently skipped when unset — cache still works without it.
+    #[arg(long, env = "CLAWSTOR_REPO")]
+    repo: Option<String>,
+    /// Phase 7f (2026-07-14): git ref (branch or tag name)
+    /// associated with this cache-put. Defaults from CI env:
+    /// `GITEA_REF_NAME` / `GITHUB_REF_NAME`. Silently skipped
+    /// when unset.
+    #[arg(long, env = "CLAWSTOR_GIT_REF")]
+    git_ref: Option<String>,
+    /// Path to the daemon's cluster.blob_store_root — needed to
+    /// write ref-tracking annotations. Defaults to
+    /// `/var/lib/claw-store/data`. Skipped if not writable.
+    #[arg(long, env = "CLAWSTOR_DATA_DIR")]
+    ref_tracking_dir: Option<std::path::PathBuf>,
     /// Extra args passed verbatim to `cargo build` (after `--`).
     #[arg(last = true)]
     cargo_args: Vec<String>,
@@ -784,6 +802,44 @@ async fn cmd_build(args: BuildArgs) -> Result<()> {
                 blob_id,
                 uploaded_bytes: capture_bytes,
             };
+            // Phase 7f: annotate this fingerprint with its producing
+            // (repo, git_ref) so a later cluster-ref-sweep can
+            // identify it as stale when the ref disappears
+            // upstream. Silently skipped when any required piece
+            // is missing — the cache still works without tracking.
+            if let (Some(repo), Some(git_ref), Some(dir)) = (
+                args.repo.as_deref(),
+                args.git_ref.as_deref(),
+                args.ref_tracking_dir.as_ref(),
+            ) {
+                if dir.is_dir() {
+                    match crate::cluster::ref_tracking::RefTracking::open(dir.clone()) {
+                        Ok(rt) => {
+                            let now = std::time::SystemTime::now()
+                                .duration_since(std::time::UNIX_EPOCH)
+                                .map(|d| d.as_secs())
+                                .unwrap_or(0);
+                            if let Err(e) = rt
+                                .record(*fp.as_bytes(), repo, git_ref, now)
+                                .await
+                            {
+                                tracing::warn!(
+                                    fingerprint = %fp,
+                                    repo,
+                                    git_ref,
+                                    error = %e,
+                                    "ref-tracking record failed; cache still valid"
+                                );
+                            }
+                        }
+                        Err(e) => tracing::warn!(
+                            dir = %dir.display(),
+                            error = %e,
+                            "opening ref-tracking store failed; skipping annotation"
+                        ),
+                    }
+                }
+            }
             // Tempfile drops when we leave scope, unlinking automatically.
         }
     }