For You Feed

It’s now common for apps to default to a “For you” style feed instead of just a following feed. This section of the docs will explain how to build a for you feed with Stream.

While the exact logic differs per app, fundamently the “for you” feed does a 2 different things:

1 - Activity Selectors

The feed pulls in activities from different sources (activity selectors). Examples include:

• Popular activities
• Activities close to you
• Activities from people you follow
• Activities from your follow recommendations
• Specific editorial feeds
• Activities that match your interests
• Other activity queries/selections

Read more about the supported activity selectors here.

2- Ranking

After the feed combines the activities from different selectors it applies ranking. Stream supports expression based ranking out of the box. This allows you to define a formula to rank activities.

In the example below we’ll build a simple interest based for you feed

Step 1 - Create a feed group

For the feed group we’re enabling interest based ranking. We are ranking on interest_score * popularity * decay_exp(time) For activity selectors we’re also keeping it simple, showing just the activities from people you follow & popular activities.

We’re also enabling activity processors. The text topics activity processor uses an LLM to summarize the topics for an activity. It writes this data to activity.interest_tags. This update happens in the background.

const response = await serverClient.feeds.updateFeedGroup({
  id: "timeline",
  activity_selectors: [{ type: "following" }, { type: "popular" }],
  ranking: {
    type: "interest",
    score: "interest_score * popularity * decay_exp(time)",
    defaults: { popularity: 1 },
  },
  activity_processors: [{ type: "text_topics" }],
});

updateResponse, err := feedsClient.UpdateFeedGroup(ctx, "feed_group_id", &getstream.UpdateFeedGroupRequest{
	ActivityProcessors: []getstream.ActivityProcessorConfig{
		{Type: "default"},
	},
	Aggregation: &getstream.AggregationConfig{
		Format: getstream.PtrTo("time_based"),
	},
})

$updateResponse = $this->feedsV3Client->updateFeedGroup('feed_group_id', new GeneratedModels\UpdateFeedGroupRequest(
    aggregation: new GeneratedModels\AggregationConfig('default')
));

var updateResponse = await _feedsV3Client.UpdateFeedGroupAsync("feed_group_id", new UpdateFeedGroupRequest
{
    ActivityProcessors = new List<ActivityProcessorConfig>
    {
        new() { Type = "default" }
    },
    Aggregation = new AggregationConfig
    {
        Format = "time_based"
    }
});

update_response = self.client.feeds.update_feed_group(id= "feed_group_id")

Step 2 - Activities with interest tags

Let’s add 2 activities to a feed

const feed = client.feeds.feed("user", "jack");

// since we've enabled the "text_topics" activity processor the "activity.interest_tags" will be automatically set
const response = await client.feeds.addActivity({
  feeds: [feed.feed]
  type: "post",
  text: "apple stock will go up",
  user_id: 'jack'
});

// you can also set this field manually
const response = await client.feeds.addActivity({
  feeds: ["user:1", "stock:apple"],
  type: "post",
  text: "apple stock will go up",
  interest_tags: ["apple", "stock"],
  user_id: 'jack'
});

feedIdentifier := fmt.Sprintf("%s:%s", userFeedType, testUserID)
response, err := feedsClient.AddActivity(ctx, &getstream.AddActivityRequest{
	Type:   "post",
	Feeds:  []string{feedIdentifier},
	Text:   getstream.PtrTo("This is a test activity from Go SDK"),
	UserID: &testUserID,
	Custom: map[string]interface{}{
		"test_field": "test_value",
		"timestamp":  time.Now().Unix(),
	},
})

AddActivityRequest activity =
    AddActivityRequest.builder()
        .type("post")
        .feeds(List.of(testFeedId))
        .text("This is a test activity from Java SDK")
        .userID(testUserId)
        .build();

AddActivityResponse response = feeds.addActivity(activity).execute().getData();

$activity = new GeneratedModels\AddActivityRequest(
    type: 'post',
    feeds: [$this->testFeed->getFeedIdentifier()],
    text: 'This is a test activity from PHP SDK',
    userID: $this->testUserId,
    custom: (object)[
        'test_field' => 'test_value',
        'timestamp' => time()
    ]
);
$response = $this->feedsV3Client->addActivity($activity);

