Function TestLocalListObjectsGetTargetURL

ais/tests/regression_test.go:53–136

(t *testing.T)

)

func TestLocalListObjectsGetTargetURL(t *testing.T) {
	var (
		m = ioContext{
			t:         t,
			num:       1000,
			fileSize:  cos.KiB,
			fixedSize: true,
		}

		targets    = make(map[string]struct{})
		proxyURL   = tutils.RandomProxyURL(t)
		baseParams = tutils.BaseAPIParams(proxyURL)
		smap       = tutils.GetClusterMap(t, proxyURL)
	)

	m.initWithCleanupAndSaveState()
	m.expectTargets(1)

	tutils.CreateBucketWithCleanup(t, proxyURL, m.bck, nil)

	m.puts()

	msg := &apc.ListObjsMsg{Props: apc.GetTargetURL}
	bl, err := api.ListObjects(baseParams, m.bck, msg, uint(m.num))
	tassert.CheckFatal(t, err)

	if len(bl.Entries) != m.num {
		t.Errorf("Expected %d bucket list entries, found %d\n", m.num, len(bl.Entries))
	}

	j := 10
	if len(bl.Entries) >= 200 {
		j = 100
	}
	for i, e := range bl.Entries {
		if e.TargetURL == "" {
			t.Error("Target URL in response is empty")
		}
		if _, ok := targets[e.TargetURL]; !ok {
			targets[e.TargetURL] = struct{}{}
		}
		baseParams := tutils.BaseAPIParams(e.TargetURL)

		l, err := api.GetObject(baseParams, m.bck, e.Name)
		tassert.CheckFatal(t, err)
		if uint64(l) != m.fileSize {
			t.Errorf("Expected filesize: %d, actual filesize: %d\n", m.fileSize, l)
		}

		if i%j == 0 {
			if i == 0 {
				tlog.Logln("Modifying config to enforce intra-cluster access, expecting errors...\n")
			}
			tutils.SetClusterConfig(t, cos.SimpleKVs{"features": feat.EnforceIntraClusterAccess.Value()})
			_, err = api.GetObject(baseParams, m.bck, e.Name)

			// TODO -- FIXME: see cmn.ConfigRestartRequired and cmn.Features
			// tassert.Errorf(t, err != nil, "expected intra-cluster access enforced")