Context Navigation

source: branches/2.0/expressoMail1_2/js/local_messages.js @ 3676

Revision 3676, 43.0 KB checked in by niltonneto, 13 years ago (diff)
Ticket #785 - Corrigido problema da navegação anterior/próximo no resultado da busca.

Line
1	/**
2	* @author diogenes
3	*/
4
5	function local_messages() {
6	this.dbGears = null;
7	this.localServer = null;
8	this.store = null;
9	this.fileSubmitter = null;
10	}
11
12	local_messages.prototype.init_local_messages = function(){
13	if(this.dbGears == null)
14	this.dbGears = google.gears.factory.create('beta.database');
15	if(this.localServer==null)
16	this.localServer = google.gears.factory.create('beta.localserver');
17	if(this.store==null)
18	this.store = this.localServer.createStore('test-store');
19	this.dbGears.open('database-test');
20	this.dbGears.execute('create table if not exists folder (folder text,uid_usuario int,unique(folder,uid_usuario))');
21	this.dbGears.execute('create table if not exists mail' +
22	' (mail blob,original_id int,original_folder text,header blob,timestamp int,uid_usuario int,unseen int,id_folder int,' +
23	' ffrom text, subject text, fto text, cc text, body text, size int,unique (original_id,original_folder,uid_usuario))');
24	this.dbGears.execute('create table if not exists anexo' +
25	' (id_mail int,nome_anexo text,url text,pid int)');
26
27	//some people that used old version of local messages could not have the size column. If it's the first version
28	//with local messages you're using in expresso, this part of code can be removed
29	try {
30	this.dbGears.execute('alter table mail add column size int');
31	}catch(Exception) {
32
33	}
34	var rs = this.dbGears.execute('select rowid,header from mail where size is null');
35	while(rs.isValidRow()) {
36	var temp = connector.unserialize(rs.field(1));
37
38	this.dbGears.execute('update mail set size='+temp.Size+' where rowid='+rs.field(0));
39	rs.next();
40	}
41	//end of temporary code
42	}
43
44	local_messages.prototype.drop_tables = function() {
45	this.init_local_messages();
46	var rs = this.dbGears.execute('select url from anexo');
47	while(rs.isValidRow()) {
48	this.store.remove(rs.field(0));
49	rs.next();
50	}
51	this.dbGears.execute('drop table folder');
52	this.dbGears.execute('drop table mail');
53	this.dbGears.execute('drop table anexo');
54	this.finalize();
55	}
56
57	local_messages.prototype.insert_mail = function(msg_info,msg_header,anexos,folder) {
58	try {
59	this.init_local_messages();
60	var unseen = 0;
61	var login = msg_info.login;
62	var original_id = msg_info.msg_number;
63	var original_folder = msg_info.msg_folder;
64
65	//This fields needs to be separeted to search.
66	var from = connector.serialize(msg_info.from);
67	var subject = msg_info.subject;
68	var body = msg_info.body;
69	var to = connector.serialize(msg_info.toaddress2);
70	var cc = connector.serialize(msg_info.cc);
71	var size = msg_header.Size;
72
73	//do not duplicate this information
74	msg_info.from = null;
75	msg_info.subject = null;
76	msg_info.body = null;
77	msg_info.to = null;
78	msg_info.cc = null;
79	msg_header.Size=null;
80	//If the mail was archieved in the same date the user received it, the date cames with the time.
81	//here I solved it
82	if(msg_header.udate.indexOf(":")!=-1) {
83	msg_header.udate = msg_header.aux_date;
84	}
85
86	/**
87	* The importance attribute can be empty, and javascript consider as null causing nullpointer.
88	*/
89	if((msg_header.Importance == null) \|\| (msg_header.Importance == ""))
90	msg_header.Importance = "Normal";
91
92	msg_header.aux_date = null;
93
94	var mail = connector.serialize(msg_info);
95	var header = connector.serialize(msg_header);
96
97	var timestamp = msg_info.timestamp;
98	var id_folder;
99
100	if((folder==null) \|\| (folder=="local_root"))
101	folder = "Inbox";
102	else
103	folder = folder.substr(6);//take off the word "local_"
104
105	var rs = this.dbGears.execute("select rowid from folder where folder=? and uid_usuario=?",[folder,account_id]);
106	if(rs.isValidRow())
107	id_folder=rs.field(0);
108	else {
109	this.dbGears.execute("insert into folder (folder,uid_usuario) values (?,?)",["Inbox",account_id]);
110	id_folder = this.dbGears.lastInsertRowId;
111	}
112
113	if(msg_info.Unseen=="U")
114	unseen = 1;
115	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]);
116	var call_back = function() {
117	}
118	this.store.capture(msg_info.url_export_file,call_back);
119	var id_mail = this.dbGears.lastInsertRowId;
120
121	this.insert_attachments(id_mail,anexos);
122	this.finalize();
123	return true;
124	} catch (error) {
125	this.finalize();
126	return false;
127	}
128
129
130	}
131
132	/**
133	* check if ID is no from main tab, if it's from main returns false, else
134	* returns an array with all string in position 0, the mail id in position 1
135	* and the part of string relative to tab in position 2
136	* @param {Object} id_mail
137	*/
138	local_messages.prototype.parse_id_mail = function(id_mail) {
139	if (this.isInt(id_mail))
140	return false;
141
142	var matches = id_mail.match(/(.+)(_[a-zA-Z0-9]+)/);
143	return matches;
144	}
145
146	local_messages.prototype.isInt = function(x) {
147	var y=parseInt(x);
148	if (isNaN(y)) return false;
149	return x==y && x.toString()==y.toString();
150	}
151
152	local_messages.prototype.get_local_mail = function(id_mail) {
153	this.init_local_messages();
154
155	var plus_id = '';
156	var matches = '';
157	if(matches = this.parse_id_mail(id_mail)) { //Mails coming from other tab.
158	id_mail = matches[1];
159	plus_id = matches[2];
160	}
161
162	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);
163	var retorno = null;
164	if(rs.isValidRow()) {
165	retorno = rs.field(1);
166	}
167	retorno = connector.unserialize(retorno);
168
169	//alert('tipo retorno.source: ' + typeof(retorno.source));
170
171	if (typeof(retorno.source) == 'string')
172	{
173	retorno.msg_number=rs.field(0)+plus_id;
174	retorno.original_ID=rs.field(8);
175	retorno.msg_folder=rs.field(7);
176
177	//alert('tipo retorno: '+typeof(retorno))
178	//show_msg(retorno);
179	}
180	else
181	{
182	retorno['from'] = connector.unserialize(rs.field(2));
183	retorno['subject'] = rs.field(3);
184	retorno['body'] = rs.field(4);
185	//Codigo que as imagens embutidas em emails (com multipart/related ou multipart/mixed) sejam corretamente mostradas em emails arquivados. Os links do
186	//tipo "./inc/show_embedded_attach.php?msg_folder=[folder]&msg_num=[msg_num]&msg_part=[part]"
187	//são substituidos pelos links dos anexos capturados pelo gears.
188
189	var thumbs= retorno.thumbs;
190	var anexos= retorno.array_attach;
191	for (i in anexos)
192	{
193	nomeArquivo = anexos[i]['name'].substring(0,anexos[i]['name'].length - 4);
194	if(nomeArquivo.match('jpg')\|\|anexos[i]['name'].match('gif')\|\|anexos[i]['name'].match('png'))
195	{
196	var er_imagens = new RegExp("\\.\\/inc\\/show_embedded_attach.php\\?msg_folder=[\\w/]+\\&msg_num=[0-9]+\\&msg_part="+anexos[i]['pid']);
197	var Result_imagens = er_imagens.exec(retorno['body']);
198	retorno['body'] = retorno['body'].replace(Result_imagens,anexos[i]['url']);
199	if(thumbs && thumbs[i]){
200	er_imagens = new RegExp("\\.\\/inc\\/show_thumbs.php\\?file_type=image\\/[\\w]+\\&msg_num=[0-9]+\\&msg_folder=[\\w/%]+\\&msg_part="+anexos[i]['pid']);
201	Result_imagens = er_imagens.exec(thumbs[i]);
202	thumbs[i] = thumbs[i].replace(Result_imagens,"'"+anexos[i]['url']+"'");
203	er_imagens = new RegExp("\\.\\/inc\\/show_img.php\\?msg_num=[0-9]+\\&msg_folder=[\\w/%]+\\&msg_part="+anexos[i]['pid']);
204	Result_imagens = er_imagens.exec(thumbs[i]);
205	thumbs[i] = thumbs[i].replace(Result_imagens,"'"+anexos[i]['url']+"'");
206	thumbs[i] = thumbs[i].replace(/<IMG/i,'<img width="120"');
207	}
208	}
209	}
210
211	retorno['to'] = connector.unserialize(rs.field(5));
212	retorno['cc'] = connector.unserialize(rs.field(6));
213
214	retorno['local_message'] = true;
215	retorno['msg_folder'] = "local_"+rs.field(7); //Now it's a local folder
216	retorno['msg_number'] = rs.field(0)+plus_id; //the message number is the rowid
217
218	}
219
220	rs.close();
221	this.finalize();
222	return retorno;
223	}
224
225	local_messages.prototype.insert_attachments = function(id_msg,anexos) {
226	//insert_mail already close and open gears.
227	for (var i = 0; i < anexos.length; i++) {
228	this.dbGears.execute("insert into anexo (id_mail,nome_anexo,url,pid) values (?,?,?,?)", [id_msg, anexos[i]['name'],anexos[i]['url'],anexos[i]['pid']]);
229	this.save_anexos(anexos[i]['url']);
230	}
231	}
232
233	local_messages.prototype.save_anexos = function (url) {
234	//insert_mail already close and open gears.
235	var call_back = function(url,success,captureId) {
236	//alert("Capturado: " + url);
237	}
238	//alert(url);
239	this.store.capture(url,call_back);
240	}
241
242	local_messages.prototype.get_local_range_msgs = function(folder,msg_range_begin,emails_per_page,sort,sort_reverse,search) {
243	this.init_local_messages();
244	var retorno = new Array();
245	msg_range_begin--;
246
247	filter = " ";
248	if(search=="FLAGGED") {
249	filter = "and (header like '%\"Flagged\";s:1:\"F%' or header like '%\"Importance\";s:5:\"High%') ";
250	}
251	if(search=="UNSEEN") {
252	filter = "and unseen = 1 ";
253	}
254	if(search=="SEEN") {
255	filter = "and unseen = 0 ";
256	}
257	if (search=="ANSWERED") {
258	filter = "and header like '%\"Answered\";s:1:\"A%' ";
259	}
260	sql = 'select rowid,header,size,timestamp,unseen from (';
261	sql += 'select mail.rowid as rowid,mail.header as header,mail.size as size,mail.timestamp as timestamp,mail.unseen as unseen,ltrim(ltrim(substr(UPPER(ffrom),21,length(ffrom)),\':\'),\'"\') as order_from,mail.subject from mail inner join folder on mail.id_folder=folder.rowid where mail.uid_usuario=? and folder.folder=? and lower(mail.ffrom) not like lower(?) ';
262	sql += filter;
263	sql += 'union ';
264	sql += 'select mail.rowid as rowid,mail.header as header,mail.size as size,mail.timestamp as timestamp,mail.unseen as unseen,ltrim(ltrim(substr(UPPER(fto),7,length(fto)),\':\'),\'"\') as order_from,mail.subject from mail inner join folder on mail.id_folder=folder.rowid where mail.uid_usuario=? and folder.folder=? and lower(mail.ffrom) like lower(?) ';
265	sql += filter;
266	sql += ') order by '
267
268	if(sort == 'SORTFROM') {
269	sql += 'order_from ';
270	}
271	if(sort == 'SORTARRIVAL') {
272	sql += 'timestamp ';
273	}
274	if(sort == 'SORTSIZE') {
275	sql += 'size ';
276	}
277	if(sort == 'SORTSUBJECT') {
278	sql += 'UPPER(subject) ';
279	}
280
281
282	sql+= sort_reverse==0?"ASC ":"DESC ";
283	sql +='limit ?,? ';
284
285
286	var rs = this.dbGears.execute(sql,[account_id,folder,'%'+Element("user_email").value+'%',account_id,folder,'%'+Element("user_email").value+'%',msg_range_begin,emails_per_page]);
287	var cont = 0;
288
289	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=?'+filter,[account_id,folder]);
290
291	while (rs.isValidRow()) {
292	//var email = rs.field(1);
293	var head = rs.field(1);
294	var codigoMail = rs.field(0);
295	var rs2 = this.dbGears.execute('select count(*) from anexo where id_mail = '+codigoMail);
296	var head_unserialized = connector.unserialize(head);
297	head_unserialized.Size = rs.field(2);
298	if(rs.field(4)==1)
299	head_unserialized.Unseen = 'U';
300
301	//var email_unserialized = connector.unserialize(email);
302	retorno[cont] = head_unserialized;
303	retorno[cont]['msg_number'] = codigoMail;
304
305	cont++;
306	rs.next();
307	}
308	retorno['num_msgs'] = rs3.field(0);
309	rs3.close();
310	rs.close();
311	if(cont>0)
312	rs2.close();
313	this.finalize();
314	return retorno;
315	}
316
317	local_messages.prototype.get_url_anexo = function(msg_number,pid) {
318	this.init_local_messages();
319	var matches = '';
320	if(matches = this.parse_id_mail(msg_number)) {
321	msg_number = matches[1];
322	}
323	var retorno;
324	var rs = this.dbGears.execute("select url from anexo where id_mail="+msg_number+" and pid = '"+pid+"'");
325	retorno = rs.field(0)
326	this.finalize();
327
328	return retorno;
329	}
330
331	local_messages.prototype.getInputFileFromAnexo = function (element,url) {
332	this.init_local_messages();
333	fileSubmitter = this.store.createFileSubmitter();
334	fileSubmitter.setFileInputElement(element,url);
335	this.finalize();
336	}
337
338	local_messages.prototype.finalize = function() {
339	this.dbGears.close();
340	this.dbGears = null;
341	}
342
343	local_messages.prototype.delete_msgs = function(msgs_number,border_ID) {
344	this.init_local_messages();
345	var rs = this.dbGears.execute("select url from anexo where id_mail in ("+msgs_number+")");
346	while(rs.isValidRow()) {
347	this.store.remove(rs.field(0));
348	rs.next();
349	}
350	this.dbGears.execute("delete from anexo where id_mail in ("+msgs_number+")");
351	this.dbGears.execute("delete from mail where rowid in ("+msgs_number+")");
352	this.finalize();
353	if (msgs_number.length == 1)
354	write_msg(get_lang("The message was deleted."));
355	else
356	write_msg(get_lang("The messages were deleted."));
357
358	mail_msg = Element("tbody_box");
359
360	try {
361	msgs_exploded = msgs_number.split(",");
362	}catch(error) {
363	msgs_exploded = new Array();
364	msgs_exploded[0] = msgs_number;
365	}
366	var msg_to_delete;
367	for (var i=0; i<msgs_exploded.length; i++){
368	msg_to_delete = Element(msgs_exploded[i]);
369	if (msg_to_delete){
370	if ( (msg_to_delete.style.backgroundColor != '') && (preferences.use_shortcuts == '1') )
371	select_msg('null', 'down');
372	mail_msg.removeChild(msg_to_delete);
373	decrement_folder_unseen();
374	}
375	}
376	Element('chk_box_select_all_messages').checked = false;
377	if (border_ID != 'null')
378	delete_border(border_ID,'false');
379
380	}
381
382	local_messages.prototype.get_source_msg = function(id_msg) {
383	this.init_local_messages();
384	var rs = this.dbGears.execute("select mail from mail where rowid="+id_msg);
385
386
387	mail = connector.unserialize(rs.field(0));
388	download_local_attachment(mail.url_export_file)
389
390	this.finalize();
391	}
392
393	local_messages.prototype.set_messages_flag = function(msgs_number, flag) {
394	this.init_local_messages();
395	var msgs_to_set;
396	if (msgs_number == 'get_selected_messages') {
397	var msgs_to_set = get_selected_messages();
398	msgs_to_set= msgs_to_set.split(",");
399	}
400	else { //Just one message
401	msgs_to_set = new Array();
402	msgs_to_set[0] = msgs_number;
403	}
404	for (var i in msgs_to_set) {
405
406	var matches = '';//Messages comming from other tabs.
407	if(matches = this.parse_id_mail(msgs_to_set[i])) {
408	msgs_to_set[i] = matches[1];
409	}
410
411	var rs = this.dbGears.execute("select header,unseen from mail where rowid=" + msgs_to_set[i]);
412	header = connector.unserialize(rs.field(0));
413	unseen = rs.field(1);
414	switch(flag) {
415	case "unseen":
416	set_msg_as_unread(msgs_to_set[i]);
417	header["Unseen"] = "U";
418	unseen = 1;
419	break;
420	case "flagged":
421	set_msg_as_flagged(msgs_to_set[i]);
422	header["Flagged"] = "F";
423	break;
424	case "unflagged":
425	if (header["Importance"].indexOf("High") != -1)
426	write_msg(get_lang("At least one of selected message cant be marked as normal"));
427	else {
428	set_msg_as_unflagged(msgs_to_set[i]);
429	header["Flagged"] = "N";
430	}
431	break;
432	case "seen":
433	header["Unseen"] = "N";
434	set_msg_as_read(msgs_to_set[i],true);
435	unseen = 0;
436	break;
437	case "answered":
438	header["Draft"]="";
439	header["Answered"]="A";
440	Element("td_message_answered_"+msgs_to_set[i]).innerHTML = '<img src=templates/default/images/answered.gif title=Respondida>';
441	break;
442	case "forwarded":
443	header["Draft"]="X";
444	header["Answered"]="A";
445	Element("td_message_answered_"+msgs_to_set[i]).innerHTML = '<img src=templates/default/images/forwarded.gif title=Encaminhada>';
446	break;
447	}
448
449	rs.close();
450
451	if(Element("check_box_message_" + msgs_to_set[i]))
452	Element("check_box_message_" + msgs_to_set[i]).checked = false;
453
454	this.dbGears.execute("update mail set header='"+connector.serialize(header)+"',unseen="+unseen+" where rowid="+msgs_to_set[i]);
455	}
456	if(Element('chk_box_select_all_messages'))
457	Element('chk_box_select_all_messages').checked = false;
458	this.finalize();
459
460	}
461
462	local_messages.prototype.set_message_flag = function(msg_number,flag) {
463	this.set_messages_flag(msg_number,flag);
464	}
465
466	local_messages.prototype.get_unseen_msgs_number = function() {
467	this.init_local_messages();
468	var rs = this.dbGears.execute("select count(*) from mail where unseen=1");
469	var retorno = rs.field(0);
470	rs.close();
471	this.finalize();
472	return retorno;
473	}
474
475	local_messages.prototype.create_folder = function(folder) {
476
477	if (folder.indexOf("local_") != -1)
478	return false; //can't create folder with string local_
479
480	this.init_local_messages();
481	try {
482	this.dbGears.execute("insert into folder (folder,uid_usuario) values (?,?)",[folder,account_id]);
483	} catch (error) {
484	this.finalize();
485	throw error;
486	return false;
487	}
488	this.finalize();
489	return true;
490	}
491
492	local_messages.prototype.list_local_folders = function(folder) {
493	this.init_local_messages();
494	var retorno = new Array();
495	rs = this.dbGears.execute("select folder.folder,sum(mail.unseen) from folder left join mail on "+
496	"folder.rowid=mail.id_folder where folder.uid_usuario=? group by folder.folder",[account_id]);
497	while(rs.isValidRow()) {
498	var temp = new Array();
499	temp[0] = rs.field(0);
500	temp[1] = rs.field(1);
501	retorno.push(temp);
502	rs.next();
503	}
504
505	rs.close();
506	this.finalize();
507	return retorno;
508	}
509
510	local_messages.prototype.rename_folder = function(folder,old_folder) {
511	if (folder.indexOf("local_") != -1)
512	return false; //can't create folder with string local_
513	this.init_local_messages();
514	try {
515	this.dbGears.execute("update folder set folder=? where folder=? and uid_usuario=?",[folder,old_folder,account_id]);
516	} catch (error) {
517	this.finalize();
518	return false;
519	}
520	this.finalize();
521	return true;
522	}
523
524	local_messages.prototype.remove_folder = function(folder) {
525	this.init_local_messages();
526	var rs = this.dbGears.execute("select rowid from folder where folder=? and uid_usuario=?",[folder,account_id]);
527	var folder_id = rs.field(0);
528	rs.close();
529	this.dbGears.execute("delete from folder where rowid=?",[folder_id]);
530	rs = this.dbGears.execute("select rowid,mail from mail where id_folder=?",[folder_id]);
531	while(rs.isValidRow()) {
532	var rs2 = this.dbGears.execute("select url from anexo where id_mail=?",[rs.field(0)]);
533	while(rs2.isValidRow()) {
534	this.store.remove(rs2.field(0));
535	rs2.next();
536	}
537	rs2.close();
538	this.dbGears.execute("delete from anexo where id_mail=?",[rs.field(0)]);
539	var mail = connector.unserialize(rs.field(1));
540	this.store.remove(mail.url_export_file);
541	rs.next();
542	}
543	rs.close();
544	this.dbGears.execute("delete from mail where id_folder=?",[folder_id]);
545	this.finalize();
546	}
547
548	local_messages.prototype.move_messages = function(new_folder,msgs_number) {
549	this.init_local_messages();
550	var rs = this.dbGears.execute("select rowid from folder where folder=? and uid_usuario=?",[new_folder,account_id]);
551	var id_folder = rs.field(0);
552	rs.close();
553	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...
554	this.finalize();
555	}
556
557	local_messages.prototype.search = function(folders,filter) {
558	this.init_local_messages();
559	var filters = filter.replace(/##/g," ");
560	filters = filters.replace(/^ +\| +$/g,"");
561	filters = filters.split("<=>");
562	var friendly_filters = new Array();
563	if (filters[0].indexOf('ALL') != -1) { //all filters...
564	friendly_filters.push("SUBJECT");
565	friendly_filters.push(filters[1]);
566	friendly_filters.push("BODY");
567	friendly_filters.push(filters[1]);
568	friendly_filters.push("FROM");
569	friendly_filters.push(filters[1]);
570	friendly_filters.push("TO");
571	friendly_filters.push(filters[1]);
572	friendly_filters.push("CC");
573	friendly_filters.push(filters[1]);
574	}
575	else {
576	friendly_filters[0] = filters[0];
577	for (var i in filters) {
578	if (i != 0) {
579	var temp = filters[i].split(" ");
580	friendly_filters.push(temp[0]);
581	friendly_filters.push(temp[1]);
582	}
583	}
584	}
585	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 (";
586	for(var fnum in folders) {
587	sql+="'"+folders[fnum]+"'";
588	if(fnum<folders.length-1)
589	sql+=",";
590	}
591	sql += ") and (";
592	for (var z=0;z<friendly_filters.length-1;z++) {
593	if(z%2==0) {
594	if (z != 0) {
595	if (filters[0].indexOf('ALL') != -1)
596	sql += " or";
597	else
598	sql += " and";
599	}
600	sql+=" mail."+this.aux_convert_filter_field(friendly_filters[z])+" like '%"+url_decode(friendly_filters[z+1])+"%'";
601	}
602	}
603	sql += ")";
604	var rs = this.dbGears.execute(sql);
605	var retorno = "";
606	while(rs.isValidRow()) {
607	var header = connector.unserialize(rs.field(0));
608	retorno+="##"+"local_"+rs.field(1)+"--"+header["from"]["name"]+"--"+header["subject"]+"--"+header["udate"]+"--"+this.aux_convert_size(rs.field(3))+"--"+header["Unseen"]+header["Recent"]+header["Flagged"]+header["Draft"]+"--"+rs.field(2)+"##";
609	rs.next();
610	}
611
612	this.finalize();
613	return retorno==""?false:retorno;
614
615	}
616
617	local_messages.prototype.aux_convert_size = function(size) {
618	var tmp = Math.floor(size/1024);
619	if(tmp >= 1){
620	return tmp + " kb";
621	}else{
622	return size + " b";
623	}
624
625	}
626
627	local_messages.prototype.aux_convert_filter_field = function(filter) {
628	if((filter=="SUBJECT ") \|\| (filter=="SUBJECT"))
629	return "subject";
630	else if((filter=="BODY ") \|\| (filter=="BODY"))
631	return "body";
632	else if((filter=="FROM ") \|\| (filter=="FROM"))
633	return "ffrom";
634	else if((filter=="TO ") \|\| (filter=="TO"))
635	return "fto";
636	else if((filter=="CC ") \|\| (filter=="CC"))
637	return "cc";
638	}
639
640	local_messages.prototype.has_local_mails = function() {
641	this.init_local_messages();
642	var rs = this.dbGears.execute("select rowid from folder limit 0,1");
643	var retorno;
644	if(rs.isValidRow())
645	retorno = true;
646	else
647	retorno = false;
648	this.finalize();
649	return retorno;
650	}
651
652	//Por Bruno Costa(bruno.vieira-costa@serpro.gov.br - Essa função é um AJAX simples que serve apenas para pegar o fonte de uma msg local (no formato RFC 822).
653	local_messages.prototype.get_src = function(url){
654	AJAX = false;
655	if (window.XMLHttpRequest) { // Mozilla, Safari,...
656	AJAX = new XMLHttpRequest();
657	if (AJAX.overrideMimeType) {
658	AJAX.overrideMimeType('text/xml');
659	}
660	} else if (window.ActiveXObject) { // IE
661	try {
662	AJAX = new ActiveXObject("Msxml2.XMLHTTP");
663	} catch (e) {
664	try {
665	AJAX = new ActiveXObject("Microsoft.XMLHTTP");
666	} catch (e) {}
667	}
668	}
669
670	if (!AJAX) {
671	alert('ERRO :(Seu navegador não suporta a aplicação usada neste site');
672	return false;
673	}
674
675	AJAX.onreadystatechange = function() {
676	if (AJAX.readyState == 4) {
677	AJAX.src=AJAX.responseText;
678	if (AJAX.status == 200) {
679	return AJAX.responseText;
680	} else {
681	return false;
682	}
683	}
684	}
685
686	AJAX.open('get', url, false);
687	AJAX.send(null);
688	return AJAX.responseText;
689	};
690
691	//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
692	//para que elas sejam inseridas no imap pela função imap_functions.unarchive_mail.
693	local_messages.prototype.unarchive_msgs = function (folder,new_folder,msgs_number){
694
695	if(!new_folder)
696	new_folder='INBOX';
697	this.init_local_messages();
698	// alert(folder+new_folder+msgs_number);
699	var handler_unarchive = function(data)
700	{
701	if(data.error == '')
702	write_msg(get_lang('All messages are successfully unarchived'));
703	else
704	alert(data.error);
705	}
706	if(msgs_number =='selected' \|\| !msgs_number)
707	{
708	msgs_number = get_selected_messages()
709	if (!msgs_number){
710	write_msg(get_lang('No selected message.'));
711	return;
712	}
713	var rs = this.dbGears.execute("select mail,timestamp from mail where rowid in ("+msgs_number+")");
714	var source="";
715	var timestamp="";
716	while(rs.isValidRow()) {
717	mail=connector.unserialize(rs.field(0));
718	source_tmp=escape(this.get_src(mail.url_export_file));
719	source+="#@#@#@"+source_tmp;
720	timestamp+="#@#@#@"+rs.field(1);
721	rs.next();
722	}
723	rs.close();
724	this.finalize();
725	}
726	else
727	{
728	var rs = this.dbGears.execute("select mail,timestamp from mail where rowid="+msgs_number);
729	mail=connector.unserialize(rs.field(0));
730	var source ="";
731	source = this.get_src(mail.url_export_file);
732	timestamp=rs.field(1);
733	rs.close();
734	this.finalize();
735	}
736	params="&folder="+new_folder+"&source="+source+"&timestamp="+timestamp;
737	cExecute ("$this.imap_functions.unarchive_mail&", handler_unarchive, params);
738	}
739
740	local_messages.prototype.get_msg_date = function (original_id, is_local){
741
742	this.init_local_messages();
743
744	if (typeof(is_local) == 'undefined')
745	{
746	is_local = false;
747	}
748
749	var rs;
750
751	if (is_local)
752	{
753	rs = this.dbGears.execute("select mail from mail where rowid="+original_id);
754	}
755	else
756	{
757	rs = this.dbGears.execute("select mail from mail where original_id="+original_id);
758	}
759	var tmp = connector.unserialize(rs.field(0));
760	var ret = new Array();
761	ret.fulldate = tmp.fulldate.substr(0,16);
762	ret.smalldate = tmp.msg_day;
763	ret.msg_day = tmp.msg_day;
764	ret.msg_hour = tmp.msg_day;
765
766	rs.close();
767	this.finalize();
768	return ret;
769	}
770
771
772	local_messages.prototype.download_all_local_attachments = function(folder,id){
773	this.init_local_messages();
774	var rs = this.dbGears.execute("select mail from mail where rowid="+id);
775	var tmp = connector.unserialize(rs.field(0));
776	rs.close();
777	this.finalize();
778	source = this.get_src(tmp.url_export_file);
779	source = escape(source);
780	var handler_source = function(data){
781	download_attachments(null, null, data, null,null,'anexos.zip');
782	}
783	cExecute("$this.imap_functions.download_all_local_attachments",handler_source,"source="+source);
784	}
785
786	/*************************************************************************/
787	/* Funcao usada para exportar mensagens arquivadas localmente.
788	* Rommel de Brito Cysne (rommel.cysne@serpro.gov.br)
789	* em 22/12/2008.
790	*/
791	local_messages.prototype.local_messages_to_export = function(){
792
793	if (openTab.type[currentTab] > 1){
794	var msgs_to_export_id = currentTab.substring(0,currentTab.length-2,currentTab);
795	}else{
796	var msgs_to_export_id = get_selected_messages();
797	}
798	var handler_local_mesgs_to_export = function(data){
799	download_attachments(null, null, data, null,null,'mensagens.zip');
800	}
801	if(msgs_to_export_id){
802	this.init_local_messages();
803	var l_msg = "t";
804	var mesgs ="";
805	var subjects ="";
806	var rs = this.dbGears.execute("select mail,subject from mail where rowid in ("+msgs_to_export_id+")");
807	while(rs.isValidRow()){
808	mail = connector.unserialize(rs.field(0));
809	src = this.get_src(mail.url_export_file);
810	subject = rs.field(1);
811	mesgs += src;
812	mesgs += "@@";
813	subjects += subject;
814	subjects += "@@";
815	rs.next();
816	}
817	rs.close();
818	this.finalize();
819	mesgs = escape(mesgs);
820	subjects = escape(subjects);
821	params = "subjects="+subjects+"&mesgs="+mesgs+"&l_msg="+l_msg+"&msgs_to_export="+msgs_to_export_id;
822	cExecute ("$this.exporteml.makeAll&", handler_local_mesgs_to_export, params);
823	}
824	return true;
825	}
826
827	local_messages.prototype.get_all_local_folder_messages= function(folder_name){
828
829
830	var mesgs = new Array();
831	var subjects = new Array();
832	var hoje = new Date();
833	var msgs_to_export = new Array();
834	var l_msg="t";
835
836	this.init_local_messages();
837	var query = "select mail,subject,mail.rowid from mail inner join folder on (mail.id_folder=folder.rowid) where folder.folder='" + folder_name + "'";
838
839	var rs = this.dbGears.execute(" "+query)
840
841	var handler_local_mesgs_to_export = function(data){
842	//alert("data - " + data + " - tipo - " + typeof(data));
843	download_attachments(null, null, data, null,null,'mensagens.zip');
844	}
845	var j=0;
846	while (rs.isValidRow()){
847	msgs_to_export[j]=rs.field(2)
848	mail = connector.unserialize(rs.field(0));
849	msg=this.get_src(mail.url_export_file);
850	subject = rs.field(1);
851	mesgs += msg;
852	mesgs += "@@";
853	subjects += subject;
854	subjects += "@@";
855	rs.next();
856	j++;
857
858	}
859	rs.close();
860	this.finalize();
861	source = escape(mesgs);
862	subjects = escape(subjects);
863	params = "folder="+folder_name+"&subjects="+subjects+"&mesgs="+source+"&l_msg="+l_msg+"&msgs_to_export="+msgs_to_export;
864	cExecute ("$this.exporteml.makeAll&", handler_local_mesgs_to_export, params);
865
866
867	}
868
869
870	/*************************************************************************/
871
872
873	/******************************************************************
874	Offline Part
875	******************************************************************/
876
877	local_messages.prototype.is_offline_installed = function() {
878	this.init_local_messages();
879	var check = this.localServer.openManagedStore('expresso-offline');
880	this.finalize();
881	if(check==null)
882	return false;
883	else
884	return true;
885
886	}
887
888	local_messages.prototype.update_offline = function(redirect) {
889	this.init_local_messages();
890	var managedStore = this.localServer.openManagedStore('expresso-offline');
891
892	if(managedStore!=null){
893
894	managedStore.oncomplete = function(details){
895	if(redirect!=null)
896	location.href=redirect;
897	}
898
899	managedStore.checkForUpdate();
900	} else if(redirect!=null) {
901	location.href=redirect;
902	}
903	this.finalize();
904	}
905
906	local_messages.prototype.uninstall_offline = function() {
907	if (!window.google \|\| !google.gears) {
908	temp = confirm(document.getElementById('lang_gears_redirect').value);
909	if (temp) {
910	location.href = "http://gears.google.com/?action=install&message="+
911	"Para utilizar o recurso de mensagens locais, instale o google gears&return=" + document.location.href;
912	}
913	return;
914
915	}
916	this.init_local_messages();
917	this.localServer.removeManagedStore('expresso-offline');
918	alert(document.getElementById('lang_offline_uninstalled').value);
919	//this.dbGears.execute('drop table user');
920	//this.dbGears.execute('drop table queue');
921	//this.dbGears.execute('drop table attachments_queue');
922	this.finalize();
923	}
924
925	local_messages.prototype.install_offline = function(urlOffline,urlIcone,uid_usuario,login,pass,redirect) {
926	if (!window.google \|\| !google.gears) {
927	temp = confirm(document.getElementById('lang_gears_redirect').value);
928	if (temp) {
929	location.href = "http://gears.google.com/?action=install&message="+
930	"Para utilizar o recurso de mensagens locais, instale o google gears&return=" + document.location.href;
931	}
932	return;
933
934	}
935
936	if(pass.length>0) {
937	only_spaces = true;
938	for(cont=0;cont<pass.length;cont++) {
939	if(pass.charAt(cont)!=" ")
940	only_spaces = false;
941	}
942	if(only_spaces) {
943	alert(document.getElementById('lang_only_spaces_not_allowed').value);
944	return false;
945	}
946	}
947
948	modal('loading');
949	var desktop = google.gears.factory.create('beta.desktop');
950	desktop.createShortcut('ExpressoMail Offline',
951	urlOffline,
952	{'32x32': urlIcone},
953	'ExpressoMail Offline');
954
955
956	this.init_local_messages();
957
958	//user with offline needs to have at least the folder Inbox already created.
959	tmp_rs = this.dbGears.execute("select rowid from folder where folder='Inbox' and uid_usuario=?",[uid_usuario]);
960	if(!tmp_rs.isValidRow())
961	this.dbGears.execute("insert into folder (folder,uid_usuario) values (?,?)",['Inbox',uid_usuario]);
962
963	this.localServer.removeManagedStore('expresso-offline');
964
965	var managedStore = this.localServer.createManagedStore('expresso-offline');
966	managedStore.manifestUrl = 'js/manifest';
967
968	managedStore.onerror = function (error) {
969	alert(error);
970	}
971
972	managedStore.oncomplete = function(details) {
973	if (close_lightbox_div) {
974	close_lightbox();
975	close_lightbox_div = false;
976	alert(document.getElementById('lang_offline_installed').value);
977	location.href=redirect;
978	}
979	}
980
981	//create structure to user in db
982	this.dbGears.execute('create table if not exists user (uid_usuario int,login text,pass text, logged int,unique(uid_usuario))');
983	this.dbGears.execute('create table if not exists queue (ffrom text, fto text, cc text, cco text,'+
984	'subject text, conf_receipt int, important int,body text,sent int,user int)');
985	this.dbGears.execute('create table if not exists attachments_queue ('+
986	'id_queue int, url_attach text)');
987	this.dbGears.execute('create table if not exists sent_problems (' +
988	'id_queue int,message text)');
989
990	//d = new Date();
991
992	try {
993	var rs = this.dbGears.execute("select uid_usuario from user where uid_usuario=?",[uid_usuario]);
994	if(!rs.isValidRow())
995	this.dbGears.execute("insert into user (uid_usuario,login,pass) values (?,?,?)",[uid_usuario,login,pass]);
996	else
997	this.dbGears.execute("update user set pass=? where uid_usuario=?",[pass,uid_usuario]);
998	} catch (error) {
999	this.finalize();
1000	alert(error);
1001	return false;
1002	}
1003	managedStore.checkForUpdate();
1004
1005	this.finalize();
1006	}
1007
1008	/**
1009	* Return all users in an array following the structure below.
1010	*
1011	* key: uid
1012	* value: user login
1013	*/
1014	local_messages.prototype.get_all_users = function() {
1015	this.init_local_messages();
1016	var users = new Array();
1017	var rs = this.dbGears.execute("select uid_usuario,login from user");
1018	while(rs.isValidRow()) {
1019	users[rs.field(0)] = rs.field(1);
1020	rs.next();
1021	}
1022	this.finalize();
1023	return users;
1024	}
1025
1026	local_messages.prototype.set_as_logged = function(uid_usuario,pass) {
1027	this.init_local_messages();
1028	var rs = this.dbGears.execute("select pass from user where uid_usuario=?",[uid_usuario]);
1029	if(!rs.isValidRow() \|\| (pass!=rs.field(0) && pass!=MD5(rs.field(0))) ) {
1030	this.finalize();
1031	return false;
1032	}
1033	d = new Date();
1034
1035	this.dbGears.execute("update user set logged=null"); //Logoff in everybody
1036	this.dbGears.execute("update user set logged=? where uid_usuario=?",[d.getTime(),uid_usuario]); //Login just in one...
1037	this.finalize();
1038	return true;
1039	}
1040
1041	local_messages.prototype.unset_as_logged = function() {
1042	this.init_local_messages();
1043	this.dbGears.execute("update user set logged=null"); //Logoff in everybody
1044	this.finalize();
1045	}
1046
1047	local_messages.prototype.user_logged = function() {
1048	this.init_local_messages();
1049	var user_logged = new Array();
1050	var rs = this.dbGears.execute("select uid_usuario,logged from user where logged is not null");
1051	if(!rs.isValidRow()) {
1052	this.finalize();
1053	return null;
1054	}
1055	user_logged[0] = rs.field(0);
1056	user_logged[1] = rs.field(1);
1057	this.finalize();
1058	return user_logged;
1059	}
1060
1061	local_messages.prototype.send_to_queue = function (form) {
1062	this.init_local_messages();
1063	var mail_values = new Array();
1064
1065	for (var i=0;i<form.length;i++) {
1066	if (form.elements[i].name != '') { //I.E made me to do that...
1067	if(form.elements[i].name=='folder' \|\| form.elements[i].name=='msg_id' \|\| form.elements[i].name=='' \|\| form.elements[i].name==null)
1068	continue;
1069	else if (form.elements[i].name == 'input_return_receipt' )
1070	mail_values['conf_receipt'] = form.elements[i].checked ? 1 : 0;
1071	else if(form.elements[i].name == 'input_important_message')
1072	mail_values['important'] = form.elements[i].checked ? 1 : 0;
1073	else
1074	if (form.elements[i].name == 'body')
1075	mail_values['body'] = form.elements[i].value;
1076	else
1077	if (form.elements[i].name == 'input_from')
1078	mail_values['ffrom'] = form.elements[i].value;
1079	else
1080	if (form.elements[i].name == 'input_to')
1081	mail_values['fto'] = form.elements[i].value;
1082	else
1083	if (form.elements[i].name == 'input_cc')
1084	mail_values['cc'] = form.elements[i].value;
1085	else
1086	if (form.elements[i].name == 'input_cco')
1087	mail_values['cco'] = form.elements[i].value;
1088	else
1089	if (form.elements[i].name == 'input_subject')
1090	mail_values['subject'] = form.elements[i].value;
1091	}
1092	}
1093	//mail_values['fto'] = input_to;
1094	//mail_values['cc'] = input_cc;
1095	//mail_values['cco'] = input_cco;
1096	//mail_values['subject'] = input_subject;
1097	//mail_values['conf_receipt'] = input_return_receipt;
1098	//mail_values['important'] = input_important_message;
1099
1100	try {
1101	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]);
1102	this.send_attach_to_queue(this.dbGears.lastInsertRowId,form);
1103	}catch(error) {
1104	alert(error);
1105	return get_lang('Error sending a mail to queue. Verify if you have installed ExpressoMail Offline');
1106	}
1107	this.finalize();
1108	return true;
1109	}
1110
1111	local_messages.prototype.send_attach_to_queue = function(id_queue,form) {
1112
1113	for(i=0;i<form.elements.length;i++) {
1114
1115	if(form.elements[i].name.indexOf("file_")!=-1) {
1116	var tmp_input = form.elements[i];
1117	var d = new Date();
1118	var url_local = 'local_attachs/'+d.getTime();
1119	this.store.captureFile(tmp_input, url_local);
1120	this.dbGears.execute("insert into attachments_queue (id_queue,url_attach) values (?,?)",[id_queue,url_local]);
1121	}
1122	else if(form.elements[i].name.indexOf("offline_forward_")!=-1){
1123	//alert();
1124	this.dbGears.execute("insert into attachments_queue (id_queue,url_attach) values (?,?)",[id_queue,form.elements[i].value]);
1125	}
1126	}
1127	}
1128
1129
1130	local_messages.prototype.get_num_msgs_to_send = function() {
1131	this.init_local_messages();
1132
1133	var rs = this.dbGears.execute("select count(*) from queue where user=? and sent=0",[account_id]);
1134	var to_return = rs.field(0);
1135
1136	this.finalize();
1137	return to_return;
1138	}
1139
1140	local_messages.prototype.set_problem_on_sent = function(rowid_message,msg) {
1141	this.init_local_messages();
1142	this.dbGears.execute("update queue set sent = 2 where rowid=?",[rowid_message]);
1143	this.dbGears.execute("insert into sent_problems (id_queue,message) values (?,?)"[rowid_message,msg]);
1144	this.finalize();
1145	}
1146
1147	local_messages.prototype.set_as_sent = function(rowid_message) {
1148	this.init_local_messages();
1149	this.dbGears.execute("update queue set sent = 1 where rowid=?",[rowid_message]);
1150	this.finalize();
1151	}
1152
1153	local_messages.prototype.get_form_msg_to_send = function() {
1154	this.init_local_messages();
1155	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]);
1156	if(!rs.isValidRow())
1157	return false;
1158
1159	var form = document.createElement('form');
1160	form.method = 'POST';
1161	form.name = 'form_queue_'+rs.field(8);
1162	form.style.display = 'none';
1163	form.onsubmit = function(){return false;}
1164	if(!is_ie)
1165	form.enctype="multipart/form-data";
1166	else
1167	form.encoding="multipart/form-data";
1168
1169	var ffrom = document.createElement('TEXTAREA');
1170	ffrom.name = "input_from";
1171	ffrom.value = rs.field(0);
1172	form.appendChild(ffrom);
1173
1174	var fto = document.createElement('TEXTAREA');
1175	fto.name = "input_to";
1176	fto.value = rs.field(1);
1177	form.appendChild(fto);
1178
1179	var cc = document.createElement('TEXTAREA');
1180	cc.name = "input_cc";
1181	cc.value = rs.field(2);
1182	form.appendChild(cc);
1183
1184	var cco = document.createElement('TEXTAREA');
1185	cco.name = "input_cco";
1186	cco.value = rs.field(3);
1187	form.appendChild(cco);
1188
1189	var subject = document.createElement('TEXTAREA');
1190	subject.name = "input_subject";
1191	subject.value = rs.field(4);
1192	form.appendChild(subject);
1193
1194	var folder = document.createElement('input');
1195	folder.name='folder';
1196	folder.value=preferences.save_in_folder;
1197	form.appendChild(folder);
1198
1199	if (rs.field(5) == 1) {
1200	var conf_receipt = document.createElement('input');
1201	conf_receipt.type='text';
1202	conf_receipt.name = "input_return_receipt";
1203	conf_receipt.value = 'on';
1204	form.appendChild(conf_receipt);
1205	}
1206
1207	if (rs.field(6) == 1) {
1208	var important = document.createElement('input');
1209	important.type='text';
1210	important.name = "input_important_message";
1211	important.value = 'on';
1212	form.appendChild(important);
1213	}
1214
1215	var body = document.createElement('TEXTAREA');
1216	body.name = "body";
1217	body.value = rs.field(7);
1218	form.appendChild(body);
1219
1220	var rowid = document.createElement('input');
1221	rowid.type = 'hidden';
1222	rowid.name = 'rowid';
1223	rowid.value = rs.field(8);
1224	form.appendChild(rowid);
1225
1226	//Mounting the attachs
1227	var divFiles = document.createElement("div");
1228	divFiles.id = 'divFiles_queue_'+rs.field(8);
1229
1230	form.appendChild(divFiles);
1231
1232	document.getElementById('forms_queue').appendChild(form);
1233
1234	var is_local_forward = false;
1235	try {
1236
1237	var rs_attach = this.dbGears.execute('select url_attach from attachments_queue where id_queue=?', [rs.field(8)]);
1238	while (rs_attach.isValidRow()) {
1239	if(rs_attach.field(0).indexOf('../tmpLclAtt/')==-1) {
1240	tmp_field = addForwardedFile('queue_' + rs.field(8), this.store.getCapturedFileName(rs_attach.field(0)), 'nothing');
1241	}
1242	else {
1243	var tempNomeArquivo = rs_attach.field(0).split("/");
1244	var nomeArquivo = tempNomeArquivo[tempNomeArquivo.length-1];
1245	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.
1246	is_local_forward = true;
1247	tmp_field = addForwardedFile('queue_' + rs.field(8), nomeArquivo, 'nothing');
1248	}
1249	fileSubmitter = this.store.createFileSubmitter();
1250	fileSubmitter.setFileInputElement(tmp_field,rs_attach.field(0));
1251	// alert(form.innerHTML);
1252	// div.appendChild(tmp_field);
1253	rs_attach.next();
1254	}
1255
1256	if(is_local_forward) {
1257	var is_lcl_fw = document.createElement('input');
1258	is_lcl_fw.type = 'hidden';
1259	is_lcl_fw.name = 'is_local_forward';
1260	is_lcl_fw.value = "1";
1261	form.appendChild(is_lcl_fw);
1262	}
1263
1264	}
1265	catch(exception) {
1266	alert(exception);
1267	}
1268
1269	this.finalize();
1270	return form;
1271	}
1272
1273	var expresso_local_messages;
1274	expresso_local_messages = new local_messages();

Note: See TracBrowser for help on using the repository browser.

Download in other formats: