Function TestEncrypt

pkg/blobserver/encrypt/encrypt_test.go:97–168

(t *testing.T)

}

func TestEncrypt(t *testing.T) {
	ts := newTestStorage()

	const blobData = "foofoofoo"
	tb := &test.Blob{Contents: blobData}
	tb.MustUpload(t, ts.sto)
	if got := ts.fetchOrErrorString(tb.BlobRef()); got != blobData {
		t.Errorf("Fetching plaintext blobref %v = %v; want %q", tb.BlobRef(), got, blobData)
	}

	// Make sure the plaintext doesn't show up anywhere.
	for _, bs := range []*test.Fetcher{ts.meta, ts.blobs} {
		c := make(chan blob.SizedRef)
		go bs.EnumerateBlobs(context.TODO(), c, "", 0)
		for sb := range c {
			data, ok := bs.BlobContents(sb.Ref)
			if !ok {
				panic("where did it go?")
			}
			if strings.Contains(data, blobData) {
				t.Error("plaintext found in storage")
			}
		}
	}

	const blobData2 = "bar"
	tb2 := &test.Blob{Contents: blobData2}
	tb2.MustUpload(t, ts.sto)
	if got := ts.fetchOrErrorString(tb2.BlobRef()); got != blobData2 {
		t.Errorf("Fetching plaintext blobref %v = %v; want %q", tb2.BlobRef(), got, blobData2)
	}

	missingError := "Error: file does not exist"
	tb3 := &test.Blob{Contents: "xxx"}
	if got := ts.fetchOrErrorString(tb3.BlobRef()); got != missingError {
		t.Errorf("Fetching missing blobref %v; want %q", got, missingError)
	}

	ctx := context.Background()
	got, err := blobserver.StatBlobs(ctx, ts.sto, []blob.Ref{tb3.BlobRef(), tb.BlobRef(), tb2.BlobRef()})
	if err != nil {
		t.Fatalf("StatBlobs: %v", err)
	}
	if sr := got[tb.BlobRef()]; sr != tb.SizedRef() {
		t.Errorf("tb stat = %v; want %v", sr, tb.SizedRef())
	}
	if sr := got[tb2.BlobRef()]; sr != tb2.SizedRef() {
		t.Errorf("tb2 stat = %v; want %v", sr, tb2.SizedRef())
	}
	if sr, ok := got[tb3.BlobRef()]; ok {
		t.Errorf("unexpected stat response for tb3: %v", sr)
	}
	if len(got) != 2 {
		t.Errorf("unexpected blobs in stat response")
	}

	c := make(chan blob.SizedRef)
	go func() {