meillo@0: /*  MasqMail
meillo@0:     Copyright (C) 1999-2001 Oliver Kurth
meillo@0: 
meillo@0:     This program is free software; you can redistribute it and/or modify
meillo@0:     it under the terms of the GNU General Public License as published by
meillo@0:     the Free Software Foundation; either version 2 of the License, or
meillo@0:     (at your option) any later version.
meillo@0: 
meillo@0:     This program is distributed in the hope that it will be useful,
meillo@0:     but WITHOUT ANY WARRANTY; without even the implied warranty of
meillo@0:     MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
meillo@0:     GNU General Public License for more details.
meillo@0: 
meillo@0:     You should have received a copy of the GNU General Public License
meillo@0:     along with this program; if not, write to the Free Software
meillo@0:     Foundation, Inc., 59 Temple Place - Suite 330, Boston, MA 02111-1307, USA.
meillo@0: */
meillo@0: 
meillo@0: #include "masqmail.h"
meillo@0: 
meillo@0: #include <sys/stat.h>
meillo@0: #include <glob.h>
meillo@0: 
meillo@0: static
meillo@0: void mix_arr(int *buf, int len)
meillo@0: {
meillo@0:   int i;
meillo@0: 
meillo@0:   for(i = 0; i < len; i++)
meillo@0:     buf[i] = i;
meillo@0:   for(i = 0; i < len-1; i++){
meillo@0:     int j = (int)((float)(len-i) * ((float)rand())/(RAND_MAX + 1.0));
meillo@0:     int tmp;
meillo@0: 
meillo@0:     if(i != j){
meillo@0:       tmp = buf[i]; buf[i] = buf[j]; buf[j] = tmp;
meillo@0:     }
meillo@0:   }
meillo@0: }
meillo@0: 
meillo@0: GList *read_queue(gboolean do_readdata)
meillo@0: {
meillo@0:   GList *msg_list = NULL;
meillo@0:   glob_t gl;
meillo@0:   gchar *pattern;
meillo@0:   int i, *idx_arr;
meillo@0: 
meillo@0:   pattern = g_strdup_printf("%s/input/??????-???-??-H", conf.spool_dir);
meillo@0:   gl.gl_offs = 0;
meillo@0:   glob(pattern, 0, NULL, &gl);
meillo@0: 
meillo@0:   g_free(pattern);
meillo@0: 
meillo@0:   DEBUG(4){
meillo@0:     int i;
meillo@0:     for(i = 0; i < gl.gl_pathc; i++){
meillo@0:       debugf("spoolfile: %s\n", gl.gl_pathv[i]);
meillo@0:     }
meillo@0:   }
meillo@0: 
meillo@0:   idx_arr = g_malloc(sizeof(int) * gl.gl_pathc);
meillo@0:   mix_arr(idx_arr, gl.gl_pathc);
meillo@0: 
meillo@0:   for(i = 0; i < gl.gl_pathc; i++){
meillo@0:     gchar *uid;
meillo@0: 
meillo@0:     /* copy 13 chars, offset spooldir path + 7 chars for /input/ */
meillo@0:     /* uid length = 6 chars + '-' + 3 chars + '-' + 2 = 13 chars */
meillo@0:     uid = g_strndup(&(gl.gl_pathv[idx_arr[i]][strlen(conf.spool_dir) + 7]), 13);
meillo@0: 
meillo@0:     DEBUG(5) debugf("uid: %s\n", uid);
meillo@0: 
meillo@0:     msg_list = g_list_append(msg_list, msg_spool_read(uid, do_readdata));
meillo@0: 
meillo@0:     DEBUG(5) debugf("after read spool file for %s\n", uid);
meillo@0: 
meillo@0:     g_free(uid);
meillo@0:   }
meillo@0:   return msg_list;
meillo@0: }
meillo@0: 
meillo@0: gboolean queue_run()
meillo@0: {
meillo@0:   GList *msg_list;
meillo@0:   gboolean ok = TRUE;
meillo@0: 
meillo@0:   logwrite(LOG_NOTICE, "Starting queue run.\n");
meillo@0: 
meillo@0:   msg_list = read_queue(FALSE);
meillo@0: 
meillo@0:   if(msg_list != NULL){
meillo@0:     ok = deliver_msg_list(msg_list, DLVR_ALL);
meillo@0:     destroy_msg_list(msg_list);
meillo@0:   }
meillo@0:   logwrite(LOG_NOTICE, "Finished queue run.\n");
meillo@0: 
meillo@0:   return ok;
meillo@0: }
meillo@0: 
meillo@0: gboolean queue_run_online()
meillo@0: {
meillo@0:   GList *msg_list = read_queue(FALSE);
meillo@0:   gboolean ok = TRUE;
meillo@0: 
meillo@0:   logwrite(LOG_NOTICE, "Starting online queue run.\n");
meillo@0:   if(msg_list != NULL){
meillo@0:     ok = deliver_msg_list(msg_list, DLVR_ONLINE);
meillo@0:     destroy_msg_list(msg_list);
meillo@0:   }
meillo@0:   logwrite(LOG_NOTICE, "Finished online queue run.\n");
meillo@0: 
meillo@0:   return ok;
meillo@0: }
meillo@0: 
meillo@0: static
meillo@0: gchar *format_difftime(double secs)
meillo@0: {
meillo@0:   if(secs > 86400)
meillo@0:     return g_strdup_printf("%.1fd", secs/86400);
meillo@0:   else if(secs > 3600)
meillo@0:     return g_strdup_printf("%.1fh", secs/3600);
meillo@0:   else if(secs > 60)
meillo@0:     return g_strdup_printf("%.1fm", secs/60);
meillo@0:   else
meillo@0:     return g_strdup_printf("%.0fs", secs);
meillo@0: }  
meillo@0: 
meillo@0: void queue_list()
meillo@0: {
meillo@0:   GList *msg_list;
meillo@0:   GList *msg_node;
meillo@0: 
meillo@0:   msg_list = read_queue(FALSE);
meillo@0: 
meillo@0:   if(msg_list != NULL){
meillo@0:     foreach(msg_list, msg_node){
meillo@0:       message *msg = (message *)(msg_node->data);
meillo@0:       GList *rcpt_node;
meillo@0:       gchar *size_str = NULL;
meillo@0:       gchar *time_str = NULL;
meillo@0:       gchar *host_str = NULL;
meillo@0:       gchar *ident_str = NULL;
meillo@0:     
meillo@0:       if(msg->data_size >= 0)
meillo@0: 	size_str = g_strdup_printf(" size=%d", msg->data_size);
meillo@0:       if(msg->received_time > 0){
meillo@0: 	gchar *tmp_str;
meillo@0: 	time_str =
meillo@0: 	  g_strdup_printf(" age=%s",
meillo@0: 			  tmp_str = format_difftime(difftime(time(NULL),
meillo@0: 							     msg->received_time)));
meillo@0: 	g_free(tmp_str);
meillo@0:       }
meillo@0:       if(msg->received_host != NULL)
meillo@0: 	host_str = g_strdup_printf(" host=%s", msg->received_host);
meillo@0:       if(msg->ident != NULL)
meillo@0: 	ident_str = g_strdup_printf(" ident=%s", msg->ident);
meillo@0: 
meillo@0:       printf("%s <= %s%s%s%s%s\n", msg->uid,
meillo@0: 	     addr_string(msg->return_path),
meillo@0: 	     size_str ? size_str : "",
meillo@0: 	     time_str ? time_str : "",
meillo@0: 	     host_str ? host_str : "",
meillo@0: 	     ident_str ? ident_str : ""
meillo@0: 	     );
meillo@0: 
meillo@0:       if(size_str) g_free(size_str);
meillo@0:       if(time_str) g_free(time_str);
meillo@0:       if(host_str) g_free(host_str);
meillo@0:       if(ident_str) g_free(ident_str);
meillo@0: 
meillo@0:       foreach(msg->rcpt_list, rcpt_node){
meillo@0: 	address *rcpt = (address *)(rcpt_node->data);
meillo@0:       
meillo@0: 	printf("              %s %s\n",
meillo@0: 	       addr_is_delivered(rcpt) ? "=>" : (addr_is_failed(rcpt) ? "!=" : "=="),
meillo@0: 	       addr_string(rcpt));
meillo@0:       }
meillo@0:       g_free(msg);
meillo@0:     }
meillo@0:   }else
meillo@0:     printf("mail queue is empty.\n");
meillo@0: }  
meillo@0: 
meillo@0: gboolean queue_delete(gchar *uid)
meillo@0: {
meillo@0:   gboolean hdr_ok = TRUE;
meillo@0:   gboolean dat_ok = TRUE;
meillo@0:   gchar *hdr_name = g_strdup_printf("%s/input/%s-H", conf.spool_dir, uid);
meillo@0:   gchar *dat_name = g_strdup_printf("%s/input/%s-D", conf.spool_dir, uid);
meillo@0:   struct stat stat_buf;
meillo@0: 
meillo@0:   if(spool_lock(uid)){
meillo@0: 
meillo@0:     if(stat(hdr_name, &stat_buf) == 0){
meillo@0:       if(unlink(hdr_name) != 0){
meillo@0: 	fprintf(stderr, "could not unlink %s: %s\n", hdr_name, strerror(errno));
meillo@0: 	hdr_ok = FALSE;
meillo@0:       }
meillo@0:     }else{
meillo@0:       fprintf(stderr, "could not stat file %s: %s\n", hdr_name, strerror(errno));
meillo@0:       hdr_ok = FALSE;
meillo@0:     }
meillo@0:     if(stat(dat_name, &stat_buf) == 0){
meillo@0:       if(unlink(dat_name) != 0){
meillo@0: 	fprintf(stderr, "could not unlink %s: %s\n", dat_name, strerror(errno));
meillo@0: 	dat_ok = FALSE;
meillo@0:       }
meillo@0:     }else{
meillo@0:       fprintf(stderr, "could not stat file %s: %s\n", dat_name, strerror(errno));
meillo@0:       dat_ok = FALSE;
meillo@0:     }
meillo@0:     printf("message %s deleted\n", uid);
meillo@0: 
meillo@0:     spool_unlock(uid);
meillo@0: 
meillo@0:   }else{
meillo@0: 
meillo@0:     fprintf(stderr, "message %s is locked.\n", uid);
meillo@0:     return FALSE;
meillo@0:   }
meillo@0: 
meillo@0:   return (dat_ok && hdr_ok);
meillo@0: }