internal/pkg: move dependency flooding to cache

This imposes a hard upper limit to concurrency during dependency satisfaction and moves all dependency-related code out of individual implementations of Artifact. This change also includes ctx and msg as part of Cache.

Signed-off-by: Ophestra <cat@gensokyo.uk>

1 files changed, 13 insertions, 13 deletions

diff --git a/internal/pkg/net_test.go b/internal/pkg/net_test.go
index da1a75dc..2ea3dd07 100644
--- a/internal/pkg/net_test.go
+++ b/internal/pkg/net_test.go
@@ -37,10 +37,10 @@ func TestHTTPGet(t *testing.T) {
 				testdataChecksum,
 			)
 			wantIdent := pkg.KindHTTPGet.Ident([]byte("file:///testdata"))
-			if got, err := f.Data(); err != nil {
-				t.Fatalf("Data: error = %v", err)
+			if got, err := f.Cure(); err != nil {
+				t.Fatalf("Cure: error = %v", err)
 			} else if string(got) != testdata {
-				t.Fatalf("Data: %x, want %x", got, testdata)
+				t.Fatalf("Cure: %x, want %x", got, testdata)
 			} else if gotIdent := pkg.Ident(f); gotIdent != wantIdent {
 				t.Fatalf("Ident: %s, want %s", pkg.Encode(gotIdent), pkg.Encode(wantIdent))
 			}
@@ -55,8 +55,8 @@ func TestHTTPGet(t *testing.T) {
 			wantErrMismatch := &pkg.ChecksumMismatchError{
 				Got: testdataChecksum,
 			}
-			if _, err := f.Data(); !reflect.DeepEqual(err, wantErrMismatch) {
-				t.Fatalf("Data: error = %#v, want %#v", err, wantErrMismatch)
+			if _, err := f.Cure(); !reflect.DeepEqual(err, wantErrMismatch) {
+				t.Fatalf("Cure: error = %#v, want %#v", err, wantErrMismatch)
 			} else if gotIdent := pkg.Ident(f); gotIdent != wantIdent {
 				t.Fatalf("Ident: %s, want %s", pkg.Encode(gotIdent), pkg.Encode(wantIdent))
 			}
@@ -70,8 +70,8 @@ func TestHTTPGet(t *testing.T) {
 			)
 			wantIdentNonexistent := pkg.KindHTTPGet.Ident([]byte("file:///nonexistent"))
 			wantErrNotFound := pkg.ResponseStatusError(http.StatusNotFound)
-			if _, err := f.Data(); !reflect.DeepEqual(err, wantErrNotFound) {
-				t.Fatalf("Data: error = %#v, want %#v", err, wantErrNotFound)
+			if _, err := f.Cure(); !reflect.DeepEqual(err, wantErrNotFound) {
+				t.Fatalf("Cure: error = %#v, want %#v", err, wantErrNotFound)
 			} else if gotIdent := pkg.Ident(f); gotIdent != wantIdentNonexistent {
 				t.Fatalf("Ident: %s, want %s", pkg.Encode(gotIdent), pkg.Encode(wantIdentNonexistent))
 			}
@@ -97,10 +97,10 @@ func TestHTTPGet(t *testing.T) {
 				t.Fatalf("Cure: %x, want %x", checksum, testdataChecksum)
 			}
 
-			if got, err := f.Data(); err != nil {
-				t.Fatalf("Data: error = %v", err)
+			if got, err := f.Cure(); err != nil {
+				t.Fatalf("Cure: error = %v", err)
 			} else if string(got) != testdata {
-				t.Fatalf("Data: %x, want %x", got, testdata)
+				t.Fatalf("Cure: %x, want %x", got, testdata)
 			} else if gotIdent := pkg.Ident(f); gotIdent != wantIdent {
 				t.Fatalf("Ident: %s, want %s", pkg.Encode(gotIdent), pkg.Encode(wantIdent))
 			}
@@ -112,10 +112,10 @@ func TestHTTPGet(t *testing.T) {
 				"file:///testdata",
 				testdataChecksum,
 			)
-			if got, err := f.Data(); err != nil {
-				t.Fatalf("Data: error = %v", err)
+			if got, err := f.Cure(); err != nil {
+				t.Fatalf("Cure: error = %v", err)
 			} else if string(got) != testdata {
-				t.Fatalf("Data: %x, want %x", got, testdata)
+				t.Fatalf("Cure: %x, want %x", got, testdata)
 			} else if gotIdent := pkg.Ident(f); gotIdent != wantIdent {
 				t.Fatalf("Ident: %s, want %s", pkg.Encode(gotIdent), pkg.Encode(wantIdent))
 			}