Merge branch 'master' into mod210

Author: varbhat

CHANGELOG.md

@@ -1,3 +1,19 @@
+## [9.25.0](https://github.com/GetStream/stream-chat-js/compare/v9.24.0...v9.25.0) (2025-10-23)
+
+### Bug Fixes
+
+* prevent search source pagination on non-retryable response errors ([#1638](https://github.com/GetStream/stream-chat-js/issues/1638)) ([d306a1a](https://github.com/GetStream/stream-chat-js/commit/d306a1a7dd6fb138d07d0278068d31d0dcf068de))
+
+### Features
+
+* add delivery_events channel configuration parameter ([#1639](https://github.com/GetStream/stream-chat-js/issues/1639)) ([13d295a](https://github.com/GetStream/stream-chat-js/commit/13d295ae251f1c5aa5d97fad9340cce092dfb91c))
+
+## [9.24.0](https://github.com/GetStream/stream-chat-js/compare/v9.23.0...v9.24.0) (2025-10-17)
+
+### Features
+
+* llm config types for upsert config api ([#1640](https://github.com/GetStream/stream-chat-js/issues/1640)) ([e80e42c](https://github.com/GetStream/stream-chat-js/commit/e80e42cbf43a40a79f5c3ba811c4cb9360a2b94f))
+
 ## [9.23.0](https://github.com/GetStream/stream-chat-js/compare/v9.22.1...v9.23.0) (2025-10-15)
 
 ### Features

src/channel.ts

@@ -1936,6 +1936,15 @@ export class Channel {
             deliveredAt: event.created_at,
             lastDeliveredMessageId: event.last_delivered_message_id,
           });
+
+          const client = this.getClient();
+          const isOwnEvent = event.user?.id === client.user?.id;
+
+          // make sure not to report deliveries that were
+          // already confirmed from own user from another device
+          if (isOwnEvent) {
+            client.syncDeliveredCandidates([this]);
+          }
         }
         break;
       case 'user.watching.start':

src/channel_state.ts

@@ -250,11 +250,15 @@ export class ChannelState {
           delete this.threads[message.id];
         }
 
-        if (!this.last_message_at) {
-          this.last_message_at = new Date(message.created_at.getTime());
-        }
-
-        if (message.created_at.getTime() > this.last_message_at.getTime()) {
+        const shouldSkipLastMessageAtUpdate =
+          this._channel.getConfig()?.skip_last_msg_update_for_system_msgs &&
+          message.type === 'system';
+
+        if (
+          !shouldSkipLastMessageAtUpdate &&
+          (!this.last_message_at ||
+            message.created_at.getTime() > this.last_message_at.getTime())
+        ) {
           this.last_message_at = new Date(message.created_at.getTime());
         }
       }

src/client.ts

@@ -4749,17 +4749,14 @@ export class StreamChat {
   }
 
   /**
-   * Send the mark delivered event for this user
+   * Mark the channels delivered for the given messages and the user
    *
    * @param {MarkDeliveredOptions} data
    * @return {Promise<EventAPIResponse | void>} Description
    */
   async markChannelsDelivered(data: MarkDeliveredOptions) {
     if (!data?.latest_delivered_messages?.length) return;
-    return await this.post<EventAPIResponse>(
-      this.baseURL + '/channels/delivered',
-      data ?? {},
-    );
+    return await this.post<EventAPIResponse>(this.baseURL + '/channels/delivered', data);
   }
 
   syncDeliveredCandidates(collections: Channel[]) {

src/messageDelivery/MessageDeliveryReporter.ts

@@ -54,6 +54,11 @@ export class MessageDeliveryReporter {
     return this.deliveryReportCandidates.size > 0;
   }
 
+  private static hasPermissionToReportDeliveryFor(collection: Channel | Thread) {
+    if (isChannel(collection)) return !!collection.getConfig()?.delivery_events;
+    if (isThread(collection)) return !!collection.channel.getConfig()?.delivery_events;
+  }
+
   /**
    * Build latest_delivered_messages payload from an arbitrary buffer (deliveryReportCandidates / nextDeliveryReportCandidates)
    */
@@ -142,8 +147,7 @@ export class MessageDeliveryReporter {
    * @param collection
    */
   private trackDeliveredCandidate(collection: Channel | Thread) {
-    if (isChannel(collection) && !collection.getConfig()?.read_events) return;
-    if (isThread(collection) && !collection.channel.getConfig()?.read_events) return;
+    if (!MessageDeliveryReporter.hasPermissionToReportDeliveryFor(collection)) return;
     const candidate = this.getNextDeliveryReportCandidate(collection);
     if (!candidate?.key) return;
     const buffer = this.markDeliveredRequestInFlight

src/search/BaseSearchSource.ts

@@ -6,6 +6,8 @@ import type {
   SearchSourceState,
   SearchSourceType,
 } from './types';
+import type { APIError } from '../errors';
+import { isAPIError, isErrorRetryable } from '../errors';
 
 export type DebounceOptions = {
   debounceMs: number;
@@ -237,6 +239,9 @@ export abstract class BaseSearchSource<T>
       stateUpdate.items = await this.filterQueryResults(items);
     } catch (e) {
       stateUpdate.lastQueryError = e as Error;
+      if (isAPIError(e as Error) && !isErrorRetryable(e as APIError)) {
+        stateUpdate.hasNext = false;
+      }
     } finally {
       this.state.next(this.getStateAfterQuery(stateUpdate, hasNewSearchQuery));
     }
@@ -285,6 +290,9 @@ export abstract class BaseSearchSourceSync<T>
       stateUpdate.items = this.filterQueryResults(items);
     } catch (e) {
       stateUpdate.lastQueryError = e as Error;
+      if (isAPIError(e as Error) && !isErrorRetryable(e as APIError)) {
+        stateUpdate.hasNext = false;
+      }
     } finally {
       this.state.next(this.getStateAfterQuery(stateUpdate, hasNewSearchQuery));
     }

src/types.ts

@@ -95,6 +95,7 @@ export type AppSettingsAPIResponse = APIResponse & {
         connect_events?: boolean;
         created_at?: string;
         custom_events?: boolean;
+        delivery_events?: boolean;
         mark_messages_pending?: boolean;
         max_message_length?: number;
         message_retention?: string;
@@ -1015,6 +1016,7 @@ export type CreateChannelOptions = {
   connect_events?: boolean;
   connection_id?: string;
   custom_events?: boolean;
+  delivery_events?: boolean;
   grants?: Record<string, string[]>;
   mark_messages_pending?: boolean;
   max_message_length?: number;
@@ -1120,6 +1122,7 @@ export type UpdateChannelTypeRequest =
     commands?: CommandVariants[];
     connect_events?: boolean;
     custom_events?: boolean;
+    delivery_events?: boolean;
     grants?: Record<string, string[]>;
     mark_messages_pending?: boolean;
     mutes?: boolean;
@@ -1151,6 +1154,7 @@ export type UpdateChannelTypeResponse = {
   connect_events: boolean;
   created_at: string;
   custom_events: boolean;
+  delivery_events: boolean;
   duration: string;
   grants: Record<string, string[]>;
   mark_messages_pending: boolean;
@@ -1188,6 +1192,7 @@ export type GetChannelTypeResponse = {
   connect_events: boolean;
   created_at: string;
   custom_events: boolean;
+  delivery_events: boolean;
   duration: string;
   grants: Record<string, string[]>;
   mark_messages_pending: boolean;
@@ -2384,6 +2389,7 @@ export type ChannelConfigFields = {
   blocklist_behavior?: ChannelConfigAutomodBehavior;
   connect_events?: boolean;
   custom_events?: boolean;
+  delivery_events?: boolean;
   mark_messages_pending?: boolean;
   max_message_length?: number;
   message_retention?: string;
@@ -2397,6 +2403,7 @@ export type ChannelConfigFields = {
   replies?: boolean;
   search?: boolean;
   shared_locations?: boolean;
+  skip_last_msg_update_for_system_msgs?: boolean;
   count_messages?: boolean;
   typing_events?: boolean;
   uploads?: boolean;
@@ -3889,6 +3896,7 @@ export type ModerationConfig = {
   automod_semantic_filters_config?: AutomodSemanticFiltersConfig;
   automod_toxicity_config?: AutomodToxicityConfig;
   block_list_config?: BlockListConfig;
+  llm_config?: LLMConfig;
   team?: string;
 };
 
@@ -4119,6 +4127,8 @@ export type ModerationActionType =
   | 'bounce_flag'
   | 'bounce_remove';
 
+export type ModerationSeverity = 'low' | 'medium' | 'high' | 'critical';
+
 export type AutomodRule = {
   action: ModerationActionType;
   label: string;
@@ -4136,6 +4146,24 @@ export type BlockListConfig = {
   async?: boolean;
 };
 
+export type LLMConfig = {
+  rules: LLMRule[];
+  severity_descriptions?: Record<ModerationSeverity, string>;
+  app_context?: string;
+};
+
+export type LLMRule = {
+  label: string;
+  description: string;
+  action: ModerationActionType;
+  severity_rules?: LLMSeverityRule[];
+};
+
+export type LLMSeverityRule = {
+  severity: ModerationSeverity;
+  action: ModerationActionType;
+};
+
 export type AutomodToxicityConfig = {
   enabled: boolean;
   rules: AutomodRule[];
@@ -4162,7 +4190,7 @@ export type AutomodSemanticFiltersConfig = {
 
 export type AITextSeverityRule = {
   action: ModerationActionType;
-  severity: 'low' | 'medium' | 'high' | 'critical';
+  severity: ModerationSeverity;
 };
 
 export type AITextRule = {