var activity = new AddActivityRequest
{
    Type = "post",
    Text = "This is a test activity from .NET SDK",
    UserID = _testUserId,
    Feeds = new List<string> { $"user:{_testFeedId}" }
};
var response = await _feedsV3Client.AddActivityAsync(activity);

response = self.client.feeds.add_activity(
    type="post",
    feeds=[self.test_feed.get_feed_identifier()],
    text="This is a test activity from Python SDK",
    user_id=self.test_user_id,
    custom={
        "test_field": "test_value",
        "timestamp": int(datetime.now().timestamp()),
    },
)

The important part here is that the activity has the interest tags set.

Step 3 - Reading the interest based ranked feed

When reading an interest based feed you can either have Stream automatically calculate the interest weights, or pass them manually.

const interestWeights = {
  go: 1.0, // User loves Go
  python: 0.5, // User is ok with Python
  ruby: -1.0, // User dislikes Ruby
};
const feed = client.feeds.feed("user", "jack");
const response = await feed.getOrCreate({
  limit: 10,
  view: "my_for_you_view",
  interest_weights: interestWeights, // overwrite the default interest weights for this feed
  user_id: "jack",
});

feedsClient := client.Feeds()
_, err = feedsClient.GetOrCreateFeed(ctx, userFeedType, testUserID, &getstream.GetOrCreateFeedRequest{
	UserID: &testUserID,
})

if err != nil {
	t.Logf("Failed to create feed 1: %v", err)
}

_, err = feedsClient.GetOrCreateFeed(ctx, userFeedType, testUserID2, &getstream.GetOrCreateFeedRequest{
	UserID: &testUserID2,
})

testFeed = new Feed("user", testUserId, feeds);
testFeed2 = new Feed("user", testUserId2, feeds);

GetOrCreateFeedRequest feedRequest1 =
    GetOrCreateFeedRequest.builder().userID(testUserId).build();
GetOrCreateFeedRequest feedRequest2 =
    GetOrCreateFeedRequest.builder().userID(testUserId2).build();

GetOrCreateFeedResponse feedResponse1 = testFeed.getOrCreate(feedRequest1).getData();
GetOrCreateFeedResponse feedResponse2 = testFeed2.getOrCreate(feedRequest2).getData();
testFeedId = feedResponse1.getFeed().getFeed();
testFeedId2 = feedResponse2.getFeed().getFeed();

$feedResponse1 = $this->testFeed->getOrCreateFeed(
    new GeneratedModels\GetOrCreateFeedRequest(userID: $this->testUserId)
);
$feedResponse2 = $this->testFeed2->getOrCreateFeed(
    new GeneratedModels\GetOrCreateFeedRequest(userID: $this->testUserId2)
);

var feedResponse1 = await _feedsV3Client.GetOrCreateFeedAsync(
    FeedGroupID: "user",
    FeedID: _testFeedId,
    request: new GetOrCreateFeedRequest { UserID = _testUserId }
);
var feedResponse2 = await _feedsV3Client.GetOrCreateFeedAsync(
    FeedGroupID: "user",
    FeedID: _testFeedId2,
    request: new GetOrCreateFeedRequest { UserID = _testUserId2 }
);

feed_response_1 = self.test_feed.get_or_create(user_id=self.test_user_id)
feed_response_2 = self.test_feed_2.get_or_create(
    user_id=self.test_user_id_2
)

Conclusion

In a few lines of code you created an interest based “for you” style feed. It includes popular content as well as activities from the people you follow. Activities from topics you engage with are shown higher in the feed.

This example kept things pretty basic but you can make it more complex.

• You could include activities based on their interest_tags. So if someone engages with content about snowboarding you could show them more of that
• Images can also be processed for interest tags
• More ranking & activity selectors can be added. Activities close to you, activities from follow suggestions etc.

You can build infinitely complex “for you” style feeds with ranking & activity selectors. Be sure to reach out to our support team in case anything is missing. We’re often adding selector or processors based on customer feedback.