Function TestAddCollectionObject

collections_test.go:144–185

(t *testing.T)

}

func TestAddCollectionObject(t *testing.T) {
	ctx := context.Background()
	client, requester := newClient(t)
	testCases := []struct {
		object       stream.CollectionObject
		collection   string
		opts         []stream.AddObjectOption
		expectedURL  string
		expectedBody string
	}{
		{
			collection: "no_user_id",
			object: 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/no_user_id/?api_key=key",
			expectedBody: `{"data":{"hobbies":["playing","sleeping","eating"],"name":"Juniper"},"id":"1"}`,
		},
		{
			collection: "with_user_id",
			object: stream.CollectionObject{
				ID: "1",
				Data: map[string]any{
					"name":    "Juniper",
					"hobbies": []string{"playing", "sleeping", "eating"},
				},
			},
			opts:         []stream.AddObjectOption{stream.WithUserID("user1")},
			expectedURL:  "https://api.stream-io-api.com/api/v1.0/collections/with_user_id/?api_key=key",
			expectedBody: `{"data":{"hobbies":["playing","sleeping","eating"],"name":"Juniper"},"id":"1","user_id":"user1"}`,
		},
	}
	for _, tc := range testCases {
		_, err := client.Collections().Add(ctx, tc.collection, tc.object, tc.opts...)
		require.NoError(t, err)
		testRequest(t, requester.req, http.MethodPost, tc.expectedURL, tc.expectedBody)
	}
}

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