define([ 'jquery', '/bower_components/nthen/index.js', '/customize/messages.js', '/common/sframe-chainpad-netflux-inner.js', '/common/sframe-channel.js', '/common/sframe-common-title.js', '/common/common-ui-elements.js', '/common/sframe-common-history.js', '/common/sframe-common-file.js', '/common/sframe-common-codemirror.js', '/common/metadata-manager.js', '/customize/application_config.js', '/common/common-realtime.js', '/common/common-util.js', '/common/common-hash.js', '/common/common-thumbnail.js', '/common/common-interface.js', '/common/common-feedback.js', '/bower_components/localforage/dist/localforage.min.js' ], function ( $, nThen, Messages, CpNfInner, SFrameChannel, Title, UIElements, History, File, CodeMirror, MetadataMgr, AppConfig, CommonRealtime, Util, Hash, Thumb, UI, Feedback, localForage ) { // Chainpad Netflux Inner var funcs = {}; var ctx = {}; funcs.Messages = Messages; var evRealtimeSynced = Util.mkEvent(true); funcs.startRealtime = function (options) { if (ctx.cpNfInner) { return ctx.cpNfInner; } options.sframeChan = ctx.sframeChan; options.metadataMgr = ctx.metadataMgr; ctx.cpNfInner = CpNfInner.start(options); ctx.cpNfInner.metadataMgr.onChangeLazy(options.onLocal); ctx.cpNfInner.whenRealtimeSyncs(function () { evRealtimeSynced.fire(); }); return ctx.cpNfInner; }; funcs.getMetadataMgr = function () { return ctx.metadataMgr; }; funcs.getSframeChannel = function () { return ctx.sframeChan; }; funcs.getAppConfig = function () { return AppConfig; }; funcs.isLoggedIn = function () { return ctx.metadataMgr.getPrivateData().accountName; }; // MISC // Call the selected function with 'funcs' as a (new) first parameter var callWithCommon = function (f) { return function () { [].unshift.call(arguments, funcs); return f.apply(null, arguments); }; }; // UI funcs.createUserAdminMenu = callWithCommon(UIElements.createUserAdminMenu); funcs.initFilePicker = callWithCommon(UIElements.initFilePicker); funcs.openFilePicker = callWithCommon(UIElements.openFilePicker); funcs.openTemplatePicker = callWithCommon(UIElements.openTemplatePicker); funcs.displayMediatagImage = callWithCommon(UIElements.displayMediatagImage); funcs.displayAvatar = callWithCommon(UIElements.displayAvatar); funcs.createButton = callWithCommon(UIElements.createButton); funcs.createUsageBar = callWithCommon(UIElements.createUsageBar); funcs.updateTags = callWithCommon(UIElements.updateTags); funcs.createLanguageSelector = callWithCommon(UIElements.createLanguageSelector); funcs.createMarkdownToolbar = callWithCommon(UIElements.createMarkdownToolbar); // Thumb funcs.displayThumbnail = callWithCommon(Thumb.displayThumbnail); // History funcs.getHistory = callWithCommon(History.create); // Title module funcs.createTitle = callWithCommon(Title.create); // Files funcs.uploadFile = callWithCommon(File.uploadFile); funcs.createFileManager = callWithCommon(File.create); funcs.getMediatagScript = function () { var origin = ctx.metadataMgr.getPrivateData().origin; return ''; }; funcs.getMediatagFromHref = function (href) { var parsed = Hash.parsePadUrl(href); var secret = Hash.getSecrets('file', parsed.hash); var data = ctx.metadataMgr.getPrivateData(); if (secret.keys && secret.channel) { var cryptKey = secret.keys && secret.keys.fileKeyStr; var hexFileName = Util.base64ToHex(secret.channel); var origin = data.fileHost || data.origin; var src = origin + Hash.getBlobPathFromHex(hexFileName); return '' + ''; } return; }; funcs.getFileSize = function (href, cb) { var channelId = Hash.hrefToHexChannelId(href); funcs.sendAnonRpcMsg("GET_FILE_SIZE", channelId, function (data) { if (!data) { return void cb("No response"); } if (data.error) { return void cb(data.error); } if (data.response && data.response.length && typeof(data.response[0]) === 'number') { return void cb(void 0, data.response[0]); } else { cb('INVALID_RESPONSE'); } }); }; // CodeMirror funcs.initCodeMirrorApp = callWithCommon(CodeMirror.create); // Window funcs.logout = function (cb) { cb = cb || $.noop; ctx.sframeChan.query('Q_LOGOUT', null, cb); }; funcs.notify = function () { ctx.sframeChan.event('EV_NOTIFY'); }; funcs.setTabTitle = function (newTitle) { ctx.sframeChan.event('EV_SET_TAB_TITLE', newTitle); }; funcs.setLoginRedirect = function (cb) { cb = cb || $.noop; ctx.sframeChan.query('Q_SET_LOGIN_REDIRECT', null, cb); }; funcs.isPresentUrl = function (cb) { ctx.sframeChan.query('Q_PRESENT_URL_GET_VALUE', null, cb); }; funcs.setPresentUrl = function (value) { ctx.sframeChan.event('EV_PRESENT_URL_SET_VALUE', value); }; // Store funcs.sendAnonRpcMsg = function (msg, content, cb) { ctx.sframeChan.query('Q_ANON_RPC_MESSAGE', { msg: msg, content: content }, function (err, data) { if (cb) { cb(data); } }); }; funcs.getPinUsage = function (cb) { cb = cb || $.noop; ctx.sframeChan.query('Q_PIN_GET_USAGE', null, function (err, data) { cb(err || data.error, data.data); }); }; funcs.isOverPinLimit = function (cb) { ctx.sframeChan.query('Q_GET_PIN_LIMIT_STATUS', null, function (err, data) { cb(data.error, data.overLimit, data.limits); }); }; funcs.getFullHistory = function (realtime, cb) { ctx.sframeChan.query('Q_GET_FULL_HISTORY', null, function (err, messages) { if (err) { return void console.error(err); } if (!Array.isArray(messages)) { return; } messages.forEach(function (m) { realtime.message(m); }); cb(); }); }; funcs.getPadAttribute = function (key, cb) { ctx.sframeChan.query('Q_GET_PAD_ATTRIBUTE', { key: key }, function (err, res) { cb (err || res.error, res.data); }); }; funcs.setPadAttribute = function (key, value, cb) { cb = cb || $.noop; ctx.sframeChan.query('Q_SET_PAD_ATTRIBUTE', { key: key, value: value }, cb); }; funcs.getAttribute = function (key, cb) { ctx.sframeChan.query('Q_GET_ATTRIBUTE', { key: key }, function (err, res) { cb (err || res.error, res.data); }); }; funcs.setAttribute = function (key, value, cb) { cb = cb || $.noop; ctx.sframeChan.query('Q_SET_ATTRIBUTE', { key: key, value: value }, cb); }; // Thumbnails funcs.setThumbnail = function (key, value, cb) { cb = cb || $.noop; ctx.sframeChan.query('Q_THUMBNAIL_SET', { key: key, value: value }, cb); }; funcs.getThumbnail = function (key, cb) { ctx.sframeChan.query('Q_THUMBNAIL_GET', { key: key }, function (err, res) { cb (err || res.error, res.data); }); }; funcs.sessionStorage = { put: function (key, value, cb) { ctx.sframeChan.query('Q_SESSIONSTORAGE_PUT', { key: key, value: value }, cb); } }; funcs.isStrongestStored = function () { var data = ctx.metadataMgr.getPrivateData(); if (data.availableHashes.fileHash) { return true; } return !data.readOnly || !data.availableHashes.editHash; }; funcs.setDisplayName = function (name, cb) { cb = cb || $.noop; ctx.sframeChan.query('Q_SETTINGS_SET_DISPLAY_NAME', name, cb); }; funcs.mergeAnonDrive = function (cb) { ctx.sframeChan.query('Q_MERGE_ANON_DRIVE', null, cb); }; // Friends var pendingFriends = []; funcs.getPendingFriends = function () { return pendingFriends.slice(); }; funcs.sendFriendRequest = function (netfluxId) { ctx.sframeChan.query('Q_SEND_FRIEND_REQUEST', netfluxId, $.noop); pendingFriends.push(netfluxId); }; // Feedback funcs.prepareFeedback = function (key) { if (typeof(key) !== 'string') { return $.noop; } var type = ctx.metadataMgr.getMetadata().type; return function () { Feedback.send((key + (type? '_' + type: '')).toUpperCase()); }; }; // RESTRICTED // Filepicker app funcs.getFilesList = function (types, cb) { ctx.sframeChan.query('Q_GET_FILES_LIST', types, function (err, data) { cb(err || data.error, data.data); }); }; /* funcs.storeLinkToClipboard = function (readOnly, cb) { ctx.sframeChan.query('Q_STORE_LINK_TO_CLIPBOARD', readOnly, function (err) { if (cb) { cb(err); } }); }; */ funcs.gotoURL = function (url) { ctx.sframeChan.event('EV_GOTO_URL', url); }; funcs.openURL = function (url) { ctx.sframeChan.event('EV_OPEN_URL', url); }; funcs.openUnsafeURL = function (url) { var bounceHref = window.location.origin + '/bounce/#' + encodeURIComponent(url); window.open(bounceHref); }; funcs.whenRealtimeSyncs = evRealtimeSynced.reg; var logoutHandlers = []; funcs.onLogout = function (h) { if (typeof (h) !== "function") { return; } if (logoutHandlers.indexOf(h) !== -1) { return; } logoutHandlers.push(h); }; Object.freeze(funcs); return { create: function (cb) { // TODO(cjd): This is crap but this gets loaded multiple places by /code/ and it is // not ok with being loaded more than once. if (window.CryptPad_sframe_common) { setTimeout(function () { cb(window.CryptPad_sframe_common); }); return; } window.CryptPad_sframe_common = funcs; nThen(function (waitFor) { SFrameChannel.create(window.parent, waitFor(function (sfc) { ctx.sframeChan = sfc; }), true); // CpNfInner.start() should be here.... }).nThen(function () { localForage.clear(); ctx.metadataMgr = MetadataMgr.create(ctx.sframeChan); ctx.sframeChan.whenReg('EV_CACHE_PUT', function () { if (Object.keys(window.cryptpadCache.updated).length) { ctx.sframeChan.event('EV_CACHE_PUT', window.cryptpadCache.updated); } window.cryptpadCache._put = window.cryptpadCache.put; window.cryptpadCache.put = function (k, v, cb) { window.cryptpadCache._put(k, v, cb); var x = {}; x[k] = v; ctx.sframeChan.event('EV_CACHE_PUT', x); }; }); ctx.sframeChan.whenReg('EV_LOCALSTORE_PUT', function () { if (Object.keys(window.cryptpadStore.updated).length) { ctx.sframeChan.event('EV_LOCALSTORE_PUT', window.cryptpadStore.updated); } window.cryptpadStore._put = window.cryptpadStore.put; window.cryptpadStore.put = function (k, v, cb) { window.cryptpadStore._put(k, v, cb); var x = {}; x[k] = v; ctx.sframeChan.event('EV_LOCALSTORE_PUT', x); }; }); UI.addTooltips(); ctx.sframeChan.on('EV_LOGOUT', function () { $(window).on('keyup', function (e) { if (e.keyCode === 27) { UI.removeLoadingScreen(); } }); UI.addLoadingScreen({hideTips: true}); UI.errorLoadingScreen(Messages.onLogout, true); logoutHandlers.forEach(function (h) { if (typeof (h) === "function") { h(); } }); }); ctx.sframeChan.on('EV_RT_CONNECT', function () { CommonRealtime.setConnectionState(true); }); ctx.sframeChan.on('EV_RT_DISCONNECT', function () { CommonRealtime.setConnectionState(false); }); ctx.sframeChan.on('Q_INCOMING_FRIEND_REQUEST', function (confirmMsg, cb) { UI.confirm(confirmMsg, cb, null, true); }); ctx.sframeChan.on('EV_FRIEND_REQUEST', function (data) { var i = pendingFriends.indexOf(data.netfluxId); if (i !== -1) { pendingFriends.splice(i, 1); } UI.log(data.logText); }); ctx.metadataMgr.onChange(function () { try { var feedback = ctx.metadataMgr.getPrivateData().feedbackAllowed; Feedback.init(feedback); } catch (e) { Feedback.init(false); } }); ctx.sframeChan.ready(); cb(funcs); }); } }; });