Function TestBulkDocs

rest/api_test.go:405–532

(t *testing.T)

}

func TestBulkDocs(t *testing.T) {
	tests := []struct {
		occKey string
	}{
		{occKey: db.BodyRev},
		{occKey: db.BodyCV},
	}

	for _, test := range tests {
		t.Run(test.occKey, func(t *testing.T) {
			rt := NewRestTester(t, nil)
			defer rt.Close()

			const bulk1DocID = "bulk1"
			const bulk2DocID = "bulk2"
			const bulk3LocalDocID = "_local/bulk3"

			// insert all

			input := fmt.Sprintf(
				`{"docs": [{%q:%q, %q:%d}, {%q:%q, %q:%d}, {%q:%q, %q:%d}]}`,
				db.BodyId, bulk1DocID, "n", 1,
				db.BodyId, bulk2DocID, "n", 2,
				db.BodyId, bulk3LocalDocID, "n", 3,
			)
			response := rt.SendAdminRequest(http.MethodPost, "/{{.keyspace}}/_bulk_docs", input)
			RequireStatus(t, response, http.StatusCreated)

			// get persisted versions
			bulk1Version, _ := rt.GetDoc(bulk1DocID)
			bulk2Version, _ := rt.GetDoc(bulk2DocID)
			bulk3Version, _ := rt.GetDoc(bulk3LocalDocID)

			var docs []any
			require.NoError(t, base.JSONUnmarshal(response.Body.Bytes(), &docs))
			assert.Equal(t, []any{
				map[string]any{"rev": bulk1Version.RevTreeID, "cv": bulk1Version.CV.String(), "id": bulk1DocID},
				map[string]any{"rev": bulk2Version.RevTreeID, "cv": bulk2Version.CV.String(), "id": bulk2DocID},
				map[string]any{"rev": bulk3Version.RevTreeID, "id": bulk3LocalDocID},
			}, docs)

			// check stored docs
			response = rt.SendAdminRequest(http.MethodGet, fmt.Sprintf("/{{.keyspace}}/%s", bulk1DocID), "")
			RequireStatus(t, response, http.StatusOK)
			assert.JSONEq(t, fmt.Sprintf(`{%q:%q, %q:%q, %q:%q, %q:%d}`,
				db.BodyId, bulk1DocID,
				db.BodyRev, bulk1Version.RevTreeID,
				db.BodyCV, bulk1Version.CV,
				"n", 1,
			), response.BodyString())
			response = rt.SendAdminRequest(http.MethodGet, fmt.Sprintf("/{{.keyspace}}/%s", bulk2DocID), "")
			RequireStatus(t, response, http.StatusOK)
			assert.JSONEq(t, fmt.Sprintf(`{%q:%q, %q:%q, %q:%q, %q:%d}`,
				db.BodyId, bulk2DocID,
				db.BodyRev, bulk2Version.RevTreeID,
				db.BodyCV, bulk2Version.CV,
				"n", 2,
			), response.BodyString())