| | |
| | | this.onloads = []; |
| | | this.messages = {}; |
| | | this.group2expand = {}; |
| | | this.http_request_jobs = {}; |
| | | |
| | | // webmail client settings |
| | | this.dblclick_time = 500; |
| | |
| | | this.gui_objects.messagelist.parentNode.onmousedown = function(e){ return p.click_on_list(e); }; |
| | | |
| | | this.enable_command('toggle_status', 'toggle_flag', 'sort', true); |
| | | this.enable_command('set-listmode', this.env.threads && !this.env.search_request); |
| | | |
| | | // load messages |
| | | this.command('list'); |
| | |
| | | // execute a specific command on the web client |
| | | this.command = function(command, props, obj, event) |
| | | { |
| | | var ret, uid, cid, url, flag; |
| | | var ret, uid, cid, url, flag, aborted = false; |
| | | |
| | | if (obj && obj.blur) |
| | | obj.blur(); |
| | |
| | | |
| | | case 'open': |
| | | if (uid = this.get_single_uid()) { |
| | | obj.href = this.url('show', {_mbox: this.env.mailbox, _uid: uid}); |
| | | obj.href = this.url('show', {_mbox: this.get_message_mailbox(uid), _uid: uid}); |
| | | return true; |
| | | } |
| | | break; |
| | |
| | | break; |
| | | |
| | | case 'list': |
| | | if (props && props != '') |
| | | this.reset_qsearch(); |
| | | // re-send for the selected folder |
| | | if (props && props != '' && this.env.search_request) { |
| | | var oldmbox = this.env.search_scope == 'all' ? '*' : this.env.mailbox; |
| | | this.env.search_mods[props] = this.env.search_mods[oldmbox]; // copy search mods from active search |
| | | this.env.mailbox = props; |
| | | this.env.search_scope = 'base'; |
| | | this.qsearch(this.gui_objects.qsearchbox.value); |
| | | this.select_folder(this.env.mailbox, '', true); |
| | | break; |
| | | } |
| | | |
| | | if (this.env.action == 'compose' && this.env.extwin) |
| | | window.close(); |
| | | else if (this.task == 'mail') { |
| | |
| | | } |
| | | else if (this.task == 'addressbook') |
| | | this.list_contacts(props); |
| | | break; |
| | | |
| | | case 'set-listmode': |
| | | this.set_list_options(null, undefined, undefined, props == 'threads' ? 1 : 0); |
| | | break; |
| | | |
| | | case 'sort': |
| | |
| | | this.load_contact(cid, 'edit'); |
| | | else if (this.task == 'settings' && props) |
| | | this.load_identity(props, 'edit-identity'); |
| | | else if (this.task == 'mail' && (cid = this.get_single_uid())) { |
| | | url = { _mbox: this.env.mailbox }; |
| | | url[this.env.mailbox == this.env.drafts_mailbox && props != 'new' ? '_draft_uid' : '_uid'] = cid; |
| | | else if (this.task == 'mail' && (uid = this.get_single_uid())) { |
| | | url = { _mbox: this.get_message_mailbox(uid) }; |
| | | url[this.env.mailbox == this.env.drafts_mailbox && props != 'new' ? '_draft_uid' : '_uid'] = uid; |
| | | this.open_compose_step(url); |
| | | } |
| | | break; |
| | |
| | | // Reset the auto-save timer |
| | | clearTimeout(this.save_timer); |
| | | |
| | | this.upload_file(props || this.gui_objects.uploadform, 'upload'); |
| | | if (!this.upload_file(props || this.gui_objects.uploadform, 'upload')) { |
| | | alert(this.get_label('selectimportfile')); |
| | | aborted = true; |
| | | } |
| | | break; |
| | | |
| | | case 'insert-sig': |
| | |
| | | case 'reply-list': |
| | | case 'reply': |
| | | if (uid = this.get_single_uid()) { |
| | | url = {_reply_uid: uid, _mbox: this.env.mailbox}; |
| | | url = {_reply_uid: uid, _mbox: this.get_message_mailbox(uid)}; |
| | | if (command == 'reply-all') |
| | | // do reply-list, when list is detected and popup menu wasn't used |
| | | url._all = (!props && this.env.reply_all_mode == 1 && this.commands['reply-list'] ? 'list' : 'all'); |
| | |
| | | this.gui_objects.messagepartframe.contentWindow.print(); |
| | | } |
| | | else if (uid = this.get_single_uid()) { |
| | | ref.printwin = this.open_window(this.env.comm_path+'&_action=print&_uid='+uid+'&_mbox='+urlencode(this.env.mailbox)+(this.env.safemode ? '&_safe=1' : ''), true, true); |
| | | ref.printwin = this.open_window(this.env.comm_path+'&_action=print&_uid='+uid+'&_mbox='+urlencode(this.get_message_mailbox(uid))+(this.env.safemode ? '&_safe=1' : ''), true, true); |
| | | if (this.printwin) { |
| | | if (this.env.action != 'show') |
| | | this.mark_message('read', uid); |
| | |
| | | if (this.env.action == 'get') { |
| | | location.href = location.href.replace(/_frame=/, '_download='); |
| | | } |
| | | else if (uid = this.get_single_uid()) |
| | | this.goto_url('viewsource', { _uid: uid, _mbox: this.env.mailbox, _save: 1 }); |
| | | else if (uid = this.get_single_uid()) { |
| | | this.goto_url('viewsource', { _uid: uid, _mbox: this.get_message_mailbox(uid), _save: 1 }); |
| | | } |
| | | break; |
| | | |
| | | // quicksearch |
| | |
| | | if (!this.upload_file(form, 'import')) { |
| | | this.set_busy(false, null, importlock); |
| | | alert(this.get_label('selectimportfile')); |
| | | aborted = true; |
| | | } |
| | | break; |
| | | |
| | |
| | | var file = document.getElementById('rcmimportfile'); |
| | | if (file && !file.value) { |
| | | alert(this.get_label('selectimportfile')); |
| | | aborted = true; |
| | | break; |
| | | } |
| | | this.gui_objects.importform.submit(); |
| | |
| | | break; |
| | | } |
| | | |
| | | if (this.triggerEvent('after'+command, props) === false) |
| | | if (!aborted && this.triggerEvent('after'+command, props) === false) |
| | | ret = false; |
| | | this.triggerEvent('actionafter', {props:props, action:command}); |
| | | this.triggerEvent('actionafter', { props:props, action:command, aborted:aborted }); |
| | | |
| | | return ret === false ? false : obj ? false : true; |
| | | }; |
| | |
| | | |
| | | var uid = list.get_single_selection(); |
| | | |
| | | if (uid && this.env.mailbox == this.env.drafts_mailbox) |
| | | if (uid && (this.env.messages[uid].mbox || this.env.mailbox) == this.env.drafts_mailbox) |
| | | this.open_compose_step({ _draft_uid: uid, _mbox: this.env.mailbox }); |
| | | else if (uid) |
| | | this.show_message(uid, false, false); |
| | |
| | | this.init_message_row = function(row) |
| | | { |
| | | var i, fn = {}, self = this, uid = row.uid, |
| | | status_icon = (this.env.status_col != null ? 'status' : 'msg') + 'icn' + row.uid; |
| | | status_icon = (this.env.status_col != null ? 'status' : 'msg') + 'icn' + row.id; |
| | | |
| | | if (uid && this.env.messages[uid]) |
| | | $.extend(row, this.env.messages[uid]); |
| | |
| | | |
| | | // save message icon position too |
| | | if (this.env.status_col != null) |
| | | row.msgicon = document.getElementById('msgicn'+row.uid); |
| | | row.msgicon = document.getElementById('msgicn'+row.id); |
| | | else |
| | | row.msgicon = row.icon; |
| | | |
| | | // set eventhandler to flag icon |
| | | if (this.env.flagged_col != null && (row.flagicon = document.getElementById('flagicn'+row.uid))) { |
| | | if (this.env.flagged_col != null && (row.flagicon = document.getElementById('flagicn'+row.id))) { |
| | | fn.flagicon = function(e) { self.command('toggle_flag', uid); }; |
| | | } |
| | | |
| | | // set event handler to thread expand/collapse icon |
| | | if (!row.depth && row.has_children && (row.expando = document.getElementById('rcmexpando'+row.uid))) { |
| | | if (!row.depth && row.has_children && (row.expando = document.getElementById('rcmexpando'+row.id))) { |
| | | fn.expando = function(e) { self.expand_message_row(e, uid); }; |
| | | } |
| | | |
| | |
| | | selected: this.select_all_mode || this.message_list.in_selection(uid), |
| | | ml: flags.ml?1:0, |
| | | ctype: flags.ctype, |
| | | mbox: flags.mbox, |
| | | // flags from plugins |
| | | flags: flags.extra_flags |
| | | }); |
| | |
| | | + (flags.deleted ? ' deleted' : '') |
| | | + (flags.flagged ? ' flagged' : '') |
| | | + (message.selected ? ' selected' : ''), |
| | | row = { cols:[], style:{}, id:'rcmrow'+uid }; |
| | | row = { cols:[], style:{}, id:'rcmrow'+this.html_identifier(uid,true), uid:uid }; |
| | | |
| | | // message status icons |
| | | css_class = 'msgicon'; |
| | |
| | | if (this.env.threading) { |
| | | if (message.depth) { |
| | | // This assumes that div width is hardcoded to 15px, |
| | | tree += '<span id="rcmtab' + uid + '" class="branch" style="width:' + (message.depth * 15) + 'px;"> </span>'; |
| | | tree += '<span id="rcmtab' + row.id + '" class="branch" style="width:' + (message.depth * 15) + 'px;"> </span>'; |
| | | |
| | | if ((rows[message.parent_uid] && rows[message.parent_uid].expanded === false) |
| | | || ((this.env.autoexpand_threads == 0 || this.env.autoexpand_threads == 2) && |
| | |
| | | message.expanded = true; |
| | | } |
| | | |
| | | expando = '<div id="rcmexpando' + uid + '" class="' + (message.expanded ? 'expanded' : 'collapsed') + '"> </div>'; |
| | | expando = '<div id="rcmexpando' + row.id + '" class="' + (message.expanded ? 'expanded' : 'collapsed') + '"> </div>'; |
| | | row_class += ' thread' + (message.expanded? ' expanded' : ''); |
| | | } |
| | | |
| | |
| | | row_class += ' unroot'; |
| | | } |
| | | |
| | | tree += '<span id="msgicn'+uid+'" class="'+css_class+'"> </span>'; |
| | | tree += '<span id="msgicn'+row.id+'" class="'+css_class+'"> </span>'; |
| | | row.className = row_class; |
| | | |
| | | // build subject link |
| | | // build subject link |
| | | if (cols.subject) { |
| | | var action = flags.mbox == this.env.drafts_mailbox ? 'compose' : 'show'; |
| | | var uid_param = flags.mbox == this.env.drafts_mailbox ? '_draft_uid' : '_uid'; |
| | | cols.subject = '<a href="./?_task=mail&_action='+action+'&_mbox='+urlencode(flags.mbox)+'&'+uid_param+'='+uid+'"'+ |
| | | cols.subject = '<a href="./?_task=mail&_action='+action+'&_mbox='+urlencode(flags.mbox)+'&'+uid_param+'='+urlencode(uid)+'"'+ |
| | | ' onclick="return rcube_event.cancel(event)" onmouseover="rcube_webmail.long_subject_title(this,'+(message.depth+1)+')"><span>'+cols.subject+'</span></a>'; |
| | | } |
| | | |
| | |
| | | |
| | | if (c == 'flag') { |
| | | css_class = (flags.flagged ? 'flagged' : 'unflagged'); |
| | | html = '<span id="flagicn'+uid+'" class="'+css_class+'"> </span>'; |
| | | html = '<span id="flagicn'+row.id+'" class="'+css_class+'"> </span>'; |
| | | } |
| | | else if (c == 'attachment') { |
| | | if (/application\/|multipart\/(m|signed)/.test(flags.ctype)) |
| | |
| | | css_class = 'unreadchildren'; |
| | | else |
| | | css_class = 'msgicon'; |
| | | html = '<span id="statusicn'+uid+'" class="'+css_class+'"> </span>'; |
| | | html = '<span id="statusicn'+row.id+'" class="'+css_class+'"> </span>'; |
| | | } |
| | | else if (c == 'threads') |
| | | html = expando; |
| | |
| | | |
| | | var win, target = window, |
| | | action = preview ? 'preview': 'show', |
| | | url = '&_action='+action+'&_uid='+id+'&_mbox='+urlencode(this.env.mailbox); |
| | | url = '&_action='+action+'&_uid='+id+'&_mbox='+urlencode(this.get_message_mailbox(id)); |
| | | |
| | | if (preview && (win = this.get_frame_window(this.env.contentframe))) { |
| | | target = win; |
| | |
| | | } |
| | | |
| | | if (html) |
| | | $('#rcmtab'+uid).html(html); |
| | | $('#rcmtab'+this.html_identifier(uid, true)).html(html); |
| | | }; |
| | | |
| | | // update parent in a thread |
| | |
| | | |
| | | r.depth--; // move left |
| | | // reset width and clear the content of a tab, icons will be added later |
| | | $('#rcmtab'+r.uid).width(r.depth * 15).html(''); |
| | | $('#rcmtab'+r.id).width(r.depth * 15).html(''); |
| | | if (!r.depth) { // a new root |
| | | count++; // increase roots count |
| | | r.parent_uid = 0; |
| | | if (r.has_children) { |
| | | // replace 'leaf' with 'collapsed' |
| | | $('#rcmrow'+r.uid+' '+'.leaf:first') |
| | | .attr('id', 'rcmexpando' + r.uid) |
| | | $('#'+r.id+' .leaf:first') |
| | | .attr('id', 'rcmexpando' + r.id) |
| | | .attr('class', (r.obj.style.display != 'none' ? 'expanded' : 'collapsed')) |
| | | .bind('mousedown', {uid:r.uid, p:this}, |
| | | function(e) { return e.data.p.expand_message_row(e, e.data.uid); }); |
| | |
| | | if (numfiles) { |
| | | if (this.env.max_filesize && this.env.filesizeerror && size > this.env.max_filesize) { |
| | | this.display_message(this.env.filesizeerror, 'error'); |
| | | return; |
| | | return false; |
| | | } |
| | | |
| | | var frame_name = this.async_upload_form(form, action || 'upload', function(e) { |
| | |
| | | r = this.http_request(action, url, lock); |
| | | |
| | | this.env.qsearch = {lock: lock, request: r}; |
| | | this.enable_command('set-listmode', this.env.threads && (this.env.search_scope || 'base') == 'base'); |
| | | } |
| | | }; |
| | | |
| | | // build URL params for search |
| | | this.search_params = function(search, filter) |
| | | this.search_params = function(search, filter, smods) |
| | | { |
| | | var n, url = {}, mods_arr = [], |
| | | mods = this.env.search_mods, |
| | | mbox = this.env.mailbox; |
| | | scope = this.env.search_scope || 'base', |
| | | mbox = scope == 'all' ? '*' : this.env.mailbox; |
| | | |
| | | if (!filter && this.gui_objects.search_filter) |
| | | filter = this.gui_objects.search_filter.value; |
| | |
| | | if (search) { |
| | | url._q = search; |
| | | |
| | | if (mods && this.message_list) |
| | | mods = mods[mbox] ? mods[mbox] : mods['*']; |
| | | if (!smods && mods && this.message_list) |
| | | smods = mods[mbox] || mods['*']; |
| | | |
| | | if (mods) { |
| | | for (n in mods) |
| | | if (smods) { |
| | | for (n in smods) |
| | | mods_arr.push(n); |
| | | url._headers = mods_arr.join(','); |
| | | } |
| | | } |
| | | |
| | | if (mbox) |
| | | if (scope) |
| | | url._scope = scope; |
| | | if (mbox && scope != 'all') |
| | | url._mbox = mbox; |
| | | |
| | | return url; |
| | |
| | | this.env.qsearch = null; |
| | | this.env.search_request = null; |
| | | this.env.search_id = null; |
| | | |
| | | this.enable_command('set-listmode', this.env.threads); |
| | | }; |
| | | |
| | | this.sent_successfully = function(type, msg, folders) |
| | |
| | | p = inp_value.lastIndexOf(this.env.recipients_separator, cpos-1), |
| | | q = inp_value.substring(p+1, cpos), |
| | | min = this.env.autocomplete_min_length, |
| | | ac = this.ksearch_data; |
| | | data = this.ksearch_data; |
| | | |
| | | // trim query string |
| | | q = $.trim(q); |
| | |
| | | return; |
| | | |
| | | // ...new search value contains old one and previous search was not finished or its result was empty |
| | | if (old_value && old_value.length && q.startsWith(old_value) && (!ac || ac.num <= 0) && this.env.contacts && !this.env.contacts.length) |
| | | if (old_value && old_value.length && q.startsWith(old_value) && (!data || data.num <= 0) && this.env.contacts && !this.env.contacts.length) |
| | | return; |
| | | |
| | | var i, lock, source, xhr, reqid = new Date().getTime(), |
| | | post_data = {_search: q, _id: reqid}, |
| | | threads = props && props.threads ? props.threads : 1, |
| | | sources = props && props.sources ? props.sources : [], |
| | | action = props && props.action ? props.action : 'mail/autocomplete'; |
| | | var sources = props && props.sources ? props.sources : ['']; |
| | | var reqid = this.multi_thread_http_request({ |
| | | items: sources, |
| | | threads: props && props.threads ? props.threads : 1, |
| | | action: props && props.action ? props.action : 'mail/autocomplete', |
| | | postdata: { _search:q, _source:'%s' }, |
| | | lock: this.display_message(this.get_label('searching'), 'loading') |
| | | }); |
| | | |
| | | this.ksearch_data = {id: reqid, sources: sources.slice(), action: action, |
| | | locks: [], requests: [], num: sources.length}; |
| | | |
| | | for (i=0; i<threads; i++) { |
| | | source = this.ksearch_data.sources.shift(); |
| | | if (threads > 1 && source === undefined) |
| | | break; |
| | | |
| | | post_data._source = source ? source : ''; |
| | | lock = this.display_message(this.get_label('searching'), 'loading'); |
| | | xhr = this.http_post(action, post_data, lock); |
| | | |
| | | this.ksearch_data.locks.push(lock); |
| | | this.ksearch_data.requests.push(xhr); |
| | | } |
| | | this.ksearch_data = { id:reqid, sources:sources.slice(), num:sources.length }; |
| | | }; |
| | | |
| | | this.ksearch_query_results = function(results, search, reqid) |
| | | { |
| | | // trigger multi-thread http response callback |
| | | this.multi_thread_http_response(results, reqid); |
| | | |
| | | // search stopped in meantime? |
| | | if (!this.ksearch_value) |
| | | return; |
| | |
| | | // display search results |
| | | var i, len, ul, li, text, type, init, |
| | | value = this.ksearch_value, |
| | | data = this.ksearch_data, |
| | | maxlen = this.env.autocomplete_max ? this.env.autocomplete_max : 15; |
| | | |
| | | // create results pane if not present |
| | |
| | | if (len) |
| | | this.env.contacts = this.env.contacts.concat(results); |
| | | |
| | | // run next parallel search |
| | | if (data.id == reqid) { |
| | | data.num--; |
| | | if (maxlen > 0 && data.sources.length) { |
| | | var lock, xhr, source = data.sources.shift(), post_data; |
| | | if (source) { |
| | | post_data = {_search: value, _id: reqid, _source: source}; |
| | | lock = this.display_message(this.get_label('searching'), 'loading'); |
| | | xhr = this.http_post(data.action, post_data, lock); |
| | | |
| | | this.ksearch_data.locks.push(lock); |
| | | this.ksearch_data.requests.push(xhr); |
| | | } |
| | | } |
| | | else if (!maxlen) { |
| | | if (!this.ksearch_msg) |
| | | this.ksearch_msg = this.display_message(this.get_label('autocompletemore')); |
| | | // abort pending searches |
| | | this.ksearch_abort(); |
| | | } |
| | | } |
| | | if (this.ksearch_data.id == reqid) |
| | | this.ksearch_data.num--; |
| | | }; |
| | | |
| | | this.ksearch_click = function(node) |
| | |
| | | // Clears autocomplete data/requests |
| | | this.ksearch_destroy = function() |
| | | { |
| | | this.ksearch_abort(); |
| | | if (this.ksearch_data) |
| | | this.multi_thread_request_abort(this.ksearch_data.id); |
| | | |
| | | if (this.ksearch_info) |
| | | this.hide_message(this.ksearch_info); |
| | |
| | | this.ksearch_data = null; |
| | | this.ksearch_info = null; |
| | | this.ksearch_msg = null; |
| | | } |
| | | |
| | | // Aborts pending autocomplete requests |
| | | this.ksearch_abort = function() |
| | | { |
| | | var i, len, ac = this.ksearch_data; |
| | | |
| | | if (!ac) |
| | | return; |
| | | |
| | | for (i=0, len=ac.locks.length; i<len; i++) |
| | | this.abort_request({request: ac.requests[i], lock: ac.locks[i]}); |
| | | }; |
| | | |
| | | |
| | |
| | | if ((n = $.inArray('status', this.env.coltypes)) >= 0) |
| | | this.env.status_col = n; |
| | | |
| | | if (list) |
| | | if (list) { |
| | | list.hide_column('folder', !(this.env.search_request || this.env.search_id) || this.env.search_scope == 'base'); |
| | | list.init_header(); |
| | | } |
| | | }; |
| | | |
| | | // replace content of row count display |
| | |
| | | else if (status == 'timeout') |
| | | this.display_message(this.get_label('requesttimedout'), 'error'); |
| | | else if (request.status == 0 && status != 'abort') |
| | | this.display_message(this.get_label('servererror') + ' (No connection)', 'error'); |
| | | this.display_message(this.get_label('connerror'), 'error'); |
| | | |
| | | // redirect to url specified in location header if not empty |
| | | var location_url = request.getResponseHeader("Location"); |
| | |
| | | |
| | | if (this.submit_timer) |
| | | clearTimeout(this.submit_timer); |
| | | }; |
| | | |
| | | /** |
| | | Send multi-threaded parallel HTTP requests to the server for a list if items. |
| | | The string '%' in either a GET query or POST parameters will be replaced with the respective item value. |
| | | This is the argument object expected: { |
| | | items: ['foo','bar','gna'], // list of items to send requests for |
| | | action: 'task/some-action', // Roudncube action to call |
| | | query: { q:'%s' }, // GET query parameters |
| | | postdata: { source:'%s' }, // POST data (sends a POST request if present) |
| | | threads: 3, // max. number of concurrent requests |
| | | onresponse: function(data){ }, // Callback function called for every response received from server |
| | | whendone: function(alldata){ } // Callback function called when all requests have been sent |
| | | } |
| | | */ |
| | | this.multi_thread_http_request = function(prop) |
| | | { |
| | | var reqid = new Date().getTime(); |
| | | |
| | | prop.reqid = reqid; |
| | | prop.running = 0; |
| | | prop.requests = []; |
| | | prop.result = []; |
| | | prop._items = $.extend([], prop.items); // copy items |
| | | |
| | | if (!prop.lock) |
| | | prop.lock = this.display_message(this.get_label('loading'), 'loading'); |
| | | |
| | | // add the request arguments to the jobs pool |
| | | this.http_request_jobs[reqid] = prop; |
| | | |
| | | // start n threads |
| | | var item, threads = prop.threads || 1; |
| | | for (var i=0; i < threads; i++) { |
| | | item = prop._items.shift(); |
| | | if (item === undefined) |
| | | break; |
| | | |
| | | prop.running++; |
| | | prop.requests.push(this.multi_thread_send_request(prop, item)); |
| | | } |
| | | |
| | | return reqid; |
| | | }; |
| | | |
| | | // helper method to send an HTTP request with the given iterator value |
| | | this.multi_thread_send_request = function(prop, item) |
| | | { |
| | | var postdata, query; |
| | | |
| | | // replace %s in post data |
| | | if (prop.postdata) { |
| | | postdata = {}; |
| | | for (var k in prop.postdata) { |
| | | postdata[k] = String(prop.postdata[k]).replace('%s', item); |
| | | } |
| | | postdata._reqid = prop.reqid; |
| | | } |
| | | // replace %s in query |
| | | else if (typeof prop.query == 'string') { |
| | | query = prop.query.replace('%s', item); |
| | | query += '&_reqid=' + prop.reqid; |
| | | } |
| | | else if (typeof prop.query == 'object' && prop.query) { |
| | | query = {}; |
| | | for (var k in prop.query) { |
| | | query[k] = String(prop.query[k]).replace('%s', item); |
| | | } |
| | | query._reqid = prop.reqid; |
| | | } |
| | | |
| | | // send HTTP GET or POST request |
| | | return postdata ? this.http_post(prop.action, postdata) : this.http_request(prop.action, query); |
| | | }; |
| | | |
| | | // callback function for multi-threaded http responses |
| | | this.multi_thread_http_response = function(data, reqid) |
| | | { |
| | | var prop = this.http_request_jobs[reqid]; |
| | | if (!prop || prop.running <= 0 || prop.cancelled) |
| | | return; |
| | | |
| | | prop.running--; |
| | | |
| | | // trigger response callback |
| | | if (prop.onresponse && typeof prop.onresponse == 'function') { |
| | | prop.onresponse(data); |
| | | } |
| | | |
| | | prop.result = $.extend(prop.result, data); |
| | | |
| | | // send next request if prop.items is not yet empty |
| | | var item = prop._items.shift(); |
| | | if (item !== undefined) { |
| | | prop.running++; |
| | | prop.requests.push(this.multi_thread_send_request(prop, item)); |
| | | } |
| | | // trigger whendone callback and mark this request as done |
| | | else if (prop.running == 0) { |
| | | if (prop.whendone && typeof prop.whendone == 'function') { |
| | | prop.whendone(prop.result); |
| | | } |
| | | |
| | | this.set_busy(false, '', prop.lock); |
| | | |
| | | // remove from this.http_request_jobs pool |
| | | delete this.http_request_jobs[reqid]; |
| | | } |
| | | }; |
| | | |
| | | // abort a running multi-thread request with the given identifier |
| | | this.multi_thread_request_abort = function(reqid) |
| | | { |
| | | var prop = this.http_request_jobs[reqid]; |
| | | if (prop) { |
| | | for (var i=0; prop.running > 0 && i < prop.requests.length; i++) { |
| | | if (prop.requests[i].abort) |
| | | prop.requests[i].abort(); |
| | | } |
| | | |
| | | prop.running = 0; |
| | | prop.cancelled = true; |
| | | this.set_busy(false, '', prop.lock); |
| | | } |
| | | }; |
| | | |
| | | // post the given form to a hidden iframe |
| | |
| | | return this.env.cid ? this.env.cid : (this.contact_list ? this.contact_list.get_single_selection() : null); |
| | | }; |
| | | |
| | | // get the IMP mailbox of the message with the given UID |
| | | this.get_message_mailbox = function(uid) |
| | | { |
| | | var msg = this.env.messages ? this.env.messages[uid] : {}; |
| | | return msg.mbox || this.env.mailbox; |
| | | } |
| | | |
| | | // gets cursor position |
| | | this.get_caret_pos = function(obj) |
| | | { |
| | |
| | | try { |
| | | window.navigator.registerProtocolHandler('mailto', this.mailto_handler_uri(), name); |
| | | } |
| | | catch(e) {}; |
| | | catch(e) { |
| | | this.display_message(String(e), 'error'); |
| | | }; |
| | | }; |
| | | |
| | | this.check_protocol_handler = function(name, elem) |
| | | { |
| | | var nav = window.navigator; |
| | | if (!nav |
| | | || (typeof nav.registerProtocolHandler != 'function') |
| | | || ((typeof nav.isProtocolHandlerRegistered == 'function') |
| | | && nav.isProtocolHandlerRegistered('mailto', this.mailto_handler_uri()) == 'registered') |
| | | ) |
| | | $(elem).addClass('disabled'); |
| | | else |
| | | $(elem).click(function() { rcmail.register_protocol_handler(name); return false; }); |
| | | if (!nav || (typeof nav.registerProtocolHandler != 'function')) { |
| | | $(elem).addClass('disabled').click(function(){ return false; }); |
| | | } |
| | | else { |
| | | var status = null; |
| | | if (typeof nav.isProtocolHandlerRegistered == 'function') { |
| | | status = nav.isProtocolHandlerRegistered('mailto', this.mailto_handler_uri()); |
| | | if (status) |
| | | $(elem).parent().find('.mailtoprotohandler-status').html(status); |
| | | } |
| | | else { |
| | | $(elem).click(function() { rcmail.register_protocol_handler(name); return false; }); |
| | | } |
| | | } |
| | | }; |
| | | |
| | | // Checks browser capabilities eg. PDF support, TIF support |