Context Navigation

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

Revision 1330, 41.8 KB checked in by niltonneto, 15 years ago (diff)
Ticket #605 - Opção de mostrar pastas compartilhadas por nome (CN) ou login (uid).

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)+"--"+"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){
704
705	this.init_local_messages();
706
707	var rs = this.dbGears.execute("select mail from mail where rowid="+original_id);
708	// rs = this.dbGears.execute("select mail from mail where original_id="+original_id);
709	var tmp = connector.unserialize(rs.field(0));
710	var ret = new Array();
711	ret.fulldate = tmp.fulldate.substr(0,16);
712	ret.smalldate = tmp.msg_day;
713	ret.msg_day = tmp.msg_day;
714	ret.msg_hour = tmp.msg_day;
715
716	rs.close();
717	this.finalize();
718	return ret;
719	}
720
721
722	local_messages.prototype.download_all_local_attachments = function(folder,id){
723	this.init_local_messages();
724	var rs = this.dbGears.execute("select mail from mail where rowid="+id);
725	var tmp = connector.unserialize(rs.field(0));
726	rs.close();
727	this.finalize();
728	source = this.get_src(tmp.url_export_file);
729	source = escape(source);
730	var handler_source = function(data){
731	download_attachments(null, null, data, null,null,'anexos.zip');
732	}
733	cExecute("$this.imap_functions.download_all_local_attachments",handler_source,"source="+source);
734	}
735
736	/*************************************************************************/
737	/* Funcao usada para exportar mensagens arquivadas localmente.
738	* Rommel de Brito Cysne (rommel.cysne@serpro.gov.br)
739	* em 22/12/2008.
740	*/
741	local_messages.prototype.local_messages_to_export = function(){
742
743	if (openTab.type[currentTab] > 1){
744	var msgs_to_export_id = currentTab.substring(0,currentTab.length-2,currentTab);
745	}else{
746	var msgs_to_export_id = get_selected_messages();
747	}
748	var handler_local_mesgs_to_export = function(data){
749	download_attachments(null, null, data, null,null,'mensagens.zip');
750	}
751	if(msgs_to_export_id){
752	this.init_local_messages();
753	var l_msg = "t";
754	var mesgs ="";
755	var subjects ="";
756	var rs = this.dbGears.execute("select mail,subject from mail where rowid in ("+msgs_to_export_id+")");
757	while(rs.isValidRow()){
758	mail = connector.unserialize(rs.field(0));
759	src = this.get_src(mail.url_export_file);
760	subject = rs.field(1);
761	mesgs += src;
762	mesgs += "@@";
763	subjects += subject;
764	subjects += "@@";
765	rs.next();
766	}
767	rs.close();
768	this.finalize();
769	mesgs = escape(mesgs);
770	subjects = escape(subjects);
771	params = "subjects="+subjects+"&mesgs="+mesgs+"&l_msg="+l_msg+"&msgs_to_export="+msgs_to_export_id;
772	cExecute ("$this.exporteml.makeAll&", handler_local_mesgs_to_export, params);
773	}
774	return true;
775	}
776
777	local_messages.prototype.get_all_local_folder_messages= function(folder_name){
778
779
780	var mesgs = new Array();
781	var subjects = new Array();
782	var hoje = new Date();
783	var msgs_to_export = new Array();
784	var l_msg="t";
785
786	this.init_local_messages();
787	var query = "select mail,subject,mail.rowid from mail inner join folder on (mail.id_folder=folder.rowid) where folder.folder='" + folder_name + "'";
788
789	var rs = this.dbGears.execute(" "+query)
790
791	var handler_local_mesgs_to_export = function(data){
792	//alert("data - " + data + " - tipo - " + typeof(data));
793	download_attachments(null, null, data, null,null,'mensagens.zip');
794	}
795	var j=0;
796	while (rs.isValidRow()){
797	msgs_to_export[j]=rs.field(2)
798	mail = connector.unserialize(rs.field(0));
799	msg=this.get_src(mail.url_export_file);
800	subject = rs.field(1);
801	mesgs += msg;
802	mesgs += "@@";
803	subjects += subject;
804	subjects += "@@";
805	rs.next();
806	j++;
807
808	}
809	rs.close();
810	this.finalize();
811	source = escape(mesgs);
812	subjects = escape(subjects);
813	params = "folder="+folder_name+"&subjects="+subjects+"&mesgs="+source+"&l_msg="+l_msg+"&msgs_to_export="+msgs_to_export;
814	cExecute ("$this.exporteml.makeAll&", handler_local_mesgs_to_export, params);
815
816
817	}
818
819
820	/*************************************************************************/
821
822
823	/******************************************************************
824	Offline Part
825	******************************************************************/
826
827	local_messages.prototype.is_offline_installed = function() {
828	this.init_local_messages();
829	var check = this.localServer.openManagedStore('expresso-offline');
830	this.finalize();
831	if(check==null)
832	return false;
833	else
834	return true;
835
836	}
837
838	local_messages.prototype.update_offline = function(redirect) {
839	this.init_local_messages();
840	var managedStore = this.localServer.openManagedStore('expresso-offline');
841
842	if(managedStore!=null){
843
844	managedStore.oncomplete = function(details){
845	if(redirect!=null)
846	location.href=redirect;
847	}
848
849	managedStore.checkForUpdate();
850	} else if(redirect!=null) {
851	location.href=redirect;
852	}
853	this.finalize();
854	}
855
856	local_messages.prototype.uninstall_offline = function() {
857	if (!window.google \|\| !google.gears) {
858	temp = confirm(document.getElementById('lang_gears_redirect').value);
859	if (temp) {
860	location.href = "http://gears.google.com/?action=install&message="+
861	"Para utilizar o recurso de mensagens locais, instale o google gears&return=" + document.location.href;
862	}
863	return;
864
865	}
866	this.init_local_messages();
867	this.localServer.removeManagedStore('expresso-offline');
868	alert(document.getElementById('lang_offline_uninstalled').value);
869	//this.dbGears.execute('drop table user');
870	//this.dbGears.execute('drop table queue');
871	//this.dbGears.execute('drop table attachments_queue');
872	this.finalize();
873	}
874
875	local_messages.prototype.install_offline = function(urlOffline,urlIcone,uid_usuario,login,pass,redirect) {
876	if (!window.google \|\| !google.gears) {
877	temp = confirm(document.getElementById('lang_gears_redirect').value);
878	if (temp) {
879	location.href = "http://gears.google.com/?action=install&message="+
880	"Para utilizar o recurso de mensagens locais, instale o google gears&return=" + document.location.href;
881	}
882	return;
883
884	}
885
886	if(pass.length>0) {
887	only_spaces = true;
888	for(cont=0;cont<pass.length;cont++) {
889	if(pass.charAt(cont)!=" ")
890	only_spaces = false;
891	}
892	if(only_spaces) {
893	alert(document.getElementById('lang_only_spaces_not_allowed').value);
894	return false;
895	}
896	}
897
898	modal('loading');
899	var desktop = google.gears.factory.create('beta.desktop');
900	desktop.createShortcut('ExpressoMail Offline',
901	urlOffline,
902	{'32x32': urlIcone},
903	'ExpressoMail Offline');
904
905
906	this.init_local_messages();
907
908	//user with offline needs to have at least the folder Inbox already created.
909	tmp_rs = this.dbGears.execute("select rowid from folder where folder='Inbox' and uid_usuario=?",[uid_usuario]);
910	if(!tmp_rs.isValidRow())
911	this.dbGears.execute("insert into folder (folder,uid_usuario) values (?,?)",['Inbox',uid_usuario]);
912
913	this.localServer.removeManagedStore('expresso-offline');
914
915	var managedStore = this.localServer.createManagedStore('expresso-offline');
916	managedStore.manifestUrl = 'js/manifest';
917
918	managedStore.onerror = function (error) {
919	alert(error);
920	}
921
922	managedStore.oncomplete = function(details) {
923	if (close_lightbox_div) {
924	close_lightbox();
925	close_lightbox_div = false;
926	alert(document.getElementById('lang_offline_installed').value);
927	location.href=redirect;
928	}
929	}
930
931	//create structure to user in db
932	this.dbGears.execute('create table if not exists user (uid_usuario int,login text,pass text, logged int,unique(uid_usuario))');
933	this.dbGears.execute('create table if not exists queue (ffrom text, fto text, cc text, cco text,'+
934	'subject text, conf_receipt int, important int,body text,sent int,user int)');
935	this.dbGears.execute('create table if not exists attachments_queue ('+
936	'id_queue int, url_attach text)');
937	this.dbGears.execute('create table if not exists sent_problems (' +
938	'id_queue int,message text)');
939
940	//d = new Date();
941
942	try {
943	var rs = this.dbGears.execute("select uid_usuario from user where uid_usuario=?",[uid_usuario]);
944	if(!rs.isValidRow())
945	this.dbGears.execute("insert into user (uid_usuario,login,pass) values (?,?,?)",[uid_usuario,login,pass]);
946	else
947	this.dbGears.execute("update user set pass=? where uid_usuario=?",[pass,uid_usuario]);
948	} catch (error) {
949	this.finalize();
950	alert(error);
951	return false;
952	}
953	managedStore.checkForUpdate();
954
955	this.finalize();
956	}
957
958	/**
959	* Return all users in an array following the structure below.
960	*
961	* key: uid
962	* value: user login
963	*/
964	local_messages.prototype.get_all_users = function() {
965	this.init_local_messages();
966	var users = new Array();
967	var rs = this.dbGears.execute("select uid_usuario,login from user");
968	while(rs.isValidRow()) {
969	users[rs.field(0)] = rs.field(1);
970	rs.next();
971	}
972	this.finalize();
973	return users;
974	}
975
976	local_messages.prototype.set_as_logged = function(uid_usuario,pass) {
977	this.init_local_messages();
978	var rs = this.dbGears.execute("select pass from user where uid_usuario=?",[uid_usuario]);
979	if(!rs.isValidRow() \|\| (pass!=rs.field(0) && pass!=MD5(rs.field(0))) ) {
980	this.finalize();
981	return false;
982	}
983	d = new Date();
984
985	this.dbGears.execute("update user set logged=null"); //Logoff in everybody
986	this.dbGears.execute("update user set logged=? where uid_usuario=?",[d.getTime(),uid_usuario]); //Login just in one...
987	this.finalize();
988	return true;
989	}
990
991	local_messages.prototype.unset_as_logged = function() {
992	this.init_local_messages();
993	this.dbGears.execute("update user set logged=null"); //Logoff in everybody
994	this.finalize();
995	}
996
997	local_messages.prototype.user_logged = function() {
998	this.init_local_messages();
999	var user_logged = new Array();
1000	var rs = this.dbGears.execute("select uid_usuario,logged from user where logged is not null");
1001	if(!rs.isValidRow()) {
1002	this.finalize();
1003	return null;
1004	}
1005	user_logged[0] = rs.field(0);
1006	user_logged[1] = rs.field(1);
1007	this.finalize();
1008	return user_logged;
1009	}
1010
1011	local_messages.prototype.send_to_queue = function (form) {
1012	this.init_local_messages();
1013	var mail_values = new Array();
1014
1015	for (var i=0;i<form.length;i++) {
1016	if (form.elements[i].name != '') { //I.E made me to do that...
1017	if(form.elements[i].name=='folder' \|\| form.elements[i].name=='msg_id' \|\| form.elements[i].name=='' \|\| form.elements[i].name==null)
1018	continue;
1019	else if (form.elements[i].name == 'input_return_receipt' )
1020	mail_values['conf_receipt'] = form.elements[i].checked ? 1 : 0;
1021	else if(form.elements[i].name == 'input_important_message')
1022	mail_values['important'] = form.elements[i].checked ? 1 : 0;
1023	else
1024	if (form.elements[i].name == 'body')
1025	mail_values['body'] = form.elements[i].value;
1026	else
1027	if (form.elements[i].name == 'input_from')
1028	mail_values['ffrom'] = form.elements[i].value;
1029	else
1030	if (form.elements[i].name == 'input_to')
1031	mail_values['fto'] = form.elements[i].value;
1032	else
1033	if (form.elements[i].name == 'input_cc')
1034	mail_values['cc'] = form.elements[i].value;
1035	else
1036	if (form.elements[i].name == 'input_cco')
1037	mail_values['cco'] = form.elements[i].value;
1038	else
1039	if (form.elements[i].name == 'input_subject')
1040	mail_values['subject'] = form.elements[i].value;
1041	}
1042	}
1043	//mail_values['fto'] = input_to;
1044	//mail_values['cc'] = input_cc;
1045	//mail_values['cco'] = input_cco;
1046	//mail_values['subject'] = input_subject;
1047	//mail_values['conf_receipt'] = input_return_receipt;
1048	//mail_values['important'] = input_important_message;
1049
1050	try {
1051	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]);
1052	this.send_attach_to_queue(this.dbGears.lastInsertRowId,form);
1053	}catch(error) {
1054	alert(error);
1055	return get_lang('Error sending a mail to queue. Verify if you have installed ExpressoMail Offline');
1056	}
1057	this.finalize();
1058	return true;
1059	}
1060
1061	local_messages.prototype.send_attach_to_queue = function(id_queue,form) {
1062
1063	for(i=0;i<form.elements.length;i++) {
1064
1065	if(form.elements[i].name.indexOf("file_")!=-1) {
1066	var tmp_input = form.elements[i];
1067	var d = new Date();
1068	var url_local = 'local_attachs/'+d.getTime();
1069	this.store.captureFile(tmp_input, url_local);
1070	this.dbGears.execute("insert into attachments_queue (id_queue,url_attach) values (?,?)",[id_queue,url_local]);
1071	}
1072	else if(form.elements[i].name.indexOf("offline_forward_")!=-1){
1073	//alert();
1074	this.dbGears.execute("insert into attachments_queue (id_queue,url_attach) values (?,?)",[id_queue,form.elements[i].value]);
1075	}
1076	}
1077	}
1078
1079
1080	local_messages.prototype.get_num_msgs_to_send = function() {
1081	this.init_local_messages();
1082
1083	var rs = this.dbGears.execute("select count(*) from queue where user=? and sent=0",[account_id]);
1084	var to_return = rs.field(0);
1085
1086	this.finalize();
1087	return to_return;
1088	}
1089
1090	local_messages.prototype.set_problem_on_sent = function(rowid_message,msg) {
1091	this.init_local_messages();
1092	this.dbGears.execute("update queue set sent = 2 where rowid=?",[rowid_message]);
1093	this.dbGears.execute("insert into sent_problems (id_queue,message) values (?,?)"[rowid_message,msg]);
1094	this.finalize();
1095	}
1096
1097	local_messages.prototype.set_as_sent = function(rowid_message) {
1098	this.init_local_messages();
1099	this.dbGears.execute("update queue set sent = 1 where rowid=?",[rowid_message]);
1100	this.finalize();
1101	}
1102
1103	local_messages.prototype.get_form_msg_to_send = function() {
1104	this.init_local_messages();
1105	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]);
1106	if(!rs.isValidRow())
1107	return false;
1108
1109	var form = document.createElement('form');
1110	form.method = 'POST';
1111	form.name = 'form_queue_'+rs.field(8);
1112	form.style.display = 'none';
1113	form.onsubmit = function(){return false;}
1114	if(!is_ie)
1115	form.enctype="multipart/form-data";
1116	else
1117	form.encoding="multipart/form-data";
1118
1119	var ffrom = document.createElement('TEXTAREA');
1120	ffrom.name = "input_from";
1121	ffrom.value = rs.field(0);
1122	form.appendChild(ffrom);
1123
1124	var fto = document.createElement('TEXTAREA');
1125	fto.name = "input_to";
1126	fto.value = rs.field(1);
1127	form.appendChild(fto);
1128
1129	var cc = document.createElement('TEXTAREA');
1130	cc.name = "input_cc";
1131	cc.value = rs.field(2);
1132	form.appendChild(cc);
1133
1134	var cco = document.createElement('TEXTAREA');
1135	cco.name = "input_cco";
1136	cco.value = rs.field(3);
1137	form.appendChild(cco);
1138
1139	var subject = document.createElement('TEXTAREA');
1140	subject.name = "input_subject";
1141	subject.value = rs.field(4);
1142	form.appendChild(subject);
1143
1144	var folder = document.createElement('input');
1145	folder.name='folder';
1146	folder.value=preferences.save_in_folder;
1147	form.appendChild(folder);
1148
1149	if (rs.field(5) == 1) {
1150	var conf_receipt = document.createElement('input');
1151	conf_receipt.type='text';
1152	conf_receipt.name = "input_return_receipt";
1153	conf_receipt.value = 'on';
1154	form.appendChild(conf_receipt);
1155	}
1156
1157	if (rs.field(6) == 1) {
1158	var important = document.createElement('input');
1159	important.type='text';
1160	important.name = "input_important_message";
1161	important.value = 'on';
1162	form.appendChild(important);
1163	}
1164
1165	var body = document.createElement('TEXTAREA');
1166	body.name = "body";
1167	body.value = rs.field(7);
1168	form.appendChild(body);
1169
1170	var rowid = document.createElement('input');
1171	rowid.type = 'hidden';
1172	rowid.name = 'rowid';
1173	rowid.value = rs.field(8);
1174	form.appendChild(rowid);
1175
1176	//Mounting the attachs
1177	var divFiles = document.createElement("div");
1178	divFiles.id = 'divFiles_queue_'+rs.field(8);
1179
1180	form.appendChild(divFiles);
1181
1182	document.getElementById('forms_queue').appendChild(form);
1183
1184	var is_local_forward = false;
1185	try {
1186
1187	var rs_attach = this.dbGears.execute('select url_attach from attachments_queue where id_queue=?', [rs.field(8)]);
1188	while (rs_attach.isValidRow()) {
1189	if(rs_attach.field(0).indexOf('../tmpLclAtt/')==-1) {
1190	tmp_field = addForwardedFile('queue_' + rs.field(8), this.store.getCapturedFileName(rs_attach.field(0)), 'nothing');
1191	}
1192	else {
1193	var tempNomeArquivo = rs_attach.field(0).split("/");
1194	var nomeArquivo = tempNomeArquivo[tempNomeArquivo.length-1];
1195	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.
1196	is_local_forward = true;
1197	tmp_field = addForwardedFile('queue_' + rs.field(8), nomeArquivo, 'nothing');
1198	}
1199	fileSubmitter = this.store.createFileSubmitter();
1200	fileSubmitter.setFileInputElement(tmp_field,rs_attach.field(0));
1201	// alert(form.innerHTML);
1202	// div.appendChild(tmp_field);
1203	rs_attach.next();
1204	}
1205
1206	if(is_local_forward) {
1207	var is_lcl_fw = document.createElement('input');
1208	is_lcl_fw.type = 'hidden';
1209	is_lcl_fw.name = 'is_local_forward';
1210	is_lcl_fw.value = "1";
1211	form.appendChild(is_lcl_fw);
1212	}
1213
1214	}
1215	catch(exception) {
1216	alert(exception);
1217	}
1218
1219	this.finalize();
1220	return form;
1221	}
1222
1223	var expresso_local_messages;
1224	expresso_local_messages = new local_messages();

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

Download in other formats: