Function TestHandlersWithOnePartitionPrimaryFeedIndex

rest_test.go:880–1616

(t *testing.T)

}

func TestHandlersWithOnePartitionPrimaryFeedIndex(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)

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

	var doneCh chan *httptest.ResponseRecorder

	var feed *cbgt.PrimaryFeed

	tests := []*RESTHandlerTest{
		{
			Desc:   "create an index with dest feed with bad sourceParams",
			Path:   "/api/index/idx0",
			Method: "PUT",
			Params: url.Values{
				"indexType":    []string{"fulltext-index"},
				"sourceType":   []string{"primary"},
				"sourceParams": []string{"-}totally n0t json{-"},
			},
			Body:   nil,
			Status: 400,
			ResponseMatch: map[string]bool{
				`could not parse sourceParams`: true,
			},
		},
		{
			Desc:   "create an index with dest feed with 1 partition",
			Path:   "/api/index/idx0",
			Method: "PUT",
			Params: url.Values{
				"indexType":    []string{"fulltext-index"},
				"sourceType":   []string{"primary"},
				"sourceParams": []string{`{"numPartitions":1}`},
			},
			Body:   nil,
			Status: http.StatusOK,
			ResponseMatch: map[string]bool{
				`"status":"ok"`: true,