refactor(test): rust integration tests

crates/turborepo/tests/common/mod.rs

@@ -0,0 +1,56 @@
+use std::{path::Path, process::Command};
+
+use camino::Utf8Path;
+
+pub fn setup_fixture(
+    fixture: &str,
+    package_manager: Option<&str>,
+    test_dir: &Path,
+) -> Result<(), anyhow::Error> {
+    let script_path = Utf8Path::new(env!("CARGO_MANIFEST_DIR"))
+        .join("../../turborepo-tests/helpers/setup_integration_test.sh");
+
+    Command::new("bash")
+        .arg("-c")
+        .arg(format!(
+            "{} {} {}",
+            script_path,
+            fixture,
+            package_manager.unwrap_or("npm@10.5.0")
+        ))
+        .current_dir(test_dir)
+        .spawn()?
+        .wait()?;
+
+    Ok(())
+}
+
+/// Executes a command with different arguments in a specific fixture and
+/// package manager. Creates a snapshot file for each set of arguments
+#[macro_export]
+macro_rules! check {
+    ($fixture:expr, $package_manager:expr, $command:expr, $($name:expr => $query:expr,)*) => {
+        {
+            let tempdir = tempfile::tempdir()?;
+            crate::common::setup_fixture($fixture, $package_manager, tempdir.path())?;
+            $(
+                let output = assert_cmd::Command::cargo_bin("turbo")?
+                .arg($command)
+                    .arg($query)
+                    .current_dir(tempdir.path())
+                    .output()?;
+
+                let stdout = String::from_utf8(output.stdout)?;
+                let query_output: serde_json::Value = serde_json::from_str(&stdout)?;
+                let test_name = format!(
+                    "{}_{}_{}_({})",
+                    module_path!(),
+                    $fixture,
+                    $name.replace(' ', "_"),
+                    $package_manager
+                );
+                insta::assert_json_snapshot!(test_name, query_output);
+            )*
+        }
+    }
+}

crates/turborepo/tests/common/snapshots/query__common__check_query.snap

@@ -0,0 +1,23 @@
+---
+source: crates/turborepo-lib/tests/common/mod.rs
+expression: query_output
+---
+{
+  "data": {
+    "file": {
+      "path": "index.js",
+      "dependencies": {
+        "files": {
+          "items": [
+            {
+              "path": "nm/index.js"
+            }
+          ]
+        },
+        "errors": {
+          "items": []
+        }
+      }
+    }
+  }
+}

crates/turborepo/tests/query.rs

@@ -1,52 +1,13 @@
-use std::{path::Path, process::Command};
-
-use camino::Utf8Path;
-
-fn setup_fixture(
-    fixture: &str,
-    package_manager: Option<&str>,
-    test_dir: &Path,
-) -> Result<(), anyhow::Error> {
-    let script_path = Utf8Path::new(env!("CARGO_MANIFEST_DIR"))
-        .join("../../turborepo-tests/helpers/setup_integration_test.sh");
-
-    Command::new("bash")
-        .arg("-c")
-        .arg(format!(
-            "{} {} {}",
-            script_path,
-            fixture,
-            package_manager.unwrap_or("npm@10.5.0")
-        ))
-        .current_dir(test_dir)
-        .spawn()?
-        .wait()?;
-
-    Ok(())
-}
-
-fn check_query(fixture: &str, query: &str) -> Result<(), anyhow::Error> {
-    let tempdir = tempfile::tempdir()?;
-    setup_fixture(fixture, None, tempdir.path())?;
-    let output = assert_cmd::Command::cargo_bin("turbo")?
-        .arg("query")
-        .arg(query)
-        .current_dir(tempdir.path())
-        .output()?;
-
-    let stdout = String::from_utf8(output.stdout)?;
-    let query_output: serde_json::Value = serde_json::from_str(&stdout)?;
-    insta::assert_json_snapshot!(query_output);
-
-    Ok(())
-}
+mod common;
 
 #[cfg(not(windows))]
 #[test]
 fn test_double_symlink() -> Result<(), anyhow::Error> {
-    check_query(
+    check!(
         "oxc_repro",
-        "query {
+        "npm@10.5.0",
+        "query",
+        "get_dependencies" => "query {
                  file(path: \"./index.js\") {
                     path
                     dependencies {
@@ -55,6 +16,24 @@
                     }
                  }
               }",
-    )?;
+    );
+    Ok(())
+}
+
+#[test]
+fn test_trace() -> Result<(), anyhow::Error> {
+    check!(
+        "turbo_trace",
+        "npm@10.5.0",
+        "query",
+        "get `main.ts`" => "query { file(path: \"main.ts\") { path } }",
+        "get `main.ts` with dependencies" => "query { file(path: \"main.ts\") { path, dependencies { files { items { path } } } } }",
+        "get `button.tsx` with dependencies" => "query { file(path: \"button.tsx\") { path, dependencies { files { items { path } } } } }",
+        "get `circular.ts` with dependencies" => "query { file(path: \"circular.ts\") { path dependencies { files { items { path } } } } }",
+        "get `invalid.ts` with dependencies" => "query { file(path: \"invalid.ts\") { path dependencies { files { items { path } } errors { items { message } } } } }",
+        "get `main.ts` with ast" => "query { file(path: \"main.ts\") { path ast } }",
+        "get `main.ts` with depth = 0" => "query { file(path: \"main.ts\") { path dependencies(depth: 1) { files { items { path } } } } }",
+    );
+
     Ok(())
 }

crates/turborepo/tests/snapshots/query__query_oxc_repro_get_dependencies_(npm@10.5.0).snap

@@ -0,0 +1,23 @@
+---
+source: crates/turborepo/tests/query.rs
+expression: query_output
+---
+{
+  "data": {
+    "file": {
+      "path": "index.js",
+      "dependencies": {
+        "files": {
+          "items": [
+            {
+              "path": "nm/index.js"
+            }
+          ]
+        },
+        "errors": {
+          "items": []
+        }
+      }
+    }
+  }
+}

crates/turborepo/tests/snapshots/query__query_turbo_trace_get_`button.tsx`_with_dependencies_(npm@10.5.0).snap

@@ -0,0 +1,16 @@
+---
+source: crates/turborepo/tests/query.rs
+expression: query_output
+---
+{
+  "data": {
+    "file": {
+      "path": "button.tsx",
+      "dependencies": {
+        "files": {
+          "items": []
+        }
+      }
+    }
+  }
+}

crates/turborepo/tests/snapshots/query__query_turbo_trace_get_`circular.ts`_with_dependencies_(npm@10.5.0).snap

@@ -0,0 +1,20 @@
+---
+source: crates/turborepo/tests/query.rs
+expression: query_output
+---
+{
+  "data": {
+    "file": {
+      "path": "circular.ts",
+      "dependencies": {
+        "files": {
+          "items": [
+            {
+              "path": "circular2.ts"
+            }
+          ]
+        }
+      }
+    }
+  }
+}

crates/turborepo/tests/snapshots/query__query_turbo_trace_get_`invalid.ts`_with_dependencies_(npm@10.5.0).snap

@@ -0,0 +1,27 @@
+---
+source: crates/turborepo/tests/query.rs
+expression: query_output
+---
+{
+  "data": {
+    "file": {
+      "path": "invalid.ts",
+      "dependencies": {
+        "files": {
+          "items": [
+            {
+              "path": "button.tsx"
+            }
+          ]
+        },
+        "errors": {
+          "items": [
+            {
+              "message": "failed to resolve import"
+            }
+          ]
+        }
+      }
+    }
+  }
+}

crates/turborepo/tests/snapshots/query__query_turbo_trace_get_`main.ts`_(npm@10.5.0).snap

@@ -0,0 +1,11 @@
+---
+source: crates/turborepo/tests/query.rs
+expression: query_output
+---
+{
+  "data": {
+    "file": {
+      "path": "main.ts"
+    }
+  }
+}