fix(abi): enumerate the flat slot from S3, not through the edge (#203)
Some checks failed
ci/crow/cron/process-updates/16 Pipeline is pending
ci/crow/cron/process-updates/11 Pipeline was successful
ci/crow/cron/process-updates/18 Pipeline was successful
ci/crow/cron/process-updates/12 Pipeline failed
ci/crow/cron/process-updates/17 Pipeline was successful
ci/crow/manual/backfill-flat-safety/1 Pipeline was successful
ci/crow/manual/backfill-flat-safety/3 Pipeline was successful
ci/crow/manual/backfill-flat-safety/5 Pipeline was successful
ci/crow/manual/backfill-flat-safety/7 Pipeline was successful
ci/crow/manual/backfill-flat-safety/9 Pipeline was successful
ci/crow/manual/backfill-flat-safety/11 Pipeline was successful
ci/crow/manual/backfill-flat-safety/13 Pipeline was successful
ci/crow/manual/backfill-flat-safety/15 Pipeline was successful
ci/crow/manual/backfill-flat-safety/17 Pipeline was successful
ci/crow/manual/backfill-flat-safety/18 Pipeline was successful
ci/crow/manual/backfill-flat-safety/4 Pipeline was successful
ci/crow/manual/backfill-flat-safety/10 Pipeline was successful
ci/crow/manual/backfill-flat-safety/14 Pipeline was successful
ci/crow/cron/process-updates/6 Pipeline was successful
ci/crow/cron/process-updates/5 Pipeline was successful
ci/crow/manual/backfill-flat-safety/8 Pipeline was successful
ci/crow/manual/backfill-flat-safety/6 Pipeline was successful
ci/crow/manual/backfill-flat-safety/16 Pipeline was successful
ci/crow/cron/process-updates/1 Pipeline was successful
ci/crow/manual/backfill-flat-safety/12 Pipeline was successful
ci/crow/manual/backfill-flat-safety/2 Pipeline was successful
ci/crow/manual/reindex/7 Pipeline failed
ci/crow/manual/reindex/11 Pipeline failed
ci/crow/manual/reindex/15 Pipeline failed
ci/crow/manual/reindex/9 Pipeline failed
ci/crow/manual/reindex/3 Pipeline failed
ci/crow/manual/reindex/13 Pipeline was successful
ci/crow/manual/reindex/17 Pipeline was successful
ci/crow/manual/reindex/8 Pipeline was successful
ci/crow/manual/reindex/4 Pipeline was successful
ci/crow/manual/reindex/1 Pipeline was successful
ci/crow/manual/reindex/2 Pipeline was successful
ci/crow/manual/reindex/5 Pipeline was successful
ci/crow/manual/reindex/6 Pipeline was successful
ci/crow/manual/reindex/10 Pipeline was successful
ci/crow/cron/process-updates/2 Pipeline was successful
ci/crow/manual/reindex/12 Pipeline was successful
ci/crow/manual/reindex/14 Pipeline was successful
ci/crow/manual/reindex/16 Pipeline was successful
ci/crow/manual/reindex/18 Pipeline was successful
ci/crow/cron/process-updates/7 Pipeline was successful
ci/crow/cron/process-updates/8 Pipeline was successful
ci/crow/cron/process-updates/9 Pipeline was successful
ci/crow/cron/process-updates/3 Pipeline was successful

## Why

The first backfill run reported:

```
amd64/resolute: 27105 flat binaries, 8187 compiled and worth inspecting
Done: 300 inspected, 7 safe for every minor, 1 unsafe, 292 skipped
```

292 of 300 skipped, and `27105` is larger than the flat index (~24k). Both have the same cause: the script read `PACKAGES.gz` over HTTPS from inside R, which sends an R User-Agent, so **the edge routed it to a per-minor index**. It then enumerated union records carrying `Path: <minor>`, whose objects do not exist at the flat path, and every download 404'd.

An ironic failure given what this whole change is about, and one the trial run existed to catch.

## What changed

- List the flat slot with `s3fs::s3_dir_ls()`, keeping only objects with no `<minor>/` prefix and nothing under `Archive/`. The bucket cannot be routed and is authoritative about what is actually in the flat slot.
- Fetch each object from S3 too. The edge does not rewrite tarball requests, but it does cache them, and the verdict is about the object.
- `NeedsCompilation` still comes from CRAN's own index, which is not behind our edge.

## Verification

The next trial run is the check: `flat objects` should now match the flat index rather than exceed it, and `skipped` should be near zero.

Reviewed-on: #203
This commit is contained in:
Patrick Schratz 2026-09-05 09:41:57 +00:00 • committed by Patrick Schratz
commit 844ad9749b

View file

@ -48,29 +48,56 @@ cat(sprintf(
length(bincraft:::cross_minor_volatile_symbols(sets))
))
read_index <- function(index_url) {
con <- gzcon(url(index_url, open = "rb"))
on.exit(close(con), add = TRUE)
read.dcf(con, fields = c("Package", "Version", "Built", "NeedsCompilation"))
}
flat <- read_index(sprintf(
"https://cran.rpkgs.com/%s/%s/latest/src/contrib/PACKAGES.gz",
# The flat slot is listed from S3, not from PACKAGES.gz over HTTPS. Reading the
# index from inside R sends an R User-Agent, which the edge routes to a
# per-minor index; that enumerates union records carrying `Path: <minor>`, whose
# objects do not exist at the flat path. Every download then 404s: a first run
# skipped 292 of 300 that way. The bucket cannot be routed and is authoritative.
s3fs::s3_file_system(
aws_access_key_id = Sys.getenv("B2_S3_ACCESS_KEY"),
aws_secret_access_key = Sys.getenv("B2_S3_SECRET_KEY"),
endpoint = "https://s3.eu-central-003.backblazeb2.com",
region_name = "eu-central-003",
refresh = TRUE
)
contrib <- sprintf(
"devxy-rpkgs-binaries/%s/%s/latest/src/contrib",
arch,
codename
))
# Source fallbacks carry no binary, so there is nothing to inspect.
flat <- flat[!is.na(flat[, "Built"]), , drop = FALSE]
compiled <- flat[
!is.na(flat[, "NeedsCompilation"]) & flat[, "NeedsCompilation"] == "yes",
,
drop = FALSE
)
objects <- s3fs::s3_dir_ls(contrib, recurse = TRUE)
relative <- sub(sprintf("^(s3://)?%s/", contrib), "", objects)
# Flat objects only: no `<minor>/` prefix and nothing under Archive/.
flat_files <- relative[
grepl("\\.tar\\.gz$", relative) & !grepl("/", relative, fixed = TRUE)
]
flat_pkg <- sub("_.*$", "", flat_files)
flat_ver <- sub("\\.tar\\.gz$", "", sub("^[^_]*_", "", flat_files))
# Only compiled packages can fail at dyn.load(), so the rest are not worth
# downloading. CRAN's own index says which; it is not behind our edge.
cran <- read.dcf(
gzcon(url(
"https://cloud.r-project.org/src/contrib/PACKAGES.gz",
open = "rb"
)),
fields = c("Package", "NeedsCompilation")
)
compiled_names <- cran[
!is.na(cran[, "NeedsCompilation"]) & cran[, "NeedsCompilation"] == "yes",
"Package"
]
keep <- flat_pkg %in% compiled_names
compiled <- data.frame(
Package = flat_pkg[keep],
Version = flat_ver[keep],
stringsAsFactors = FALSE
)
cat(sprintf(
"%s/%s: %d flat binaries, %d compiled and worth inspecting\n",
"%s/%s: %d flat objects, %d compiled and worth inspecting\n",
arch,
codename,
nrow(flat),
length(flat_files),
nrow(compiled)
))
if (!is.na(limit) && limit > 0L && limit < nrow(compiled)) {
@ -78,11 +105,8 @@ if (!is.na(limit) && limit > 0L && limit < nrow(compiled)) {
cat(sprintf("Limited to the first %d\n", limit))
}
base <- sprintf(
"https://cran.rpkgs.com/%s/%s/latest/src/contrib",
arch,
codename
)
# Fetch from the bucket as well: the edge does not rewrite tarball requests,
# but it does cache them, and the object is what the verdict is about.
safe <- 0L
unsafe <- 0L
skipped <- 0L
@ -92,13 +116,12 @@ for (i in seq_len(nrow(compiled))) {
tarball <- file.path(tempdir(), sprintf("%s_%s.tar.gz", pkg, ver))
ok <- tryCatch(
{
utils::download.file(
sprintf("%s/%s_%s.tar.gz", base, pkg, ver),
s3fs::s3_file_download(
sprintf("%s/%s_%s.tar.gz", contrib, pkg, ver),
tarball,
quiet = TRUE,
mode = "wb"
overwrite = TRUE
)
TRUE
file.exists(tarball)
},
error = function(e) FALSE,
warning = function(w) FALSE