qmail-qmaint.c

Go to the documentation of this file.

/*
  Based on an implementation of queue-fix 1.2 by Eric Huss
*/
#include <unistd.h>
#include <sys/stat.h>
#include <pwd.h>
#include <grp.h>
#include <stdio.h> // rename
#include "stralloc.h"
#include "direntry.h"
#include "fmt.h"
#include "fmtqfn.h"
#include "error.h"
#include "buffer.h"
#include "getln.h"
#include "str.h"
#include "open.h"
#include "fifo.h"
#include "scan.h"
#include "readsubdir.h"
#include "logmsg.h"
#include "exit.h"
#include "auto_queue.h"
#include "auto_split.h"
#include "auto_uids.h"
#include "datetime.h"
#include "date822fmt.h"
 
#define WHO "qmail-qmaint"
 
stralloc queue_dir     = {0}; /*the root queue dir with trailing slash*/
stralloc check_dir     = {0}; /*the current directory being checked*/
stralloc temp_dirname  = {0}; /*temporary used for checking directories */
stralloc temp_filename = {0}; /*temporary used for checking individuals*/
stralloc old_name      = {0}; /*used in rename*/
stralloc new_name      = {0}; /*used in rename*/
stralloc mess_dir      = {0}; /*used for renaming in mess dir*/
stralloc dkim_dir      = {0}; /*used for cleaning up dkim dir*/
stralloc query         = {0}; /*used in interactive query function*/
stralloc birth_date    = {0}; /*used to display dkim messages*/
 
char strnum[FMT_ULONG];
int flag_interactive = 0;
int flag_dircreate = 0;
int flag_filecreate = 0;
int flag_permfix = 0;
int flag_namefix = 0;
int flag_delete = 0;
 
int qmailq_uid;
int qmails_uid;
int qmailr_uid;
int qmail_gid;
int split_num;
 
static void die_make(char *name)
{
  logmsg(WHO,111,ERROR,B("Failed to make: ",name));
}
 
static void die_check()
{
  logmsg(WHO,111,ERROR,"Failed while checking directory structure. \nEnsure the given queue exists and you have permission to access it.");
}
 
static void die_nomem()
{
  logmsg(WHO,110,ERROR,"Out of memory.");
}
 
static void err_unlink(unsigned long id)
{
   char foo[FMT_ULONG];
   foo[fmt_ulong(foo,id)] = 0;
   logmsg(WHO,100,ERROR,B("trouble with unlinking #",foo));
}
 
static void err_chdir()
{
   logmsg(WHO,110,FATAL,"unable to chdir");
}
 
/*returns 1==yes, 0==no*/
 
static int confirm()
{
  int match;
 
  if (getln(buffer_0,&query,&match,'\n')) return 0;
  if (!match) return 0;
  if (query.s[0] == 'y' || query.s[0] == 'Y' || query.s[0] == '\n') return 1;
  return 0;
}
 
/*gid may be -1 on files for "unknown*/
 
#define DIRS logmsg(WHO,0,WARN,"It looks like some directories don't exist, should I create them? (Y/n)")
#define FILES logmsg(WHO,0,WARN,"It looks like some files don't exist, should I create them? (Y/n)")
 
#define PERMS logmsg(WHO,0,WARN,B("It looks like permissions are wrong for ",name," should I fix them? (Y/n)"))
#define CPERMS logmsg(WHO,0,WARN,B("Changing permissions: ",name," => ",pnum))
 
#define OWNER logmsg(WHO,0,WARN,B("It looks like ownerships are wrong for ",name," should I fix them? (Y/n)"))
#define COWNER logmsg(WHO,0,WARN,B("Changing ownership: ",name," => ",unum,"/",gnum))
 
static int check_item(char *name,int uid,int gid,int perm,char type,int size)
{
  struct stat st;
  int fd;
  char num[12];
  char unum[12];
  char gnum[12];
  char pnum[12];
 
 /*check for existence and proper credentials*/
 
  strnum[fmt_uint(unum,uid)] = 0;
  strnum[fmt_uint(gnum,gid)] = 0;
  strnum[fmt_uint(pnum,perm)] = 0;
 
  switch (type) {
   case 'd': /*directory*/
             if (stat(name,&st)) {
               if (errno != ENOENT) return -1;
               if (!flag_dircreate && flag_interactive) {
                 DIRS; if (!confirm()) return -1;
                 flag_dircreate = 1;
               }
               /*create it*/
               logmsg(WHO,0,INFO,B("Creating directory: ",name));
               if (mkdir(name,perm)) die_make(name); 
               CPERMS; if (chmod(name,perm)) die_make(name); 
               COWNER; if (chown(name,uid,gid)) die_make(name);
               return 0;
             }
             /*check the values*/
             if (st.st_uid != uid || st.st_gid != gid) { 
               if (!flag_permfix && flag_interactive) { OWNER; if (!confirm()) return -1; flag_permfix = 1; }
               COWNER; if (chown(name,uid,gid)) die_make(name);
             }
             if ((st.st_mode & 07777) != perm) {
               if (!flag_permfix && flag_interactive) { PERMS; if (!confirm()) return -1; flag_permfix = 1; } 
               CPERMS; if (chmod(name,perm)) die_make(name);
             }
            return 0;
   case 'f': /*regular file*/
             if (stat(name,&st)) return -1;
             /*check the values*/
             if (st.st_uid != uid || (st.st_gid != gid && gid != -1)) {
               if (!flag_permfix && flag_interactive) { OWNER; if (!confirm()) return -1; flag_permfix = 1; }
               COWNER; if (chown(name,uid,gid)) die_make(name);
             }
             if ((st.st_mode & 07777) != perm) {
               if (!flag_permfix && flag_interactive) { PERMS; if (!confirm()) return -1; flag_permfix = 1; }
               CPERMS; if (chmod(name,perm)) die_make(name);
             }
             return 0;
   case 'z': /*regular file with a size*/
             if (stat(name,&st)) {
               if (errno != ENOENT) return -1;
               if (!flag_filecreate && flag_interactive) {
                 FILES; if (!confirm()) return -1;
                 flag_filecreate = 1;
               }
               /*create it*/
 
               strnum[fmt_ulong(num,size)] = 0;
               logmsg(WHO,0,INFO,B("Creating: ",name," with size ",num));
               fd = open_trunc(name);
               if (fd == -1) die_make(name);
               while (size--) { if (write(fd,"",1)!=1) die_make(name); }
               close(fd);
               CPERMS; if (chmod(name,perm)) die_make(name);
               COWNER; if (chown(name,uid,gid)) die_make(name);
               return 0;
             }
             /*check the values*/
             if (st.st_uid != uid || (st.st_gid != gid && gid != -1)) {
               if (!flag_permfix && flag_interactive) { OWNER; if (!confirm()) return -1; flag_permfix = 1; }
               COWNER; if (chown(name,uid,gid)) die_make(name);
             }
             if ((st.st_mode & 07777) != perm) {
               if (!flag_permfix && flag_interactive) { PERMS; if (!confirm()) return -1; flag_permfix = 1; }
               CPERMS; if (chmod(name,perm)) die_make(name);
             }
             if (st.st_size != size) {
                logmsg(WHO,0,WARN,B("File ",name," has not the right size. I will not fix it, please investigate."));
             }
              return 0;
    case 'p': /*a named pipe*/
             if (stat(name,&st)) {
                if (errno != ENOENT) return -1;
                if (!flag_filecreate && flag_interactive) {
                  FILES; if (!confirm()) return -1;
                  flag_filecreate = 1;
                }
                /*create it*/
                logmsg(WHO,INFO,0,B("Creating fifo: ",name));
                if (fifo_make(name,perm)) die_make(name);
                CPERMS; if (chmod(name,perm)) die_make(name);
                COWNER; if (chown(name,uid,gid)) die_make(name);
                return 0;
             }
             /*check the values*/
             if (st.st_uid != uid || (st.st_gid != gid && gid != -1)) {
               if (!flag_permfix && flag_interactive) { OWNER; if (!confirm()) return -1; flag_permfix = 1; }
               COWNER; if (chown(name,uid,gid)) die_make(name);
             }
             if ((st.st_mode & 07777) != perm) {
               if (!flag_permfix && flag_interactive) { PERMS; if (!confirm()) return -1; flag_permfix = 1; }
               CPERMS; if (chmod(name,perm)) die_make(name); 
             }
             return 0;
  } 
 
  return 0;
}
 
static int check_files(char * directory,int uid,int gid,int perm)
{
  DIR *dir;
  direntry *d;
 
  dir = opendir(directory);
 
  if (!dir) return -1;
  while ((d = readdir(dir))) {
    if (d->d_name[0] == '.') continue;
    if (!stralloc_copys(&temp_filename,directory)) die_nomem();
    if (!stralloc_append(&temp_filename,"/")) die_nomem();
    if (!stralloc_cats(&temp_filename,d->d_name)) die_nomem();
    if (!stralloc_0(&temp_filename)) die_nomem();
    if (check_item(temp_filename.s,uid,gid,perm,'f',0))  { closedir(dir); return -1; }
  }
  closedir(dir);
  return 0;
}
 
static void warn_files(char * directory)
{
  DIR *dir;
  direntry *d;
  int found = 0;
 
  dir = opendir(directory);
  if (!dir) return;
 
  while ((d = readdir(dir))) {
    if (d->d_name[0] == '.') continue;
    found = 1;
    break;
  }
 
  closedir(dir);
 
  if (found) 
    logmsg(WHO,0,WARN,B("Found files in ",directory," that shouldn't be there. I will not remove them. You should consider checking it out."));
}
 
static int check_splits(char * directory,int dir_uid,int dir_gid,int dir_perm,int file_gid,int file_perm) 
{
  DIR *dir;
  direntry *d;
  int i;
 
  for (i = 0; i < split_num ; i++) {
    strnum[fmt_ulong(strnum,i)] = 0;
    if (!stralloc_copys(&temp_dirname,directory)) die_nomem();
    if (!stralloc_append(&temp_dirname,"/")) die_nomem();
    if (!stralloc_cats(&temp_dirname,strnum)) die_nomem();
    if (!stralloc_0(&temp_dirname)) die_nomem();
 
    /*check the split dir*/
    if (check_item(temp_dirname.s,dir_uid,dir_gid,dir_perm,'d',0)) return -1;
 
    /*check its contents*/
    dir = opendir(temp_dirname.s);
    if (!dir) return -1;
    while ((d = readdir(dir))) {
      if (d->d_name[0] == '.') continue;
      if (!stralloc_copys(&temp_filename,temp_dirname.s)) die_nomem();
      if (!stralloc_append(&temp_filename,"/")) die_nomem();
      if (!stralloc_cats(&temp_filename,d->d_name)) die_nomem();
      if (!stralloc_0(&temp_filename)) die_nomem();
      if (check_item(temp_filename.s,dir_uid,file_gid,file_perm,'f',0)) { closedir(dir); return -1; }
    }
    closedir(dir);
  } 
 
  return 0;
}
 
static int rename_mess(char *dir,char *part,char *new_part,char *old_filename,char *new_filename)
{
 
  if (flag_interactive && !flag_namefix) {
    logmsg(WHO,0,INFO,"It looks like some files need to be renamed, should I rename them? (Y/n)\n");
    if (!confirm()) return -1;
    flag_namefix = 1;
  }
 
  /*prepare the old filename*/
  if (!stralloc_copy(&old_name,&queue_dir)) die_nomem();
  if (!stralloc_cats(&old_name,dir)) die_nomem();
  if (!stralloc_cats(&old_name,part)) die_nomem();
  if (!stralloc_append(&old_name,"/")) die_nomem();
  if (!stralloc_cats(&old_name,old_filename)) die_nomem();
  if (!stralloc_0(&old_name)) die_nomem();
 
  /*prepare the new filename*/
  if (!stralloc_copy(&new_name,&queue_dir)) die_nomem();
  if (!stralloc_cats(&new_name,dir)) die_nomem();
  if (!stralloc_cats(&new_name,new_part)) die_nomem();
  if (!stralloc_append(&new_name,"/")) die_nomem();
  if (!stralloc_cats(&new_name,new_filename)) die_nomem();
  if (!stralloc_0(&new_name)) die_nomem();
 
  logmsg(WHO,0,INFO,B("Renaming ",old_name.s," to ",new_name.s));
  if (rename(old_name.s,new_name.s)) {
    if (errno != ENOENT) return -1; 
  }
 
  return 0;
}
 
