Function TestFollowMany

client_test.go:44–66

(t *testing.T)

}

func TestFollowMany(t *testing.T) {
	var (
		client, requester = newClient(t)
		ctx               = context.Background()
		relationships     = make([]stream.FollowRelationship, 3)
		flat, _           = newFlatFeedWithUserID(client, "123")
	)

	for i := range relationships {
		other, _ := newAggregatedFeedWithUserID(client, strconv.Itoa(i))
		relationships[i] = stream.NewFollowRelationship(other, flat)
	}

	err := client.FollowMany(ctx, relationships)
	require.NoError(t, err)
	body := `[{"source":"aggregated:0","target":"flat:123"},{"source":"aggregated:1","target":"flat:123"},{"source":"aggregated:2","target":"flat:123"}]`
	testRequest(t, requester.req, http.MethodPost, "https://api.stream-io-api.com/api/v1.0/follow_many/?api_key=key", body)

	err = client.FollowMany(ctx, relationships, stream.WithFollowManyActivityCopyLimit(500))
	require.NoError(t, err)
	body = `[{"source":"aggregated:0","target":"flat:123"},{"source":"aggregated:1","target":"flat:123"},{"source":"aggregated:2","target":"flat:123"}]`
	testRequest(t, requester.req, http.MethodPost, "https://api.stream-io-api.com/api/v1.0/follow_many/?activity_copy_limit=500&api_key=key", body)
}

func TestFollowManyActivityCopyLimit(t *testing.T) {
	var (