Function TestUpsertCollectionObjects

collections_test.go:21–71

(t *testing.T)

}

func TestUpsertCollectionObjects(t *testing.T) {
	ctx := context.Background()
	client, requester := newClient(t)
	testCases := []struct {
		objects      []stream.CollectionObject
		collection   string
		expectedURL  string
		expectedBody string
	}{
		{
			collection: "test-single",
			objects: []stream.CollectionObject{
				{
					ID: "1",
					Data: map[string]any{
						"name":    "Juniper",
						"hobbies": []string{"playing", "sleeping", "eating"},
					},
				},
			},
			expectedURL:  "https://api.stream-io-api.com/api/v1.0/collections/?api_key=key",
			expectedBody: `{"data":{"test-single":[{"hobbies":["playing","sleeping","eating"],"id":"1","name":"Juniper"}]}}`,
		},
		{
			collection: "test-many",
			objects: []stream.CollectionObject{
				{
					ID: "1",
					Data: map[string]any{
						"name":    "Juniper",
						"hobbies": []string{"playing", "sleeping", "eating"},
					},
				},
				{
					ID: "2",
					Data: map[string]any{
						"name":      "Ruby",
						"interests": []string{"sunbeams", "surprise attacks"},
					},
				},
			},
			expectedURL:  "https://api.stream-io-api.com/api/v1.0/collections/?api_key=key",
			expectedBody: `{"data":{"test-many":[{"hobbies":["playing","sleeping","eating"],"id":"1","name":"Juniper"},{"id":"2","interests":["sunbeams","surprise attacks"],"name":"Ruby"}]}}`,
		},
	}
	for _, tc := range testCases {
		_, err := client.Collections().Upsert(ctx, tc.collection, tc.objects...)
		require.NoError(t, err)
		testRequest(t, requester.req, http.MethodPost, tc.expectedURL, tc.expectedBody)
	}
}

func TestSelectCollectionObjects(t *testing.T) {
	ctx := context.Background()