mattermost-mobile/app/queries/servers/post.ts

// Copyright (c) 2015-present Mattermost, Inc. All Rights Reserved.
// See LICENSE.txt for license information.

import {Database, Q} from '@nozbe/watermelondb';

import {MM_TABLES} from '@constants/database';

import type PostModel from '@typings/database/models/servers/post';
import type PostInChannelModel from '@typings/database/models/servers/posts_in_channel';

const {SERVER: {POST, POSTS_IN_CHANNEL}} = MM_TABLES;

export const queryPostsInChannel = (database: Database, channelId: string): Promise<PostInChannelModel[]> => {
    try {
        return database.get(POSTS_IN_CHANNEL).query(
            Q.where('channel_id', channelId),
            Q.experimentalSortBy('latest', Q.desc),
        ).fetch() as Promise<PostInChannelModel[]>;
    } catch {
        return Promise.resolve([] as PostInChannelModel[]);
    }
};

export const queryPostsChunk = (database: Database, channelId: string, earliest: number, latest: number): Promise<PostModel[]> => {
    try {
        return database.get(POST).query(
            Q.and(
                Q.where('channel_id', channelId),
                Q.where('create_at', Q.between(earliest, latest)),
                Q.where('delete_at', Q.eq(0)),
            ),
            Q.experimentalSortBy('create_at', Q.desc),
        ).fetch() as Promise<PostModel[]>;
    } catch {
        return Promise.resolve([] as PostModel[]);
    }
};

export const queryRecentPostsInChannel = async (database: Database, channelId: string): Promise<PostModel[]> => {
    try {
        const chunks = await queryPostsInChannel(database, channelId);
        if (chunks.length) {
            const recent = chunks[0];
            return queryPostsChunk(database, channelId, recent.earliest, recent.latest);
        }
        return Promise.resolve([] as PostModel[]);
    } catch {
        return Promise.resolve([] as PostModel[]);
    }
};