Channel Unread Count

import { ChannelRepository } from '@amityco/ts-sdk';

const unsubscribe = ChannelRepository.getChannel(
  channelId,
  ({ data: channelSnapshot, loading, error }) => {
    if (error) {
      handleError(error);
      return;
    }

    if (!loading && channelSnapshot?.isUnreadCountSupport) {
      renderResults({
        unreadCount: channelSnapshot.unreadCount,
        isMentioned: channelSnapshot.isMentioned,
        subChannelsUnreadCount: channelSnapshot.subChannelsUnreadCount,
      });
    }
  },
);

unsubscribe();

token = channelRepository.getChannel(channelId).observe { liveObject, error in
    if let error {
        handleError(error)
        return
    }

    guard let channel = liveObject.snapshot else { return }

    if channel.isUnreadCountSupported {
        showSuccessMessage([
            "unreadCount": channel.unreadCount,
            "isMentioned": channel.isMentioned,
            "subChannelsUnreadCount": channel.subChannelsUnreadCount
        ])
    }
}

val currentChannel = channel ?: return

if (currentChannel.isUnreadCountSupport()) {
    showSuccessMessage(
        mapOf(
            "unreadCount" to currentChannel.getUnreadCount(),
            "isMentioned" to currentChannel.isMentioned(),
            "subChannelsUnreadCount" to currentChannel.getSubChannelsUnreadCount(),
        ),
    )
}

final fetchedChannel = await AmityChatClient.newChannelRepository()
    .getChannel(channelId);

final unreadCount = fetchedChannel.unreadCount ?? 0;
final isMentioned = fetchedChannel.isMentioned;

import { ChannelRepository } from '@amityco/ts-sdk';

const unsubscribe = ChannelRepository.getTotalChannelsUnread(
  ({ data: unread, loading, error }) => {
    if (error) {
      handleError(error);
      return;
    }

    if (!loading && unread) {
      renderResults({
        unreadCount: unread.unreadCount,
        isMentioned: unread.isMentioned,
      });
    }
  },
);

unsubscribe();

var cancellables = Set<AnyCancellable>()

channelRepository.getTotalChannelsUnread()
    .sink { unread in
        showSuccessMessage([
            "unreadCount": unread.unreadCount,
            "isMentioned": unread.isMentioned
        ])
    }
    .store(in: &cancellables)

val disposable = channelRepository
    .getTotalChannelUnread()
    .subscribe(
        { unread ->
            showSuccessMessage(
                mapOf(
                    "unreadCount" to unread.unreadCount,
                    "isMentioned" to unread.isMentioned,
                ),
            )
        },
        { error -> handleGeneralError(error) },
    )

AmityChatClient.newChannelRepository()
    .getChannelTotalUnreads()
    .listen((unread) {
  final totalUnreadCount = unread.unreadCount;
  final hasMention = unread.isMentioned;
});