val client = FeedsClient(context = context, apiKey = apiKey, user = user, tokenProvider = tokenProvider)
val moderation = client.moderationModeration
Stream Feeds has support for moderation, allowing you to manage user interactions, content moderation, and platform safety. It's accessible through the client.moderation property.
Overview
User Moderation
Ban Users
Ban a user from the platform with various options including timeout, shadow bans, and IP bans.
val banRequest = BanRequest(
targetUserId = "user-123",
reason = "Violation of community guidelines",
timeout = 3600, // 1 hour in seconds
shadow = false,
ipBan = false
)
val response: Result<BanResponse> = client.moderation.ban(banRequest = banRequest)
println("User banned for: ${response.getOrNull()?.duration}")Parameters:
targetUserId: The ID of the user to banreason: Optional reason for the bantimeout: Optional timeout in seconds (null for permanent ban)shadow: Whether to perform a shadow ban (user doesn't know they're banned)ipBan: Whether to ban the user's IP addressbannedBy: Optional user who performed the bandeleteMessages: Whether to delete user's messages
To reverse a ban, see Unban User in the Moderation docs. The user object returned by queryUsers only exposes the ban state (banned, ban_expires) — it does not include banned_by or the ban reason. To retrieve that metadata, use Query Banned Users.
Mute Users
Mute is not supported in Feeds. Muting a user does not hide their activities from feed reads.
To hide another user's activities in Feeds, use Block Users instead.
Block Users
Block a user. Blocking is bidirectional:
- Neither user sees the other's activities in feeds
- Neither can follow the other
This replaces the v2 discard_actors option. Instead of sending blocked user IDs on every feed read, call blockUsers once — Stream filters those activities automatically.
val blockRequest = BlockUsersRequest(blockedUserId = "user-123")
val response: Result<BlockUsersResponse> = client.moderation.blockUser(blockRequest)Unblock Users
Unblock a previously blocked user.
val unblockRequest = UnblockUsersRequest(blockedUserId = "user-123")
val response: Result<UnblockUsersResponse> = client.moderation.unblockUser(unblockRequest)Get Blocked Users
Retrieve a list of users you have blocked.
val blockedUsers: Result<GetBlockedUsersResponse> = client.moderation.getBlockedUsers()
blockedUsers.getOrNull()?.blocks?.forEach { block ->
println("Blocked user: ${block.blockedUser.id}")
}Content Moderation
Flag Content
Flag inappropriate content for moderation review.
val flagRequest = FlagRequest(
entityId = "activity-123",
entityType = "stream:feeds:v3:activity",
reason = "Inappropriate content",
entityCreatorId = "user-456"
)
val response: Result<FlagResponse> = client.moderation.flag(flagRequest = flagRequest)Parameters:
entityId: The ID of the content to flagentityType: The type of content (e.g., "stream:feeds:v3:activity", "stream:feeds:v3:comment")reason: Optional reason for flaggingentityCreatorId: Optional ID of the content creatorcustom: Optional custom data for the flag
Submit Moderation Actions
Submit moderation actions for flagged content.
val actionRequest = SubmitActionRequest(
actionType = SubmitActionRequest.ActionType.MarkReviewed,
itemId = "item-123",
)
val response: Result<SubmitActionResponse> = client.moderation.submitAction(submitActionRequest = actionRequest)Review Queue
Query Review Queue
Retrieve items in the moderation review queue.
val queryRequest = QueryReviewQueueRequest(
// Query parameters for filtering and pagination
)
val reviewQueue: Result<QueryReviewQueueResponse> = client.moderation.queryReviewQueue(queryRequest)Configuration Management
Upsert Moderation Configuration
Create or update moderation configuration settings.
val configRequest = UpsertConfigRequest(
// Configuration details
)
val response: Result<UpsertConfigResponse> = client.moderation.upsertConfig(configRequest)Get Moderation Configuration
Retrieve a specific moderation configuration.
val config: Result<GetConfigResponse> = client.moderation.getConfig(key = "automod_settings", team = "team-123")Parameters:
key: The configuration key to retrieveteam: Optional team identifier
Delete Moderation Configuration
Remove a moderation configuration.
val response: Result<DeleteModerationConfigResponse> = client.moderation.deleteConfig(key = "automod_settings", team = "team-123")Query Moderation Configurations
Search and filter moderation configurations.
val queryRequest = QueryModerationConfigsRequest(
// Query parameters for filtering and pagination
)
val configs: Result<QueryModerationConfigsResponse> = client.moderation.queryModerationConfigs(queryModerationConfigsRequest = queryRequest)Moderation Config Queryable Built-In Fields
| name | type | description | supported operations | example |
|---|---|---|---|---|
key | string or list of strings | The configuration key identifier | $eq, $ne, $gt, $gte, $lt, $lte, $in, $nin, $exists, $autocomplete | { key: { $autocomplete: 'spam' } } |
team | string or list of strings | The team identifier for multi-tenant applications | $eq, $ne, $gt, $gte, $lt, $lte, $in, $nin, $exists | { team: { $eq: 'team_123' } } |
created_at | string, must be formatted as an RFC3339 timestamp | The time the configuration was created | $eq, $gt, $gte, $lt, $lte | { created_at: { $gte: '2023-12-04T09:30:20.45Z' } } |
updated_at | string, must be formatted as an RFC3339 timestamp | The time the configuration was last updated | $eq, $gt, $gte, $lt, $lte | { updated_at: { $gte: '2023-12-04T09:30:20.45Z' } } |
Error Handling
All moderation methods can throw errors. Error handling documents the exception classes and their fields for each backend SDK, and API error codes explains what the codes mean. Handle them appropriately:
// Functions that can result in errors, return Kotlin `Result` objects
val result: Result<BanResponse> = client.moderation.ban(banRequest)