Normalize queryDrafts sort

Author: arnautov-anton

src/client.ts

@@ -1464,8 +1464,8 @@ export class StreamChat<StreamChatGenerics extends ExtendableGenerics = DefaultG
     // The StableWSConnection handles all the reconnection logic.
     if (this.options.wsConnection && this.node) {
       // Intentionally avoiding adding ts generics on wsConnection in options since its only useful for unit test purpose.
-      ((this.options.wsConnection as unknown) as StableWSConnection<StreamChatGenerics>).setClient(this);
-      this.wsConnection = (this.options.wsConnection as unknown) as StableWSConnection<StreamChatGenerics>;
+      (this.options.wsConnection as unknown as StableWSConnection<StreamChatGenerics>).setClient(this);
+      this.wsConnection = this.options.wsConnection as unknown as StableWSConnection<StreamChatGenerics>;
     } else {
       this.wsConnection = new StableWSConnection<StreamChatGenerics>({
         client: this,
@@ -1967,7 +1967,7 @@ export class StreamChat<StreamChatGenerics extends ExtendableGenerics = DefaultG
     // Check if the channel already exists.
     // Only allow 1 channel object per cid
     const memberIds = (custom.members ?? []).map((member: string | NewMemberPayload<StreamChatGenerics>) =>
-      typeof member === 'string' ? member : member.user_id ?? '',
+      typeof member === 'string' ? member : (member.user_id ?? ''),
     );
     const membersStr = memberIds.sort().join(',');
     const tempCid = generateChannelTempCid(channelType, memberIds);
@@ -2647,13 +2647,13 @@ export class StreamChat<StreamChatGenerics extends ExtendableGenerics = DefaultG
     );
     return this.partialUpdateMessage(
       messageId,
-      ({
+      {
         set: {
           pinned: true,
           pin_expires: this._normalizeExpiration(timeoutOrExpirationDate),
           pinned_at: this._normalizeExpiration(pinnedAt),
         },
-      } as unknown) as PartialMessageUpdate<StreamChatGenerics>,
+      } as unknown as PartialMessageUpdate<StreamChatGenerics>,
       pinnedBy,
     );
   }
@@ -2670,9 +2670,9 @@ export class StreamChat<StreamChatGenerics extends ExtendableGenerics = DefaultG
     );
     return this.partialUpdateMessage(
       messageId,
-      ({
+      {
         set: { pinned: false },
-      } as unknown) as PartialMessageUpdate<StreamChatGenerics>,
+      } as unknown as PartialMessageUpdate<StreamChatGenerics>,
       userId,
     );
   }
@@ -2735,7 +2735,7 @@ export class StreamChat<StreamChatGenerics extends ExtendableGenerics = DefaultG
      * SDK missed this conversion.
      */
     if (Array.isArray(clonedMessage.mentioned_users) && !isString(clonedMessage.mentioned_users[0])) {
-      clonedMessage.mentioned_users = clonedMessage.mentioned_users.map((mu) => ((mu as unknown) as UserResponse).id);
+      clonedMessage.mentioned_users = clonedMessage.mentioned_users.map((mu) => (mu as unknown as UserResponse).id);
     }
 
     return await this.post<UpdateMessageAPIResponse<StreamChatGenerics>>(
@@ -2846,9 +2846,7 @@ export class StreamChat<StreamChatGenerics extends ExtendableGenerics = DefaultG
     );
 
     return {
-      threads: response.threads.map(
-        (thread) => new Thread<StreamChatGenerics>({ client: this, threadData: thread }),
-      ),
+      threads: response.threads.map((thread) => new Thread<StreamChatGenerics>({ client: this, threadData: thread })),
       next: response.next,
     };
   }
@@ -2943,14 +2941,16 @@ export class StreamChat<StreamChatGenerics extends ExtendableGenerics = DefaultG
 
     const { os, model } = this.deviceIdentifier ?? {};
 
-    return ([
-      // reports the device OS, if provided
-      ['os', os],
-      // reports the device model, if provided
-      ['device_model', model],
-      // reports which bundle is being picked from the exports
-      ['client_bundle', clientBundle],
-    ] as const).reduce(
+    return (
+      [
+        // reports the device OS, if provided
+        ['os', os],
+        // reports the device model, if provided
+        ['device_model', model],
+        // reports which bundle is being picked from the exports
+        ['client_bundle', clientBundle],
+      ] as const
+    ).reduce(
       (withArguments, [key, value]) =>
         value && value.length > 0 ? withArguments.concat(`|${key}=${value}`) : withArguments,
       userAgentString,
@@ -2994,8 +2994,11 @@ export class StreamChat<StreamChatGenerics extends ExtendableGenerics = DefaultG
       };
     }
 
-    const { params: axiosRequestConfigParams, headers: axiosRequestConfigHeaders, ...axiosRequestConfigRest } =
-      this.options.axiosRequestConfig || {};
+    const {
+      params: axiosRequestConfigParams,
+      headers: axiosRequestConfigHeaders,
+      ...axiosRequestConfigRest
+    } = this.options.axiosRequestConfig || {};
 
     return {
       params: {
@@ -4071,6 +4074,12 @@ export class StreamChat<StreamChatGenerics extends ExtendableGenerics = DefaultG
       user_id?: string;
     } = {},
   ) {
-    return await this.post<QueryDraftsResponse<StreamChatGenerics>>(this.baseURL + '/drafts/query', options);
+    const payload = {
+      filter: options.filter,
+      user_id: options.user_id,
+      sort: options.sort ? normalizeQuerySort(options.sort) : undefined,
+    };
+
+    return await this.post<QueryDraftsResponse<StreamChatGenerics>>(this.baseURL + '/drafts/query', payload);
   }
 }