Context Navigation

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

Revision 1121, 42.0 KB checked in by eduardoalex, 15 years ago (diff)
Ticket #548 - Implementação do Expresso (Mail) Offline

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

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

Download in other formats: