Function TestIndexDefWithJSON

rest_test.go:3076–3200

(t *testing.T)

}

func TestIndexDefWithJSON(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:   "try create index with bad JSON",
			Path:   "/api/index/idx0",
			Method: "PUT",
			Params: url.Values{
				"indexType":    []string{"fulltext-index"},
				"sourceType":   []string{"primary"},
				"sourceParams": []string{`{"numPartitions":10}`},
			},
			Body:   []byte(`BAAAAD json! :-{`),
			Status: 400,
			ResponseMatch: map[string]bool{
				`err`: true,
			},
		},
		{
			Desc:   "create index with primary feed",
			Path:   "/api/index/idx0",
			Method: "PUT",
			Params: url.Values{
				"indexType":    []string{"fulltext-index"},
				"sourceType":   []string{"primary"},
				"sourceParams": []string{`{"numPartitions":10}`},
			},
			Body: []byte(`{ "indexType": "fulltext-index",
                            "indexParams": "{}",
                            "sourceType": "primary",
                            "sourceUUID": "beefbeef",
                            "sourceParams": "{\"numPartitions\":10}"
                          }`),
			Status: http.StatusOK,