openerp.mail = function (session) { var _t = session.web._t, _lt = session.web._lt; var mail = session.mail = {}; openerp_mail_followers(session, mail); // import mail_followers.js openerp_FieldMany2ManyTagsEmail(session); // import manyy2many_tags_email.js /** * ------------------------------------------------------------ * FormView * ------------------------------------------------------------ * * Override of formview do_action method, to catch all return action about * mail.compose.message. The purpose is to bind 'Send by e-mail' buttons. */ session.web.FormView = session.web.FormView.extend({ do_action: function (action) { if (action.res_model == 'mail.compose.message') { /* hack for stop context propagation of wrong value * delete this hack when a global method to clean context is create */ var context_keys = ['default_template_id', 'default_composition_mode', 'default_use_template', 'default_partner_ids', 'default_model', 'default_res_id', 'default_content_subtype', , 'default_subject', 'default_body', 'active_id', 'lang', 'bin_raw', 'tz', 'active_model', 'edi_web_url_view', 'active_ids'] for (var key in action.context) { if (_.indexOf(context_keys, key) == -1) { action.context[key] = null; } } /* end hack */ } return this._super.apply(this, arguments); }, }); /** * ------------------------------------------------------------ * ChatterUtils * ------------------------------------------------------------ * * This class holds a few tools method for Chatter. * Some regular expressions not used anymore, kept because I want to * - (^|\s)@((\w|@|\.)*): @login@log.log * - (^|\s)\[(\w+).(\w+),(\d)\|*((\w|[@ .,])*)\]: [ir.attachment,3|My Label], * for internal links */ mail.ChatterUtils = { /* Get an image in /web/binary/image?... */ get_image: function (session, model, field, id) { return session.prefix + '/web/binary/image?session_id=' + session.session_id + '&model=' + model + '&field=' + field + '&id=' + (id || ''); }, /* Get the url of an attachment {'id': id} */ get_attachment_url: function (session, attachment) { return session.origin + '/web/binary/saveas?session_id=' + session.session_id + '&model=ir.attachment&field=datas&filename_field=datas_fname&id=' + attachment['id']; }, /** * Replaces some expressions * - :name - shortcut to an image */ do_replace_expressions: function (string) { var icon_list = ['al', 'pinky'] /* special shortcut: :name, try to find an icon if in list */ var regex_login = new RegExp(/(^|\s):((\w)*)/g); var regex_res = regex_login.exec(string); while (regex_res != null) { var icon_name = regex_res[2]; if (_.include(icon_list, icon_name)) string = string.replace(regex_res[0], regex_res[1] + '' + icon_name + ''); regex_res = regex_login.exec(string); } return string; }, /** * Replaces textarea text into html text (add

, ) * TDE note : should be done server-side, in Python -> use mail.compose.message ? */ get_text2html: function (text) { return text .replace(/[\n\r]/g,'
') .replace(/((?:https?|ftp):\/\/[\S]+)/g,'
$1 ') }, /* Returns the complete domain with "&" * TDE note: please add some comments to explain how/why */ expand_domain: function (domain) { var new_domain = []; var nb_and = -1; // TDE note: smarted code maybe ? for ( var k = domain.length-1; k >= 0 ; k-- ) { if ( typeof domain[k] != 'array' && typeof domain[k] != 'object' ) { nb_and -= 2; continue; } nb_and += 1; } for (var k = 0; k < nb_and ; k++) { domain.unshift('&'); } return domain; } }; /** * ------------------------------------------------------------ * ComposeMessage widget * ------------------------------------------------------------ * * This widget handles the display of a form to compose a new message. * This form is a mail.compose.message form_view. * On first time : display a compact textarea that is not the compose form. * When the user focuses the textarea, the compose message is instantiated. */ mail.ThreadComposeMessage = session.web.Widget.extend({ template: 'mail.compose_message', /** * @param {Object} parent parent * @param {Object} [options] * @param {Object} [context] context passed to the * mail.compose.message DataSetSearch. Please refer to this model * for more details about fields and default values. */ init: function (parent, datasets, options) { var self = this; this._super(parent); this.context = options.context || {}; this.options = options.options; this.show_compact_message = false; // data of this compose message this.attachment_ids = []; this.id = datasets.id; this.model = datasets.model; this.res_model = datasets.res_model; this.is_private = datasets.is_private || false; this.partner_ids = datasets.partner_ids || []; this.avatar = mail.ChatterUtils.get_image(this.session, 'res.users', 'image_small', this.session.uid); this.thread_level = datasets.thread_level; this.parent_thread= parent.messages!= undefined ? parent : false; this.ds_attachment = new session.web.DataSetSearch(this, 'ir.attachment'); this.show_delete_attachment = true; this.fileupload_id = _.uniqueId('oe_fileupload_temp'); $(window).on(self.fileupload_id, self.on_attachment_loaded); }, start: function () { this.display_attachments(); this.bind_events(); }, /* upload the file on the server, add in the attachments list and reload display */ display_attachments: function () { this.$(".oe_msg_attachment_list").html( session.web.qweb.render('mail.thread.message.attachments', {'widget': this}) ); // event: delete an attachment this.$(".oe_msg_attachment_list").on('click', '.oe_mail_attachment_delete', this.on_attachment_delete); }, /* when a user click on the upload button, send file read on_attachment_loaded */ on_attachment_change: function (event) { event.stopPropagation(); var self = this; var $target = $(event.target); if ($target.val() !== '') { var filename = $target.val().replace(/.*[\\\/]/,''); // if the files exits for this answer, delete the file before upload var attachments=[]; for (var i in this.attachment_ids) { if ((this.attachment_ids[i].filename || this.attachment_ids[i].name) == filename) { if (this.attachment_ids[i].upload) { return false; } this.ds_attachment.unlink([this.attachment_ids[i].id]); } else { attachments.push(this.attachment_ids[i]); } } this.attachment_ids = attachments; // submit file this.$('form.oe_form_binary_form').submit(); this.$(".oe_attachment_file").hide(); this.attachment_ids.push({ 'id': 0, 'name': filename, 'filename': filename, 'url': '', 'upload': true }); this.display_attachments(); } }, /* when the file is uploaded */ on_attachment_loaded: function (event, result) { for (var i in this.attachment_ids) { if (this.attachment_ids[i].filename == result.filename && this.attachment_ids[i].upload) { this.attachment_ids[i]={ 'id': result.id, 'name': result.name, 'filename': result.filename, 'url': mail.ChatterUtils.get_attachment_url(this.session, result) }; } } this.display_attachments(); var $input = this.$('input.oe_form_binary_file'); $input.after($input.clone(true)).remove(); this.$(".oe_attachment_file").show(); }, /* unlink the file on the server and reload display */ on_attachment_delete: function (event) { event.stopPropagation(); var attachment_id=$(event.target).data("id"); if (attachment_id) { var attachments=[]; for (var i in this.attachment_ids) { if (attachment_id!=this.attachment_ids[i].id) { attachments.push(this.attachment_ids[i]); } else { this.ds_attachment.unlink([attachment_id]); } } this.attachment_ids = attachments; this.display_attachments(); } }, bind_events: function () { var self = this; this.$('textarea.oe_compact').on('focus', _.bind( this.on_compose_expandable, this)); // set the function called when attachments are added this.$el.on('change', 'input.oe_form_binary_file', _.bind( this.on_attachment_change, this) ); this.$el.on('click', '.oe_cancel', _.bind( this.on_cancel, this) ); this.$el.on('click', '.oe_post', _.bind( this.on_message_post, this) ); this.$el.on('click', '.oe_full', _.bind( this.on_compose_fullmail, this, 'reply') ); /* stack for don't close the compose form if the user click on a button */ this.$el.on('mousedown', '.oe_msg_footer', _.bind( function () { this.stay_open = true; }, this)); this.$('textarea:not(.oe_compact):first').on('focus, mouseup, keydown', _.bind( function () { this.stay_open = false; }, this)); this.$('textarea:not(.oe_compact):first').autosize(); // auto close this.$el.on('blur', 'textarea:not(.oe_compact):first', _.bind( this.on_compose_expandable, this)); }, on_compose_fullmail: function (default_composition_mode) { if (default_composition_mode == 'reply') { var context = { 'default_composition_mode': default_composition_mode, 'default_parent_id': this.id, 'default_body': mail.ChatterUtils.get_text2html(this.$el ? (this.$el.find('textarea:not(.oe_compact)').val() || '') : ''), 'default_attachment_ids': this.attachment_ids, }; } else { var context = { 'default_model': this.context.default_model, 'default_res_id': this.context.default_res_id, 'default_content_subtype': 'html', 'default_composition_mode': default_composition_mode, 'default_parent_id': this.id, 'default_body': mail.ChatterUtils.get_text2html(this.$el ? (this.$el.find('textarea:not(.oe_compact)').val() || '') : ''), 'default_attachment_ids': this.attachment_ids, }; } var action = { type: 'ir.actions.act_window', res_model: 'mail.compose.message', view_mode: 'form', view_type: 'form', action_from: 'mail.ThreadComposeMessage', views: [[false, 'form']], target: 'new', context: context, }; this.do_action(action); this.on_cancel(); }, reinit: function() { var $render = $( session.web.qweb.render('mail.compose_message', {'widget': this}) ); $render.insertAfter(this.$el.last()); this.$el.remove(); this.$el = $render; this.display_attachments(); this.bind_events(); }, on_cancel: function (event) { if (event) event.stopPropagation(); this.attachment_ids=[]; this.stay_open = false; this.show_composer = false; this.reinit(); }, /*post a message and fetch the message*/ on_message_post: function (event) { var self = this; var comment_node = this.$('textarea'); var body = comment_node.val(); comment_node.val(''); var attachments=[]; for (var i in this.attachment_ids) { if (this.attachment_ids[i].upload) { session.web.dialog($('

' + session.web.qweb.render('CrashManager.warning', {message: 'Please, wait while the file is uploading.'}) + '
')); return false; } attachments.push(this.attachment_ids[i].id); } if (body.match(/\S+/)) { //session.web.blockUI(); this.parent_thread.ds_thread.call('message_post_api', [ this.context.default_res_id, mail.ChatterUtils.get_text2html(body), false, this.context.default_parent_id, attachments, this.parent_thread.context ]).done(function (record) { var thread = self.parent_thread; // create object and attach to the thread object thread.message_fetch(false, false, [record], function (arg, data) { var message = thread.create_message_object( data[0] ); // insert the message on dom thread.insert_message( message, self.$el ); if (thread.parent_message) { self.$el.remove(); self.parent_thread.compose_message = null; } else { self.on_cancel(); } }); //session.web.unblockUI(); }); return true; } }, /* convert the compact mode into the compose message */ on_compose_expandable: function (event) { if (!this.stay_open && (!this.show_composer || !this.$('textarea:not(.oe_compact)').val().match(/\S+/))) { this.show_composer = !this.show_composer || this.stay_open; this.reinit(); } if (!this.stay_open && this.show_composer) { this.$('textarea:not(.oe_compact):first').focus(); } return true; }, do_hide_compact: function () { this.show_compact_message = false; if (!this.show_composer) { this.reinit(); } }, do_show_compact: function () { this.show_compact_message = true; if (!this.show_composer) { this.reinit(); } } }); /** * ------------------------------------------------------------ * Thread Message Expandable Widget * ------------------------------------------------------------ * * This widget handles the display the expandable message in a thread. * - thread * - - visible message * - - expandable * - - visible message * - - visible message * - - expandable */ mail.ThreadExpandable = session.web.Widget.extend({ template: 'mail.thread.expandable', init: function (parent, datasets, context) { this._super(parent); this.domain = datasets.domain || []; this.options = datasets.options; this.context = _.extend({ default_model: 'mail.thread', default_res_id: 0, default_parent_id: false }, context || {}); // data of this expandable message this.id = datasets.id || -1, this.model = datasets.model || false, this.parent_id = datasets.parent_id || false, this.nb_messages = datasets.nb_messages || 0, this.thread_level = datasets.thread_level || 0, this.type = 'expandable', this.max_limit = this.id < 0 || false, this.flag_used = false, this.parent_thread= parent.messages!= undefined ? parent : this.options._parents[0]; }, start: function () { this._super.apply(this, arguments); this.bind_events(); }, reinit: function () { var $render = $(session.web.qweb.render('mail.thread.expandable', {'widget': this})); this.$el.replaceWith( $render ); this.$el = $render; this.bind_events(); }, /** * Bind events in the widget. Each event is slightly described * in the function. */ bind_events: function () { this.$el.on('click', 'a.oe_msg_fetch_more', this.on_expandable); }, animated_destroy: function (fadeTime) { var self=this; this.$el.fadeOut(fadeTime, function () { self.destroy(); }); }, /*The selected thread and all childs (messages/thread) became read * @param {object} mouse envent */ on_expandable: function (event) { if (event)event.stopPropagation(); if (this.flag_used) { return false } this.flag_used = true; this.animated_destroy(200); this.parent_thread.message_fetch(this.domain, this.context); return false; }, /** * call on_message_delete on his parent thread */ destroy: function () { this._super(); this.parent_thread.on_message_detroy(this); } }); /** * ------------------------------------------------------------ * Thread Message Widget * ------------------------------------------------------------ * This widget handles the display of a messages in a thread. * Displays a record and performs some formatting on the record : * - record.date: formatting according to the user timezone * - record.timerelative: relative time givein by timeago lib * - record.avatar: image url * - record.attachment_ids[].url: url of each attachmentThe * thread view : * - root thread * - - sub message (parent_id = root message) * - - - sub thread * - - - - sub sub message (parent id = sub thread) * - - sub message (parent_id = root message) * - - - sub thread */ mail.ThreadMessage = session.web.Widget.extend({ template: 'mail.thread.message', /** * @param {Object} parent parent * @param {Array} [domain] * @param {Object} [context] context of the thread. It should contain at least default_model, default_res_id. Please refer to the ComposeMessage widget for more information about it. * @param {Object} [options] * @param {Object} [thread] read obout mail.Thread object * @param {Object} [message] * @param {Number} [truncate_limit=250] number of character to * display before having a "show more" link; note that the text * will not be truncated if it does not have 110% of the parameter * @param {Boolean} [show_record_name] *... @param {int} [show_reply_button] number thread level to display the reply button *... @param {int} [show_read_unread_button] number thread level to display the read/unread button */ init: function (parent, datasets, context) { this._super(parent); // record domain and context this.domain = datasets.domain || []; this.context = _.extend({ default_model: 'mail.thread', default_res_id: 0, default_parent_id: false }, context || {}); // record options this.options = datasets.options; // data of this message this.id = datasets.id || -1, this.model = datasets.model || false, this.parent_id = datasets.parent_id || false, this.res_id = datasets.res_id || false, this.type = datasets.type || false, this.is_author = datasets.is_author || false, this.is_private = datasets.is_private || false, this.subject = datasets.subject || false, this.name = datasets.name || false, this.record_name = datasets.record_name || false, this.body = datasets.body || false, this.vote_nb = datasets.vote_nb || 0, this.has_voted = datasets.has_voted || false, this.is_favorite = datasets.is_favorite || false, this.thread_level = datasets.thread_level || 0, this.to_read = datasets.to_read || false, this.author_id = datasets.author_id || [], this.attachment_ids = datasets.attachment_ids || [], this._date = datasets.date; this.show_reply_button = this.options.show_compose_message && this.options.show_reply_button > this.thread_level; this.show_read_unread_button = this.options.show_read_unread_button > this.thread_level; // record options and data this.parent_thread= parent.messages!= undefined ? parent : this.options._parents[0]; this.thread = false; if ( this.id > 0 ) { this.formating_data(); } this.ds_notification = new session.web.DataSetSearch(this, 'mail.notification'); this.ds_message = new session.web.DataSetSearch(this, 'mail.message'); this.ds_follow = new session.web.DataSetSearch(this, 'mail.followers'); }, /* Convert date, timerelative and avatar in displayable data. */ formating_data: function () { //formating and add some fields for render this.date = session.web.format_value(this._date, {type:"datetime"}); this.timerelative = $.timeago(this.date); if (this.type == 'email') { this.avatar = ('/mail/static/src/img/email_icon.png'); } else { this.avatar = mail.ChatterUtils.get_image(this.session, 'res.partner', 'image_small', this.author_id[0]); } for (var l in this.attachment_ids) { var attach = this.attachment_ids[l]; attach['url'] = mail.ChatterUtils.get_attachment_url(this.session, attach); if ((attach.filename || attach.name).match(/[.](jpg|jpg|gif|png|tif|svg)$/i)) { attach.is_image = true; attach['url'] = mail.ChatterUtils.get_image(this.session, 'ir.attachment', 'datas', attach.id); } } }, start: function () { this._super.apply(this, arguments); this.expender(); this.$el.hide().fadeIn(750, function () {$(this).css('display', '');}); this.resize_img(); this.bind_events(); if(this.thread_level < this.options.display_indented_thread) { this.create_thread(); } this.$('.oe_msg_attachments, .oe_msg_images').addClass("oe_hidden"); }, resize_img: function () { var resize = function () { var h = $(this).height(); var w = $(this).width(); if ( h > 100 || w >100 ) { var ratio = 100 / (h > w ? h : w); $(this).attr("width", parseInt( w*ratio )).attr("height", parseInt( h*ratio )); } }; this.$("img").load(resize).each(resize); }, /** * Bind events in the widget. Each event is slightly described * in the function. */ bind_events: function () { var self = this; // event: click on 'Attachment(s)' in msg this.$('.oe_mail_msg_view_attachments').on('click', function (event) { var attach = self.$('.oe_msg_attachments:first, .oe_msg_images:first'); if ( self.$('.oe_msg_attachments:first').hasClass("oe_hidden") ) { attach.removeClass("oe_hidden"); } else { attach.addClass("oe_hidden"); } self.resize_img(); }); // event: click on icone 'Read' in header this.$el.on('click', '.oe_read', this.on_message_read_unread); // event: click on icone 'UnRead' in header this.$el.on('click', '.oe_unread', this.on_message_read_unread); // event: click on 'Delete' in msg side menu this.$el.on('click', '.oe_msg_delete', this.on_message_delete); // event: click on 'Reply' in msg this.$el.on('click', '.oe_reply', this.on_message_reply); // event: click on 'Vote' button this.$el.on('click', '.oe_msg_vote', this.on_vote); // event: click on 'starred/favorite' button this.$el.on('click', '.oe_star', this.on_star); }, /* Call the on_compose_message on the thread of this message. */ on_message_reply:function (event) { event.stopPropagation(); this.create_thread(); this.thread.on_compose_message(); return false; }, expender: function () { this.$('.oe_msg_body:first').expander({ slicePoint: this.options.truncate_limit, expandText: 'read more', userCollapseText: '[^]', detailClass: 'oe_msg_tail', moreClass: 'oe_mail_expand', lessClass: 'oe_mail_reduce', }); }, /** * Instantiate the thread object of this message. * Each message have only one thread. */ create_thread: function () { if (this.thread) { return false; } /*create thread*/ this.thread = new mail.Thread(this, this, { 'domain': this.domain, 'context':{ 'default_model': this.model, 'default_res_id': this.res_id, 'default_parent_id': this.id }, 'options': this.options } ); /*insert thread in parent message*/ this.thread.insertAfter(this.$el); }, /** * Fade out the message and his child thread. * Then this object is destroyed. */ animated_destroy: function (fadeTime) { var self=this; this.$el.fadeOut(fadeTime, function () { self.parent_thread.message_to_expandable(self); }); if (this.thread) { this.thread.$el.fadeOut(fadeTime); } }, /** * Wait a confirmation for delete the message on the DB. * Make an animate destroy */ on_message_delete: function (event) { event.stopPropagation(); if (! confirm(_t("Do you really want to delete this message?"))) { return false; } this.animated_destroy(150); // delete this message and his childs var ids = [this.id].concat( this.get_child_ids() ); this.ds_message.unlink(ids); return false; }, /*The selected thread and all childs (messages/thread) became read * @param {object} mouse envent */ on_message_read_unread: function (event) { event.stopPropagation(); var self=this; if ( (this.to_read && this.options.typeof_thread == 'inbox') || (!this.to_read && this.options.typeof_thread == 'archives')) { this.animated_destroy(150); } // if this message is read, all childs message display is read this.ds_notification.call('set_message_read', [ [this.id].concat( this.get_child_ids() ) , this.to_read, this.context]).then(function () { self.$el.removeClass(self.to_read ? 'oe_msg_unread':'oe_msg_read').addClass(self.to_read ? 'oe_msg_read':'oe_msg_unread'); self.to_read = !self.to_read; }); return false; }, /** * search a message in all thread and child thread. * This method return an object message. * @param {object}{int} option.id * @param {object}{string} option.model * @param {object}{boolean} option._go_thread_wall * private for check the top thread * @return thread object */ browse_message: function (options) { // goto the wall thread for launch browse if (!options._go_thread_wall) { options._go_thread_wall = true; for (var i in this.options._parents[0].messages) { var res=this.options._parents[0].messages[i].browse_message(options); if (res) return res; } } if (this.id==options.id) return this; for (var i in this.thread.messages) { if (this.thread.messages[i].thread) { var res=this.thread.messages[i].browse_message(options); if (res) return res; } } return false; }, /* get all child message id linked. * @return array of id */ get_child_ids: function () { var res=[] if (arguments[0]) res.push(this.id); if (this.thread) { res = res.concat( this.thread.get_child_ids(true) ); } return res; }, /** * add or remove a vote for a message and display the result */ on_vote: function (event) { event.stopPropagation(); var self=this; return this.ds_message.call('vote_toggle', [[self.id]]).then(function (vote) { self.has_voted = vote; self.vote_nb += self.has_voted ? 1 : -1; self.display_vote(); }); return false; }, /** * Display the render of this message's vote */ display_vote: function () { var self = this; var vote_element = session.web.qweb.render('mail.thread.message.vote', {'widget': self}); self.$(".oe_msg_vote:first").remove(); self.$(".oe_mail_vote_count:first").replaceWith(vote_element); }, /** * add or remove a favorite (or starred) for a message and change class on the DOM */ on_star: function (event) { event.stopPropagation(); var self=this; var button = self.$('.oe_star:first'); return this.ds_message.call('favorite_toggle', [[self.id]]).then(function (star) { self.is_favorite=star; if (self.is_favorite) { button.addClass('oe_starred'); } else { button.removeClass('oe_starred'); if ( self.options.typeof_thread == 'stared' ) { self.animated_destroy(150); } } }); return false; }, /** * call on_message_delete on his parent thread */ destroy: function () { this._super(); this.parent_thread.on_message_detroy(this); } }); /** * ------------------------------------------------------------ * Thread Widget * ------------------------------------------------------------ * * This widget handles the display of a thread of messages. The * thread view: * - root thread * - - sub message (parent_id = root message) * - - - sub thread * - - - - sub sub message (parent id = sub thread) * - - sub message (parent_id = root message) * - - - sub thread */ mail.Thread = session.web.Widget.extend({ template: 'mail.thread', /** * @param {Object} parent parent * @param {Array} [domain] * @param {Object} [context] context of the thread. It should contain at least default_model, default_res_id. Please refer to the ComposeMessage widget for more information about it. * @param {Object} [options] * @param {Object} [message] read about mail.ThreadMessage object * @param {Object} [thread] * @param {int} [display_indented_thread] number thread level to indented threads. * other are on flat mode * @param {Select} [typeof_thread] inbox/archives/stared/sent * type of thread and option for user application like animate * destroy for read/unread * @param {Array} [parents] liked with the parents thread * use with browse, fetch... [O]= top parent */ init: function (parent, datasets, options) { this._super(parent); this.domain = options.domain || []; this.context = _.extend({ default_model: 'mail.thread', default_res_id: 0, default_parent_id: false }, options.context || {}); this.options = options.options; this.options._parents = (options.options._parents != undefined ? options.options._parents : []).concat( [this] ); // record options and data this.parent_message= parent.thread!= undefined ? parent : false ; // data of this thread this.id = datasets.id || false, this.model = datasets.model || false, this.parent_id = datasets.parent_id || false, this.is_private = datasets.is_private || false, this.author_id = datasets.author_id || false, this.thread_level = (datasets.thread_level+1) || 0, this.partner_ids = _.filter(datasets.partner_ids, function (partner) { return partner[0]!=datasets.author_id[0]; } ) this.messages = []; this.show_compose_message = this.options.show_compose_message && (this.options.show_reply_button > this.thread_level || !this.thread_level); // object compose message this.compose_message = false; this.ds_thread = new session.web.DataSetSearch(this, this.context.default_model || 'mail.thread'); this.ds_message = new session.web.DataSetSearch(this, 'mail.message'); }, start: function () { this._super.apply(this, arguments); this.bind_events(); }, /* instantiate the compose message object and insert this on the DOM. * The compose message is display in compact form. */ instantiate_compose_message: function () { // add message composition form view if (!this.compose_message) { this.compose_message = new mail.ThreadComposeMessage(this, this, { 'context': this.context, 'options': this.options, }); if (!this.thread_level) { // root view this.compose_message.insertBefore(this.$el); } else if (this.thread_level > this.options.display_indented_thread) { this.compose_message.insertAfter(this.$el); } else { this.compose_message.appendTo(this.$el); } } }, /* When the expandable object is visible on screen (with scrolling) * then the on_expandable function is launch */ on_scroll: function (event) { if (event)event.stopPropagation(); this.$('.oe_msg_expandable:last'); var message = this.messages[this.messages.length-1]; if (message && message.type=="expandable" && message.max_limit) { var pos = message.$el.position(); if (pos.top) { /* bottom of the screen */ var bottom = $(window).scrollTop()+$(window).height()+200; if (bottom > pos.top) { message.on_expandable(); } } } }, /** * Bind events in the widget. Each event is slightly described * in the function. */ bind_events: function () { var self = this; self.$el.on('click', '.oe_mail_list_recipients .oe_more', self.on_show_recipients); self.$el.on('click', '.oe_mail_compose_textarea .oe_more_hidden', self.on_hide_recipients); }, /** *show all the partner list of this parent message */ on_show_recipients: function () { var p=$(this).parent(); p.find('.oe_more_hidden, .oe_hidden').show(); p.find('.oe_more').hide(); }, /** *hide a part of the partner list of this parent message */ on_hide_recipients: function () { var p=$(this).parent(); p.find('.oe_more_hidden, .oe_hidden').hide(); p.find('.oe_more').show(); }, /* get all child message/thread id linked. * @return array of id */ get_child_ids: function () { var res=[]; _(this.get_childs()).each(function (val, key) { res.push(val.id); }); return res; }, /* get all child message/thread linked. * @param {int} nb_thread_level, number of traversed thread level for this search * @return array of thread object */ get_childs: function (nb_thread_level) { var res=[]; if (arguments[1]) res.push(this); if (isNaN(nb_thread_level) || nb_thread_level>0) { _(this.messages).each(function (val, key) { if (val.thread) { res = res.concat( val.thread.get_childs((isNaN(nb_thread_level) ? undefined : nb_thread_level-1), true) ); } }); } return res; }, /** *search a thread in all thread and child thread. * This method return an object thread. * @param {object}{int} option.id * @param {object}{string} option.model * @param {object}{boolean} option._go_thread_wall * private for check the top thread * @param {object}{boolean} option.default_return_top_thread * return the top thread (wall) if no thread found * @return thread object */ browse_thread: function (options) { // goto the wall thread for launch browse if (!options._go_thread_wall) { options._go_thread_wall = true; return this.options._parents[0].browse_thread(options); } if (this.id==options.id) { return this; } if (options.id) { for (var i in this.messages) { if (this.messages[i].thread) { var res=this.messages[i].thread.browse_thread({'id':options.id, '_go_thread_wall':true}); if (res) return res; } } } //if option default_return_top_thread, return the top if no found thread if (options.default_return_top_thread) { return this; } return false; }, /** *search a message in all thread and child thread. * This method return an object message. * @param {object}{int} option.id * @param {object}{string} option.model * @param {object}{boolean} option._go_thread_wall * private for check the top thread * @return message object */ browse_message: function (options) { if (this.options._parents[0].messages[0]) return this.options._parents[0].messages[0].browse_message(options); }, /** *If compose_message doesn't exist, instantiate the compose message. * Call the on_compose_expandable method to allow the user to write his message. * (Is call when a user click on "Reply" button) */ on_compose_message: function () { this.instantiate_compose_message(); this.compose_message.on_compose_expandable(); }, /** *display the message "there are no message" on the thread */ no_message: function () { var no_message = $(session.web.qweb.render('mail.wall_no_message', {})); if (this.options.no_message) { no_message.html(this.options.no_message); } no_message.appendTo(this.$el); }, /** *make a request to read the message (calling RPC to "message_read"). * The result of this method is send to the switch message for sending ach message to * his parented object thread. * @param {Array} replace_domain: added to this.domain * @param {Object} replace_context: added to this.context * @param {Array} ids read (if the are some ids, the method don't use the domain) */ message_fetch: function (replace_domain, replace_context, ids, callback) { var self = this; // domain and context: options + additional fetch_domain = replace_domain ? replace_domain : this.domain; fetch_context = replace_context ? replace_context : this.context; var message_loaded_ids = this.id ? [this.id].concat( self.get_child_ids() ) : self.get_child_ids(); // CHM note : option for sending in flat mode by server var thread_level = this.options.display_indented_thread > this.thread_level ? this.options.display_indented_thread - this.thread_level : 0; return this.ds_message.call('message_read', [ids, fetch_domain, message_loaded_ids, thread_level, fetch_context, this.context.default_parent_id || undefined]) .done(callback ? _.bind(callback, this, arguments) : this.proxy('switch_new_message')); }, /** *create the message object and attached on this thread. * When the message object is create, this method call insert_message for, * displaying this message on the DOM. * @param : {object} data from calling RPC to "message_read" */ create_message_object: function (data) { var self = this; var data = _.extend(data, {'thread_level': data.thread_level ? data.thread_level : self.thread_level}); data.options = _.extend(self.options, data.options); if (data.type=='expandable') { var message = new mail.ThreadExpandable(self, data, { 'default_model': data.model || self.context.default_model, 'default_res_id': data.res_id || self.context.default_res_id, 'default_parent_id': self.id, }); } else { var message = new mail.ThreadMessage(self, data, { 'default_model': data.model, 'default_res_id': data.res_id, 'default_parent_id': data.id, }); } // check if the message is already create for (var i in self.messages) { if (self.messages[i] && self.messages[i].id == message.id) { self.messages[i].destroy(); } } self.messages.push( message ); return message; }, /** *insert the message on the DOM. * All message (and expandable message) are sorted. The method get the * older and newer message to insert the message (before, after). * If there are no older or newer, the message is prepend or append to * the thread (parent object or on root thread for flat view). * The sort is define by the thread_level (O for newer on top). * @param : {object} ThreadMessage object */ insert_message: function (message, dom_insert_after) { var self=this; if (this.show_compose_message && this.options.show_compact_message) { this.instantiate_compose_message(); this.compose_message.do_show_compact(); } this.$('.oe_wall_no_message').remove(); if (dom_insert_after) { message.insertAfter(dom_insert_after); return message } // check older and newer message for insertion var message_newer = false; var message_older = false; if (message.id > 0) { for (var i in self.messages) { if (self.messages[i].id > message.id) { if (!message_newer || message_newer.id > self.messages[i].id) { message_newer = self.messages[i]; } } else if (self.messages[i].id > 0 && self.messages[i].id < message.id) { if (!message_older || message_older.id < self.messages[i].id) { message_older = self.messages[i]; } } } } var sort = (!!self.thread_level || message.id<0); if (sort) { if (message_older) { message.insertAfter(message_older.thread ? (message_older.thread.compose_message ? message_older.thread.compose_message.$el : message_older.thread.$el) : message_older.$el); } else if (message_newer) { message.insertBefore(message_newer.$el); } else if (message.id < 0) { message.appendTo(self.$el); } else { message.prependTo(self.$el); } } else { if (message_older) { message.insertBefore(message_older.$el); } else if (message_newer) { message.insertAfter(message_newer.thread ? (message_newer.thread.compose_message ? message_newer.thread.compose_message.$el : message_newer.thread.$el) : message_newer.$el ); } else if (message.id < 0) { message.prependTo(self.$el); } else { message.appendTo(self.$el); } } return message }, /** *get the parent thread of the messages. * Each message is send to his parent object (or parent thread flat mode) for creating the object message. * @param : {Array} datas from calling RPC to "message_read" */ switch_new_message: function (records) { var self=this; _(records).each(function (record) { var thread = self.browse_thread({ 'id': record.parent_id, 'default_return_top_thread':true }); // create object and attach to the thread object var message = thread.create_message_object( record ); // insert the message on dom thread.insert_message( message ); }); }, /** * this method is call when the widget of a message or an expandable message is destroy * in this thread. The this.messages array is filter to remove this message */ on_message_detroy: function (message) { this.messages = _.filter(this.messages, function (val) { return !val.isDestroyed(); }); }, /** * Convert a destroyed message into a expandable message */ message_to_expandable: function (message) { if (!this.thread_level || message.isDestroyed()) { message.destroy(); return false; } var messages = _.sortBy( this.messages, function (val) { return val.id; }); var it = _.indexOf( messages, message ); var msg_up = messages[it-1]; var msg_down = messages[it+1]; var message_dom = [ ["id", "=", message.id] ]; if ( msg_up && msg_up.type == "expandable" && msg_down && msg_down.type == "expandable") { // concat two expandable message and add this message to this dom msg_up.domain = mail.ChatterUtils.expand_domain( msg_up.domain ); msg_down.domain = mail.ChatterUtils.expand_domain( msg_down.domain ); msg_down.domain = ['|','|'].concat( msg_up.domain ).concat( message_dom ).concat( msg_down.domain ); if ( !msg_down.max_limit ) { msg_down.nb_messages += 1 + msg_up.nb_messages; } msg_up.$el.remove(); msg_up.destroy(); msg_down.reinit(); } else if ( msg_up && msg_up.type == "expandable") { // concat preview expandable message and this message to this dom msg_up.domain = mail.ChatterUtils.expand_domain( msg_up.domain ); msg_up.domain = ['|'].concat( msg_up.domain ).concat( message_dom ); msg_up.nb_messages++; msg_up.reinit(); } else if ( msg_down && msg_down.type == "expandable") { // concat next expandable message and this message to this dom msg_down.domain = mail.ChatterUtils.expand_domain( msg_down.domain ); msg_down.domain = ['|'].concat( msg_down.domain ).concat( message_dom ); // it's maybe a message expandable for the max limit read message if ( !msg_down.max_limit ) { msg_down.nb_messages++; } msg_down.reinit(); } else { // create a expandable message var expandable = new mail.ThreadExpandable(this, { 'id': message.id, 'model': message.model, 'parent_id': message.parent_id, 'nb_messages': 1, 'thread_level': message.thread_level, 'parent_id': message.parent_id, 'domain': message_dom, 'options': message.options, }, { 'default_model': message.model || this.context.default_model, 'default_res_id': message.res_id || this.context.default_res_id, 'default_parent_id': this.id, }); // add object on array and DOM this.messages.push(expandable); expandable.insertAfter(message.$el); } // destroy message message.destroy(); return true; }, }); /** * ------------------------------------------------------------ * mail : root Widget * ------------------------------------------------------------ * * This widget handles the display of messages with thread options. Its main * use is to receive a context and a domain, and to delegate the message * fetching and displaying to the Thread widget. */ session.web.client_actions.add('mail.Widget', 'session.mail.Widget'); mail.Widget = session.web.Widget.extend({ template: 'mail.Widget', /** * @param {Object} parent parent * @param {Array} [domain] * @param {Object} [context] context of the thread. It should * contain at least default_model, default_res_id. Please refer to * the compose_message widget for more information about it. * ... @param {Select} [typeof_thread=(mail|stared|archives|send|other)] * options for destroy message when the user click on a button * @param {Object} [options] *... @param {Number} [truncate_limit=250] number of character to * display before having a "show more" link; note that the text * will not be truncated if it does not have 110% of the parameter *... @param {Boolean} [show_record_name] display the name and link for do action *... @param {int} [show_reply_button] number thread level to display the reply button *... @param {int} [show_read_unread_button] number thread level to display the read/unread button *... @param {int} [display_indented_thread] number thread level to indented threads. * other are on flat mode *... @param {Boolean} [show_compose_message] allow to display the composer *... @param {Boolean} [show_compact_message] display the compact message on the thread * when the user clic on this compact mode, the composer is open *... @param {Array} [message_ids] List of ids to fetch by the root thread. * When you use this option, the domain is not used for the fetch root. * @param {String} [no_message] Message to display when there are no message */ init: function (parent, action) { var options = action.params || {}; this._super(parent); this.domain = options.domain || []; this.context = options.context || {}; this.search_results = {'domain': [], 'context': {}, 'groupby': {}}; this.options = _.extend({ 'typeof_thread' : 'inbox', 'display_indented_thread' : -1, 'show_reply_button' : -1, 'show_read_unread_button' : -1, 'truncate_limit' : 250, 'show_record_name' : false, 'show_compose_message' : false, 'show_compact_message' : false, 'message_ids': undefined, 'no_message': false }, options); if (this.display_indented_thread === false) { this.display_indented_thread = -1; } if (this.show_reply_button === false) { this.show_reply_button = -1; } if (this.show_read_unread_button === false) { this.show_read_unread_button = -1; } }, start: function (options) { this._super.apply(this, arguments); this.message_render(); this.bind_events(); }, /** *Create the root thread and display this object in the DOM. * Call the no_message method then c all the message_fetch method * of this root thread to display the messages. */ message_render: function (search) { this.thread = new mail.Thread(this, {}, { 'domain' : this.domain, 'context' : this.context, 'options': this.options, }); this.thread.appendTo( this.$el ); this.thread.no_message(); this.thread.message_fetch(null, null, this.options.message_ids); if (this.options.show_compose_message) { this.thread.instantiate_compose_message(); if (this.options.show_compact_message) { this.thread.compose_message.do_show_compact(); } else { this.thread.compose_message.do_hide_compact(); } } }, bind_events: function () { if (this.context['typeof_thread']!='other') { $(document).scroll( this.thread.on_scroll ); $(window).resize( this.thread.on_scroll ); window.setTimeout( this.thread.on_scroll, 500 ); } } }); /** * ------------------------------------------------------------ * mail_thread Widget * ------------------------------------------------------------ * * This widget handles the display of messages on a document. Its main * use is to receive a context and a domain, and to delegate the message * fetching and displaying to the Thread widget. * Use Help on the field to display a custom "no message loaded" */ session.web.form.widgets.add('mail_thread', 'openerp.mail.RecordThread'); mail.RecordThread = session.web.form.AbstractField.extend({ template: 'mail.record_thread', init: function () { this._super.apply(this, arguments); this.options.domain = this.options.domain || []; this.options.context = {'default_model': 'mail.thread', 'default_res_id': false}; }, start: function () { this._super.apply(this, arguments); // NB: check the actual_mode property on view to know if the view is in create mode anymore this.view.on("change:actual_mode", this, this._check_visibility); this._check_visibility(); }, _check_visibility: function () { this.$el.toggle(this.view.get("actual_mode") !== "create"); }, render_value: function () { var self = this; if (! this.view.datarecord.id || session.web.BufferedDataSet.virtual_id_regex.test(this.view.datarecord.id)) { this.$('oe_mail_thread').hide(); return; } // update context _.extend(this.options.context, { default_res_id: this.view.datarecord.id, default_model: this.view.model, default_is_private: false }); // update domain var domain = this.options.domain.concat([['model', '=', this.view.model], ['res_id', '=', this.view.datarecord.id]]); var show_compose_message = this.view.is_action_enabled('edit') || (this.getParent().fields.message_is_follower && this.getParent().fields.message_is_follower.get_value()); var message_ids = this.getParent().fields.message_ids && this.getParent().fields.message_ids.get_value(); if (this.root) { this.root.destroy(); } // create and render Thread widget this.root = new mail.Widget(this, { params: { 'domain' : domain, 'context' : this.options.context, 'typeof_thread': this.options.context['typeof_thread'] || 'other', 'display_indented_thread': -1, 'show_reply_button': 0, 'show_read_unread_button': -1, 'show_compose_message': show_compose_message, 'message_ids': message_ids, 'show_compact_message': true, 'no_message': this.node.attrs.help }} ); return this.root.replace(this.$('.oe_mail-placeholder')); }, }); /** * ------------------------------------------------------------ * Wall Widget * ------------------------------------------------------------ * * This widget handles the display of messages on a Wall. Its main * use is to receive a context and a domain, and to delegate the message * fetching and displaying to the Thread widget. */ session.web.client_actions.add('mail.wall', 'session.mail.Wall'); mail.Wall = session.web.Widget.extend({ template: 'mail.wall', /** * @param {Object} parent parent * @param {Object} [options] * @param {Array} [options.domain] domain on the Wall * @param {Object} [options.context] context, is an object. It should * contain default_model, default_res_id, to give it to the threads. */ init: function (parent, action) { this._super(parent); var options = action.params || {}; this.options = options; this.options.domain = options.domain || []; this.options.context = options.context || {}; this.search_results = {'domain': [], 'context': {}, 'groupby': {}} this.ds_msg = new session.web.DataSetSearch(this, 'mail.message'); }, start: function () { this._super.apply(this, arguments); var searchview_ready = this.load_searchview({}, false); var thread_displayed = this.message_render(); this.options.domain = this.options.domain.concat(this.search_results['domain']); this.bind_events(); return $.when(searchview_ready, thread_displayed); }, /** * Load the mail.message search view * @param {Object} defaults ?? * @param {Boolean} hidden some kind of trick we do not care here */ load_searchview: function (defaults, hidden) { var self = this; this.searchview = new session.web.SearchView(this, this.ds_msg, false, defaults || {}, hidden || false); return this.searchview.appendTo(this.$('.oe_view_manager_view_search')).done(function () { self.searchview.on('search_data', self, self.do_searchview_search); }); }, /** * Get the domains, contexts and groupbys in parameter from search * view, then render the filtered threads. * @param {Array} domains * @param {Array} contexts * @param {Array} groupbys */ do_searchview_search: function (domains, contexts, groupbys) { var self = this; this.rpc('/web/session/eval_domain_and_context', { domains: domains || [], contexts: contexts || [], group_by_seq: groupbys || [] }).done(function (results) { self.search_results['context'] = results.context; self.search_results['domain'] = results.domain; self.root.destroy(); return self.message_render(); }); }, /** *Create the root thread widget and display this object in the DOM */ message_render: function (search) { var domain = this.options.domain.concat(this.search_results['domain']); var context = _.extend(this.options.context, search&&search.search_results['context'] ? search.search_results['context'] : {}); this.root = new mail.Widget(this, { params: { 'domain' : domain, 'context' : context, 'typeof_thread': context['typeof_thread'] || 'other', 'display_indented_thread': 1, 'show_reply_button': 10, 'show_read_unread_button': 11, 'show_compose_message': true, 'show_compact_message': false, }} ); return this.root.replace(this.$('.oe_mail-placeholder')); }, bind_events: function () { var self=this; this.$(".oe_write_full").click(function (event) { event.stopPropagation(); var action = { type: 'ir.actions.act_window', res_model: 'mail.compose.message', view_mode: 'form', view_type: 'form', action_from: 'mail.ThreadComposeMessage', views: [[false, 'form']], target: 'new', context: { 'default_content_subtype': 'html', }, }; session.client.action_manager.do_action(action); }); this.$(".oe_write_onwall").click(function(){ self.root.thread.on_compose_message(); }); } }); /** * ------------------------------------------------------------ * UserMenu * ------------------------------------------------------------ * * Add a link on the top user bar for write a full mail */ session.web.ComposeMessageTopButton = session.web.Widget.extend({ template:'mail.compose_message.button_top_bar', start: function (parent, params) { var self = this; this.$el.on('click', 'button', self.on_compose_message ); this._super(parent, params); }, on_compose_message: function (event) { event.stopPropagation(); var action = { type: 'ir.actions.act_window', res_model: 'mail.compose.message', view_mode: 'form', view_type: 'form', action_from: 'mail.ThreadComposeMessage', views: [[false, 'form']], target: 'new', context: { 'default_model': '', 'default_res_id': false, 'default_content_subtype': 'html', }, }; session.client.action_manager.do_action(action); }, }); session.web.UserMenu = session.web.UserMenu.extend({ start: function (parent, params) { var render = new session.web.ComposeMessageTopButton(); render.insertAfter(this.$el); this._super(parent, params); } }); };