Context Navigation

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

Revision 1381, 42.0 KB checked in by eduardoalex, 15 years ago (diff)
Ticket #458 - Ajuste na função delete_msgs decrementando o contador

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

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

Download in other formats: