add support for external ranking vars

flat_feed_test.go

@@ -2,6 +2,7 @@ package stream_test
 
 import (
 	"context"
+	"encoding/json"
 	"fmt"
 	"net/http"
 	"testing"
@@ -69,6 +70,39 @@ func TestFlatFeedGetActivities(t *testing.T) {
 		assert.NoError(t, err)
 	}
 }
+func TestFlatFeedGetActivitiesExternalRanking(t *testing.T) {
+	ctx := context.Background()
+	client, requester := newClient(t)
+	flat, _ := newFlatFeedWithUserID(client, "123")
+
+	externalVarJSON, err := json.Marshal(map[string]any{
+		"music":   1,
+		"sports":  2.1,
+		"boolVal": true,
+		"string":  "str",
+	})
+
+	require.NoError(t, err)
+	testCases := []struct {
+		opts        []stream.GetActivitiesOption
+		url         string
+		enrichedURL string
+	}{
+		{
+			opts: []stream.GetActivitiesOption{
+				stream.WithExternalRankingVars(string(externalVarJSON)),
+			},
+			url:         "https://api.stream-io-api.com/api/v1.0/feed/flat/123/?api_key=key&ranking_vars=%7B%22boolVal%22%3Atrue%2C%22music%22%3A1%2C%22sports%22%3A2.1%2C%22string%22%3A%22str%22%7D",
+			enrichedURL: "https://api.stream-io-api.com/api/v1.0/enrich/feed/flat/123/?api_key=key&ranking_vars=%7B%22boolVal%22%3Atrue%2C%22music%22%3A1%2C%22sports%22%3A2.1%2C%22string%22%3A%22str%22%7D",
+		},
+	}
+
+	for _, tc := range testCases {
+		_, err := flat.GetActivities(ctx, tc.opts...)
+		testRequest(t, requester.req, http.MethodGet, tc.url, "")
+		assert.NoError(t, err)
+	}
+}
 
 func TestFlatFeedGetNextPageActivities(t *testing.T) {
 	ctx := context.Background()

options.go

@@ -105,6 +105,11 @@ func WithRankingScoreVars() GetActivitiesOption {
 	return GetActivitiesOption{makeRequestOption("withScoreVars", true)}
 }
 
+// externalVarJSON should be valid json
+func WithExternalRankingVars(externalVarJSON string) GetActivitiesOption {
+	return GetActivitiesOption{makeRequestOption("ranking_vars", externalVarJSON)}
+}
+
 // WithNotificationsMarkSeen marks as seen the given activity ids in a notification
 // feed. If the all parameter is true, every activity in the feed is marked as seen.
 func WithNotificationsMarkSeen(all bool, activityIDs ...string) GetActivitiesOption {