fix: own reactions

Author: isekovanic

package/src/store/OfflineDB.ts

@@ -1,13 +1,10 @@
-import {
-  AbstractOfflineDB,
-  GetAppSettingsType,
-  StreamChat,
-  UpsertAppSettingsType,
-} from 'stream-chat';
+import { AbstractOfflineDB, StreamChat } from 'stream-chat';
 import type {
+  GetAppSettingsType,
   GetChannelsForQueryType,
   GetChannelsType,
   GetLastSyncedAtType,
+  UpsertAppSettingsType,
   UpsertUserSyncStatusType,
 } from 'stream-chat';
 

package/src/store/apis/getChannelMessages.ts

@@ -25,7 +25,7 @@ export const getChannelMessages = async ({
   const messageIds = messageRows.map(({ id }) => id);
 
   // Populate the message reactions.
-  const reactionRows = await selectReactionsForMessages(messageIds);
+  const reactionRows = await selectReactionsForMessages(messageIds, null);
   const messageIdVsReactions: Record<string, TableRowJoinedUser<'reactions'>[]> = {};
   reactionRows.forEach((reaction) => {
     if (!messageIdVsReactions[reaction.messageId]) {

package/src/store/apis/queries/selectReactionsForMessages.ts

@@ -13,7 +13,7 @@ import type { TableRowJoinedUser } from '../../types';
  */
 export const selectReactionsForMessages = async (
   messageIds: string[],
-  limit: number = 25,
+  limit: number | null = 25,
   filters?: Pick<ReactionFilters, 'type'>,
   sort?: ReactionSort,
 ): Promise<TableRowJoinedUser<'reactions'>[]> => {
@@ -52,8 +52,8 @@ export const selectReactionsForMessages = async (
     ON b.id = a.userId
     WHERE a.messageId in (${questionMarks}) ${filters?.type ? `AND a.type = ?` : ''}
     ${orderByClause}
-    LIMIT ?`,
-    [...messageIds, ...filterValue, limit],
+    ${limit ? 'LIMIT ?' : ''}`,
+    [...messageIds, ...filterValue, ...(limit ? [limit] : [])],
   );
 
   return result.map((r) => JSON.parse(r.value));