snappymail/dev/Remote/User/Fetch.js

import { pString, pInt, b64EncodeJSONSafe } from 'Common/Utils';

import {
	getFolderFromCacheList
} from 'Common/Cache';

import { SettingsGet } from 'Common/Globals';
import { SUB_QUERY_PREFIX } from 'Common/Links';

import { AppUserStore } from 'Stores/User/App';
import { SettingsUserStore } from 'Stores/User/Settings';
import { FolderUserStore } from 'Stores/User/Folder';

import { AbstractFetchRemote } from 'Remote/AbstractFetch';

class RemoteUserFetch extends AbstractFetchRemote {

	/**
	 * @param {Function} fCallback
	 * @param {object} params
	 * @param {boolean=} bSilent = false
	 */
	messageList(fCallback, params, bSilent = false) {
		const
	//		folder = getFolderFromCacheList(params.folder.fullName),
			folder = getFolderFromCacheList(params.folder),
			folderETag = folder?.etag || '';

		params = Object.assign({
			offset: 0,
			limit: SettingsUserStore.messagesPerPage(),
			search: '',
			uidNext: folder?.uidNext || 0, // Used to check for new messages
			sort: FolderUserStore.sortMode()
		}, params);
		if (AppUserStore.threadsAllowed() && SettingsUserStore.useThreads()) {
			params.useThreads = 1;
		} else {
			params.threadUid = 0;
		}

		let sGetAdd = '';
		if (folderETag) {
			params.hash = folderETag + '-' + SettingsGet('accountHash');
			sGetAdd = 'MessageList/' + SUB_QUERY_PREFIX + '/' + b64EncodeJSONSafe(params);
			params = {};
		}

		bSilent || this.abort('MessageList');
		this.request('MessageList',
			fCallback,
			params,
			60000, // 60 seconds before aborting
			sGetAdd
		);
	}

	/**
	 * @param {?Function} fCallback
	 * @param {string} sFolderFullName
	 * @param {number} iUid
	 * @returns {boolean}
	 */
	message(fCallback, sFolderFullName, iUid) {
		sFolderFullName = pString(sFolderFullName);
		iUid = pInt(iUid);

		if (getFolderFromCacheList(sFolderFullName) && 0 < iUid) {
			this.abort('Message').request('Message',
				fCallback,
				{},
				null,
				'Message/' +
					SUB_QUERY_PREFIX +
					'/' +
					b64EncodeJSONSafe([
						sFolderFullName,
						iUid,
						AppUserStore.threadsAllowed() && SettingsUserStore.useThreads() ? 1 : 0,
						SettingsGet('accountHash')
					])
			);

			return true;
		}

		return false;
	}

	/**
	 * @param {?Function} fCallback
	 * @param {Object} oData
	 */
	saveSettings(fCallback, oData) {
		this.request('SettingsUpdate', fCallback, oData);
	}

	/**
	 * @param {string} key
	 * @param {?scalar} value
	 * @param {?Function} fCallback
	 */
	saveSetting(key, value, fCallback) {
		this.saveSettings(fCallback, {
			[key]: value
		});
	}

/*
	folderMove(sPrevFolderFullName, sNewFolderFullName, bSubscribe) {
		return this.post('FolderMove', FolderUserStore.foldersRenaming, {
			folder: sPrevFolderFullName,
			newFolder: sNewFolderFullName,
			subscribe: bSubscribe ? 1 : 0
		});
	}
*/
}

export default new RemoteUserFetch();