mattermost-mobile-upstream/app/screens/channel/index.tsx

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

import {withDatabase, withObservables} from '@nozbe/watermelondb/react';
import {combineLatest, combineLatestWith, distinctUntilChanged, of as of$, switchMap} from 'rxjs';

import {observeCallStateInChannel, observeIsCallsEnabledInChannel} from '@calls/observers';
import {observeCallsConfig} from '@calls/state';
import {Preferences} from '@constants';
import {withServerUrl} from '@context/server';
import {observeCurrentChannel} from '@queries/servers/channel';
import {queryBookmarks} from '@queries/servers/channel_bookmark';
import {observeChannelBookmarksEnabled, observeHasGMasDMFeature} from '@queries/servers/features';
import {queryPreferencesByCategoryAndName} from '@queries/servers/preference';
import {observeScheduledPostCountForChannel} from '@queries/servers/scheduled_post';
import {
    observeCurrentChannelId,
    observeCurrentUserId,
} from '@queries/servers/system';
import {observeIsCRTEnabled} from '@queries/servers/thread';
import {observeChannelBannerIncluded} from '@screens/channel/channel_feature_checks';

import Channel from './channel';

import type {WithDatabaseArgs} from '@typings/database/database';

type EnhanceProps = WithDatabaseArgs & {
    serverUrl: string;
}

const enhanced = withObservables([], ({database, serverUrl}: EnhanceProps) => {
    const channelId = observeCurrentChannelId(database);
    const dismissedGMasDMNotice = queryPreferencesByCategoryAndName(database, Preferences.CATEGORIES.SYSTEM_NOTICE, Preferences.NOTICES.GM_AS_DM).observe();
    const channelType = observeCurrentChannel(database).pipe(switchMap((c) => of$(c?.type)));
    const currentUserId = observeCurrentUserId(database);
    const hasGMasDMFeature = observeHasGMasDMFeature(database);
    const isBookmarksEnabled = observeChannelBookmarksEnabled(database);
    const hasBookmarks = (count: number) => of$(count > 0);
    const includeBookmarkBar = channelId.pipe(
        combineLatestWith(isBookmarksEnabled),
        switchMap(([cId, enabled]) => {
            if (!enabled) {
                return of$(false);
            }

            return queryBookmarks(database, cId).observeCount(false).pipe(
                switchMap(hasBookmarks),
                distinctUntilChanged(),
            );
        }),
    );

    const groupCallsAllowed = observeCallsConfig(serverUrl).pipe(
        switchMap((config) => of$(config.GroupCallsAllowed)),
        distinctUntilChanged(),
    );

    const includeChannelBanner = observeChannelBannerIncluded(database, channelType, channelId);

    const isCRTEnabled = observeIsCRTEnabled(database);

    const scheduledPostCount = combineLatest([channelId, isCRTEnabled]).pipe(
        switchMap(([cid, isCRT]) => observeScheduledPostCountForChannel(database, cid, isCRT)),
    );

    return {
        channelId,
        ...observeCallStateInChannel(serverUrl, database, channelId),
        isCallsEnabledInChannel: observeIsCallsEnabledInChannel(database, serverUrl, channelId),
        groupCallsAllowed,
        dismissedGMasDMNotice,
        channelType,
        currentUserId,
        hasGMasDMFeature,
        includeBookmarkBar,
        includeChannelBanner,
        scheduledPostCount,
    };
});

export default withDatabase(withServerUrl(enhanced(Channel)));