feat: move poll db updates to llc

Author: isekovanic

package/src/components/Chat/hooks/handleEventToSyncDB.ts

@@ -4,7 +4,6 @@ import { deleteChannel } from '../../../store/apis/deleteChannel';
 import { deleteMember } from '../../../store/apis/deleteMember';
 import { deleteMessagesForChannel } from '../../../store/apis/deleteMessagesForChannel';
 import { updateMessage } from '../../../store/apis/updateMessage';
-import { updatePollMessage } from '../../../store/apis/updatePollMessage';
 import { upsertChannelData } from '../../../store/apis/upsertChannelData';
 import { upsertChannelDataFromChannel } from '../../../store/apis/upsertChannelDataFromChannel';
 import { upsertMembers } from '../../../store/apis/upsertMembers';
@@ -264,26 +263,5 @@ export const handleEventToSyncDB = async (event: Event, client: StreamChat, flus
     }
   }
 
-  if (
-    [
-      'poll.closed',
-      'poll.updated',
-      'poll.vote_casted',
-      'poll.vote_changed',
-      'poll.vote_removed',
-    ].includes(type)
-  ) {
-    const { poll, poll_vote, type } = event;
-    if (poll) {
-      return updatePollMessage({
-        eventType: type,
-        flush,
-        poll,
-        poll_vote,
-        userID: client?.userID || '',
-      });
-    }
-  }
-
   return [];
 };

package/src/store/OfflineDB.ts

@@ -31,6 +31,8 @@ export class OfflineDB extends AbstractOfflineDB {
   upsertAppSettings = ({ appSettings, userId, flush }: UpsertAppSettingsType) =>
     api.upsertAppSettings({ appSettings, currentUserId: userId, flush });
 
+  upsertPoll = api.upsertPoll;
+
   // FIXME
   getChannels = ({ cids, userId }: GetChannelsType) =>
     api.getChannels({ channelIds: cids, currentUserId: userId });

package/src/store/apis/index.ts

@@ -25,6 +25,7 @@ export * from './upsertMembers';
 export * from './upsertMessages';
 export * from './upsertReads';
 export * from './updatePollMessage';
+export * from './upsertPoll';
 export * from './addPendingTask';
 export * from './deletePendingTask';
 export * from './getPendingTasks';

package/src/store/apis/upsertPoll.ts

@@ -0,0 +1,29 @@
+import { PollResponse } from 'stream-chat';
+
+import { mapPollToStorable } from '../mappers/mapPollToStorable';
+import { createUpsertQuery } from '../sqlite-utils/createUpsertQuery';
+import { SqliteClient } from '../SqliteClient';
+import type { PreparedQueries } from '../types';
+
+export const upsertPoll = async ({
+  flush = true,
+  poll,
+}: {
+  poll: PollResponse;
+  flush?: boolean;
+}) => {
+  const queries: PreparedQueries[] = [];
+
+  const storablePoll = mapPollToStorable(poll);
+
+  queries.push(createUpsertQuery('poll', storablePoll));
+  SqliteClient.logger?.('info', 'upsertPoll', {
+    poll: storablePoll,
+  });
+
+  if (flush) {
+    await SqliteClient.executeSqlBatch(queries);
+  }
+
+  return queries;
+};