static unsigned int datefmt(char *s,datetime_sec when)
{
  unsigned int i;
  unsigned int len;
  struct datetime dt;
  datetime_tai(&dt,when);
  len = 0;
  i = fmt_str(s," Date: "); len += i; if (s) s += i;
  i = date822fmt(s,&dt); len += i; if (s) s += i;
  return len;
}
 
static int date_make(datetime_sec when)
{
  if (!stralloc_ready(&birth_date,datefmt(FMT_LEN,when))) return 0;
  birth_date.len = datefmt(birth_date.s,when);
  return 1;
} 
 
static int cleanup_dkim()
{
  DIR *dir;
  direntry *d;
  struct stat st;
  int deleted = 0;
 
  if (chdir(auto_queue) == -1) err_chdir(); 
  if (chdir("queue/dkim") == -1) return 0;
 
  if (!stralloc_copy(&dkim_dir,&queue_dir)) die_nomem();
  if (!stralloc_cats(&dkim_dir,"dkim/")) die_nomem();
 
  for (int i = 0; i < split_num; i++) {
    strnum[fmt_uint(strnum,i)] = 0; 
    if (!stralloc_copy(&temp_dirname,&dkim_dir)) die_nomem();
    if (!stralloc_cats(&temp_dirname,strnum)) die_nomem();
    if (!stralloc_append(&temp_dirname,"/")) die_nomem();
 
    dir = opendir(temp_dirname.s);
    if (!dir) continue;
 
    while ((d = readdir(dir))) {
      if (d->d_name[0] == '.') continue;
      /*check for dkim remnant */
      if (!stralloc_copy(&temp_filename,&temp_dirname)) die_nomem();
      if (!stralloc_cats(&temp_filename,d->d_name)) die_nomem();
      if (!stralloc_0(&temp_filename)) die_nomem();
 
      if (stat(temp_filename.s,&st) == -1) continue;
      date_make(st.st_mtime);
      // message
      logmsg(WHO,0,INFO,B("Deleting DKIM remnant message: ",temp_filename.s,birth_date.s," !"));
      // delete
      if (unlink(temp_filename.s) == -1) {
        logmsg(WHO,111,ERROR,B("Can't remove file: ",temp_filename.s));
      }
      // counter
      ++deleted;
    }
  }    
 
  return deleted;
}
 
