feat!: [CHA-5933] add scheduled messages

src/main/java/io/getstream/Webhook.java

@@ -25,6 +25,7 @@
 import io.getstream.models.AsyncBulkImageModerationEvent;
 import io.getstream.models.AsyncExportChannelsEvent;
 import io.getstream.models.AsyncExportErrorEvent;
+import io.getstream.models.AsyncExportLabelResultsEvent;
 import io.getstream.models.AsyncExportModerationLogsEvent;
 import io.getstream.models.AsyncExportReviewQueueEvent;
 import io.getstream.models.AsyncExportUsersEvent;
@@ -67,6 +68,7 @@
 import io.getstream.models.CallRecordingStoppedEvent;
 import io.getstream.models.CallRejectedEvent;
 import io.getstream.models.CallRingEvent;
+import io.getstream.models.CallRingSettledEvent;
 import io.getstream.models.CallRtmpBroadcastFailedEvent;
 import io.getstream.models.CallRtmpBroadcastStartedEvent;
 import io.getstream.models.CallRtmpBroadcastStoppedEvent;
@@ -100,6 +102,7 @@
 import io.getstream.models.ClosedCaptionEvent;
 import io.getstream.models.CommentAddedEvent;
 import io.getstream.models.CommentDeletedEvent;
+import io.getstream.models.CommentFeedbackEvent;
 import io.getstream.models.CommentReactionAddedEvent;
 import io.getstream.models.CommentReactionDeletedEvent;
 import io.getstream.models.CommentReactionUpdatedEvent;
@@ -123,7 +126,6 @@
 import io.getstream.models.IngressErrorEvent;
 import io.getstream.models.IngressStartedEvent;
 import io.getstream.models.IngressStoppedEvent;
-import io.getstream.models.IntentDetectedEvent;
 import io.getstream.models.KickedUserEvent;
 import io.getstream.models.MaxStreakChangedEvent;
 import io.getstream.models.MemberAddedEvent;
@@ -149,6 +151,12 @@
 import io.getstream.models.NotificationThreadMessageNewEvent;
 import io.getstream.models.PendingMessageEvent;
 import io.getstream.models.PermissionRequestEvent;
+import io.getstream.models.PollClosedEvent;
+import io.getstream.models.PollDeletedEvent;
+import io.getstream.models.PollUpdatedEvent;
+import io.getstream.models.PollVoteCastedEvent;
+import io.getstream.models.PollVoteChangedEvent;
+import io.getstream.models.PollVoteRemovedEvent;
 import io.getstream.models.ReactionDeletedEvent;
 import io.getstream.models.ReactionNewEvent;
 import io.getstream.models.ReactionUpdatedEvent;
@@ -158,6 +166,8 @@
 import io.getstream.models.ReminderUpdatedEvent;
 import io.getstream.models.ReviewQueueItemNewEvent;
 import io.getstream.models.ReviewQueueItemUpdatedEvent;
+import io.getstream.models.ScheduledMessageFailedEvent;
+import io.getstream.models.ScheduledMessageSentEvent;
 import io.getstream.models.StoriesFeedUpdatedEvent;
 import io.getstream.models.ThreadUpdatedEvent;
 import io.getstream.models.UnblockedUserEvent;
@@ -245,6 +255,7 @@ public static class EventType {
     public static final String CALL_RECORDING_STOPPED = "call.recording_stopped";
     public static final String CALL_REJECTED = "call.rejected";
     public static final String CALL_RING = "call.ring";
+    public static final String CALL_RING_SETTLED = "call.ring_settled";
     public static final String CALL_RTMP_BROADCAST_FAILED = "call.rtmp_broadcast_failed";
     public static final String CALL_RTMP_BROADCAST_STARTED = "call.rtmp_broadcast_started";
     public static final String CALL_RTMP_BROADCAST_STOPPED = "call.rtmp_broadcast_stopped";
@@ -285,6 +296,8 @@ public static class EventType {
         "export.bulk_image_moderation.success";
     public static final String EXPORT_CHANNELS_ERROR = "export.channels.error";
     public static final String EXPORT_CHANNELS_SUCCESS = "export.channels.success";
+    public static final String EXPORT_LABEL_RESULTS_ERROR = "export.label_results.error";
+    public static final String EXPORT_LABEL_RESULTS_SUCCESS = "export.label_results.success";
     public static final String EXPORT_MODERATION_LOGS_ERROR = "export.moderation_logs.error";
     public static final String EXPORT_MODERATION_LOGS_SUCCESS = "export.moderation_logs.success";
     public static final String EXPORT_REVIEW_QUEUE_ERROR = "export.review_queue.error";
@@ -311,6 +324,7 @@ public static class EventType {
     public static final String FEEDS_BOOKMARK_FOLDER_UPDATED = "feeds.bookmark_folder.updated";
     public static final String FEEDS_COMMENT_ADDED = "feeds.comment.added";
     public static final String FEEDS_COMMENT_DELETED = "feeds.comment.deleted";
+    public static final String FEEDS_COMMENT_FEEDBACK = "feeds.comment.feedback";
     public static final String FEEDS_COMMENT_REACTION_ADDED = "feeds.comment.reaction.added";
     public static final String FEEDS_COMMENT_REACTION_DELETED = "feeds.comment.reaction.deleted";
     public static final String FEEDS_COMMENT_REACTION_UPDATED = "feeds.comment.reaction.updated";
@@ -352,7 +366,6 @@ public static class EventType {
     public static final String MODERATION_FLAGGED = "moderation.flagged";
     public static final String MODERATION_IMAGE_ANALYSIS_COMPLETE =
         "moderation.image_analysis.complete";
-    public static final String MODERATION_INTENT_DETECTED = "moderation.intent_detected";
     public static final String MODERATION_MARK_REVIEWED = "moderation.mark_reviewed";
     public static final String MODERATION_TEXT_ANALYSIS_COMPLETE =
         "moderation.text_analysis.complete";
@@ -361,6 +374,12 @@ public static class EventType {
     public static final String NOTIFICATION_MARK_UNREAD = "notification.mark_unread";
     public static final String NOTIFICATION_REMINDER_DUE = "notification.reminder_due";
     public static final String NOTIFICATION_THREAD_MESSAGE_NEW = "notification.thread_message_new";
+    public static final String POLL_CLOSED = "poll.closed";
+    public static final String POLL_DELETED = "poll.deleted";
+    public static final String POLL_UPDATED = "poll.updated";
+    public static final String POLL_VOTE_CASTED = "poll.vote_casted";
+    public static final String POLL_VOTE_CHANGED = "poll.vote_changed";
+    public static final String POLL_VOTE_REMOVED = "poll.vote_removed";
     public static final String REACTION_DELETED = "reaction.deleted";
     public static final String REACTION_NEW = "reaction.new";
     public static final String REACTION_UPDATED = "reaction.updated";
@@ -369,6 +388,8 @@ public static class EventType {
     public static final String REMINDER_UPDATED = "reminder.updated";
     public static final String REVIEW_QUEUE_ITEM_NEW = "review_queue_item.new";
     public static final String REVIEW_QUEUE_ITEM_UPDATED = "review_queue_item.updated";
+    public static final String SCHEDULED_MESSAGE_FAILED = "scheduled_message.failed";
+    public static final String SCHEDULED_MESSAGE_SENT = "scheduled_message.sent";
     public static final String THREAD_UPDATED = "thread.updated";
     public static final String USER_BANNED = "user.banned";
     public static final String USER_DEACTIVATED = "user.deactivated";
@@ -556,6 +577,8 @@ private static Class<?> getEventClass(String eventType) {
         return CallRejectedEvent.class;
       case "call.ring":
         return CallRingEvent.class;
+      case "call.ring_settled":
+        return CallRingSettledEvent.class;
       case "call.rtmp_broadcast_failed":
         return CallRtmpBroadcastFailedEvent.class;
       case "call.rtmp_broadcast_started":
@@ -630,6 +653,10 @@ private static Class<?> getEventClass(String eventType) {
         return AsyncExportErrorEvent.class;
       case "export.channels.success":
         return AsyncExportChannelsEvent.class;
+      case "export.label_results.error":
+        return AsyncExportErrorEvent.class;
+      case "export.label_results.success":
+        return AsyncExportLabelResultsEvent.class;
       case "export.moderation_logs.error":
         return AsyncExportErrorEvent.class;
       case "export.moderation_logs.success":
@@ -680,6 +707,8 @@ private static Class<?> getEventClass(String eventType) {
         return CommentAddedEvent.class;
       case "feeds.comment.deleted":
         return CommentDeletedEvent.class;
+      case "feeds.comment.feedback":
+        return CommentFeedbackEvent.class;
       case "feeds.comment.reaction.added":
         return CommentReactionAddedEvent.class;
       case "feeds.comment.reaction.deleted":
@@ -760,8 +789,6 @@ private static Class<?> getEventClass(String eventType) {
         return ModerationFlaggedEvent.class;
       case "moderation.image_analysis.complete":
         return ModerationImageAnalysisCompleteEvent.class;
-      case "moderation.intent_detected":
-        return IntentDetectedEvent.class;
       case "moderation.mark_reviewed":
         return ModerationMarkReviewedEvent.class;
       case "moderation.text_analysis.complete":
@@ -776,6 +803,18 @@ private static Class<?> getEventClass(String eventType) {
         return ReminderNotificationEvent.class;
       case "notification.thread_message_new":
         return NotificationThreadMessageNewEvent.class;
+      case "poll.closed":
+        return PollClosedEvent.class;
+      case "poll.deleted":
+        return PollDeletedEvent.class;
+      case "poll.updated":
+        return PollUpdatedEvent.class;
+      case "poll.vote_casted":
+        return PollVoteCastedEvent.class;
+      case "poll.vote_changed":
+        return PollVoteChangedEvent.class;
+      case "poll.vote_removed":
+        return PollVoteRemovedEvent.class;
       case "reaction.deleted":
         return ReactionDeletedEvent.class;
       case "reaction.new":
@@ -792,6 +831,10 @@ private static Class<?> getEventClass(String eventType) {
         return ReviewQueueItemNewEvent.class;
       case "review_queue_item.updated":
         return ReviewQueueItemUpdatedEvent.class;
+      case "scheduled_message.failed":
+        return ScheduledMessageFailedEvent.class;
+      case "scheduled_message.sent":
+        return ScheduledMessageSentEvent.class;
       case "thread.updated":
         return ThreadUpdatedEvent.class;
       case "user.banned":

src/main/java/io/getstream/models/AIAudioConfigRequest.java

@@ -29,4 +29,12 @@ public class AIAudioConfigRequest {
   @Nullable
   @JsonProperty("rules")
   private List<BodyguardRule> rules;
+
+  @Nullable
+  @JsonProperty("ai_text_config")
+  private AITextConfig aiTextConfig;
+
+  @Nullable
+  @JsonProperty("llm_config")
+  private LLMConfig llmConfig;
 }

src/main/java/io/getstream/models/AIAudioConfigResponse.java

@@ -14,6 +14,7 @@
 
 import com.fasterxml.jackson.annotation.JsonProperty;
 import java.util.List;
+import org.jetbrains.annotations.Nullable;
 
 @lombok.Data
 @lombok.Builder
@@ -29,4 +30,12 @@ public class AIAudioConfigResponse {
 
   @JsonProperty("rules")
   private List<BodyguardRule> rules;
+
+  @Nullable
+  @JsonProperty("ai_text_config")
+  private AITextConfig aiTextConfig;
+
+  @Nullable
+  @JsonProperty("llm_config")
+  private LLMConfig llmConfig;
 }

src/main/java/io/getstream/models/APIError.java

@@ -41,6 +41,10 @@ public class APIError {
   @JsonProperty("details")
   private List<Integer> details;
 
+  @Nullable
+  @JsonProperty("cooldown_remaining_ms")
+  private Integer cooldownRemainingMs;
+
   @Nullable
   @JsonProperty("unrecoverable")
   private Boolean unrecoverable;

src/main/java/io/getstream/models/ActivitySelectorConfig.java

@@ -42,6 +42,10 @@ public class ActivitySelectorConfig {
   @JsonProperty("ranking_candidate_limit")
   private Integer rankingCandidateLimit;
 
+  @Nullable
+  @JsonProperty("time_budget_ms")
+  private Integer timeBudgetMs;
+
   @Nullable
   @JsonProperty("sort")
   private List<SortParamRequest> sort;

src/main/java/io/getstream/models/ActivitySelectorConfigResponse.java

@@ -43,6 +43,10 @@ public class ActivitySelectorConfigResponse {
   @JsonProperty("ranking_candidate_limit")
   private Integer rankingCandidateLimit;
 
+  @Nullable
+  @JsonProperty("time_budget_ms")
+  private Integer timeBudgetMs;
+
   @Nullable
   @JsonProperty("sort")
   private List<SortParamRequest> sort;

src/main/java/io/getstream/models/AddActivityRequest.java

@@ -78,6 +78,10 @@ public class AddActivityRequest {
   @JsonProperty("skip_enrich_url")
   private Boolean skipEnrichUrl;
 
+  @Nullable
+  @JsonProperty("skip_existing")
+  private Boolean skipExisting;
+
   @Nullable
   @JsonProperty("skip_push")
   private Boolean skipPush;

src/main/java/io/getstream/models/AddActivityResponse.java

@@ -13,6 +13,7 @@
 package io.getstream.models;
 
 import com.fasterxml.jackson.annotation.JsonProperty;
+import java.util.List;
 import org.jetbrains.annotations.Nullable;
 
 @lombok.Data
@@ -30,4 +31,8 @@ public class AddActivityResponse {
   @Nullable
   @JsonProperty("mention_notifications_created")
   private Integer mentionNotificationsCreated;
+
+  @Nullable
+  @JsonProperty("skipped_existing")
+  private List<String> skippedExisting;
 }

src/main/java/io/getstream/models/AnalyzeResponse.java

@@ -28,6 +28,14 @@ public class AnalyzeResponse {
   @JsonProperty("status")
   private String status;
 
+  @Nullable
+  @JsonProperty("llm_model")
+  private String llmModel;
+
+  @Nullable
+  @JsonProperty("llm_reasoning_effort")
+  private String llmReasoningEffort;
+
   @Nullable
   @JsonProperty("images")
   private Map<String, AnalyzeImageField> images;

src/main/java/io/getstream/models/AppDefaults.java

@@ -0,0 +1,29 @@
+/*
+ * ========================================================================
+ * WARNING: GENERATED CODE -- DO NOT EDIT!
+ * ========================================================================
+ *
+ * This file was auto-generated by GetStream internal OpenAPI
+ *
+ * Any modifications to this file will be lost upon regeneration.
+ * To make changes, please modify the source templates and regenerate.
+ *
+ * ========================================================================
+ */
+package io.getstream.models;
+
+import com.fasterxml.jackson.annotation.JsonProperty;
+
+/** Request limit defaults applied by the server when the corresponding field is omitted. */
+@lombok.Data
+@lombok.Builder
+@lombok.NoArgsConstructor
+@lombok.AllArgsConstructor
+public class AppDefaults {
+
+  @JsonProperty("get_or_create_channel")
+  private GetOrCreateChannelDefaults getOrCreateChannel;
+
+  @JsonProperty("query_channels")
+  private QueryChannelsDefaults queryChannels;
+}

src/main/java/io/getstream/models/AppResponseFields.java

@@ -18,6 +18,7 @@
 import java.util.Map;
 import org.jetbrains.annotations.Nullable;
 
+/** A type representing the app settings. */
 @lombok.Data
 @lombok.Builder
 @lombok.NoArgsConstructor
@@ -165,6 +166,9 @@ public class AppResponseFields {
   @JsonProperty("channel_configs")
   private Map<String, ChannelConfig> channelConfigs;
 
+  @JsonProperty("defaults")
+  private AppDefaults defaults;
+
   @JsonProperty("file_upload_config")
   private FileUploadConfig fileUploadConfig;
 

src/main/java/io/getstream/models/AsyncExportLabelResultsEvent.java

@@ -0,0 +1,50 @@
+/*
+ * ========================================================================
+ * WARNING: GENERATED CODE -- DO NOT EDIT!
+ * ========================================================================
+ *
+ * This file was auto-generated by GetStream internal OpenAPI
+ *
+ * Any modifications to this file will be lost upon regeneration.
+ * To make changes, please modify the source templates and regenerate.
+ *
+ * ========================================================================
+ */
+package io.getstream.models;
+
+import com.fasterxml.jackson.annotation.JsonProperty;
+import java.util.Date;
+import java.util.Map;
+import org.jetbrains.annotations.Nullable;
+
+@lombok.Data
+@lombok.Builder
+@lombok.NoArgsConstructor
+@lombok.AllArgsConstructor
+public class AsyncExportLabelResultsEvent {
+
+  @JsonProperty("created_at")
+  private Date createdAt;
+
+  @JsonProperty("finished_at")
+  private Date finishedAt;
+
+  @JsonProperty("started_at")
+  private Date startedAt;
+
+  @JsonProperty("task_id")
+  private String taskID;
+
+  @JsonProperty("url")
+  private String url;
+
+  @JsonProperty("custom")
+  private Map<String, Object> custom;
+
+  @JsonProperty("type")
+  private String type;
+
+  @Nullable
+  @JsonProperty("received_at")
+  private Date receivedAt;
+}