Function TestHandlersForIndexControl

rest_test.go:2752–2998

(t *testing.T)

}

func TestHandlersForIndexControl(t *testing.T) {
	rest.RequestProxyStubFunc = func() bool {
		return false
	}
	emptyDir, _ := ioutil.TempDir("./tmp", "test")
	defer func() {
		os.RemoveAll(emptyDir)
		rest.RequestProxyStubFunc = nil
	}()

	cfg := cbgt.NewCfgMem()
	meh := &TestMEH{}
	mgr := cbgt.NewManager(cbgt.VERSION, cfg, cbgt.NewUUID(),
		nil, "", 1, "", ":1000", emptyDir, "some-datasource", meh)
	mgr.Start("wanted")
	mgr.Kick("test-start-kick")

	mr, _ := cbgt.NewMsgRing(os.Stderr, 1000)
	mr.Write([]byte("hello"))
	mr.Write([]byte("world"))

	router, _, err := NewRESTRouter("v0", mgr, "static", "", mr, nil)
	if err != nil || router == nil {
		t.Errorf("no mux router")
	}

	tests := []*RESTHandlerTest{
		{
			Desc:   "ingestControl on not-an-index",
			Path:   "/api/index/not-an-index/ingestControl/pause",
			Method: "POST",
			Params: nil,
			Body:   nil,
			Status: 400,
			ResponseMatch: map[string]bool{
				`err`: true,
			},
		},
		{
			Desc:   "queryControl on not-an-index",
			Path:   "/api/index/not-an-index/queryControl/disallow",
			Method: "POST",
			Params: nil,
			Body:   nil,
			Status: 400,
			ResponseMatch: map[string]bool{
				`err`: true,
			},
		},
		{
			Desc:   "create an index with nil feed",
			Path:   "/api/index/idx0",
			Method: "PUT",
			Params: url.Values{
				"indexType":  []string{"fulltext-index"},
				"sourceType": []string{"nil"},
			},
			Body:   nil,