source: trunk/expressoMail1_2/js/local_messages.js @ 4939

Revision 4939, 59.1 KB checked in by roberto.santosjunior, 13 years ago (diff)

Ticket #1820 - na função unarchive_mgs escapa o fonte da mensagem antes de chamar o ajax.r4925

Line 
1/**
2 * @author diogenes
3 */
4
5function local_messages() {
6    this.dbGears = null;
7    this.localServer = null;
8    this.store = null;
9    this.filterSerch = "";
10    this.folders = [];
11    this.sortType = "";
12}
13
14function charOrdA (a, b){
15    var primeiro = a[0].toLowerCase();
16    var segundo = b[0].toLowerCase();
17    if (primeiro > segundo) return 1;
18    if (primeiro < segundo) return -1;
19    return 0;
20}
21function charOrdD(a, b){
22    a = a[0].toLowerCase();
23    b = b[0].toLowerCase();
24    if (a<b) return 1;
25    if (a>b) return -1;
26    return 0;
27}
28
29
30function HeaderFlags()
31{
32    this.Answered = 0;
33    //this.Draft = 0;
34    this.Flagged = 0;
35    this.Recent = 0;
36}
37
38HeaderFlags.prototype.getAnswered = function()
39{
40    return this.Answered;
41}
42
43HeaderFlags.prototype.setAnswered = function(answered)
44{
45    this.Answered = answered;
46}
47
48//HeaderFlags.prototype.getDraft = function()
49//{
50//    return this.Draft;
51//}
52
53HeaderFlags.prototype.setDraft = function(draft)
54{
55    this.Draft = draft;
56}
57
58HeaderFlags.prototype.getFlagged = function()
59{
60    return this.Flagged;
61}
62
63HeaderFlags.prototype.setFlagged = function(flagged)
64{
65    this.Flagged = flagged;
66}
67
68HeaderFlags.prototype.getRecent = function()
69{
70    return this.Recent;
71}
72
73HeaderFlags.prototype.setRecent = function(recent)
74{
75    this.Recent = recent;
76}
77
78function FlagsParser(headerObj)
79{
80    this.Header = headerObj;
81}
82
83FlagsParser.prototype.parse = function()
84{
85    var tmp = null;
86    if (typeof this.Header == 'string')
87    {
88        tmp = connector.unserialize(this.Header);
89    }
90    else
91    {
92        tmp = this.Header;
93    }
94
95    flags = new HeaderFlags();
96
97    if (tmp.Answered && tmp.Answered.match(/^A$/))
98    {
99        flags.setAnswered(1);
100    //if (tmp.Draft && tmp.Draft.match(/^X$/))
101    //{
102    //    flags.setDraft(1);
103    //}
104    }
105
106    if (tmp.Flagged && tmp.Flagged.match(/^F$/)){
107        flags.setFlagged(1);
108    }
109
110    if (tmp.Forwarded && tmp.Forwarded.match(/^F$/)){
111        flags.setAnswered(1);
112    //flags.setDraft(1);
113    }
114
115    if (tmp.Recent && tmp.Recent.match(/^R$/)){
116        flags.setRecent(1);
117    }
118
119    return flags;
120
121}
122
123local_messages.prototype.installGears = function (){
124    temp = confirm(get_lang("To use local messages you have to install google gears. Would you like to install it now?"));
125    if (temp && typeof(preferences.googlegears_url) != 'undefined'){
126        if (is_ie)
127            location.href = preferences.googlegears_url + "/gears.exe";
128        else
129            location.href = preferences.googlegears_url + "/gears.xpi";
130        return false;
131    }
132    if (temp) {
133        location.href = "http://gears.google.com/?action=install&message="+
134        get_lang("To use local messages, install Google Gears")+"&return=" + document.location.href;
135    }
136    else return false;
137}
138
139local_messages.prototype.create_objects = function() {
140    if(window.google){
141        if (this.dbGears == null)
142            this.dbGears = google.gears.factory.create('beta.database');
143        if(this.localServer == null)
144            this.localServer = google.gears.factory.create('beta.localserver');
145        if(this.store == null)
146            this.store = this.localServer.createStore('test-store');
147    }
148}
149
150local_messages.prototype.init_local_messages = function(){ //starts only database operations
151               
152    if(this.dbGears==null || this.localServer==null || this.store == null)
153        this.create_objects();
154               
155    var db_in_other_use = true;
156    var start_trying = new Date().getTime();
157    while (db_in_other_use) {
158        try {
159            this.dbGears.open('database-test');
160            db_in_other_use = false;
161        }
162        catch (ex) {
163                                if(new Date().getTime()-start_trying>10000) { //too much time trying, throw an exception
164                                        throw ex;
165        }
166    }
167                }
168                       
169    //          this.dbGears.open('database-test');
170    this.dbGears.execute('create table if not exists folder (folder text,uid_usuario int,unique(folder,uid_usuario))');
171    this.dbGears.execute('create table if not exists mail' +
172        ' (mail blob,original_id int,original_folder text,header blob,timestamp int,uid_usuario int,unseen int,id_folder int,' +
173        ' ffrom text, subject text, fto text, cc text, body text, size int,unique (original_id,original_folder,uid_usuario,id_folder))');
174    this.dbGears.execute('create table if not exists anexo' +
175        ' (id_mail int,nome_anexo text,url text,pid int)');
176    this.dbGears.execute('create table if not exists folders_sync' +
177        ' (id_folder text,folder_name text,uid_usuario int)');
178    this.dbGears.execute('create table if not exists msgs_to_remove (id_msg int,folder text,uid_usuario int)');
179    this.dbGears.execute('create index if not exists idx_user3 on mail (id_folder,uid_usuario,timestamp)');
180    this.dbGears.execute('create INDEX if not exists idx_folder ON folder(uid_usuario,folder)');
181
182    //some people that used old version of local messages could not have the size column. If it's the first version
183    //with local messages you're using in expresso, this part of code can be removed
184    try {
185        this.dbGears.execute('alter table mail add column size int');
186    }catch(Exception) {
187                       
188    }
189    var rs = this.dbGears.execute('select rowid,header from mail where size is null');
190    while(rs.isValidRow()) {
191        var temp = connector.unserialize(rs.field(1));
192                       
193        this.dbGears.execute('update mail set size='+temp.Size+' where rowid='+rs.field(0));
194        rs.next();
195    }
196    //end of temporary code
197
198    try {
199        this.dbGears.execute('begin transaction');
200        this.dbGears.execute('alter table mail add column answered int');
201        //this.dbGears.execute('alter table mail add column draft int');
202        this.dbGears.execute('alter table mail add column flagged int');
203        this.dbGears.execute('alter table mail add column recent int');
204        //this.dbGears.execute('commit transaction');
205        //transaction_ended = true;
206        //if (transaction_ended){
207        rs = null;
208        rs = this.dbGears.execute('select rowid,header from mail');
209
210        // Popular os valores das novas colunas.
211        var tmp = null;
212        //this.dbGears.execute('begin transaction');
213        while(rs.isValidRow()) {
214            //tmp = connector.unserialize(rs.field(1));
215            parser = new FlagsParser(rs.field(1));
216            flags = parser.parse();
217
218            this.dbGears.execute('update mail set answered='+flags.getAnswered()+
219                ',flagged='+flags.getFlagged()+',recent='+flags.getRecent()+
220                //',draft='+flags.getDraft()+' where rowid='+rs.field(0));
221                ' where rowid='+rs.field(0));
222
223            rs.next();
224        }
225        this.dbGears.execute('commit transaction');
226
227    //tmp = null;
228
229    }catch(Exception) {
230        this.dbGears.execute('rollback transaction');
231    }
232
233}
234       
235local_messages.prototype.drop_tables = function() {
236    this.init_local_messages();
237    var rs = this.dbGears.execute('select url from anexo');
238    while(rs.isValidRow()) {
239        this.store.remove(rs.field(0));
240        rs.next();
241    }
242    this.dbGears.execute('drop table folder');
243    this.dbGears.execute('drop table mail');
244    this.dbGears.execute('drop table anexo');
245    this.finalize();
246}
247       
248local_messages.prototype.insert_mail = function(msg_info,msg_header,anexos,folder) {
249    try {
250        this.init_local_messages();
251        var unseen = 0;
252        var login = msg_info.login;
253        var original_id = msg_info.msg_number;
254        var original_folder = msg_info.msg_folder;
255                       
256        //This fields needs to be separeted to search.
257        var from = connector.serialize(msg_info.from);
258        var subject = msg_info.subject;
259        var body = msg_info.body;
260        var to = connector.serialize(msg_info.toaddress2);
261        var cc = connector.serialize(msg_info.cc);
262        var size = msg_header.Size;
263       
264        //do not duplicate this information
265        msg_info.from = null;
266        msg_info.subject = null;
267        msg_info.body = null;
268        msg_info.to = null;
269        msg_info.cc = null;
270        msg_header.Size=null;
271        //If the mail was archieved in the same date the user received it, the date cames with the time.
272        //here I solved it
273        if(msg_header.udate.indexOf(":")!=-1) {
274            msg_header.udate = msg_header.aux_date;
275        }
276                       
277        /**
278                         * The importance attribute can be empty, and javascript consider as null causing nullpointer.
279                         */
280        if((msg_header.Importance == null) ||  (msg_header.Importance == ""))
281            msg_header.Importance = "Normal";
282                       
283        msg_header.aux_date = null;
284                       
285        var mail = connector.serialize(msg_info);
286        var header = connector.serialize(msg_header);
287       
288        var timestamp = msg_info.timestamp;
289        var id_folder;
290       
291        if((folder==null) || (folder=="local_root"))
292            folder = "Inbox";
293        else
294            folder = folder.substr(6);//take off the word "local_"
295                       
296        var rs = this.dbGears.execute("select rowid from folder where folder=? and uid_usuario=?",[folder,account_id]);
297        if(rs.isValidRow())
298            id_folder=rs.field(0);
299        else {
300            this.dbGears.execute("insert into folder (folder,uid_usuario) values (?,?)",["Inbox",account_id]);
301            id_folder = this.dbGears.lastInsertRowId;
302        }
303                       
304        if(msg_info.Unseen=="U")
305            unseen = 1;
306
307        //parse header
308        parser = new FlagsParser(msg_header);
309        flags = parser.parse();
310
311        //insere o e-mail
312        //this.dbGears.execute("insert into mail (mail,original_id,original_folder,header,timestamp,uid_usuario,unseen,id_folder,ffrom,subject,fto,cc,body,size) values (?,?,?,?,?,?,?,?,?,?,?,?,?,?)",[mail,original_id,original_folder,header,timestamp,login,unseen,id_folder,from,subject,to,cc,body,size]);
313        this.dbGears.execute("insert into mail (mail,original_id,original_folder,header,timestamp,uid_usuario,unseen,id_folder,ffrom,subject,fto,cc,body,size,answered,flagged,recent) values (?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?)",[mail,original_id,original_folder,header,timestamp,login,unseen,id_folder,from,subject,to,cc,body,size,flags.getAnswered(),flags.getFlagged(),flags.getRecent()]);
314        var call_back = function() {
315        }
316        this.store.capture(msg_info.url_export_file,call_back);
317        var id_mail = this.dbGears.lastInsertRowId;
318       
319        this.insert_attachments(id_mail,anexos);
320        this.finalize();
321        return true;
322    } catch (error) {
323        this.finalize();
324        return false;
325    }
326
327
328}
329       
330/**
331         * check if ID is no from main tab, if it's from main returns false, else
332         * returns an array with all string in position 0, the mail id in position 1
333         * and the part of string relative to tab in position 2
334         * @param {Object} id_mail
335         */
336local_messages.prototype.parse_id_mail = function(id_mail) {
337    if (this.isInt(id_mail))
338        return false;
339               
340    var matches = id_mail.match(/(.+)(_[a-zA-Z0-9]+)/);
341    return matches;
342}
343       
344local_messages.prototype.isInt = function(x) {
345    var y=parseInt(x);
346    if (isNaN(y)) return false;
347    return x==y && x.toString()==y.toString();
348}
349       
350local_messages.prototype.get_local_mail = function(id_mail) {
351    this.init_local_messages();
352
353    var plus_id = '';
354    var matches = '';
355    if(matches = this.parse_id_mail(id_mail)) { //Mails coming from other tab.
356        id_mail = matches[1];
357        plus_id = matches[2];
358    }
359               
360    var rs = this.dbGears.execute("select mail.rowid,mail.mail,mail.ffrom,mail.subject,mail.body,mail.fto,mail.cc,folder.folder,mail.original_id from mail inner join folder on mail.id_folder=folder.rowid  where mail.rowid="+id_mail);
361    var retorno = null;
362    if(rs.isValidRow()) {
363        retorno = rs.field(1);
364    }
365    retorno = connector.unserialize(retorno);
366
367    //alert('tipo retorno.source: ' + typeof(retorno.source));
368
369    if (typeof(retorno.source) == 'string')
370    {
371        retorno.msg_number=rs.field(0)+plus_id;
372        retorno.original_ID=rs.field(8);
373        retorno.msg_folder=rs.field(7);
374
375    //alert('tipo retorno: '+typeof(retorno))
376    //show_msg(retorno);
377    }
378    else
379    {
380        retorno['from'] = connector.unserialize(rs.field(2));
381        retorno['subject'] = rs.field(3);
382        retorno['body'] = rs.field(4);
383        //Codigo que as imagens embutidas em emails (com multipart/related ou multipart/mixed) sejam corretamente mostradas em emails arquivados. Os links do
384        //tipo "./inc/show_embedded_attach.php?msg_folder=[folder]&msg_num=[msg_num]&msg_part=[part]"
385        //são substituidos pelos links dos anexos capturados pelo gears.
386
387        var thumbs= retorno.thumbs;
388        var anexos= retorno.array_attach;
389        for (i in anexos)
390        {
391            if(anexos[i]['url'] && anexos[i]['url'].match(/((jpg)|(jpeg)|(png)|(gif)|(bmp))/gi))
392            {
393                var er_imagens = new RegExp("\\.\\/inc\\/show_embedded_attach.php\\?msg_folder=[\\w/]+\\&msg_num=[0-9]+\\&msg_part="+anexos[i]['pid']);
394                var Result_imagens = er_imagens.exec(retorno['body']);
395                retorno['body'] = retorno['body'].replace(Result_imagens,anexos[i]['url']);
396                if(thumbs && thumbs[i]){
397                    er_imagens = new RegExp("\\.\\/inc\\/show_thumbs.php\\?file_type=image\\/[\\w]+\\&msg_num=[0-9]+\\&msg_folder=[\\w/%]+\\&msg_part="+anexos[i]['pid']);
398                    Result_imagens = er_imagens.exec(thumbs[i]);
399                    thumbs[i] = thumbs[i].replace(Result_imagens,"'"+anexos[i]['url']+"'");
400                    er_imagens = new RegExp("\\.\\/inc\\/show_img.php\\?msg_num=[0-9]+\\&msg_folder=[\\w/%]+\\&msg_part="+anexos[i]['pid']);
401                    Result_imagens = er_imagens.exec(thumbs[i]);
402                    thumbs[i] = thumbs[i].replace(Result_imagens,anexos[i]['url']);
403                    thumbs[i] = thumbs[i].replace(/<IMG/i,'<img width="120"');
404                }
405            }
406        }
407
408        retorno['to'] = connector.unserialize(rs.field(5));
409        retorno['cc'] = connector.unserialize(rs.field(6));
410
411        retorno['local_message'] = true;
412        retorno['msg_folder'] = "local_"+rs.field(7); //Now it's a local folder
413        retorno['msg_number'] = rs.field(0)+plus_id; //the message number is the rowid
414
415    }
416
417    rs.close();
418    this.finalize();
419    return retorno;
420}
421
422local_messages.prototype.insert_attachments = function(id_msg,anexos) {
423    //insert_mail already close and open gears.
424    for (var i = 0; i < anexos.length; i++) {
425        this.dbGears.execute("insert into anexo (id_mail,nome_anexo,url,pid) values (?,?,?,?)", [id_msg, anexos[i]['name'],anexos[i]['url'],anexos[i]['pid']]);
426        this.capt_url(anexos[i]['url']);
427    }
428}
429
430local_messages.prototype.capt_url = function (url) {
431    //insert_mail already close and open gears.
432    var call_back = function(url,success,captureId) {
433    //alert("Capturado: " + url);
434    }
435    //alert(url);
436    this.store.capture(url,call_back);
437}
438
439local_messages.prototype.strip_tags = function (str) {
440    return str.replace(/<\/?[^>]+>/gi, '');
441}
442
443local_messages.prototype.get_local_range_msgs = function(folder,msg_range_begin,emails_per_page,sort,sort_reverse,search,preview_msg_subject,preview_msg_tip) {
444
445    this.init_local_messages();
446    var retorno = new Array();
447    msg_range_begin--;
448               
449    mail_filter = " ";
450    if(search=="FLAGGED") {
451        mail_filter = "and (header like '%\"Flagged\";s:1:\"F%' or header like '%\"Importance\";s:5:\"High%') ";
452    }
453    if(search=="UNSEEN") {
454        mail_filter = "and unseen = 1 ";
455    }
456    if(search=="SEEN") {
457        mail_filter = "and unseen = 0 ";
458    }
459    if (search=="ANSWERED") {
460        mail_filter = "and header like '%\"Answered\";s:1:\"A%' ";
461    }
462               
463        sql = 'select mail.rowid as rowid,mail.header as header,mail.size as size,' +
464    'mail.timestamp as timestamp,mail.unseen as unseen,mail.body as body, mail.mail as mail, ' +
465    'case when lower(mail.ffrom) like ? then ' +
466    'case when ltrim(ltrim(substr(UPPER(fto),7,length(fto)),\':\'),\'"\') like \'5:%\' then ' +
467    'substr(ltrim(ltrim(substr(UPPER(fto),7,length(fto)),\':\'),\'"\'),17) ' +
468    'else ' +
469    'ltrim(ltrim(substr(UPPER(fto),7,length(fto)),\':\'),\'"\') ' +
470    'end ' +
471    'else ' +
472    'case when ltrim(ltrim(substr(UPPER(ffrom),21,length(ffrom)),\':\'),\'"\')  like \'5:%\' then ' +
473    'substr(ltrim(ltrim(substr(UPPER(ffrom),21,length(ffrom)),\':\'),\'"\'),17) ' +
474    'else ' +
475    'ltrim(ltrim(substr(UPPER(ffrom),21,length(ffrom)),\':\'),\'"\') ' +
476    'end ' +
477    'end as order_from,mail.subject from mail inner join folder on mail.id_folder=folder.rowid where mail.uid_usuario=? and folder.folder=? ' +
478    mail_filter + ' order by ';
479               
480    if(sort == 'SORTFROM') {
481        sql += 'order_from ';
482    }
483    if(sort == 'SORTARRIVAL') {
484        sql += 'timestamp ';
485    }
486    if(sort == 'SORTSIZE') {
487        sql += 'size ';
488    }
489    if(sort == 'SORTSUBJECT') {
490        sql += 'UPPER(subject) ';
491    }
492
493
494    sql+= sort_reverse==0?"ASC ":"DESC ";
495    sql +='limit ?,? ';
496
497
498    var rs = this.dbGears.execute(sql,['%'+Element("user_email").value+'%',account_id,folder,msg_range_begin,emails_per_page]);
499    var cont = 0;
500               
501    var rs3 = this.dbGears.execute('select count(*) from mail inner join folder on mail.id_folder=folder.rowid where mail.uid_usuario=? and folder.folder=?'+mail_filter,[account_id,folder]);
502                               
503    while (rs.isValidRow()) {
504        //var email = rs.field(1);
505        var head = rs.field(1);
506        var codigoMail = rs.field(0);
507        var mail = rs.field(6);
508
509        var msg_body = rs.field(5);//recebe o conteudo da coluna "body" do banco de dados;
510
511        var rs2 = this.dbGears.execute('select count(*) from anexo where id_mail = '+codigoMail);
512        var head_unserialized = connector.unserialize(head);
513        var mail_unserialized = connector.unserialize(mail);
514
515      head_unserialized.Size = rs.field(2);
516        if(rs.field(4)==1)
517            head_unserialized.Unseen = 'U';
518                       
519
520        head_unserialized.subject=(head_unserialized.subject==null)?"":unescape(head_unserialized.subject);
521
522        //var email_unserialized = connector.unserialize(email);
523        retorno[cont] = head_unserialized;
524        retorno[cont]['msg_number'] = codigoMail;
525        retorno[cont]['msg_day'] = mail_unserialized.msg_day;
526        retorno[cont]['msg_hour'] = mail_unserialized.msg_hour;
527        //declaracao do array() para receber o body de cada mensagem encontrada na busca sql realizada;
528
529        retorno[cont]['msg_sample'] = new Array();
530
531        if( (preview_msg_subject == 0) && (preview_msg_tip == 0) )
532        {
533            retorno[cont]['msg_sample']['body'] = "";
534        }
535        else
536        {
537            msg_body += ">";
538            msg_body=this.strip_tags(msg_body);
539            msg_body=msg_body.replace(/\&nbsp;/ig," ");
540            retorno[cont]['msg_sample']['body'] = " - " + msg_body.substr(2,msg_body.length-1);
541        }
542
543        cont++;
544        rs.next();
545    }
546    retorno['num_msgs'] = rs3.field(0);
547    rs3.close();
548    rs.close();
549    if(cont>0)
550        rs2.close();
551    this.finalize();
552    return retorno;
553}
554       
555local_messages.prototype.get_url_anexo = function(msg_number,pid) {
556    this.init_local_messages();
557    var matches = '';
558    if(matches = this.parse_id_mail(msg_number)) {
559        msg_number = matches[1];
560    }
561               
562    var retorno;
563    var rs = this.dbGears.execute("select url from anexo where id_mail="+msg_number+" and pid = '"+pid+"'");
564    retorno = rs.field(0)
565    this.finalize();
566               
567    return retorno;
568}
569
570local_messages.prototype.getInputFileFromAnexo = function (element,url) {
571    this.init_local_messages();
572    fileSubmitter = this.store.createFileSubmitter();
573    fileSubmitter.setFileInputElement(element,url);
574    this.finalize();
575}
576
577local_messages.prototype.finalize = function() {
578    this.dbGears.close();
579    this.dbGears = null;
580}
581
582local_messages.prototype.delete_msgs = function(msgs_number,border_ID) {
583    this.init_local_messages();
584    var rs = this.dbGears.execute("select url from anexo where id_mail in ("+msgs_number+")");
585    while(rs.isValidRow()) {
586        this.store.remove(rs.field(0));
587        rs.next();
588    }
589    this.dbGears.execute("delete from anexo where id_mail in ("+msgs_number+")");
590    this.dbGears.execute("delete from mail where rowid in ("+msgs_number+")");
591    this.finalize();
592    if (msgs_number.length == 1)
593        write_msg(get_lang("The message was deleted."));
594    else
595        write_msg(get_lang("The messages were deleted."));
596               
597    mail_msg = Element("tbody_box");
598
599    try {
600        msgs_exploded = msgs_number.split(",");
601    }catch(error) {
602        msgs_exploded = new Array();
603        msgs_exploded[0] = msgs_number;
604    }
605    var msg_to_delete;
606    for (var i=0; i<msgs_exploded.length; i++){
607        msg_to_delete = Element(msgs_exploded[i]);
608        if (msg_to_delete){
609            if ( (msg_to_delete.style.backgroundColor != '') && (preferences.use_shortcuts == '1') )
610                select_msg('null', 'down');
611            mail_msg.removeChild(msg_to_delete);
612            decrement_folder_unseen();
613        }
614    }
615    Element('chk_box_select_all_messages').checked = false;
616    if (border_ID != 'null')
617        delete_border(border_ID,'false');
618               
619}
620       
621local_messages.prototype.get_source_msg = function(id_msg) {
622    this.init_local_messages();
623    var rs = this.dbGears.execute("select mail from mail where rowid="+id_msg);
624
625
626    mail = connector.unserialize(rs.field(0));
627    download_local_attachment(mail.url_export_file)
628
629    this.finalize();
630}
631       
632       
633       
634local_messages.prototype.set_messages_flag = function(msgs_number, flag) {
635    this.init_local_messages();
636        var no_errors = true;
637        var rowids_to_set; // rows ids
638    var msgs_to_set; // messages ids
639        var one_message = false;
640    if (msgs_number == 'get_selected_messages') {
641                msgs_to_set = get_selected_messages();
642                rowids_to_set = msgs_to_set.split(",");
643                msgs_to_set = msgs_to_set.replace(/_s[^,]*/g,"").split(",");
644    }
645    else {
646        if(isNaN(parseInt(msgs_number))){       //message(s) sent to function
647            rowids_to_set = msgs_number.split(",");
648            msgs_to_set = msgs_number.replace(/_s[^,]*/g,"").split(",");
649            if (msgs_to_set.length==1) {
650                            //Just one message
651                one_message = true;
652            }
653        }else{
654            rowids_to_set = new Array();
655            msgs_to_set = new Array()
656            msgs_to_set[0] = parseInt(msgs_number);
657            rowids_to_set[0] = parseInt(msgs_number);
658            one_message = true;
659        }
660    }
661    for (var i in msgs_to_set) {
662                       
663        var matches = '';//Messages comming from other tabs.
664        if(matches === this.parse_id_mail(msgs_to_set[i])) {
665            msgs_to_set[i] = matches[1];
666        }
667                       
668        var rs = this.dbGears.execute("select header,unseen,mail,flagged,answered from mail where rowid=" + msgs_to_set[i]);
669        header = connector.unserialize(rs.field(0));
670        var mail = connector.unserialize(rs.field(2));
671        unseen = rs.field(1);
672        flagged = rs.field(3);
673        answered = rs.field(4);
674        switch(flag) {
675            case "unseen":
676                        set_msg_as_unread(rowids_to_set[i]);
677                        header["Unseen"] = "U";
678                        mail["Unseen"] = "U";
679                        mail["header"]["Unseen"] = "U";
680                        unseen = 1;
681                        break;
682            case "flagged":
683                        set_msg_as_flagged(rowids_to_set[i]);
684                        header["Flagged"] = "F";
685                        mail["Flagged"] = "F";
686                        mail["header"]["Flagged"] = "F";
687                        flagged = 1;
688                        break;
689            case "unflagged":
690                        if (header["Importance"].indexOf("High") != -1)
691                                no_errors = false;
692                        else {
693                            set_msg_as_unflagged(rowids_to_set[i]);
694                            header["Flagged"] = "N";
695                                mail["Flagged"] = "N";
696                                mail["header"]["Flagged"] = "N";
697                        }
698                        flagged = 0;
699                break;
700            case "seen":
701                        header["Unseen"] = "N";
702                        mail["Unseen"] = "N";
703                        mail["header"]["Unseen"] = "N";
704                        set_msg_as_read(rowids_to_set[i],true);
705                        unseen = 0;
706                        break;
707            case "answered":
708                        header["Draft"]="";
709                        mail["Draft"] = "";
710                        mail["header"]["Draft"] = "";
711                        header["Answered"]="A";
712                        mail["Answered"] = "A";
713                        mail["header"]["Answered"] = "A";
714                        Element("td_message_answered_"+msgs_to_set[i]).innerHTML = '<img src=templates/default/images/answered.gif title=Respondida>';
715                        answered = 1;
716                break;
717            case "forwarded":
718                        header["Draft"]="X";
719                        mail["Draft"] = "X";
720                        mail["header"]["Draft"] = "X";
721                        header["Answered"]="A";
722                        mail["Answered"] = "A";
723                        mail["header"]["Answered"] = "A";
724                        Element("td_message_answered_"+msgs_to_set[i]).innerHTML = '<img src=templates/default/images/forwarded.gif title=Encaminhada>';
725                        answered = 1;
726                        break;
727        }
728               
729        rs.close();
730                       
731        if(Element("check_box_message_" + rowids_to_set[i]))
732            Element("check_box_message_" + rowids_to_set[i]).checked = false;
733        var smail=connector.serialize(mail);
734        smail =smail.replace(/([^'])'([^'])('?)/g,"$1''$2$3$3");
735        try{
736            this.dbGears.execute("update mail set mail='"+smail+"',header='"+connector.serialize(header)+
737                "',unseen="+unseen+",flagged="+flagged+",answered="+answered+
738                " where rowid="+msgs_to_set[i]);
739        }catch(e){
740            this.dbGears.execute("update mail set header='"+connector.serialize(header)+
741                "',unseen="+unseen+",flagged="+flagged+",answered="+answered+
742                " where rowid="+msgs_to_set[i]);
743        }
744    }
745    if(Element('chk_box_select_all_messages'))
746        Element('chk_box_select_all_messages').checked = false;
747    this.finalize();
748        if (!no_errors) {
749                if(one_message)
750                        write_msg(get_lang("this message cant be marked as normal"));
751                else
752                        write_msg(get_lang("At least one of selected message cant be marked as normal"));
753                return false;
754        }
755        return true;
756
757}
758       
759local_messages.prototype.set_message_flag = function(msg_number,flag,func_after_flag_change) {
760    no_errors = this.set_messages_flag(msg_number,flag);
761        if(no_errors && func_after_flag_change)
762                func_after_flag_change(true);
763}
764       
765local_messages.prototype.get_unseen_msgs_number = function() {
766    this.init_local_messages();
767    var rs = this.dbGears.execute("select count(*) from mail where unseen=1");
768    var retorno = rs.field(0);
769    rs.close();
770    this.finalize();
771    return retorno;
772}
773
774local_messages.prototype.create_folder = function(folder) {
775
776    if (folder.indexOf("local_") != -1)
777        return false; //can't create folder with string local_
778
779    this.init_local_messages();
780    try {
781        this.dbGears.execute("insert into folder (folder,uid_usuario) values (?,?)",[folder,account_id]);
782    } catch (error) {
783        this.finalize();
784        return false;
785    }
786    this.finalize();
787    return true;
788}
789
790local_messages.prototype.list_local_folders = function(folder) {
791    this.init_local_messages();
792    var retorno = new Array();
793    var retorno_defaults = new Array();
794    rs = this.dbGears.execute("select folder,rowid from folder where uid_usuario=?",[account_id]);
795//    rs = this.dbGears.execute("select folder.folder,sum(mail.unseen) from folder left join mail on "+
796//      "folder.rowid=mail.id_folder where folder.uid_usuario=? group by folder.folder",[account_id]);
797    var achouInbox = false,achouSent = false ,achouSentConf = false,achouTrash = false,achouDrafts = false;
798    while(rs.isValidRow()) {
799        var temp = new Array();
800        if (rs.field(0).indexOf('/') == 0){
801               var rs1 = this.dbGears.execute('update folder set folder=? where rowid=?',[rs.field(0).slice(1),rs.field(1)]);
802               temp[0] = rs.field(0).slice(1);
803               rs1.close();
804       }else{
805           temp[0] = rs.field(0);
806       }
807
808        var rs2 = this.dbGears.execute("select count(*) from mail where id_folder=? and unseen=1",[rs.field(1)]);
809         rs2.field(0)? temp[1] = rs2.field(0):temp[1]=0;
810
811        var rs3 = this.dbGears.execute("select * from folder where folder like ? limit 1",[temp[0]+"/%"]);
812        if(rs3.isValidRow())
813            temp[2] = 1;
814        else
815            temp[2] = 0;
816
817        if(sentfolder ==  preferences.save_in_folder.replace("INBOX/","") || preferences.save_in_folder.replace("INBOX/","") == trashfolder || preferences.save_in_folder.replace("INBOX/","") == draftsfolder)
818            achouSentConf= true;
819
820        switch (temp[0]) {
821            case 'Inbox':
822                retorno_defaults[0] = temp;
823                achouInbox = true;
824                break;
825            case sentfolder :
826                retorno_defaults[1] = temp;
827                achouSent = true;
828                break;
829            case trashfolder:
830                retorno_defaults[3] = temp;
831                achouTrash = true;
832                break;
833            case draftsfolder:
834                retorno_defaults[4] = temp;
835                achouDrafts = true;
836                break;
837            case preferences.save_in_folder.replace("INBOX/",""):
838                retorno_defaults[2] = temp;
839                achouSentConf = true;
840                break;
841            default:
842                retorno.push(temp);
843        }
844
845        rs.next();
846    }
847
848    rs.close();
849    this.finalize();
850
851    if(preferences.auto_create_local=='0' || (achouInbox && achouSent && achouSentConf && achouTrash && achouDrafts)){
852        var retorno_final = retorno_defaults.concat(retorno.sort(charOrdA));
853        return retorno_final;
854    }else{
855        if(!achouInbox)
856            this.create_folder('Inbox');
857        if(!achouSent)
858            this.create_folder(sentfolder);
859        if(!achouTrash)
860            this.create_folder(trashfolder);
861        if(!achouDrafts)
862            this.create_folder(draftsfolder);
863        if(!achouSentConf)
864            this.create_folder(preferences.save_in_folder.replace("INBOX/",""));
865        return this.list_local_folders();
866    }
867
868}
869local_messages.prototype.rename_folder = function(folder,old_folder) {
870    if (folder.indexOf("local_") != -1)
871        return false; //can't create folder with string local_
872    this.init_local_messages();
873    if (old_folder.indexOf("/") != "-1") {
874        final_pos = old_folder.lastIndexOf("/");
875        folder = old_folder.substr(0, final_pos) + "/" + folder;
876    }
877    try {
878        this.dbGears.execute("update folder set folder=? where folder=? and uid_usuario=?",[folder,old_folder,account_id]);
879    } catch (error) {
880        this.finalize();
881        return false;
882    }
883    rs = this.dbGears.execute("select folder from folder where folder like ? and uid_usuario=?",[old_folder+'/%',account_id]);
884    while(rs.isValidRow()) {
885        folder_tmp = rs.field(0);
886        folder_new = folder_tmp.replace(old_folder,folder);
887        this.dbGears.execute("update folder set folder=? where folder=?",[folder_new,folder_tmp]);
888        rs.next();
889    }
890
891
892    this.finalize();
893    return true;
894}
895       
896local_messages.prototype.remove_folder = function(folder) {
897    this.init_local_messages();
898    var rs = this.dbGears.execute("select count(rowid) from folder where folder like ? and uid_usuario=?",[folder+"/%",account_id]);
899    var sons = rs.field(0);
900    rs.close();
901
902    if(sons == 0){
903                var rs = this.dbGears.execute("select rowid from folder where folder=? and uid_usuario=?",[folder,account_id]);
904                var folder_id = rs.field(0);
905                rs.close();
906                this.dbGears.execute("delete from folder where rowid=?",[folder_id]);
907                rs = this.dbGears.execute("select rowid,mail from mail where id_folder=?",[folder_id]);
908                while(rs.isValidRow()) {
909                    var rs2 = this.dbGears.execute("select url from anexo where id_mail=?",[rs.field(0)]);
910                    while(rs2.isValidRow()) {
911                        this.store.remove(rs2.field(0));
912                        rs2.next();
913                    }
914                    rs2.close();
915                    this.dbGears.execute("delete from anexo where id_mail=?",[rs.field(0)]);
916                    var mail = connector.unserialize(rs.field(1));
917                    this.store.remove(mail.url_export_file);
918                    rs.next();
919                }
920                rs.close();
921                this.dbGears.execute("delete from mail where id_folder=?",[folder_id]);
922                this.finalize();
923                return true;
924    }else  {
925                this.finalize();
926                return false;
927    }
928
929}
930
931local_messages.prototype.move_messages = function(new_folder,msgs_number) {
932    this.init_local_messages();
933    var rs = this.dbGears.execute("select rowid from folder where folder=? and uid_usuario=?",[new_folder,account_id]);
934    var id_folder = rs.field(0);
935    rs.close();
936    this.dbGears.execute("update mail set id_folder="+id_folder+" where rowid in ("+msgs_number.toString()+")"); //usando statement não tava funcionando quando tinha mais de um email...
937    this.finalize();
938}
939
940local_messages.prototype.setFolders = function(sFolders)
941{
942    this.folders = sFolders;
943}
944
945local_messages.prototype.getFolders = function()
946{
947    return this.folders;
948}
949
950local_messages.prototype.setFilter = function(sFilter)
951{
952        this.filterSerch = sFilter;
953}
954
955local_messages.prototype.getFilter = function()
956{
957        return this.filterSerch;
958}
959
960local_messages.prototype.setSortType = function (sortType){
961    this.sortType = sortType;
962}
963
964local_messages.prototype.getSortType = function (){
965    if (this.sortType == "")
966    {
967        return 'SORTDATE';
968    }
969    return this.sortType;
970}
971
972local_messages.prototype.search = function(folders,sFilter) {
973    this.init_local_messages();
974    //sFilter = unescape(sFilter);
975    this.setFilter(sFilter);
976    this.setFolders(folders);
977    var filters = sFilter.replace(/^##|##$/g,"").split('##');
978    var friendly_filters = new Array();
979
980    if (sFilter.indexOf('ALL') != -1) { //all filters...
981        filters[0] = sFilter.replace(/##/g,"");
982        tmp = filters[0].split("<=>");
983
984        searchKey = new Array();
985        searchKey.push("SUBJECT");
986        searchKey.push(tmp[1]);
987        friendly_filters.push(searchKey);
988
989        searchKey = new Array();
990        searchKey.push("BODY");
991        searchKey.push(tmp[1]);
992        friendly_filters.push(searchKey);
993
994        searchKey = new Array();
995        searchKey.push("FROM");
996        searchKey.push(tmp[1]);
997        friendly_filters.push(searchKey);
998
999        searchKey = new Array();
1000        searchKey.push("TO");
1001        searchKey.push(tmp[1]);
1002        friendly_filters.push(searchKey);
1003
1004        searchKey = new Array();
1005        searchKey.push("CC");
1006        searchKey.push(tmp[1]);
1007        friendly_filters.push(searchKey);
1008    }
1009    else {
1010        for (var i=0; i<filters.length; i++)
1011        {
1012            if (filters[i] != ""){
1013                //tmp[0] = tmp[0].replace(/^\s+|\s+$/g,"");
1014                //tmp[1] = tmp[1].replace(/^\s+|\s+$/g,"");
1015                friendly_filters.push(filters[i].split("<=>"));
1016            }
1017        }
1018    }
1019    var sql = "select mail.header,folder.folder,mail.rowid,size from mail inner join folder on mail.id_folder=folder.rowid where mail.uid_usuario="+account_id + " and folder.folder in (";
1020    for(var fnum in folders) {
1021        sql+="'"+folders[fnum]+"'";
1022        if(fnum<folders.length-1)
1023            sql+=",";
1024    }
1025    sql += ") and (";
1026    for (var z=0;z<friendly_filters.length;z++) {
1027        if (z != 0) {
1028            if (sFilter.indexOf('ALL') != -1)
1029                sql += " or";
1030            else
1031                sql += " and";
1032        }
1033        var cond = friendly_filters[z][0].replace(/^\s+|\s+$/g,"");
1034        if (cond == "SINCE" || cond == "BEFORE" | cond == "ON"){
1035
1036            tmpDate = friendly_filters[z][1].replace(/\%2F/g,"/").split('/');
1037
1038            // Date = url_decode(friendly_filters[z][1]);
1039            sql+=" mail.timestamp " + this.aux_convert_filter_field(friendly_filters[z][0], tmpDate);
1040        }
1041        else if (!friendly_filters[z][1])
1042        {
1043            sql+=" mail."+this.aux_convert_filter_field(friendly_filters[z][0]);
1044        }
1045        else
1046        {
1047            sql+=" mail."+this.aux_convert_filter_field(friendly_filters[z][0])+" like '%"+url_decode_s(friendly_filters[z][1])+"%'";
1048        }
1049    }
1050    sql += ")";
1051
1052    // Sort
1053    if (this.getSortType().match('^SORTDATE.*')){
1054        sql += " order by mail.timestamp";
1055    }
1056    else if (this.getSortType().match('^SORTWHO.*')){
1057        sql += " order by mail.ffrom";
1058    }
1059    else if (this.getSortType().match('^SORTSUBJECT.*')){
1060        sql += " order by mail.subject";
1061    }
1062    else if (this.getSortType().match('^SORTSIZE.*')){
1063        sql += " order by mail.size";
1064    }
1065    else if (this.getSortType().match('^SORTBOX.*')){
1066        sql += " order by folder.folder";
1067    }
1068
1069    sql += this.getSortType().match('^.*_REVERSE$') ? ' asc' : ' desc';
1070
1071    var rs = this.dbGears.execute(sql);
1072    var retorno = [];
1073    var numRec = 0;
1074   
1075    while( rs.isValidRow() )
1076    {
1077                var header                      = connector.unserialize( rs.field(0) );
1078                var date_formated       = ( header["udate"] ).toString();
1079                /*
1080                 * Antigamente o udate vinha com o formato de data e foi alterado para vir o timestamp.
1081                 * Nesse caso, e-mails arquivados anteriormente usamos o udate, caso contrario, usamos o smalldate,
1082                 * pois o udate agora vem como timestamp
1083                 * verifica tambem no caso de mensagens antigas que nao exista o smalldate
1084                 * definir
1085                */
1086                if( !date_formated.match(/\d{2}\/\d{2}\/\d{4}/) )
1087                {
1088                    if ( (typeof(header["smalldate"]) != "undefined") && (!header["smalldate"].match(/\d{2}\:\d{2}/) ) ){
1089                            date_formated = header["smalldate"];
1090                    }else{
1091                            var day = new Date();
1092                            day.setTime(header["udate"] * 1000);
1093                            aux_dia = day.getDate() < 10 ? '0' + day.getDate() : day.getDate();
1094                            aux_mes = day.getMonth()+1; // array start with '0..11'
1095                            aux_mes = aux_mes < 10 ? '0' + aux_mes : aux_mes;
1096                            date_formated = aux_dia + '/' +  aux_mes + '/' + day.getFullYear();
1097                    }
1098                }
1099
1100                retorno[ numRec++ ] =
1101                {
1102                        'from'          : header["from"]["name"],
1103                        'subject'       : unescape(header["subject"]),
1104                        'udate'         : date_formated,
1105                        'size'          : rs.field(3),
1106                        'flag'          : header["Unseen"]+header["Recent"]+header["Flagged"]+header["Draft"],
1107                        'boxname'       : "local_"+rs.field(1),
1108                        'uid'           : rs.field(2)
1109                }
1110
1111                rs.next();
1112    }
1113
1114    this.finalize();
1115
1116    return ( retorno.length > 0 ) ? retorno : false ;
1117}
1118       
1119local_messages.prototype.aux_convert_size = function(size) {
1120    var tmp = Math.floor(size/1024);
1121    if(tmp >= 1){
1122        return tmp + " kb";
1123    }else{
1124        return size + " b";
1125    }
1126               
1127}
1128       
1129local_messages.prototype.aux_convert_filter_field = function(filter,date)
1130{
1131        var dateObj;
1132   
1133        if (typeof date != 'undefined')
1134    {
1135        dateObj = new Date(date[2],date[1]-1,date[0]);
1136    }
1137
1138    if((filter=="SUBJECT ") || (filter=="SUBJECT"))
1139        return "subject";
1140    else if((filter=="BODY ") || (filter=="BODY"))
1141        return "body";
1142    else if((filter=="FROM ") || (filter=="FROM"))
1143        return "ffrom";
1144    else if((filter=="TO ") || (filter=="TO"))
1145        return "fto";
1146    else if((filter=="CC ") || (filter=="CC"))
1147        return "cc";
1148    else if (filter.replace(/^\s+|\s+$/g,"") == "SINCE"){
1149        dateObj.setHours(0, 0, 0, 0);
1150        return ">= " + dateObj.getTime().toString(10).substr(0, 10);
1151    }
1152    else if (filter.replace(/^\s+|\s+$/g,"") == "BEFORE"){
1153        dateObj.setHours(23, 59, 59, 999);
1154        return "<= " + dateObj.getTime().toString(10).substr(0, 10);
1155    }
1156    else if (filter.replace(/^\s+|\s+$/g,"") == "ON"){
1157        dateObj.setHours(0, 0, 0, 0);
1158        var ts1 = dateObj.getTime().toString(10).substr(0, 10);
1159        dateObj.setHours(23, 59, 59, 999);
1160        var ts2 = dateObj.getTime().toString(10).substr(0, 10);
1161        return ">= " + ts1 + ") and (timestamp <= " + ts2;
1162    }
1163    else if (filter.replace(/^\s+|\s+$/g,"") == "FLAGGED")
1164        return "flagged = 1";
1165    else if (filter.replace(/^\s+|\s+$/g,"") == "UNFLAGGED")
1166        return "flagged = 0";
1167    else if (filter.replace(/^\s+|\s+$/g,"") == "UNSEEN")
1168        return "unseen = 1";
1169    else if (filter.replace(/^\s+|\s+$/g,"") == "SEEN")
1170        return "unseen = 0";
1171    else if (filter.replace(/^\s+|\s+$/g,"") == "ANSWERED")
1172        return "answered = 1";
1173    else if (filter.replace(/^\s+|\s+$/g,"") == "UNANSWERED")
1174        return "answered = 0";
1175    else if (filter.replace(/^\s+|\s+$/g,"") == "RECENT")
1176        return "recent = 1";
1177    else if (filter.replace(/^\s+|\s+$/g,"") == "OLD")
1178        return "recent = 0";
1179
1180}
1181       
1182local_messages.prototype.has_local_mails = function() {
1183    this.init_local_messages();
1184    var rs = this.dbGears.execute("select rowid from folder limit 0,1");
1185    var retorno;
1186    if(rs.isValidRow())
1187        retorno = true;
1188    else
1189        retorno = false;
1190    this.finalize();
1191    return retorno;
1192}
1193
1194//Por Bruno Costa(bruno.vieira-costa@serpro.gov.br - Simple AJAX function used to get the RFC822 email source.
1195local_messages.prototype.get_src = function(url){
1196    AJAX = false;
1197    if (window.XMLHttpRequest) { // Mozilla, Safari,...
1198        AJAX = new XMLHttpRequest();
1199        if (AJAX.overrideMimeType) {
1200            AJAX.overrideMimeType('text/xml');
1201        }
1202    } else if (window.ActiveXObject) { // IE
1203        try {
1204            AJAX = new ActiveXObject("Msxml2.XMLHTTP");
1205        } catch (e) {
1206            try {
1207                AJAX = new ActiveXObject("Microsoft.XMLHTTP");
1208            } catch (e) {}
1209        }
1210    }
1211
1212    if (!AJAX) {
1213        alert('ERRO :(Seu navegador não suporta a aplicação usada neste site');
1214        return false;
1215    }
1216
1217    AJAX.onreadystatechange = function() {
1218        if (AJAX.readyState == 4) {
1219            AJAX.src=AJAX.responseText;
1220            if (AJAX.status == 200) {
1221                return AJAX.responseText;
1222            } else {
1223                return false;
1224            }
1225        }
1226    }
1227
1228    AJAX.open('get', url, false);
1229    AJAX.send(null);
1230    return AJAX.responseText;
1231};
1232
1233//Por Bruno Costa(bruno.vieira-costa@serpro.gov.br - Dessarquiva msgs locais pegando o codigo fonte das mesmas e mandando via POST para o servidor
1234//para que elas sejam inseridas no imap pela função  imap_functions.unarchive_mail.
1235local_messages.prototype.unarchive_msgs = function (folder,new_folder,msgs_number){
1236
1237    if(!new_folder)
1238        new_folder='INBOX';
1239    this.init_local_messages();
1240    // alert(folder+new_folder+msgs_number);
1241    var handler_unarchive = function(data)
1242    {
1243                if(data.error == '')
1244                    write_msg(get_lang('All messages are successfully unarchived'));
1245                else
1246                    alert(data.error);
1247    }
1248
1249        if(currentTab.toString().indexOf("_r") != -1){
1250            msgs_number = currentTab.toString().substr(0,currentTab.toString().indexOf("_r"));
1251    }
1252       
1253    if(msgs_number =='selected' || !msgs_number)
1254    {
1255                msgs_number = get_selected_messages()
1256                if (!msgs_number){
1257                    write_msg(get_lang('No selected message.'));
1258                    return;
1259                }
1260                var rs = this.dbGears.execute("select mail,timestamp from mail where rowid in ("+msgs_number+")");
1261                var source="";
1262                var flags="";
1263                var timestamp="";
1264               
1265                while(rs.isValidRow()) {
1266                        mail=connector.unserialize(rs.field(0));
1267                        mail.msg_source?source_tmp = escape(mail.msg_source):source_tmp = escape(this.get_src(mail.url_export_file));
1268                        flags+="#@#@#@"+mail["Answered"]+":"+mail["Draft"]+":"+mail["Flagged"]+":"+mail["Unseen"];
1269                        source+="#@#@#@"+source_tmp;
1270                        timestamp+="#@#@#@"+rs.field(1);
1271                        rs.next();
1272                }
1273                rs.close();
1274                this.finalize();
1275    }
1276    else
1277    {
1278                var rs = this.dbGears.execute("select mail,timestamp from mail where rowid="+msgs_number);
1279                mail=connector.unserialize(rs.field(0));
1280                var source ="";
1281
1282                mail.msg_source?source = escape(mail.msg_source):source = escape(this.get_src(mail.url_export_file));
1283                flags = mail["Answered"]+":"+mail["Draft"]+":"+mail["Flagged"]+":"+mail["Unseen"];
1284                timestamp=rs.field(1);
1285                rs.close();
1286                this.finalize();
1287    }
1288    params="&folder="+new_folder+"&source="+source+"&timestamp="+timestamp+"&flags="+flags;
1289    cExecute ("$this.imap_functions.unarchive_mail&", handler_unarchive, params);
1290}
1291
1292local_messages.prototype.get_msg_date = function (original_id, is_local){
1293
1294    this.init_local_messages();
1295
1296    if (typeof(is_local) == 'undefined')
1297    {
1298        is_local = false;
1299    }
1300
1301    var rs;
1302
1303    if (is_local)
1304    {
1305        rs = this.dbGears.execute("select mail from mail where rowid="+original_id);
1306    }
1307    else
1308    {
1309        rs = this.dbGears.execute("select mail from mail where original_id="+original_id);
1310    }
1311        if(!rs.field(0)){
1312          ret=null;
1313    }
1314    else
1315        {
1316    var tmp = connector.unserialize(rs.field(0));
1317    var ret = new Array();
1318    ret.fulldate = tmp.fulldate.substr(0,16);
1319    ret.smalldate = tmp.msg_day;
1320    ret.msg_day = tmp.msg_day;
1321    ret.msg_hour = tmp.msg_day;
1322        }
1323    rs.close();
1324    this.finalize();
1325    return ret;
1326}
1327
1328
1329local_messages.prototype.download_all_local_attachments = function(folder,id){
1330    this.init_local_messages();
1331    var rs = this.dbGears.execute("select mail from mail where rowid="+id);
1332    var tmp = connector.unserialize(rs.field(0));
1333    rs.close();
1334    this.finalize();
1335    tmp.msg_source?source = tmp.msg_source:source = this.get_src(tmp.url_export_file);
1336    //source = this.get_src(tmp.url_export_file);
1337    source = escape(source);
1338    var handler_source = function(data){
1339        download_attachments(null, null, data, null,null,'anexos.zip');
1340    }
1341    cExecute("$this.imap_functions.download_all_local_attachments",handler_source,"source="+source);
1342}
1343
1344/*************************************************************************/
1345/* Funcao usada para exportar mensagens arquivadas localmente.
1346 * Rommel de Brito Cysne (rommel.cysne@serpro.gov.br)
1347 * em 22/12/2008.
1348 */
1349local_messages.prototype.local_messages_to_export = function(){
1350
1351    if (openTab.type[currentTab] > 1){
1352        var msgs_to_export_id = currentTab.substring(0,currentTab.length-2,currentTab);
1353    }else{
1354        var msgs_to_export_id = get_selected_messages();
1355    }
1356    var flag = true;
1357    var handler_local_mesgs_to_export = function(data){
1358        document.getElementById('lertOverlay').style.display='none';
1359        document.getElementById('lertContainer').style.display='none';
1360        document.getElementById('lertContainer').innerHTML = '';
1361        flag = false;
1362        download_attachments(null, null, data, null,null,'mensagens.zip');
1363    }
1364
1365        var cancel = new LertButton(get_lang('cancel'), function(){flag=false;connector.cancelRequest();});
1366     var titulo = '<b>' + get_lang('Warning') + '!</b>';
1367     var message = get_lang("Exporting selected messages, this can take some time.");
1368        var multConfirm = new Lert(
1369                titulo,
1370                message,
1371                [cancel],
1372                {
1373                        defaultButton:cancel,
1374                        icon:'js/lert/images/dialog-help.gif'
1375                });
1376        multConfirm.display();
1377
1378        var timeOut = function(){
1379            if(flag){
1380                document.getElementById('lertOverlay').style.display='none';
1381                document.getElementById('lertContainer').style.display='none';
1382                document.getElementById('lertContainer').innerHTML = '';
1383                connector.cancelRequest();
1384                write_msg(get_lang('Error exporting messages, try again latter'));
1385                }
1386
1387        }
1388        window.setTimeout(timeOut,300000);
1389
1390    if(msgs_to_export_id){
1391        this.init_local_messages();
1392        var l_msg = "t";
1393        var mesgs ="";
1394        var subjects ="";
1395        var rs = this.dbGears.execute("select mail,subject from mail where rowid in ("+msgs_to_export_id+")");
1396        while(rs.isValidRow()){
1397            mail = connector.unserialize(rs.field(0));
1398            mail.msg_source?src = mail.msg_source:src = this.get_src(mail.url_export_file);
1399            subject = rs.field(1);
1400            mesgs += src;
1401            mesgs += "@@";
1402            subjects += subject;
1403            subjects += "@@";
1404            rs.next();
1405        }
1406        rs.close();
1407        this.finalize();
1408        mesgs = escape(mesgs);
1409        subjects = escape(subjects);
1410        params = "subjects="+subjects+"&mesgs="+mesgs+"&l_msg="+l_msg+"&msgs_to_export="+msgs_to_export_id;
1411        cExecute ("$this.exporteml.makeAll&", handler_local_mesgs_to_export, params);
1412    }
1413    return true;
1414}
1415
1416local_messages.prototype.get_all_local_folder_messages= function(folder_name){
1417
1418
1419    var mesgs = new Array();
1420    var subjects = new Array();
1421    var hoje = new Date();
1422    var msgs_to_export = new Array();
1423    var l_msg="t";
1424
1425    this.init_local_messages();
1426    var query = "select mail,subject,mail.rowid from mail inner join folder on (mail.id_folder=folder.rowid) where folder.folder='" + folder_name + "'";
1427
1428    var rs = this.dbGears.execute(" "+query)
1429
1430    var handler_local_mesgs_to_export = function(data){
1431        //alert("data - " + data + " - tipo - " + typeof(data));
1432        download_attachments(null, null, data, null,null,'mensagens.zip');
1433    }
1434    var j=0;
1435    while (rs.isValidRow()){
1436        msgs_to_export[j]=rs.field(2)
1437        mail = connector.unserialize(rs.field(0));
1438        mail.msg_source?src = mail.msg_source:src = this.get_src(mail.url_export_file);
1439        subject = rs.field(1);
1440        mesgs += src;
1441        mesgs += "@@";
1442        subjects += subject;
1443        subjects += "@@";
1444        rs.next();
1445        j++;
1446
1447    }
1448    rs.close();
1449    this.finalize();
1450    source = escape(mesgs);
1451    subjects = escape(subjects);
1452    params = "folder="+folder_name+"&subjects="+subjects+"&mesgs="+source+"&l_msg="+l_msg+"&msgs_to_export="+msgs_to_export;
1453    cExecute ("$this.exporteml.makeAll&", handler_local_mesgs_to_export, params);
1454         
1455
1456}
1457
1458
1459/*************************************************************************/
1460
1461       
1462/******************************************************************
1463                                        Offline Part
1464 ******************************************************************/
1465
1466local_messages.prototype.is_offline_installed = function() {
1467    this.init_local_messages();
1468    var check = this.localServer.openManagedStore('expresso-offline');
1469    this.finalize();
1470    if(check==null)
1471        return false;
1472    else
1473        return true;
1474               
1475}
1476local_messages.prototype.update_offline = function(redirect) {
1477    this.init_local_messages();
1478    var managedStore = this.localServer.openManagedStore('expresso-offline');
1479
1480    if(managedStore!=null){
1481                       
1482        managedStore.oncomplete = function(details){
1483            if(redirect!=null)
1484                location.href=redirect;
1485        }
1486                       
1487        managedStore.checkForUpdate();
1488    } else if(redirect!=null) {
1489        location.href=redirect;
1490    }
1491    this.finalize();
1492}
1493       
1494local_messages.prototype.uninstall_offline = function() {
1495    if (!window.google || !google.gears) {
1496        temp = confirm(document.getElementById('lang_gears_redirect').value);
1497        if (temp) {
1498            expresso_local_messages.installGears();
1499        }
1500        return;
1501
1502    }
1503    this.init_local_messages();
1504    this.localServer.removeManagedStore('expresso-offline');
1505    alert(document.getElementById('lang_offline_uninstalled').value);
1506    //this.dbGears.execute('drop table user');
1507    //this.dbGears.execute('drop table queue');
1508    //this.dbGears.execute('drop table attachments_queue');
1509    this.finalize();
1510}
1511       
1512local_messages.prototype.get_folders_to_sync = function() {//Precisa ter visibilidade ao array de linguagens.
1513    this.init_local_messages();
1514    var rs = this.dbGears.execute("select id_folder,folder_name from folders_sync where uid_usuario="+account_id);
1515    var retorno = new Array();
1516    while(rs.isValidRow()) {
1517        temp = new Array();
1518        temp[0] = rs.field(0);
1519        if(temp[0]=='INBOX/Drafts' ||temp[0]=='INBOX/Trash' || temp[0]=='INBOX/Sent') {
1520            temp[1] = array_lang[rs.field(1).toLowerCase()];
1521        }
1522        else {
1523            temp[1] = rs.field(1);
1524        }
1525                       
1526        retorno.push(temp);
1527        rs.next();
1528    }
1529    this.finalize();
1530    return retorno;
1531}
1532       
1533local_messages.prototype.install_offline = function(urlOffline,urlIcone,uid_usuario,login,pass,redirect) {
1534    if (!window.google || !google.gears) {
1535        temp = confirm(document.getElementById('lang_gears_redirect').value);
1536        if (temp) {
1537            expresso_local_messages.installGears();
1538        }
1539        return;
1540
1541    }
1542               
1543    if(pass.length>0) {
1544        only_spaces = true;
1545        for(cont=0;cont<pass.length;cont++) {
1546            if(pass.charAt(cont)!=" ")
1547                only_spaces = false;
1548        }
1549        if(only_spaces) {
1550            alert(document.getElementById('lang_only_spaces_not_allowed').value);
1551            return false;
1552        }
1553    }
1554
1555    modal('loading');
1556    var desktop = google.gears.factory.create('beta.desktop');
1557    desktop.createShortcut('ExpressoMail Offline',
1558        urlOffline,
1559                {'32x32': urlIcone},
1560        'ExpressoMail Offline');
1561
1562
1563    this.init_local_messages();
1564
1565    //user with offline needs to have at least the folder Inbox already created.
1566    tmp_rs = this.dbGears.execute("select rowid from folder where folder='Inbox' and uid_usuario=?",[uid_usuario]);
1567    if(!tmp_rs.isValidRow())
1568        this.dbGears.execute("insert into folder (folder,uid_usuario) values (?,?)",['Inbox',uid_usuario]);
1569
1570    this.localServer.removeManagedStore('expresso-offline');
1571       
1572    var managedStore = this.localServer.createManagedStore('expresso-offline');
1573    managedStore.manifestUrl = 'js/manifest';
1574
1575    managedStore.onerror = function (error) {
1576        alert(error);
1577    }
1578               
1579    managedStore.oncomplete = function(details) {
1580        if (close_lightbox_div) {
1581            close_lightbox();
1582            close_lightbox_div = false;
1583            alert(document.getElementById('lang_offline_installed').value);
1584            location.href=redirect;
1585        }
1586    }
1587
1588    //create structure to user in db
1589    this.dbGears.execute('create table if not exists user (uid_usuario int,login text,pass text, logged int,unique(uid_usuario))');
1590    this.dbGears.execute('create table if not exists queue (ffrom text, fto text, cc text, cco text,'+
1591        'subject text, conf_receipt int, important int,body text,sent int,user int)');
1592    this.dbGears.execute('create table if not exists attachments_queue ('+
1593        'id_queue int, url_attach text)');
1594    this.dbGears.execute('create table if not exists sent_problems (' +
1595        'id_queue int,message text)');
1596               
1597    //d = new Date();
1598               
1599    try {
1600        var rs = this.dbGears.execute("select uid_usuario from user where uid_usuario=?",[uid_usuario]);
1601        if(!rs.isValidRow())
1602            this.dbGears.execute("insert into user (uid_usuario,login,pass) values (?,?,?)",[uid_usuario,login,pass]);
1603        else
1604            this.dbGears.execute("update user set pass=? where uid_usuario=?",[pass,uid_usuario]);
1605    } catch (error) {
1606        this.finalize();
1607        alert(error);
1608        return false;
1609    }
1610    managedStore.checkForUpdate();
1611    this.capt_url('controller.php?action=$this.db_functions.get_dropdown_contacts_to_cache');
1612        setTimeout(function(){
1613        managedStore.complete();
1614    }, 60000);
1615    this.finalize();
1616}
1617       
1618/**
1619         * Return all users in an array following the structure below.
1620         *
1621         * key: uid
1622         * value: user login
1623         */
1624local_messages.prototype.get_all_users = function() {
1625    this.init_local_messages();
1626    var users = new Array();
1627    var rs = this.dbGears.execute("select uid_usuario,login from user");
1628    while(rs.isValidRow()) {
1629        users[rs.field(0)] = rs.field(1);
1630        rs.next();
1631    }
1632    this.finalize();
1633    return users;
1634}
1635       
1636local_messages.prototype.set_as_logged = function(uid_usuario,pass,bypass) {
1637    this.init_local_messages();
1638    if (!bypass) {
1639        var rs = this.dbGears.execute("select pass from user where uid_usuario=?", [uid_usuario]);
1640        if (!rs.isValidRow() || (pass != rs.field(0) && pass != MD5(rs.field(0)))) {
1641            this.finalize();
1642            return false;
1643        }
1644    }
1645    d = new Date();
1646
1647    this.dbGears.execute("update user set logged=null"); //Logoff in everybody
1648    this.dbGears.execute("update user set logged=? where uid_usuario=?",[d.getTime(),uid_usuario]); //Login just in one...
1649    this.finalize();
1650    return true;
1651}
1652       
1653local_messages.prototype.unset_as_logged = function() {
1654    this.init_local_messages();
1655    this.dbGears.execute("update user set logged=null"); //Logoff in everybody
1656    this.finalize();
1657}
1658       
1659local_messages.prototype.user_logged = function() {
1660    this.init_local_messages();
1661    var user_logged = new Array();
1662    var rs = this.dbGears.execute("select uid_usuario,logged from user where logged is not null");
1663    if(!rs.isValidRow()) {
1664        this.finalize();
1665        return null;
1666    }
1667    user_logged[0] = rs.field(0);
1668    user_logged[1] = rs.field(1);
1669    this.finalize();
1670    return user_logged;
1671}
1672       
1673local_messages.prototype.send_to_queue = function (form) {
1674    this.init_local_messages();
1675    var mail_values = new Array();
1676               
1677    for (var i=0;i<form.length;i++) {
1678        if (form.elements[i].name != '') { //I.E made me to do that...
1679            if(form.elements[i].name=='folder' || form.elements[i].name=='msg_id' || form.elements[i].name=='' || form.elements[i].name==null)
1680                continue;
1681            else if (form.elements[i].name == 'input_return_receipt' )
1682                mail_values['conf_receipt'] = form.elements[i].checked ? 1 : 0;
1683            else if(form.elements[i].name == 'input_important_message')
1684                mail_values['important'] = form.elements[i].checked ? 1 : 0;
1685            else
1686            if (form.elements[i].name == 'body')
1687                mail_values['body'] = form.elements[i].value;
1688            else
1689            if (form.elements[i].name == 'input_from')
1690                mail_values['ffrom'] = form.elements[i].value;
1691            else
1692            if (form.elements[i].name == 'input_to')
1693                mail_values['fto'] = form.elements[i].value;
1694            else
1695            if (form.elements[i].name == 'input_cc')
1696                mail_values['cc'] = form.elements[i].value;
1697            else
1698            if (form.elements[i].name == 'input_cco')
1699                mail_values['cco'] = form.elements[i].value;
1700            else
1701            if (form.elements[i].name == 'input_subject')
1702                mail_values['subject'] = form.elements[i].value;
1703        }
1704    }
1705    //mail_values['fto'] = input_to;
1706    //mail_values['cc'] = input_cc;
1707    //mail_values['cco'] = input_cco;
1708    //mail_values['subject'] = input_subject;
1709    //mail_values['conf_receipt'] = input_return_receipt;
1710    //mail_values['important'] = input_important_message;
1711               
1712    try {
1713        this.dbGears.execute("insert into queue (ffrom,fto,cc,cco,subject,conf_receipt,important,body,sent,user) values (?,?,?,?,?,?,?,?,0,?)", [mail_values['ffrom'], mail_values['fto'], mail_values['cc'], mail_values['cco'], mail_values['subject'], mail_values['conf_receipt'], mail_values['important'], mail_values['body'], account_id]);
1714        this.send_attach_to_queue(this.dbGears.lastInsertRowId,form);
1715    }catch(error) {
1716        alert(error);
1717        return get_lang('Error sending a mail to queue. Verify if you have installed ExpressoMail Offline');
1718    }
1719    this.finalize();
1720    return true;
1721}
1722       
1723local_messages.prototype.send_attach_to_queue = function(id_queue,form) {
1724               
1725    for(i=0;i<form.elements.length;i++) {
1726                       
1727        if(form.elements[i].name.indexOf("file_")!=-1) {
1728            var tmp_input = form.elements[i];
1729            var d = new Date();
1730            var url_local = 'local_attachs/'+d.getTime();
1731            this.store.captureFile(tmp_input, url_local);
1732            this.dbGears.execute("insert into attachments_queue (id_queue,url_attach) values (?,?)",[id_queue,url_local]);
1733        }
1734        else if(form.elements[i].name.indexOf("offline_forward_")!=-1){
1735            //alert();
1736            this.dbGears.execute("insert into attachments_queue (id_queue,url_attach) values (?,?)",[id_queue,form.elements[i].value]);
1737        }
1738    }
1739}
1740
1741       
1742local_messages.prototype.get_num_msgs_to_send = function() {
1743    this.init_local_messages();
1744
1745    var rs = this.dbGears.execute("select count(*) from queue where user=? and sent=0",[account_id]);
1746    var to_return = rs.field(0);
1747
1748    this.finalize();
1749    return to_return;
1750}
1751       
1752local_messages.prototype.set_problem_on_sent = function(rowid_message,msg) {
1753    this.init_local_messages();
1754    this.dbGears.execute("update queue set sent = 2 where rowid=?",[rowid_message]);
1755    this.dbGears.execute("insert into sent_problems (id_queue,message) values (?,?)"[rowid_message,msg]);
1756    this.finalize();
1757}
1758       
1759local_messages.prototype.set_as_sent = function(rowid_message) {
1760    this.init_local_messages();
1761    this.dbGears.execute("update queue set sent = 1 where rowid=?",[rowid_message]);
1762    this.finalize();
1763}
1764       
1765local_messages.prototype.get_form_msg_to_send = function() {
1766    this.init_local_messages();
1767    var rs = this.dbGears.execute('select ffrom,fto,cc,cco,subject,conf_receipt,important,body,rowid from queue where sent=0 and user = ? limit 0,1',[account_id]);
1768    if(!rs.isValidRow())
1769        return false;
1770               
1771    var form = document.createElement('form');
1772    form.method = 'POST';
1773    form.name = 'form_queue_'+rs.field(8);
1774    form.style.display = 'none';
1775                form.onsubmit = function(){return false;}
1776    if(!is_ie)
1777        form.enctype="multipart/form-data";
1778    else
1779        form.encoding="multipart/form-data";
1780               
1781    var ffrom = document.createElement('TEXTAREA');
1782    ffrom.name = "input_from";
1783    ffrom.value = rs.field(0);
1784    form.appendChild(ffrom);
1785               
1786    var fto = document.createElement('TEXTAREA');
1787    fto.name = "input_to";
1788    fto.value = rs.field(1);
1789    form.appendChild(fto);
1790               
1791    var cc = document.createElement('TEXTAREA');
1792    cc.name = "input_cc";
1793    cc.value = rs.field(2);
1794    form.appendChild(cc);
1795
1796    var cco = document.createElement('TEXTAREA');
1797    cco.name = "input_cco";
1798    cco.value = rs.field(3);
1799    form.appendChild(cco);
1800               
1801    var subject = document.createElement('TEXTAREA');
1802    subject.name = "input_subject";
1803    subject.value = rs.field(4);
1804    form.appendChild(subject);
1805               
1806    var folder = document.createElement('input');
1807    folder.name='folder';
1808    folder.value=preferences.save_in_folder;
1809    form.appendChild(folder);
1810               
1811    if (rs.field(5) == 1) {
1812        var conf_receipt = document.createElement('input');
1813        conf_receipt.type='text';
1814        conf_receipt.name = "input_return_receipt";
1815        conf_receipt.value = 'on';
1816        form.appendChild(conf_receipt);
1817    }
1818               
1819    if (rs.field(6) == 1) {
1820        var important = document.createElement('input');
1821        important.type='text';
1822        important.name = "input_important_message";
1823        important.value = 'on';
1824        form.appendChild(important);
1825    }
1826               
1827    var body = document.createElement('TEXTAREA');
1828    body.name = "body";
1829    body.value = rs.field(7);
1830    form.appendChild(body);
1831               
1832    var rowid = document.createElement('input');
1833    rowid.type = 'hidden';
1834    rowid.name = 'rowid';
1835    rowid.value = rs.field(8);
1836    form.appendChild(rowid);
1837               
1838    //Mounting the attachs
1839    var divFiles = document.createElement("div");
1840    divFiles.id = 'divFiles_queue_'+rs.field(8);
1841               
1842    form.appendChild(divFiles);
1843               
1844    document.getElementById('forms_queue').appendChild(form);
1845
1846    var is_local_forward = false;
1847    try {
1848                       
1849        var rs_attach = this.dbGears.execute('select url_attach from attachments_queue where id_queue=?', [rs.field(8)]);
1850        while (rs_attach.isValidRow()) {
1851            if(rs_attach.field(0).indexOf('../tmpLclAtt/')==-1) {
1852                tmp_field = addForwardedFile('queue_' + rs.field(8), this.store.getCapturedFileName(rs_attach.field(0)), 'nothing');
1853            }
1854            else {
1855                var tempNomeArquivo = rs_attach.field(0).split("/");
1856                var nomeArquivo = tempNomeArquivo[tempNomeArquivo.length-1];
1857                nomeArquivo = nomeArquivo.substring(0,nomeArquivo.length - 4); //Anexos no gears sᅵo todos com extensᅵo .php. tenho que tirar a extensᅵo para ficar o nome real do arquivo.
1858                is_local_forward = true;
1859                tmp_field = addForwardedFile('queue_' + rs.field(8), nomeArquivo, 'nothing');
1860            }
1861            fileSubmitter = this.store.createFileSubmitter();
1862            fileSubmitter.setFileInputElement(tmp_field,rs_attach.field(0));
1863            //          alert(form.innerHTML);
1864            //  div.appendChild(tmp_field);
1865            rs_attach.next();
1866        }
1867                       
1868        if(is_local_forward) {
1869            var is_lcl_fw = document.createElement('input');
1870            is_lcl_fw.type = 'hidden';
1871            is_lcl_fw.name = 'is_local_forward';
1872            is_lcl_fw.value = "1";
1873            form.appendChild(is_lcl_fw);
1874        }
1875                               
1876    }
1877    catch(exception) {
1878        alert(exception);
1879    }
1880               
1881    this.finalize();
1882    return form;
1883}
1884
1885var expresso_local_messages;
1886expresso_local_messages = new local_messages();
1887//expresso_local_messages.create_objects();
Note: See TracBrowser for help on using the repository browser.