RocketChat/Rocket.Chat

import { CloudWorkspaceRegistrationError } from '../../../../../lib/errors/CloudWorkspaceRegistrationError';
import { SystemLogger } from '../../../../../server/lib/logger/system';
import { CloudWorkspaceAccessTokenEmptyError, CloudWorkspaceAccessTokenError, isAbortError } from '../getWorkspaceAccessToken';
import { getCachedSupportedVersionsToken } from '../supportedVersionsToken/supportedVersionsToken';
import { announcementSync } from './announcementSync';
import { legacySyncWorkspace } from './legacySyncWorkspace';
import { syncCloudData } from './syncCloudData';

/**
 * Syncs the workspace with the cloud
 * @returns {Promise<void>}
 * @throws {Error} - If there is an unexpected error during sync like a network error
 */
export async function syncWorkspace() {
    try {
        await announcementSync();
        await syncCloudData();
    } catch (err) {
        switch (true) {
            case err instanceof CloudWorkspaceRegistrationError:
            case err instanceof CloudWorkspaceAccessTokenError: {
                // There is no access token, so we can't sync
                SystemLogger.info('Workspace does not have a valid access token, sync aborted');
                break;
            }
            default: {
                if (!(err instanceof CloudWorkspaceAccessTokenEmptyError) && !isAbortError(err)) {
                    SystemLogger.error({ msg: 'Error during workspace sync', err });
                }
                SystemLogger.info({
                    msg: 'Falling back to legacy sync',
                    function: 'syncCloudData',
                });
                try {
                    await legacySyncWorkspace();
                } catch (err) {
                    switch (true) {
                        case err instanceof CloudWorkspaceRegistrationError:
                        case err instanceof CloudWorkspaceAccessTokenError: {
                            // There is no access token, so we can't sync
                            break;
                        }
                        default: {
                            if (!(err instanceof CloudWorkspaceAccessTokenEmptyError) && !isAbortError(err)) {
                                SystemLogger.error({ msg: 'Error during fallback workspace sync', err });
                            }
                            throw err;
                        }
                    }
                }
            }
        }
    } finally {
        await getCachedSupportedVersionsToken.reset();
    }
}