Function TestHandleGetBytesPartViaSharing

pkg/server/share_test.go:308–378

(t *testing.T)

}

func TestHandleGetBytesPartViaSharing(t *testing.T) {
	st := newShareTester(t)
	defer st.done()

	content1 := "monkey" // part1
	contentRef1 := blob.RefFromString(content1)
	content2 := "banana" // part2
	contentRef2 := blob.RefFromString(content2)

	link2 := fmt.Sprintf(`{"camliVersion": 1,
"camliType": "bytes",
"parts": [
   {"blobRef": "%v", "size": %d},
   {"blobRef": "%v", "size": %d}
]}`, contentRef1, len(content1), contentRef2, len(content2))
	linkRef2 := blob.RefFromString(link2)

	link1 := fmt.Sprintf(`{"camliVersion": 1,
"camliType": "file",
"parts": [
   {"blobRef": "%v", "size": %d},
   {"bytesRef": "%v", "size": %d}
]}`, blob.RefFromString("irrelevant content"), len("irrelevant content"), linkRef2, len(link2))
	linkRef1 := blob.RefFromString(link1)

	share := schema.NewShareRef(schema.ShareHaveRef, false).
		SetShareTarget(linkRef1).
		SetSigner(blob.RefFromString("irrelevant")).
		SetRawStringField("camliSig", "alsounused")
	shareRef := func() blob.Ref { return share.Blob().BlobRef() }

	t.Logf("Checking share blob doesn't yet exist...")
	st.testGet(shareRef().String(), shareFetchFailed)
	if !st.slept() {
		t.Error("expected sleep after miss")
	}
	st.put(share.Blob())
	t.Logf("Checking share blob now exists...")
	st.testGet(shareRef().String(), noError)

	t.Logf("Checking we can't get the content directly via the share...")
	st.testGet(fmt.Sprintf("%s?via=%s", contentRef2, shareRef()), shareTargetInvalid)

	t.Logf("Checking we can't get the link (file) blob directly...")
	st.putRaw(linkRef1, link1)
	st.testGet(linkRef1.String(), shareBlobInvalid)

	t.Logf("Checking we can get the link (file) blob via the share...")
	st.testGet(fmt.Sprintf("%s?via=%s", linkRef1, shareRef()), noError)

	t.Logf("Checking we can't get the deeper link (bytes) blob via the non-transitive share...")
	st.putRaw(linkRef2, link2)
	st.testGet(fmt.Sprintf("%s?via=%s,%s", linkRef2, shareRef(), linkRef1), shareNotTransitive)

	// TODO: new test?
	share.SetShareIsTransitive(true)
	st.put(share.Blob())
	st.testGet(fmt.Sprintf("%s?via=%s,%s,%s", linkRef2, shareRef(), linkRef1, linkRef2), viaChainInvalidLink)