static int fix_part(char *part)
{
  DIR *dir;
  direntry *d;
  struct stat st;
  char inode[FMT_ULONG];
  char new_part[FMT_ULONG];
  unsigned int old_inode;
  unsigned int part_num;
  unsigned int correct_part_num;
 
  scan_uint(part,&part_num);
 
  if (!stralloc_copy(&mess_dir,&queue_dir)) die_nomem();
  if (!stralloc_cats(&mess_dir,"mess/")) die_nomem();
  if (!stralloc_cats(&mess_dir,part)) die_nomem();
  if (!stralloc_0(&mess_dir)) die_nomem();
 
  dir = opendir(mess_dir.s);
  if (!dir) return -1;
 
  while ((d = readdir(dir))) {
    if (d->d_name[0] == '.') continue;
    /*check from mess*/
    if (!stralloc_copys(&temp_filename,mess_dir.s)) die_nomem();
    if (!stralloc_append(&temp_filename,"/")) die_nomem();
    if (!stralloc_cats(&temp_filename,d->d_name)) die_nomem();
    if (!stralloc_0(&temp_filename)) die_nomem();
    if (stat(temp_filename.s,&st)) { closedir(dir); return -1; }
 
    /*check that filename == inode number*/
    /*check that inode%auto_split == part_num*/
    scan_uint(d->d_name,&old_inode);
    correct_part_num = st.st_ino % split_num;
    if (st.st_ino != old_inode || part_num != correct_part_num) {
      /*rename*/
      inode[fmt_ulong(inode,st.st_ino)] = 0;
      new_part[fmt_ulong(new_part,correct_part_num)] = 0;
      if (rename_mess("dkim/",part,new_part,d->d_name,inode)) { closedir(dir); return -1; }
      if (rename_mess("mess/",part,new_part,d->d_name,inode)) { closedir(dir); return -1; }
      if (rename_mess("info/",part,new_part,d->d_name,inode)) { closedir(dir); return -1; }
      if (rename_mess("local/",part,new_part,d->d_name,inode)) { closedir(dir); return -1; }
      if (rename_mess("remote/",part,new_part,d->d_name,inode)) { closedir(dir); return -1; }
      if (rename_mess("todo/",part,new_part,d->d_name,inode)) { closedir(dir); return -1; }
      if (rename_mess("intd/",part,new_part,d->d_name,inode)) { closedir(dir); return -1; }
 
      if (rename_mess("bounce","","",d->d_name,inode)) { closedir(dir); return -1; }
    }
  }
 
  closedir(dir);
  return 0;
}
 
static int fix_names()
{
  int i;
 
  if (!stralloc_copy(&check_dir,&queue_dir)) die_nomem();
  if (!stralloc_cats(&check_dir,"mess")) die_nomem();
  if (!stralloc_0(&check_dir)) die_nomem();
 
  for (i = 0; i < split_num; i++) {
     strnum[fmt_ulong(strnum,i)] = 0;
    if (fix_part(strnum)) return -1;
  }
 
 return 0;
}
 
