Skip to content

Commit

Permalink
Include package.json when user specifies inputs (#1832)
Browse files Browse the repository at this point in the history
We want to include each workspace's package.json as an input when
the user has configured a smaller set of inputs, because the package.json
defines the actual task turbo will execute for that workspace (via scripts).
If that task definition changes, the cache is invalid.

We only apply this inclusion when inputs are defined, because if inputs
are not defined, all git-tracked files are included in the hash,
which will also include the package.json file.
  • Loading branch information
mehulkar authored Sep 9, 2022
1 parent 8645530 commit aa019da
Show file tree
Hide file tree
Showing 2 changed files with 49 additions and 6 deletions.
24 changes: 20 additions & 4 deletions cli/internal/hashing/package_deps_hash.go
Original file line number Diff line number Diff line change
Expand Up @@ -31,25 +31,41 @@ func GetPackageDeps(rootPath turbopath.AbsolutePath, p *PackageDepsOptions) (map
pkgPath := rootPath.Join(p.PackagePath.ToStringDuringMigration())
// Add all the checked in hashes.
var result map[turbopath.AnchoredUnixPath]string
if len(p.InputPatterns) == 0 {

// make a copy of the inputPatterns array, becase we may be appending to it later.
calculatedInputs := make([]string, len(p.InputPatterns))
copy(calculatedInputs, p.InputPatterns)

if len(calculatedInputs) == 0 {
gitLsTreeOutput, err := gitLsTree(pkgPath)
if err != nil {
return nil, fmt.Errorf("could not get git hashes for files in package %s: %w", p.PackagePath, err)
}
result = gitLsTreeOutput
} else {
absoluteFilesToHash, err := globby.GlobFiles(pkgPath.ToStringDuringMigration(), p.InputPatterns, nil)

// Add in package.json to input patterns because if the `scripts` in
// the package.json change (i.e. the tasks that turbo executes), we want
// a cache miss, since any existing cache could be invalid.
// Note this package.json will be resolved relative to the pkgPath.
calculatedInputs = append(calculatedInputs, "package.json")

absoluteFilesToHash, err := globby.GlobFiles(pkgPath.ToStringDuringMigration(), calculatedInputs, nil)
if err != nil {
return nil, errors.Wrapf(err, "failed to resolve input globs %v", p.InputPatterns)
return nil, errors.Wrapf(err, "failed to resolve input globs %v", calculatedInputs)
}

filesToHash := make([]turbopath.AnchoredSystemPath, len(absoluteFilesToHash))
for i, rawPath := range absoluteFilesToHash {
relativePathString, err := pkgPath.RelativePathString(rawPath)

if err != nil {
return nil, errors.Wrapf(err, "not relative to package: %v", rawPath)
}

filesToHash[i] = turbopath.AnchoredSystemPathFromUpstream(relativePathString)
}

hashes, err := gitHashObject(turbopath.AbsoluteSystemPathFromUpstream(pkgPath.ToStringDuringMigration()), filesToHash)
if err != nil {
return nil, errors.Wrap(err, "failed hashing resolved inputs globs")
Expand All @@ -59,7 +75,7 @@ func GetPackageDeps(rootPath turbopath.AbsolutePath, p *PackageDepsOptions) (map

// Update the checked in hashes with the current repo status
// The paths returned from this call are anchored at the package directory
gitStatusOutput, err := gitStatus(pkgPath, p.InputPatterns)
gitStatusOutput, err := gitStatus(pkgPath, calculatedInputs)
if err != nil {
return nil, fmt.Errorf("Could not get git hashes from git status: %v", err)
}
Expand Down
31 changes: 29 additions & 2 deletions cli/internal/hashing/package_deps_hash_test.go
Original file line number Diff line number Diff line change
Expand Up @@ -239,24 +239,43 @@ func TestGetPackageDeps(t *testing.T) {

repoRoot := fs.AbsolutePathFromUpstream(t.TempDir())
myPkgDir := repoRoot.Join("my-pkg")

// create the dir first
err := myPkgDir.MkdirAll()
assert.NilError(t, err, "CreateDir")

// create file 1
committedFilePath := myPkgDir.Join("committed-file")
err := committedFilePath.EnsureDir()
assert.NilError(t, err, "EnsureDir")
err = committedFilePath.WriteFile([]byte("committed bytes"), 0644)
assert.NilError(t, err, "WriteFile")

// create file 2
deletedFilePath := myPkgDir.Join("deleted-file")
err = deletedFilePath.WriteFile([]byte("delete-me"), 0644)
assert.NilError(t, err, "WriteFile")

// create file 3
nestedPath := myPkgDir.Join("dir", "nested-file")
assert.NilError(t, nestedPath.EnsureDir(), "EnsureDir")
assert.NilError(t, nestedPath.WriteFile([]byte("nested"), 0644), "WriteFile")

// create a package.json
packageJSONPath := myPkgDir.Join("package.json")
err = packageJSONPath.WriteFile([]byte("{}"), 0644)
assert.NilError(t, err, "WriteFile")

// set up git repo and commit all
requireGitCmd(t, repoRoot, "init", ".")
requireGitCmd(t, repoRoot, "config", "--local", "user.name", "test")
requireGitCmd(t, repoRoot, "config", "--local", "user.email", "test@example.com")
requireGitCmd(t, repoRoot, "add", ".")
requireGitCmd(t, repoRoot, "commit", "-m", "foo")

// remove a file
err = deletedFilePath.Remove()
assert.NilError(t, err, "Remove")

// create another untracked file in git
uncommittedFilePath := myPkgDir.Join("uncommitted-file")
err = uncommittedFilePath.WriteFile([]byte("uncommitted bytes"), 0644)
assert.NilError(t, err, "WriteFile")
Expand All @@ -265,25 +284,30 @@ func TestGetPackageDeps(t *testing.T) {
opts *PackageDepsOptions
expected map[turbopath.AnchoredUnixPath]string
}{
// base case. when inputs aren't specified, all files hashes are computed
{
opts: &PackageDepsOptions{
PackagePath: "my-pkg",
},
expected: map[turbopath.AnchoredUnixPath]string{
"committed-file": "3a29e62ea9ba15c4a4009d1f605d391cdd262033",
"uncommitted-file": "4e56ad89387e6379e4e91ddfe9872cf6a72c9976",
"package.json": "9e26dfeeb6e641a33dae4961196235bdb965b21b",
"dir/nested-file": "bfe53d766e64d78f80050b73cd1c88095bc70abb",
},
},
// with inputs, only the specified inputs are hashed
{
opts: &PackageDepsOptions{
PackagePath: "my-pkg",
InputPatterns: []string{"uncommitted-file"},
},
expected: map[turbopath.AnchoredUnixPath]string{
"package.json": "9e26dfeeb6e641a33dae4961196235bdb965b21b",
"uncommitted-file": "4e56ad89387e6379e4e91ddfe9872cf6a72c9976",
},
},
// inputs with glob pattern also works
{
opts: &PackageDepsOptions{
PackagePath: "my-pkg",
Expand All @@ -292,16 +316,19 @@ func TestGetPackageDeps(t *testing.T) {
expected: map[turbopath.AnchoredUnixPath]string{
"committed-file": "3a29e62ea9ba15c4a4009d1f605d391cdd262033",
"uncommitted-file": "4e56ad89387e6379e4e91ddfe9872cf6a72c9976",
"package.json": "9e26dfeeb6e641a33dae4961196235bdb965b21b",
"dir/nested-file": "bfe53d766e64d78f80050b73cd1c88095bc70abb",
},
},
// inputs with another glob pattern works
{
opts: &PackageDepsOptions{
PackagePath: "my-pkg",
InputPatterns: []string{"**/{uncommitted,committed}-file"},
},
expected: map[turbopath.AnchoredUnixPath]string{
"committed-file": "3a29e62ea9ba15c4a4009d1f605d391cdd262033",
"package.json": "9e26dfeeb6e641a33dae4961196235bdb965b21b",
"uncommitted-file": "4e56ad89387e6379e4e91ddfe9872cf6a72c9976",
},
},
Expand Down

0 comments on commit aa019da

Please sign in to comment.