WIP

Author: anthonyshew

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

@@ -11,7 +11,7 @@ use clap::ValueEnum;
 use miette::{NamedSource, SourceSpan};
 use serde::{Deserialize, Serialize};
 use struct_iterable::Iterable;
-use turbopath::AbsoluteSystemPath;
+use turbopath::{AbsoluteSystemPath, AnchoredSystemPath, AnchoredSystemPathBuf};
 use turborepo_errors::Spanned;
 use turborepo_repository::package_graph::ROOT_PKG_NAME;
 use turborepo_unescape::UnescapedString;
@@ -33,6 +33,8 @@ pub use loader::TurboJsonLoader;
 
 use crate::{boundaries::BoundariesConfig, config::UnnecessaryPackageTaskSyntaxError};
 
+const TURBO_ROOT: &str = "$TURBO_ROOT$";
+
 #[derive(Serialize, Deserialize, Debug, Default, PartialEq, Clone, Deserializable)]
 #[serde(rename_all = "camelCase")]
 pub struct SpacesJson {
@@ -537,10 +539,11 @@ impl RawTurboJson {
     }
 }
 
-impl TryFrom<RawTurboJson> for TurboJson {
-    type Error = Error;
-
-    fn try_from(raw_turbo: RawTurboJson) -> Result<Self, Error> {
+impl TurboJson {
+    fn from_raw(
+        raw_turbo: RawTurboJson,
+        path_to_repo_root: &AnchoredSystemPath,
+    ) -> Result<Self, Error> {
         if let Some(pipeline) = raw_turbo.pipeline {
             let (span, text) = pipeline.span_and_text("turbo.json");
             return Err(Error::PipelineField { span, text });
@@ -572,6 +575,16 @@ impl TryFrom<RawTurboJson> for TurboJson {
             }
         }
 
+        if let Some(tasks_from_turbo) = raw_turbo.tasks {
+            for (task_name, task_def) in tasks_from_turbo {
+                task_def
+                    .inputs
+                    .iter()
+                    .map(|glob| replace_turbo_root_token(&mut task_def, path_to_repo_root))
+                    .collect()
+            }
+        }
+
         Ok(TurboJson {
             text: raw_turbo.span.text,
             path: raw_turbo.span.path,
@@ -629,7 +642,12 @@ impl TurboJson {
         path: &AbsoluteSystemPath,
     ) -> Result<TurboJson, Error> {
         let raw_turbo_json = RawTurboJson::read(repo_root, path)?;
-        raw_turbo_json.try_into()
+        // pass in repo_root
+        // This needs the relative path to root
+        let pkg_path = path.parent().expect("turbo.json is not root");
+        // relative pkg_path -> repo_root
+        let path_to_root = AnchoredSystemPathBuf::relative_path_between(pkg_path, repo_root);
+        TurboJson::from_raw(raw_turbo_json, &path_to_root)
     }
 
     pub fn task(&self, task_id: &TaskId, task_name: &TaskName) -> Option<RawTaskDefinition> {
@@ -765,6 +783,29 @@ fn gather_env_vars(
     Ok(())
 }
 
+fn replace_turbo_root_token(
+    task_definition: &mut TaskDefinition,
+    path_to_repo_root: &AnchoredSystemPath,
+) {
+    for input in task_definition.inputs.iter_mut() {
+        let _ = input.replacen(TURBO_ROOT, path_to_repo_root.as_str(), 1);
+    }
+
+    for output in task_definition.outputs.validated_exclusions().iter_mut() {
+        let _ = output.iter().map(|glob| {
+            glob.as_str()
+                .replacen(TURBO_ROOT, path_to_repo_root.as_str(), 1)
+        });
+    }
+
+    for output in task_definition.outputs.validated_inclusions().iter_mut() {
+        let _ = output.iter().map(|glob| {
+            glob.as_str()
+                .replacen(TURBO_ROOT, path_to_repo_root.as_str(), 1)
+        });
+    }
+}
+
 #[cfg(test)]
 mod tests {
     use anyhow::Result;