static int check_dirs()
{
  /*check queue existence*/
  if (!stralloc_copy(&check_dir,&queue_dir)) die_nomem();
  if (!stralloc_0(&check_dir)) die_nomem();
  if (check_item(check_dir.s,qmailq_uid,qmail_gid,0750,'d',0)) return -1;
 
  if (!stralloc_copy(&check_dir,&queue_dir)) die_nomem();
  if (!stralloc_cats(&check_dir,"info")) die_nomem();
  if (!stralloc_0(&check_dir)) die_nomem();
  if (check_item(check_dir.s,qmails_uid,qmail_gid,0700,'d',0)) return -1;
  if (check_splits(check_dir.s,qmails_uid,qmail_gid,0700,qmail_gid,0600)) return -1;
 
  if (!stralloc_copy(&check_dir,&queue_dir)) die_nomem();
  if (!stralloc_cats(&check_dir,"mess")) die_nomem();
  if (!stralloc_0(&check_dir)) die_nomem();
  if (check_item(check_dir.s,qmailq_uid,qmail_gid,0750,'d',0)) return -1;
  if (check_splits(check_dir.s,qmailq_uid,qmail_gid,0750,-1,0644)) return -1;
 
  if (!stralloc_copy(&check_dir,&queue_dir)) die_nomem();
  if (!stralloc_cats(&check_dir,"remote")) die_nomem();
  if (!stralloc_0(&check_dir)) die_nomem();
  if (check_item(check_dir.s,qmails_uid,qmail_gid,0700,'d',0)) return -1;
  if (check_splits(check_dir.s,qmails_uid,qmail_gid,0700,qmail_gid,0600)) return -1;
 
  if (!stralloc_copy(&check_dir,&queue_dir)) die_nomem();
  if (!stralloc_cats(&check_dir,"local")) die_nomem();
  if (!stralloc_0(&check_dir)) die_nomem();
  if (check_item(check_dir.s,qmails_uid,qmail_gid,0700,'d',0)) return -1;
  if (check_splits(check_dir.s,qmails_uid,qmail_gid,0700,qmail_gid,0600)) return -1;
 
  if (!stralloc_copy(&check_dir,&queue_dir)) die_nomem();
  if (!stralloc_cats(&check_dir,"intd")) die_nomem();
  if (!stralloc_0(&check_dir)) die_nomem();
  if (check_item(check_dir.s,qmailq_uid,qmail_gid,0700,'d',0)) return -1;
  if (check_splits(check_dir.s,qmailq_uid,qmail_gid,0700,qmail_gid,0600)) return -1;
 
  /*check the bigtodo queue */
  if (!stralloc_copy(&check_dir,&queue_dir)) die_nomem();
  if (!stralloc_cats(&check_dir,"todo")) die_nomem();
  if (!stralloc_0(&check_dir)) die_nomem();
  if (check_item(check_dir.s,qmailq_uid,qmail_gid,0750,'d',0)) return -1;
  if (check_splits(check_dir.s,qmailq_uid,qmail_gid,0750,-1,0644)) return -1;
 
  /*check the dkim staging area */
  if (!stralloc_copy(&check_dir,&queue_dir)) die_nomem();
  if (!stralloc_cats(&check_dir,"dkim")) die_nomem();
  if (!stralloc_0(&check_dir)) die_nomem();
  if (check_item(check_dir.s,qmailq_uid,qmail_gid,0750,'d',0)) return -1;
  if (check_splits(check_dir.s,qmailq_uid,qmail_gid,0750,qmail_gid,0644)) return -1;
 
  /*check the others*/
  if (!stralloc_copy(&check_dir,&queue_dir)) die_nomem();
  if (!stralloc_cats(&check_dir,"bounce")) die_nomem();
  if (!stralloc_0(&check_dir)) die_nomem();
  if (check_item(check_dir.s,qmails_uid,qmail_gid,0700,'d',0)) return -1;
  if (check_files(check_dir.s,qmails_uid,qmail_gid,0600)) return -1;
 
  if (!stralloc_copy(&check_dir,&queue_dir)) die_nomem();
  if (!stralloc_cats(&check_dir,"pid")) die_nomem();
  if (!stralloc_0(&check_dir)) die_nomem();
  if (check_item(check_dir.s,qmailq_uid,qmail_gid,0700,'d',0)) return -1;
 
  warn_files(check_dir.s);
 
  /* lock has special files that must exist */
  if (!stralloc_copy(&check_dir,&queue_dir)) die_nomem();
  if (!stralloc_cats(&check_dir,"lock")) die_nomem();
  if (!stralloc_0(&check_dir)) die_nomem();
  if (check_item(check_dir.s,qmailq_uid,qmail_gid,0750,'d',0)) return -1;
 
  if (!stralloc_copy(&check_dir,&queue_dir)) die_nomem();
  if (!stralloc_cats(&check_dir,"lock/sendmutex")) die_nomem();
  if (!stralloc_0(&check_dir)) die_nomem();
  if (check_item(check_dir.s,qmails_uid,qmail_gid,0600,'z',0)) return -1;
 
  if (!stralloc_copy(&check_dir,&queue_dir)) die_nomem();
  if (!stralloc_cats(&check_dir,"lock/tcpto")) die_nomem();
  if (!stralloc_0(&check_dir)) die_nomem();
  if (check_item(check_dir.s,qmailr_uid,qmail_gid,0644,'z',1024)) return -1;
 
  if (!stralloc_copy(&check_dir,&queue_dir)) die_nomem();
  if (!stralloc_cats(&check_dir,"lock/trigger")) die_nomem();
  if (!stralloc_0(&check_dir)) die_nomem();
  if (check_item(check_dir.s,qmails_uid,qmail_gid,0622,'p',0)) return -1;
 
  return 0;
}
 
/* stolen from qmail-send */
 
stralloc fn = {0};
 
