very fast at protocol indexer with flexible filtering, xrpc queries, cursor-backed event stream, and more, built on fjall
rust
fjall
at-protocol
atproto
indexer
[tests] log CAR file paths for manual verification
+4
-4
+4
-4
tests/repo_sync_integrity.nu
+4
-4
tests/repo_sync_integrity.nu
···
128
128
}
129
129
130
130
# fetch a getRepo CAR and return its `goat repo inspect` info
131
-
def fetch-car-info [url: string, did: string] {
131
+
def fetch-car-info [url: string, did: string, label: string] {
132
132
let car = http get $"($url)/xrpc/com.atproto.sync.getRepo?did=($did)"
133
133
let tmp = (mktemp --suffix ".car")
134
134
$car | save --force $tmp
135
+
print $" ($label) car: ($tmp)"
135
136
let info = (nix-shell -p atproto-goat --run $"goat repo inspect ($tmp)" | parse-goat-inspect)
136
-
rm $tmp
137
137
$info
138
138
}
139
139
···
141
141
def check-car [hydrant_url: string, pds_url: string, did: string] {
142
142
print "checking getRepo CAR..."
143
143
144
-
let h = try { fetch-car-info $hydrant_url $did } catch {
144
+
let h = try { fetch-car-info $hydrant_url $did "hydrant" } catch {
145
145
print " error fetching CAR from hydrant"
146
146
return false
147
147
}
148
148
149
-
let p = try { fetch-car-info $pds_url $did } catch {
149
+
let p = try { fetch-car-info $pds_url $did "pds" } catch {
150
150
print " error fetching CAR from pds"
151
151
return false
152
152
}