From c3cedc290149456d7231e683e51e2f082e0f91c9 Mon Sep 17 00:00:00 2001
From: Miguel Alatzar <migbot@users.noreply.github.com>
Date: Thu, 26 Aug 2021 18:29:09 -0700
Subject: [PATCH] Fix where clause (#5646)

---
 .../server_data_operator/handlers/posts_in_channel.ts  | 10 ++++------
 1 file changed, 4 insertions(+), 6 deletions(-)

diff --git a/app/database/operator/server_data_operator/handlers/posts_in_channel.ts b/app/database/operator/server_data_operator/handlers/posts_in_channel.ts
index 74c1eb21b6..67b555403a 100644
--- a/app/database/operator/server_data_operator/handlers/posts_in_channel.ts
+++ b/app/database/operator/server_data_operator/handlers/posts_in_channel.ts
@@ -4,7 +4,6 @@
 import {Q} from '@nozbe/watermelondb';
 
 import {Database} from '@constants';
-import {retrieveRecords} from '@database/operator/utils/general';
 import {transformPostsInChannelRecord} from '@database/operator/server_data_operator/transformers/post';
 import {getPostListEdges} from '@database//operator/utils/post';
 
@@ -129,11 +128,10 @@ const PostsInChannelHandler = (superclass: any) => class extends superclass {
         let latest = 0;
 
         let recentChunk: PostsInChannelModel|undefined;
-        const chunks = (await retrieveRecords({
-            database: this.database,
-            tableName: POSTS_IN_CHANNEL,
-            condition: (Q.where('id', firstPost.channel_id), Q.experimentalSortBy('latest', Q.desc)),
-        })) as PostsInChannelModel[];
+        const chunks = (await this.database.get(POSTS_IN_CHANNEL).query(
+            Q.where('channel_id', firstPost.channel_id),
+            Q.experimentalSortBy('latest', Q.desc),
+        ).fetch()) as PostsInChannelModel[];
 
         if (chunks.length) {
             recentChunk = chunks[0];