static void fnmake_init() { while (!stralloc_ready(&fn,FMTQFN)) die_nomem(); }
static void fnmake_local(unsigned long id) { fn.len = fmtqfn(fn.s,"local/",id,1); }
static void fnmake_remote(unsigned long id) { fn.len = fmtqfn(fn.s,"remote/",id,1); }
static void fnmake_mess(unsigned long id) { fn.len = fmtqfn(fn.s,"mess/",id,1); }
static void fnmake_dkim(unsigned long id) { fn.len = fmtqfn(fn.s,"dkim/",id,1); }
static void fnmake_info(unsigned long id) { fn.len = fmtqfn(fn.s,"info/",id,1); }
static void fnmake_bounce(unsigned long id) { fn.len = fmtqfn(fn.s,"bounce/",id,0); }
 
static void warn_unlink(unsigned long id)
{
   char foo[FMT_ULONG];
   foo[fmt_ulong(foo,id)] = 0;
   logmsg(WHO,99,WARN,B("no such file to unlink #",foo));
}
 
static int delete_msg(unsigned long id)
{
  struct stat st;
  int bounce = 1;
 
  if (chdir(auto_queue) == -1) err_chdir(); 
  if (chdir("queue") == -1) err_chdir(); 
 
  fnmake_init();
 
  fnmake_mess(id);  // regular message pre-processed
  if (stat(fn.s,&st) == -1) err_unlink(id);
  else bounce = 0;
  if (!bounce && unlink(fn.s) == -1) 
    if (errno != ENOENT) err_unlink(id);
 
  fnmake_info(id);  // not delivered yet
  if (!stat(fn.s,&st))
    if (unlink(fn.s) == -1) 
      if (errno != ENOENT) err_unlink(id);
  
  if (bounce) {
    fnmake_bounce(id);
    if (!stat(fn.s,&st)) { warn_unlink(id); return 1; }
    if (unlink(fn.s) == -1) 
      if (errno != ENOENT) err_unlink(id); 
  }
 
  fnmake_remote(id);
  if (!stat(fn.s,&st))
    if (unlink(fn.s) == -1) 
      if (errno != ENOENT) err_unlink(id); 
  
  fnmake_local(id);
  if (!stat(fn.s,&st))
    if (unlink(fn.s) == -1) 
      if (errno != ENOENT) err_unlink(id); 
  
  return 0;
}
 
int main(int argc, char * const *argv)
{
  char *mess = 0;
  unsigned long id = 0;
  unsigned int n;
 
 
  if (argc > 1) {
    if (!str_diff(argv[1],"-i")) {
      flag_interactive = 1;
    } else if (!str_diff(argv[1],"-d")) {
      if (!argv[2]) logmsg(WHO,111,USAGE,"qmail-qmaint [-i] || [-d messid] || [-D]");
      mess = argv[2];
      flag_delete = 1;
      scan_ulong(mess,&id);
    } else if (!str_diff(argv[1],"-D")) {
      flag_delete = 2;
    } else
      logmsg(WHO,111,USAGE,"qmail-qmaint [-i] || [-d messid] || [-D]");
  }
 
  if (!stralloc_copys(&queue_dir,auto_queue)) die_nomem();
  if (!stralloc_cats(&queue_dir,"/queue/")) die_nomem();
 
  logmsg(WHO,0,INFO,B("Checking s/qmail queue at: ",auto_queue,"/queue/"));
 
  /* get constants */
 
  qmailq_uid = auto_uidq;
  qmails_uid = auto_uids;
  qmailr_uid = auto_uidr;
  qmail_gid = auto_gidq;
  split_num = auto_split;
 
  /*check that all the proper directories exist with proper credentials*/
 
  if (check_dirs()) die_check();
 
  if (flag_delete == 1) {
    if (!delete_msg(id))
      logmsg(WHO,0,INFO,B("file ",mess," from queue deleted."));
  } else if (flag_delete == 2) {
    n = cleanup_dkim();
    strnum[fmt_uint(strnum,n)] = 0; 
    logmsg(WHO,0,INFO,B(strnum," DKIM staging files from queue deleted."));
  } else
    if (fix_names()) die_check();
 
  logmsg(WHO,0,INFO,"done.");
  
  _exit (0);
}