source: trunk/expressoMail1_2/js/mail_sync.js @ 6930

Revision 6930, 17.2 KB checked in by gustavo, 12 years ago (diff)

Ticket #2954 - Merge de algumas novas funcionalidades da nova versão, #2953, #2971

Line 
1/**
2 * @author diogenes
3 */
4
5        /**
6         *  @param folders:
7         *              1 - rowid of folder in sqlite
8         *              2 - folder name in sqlite
9         *              3 - ids to not download(for auto archiving) or ids to download(for archiving)
10         *              4 - true for auto archiving and false for normal archiving.
11         */
12        function mail_sync() {
13                if (typeof(google) == 'undefined')
14                        return false;
15//              this.dbGears = null;
16//              this.localServer = null;
17//              this.store = null;
18                this.folders = new Array();
19                this.messages = null;
20                this.attachs = null;
21                this.url_attachs = null;
22                this.working = false;
23                this.is_auto = null;
24                this.errors = new Array();
25//              this.main_title = null;
26               
27                this.main_title = null;
28                this.dbGears = google.gears.factory.create('beta.database');
29                this.localServer = google.gears.factory.create('beta.localserver');
30                this.store = this.localServer.createStore('test-store');
31                this.update_folder = false;
32        }
33       
34        mail_sync.prototype.open_conn = function(){
35                var db_in_other_use = true;
36                var start_trying = new Date().getTime();
37                while (db_in_other_use) {
38                        try {
39                                this.dbGears.open('database-test');
40                                db_in_other_use = false;
41                        }
42                        catch (ex) {
43                                if(new Date().getTime()-start_trying>10000) { //too much time trying, throw an exception
44                                        throw ex;
45                                }
46                        }
47                }
48        }
49       
50        mail_sync.prototype.start_sync = function() {
51                if(this.working) {
52                        //Já está sincronizando...
53                        return;
54                }
55               
56                this.open_conn();
57
58                var rs = this.dbGears.execute("select id_folder,folder_name from folders_sync where uid_usuario=?",[account_id]);
59                if(!rs.isValidRow()) {
60                        this.dbGears.close();
61                        return;
62                }
63                       
64
65                this.working=true;
66                this.messages = null;
67                this.attachs = null;
68                this.url_attachs = null;
69
70                document.getElementById('main_title').innerHTML = get_lang("Creating folders structure");
71                while(rs.isValidRow()) {
72                        var temp = new Array();
73                        temp[0] = rs.field(0);
74                        temp[1] = rs.field(1);
75                        temp[2] = null;
76                        temp[3] = false;
77                        var rs2 = this.dbGears.execute("select mail.original_id from mail inner join folder on mail.id_folder=folder.rowid where folder.folder = ? and mail.uid_usuario=?",[temp[1]==get_lang('Inbox')?'Inbox':temp[1],account_id]);
78                        while(rs2.isValidRow()) {
79                                if(temp[2]==null)
80                                        temp[2]=rs2.field(0)+",";
81                                else
82                                        temp[2]+=rs2.field(0)+",";
83                                rs2.next();
84                        }
85                        this.folders.push(temp);
86                       
87                       
88                        //Criando estrutura de pastas...
89                        var folders_to_check = temp[0].split("/");//Todas as pastas tem ao menos INBOX/
90                        if (folders_to_check.length == 1)
91                                var actual_check = "Inbox";
92                        else {
93                                folders_to_check = folders_to_check.slice(1);
94                                var actual_check = folders_to_check[0];
95                        }
96                        for (var i in folders_to_check) {
97                                var rs2 = this.dbGears.execute("select rowid from folder where folder=? and uid_usuario=?", [actual_check, account_id]);
98                               
99                                if (!rs2.isValidRow()) {
100                                        if((!preferences.hide_folders) || (preferences.hide_folders=="0"))
101                                                this.update_folder = true; //Precisa atualizar as pastas na arvore de pastas
102                                        this.dbGears.execute("insert into folder (folder,uid_usuario) values (?,?)", [actual_check, account_id]);
103                                }
104                                if(parseInt(i)+1<folders_to_check.length)
105                                        actual_check += "/"+folders_to_check[parseInt(i)+1];
106                        }
107                       
108                        rs.next();
109                }
110                this.dbGears.close();
111                this.syncronize_folders();
112        }
113       
114        mail_sync.prototype.archive_msgs = function(folder,folder_dest,ids) {
115                //this.main_title = document.getElementById('main_title').innerHTML;
116                var temp = new Array();
117                temp[0] = folder;
118                temp[1] = folder_dest.substr(6);
119                temp[2] = ids;
120                temp[3] = true;
121                this.folders.push(temp);
122                Element('chk_box_select_all_messages').checked = false;
123               
124                array_ids = ids.split(",");
125                for (var i in array_ids) {
126                        if (Element("check_box_message_" + array_ids[i]))
127                                Element("check_box_message_" + array_ids[i]).checked = false;
128                        remove_className(Element(array_ids[i]), 'selected_msg');
129                }
130                if(!this.working) {
131                        this.working=true;
132                        this.syncronize_folders();
133                }
134                else {
135                        write_msg(get_lang("An archiving is in process, but dont worry, expresso will process this messages after the actual archiving"));
136                }
137        }
138       
139        mail_sync.prototype.syncronize_folders = function() {
140                if (this.folders.length == 0) {
141                        document.getElementById('main_title').innerHTML = get_lang("Deleting downloadeds msgs...");
142                        expresso_mail_sync.remove_archived_mails();
143                        if((!preferences.hide_folders) || (preferences.hide_folders=="0")) {
144                                if (expresso_mail_sync.update_folder) {
145                                        //ttreeBox.update_folder();
146                                        expresso_mail_sync.update_folder = false;
147                                }
148                                else
149                                        draw_tree_local_folders();
150                        }
151                        expresso_mail_sync.working=false;
152                        return;
153                }
154                var folder_to_sync = this.folders.pop();
155                folder_to_sync[1] = folder_to_sync[0].toUpperCase()=="INBOX" && !folder_to_sync[3]?"Inbox":folder_to_sync[1];
156               
157                if(folder_to_sync[3]) { //Em caso de arquivamento normal, pode ser que a pasta inbox ainda não tenha sido criada.
158                        expresso_mail_sync.open_conn()
159                        if(folder_to_sync[1]=="Inbox" && !expresso_mail_sync.has_inbox_folder()) {
160                                if((!preferences.hide_folders) || (preferences.hide_folders=="0"))
161                                        expresso_mail_sync.update_folder = true; //Precisa atualizar as pastas na arvore de pastas
162                                expresso_mail_sync.dbGears.execute("insert into folder (folder,uid_usuario) values (?,?)",["Inbox",account_id]);
163                        }
164                        expresso_mail_sync.dbGears.close();
165                       
166                       
167                }
168               
169                var start_sync_mails = function(data) {
170                        if (!data) { //Erro ao pegar lista de e-mails a serem baixados
171                                write_msg(get_lang("Problems while downloading mails, please try later"));
172                                expresso_mail_sync.working=false;
173                                window.setTimeout("eval('document.getElementById(\"main_title\").innerHTML =\"Expresso Mail\"')",3000);
174                                return;
175                        }
176                        expresso_mail_sync.messages=data;
177                        if(expresso_mail_sync.is_auto)
178                                document.getElementById('main_title').innerHTML = get_lang("Auto archiving")+" "+lang_folder(folder_to_sync[1])+": 0 / "+data.length;
179                        else
180                                document.getElementById('main_title').innerHTML = get_lang("Archiving messages on folder")+" "+lang_folder(folder_to_sync[1])+": 0 / "+data.length;
181
182                        expresso_mail_sync.syncronize_mails(folder_to_sync[1]);
183                }
184               
185
186                if (folder_to_sync[3]) {
187                        document.getElementById('main_title').innerHTML = get_lang("Starting to archive messages");
188                        cExecute("$this.imap_functions.get_info_msgs&folder=" + folder_to_sync[0] + "&msgs_number=" + folder_to_sync[2], start_sync_mails);
189                        this.is_auto = false;
190                }
191                else {
192                        document.getElementById('main_title').innerHTML = get_lang("Starting to sync folder")+" "+lang_folder(folder_to_sync[1]);
193                        var params = "folder="+folder_to_sync[0]+"&mails="+folder_to_sync[2];
194                        cExecute("$this.imap_functions.msgs_to_archive", start_sync_mails,params);
195                        this.is_auto = true;
196                }
197                       
198        }
199       
200        mail_sync.prototype.syncronize_mails = function(folder_dest) {
201                if (expresso_mail_sync.messages == null || expresso_mail_sync.messages.length == 0) {
202                        expresso_mail_sync.syncronize_folders();
203                        return;
204                }
205               
206                msg_to_sync = expresso_mail_sync.messages.pop();
207               
208                //refresh loading
209                var value_to_change = document.getElementById('main_title').innerHTML.match(/\d+ \//);
210                value_to_change += "";
211                var new_value = value_to_change.replace(" /","");
212                new_value = parseInt(new_value) + 1;
213                document.getElementById('main_title').innerHTML = document.getElementById('main_title').innerHTML.replace(value_to_change,new_value+" /");
214                msg_to_sync = connector.unserialize(msg_to_sync);
215               
216                var source_msg = new Array();
217                source_msg['url'] = msg_to_sync.url_export_file;
218
219                if (typeof(msg_to_sync['array_attach'])=='object'&&(msg_to_sync['array_attach'] instanceof Array))
220                        expresso_mail_sync.attachs = msg_to_sync['array_attach'].slice();
221                else
222                        expresso_mail_sync.attachs = new Array();
223                expresso_mail_sync.attachs.push(source_msg);
224                expresso_mail_sync.download_attachs(msg_to_sync,folder_dest);
225        }
226       
227        mail_sync.prototype.download_attachs = function(msg,folder_dest) {
228                if (expresso_mail_sync.attachs == null || expresso_mail_sync.attachs.length == 0) {
229                        expresso_mail_sync.insert_mail(msg, folder_dest);
230                       
231                        return;
232                }
233               
234                attach_to_capt = expresso_mail_sync.attachs.pop();
235               
236                var call_back = function(url,success,captureId) {
237                        if (!success) {
238                                /*
239                                 * 0 - original id
240                                 * 1 - message subject
241                                 * 2 - original folder
242                                 */
243                                var mail_error = new Array();
244                                mail_error[0] = msg.msg_number;
245                                mail_error[1] = msg.subject;
246                                mail_error[2] = msg.msg_folder;
247                                expresso_mail_sync.errors.push(mail_error);
248                                alert('erro ao baixar: '+url);
249                               
250                                /*if (typeof(msg['array_attach']) == 'object' && (msg['array_attach'] instanceof Array)) {
251                                        for (var i in msg['array_attach']) { //remove os anexos que já foram baixados para essa mensagem...
252                                                expresso_mail_sync.store.remove(msg['array_attach'][i]['url']);
253                                        }
254                                }*/
255                                expresso_mail_sync.syncronize_mails(folder_dest); //Pula para o próximo e-mail.
256                        }
257                        else {
258                                expresso_mail_sync.download_attachs(msg, folder_dest);//continua baixando o próximo anexo
259                        }
260                }
261                expresso_mail_sync.store.capture(attach_to_capt['url'],call_back);
262        }
263       
264        mail_sync.prototype.insert_mail = function(msg,folder) {
265                try {
266
267                        expresso_mail_sync.open_conn();
268               
269                        var msg_info = msg;
270                        var msg_header = msg['header'];
271                        var anexos = msg['array_attach'];
272                       
273                       
274                        var unseen = 0;
275                        var flagged = 0;
276                        var answered = 0;
277                        var login = msg_info.login;
278                        var original_id = msg_info.msg_number;
279                        var original_folder = msg_info.msg_folder=='INBOX/Lixeira/tmpMoveToLocal'?msg_info.msg_folder+(Date.parse(new Date)):msg_info.msg_folder;
280
281                        //Os campos abaixo precisam estar isolados para busca de mensagens em cima deles.
282                        var from = connector.serialize(msg_info.from);
283                        var subject = msg_info.subject;
284                        var body = msg_info.body;
285                        var to = connector.serialize(msg_info.toaddress2);
286                        var cc = connector.serialize(msg_info.cc);
287                        var size = msg_header.Size;
288       
289                        //Zero os campos que foram isolados para não ter informações duplicadas
290                        msg_info.from = null;
291                        msg_info.subject = null;
292                        msg_info.body = null;
293                        msg_info.to = null;
294                        msg_info.cc = null;
295                        msg_header.Size=null;
296
297                        /**
298                         * The importance attribute can be empty, and javascript consider as null causing nullpointer.
299                         */
300                        if((msg_header.Importance == null) ||  (msg_header.Importance == ""))
301                                msg_header.Importance = "Normal";
302                       
303                       
304                        var mail = connector.serialize(msg_info);
305                        var header = connector.serialize(msg_header);
306       
307                        var timestamp = msg_info.timestamp;
308                        var id_folder;
309                       
310                        var rs = this.dbGears.execute("select rowid from folder where folder=? and uid_usuario=?", [folder, account_id]);
311                        id_folder = rs.field(0);
312       
313                        if(msg_info.Unseen=="U")
314                                unseen = 1;
315                        this.dbGears.execute("insert into mail (mail,original_id,original_folder,header,timestamp,uid_usuario,unseen,id_folder,ffrom,subject,fto,cc,body,size,flagged,answered) values (?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?)",[mail,original_id,original_folder,header,timestamp,login,unseen,id_folder,from,subject,to,cc,body,size,flagged,answered]);
316
317
318                       
319                        //Preenche os anexos.
320                        var id_mail = this.dbGears.lastInsertRowId;
321
322                        for (var i = 0; i < anexos.length; i++) {
323                                this.dbGears.execute("insert into anexo (id_mail,nome_anexo,url,pid) values (?,?,?,?)", [id_mail, anexos[i]['name'],anexos[i]['url'],anexos[i]['pid']]);
324                        }
325                       
326                        var check_remove;
327                        if(this.is_auto)
328                                check_remove = preferences.keep_after_auto_archiving;
329                        else
330                                check_remove = preferences.keep_archived_messages;
331                       
332                       
333                       
334                        if(check_remove!=1)
335                                this.dbGears.execute("insert into msgs_to_remove (id_msg,folder,uid_usuario) values (?,?,?)",[original_id,original_folder,account_id]);
336                                               
337                } catch (error) {
338                        /*
339                         * 0 - original id
340                         * 1 - message subject
341                         * 2 - original folder
342                         */
343                        var mail_error = new Array();
344                        mail_error[0] = original_id;
345                        mail_error[1] = subject;
346                        mail_error[2] = original_folder;
347                        this.errors.push(mail_error);
348                       
349                        if (typeof(msg_info['array_attach'])=='object'&&(msg_info['array_attach'] instanceof Array)) {
350                                for(var i in msg_info['array_attach']) { //remove os anexos que já foram baixados para essa mensagem...
351                                        this.store.remove(msg_info['array_attach'][i]['url']);
352                                }
353                        }
354
355                }
356                this.dbGears.close();
357                this.syncronize_mails(folder);
358        }
359       
360        mail_sync.prototype.has_inbox_folder = function() {//This function considers that the connection with base is already opened.
361                var rs = this.dbGears.execute("select rowid from folder where folder='Inbox' and uid_usuario=?",[account_id]);
362                if(rs.isValidRow())
363                        return true;
364                else
365                        return false;
366        }
367       
368        mail_sync.prototype.remove_archived_mails = function() {
369               
370                expresso_mail_sync.open_conn();
371
372                var rs = this.dbGears.execute("select distinct(folder) from msgs_to_remove where uid_usuario=?",[account_id]);
373                if(rs.isValidRow()) {
374                        var folder_to_remove_msgs = rs.field(0);
375                        var rs2 = this.dbGears.execute("select id_msg from msgs_to_remove where folder=? and uid_usuario=?",[folder_to_remove_msgs,account_id]);
376                       
377                        var msgs = null;
378                        while(rs2.isValidRow()) {
379                                if(msgs==null)
380                                        msgs = rs2.field(0);
381                                else
382                                        msgs += ","+rs2.field(0);
383                                rs2.next();
384                        }
385                       
386                       
387                        var handler_delete_msgs = function(data){
388                                if (current_folder == data.folder) {
389                                        mail_msg = Element("tbody_box");
390                                        var msg_to_delete;
391                                        for (var i = 0; i < data.msgs_number.length; i++) {
392                                                msg_to_delete = Element(data.msgs_number[i]);
393                                                if (msg_to_delete) {
394                                                        mail_msg.removeChild(msg_to_delete);
395                                                }
396                                        }
397                                        Element('tot_m').innerHTML = parseInt(Element('tot_m').innerHTML) - data.msgs_number.length;
398                                }
399                               
400                                refresh();
401                                expresso_mail_sync.remove_archived_mails();
402                        }
403                       
404                        cExecute ("$this.imap_functions.delete_msgs&folder="+folder_to_remove_msgs+"&msgs_number="+msgs, handler_delete_msgs);
405                        this.dbGears.execute("delete from msgs_to_remove where folder=? and uid_usuario=?",[folder_to_remove_msgs,account_id]);
406                        this.dbGears.close();
407                       
408                }
409                else {
410                        this.dbGears.close();
411                        document.getElementById('main_title').innerHTML = get_lang("End of archive messages");
412                        if(this.errors.length>0) {
413                                //TODO: Tratar melhor quando existirem erros...
414                                write_msg(get_lang("at least, one of selected mails is already archived, expresso tried to archive the others, check them later"));
415                                this.errors=new Array();
416                        }
417                        window.setTimeout("eval('document.getElementById(\"main_title\").innerHTML =\"Expresso Mail\"')",3000);
418                }
419               
420        }
421       
422        mail_sync.prototype.configure_sync = function(folders,formul) {
423                this.dbGears = google.gears.factory.create('beta.database');
424                this.localServer = google.gears.factory.create('beta.localserver');
425                this.store = this.localServer.createStore('test-store');       
426                this.dbGears.open('database-test');
427                this.dbGears.execute("delete from folders_sync where uid_usuario=?",[account_id]);
428                for (var i=0;i<folders.length;i++) {
429                        var pos = folders[i].value.indexOf("/");
430                        if(pos=="-1")
431                                var folder_name = folders[i].text;
432                        else
433                                var folder_name = folders[i].value.substr(pos+1);
434
435                        folders[i].value = folders[i].value.replace(/#/g,' '); //Whitespaces has the # symbol in combo.
436                        folder_name = folder_name.replace(/#/g,' '); //Whitespaces has the # symbol in combo.
437                       
438                        this.dbGears.execute("insert into folders_sync (id_folder,folder_name,uid_usuario) values (?,?,?)",[folders[i].value,folder_name,account_id]);
439                }
440                this.dbGears.close();
441                formul.submit();
442        }
443       
444        mail_sync.prototype.fill_combos_of_folders = function(combo_sync) {
445                var folders = expresso_local_messages.get_folders_to_sync();
446
447                for(var i=0;i<folders.length;i++) {
448                        var option = document.createElement('option');
449                        option.value = folders[i][0];
450                        if (folders[i][1].indexOf("/") != "-1") {
451                                final_pos = folders[i][1].lastIndexOf("/");
452                                option.text =folders[i][1].substr(final_pos+1);
453                        }
454                        else
455                                option.text = folders[i][1];
456                        try {
457                                combo_sync.add(option,null);
458                        }catch (ex) {// I.E
459                                combo_sync.add(option);
460                        }
461
462                }
463        }
464       
465        mail_sync.prototype.add_folder = function (select_sync_folders,select_available_folders)
466        {
467                var count_available_folders = select_available_folders.length;
468                var count_sync_folders = select_sync_folders.options.length;
469                var new_options = '';
470               
471                for (i = 0 ; i < count_available_folders ; i++)
472                {
473                        if (select_available_folders.options[i].selected)
474                        {
475                                if(document.all)
476                                {
477                                        if ( (select_sync_folders.innerHTML.indexOf('value='+select_available_folders.options[i].value)) == '-1' )
478                                        {
479                                                new_options +=  '<option value='
480                                                                        + select_available_folders.options[i].value
481                                                                        + '>'
482                                                                        + select_available_folders.options[i].text
483                                                                        + '</option>';
484                                        }
485                                }
486                                else
487                                {
488                                        if ( (select_sync_folders.innerHTML.indexOf('value="'+select_available_folders.options[i].value+'"')) == '-1' )
489                                        {
490                                                new_options +=  '<option value='
491                                                                        + select_available_folders.options[i].value
492                                                                        + '>'
493                                                                        + select_available_folders.options[i].text
494                                                                        + '</option>';
495                                        }
496                                }
497                        }
498                }
499       
500                if (new_options != '')
501                {
502                        select_sync_folders.innerHTML = '&nbsp;' + new_options + select_sync_folders.innerHTML;
503                        select_sync_folders.outerHTML = select_sync_folders.outerHTML;
504                }
505        }
506       
507        mail_sync.prototype.remove_folder = function(select_sync_folders)
508        {
509                for(var i = 0;i < select_sync_folders.options.length; i++)
510                        if(select_sync_folders.options[i].selected)
511                                select_sync_folders.options[i--] = null;
512        }
513       
514        var expresso_mail_sync;
515        expresso_mail_sync = new mail_sync();
516       
Note: See TracBrowser for help on using the repository browser.