Merge pull request #1856 from rust-lang/fetch-latest-zstd

Update `fetch-latest` to use ZSTD instead of Snappy

Author: Kobzol

Cargo.lock

@@ -38,14 +38,15 @@ database = { path = "../database" }
 bytes = "1.0"
 url = "2"
 analyzeme = { git = "https://github.com/rust-lang/measureme", branch = "stable" }
-inferno = { version="0.11", default-features = false }
+inferno = { version = "0.11", default-features = false }
 mime = "0.3"
 prometheus = "0.13"
 uuid = { version = "1.3.0", features = ["v4"] }
 tera = { version = "1.19", default-features = false }
 rust-embed = { version = "6.6.0", features = ["include-exclude", "interpolate-folder-path"] }
 humansize = "2"
 lru = "0.12.0"
+ruzstd = "0.6.0"
 
 [target.'cfg(unix)'.dependencies]
 jemallocator = "0.5"

site/Cargo.toml

@@ -1,15 +1,17 @@
 use anyhow::Context as _;
-use snap::read::FrameDecoder;
+use ruzstd::StreamingDecoder;
 use std::io::Write;
 
 fn main() -> anyhow::Result<()> {
     let destination = std::env::args()
         .nth(1)
         .ok_or(anyhow::anyhow!("destination file should be first argument"))?;
-    let resp = reqwest::blocking::get("https://perf-data.rust-lang.org/export.db.sz")
+    let resp = reqwest::blocking::get("https://perf-data.rust-lang.org/export.db.zst")
         .context("fetching database")?;
     let resp = resp.error_for_status().context("fetching database")?;
-    let mut decoder = FrameDecoder::new(std::io::BufReader::new(resp));
+
+    let mut reader = std::io::BufReader::new(resp);
+    let mut decoder = StreamingDecoder::new(&mut reader).context("cannot decode")?;
     let mut file = std::io::BufWriter::new(
         std::fs::File::create(destination).context("creating destination file")?,
     );