Context Navigation

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

Revision 1477, 42.7 KB checked in by eduardoalex, 15 years ago (diff)
Ticket #611 - Adição da funcionalidade. (aqui é para completar os 40 caracteres)

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

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

Download in other formats: