feat(query): add schema flag (#10052)

### Description

Adds schema flag which easily lets you get the turbo graphql schema

### Testing Instructions

Snapshot test added to `tests/query.rs`

Author: NicholasLYang

crates/turborepo-lib/src/cli/mod.rs

@@ -729,6 +729,8 @@ pub enum Command {
         /// Pass variables to the query via a JSON file
         #[clap(short = 'V', long, requires = "query")]
         variables: Option<Utf8PathBuf>,
+        #[clap(long, conflicts_with = "query")]
+        schema: bool,
         /// The query to run, either a file path or a query string
         query: Option<String>,
     },
@@ -1589,17 +1591,22 @@ pub async fn run(
             })?;
             Ok(exit_code)
         }
-        Command::Query { query, variables } => {
+        Command::Query {
+            query,
+            variables,
+            schema,
+        } => {
             warn!("query command is experimental and may change in the future");
             let query = query.clone();
             let variables = variables.clone();
+            let schema = *schema;
             let event = CommandEventBuilder::new("query").with_parent(&root_telemetry);
             event.track_call();
 
             let base = CommandBase::new(cli_args, repo_root, version, color_config)?;
             event.track_ui_mode(base.opts.run_opts.ui_mode);
 
-            let query = query::run(base, event, query, variables.as_deref()).await?;
+            let query = query::run(base, event, query, variables.as_deref(), schema).await?;
 
             Ok(query)
         }

crates/turborepo-lib/src/commands/query.rs

@@ -15,6 +15,106 @@ use crate::{
     signal::SignalHandler,
 };
 
+const SCHEMA_QUERY: &str = "query IntrospectionQuery {
+  __schema {
+    queryType {
+      name
+    }
+    mutationType {
+      name
+    }
+    subscriptionType {
+      name
+    }
+    types {
+      ...FullType
+    }
+    directives {
+      name
+      description
+      locations
+      args {
+        ...InputValue
+      }
+    }
+  }
+}
+
+fragment FullType on __Type {
+  kind
+  name
+  description
+  fields(includeDeprecated: true) {
+    name
+    description
+    args {
+      ...InputValue
+    }
+    type {
+      ...TypeRef
+    }
+    isDeprecated
+    deprecationReason
+  }
+  inputFields {
+    ...InputValue
+  }
+  interfaces {
+    ...TypeRef
+  }
+  enumValues(includeDeprecated: true) {
+    name
+    description
+    isDeprecated
+    deprecationReason
+  }
+  possibleTypes {
+    ...TypeRef
+  }
+}
+
+fragment InputValue on __InputValue {
+  name
+  description
+  type {
+    ...TypeRef
+  }
+  defaultValue
+}
+
+fragment TypeRef on __Type {
+  kind
+  name
+  ofType {
+    kind
+    name
+    ofType {
+      kind
+      name
+      ofType {
+        kind
+        name
+        ofType {
+          kind
+          name
+          ofType {
+            kind
+            name
+            ofType {
+              kind
+              name
+              ofType {
+                kind
+                name
+              }
+            }
+          }
+        }
+      }
+    }
+  }
+}";
+
 #[derive(Debug, Diagnostic, Error)]
 #[error("{message}")]
 struct QueryError {
@@ -59,6 +159,7 @@ pub async fn run(
     telemetry: CommandEventBuilder,
     query: Option<String>,
     variables_path: Option<&Utf8Path>,
+    include_schema: bool,
 ) -> Result<i32, Error> {
     let signal = get_signal()?;
     let handler = SignalHandler::new(signal);
@@ -67,7 +168,7 @@ pub async fn run(
         .add_all_tasks()
         .do_not_validate_engine();
     let run = run_builder.build(&handler, telemetry).await?;
-
+    let query = query.as_deref().or(include_schema.then_some(SCHEMA_QUERY));
     if let Some(query) = query {
         let trimmed_query = query.trim();
         // If the arg starts with "query" or "mutation", and ends in a bracket, it's
@@ -80,7 +181,7 @@ pub async fn run(
         {
             query
         } else {
-            fs::read_to_string(AbsoluteSystemPathBuf::from_unknown(run.repo_root(), query))?
+            &fs::read_to_string(AbsoluteSystemPathBuf::from_unknown(run.repo_root(), query))?
         };
 
         let schema = Schema::new(
@@ -98,13 +199,13 @@ pub async fn run(
             .transpose()?
             .unwrap_or_default();
 
-        let request = Request::new(&query).variables(variables);
+        let request = Request::new(query).variables(variables);
 
         let result = schema.execute(request).await;
         println!("{}", serde_json::to_string_pretty(&result)?);
         if !result.errors.is_empty() {
             for error in result.errors {
-                let error = QueryError::new(error, query.clone());
+                let error = QueryError::new(error, query.to_string());
                 eprintln!("{:?}", Report::new(error));
             }
         }

crates/turborepo/tests/query.rs

@@ -18,6 +18,7 @@ fn test_query() -> Result<(), anyhow::Error> {
         "get the indirect dependencies of `my-app`" => ["query { packages(filter: {equal: { field: NAME, value: \"my-app\" } }) { items { indirectDependencies { items { name } } } } }"],
         "get all dependencies of `my-app`" => ["query { packages(filter: {equal: { field: NAME, value: \"my-app\" } }) { items { allDependencies { items { name } } } } }"],
         "get package graph" => ["query { packageGraph { nodes { items { name } } edges { items { source target } } } }"],
+        "get schema" => ["--schema"],
     );
 
     Ok(())