RocketChat/Rocket.Chat

import type { IUserSessionConnection } from '@rocket.chat/core-typings';
import { UserStatus } from '@rocket.chat/core-typings';

/**
 * Defines new connection status compared to a previous connection status
 */
export const processConnectionStatus = (current: UserStatus, status: UserStatus): UserStatus => {
    if (current === UserStatus.ONLINE) {
        return UserStatus.ONLINE;
    }
    if (status !== UserStatus.OFFLINE) {
        return status;
    }
    return current;
};

/**
 * Defines user's status based on presence and connection status
 */
export const processStatus = (statusConnection: UserStatus, statusDefault: UserStatus): UserStatus => {
    if (statusConnection === UserStatus.OFFLINE) {
        return statusConnection;
    }

    if (statusDefault === UserStatus.ONLINE) {
        return statusConnection;
    }

    return statusDefault;
};

/**
 * Defines user's status and connection status based on user's connections and default status
 */
export const processPresenceAndStatus = (
    userSessions: IUserSessionConnection[] = [],
    statusDefault = UserStatus.ONLINE,
): { status: UserStatus; statusConnection: UserStatus } => {
    const statusConnection = userSessions.map((s) => s.status).reduce(processConnectionStatus, UserStatus.OFFLINE);

    const status = processStatus(statusConnection, statusDefault);

    return {
        status,
        statusConnection,
    };
};