chore(blockifier_test_utils): implement download_cairo_package

Author: dorimedini-starkware

Cargo.lock

@@ -12,14 +12,17 @@ cairo_native = []
 [dependencies]
 apollo_infra_utils = { workspace = true, features = ["testing"] }
 cairo-lang-starknet-classes.workspace = true
+flate2.workspace = true
 itertools.workspace = true
 pretty_assertions.workspace = true
+reqwest.workspace = true
 rstest.workspace = true
 serde_json = { workspace = true, features = ["arbitrary_precision"] }
 starknet-types-core.workspace = true
 starknet_api = { workspace = true, features = ["testing"] }
 strum.workspace = true
 strum_macros.workspace = true
+tar.workspace = true
 tempfile.workspace = true
 tokio = { workspace = true, features = ["macros", "rt-multi-thread"] }
 tracing.workspace = true

crates/blockifier_test_utils/Cargo.toml

@@ -5,7 +5,9 @@ use std::{env, fs};
 
 use apollo_infra_utils::cairo_compiler_version::cairo1_compiler_version;
 use apollo_infra_utils::compile_time_cargo_manifest_dir;
+use apollo_infra_utils::path::project_path;
 use tempfile::NamedTempFile;
+use tracing::info;
 
 use crate::contracts::TagAndToolchain;
 
@@ -35,6 +37,32 @@ fn local_cairo1_compiler_repo_path() -> PathBuf {
     )
 }
 
+/// Path to local compiler package directory, of the specified version.
+fn cairo1_package_dir(version: &String) -> PathBuf {
+    project_path().unwrap().join(format!("target/bin/cairo_package__{version}"))
+}
+
+/// Downloads the cairo package to the local directory.
+/// Creates the directory if it does not exist.
+#[allow(dead_code)]
+async fn download_cairo_package(version: &String) {
+    let directory = cairo1_package_dir(version);
+    info!("Downloading Cairo package to {directory:?}.");
+    std::fs::create_dir_all(&directory).unwrap();
+
+    // Download the artifact.
+    let client = reqwest::Client::new();
+    let filename = "release-x86_64-unknown-linux-musl.tar.gz";
+    let package_url =
+        format!("https://github.com/starkware-libs/cairo/releases/download/v{version}/{filename}");
+    let response = client.get(package_url).send().await.unwrap();
+    assert!(response.status().is_success(), "Failed to download the package: {response:?}.");
+    let tar_package_bytes: &[u8] = &response.bytes().await.unwrap();
+    info!("Extracting and writing package.");
+    tar::Archive::new(flate2::read::GzDecoder::new(tar_package_bytes)).unpack(&directory).unwrap();
+    info!("Done.");
+}
+
 /// Runs a command. If it has succeeded, it returns the command's output; otherwise, it panics with
 /// stderr output.
 fn run_and_verify_output(command: &mut Command) -> Output {