106 lines
4.2 KiB
JavaScript
106 lines
4.2 KiB
JavaScript
define([
|
|
'/common/outer/async-store.js'
|
|
], function (AStore) {
|
|
|
|
var create = function () {
|
|
var Store = AStore.create();
|
|
|
|
var Rpc = {};
|
|
|
|
var queries = Rpc.queries = {
|
|
// Ready
|
|
CONNECT: Store.init,
|
|
DISCONNECT: Store.disconnect,
|
|
CREATE_README: Store.createReadme,
|
|
MIGRATE_ANON_DRIVE: Store.migrateAnonDrive,
|
|
// RPC
|
|
INIT_RPC: Store.initRpc,
|
|
UPDATE_PIN_LIMIT: Store.updatePinLimit,
|
|
GET_PIN_LIMIT: Store.getPinLimit,
|
|
CLEAR_OWNED_CHANNEL: Store.clearOwnedChannel,
|
|
REMOVE_OWNED_CHANNEL: Store.removeOwnedChannel,
|
|
UPLOAD_CHUNK: Store.uploadChunk,
|
|
UPLOAD_COMPLETE: Store.uploadComplete,
|
|
UPLOAD_STATUS: Store.uploadStatus,
|
|
UPLOAD_CANCEL: Store.uploadCancel,
|
|
WRITE_LOGIN_BLOCK: Store.writeLoginBlock,
|
|
REMOVE_LOGIN_BLOCK: Store.removeLoginBlock,
|
|
PIN_PADS: Store.pinPads,
|
|
UNPIN_PADS: Store.unpinPads,
|
|
GET_DELETED_PADS: Store.getDeletedPads,
|
|
GET_PINNED_USAGE: Store.getPinnedUsage,
|
|
// ANON RPC
|
|
INIT_ANON_RPC: Store.initAnonRpc,
|
|
ANON_RPC_MESSAGE: Store.anonRpcMsg,
|
|
GET_FILE_SIZE: Store.getFileSize,
|
|
GET_MULTIPLE_FILE_SIZE: Store.getMultipleFileSize,
|
|
// Store
|
|
GET: Store.get,
|
|
SET: Store.set,
|
|
ADD_PAD: Store.addPad,
|
|
SET_PAD_TITLE: Store.setPadTitle,
|
|
MOVE_TO_TRASH: Store.moveToTrash,
|
|
RESET_DRIVE: Store.resetDrive,
|
|
GET_METADATA: Store.getMetadata,
|
|
IS_ONLY_IN_SHARED_FOLDER: Store.isOnlyInSharedFolder,
|
|
SET_DISPLAY_NAME: Store.setDisplayName,
|
|
SET_PAD_ATTRIBUTE: Store.setPadAttribute,
|
|
GET_PAD_ATTRIBUTE: Store.getPadAttribute,
|
|
SET_ATTRIBUTE: Store.setAttribute,
|
|
GET_ATTRIBUTE: Store.getAttribute,
|
|
LIST_ALL_TAGS: Store.listAllTags,
|
|
GET_TEMPLATES: Store.getTemplates,
|
|
GET_SECURE_FILES_LIST: Store.getSecureFilesList,
|
|
GET_PAD_DATA: Store.getPadData,
|
|
GET_STRONGER_HASH: Store.getStrongerHash,
|
|
INCREMENT_TEMPLATE_USE: Store.incrementTemplateUse,
|
|
GET_SHARED_FOLDER: Store.getSharedFolder,
|
|
ADD_SHARED_FOLDER: Store.addSharedFolder,
|
|
LOAD_SHARED_FOLDER: Store.loadSharedFolderAnon,
|
|
// Messaging
|
|
INVITE_FROM_USERLIST: Store.inviteFromUserlist,
|
|
ADD_DIRECT_MESSAGE_HANDLERS: Store.addDirectMessageHandlers,
|
|
// Messenger
|
|
CONTACTS_GET_FRIEND_LIST: Store.messenger.getFriendList,
|
|
CONTACTS_GET_MY_INFO: Store.messenger.getMyInfo,
|
|
CONTACTS_GET_FRIEND_INFO: Store.messenger.getFriendInfo,
|
|
CONTACTS_REMOVE_FRIEND: Store.messenger.removeFriend,
|
|
CONTACTS_OPEN_FRIEND_CHANNEL: Store.messenger.openFriendChannel,
|
|
CONTACTS_GET_FRIEND_STATUS: Store.messenger.getFriendStatus,
|
|
CONTACTS_GET_MORE_HISTORY: Store.messenger.getMoreHistory,
|
|
CONTACTS_SEND_MESSAGE: Store.messenger.sendMessage,
|
|
CONTACTS_SET_CHANNEL_HEAD: Store.messenger.setChannelHead,
|
|
// Chat
|
|
CHAT_COMMAND: Store.messenger.execCommand,
|
|
// Pad
|
|
SEND_PAD_MSG: Store.sendPadMsg,
|
|
JOIN_PAD: Store.joinPad,
|
|
LEAVE_PAD: Store.leavePad,
|
|
GET_FULL_HISTORY: Store.getFullHistory,
|
|
GET_HISTORY_RANGE: Store.getHistoryRange,
|
|
IS_NEW_CHANNEL: Store.isNewChannel,
|
|
// Drive
|
|
DRIVE_USEROBJECT: Store.userObjectCommand,
|
|
// Settings,
|
|
DELETE_ACCOUNT: Store.deleteAccount,
|
|
};
|
|
|
|
Rpc.query = function (cmd, data, cb) {
|
|
if (queries[cmd]) {
|
|
queries[cmd]('0', data, cb);
|
|
} else {
|
|
console.error('UNHANDLED_STORE_RPC');
|
|
}
|
|
};
|
|
|
|
// Internal calls
|
|
Rpc._removeClient = Store._removeClient;
|
|
Rpc._subscribeToDrive = Store._subscribeToDrive;
|
|
Rpc._subscribeToMessenger = Store._subscribeToMessenger;
|
|
|
|
return Rpc;
|
|
};
|
|
|
|
return create;
|
|
});
|
|
|