/* eslint-disable no-use-before-define */
import { getActiveClient } from '~/client/api';
import {
  filterByPropIntersection,
  filterBySearchTerm,
  sortByFirstCreated,
  sortByLastCreated,
} from '~/core/query';
import { ENABLE_CACHE_MESSAGE } from '~/utils/constants';
import { dropFromCache } from '~/cache/api';
import { ChannelMemberLiveCollectionController } from './ChannelMemberLiveCollectionController';

/*
 * Exported for testing
 * @hidden
 */
export const applyFilter = <T extends Amity.Membership<'channel'>>(
  data: T[],
  params: Amity.ChannelMembersLiveCollection,
): T[] => {
  let channelMembers = filterByPropIntersection(data, 'roles', params.roles);

  if (params.memberships) {
    /*
     * even though membership includes muted as a possible value
     * when querying the server.
     * Muted is specified under seperarte property namely isMuted
     * Hence why I've seperately checked for it's equality
     */
    channelMembers = channelMembers.filter(member => {
      // @ts-ignore
      if (params.memberships.includes('muted') && member.isMuted) {
        return true;
      }

      // @ts-ignore
      return params.memberships.includes(member.membership);
    });
  }

  // sort, 'lastCreated' is the default sort order
  const sortBy = params.sortBy ? params.sortBy : 'lastCreated';
  channelMembers = channelMembers.sort(
    sortBy === 'lastCreated' ? sortByLastCreated : sortByFirstCreated,
  );

  return channelMembers;
};

/* begin_public_function
  id: channel.member.query
*/
/**
 * ```js
 * import { getMembers } from '@amityco/ts-sdk-react-native'
 *
 * let channelMembers = []
 * const unsub = getMembers({
 *   channelId: Amity.Channel['channelId'],
 * }, response => merge(channelMembers, response.data))
 * ```
 *
 * Observe all mutations on a list of {@link Amity.ChannelUser}s
 *
 * @param params for querying channel users
 * @param callback the function to call when new data are available
 * @returns An {@link Amity.Unsubscriber} function to run when willing to stop observing the channel users
 *
 * @category Channel Live Collection
 */
export const getMembers = (
  params: Amity.ChannelMembersLiveCollection,
  callback: Amity.LiveCollectionCallback<Amity.Membership<'channel'>>,
  config?: Amity.LiveCollectionConfig,
) => {
  const { log, cache } = getActiveClient();

  if (!cache) {
    // eslint-disable-next-line no-console
    console.log(ENABLE_CACHE_MESSAGE);
  }

  const timestamp = Date.now();
  log(`getMembers(tmpid: ${timestamp}) > listen`);

  const channelMemberLiveCollection = new ChannelMemberLiveCollectionController(params, callback);
  const disposers = channelMemberLiveCollection.startSubscription();

  const cacheKey = channelMemberLiveCollection.getCacheKey();

  disposers.push(() => {
    dropFromCache(cacheKey);
  });

  return () => {
    log(`getMembers(tmpid: ${timestamp}) > dispose`);
    disposers.forEach(fn => fn());
  };
};
/* end_public_function */