just 1.54.0

use super::*;

const DIR: &str = ".justcache";

pub(crate) struct Cache {
  initialized: Mutex<bool>,
  path: PathBuf,
}

impl Cache {
  pub(crate) fn status(
    &self,
    config: &Config,
    key: CacheKey,
    outputs: &BTreeMap<String, PathBuf>,
  ) -> RunResult<'static, CacheStatus> {
    let mut hasher = blake3::Hasher::new();

    serde_json::to_writer(&mut hasher, &key)
      .map_err(|source| Error::CacheKeySerialize { source })?;

    let hash = hasher.finalize();

    let path = self.entry(hash)?;

    if config.verbosity.grandiloquent() {
      let json =
        serde_json::to_string_pretty(&key).map_err(|source| Error::CacheKeySerialize { source })?;
      let stderr = config.color.stderr();
      eprintln!(
        "{}",
        stderr.banner().paint(&format!("===> cache key {hash}:")),
      );
      eprintln!("{}", stderr.doc().paint(&json));
    }

    let context = |source| Error::FilesystemIo {
      path: path.clone(),
      source,
    };

    let file = fs::OpenOptions::new()
      .create(true)
      .read(true)
      .truncate(false)
      .write(true)
      .open(&path)
      .map_err(context)?;

    file.lock().map_err(context)?;

    if file.metadata().map_err(context)?.len() == 0 {
      return Ok(CacheStatus::Miss(CacheLock {
        file,
        path,
        recipe: key.recipe.clone(),
      }));
    }

    for output in outputs.values() {
      if !filesystem::exists(output)? {
        return Ok(CacheStatus::Miss(CacheLock {
          file,
          path,
          recipe: key.recipe.clone(),
        }));
      }
    }

    Ok(CacheStatus::Hit)
  }

  pub(crate) fn new(search: &Search) -> Self {
    Self {
      path: Self::dir(search),
      initialized: Mutex::new(false),
    }
  }

  fn entry(&self, key: blake3::Hash) -> RunResult<'static, PathBuf> {
    let mut initialized = self.initialized.lock().unwrap();

    if !*initialized {
      fs::create_dir_all(&self.path).map_err(|source| Error::FilesystemIo {
        source,
        path: self.path.clone(),
      })?;
      *initialized = true;
    }

    Ok(self.path.join(format!("{key}.json")))
  }

  pub(crate) fn inputs(
    value: Value,
    working_directory: &Path,
  ) -> RunResult<'static, BTreeMap<String, blake3::Hash>> {
    let mut inputs = BTreeMap::new();

    for input in value.elements() {
      let path = working_directory.join(input);

      let metadata = match fs::metadata(&path) {
        Ok(metadata) => metadata,
        Err(source) if source.kind() == io::ErrorKind::NotFound => {
          return Err(Error::CacheInputMissing { path });
        }
        Err(source) => return Err(Error::FilesystemIo { source, path }),
      };

      if metadata.is_dir() {
        return Err(Error::CacheInputDirectory { path });
      }

      let mut hasher = blake3::Hasher::new();

      hasher
        .update_mmap_rayon(&path)
        .map_err(|source| Error::FilesystemIo {
          source,
          path: path.clone(),
        })?;

      inputs.insert(input.into(), hasher.finalize());
    }

    Ok(inputs)
  }

  pub(crate) fn dir(search: &Search) -> PathBuf {
    search.justfile_parent().join(DIR)
  }
}