/* global dijit, __ */ let init_params = {}; let _label_base_index = -1024; let loading_progress = 0; let notify_hide_timerid = false; Ajax.Base.prototype.initialize = Ajax.Base.prototype.initialize.wrap( function (callOriginal, options) { if (getInitParam("csrf_token") != undefined) { Object.extend(options, options || { }); if (Object.isString(options.parameters)) options.parameters = options.parameters.toQueryParams(); else if (Object.isHash(options.parameters)) options.parameters = options.parameters.toObject(); options.parameters["csrf_token"] = getInitParam("csrf_token"); } return callOriginal(options); } ); /* xhr shorthand helpers */ function xhrPost(url, params, complete) { console.log("xhrPost:", params); return new Ajax.Request(url, { parameters: params, onComplete: complete }); } function xhrJson(url, params, complete) { return xhrPost(url, params, (reply) => { try { const obj = JSON.parse(reply.responseText); complete(obj); } catch (e) { console.error("xhrJson", e, reply); complete(null); } }) } /* add method to remove element from array */ Array.prototype.remove = function(s) { for (let i=0; i < this.length; i++) { if (s == this[i]) this.splice(i, 1); } }; const Lists = { onRowChecked: function(elem) { // account for dojo checkboxes elem = elem.domNode || elem; elem.up("li").toggleClassName("Selected"); } }; // noinspection JSUnusedGlobalSymbols const Tables = { onRowChecked: function(elem) { // account for dojo checkboxes elem = elem.domNode || elem; elem.up("tr").toggleClassName("Selected"); }, getSelected: function(elemId) { const rv = []; $(elemId).select("tr").each((row) => { if (row.hasClassName("Selected")) { // either older prefix-XXX notation or separate attribute const rowId = row.getAttribute("data-row-id") || row.id.replace(/^[A-Z]*?-/, ""); if (!isNaN(rowId)) rv.push(parseInt(rowId)); } }); return rv; } }; const Utils = { _rpc_seq: 0, hotkey_prefix: 0, hotkey_prefix_pressed: false, hotkey_prefix_timeout: 0, urlParam: function(param) { return String(window.location.href).parseQuery()[param]; }, next_seq: function() { this._rpc_seq += 1; return this._rpc_seq; }, get_seq: function() { return this._rpc_seq; }, setLoadingProgress: function(p) { loading_progress += p; if (dijit.byId("loading_bar")) dijit.byId("loading_bar").update({progress: loading_progress}); if (loading_progress >= 90) Element.hide("overlay"); }, keyeventToAction: function(event) { const hotkeys_map = getInitParam("hotkeys"); const keycode = event.which; const keychar = String.fromCharCode(keycode).toLowerCase(); if (keycode == 27) { // escape and drop prefix this.hotkey_prefix = false; } if (keycode == 16 || keycode == 17) return; // ignore lone shift / ctrl if (!this.hotkey_prefix && hotkeys_map[0].indexOf(keychar) != -1) { this.hotkey_prefix = keychar; $("cmdline").innerHTML = keychar; Element.show("cmdline"); window.clearTimeout(this.hotkey_prefix_timeout); this.hotkey_prefix_timeout = window.setTimeout(() => { this.hotkey_prefix = false; Element.hide("cmdline"); }, 3 * 1000); event.stopPropagation(); return false; } Element.hide("cmdline"); let hotkey_name = keychar.search(/[a-zA-Z0-9]/) != -1 ? keychar : "(" + keycode + ")"; // ensure ^*char notation if (event.shiftKey) hotkey_name = "*" + hotkey_name; if (event.ctrlKey) hotkey_name = "^" + hotkey_name; if (event.altKey) hotkey_name = "+" + hotkey_name; if (event.metaKey) hotkey_name = "%" + hotkey_name; const hotkey_full = this.hotkey_prefix ? this.hotkey_prefix + " " + hotkey_name : hotkey_name; this.hotkey_prefix = false; let action_name = false; for (const sequence in hotkeys_map[1]) { if (hotkeys_map[1].hasOwnProperty(sequence)) { if (sequence == hotkey_full) { action_name = hotkeys_map[1][sequence]; break; } } } console.log('keyeventToAction', hotkey_full, '=>', action_name); return action_name; }, cleanupMemory: function(root) { const dijits = dojo.query("[widgetid]", dijit.byId(root).domNode).map(dijit.byNode); dijits.each(function (d) { dojo.destroy(d.domNode); }); $$("#" + root + " *").each(function (i) { i.parentNode ? i.parentNode.removeChild(i) : true; }); }, helpDialog: function(topic) { const query = "backend.php?op=backend&method=help&topic=" + param_escape(topic); if (dijit.byId("helpDlg")) dijit.byId("helpDlg").destroyRecursive(); const dialog = new dijit.Dialog({ id: "helpDlg", title: __("Help"), style: "width: 600px", href: query, }); dialog.show(); }, displayDlg: function(title, id, param, callback) { notify_progress("Loading, please wait...", true); const query = {op: "dlg", method: id, param: param}; xhrPost("backend.php", query, (transport) => { try { const content = transport.responseText; let dialog = dijit.byId("infoBox"); if (!dialog) { dialog = new dijit.Dialog({ title: title, id: 'infoBox', style: "width: 600px", onCancel: function () { return true; }, onExecute: function () { return true; }, onClose: function () { return true; }, content: content }); } else { dialog.attr('title', title); dialog.attr('content', content); } dialog.show(); notify(""); if (callback) callback(transport); } catch (e) { exception_error(e); } }); return false; }, handleRpcJson: function(transport) { const netalert_dijit = dijit.byId("net-alert"); let netalert = false; if (netalert_dijit) netalert = netalert_dijit.domNode; try { const reply = JSON.parse(transport.responseText); if (reply) { const error = reply['error']; if (error) { const code = error['code']; const msg = error['msg']; console.warn("[handleRpcJson] received fatal error " + code + "/" + msg); if (code != 0) { fatalError(code, msg); return false; } } const seq = reply['seq']; if (seq && this.get_seq() != seq) { console.log("[handleRpcJson] sequence mismatch: " + seq + " (want: " + this.get_seq() + ")"); return true; } const message = reply['message']; if (message == "UPDATE_COUNTERS") { console.log("need to refresh counters..."); setInitParam("last_article_id", -1); Feeds.requestCounters(true); } const counters = reply['counters']; if (counters) Feeds.parseCounters(counters); const runtime_info = reply['runtime-info']; if (runtime_info) Utils.parseRuntimeInfo(runtime_info); if (netalert) netalert.hide(); return reply; } else { if (netalert) netalert.show(); else notify_error("Communication problem with server."); } } catch (e) { if (netalert) netalert.show(); else notify_error("Communication problem with server."); console.error(e); } return false; }, parseRuntimeInfo: function(data) { //console.log("parsing runtime info..."); for (const k in data) { if (data.hasOwnProperty(k)) { const v = data[k]; console.log("RI:", k, "=>", v); if (k == "dep_ts" && parseInt(getInitParam("dep_ts")) > 0) { if (parseInt(getInitParam("dep_ts")) < parseInt(v) && getInitParam("reload_on_ts_change")) { window.location.reload(); } } if (k == "daemon_is_running" && v != 1) { notify_error("Update daemon is not running.", true); return; } if (k == "update_result") { const updatesIcon = dijit.byId("updatesIcon").domNode; if (v) { Element.show(updatesIcon); } else { Element.hide(updatesIcon); } } if (k == "daemon_stamp_ok" && v != 1) { notify_error("Update daemon is not updating feeds.", true); return; } if (k == "max_feed_id" || k == "num_feeds") { if (init_params[k] != v) { console.log("feed count changed, need to reload feedlist."); Feeds.reload(); } } init_params[k] = v; } } PluginHost.run(PluginHost.HOOK_RUNTIME_INFO_LOADED, data); }, backendSanityCallback: function (transport) { const reply = JSON.parse(transport.responseText); if (!reply) { fatalError(3, "Sanity check: invalid RPC reply", transport.responseText); return; } const error_code = reply['error']['code']; if (error_code && error_code != 0) { return fatalError(error_code, reply['error']['message']); } console.log("sanity check ok"); const params = reply['init-params']; if (params) { console.log('reading init-params...'); for (const k in params) { if (params.hasOwnProperty(k)) { switch (k) { case "label_base_index": _label_base_index = parseInt(params[k]); break; case "hotkeys": // filter mnemonic definitions (used for help panel) from hotkeys map // i.e. *(191)|Ctrl-/ -> *(191) const tmp = []; for (const sequence in params[k][1]) { if (params[k][1].hasOwnProperty(sequence)) { const filtered = sequence.replace(/\|.*$/, ""); tmp[filtered] = params[k][1][sequence]; } } params[k][1] = tmp; break; } console.log("IP:", k, "=>", params[k]); } } init_params = params; // PluginHost might not be available on non-index pages window.PluginHost && PluginHost.run(PluginHost.HOOK_PARAMS_LOADED, init_params); } App.initSecondStage(); }, explainError: function(code) { return this.displayDlg(__("Error explained"), "explainError", code); }, }; const CommonDialogs = { quickAddFeed: function() { const query = "backend.php?op=feeds&method=quickAddFeed"; // overlapping widgets if (dijit.byId("batchSubDlg")) dijit.byId("batchSubDlg").destroyRecursive(); if (dijit.byId("feedAddDlg")) dijit.byId("feedAddDlg").destroyRecursive(); const dialog = new dijit.Dialog({ id: "feedAddDlg", title: __("Subscribe to Feed"), style: "width: 600px", show_error: function (msg) { const elem = $("fadd_error_message"); elem.innerHTML = msg; if (!Element.visible(elem)) new Effect.Appear(elem); }, execute: function () { if (this.validate()) { console.log(dojo.objectToQuery(this.attr('value'))); const feed_url = this.attr('value').feed; Element.show("feed_add_spinner"); Element.hide("fadd_error_message"); xhrPost("backend.php", this.attr('value'), (transport) => { try { try { var reply = JSON.parse(transport.responseText); } catch (e) { Element.hide("feed_add_spinner"); alert(__("Failed to parse output. This can indicate server timeout and/or network issues. Backend output was logged to browser console.")); console.log('quickAddFeed, backend returned:' + transport.responseText); return; } const rc = reply['result']; notify(''); Element.hide("feed_add_spinner"); console.log(rc); switch (parseInt(rc['code'])) { case 1: dialog.hide(); notify_info(__("Subscribed to %s").replace("%s", feed_url)); Feeds.reload(); break; case 2: dialog.show_error(__("Specified URL seems to be invalid.")); break; case 3: dialog.show_error(__("Specified URL doesn't seem to contain any feeds.")); break; case 4: const feeds = rc['feeds']; Element.show("fadd_multiple_notify"); const select = dijit.byId("feedDlg_feedContainerSelect"); while (select.getOptions().length > 0) select.removeOption(0); select.addOption({value: '', label: __("Expand to select feed")}); let count = 0; for (const feedUrl in feeds) { if (feeds.hasOwnProperty(feedUrl)) { select.addOption({value: feedUrl, label: feeds[feedUrl]}); count++; } } Effect.Appear('feedDlg_feedsContainer', {duration: 0.5}); break; case 5: dialog.show_error(__("Couldn't download the specified URL: %s").replace("%s", rc['message'])); break; case 6: dialog.show_error(__("XML validation failed: %s").replace("%s", rc['message'])); break; case 0: dialog.show_error(__("You are already subscribed to this feed.")); break; } } catch (e) { console.error(transport.responseText); exception_error(e); } }); } }, href: query }); dialog.show(); }, showFeedsWithErrors: function() { const query = {op: "pref-feeds", method: "feedsWithErrors"}; if (dijit.byId("errorFeedsDlg")) dijit.byId("errorFeedsDlg").destroyRecursive(); const dialog = new dijit.Dialog({ id: "errorFeedsDlg", title: __("Feeds with update errors"), style: "width: 600px", getSelectedFeeds: function () { return Tables.getSelected("prefErrorFeedList"); }, removeSelected: function () { const sel_rows = this.getSelectedFeeds(); if (sel_rows.length > 0) { if (confirm(__("Remove selected feeds?"))) { notify_progress("Removing selected feeds...", true); const query = { op: "pref-feeds", method: "remove", ids: sel_rows.toString() }; xhrPost("backend.php", query, () => { notify(''); dialog.hide(); Feeds.reload(); }); } } else { alert(__("No feeds are selected.")); } }, execute: function () { if (this.validate()) { // } }, href: "backend.php?" + dojo.objectToQuery(query) }); dialog.show(); }, feedBrowser: function() { const query = {op: "feeds", method: "feedBrowser"}; if (dijit.byId("feedAddDlg")) dijit.byId("feedAddDlg").hide(); if (dijit.byId("feedBrowserDlg")) dijit.byId("feedBrowserDlg").destroyRecursive(); // noinspection JSUnusedGlobalSymbols const dialog = new dijit.Dialog({ id: "feedBrowserDlg", title: __("More Feeds"), style: "width: 600px", getSelectedFeedIds: function () { const list = $$("#browseFeedList li[id*=FBROW]"); const selected = []; list.each(function (child) { const id = child.id.replace("FBROW-", ""); if (child.hasClassName('Selected')) { selected.push(id); } }); return selected; }, getSelectedFeeds: function () { const list = $$("#browseFeedList li.Selected"); const selected = []; list.each(function (child) { const title = child.getElementsBySelector("span.fb_feedTitle")[0].innerHTML; const url = child.getElementsBySelector("a.fb_feedUrl")[0].href; selected.push([title, url]); }); return selected; }, subscribe: function () { const mode = this.attr('value').mode; let selected = []; if (mode == "1") selected = this.getSelectedFeeds(); else selected = this.getSelectedFeedIds(); if (selected.length > 0) { dijit.byId("feedBrowserDlg").hide(); notify_progress("Loading, please wait...", true); const query = { op: "rpc", method: "massSubscribe", payload: JSON.stringify(selected), mode: mode }; xhrPost("backend.php", query, () => { notify(''); Feeds.reload(); }); } else { alert(__("No feeds are selected.")); } }, update: function () { Element.show('feed_browser_spinner'); xhrPost("backend.php", dialog.attr("value"), (transport) => { notify(''); Element.hide('feed_browser_spinner'); const reply = JSON.parse(transport.responseText); const mode = reply['mode']; if ($("browseFeedList") && reply['content']) { $("browseFeedList").innerHTML = reply['content']; } dojo.parser.parse("browseFeedList"); if (mode == 2) { Element.show(dijit.byId('feed_archive_remove').domNode); } else { Element.hide(dijit.byId('feed_archive_remove').domNode); } }); }, removeFromArchive: function () { const selected = this.getSelectedFeedIds(); if (selected.length > 0) { if (confirm(__("Remove selected feeds from the archive? Feeds with stored articles will not be removed."))) { Element.show('feed_browser_spinner'); const query = {op: "rpc", method: "remarchive", ids: selected.toString()}; xhrPost("backend.php", query, () => { dialog.update(); }); } } }, execute: function () { if (this.validate()) { this.subscribe(); } }, href: "backend.php?" + dojo.objectToQuery(query) }); dialog.show(); }, addLabel: function(select, callback) { const caption = prompt(__("Please enter label caption:"), ""); if (caption != undefined && caption.trim().length > 0) { const query = {op: "pref-labels", method: "add", caption: caption.trim()}; if (select) Object.extend(query, {output: "select"}); notify_progress("Loading, please wait...", true); xhrPost("backend.php", query, (transport) => { if (callback) { callback(transport); } else if (App.isPrefs()) { updateLabelList(); } else { Feeds.reload(); } }); } }, unsubscribeFeed: function(feed_id, title) { const msg = __("Unsubscribe from %s?").replace("%s", title); if (title == undefined || confirm(msg)) { notify_progress("Removing feed..."); const query = {op: "pref-feeds", quiet: 1, method: "remove", ids: feed_id}; xhrPost("backend.php", query, () => { if (dijit.byId("feedEditDlg")) dijit.byId("feedEditDlg").hide(); if (App.isPrefs()) { Feeds.reload(); } else { if (feed_id == Feeds.getActive()) setTimeout(() => { Feeds.open({feed: -5}) }, 100); if (feed_id < 0) Feeds.reload(); } }); } return false; }, editFeed: function (feed) { if (feed <= 0) return alert(__("You can't edit this kind of feed.")); const query = {op: "pref-feeds", method: "editfeed", id: feed}; console.log("editFeed", query); if (dijit.byId("filterEditDlg")) dijit.byId("filterEditDlg").destroyRecursive(); if (dijit.byId("feedEditDlg")) dijit.byId("feedEditDlg").destroyRecursive(); const dialog = new dijit.Dialog({ id: "feedEditDlg", title: __("Edit Feed"), style: "width: 600px", execute: function () { if (this.validate()) { notify_progress("Saving data...", true); xhrPost("backend.php", dialog.attr('value'), () => { dialog.hide(); notify(''); Feeds.reload(); }); } }, href: "backend.php?" + dojo.objectToQuery(query) }); dialog.show(); }, genUrlChangeKey: function(feed, is_cat) { if (confirm(__("Generate new syndication address for this feed?"))) { notify_progress("Trying to change address...", true); const query = {op: "pref-feeds", method: "regenFeedKey", id: feed, is_cat: is_cat}; xhrJson("backend.php", query, (reply) => { const new_link = reply.link; const e = $('gen_feed_url'); if (new_link) { e.innerHTML = e.innerHTML.replace(/&key=.*$/, "&key=" + new_link); e.href = e.href.replace(/&key=.*$/, "&key=" + new_link); new Effect.Highlight(e); notify(''); } else { notify_error("Could not change feed URL."); } }); } return false; } }; function report_error(message, filename, lineno, colno, error) { exception_error(error, null, filename, lineno); } function exception_error(e, e_compat, filename, lineno, colno) { if (typeof e == "string") e = e_compat; if (!e) return; // no exception object, nothing to report. try { console.error(e); const msg = e.toString(); try { xhrPost("backend.php", {op: "rpc", method: "log", file: e.fileName ? e.fileName : filename, line: e.lineNumber ? e.lineNumber : lineno, msg: msg, context: e.stack}, (transport) => { console.warn(transport.responseText); }); } catch (e) { console.error("Exception while trying to log the error.", e); } let content = "
" + msg + "
"; if (e.stack) { content += "" + msg + "
"; if (ext_info) { content = content + "