upstream-rocketchat/apps/meteor/server/lib/cloud/syncWorkspace/index.ts

import { License } from '@rocket.chat/license';

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

/**
 * 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() {
	if (License.hasOfflineLicense()) {
		SystemLogger.debug({ msg: 'Skipping cloud sync: workspace has an offline license', function: 'syncWorkspace' });
		await getCachedSupportedVersionsToken.reset();
		return;
	}

	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();
	}
}