aboutsummaryrefslogtreecommitdiffstatshomepage
path: root/cli/internal/cache/cache_http_test.go
diff options
context:
space:
mode:
Diffstat (limited to 'cli/internal/cache/cache_http_test.go')
-rw-r--r--cli/internal/cache/cache_http_test.go245
1 files changed, 0 insertions, 245 deletions
diff --git a/cli/internal/cache/cache_http_test.go b/cli/internal/cache/cache_http_test.go
deleted file mode 100644
index d187931..0000000
--- a/cli/internal/cache/cache_http_test.go
+++ /dev/null
@@ -1,245 +0,0 @@
-package cache
-
-import (
- "archive/tar"
- "bytes"
- "errors"
- "net/http"
- "testing"
-
- "github.com/DataDog/zstd"
-
- "github.com/vercel/turbo/cli/internal/fs"
- "github.com/vercel/turbo/cli/internal/turbopath"
- "github.com/vercel/turbo/cli/internal/util"
- "gotest.tools/v3/assert"
-)
-
-type errorResp struct {
- err error
-}
-
-func (sr *errorResp) PutArtifact(hash string, body []byte, duration int, tag string) error {
- return sr.err
-}
-
-func (sr *errorResp) FetchArtifact(hash string) (*http.Response, error) {
- return nil, sr.err
-}
-
-func (sr *errorResp) ArtifactExists(hash string) (*http.Response, error) {
- return nil, sr.err
-}
-
-func (sr *errorResp) GetTeamID() string {
- return ""
-}
-
-func TestRemoteCachingDisabled(t *testing.T) {
- clientErr := &util.CacheDisabledError{
- Status: util.CachingStatusDisabled,
- Message: "Remote Caching has been disabled for this team. A team owner can enable it here: $URL",
- }
- client := &errorResp{err: clientErr}
- cache := &httpCache{
- client: client,
- requestLimiter: make(limiter, 20),
- }
- cd := &util.CacheDisabledError{}
- _, _, _, err := cache.Fetch("unused-target", "some-hash", []string{"unused", "outputs"})
- if !errors.As(err, &cd) {
- t.Errorf("cache.Fetch err got %v, want a CacheDisabled error", err)
- }
- if cd.Status != util.CachingStatusDisabled {
- t.Errorf("CacheDisabled.Status got %v, want %v", cd.Status, util.CachingStatusDisabled)
- }
-}
-
-func makeValidTar(t *testing.T) *bytes.Buffer {
- // <repoRoot>
- // my-pkg/
- // some-file
- // link-to-extra-file -> ../extra-file
- // broken-link -> ../../global-dep
- // extra-file
-
- t.Helper()
- buf := &bytes.Buffer{}
- zw := zstd.NewWriter(buf)
- defer func() {
- if err := zw.Close(); err != nil {
- t.Fatalf("failed to close gzip: %v", err)
- }
- }()
- tw := tar.NewWriter(zw)
- defer func() {
- if err := tw.Close(); err != nil {
- t.Fatalf("failed to close tar: %v", err)
- }
- }()
-
- // my-pkg
- h := &tar.Header{
- Name: "my-pkg/",
- Mode: int64(0644),
- Typeflag: tar.TypeDir,
- }
- if err := tw.WriteHeader(h); err != nil {
- t.Fatalf("failed to write header: %v", err)
- }
- // my-pkg/some-file
- contents := []byte("some-file-contents")
- h = &tar.Header{
- Name: "my-pkg/some-file",
- Mode: int64(0644),
- Typeflag: tar.TypeReg,
- Size: int64(len(contents)),
- }
- if err := tw.WriteHeader(h); err != nil {
- t.Fatalf("failed to write header: %v", err)
- }
- if _, err := tw.Write(contents); err != nil {
- t.Fatalf("failed to write file: %v", err)
- }
- // my-pkg/link-to-extra-file
- h = &tar.Header{
- Name: "my-pkg/link-to-extra-file",
- Mode: int64(0644),
- Typeflag: tar.TypeSymlink,
- Linkname: "../extra-file",
- }
- if err := tw.WriteHeader(h); err != nil {
- t.Fatalf("failed to write header: %v", err)
- }
- // my-pkg/broken-link
- h = &tar.Header{
- Name: "my-pkg/broken-link",
- Mode: int64(0644),
- Typeflag: tar.TypeSymlink,
- Linkname: "../../global-dep",
- }
- if err := tw.WriteHeader(h); err != nil {
- t.Fatalf("failed to write header: %v", err)
- }
- // extra-file
- contents = []byte("extra-file-contents")
- h = &tar.Header{
- Name: "extra-file",
- Mode: int64(0644),
- Typeflag: tar.TypeReg,
- Size: int64(len(contents)),
- }
- if err := tw.WriteHeader(h); err != nil {
- t.Fatalf("failed to write header: %v", err)
- }
- if _, err := tw.Write(contents); err != nil {
- t.Fatalf("failed to write file: %v", err)
- }
-
- return buf
-}
-
-func makeInvalidTar(t *testing.T) *bytes.Buffer {
- // contains a single file that traverses out
- // ../some-file
-
- t.Helper()
- buf := &bytes.Buffer{}
- zw := zstd.NewWriter(buf)
- defer func() {
- if err := zw.Close(); err != nil {
- t.Fatalf("failed to close gzip: %v", err)
- }
- }()
- tw := tar.NewWriter(zw)
- defer func() {
- if err := tw.Close(); err != nil {
- t.Fatalf("failed to close tar: %v", err)
- }
- }()
-
- // my-pkg/some-file
- contents := []byte("some-file-contents")
- h := &tar.Header{
- Name: "../some-file",
- Mode: int64(0644),
- Typeflag: tar.TypeReg,
- Size: int64(len(contents)),
- }
- if err := tw.WriteHeader(h); err != nil {
- t.Fatalf("failed to write header: %v", err)
- }
- if _, err := tw.Write(contents); err != nil {
- t.Fatalf("failed to write file: %v", err)
- }
- return buf
-}
-
-func TestRestoreTar(t *testing.T) {
- root := fs.AbsoluteSystemPathFromUpstream(t.TempDir())
-
- tar := makeValidTar(t)
-
- expectedFiles := []turbopath.AnchoredSystemPath{
- turbopath.AnchoredUnixPath("extra-file").ToSystemPath(),
- turbopath.AnchoredUnixPath("my-pkg/").ToSystemPath(),
- turbopath.AnchoredUnixPath("my-pkg/some-file").ToSystemPath(),
- turbopath.AnchoredUnixPath("my-pkg/link-to-extra-file").ToSystemPath(),
- turbopath.AnchoredUnixPath("my-pkg/broken-link").ToSystemPath(),
- }
- files, err := restoreTar(root, tar)
- assert.NilError(t, err, "readTar")
-
- expectedSet := make(util.Set)
- for _, file := range expectedFiles {
- expectedSet.Add(file.ToString())
- }
- gotSet := make(util.Set)
- for _, file := range files {
- gotSet.Add(file.ToString())
- }
- extraFiles := gotSet.Difference(expectedSet)
- if extraFiles.Len() > 0 {
- t.Errorf("got extra files: %v", extraFiles.UnsafeListOfStrings())
- }
- missingFiles := expectedSet.Difference(gotSet)
- if missingFiles.Len() > 0 {
- t.Errorf("missing expected files: %v", missingFiles.UnsafeListOfStrings())
- }
-
- // Verify file contents
- extraFile := root.UntypedJoin("extra-file")
- contents, err := extraFile.ReadFile()
- assert.NilError(t, err, "ReadFile")
- assert.DeepEqual(t, contents, []byte("extra-file-contents"))
-
- someFile := root.UntypedJoin("my-pkg", "some-file")
- contents, err = someFile.ReadFile()
- assert.NilError(t, err, "ReadFile")
- assert.DeepEqual(t, contents, []byte("some-file-contents"))
-}
-
-func TestRestoreInvalidTar(t *testing.T) {
- root := fs.AbsoluteSystemPathFromUpstream(t.TempDir())
- expectedContents := []byte("important-data")
- someFile := root.UntypedJoin("some-file")
- err := someFile.WriteFile(expectedContents, 0644)
- assert.NilError(t, err, "WriteFile")
-
- tar := makeInvalidTar(t)
- // use a child directory so that blindly untarring will squash the file
- // that we just wrote above.
- repoRoot := root.UntypedJoin("repo")
- _, err = restoreTar(repoRoot, tar)
- if err == nil {
- t.Error("expected error untarring invalid tar")
- }
-
- contents, err := someFile.ReadFile()
- assert.NilError(t, err, "ReadFile")
- assert.Equal(t, string(contents), string(expectedContents), "expected to not overwrite file")
-}
-
-// Note that testing Put will require mocking the filesystem and is not currently the most
-// interesting test. The current implementation directly returns the error from PutArtifact.
-// We should still add the test once feasible to avoid future breakage.
generated by cgit v1.2.3-70-g09d2 (git 2.46.0) at 2026-01-21 07:44:39 +0000