#include <config.h>
#ifdef HAVE_UNISTD_H
#include <unistd.h>
#endif
#include <stdlib.h>
#include <stdio.h>
#include <syslog.h>
#include <string.h>
#include <netinet/in.h>
#include "global.h"
#include "sysexits.h"
#include "exitcodes.h"
#include "imap_err.h"
#include "mailbox.h"
#include "xmalloc.h"
#include "mboxlist.h"
const int config_need_data = CONFIG_NEED_PARTITION_DATA;
extern char *optarg;
extern int optind;
extern int opterr;
extern int optopt;
int days = -1;
int size = -1;
int exact = -1;
int pattern = -1;
int skipflagged = 0;
int datemode = OFFSET_SENTDATE;
int invertmatch = 0;
typedef struct mbox_stats_s {
int total;
int total_bytes;
int deleted;
int deleted_bytes;
} mbox_stats_t;
static struct namespace purge_namespace;
int verbose = 1;
int forceall = 0;
int purge_me(char *, int, int);
int purge_check(struct mailbox *, void *, char *);
int usage(char *name);
void print_stats(mbox_stats_t *stats);
int main (int argc, char *argv[]) {
int option;
char buf[MAX_MAILBOX_PATH+1];
char *alt_config = NULL;
int r;
if (geteuid() == 0) fatal("must run as the Cyrus user", EX_USAGE);
while ((option = getopt(argc, argv, "C:hxd:b:k:m:fsXi")) != EOF) {
switch (option) {
case 'C':
alt_config = optarg;
break;
case 'd': {
if (optarg == 0) {
usage(argv[0]);
}
days = atoi(optarg) * 86400 ;
} break;
case 'b': {
if (optarg == 0) {
usage(argv[0]);
}
size = atoi(optarg);
} break;
case 'k': {
if (optarg == 0) {
usage(argv[0]);
}
size = atoi(optarg) * 1024;
} break;
case 'm': {
if (optarg == 0) {
usage(argv[0]);
}
size = atoi(optarg) * 1048576;
} break;
case 'x' : {
exact = 1;
} break;
case 'f' : {
forceall = 1;
} break;
case 's' : {
skipflagged = 1;
} break;
case 'X' : {
datemode = OFFSET_INTERNALDATE;
} break;
case 'i' : {
invertmatch = 1;
} break;
case 'h':
default: usage(argv[0]);
}
}
if ((days == -1 ) && (size == -1)) {
printf("One of these must be specified -d, -b -k, -m\n");
usage(argv[0]);
}
cyrus_init(alt_config, "ipurge", 0);
if ((r = mboxname_init_namespace(&purge_namespace, 1)) != 0) {
syslog(LOG_ERR, error_message(r));
fatal(error_message(r), EC_CONFIG);
}
mboxlist_init(0);
mboxlist_open(NULL);
quotadb_init(0);
quotadb_open(NULL);
if (optind == argc) {
strcpy(buf, "*");
(*purge_namespace.mboxlist_findall)(&purge_namespace, buf, 1, 0, 0,
purge_me, NULL);
} else {
for (; optind < argc; optind++) {
strncpy(buf, argv[optind], MAX_MAILBOX_NAME);
mboxname_hiersep_tointernal(&purge_namespace, buf,
config_virtdomains ?
strcspn(buf, "@") : 0);
(*purge_namespace.mboxlist_findall)(&purge_namespace, buf, 1, 0, 0,
purge_me, NULL);
}
}
quotadb_close();
quotadb_done();
mboxlist_close();
mboxlist_done();
cyrus_done();
return 0;
}
int
usage(char *name) {
printf("usage: %s [-f] [-s] [-C <alt_config>] [-x] [-X] [-i] {-d days | -b bytes|-k Kbytes|-m Mbytes}\n\t[mboxpattern1 ... [mboxpatternN]]\n", name);
printf("\tthere are no defaults and at least one of -d, -b, -k, -m\n\tmust be specified\n");
printf("\tif no mboxpattern is given %s works on all mailboxes\n", name);
printf("\t -x specifies an exact match for days or size\n");
printf("\t -f force also to delete mail below user.* and INBOX.*\n");
printf("\t -s skip over messages that are flagged.\n");
printf("\t -X use delivery time instead of date header for date matches.\n");
printf("\t -i invert match logic: -x means not equal, date is for newer, size is for smaller.\n");
exit(0);
}
int purge_me(char *name, int matchlen __attribute__((unused)),
int maycreate __attribute__((unused))) {
struct mailbox the_box;
int error;
mbox_stats_t stats;
if( ! forceall ) {
if (!strncasecmp(name,"INBOX",5) || mboxname_isusermailbox(name, 0))
return 0;
}
memset(&stats, '\0', sizeof(mbox_stats_t));
if (verbose) {
char mboxname[MAX_MAILBOX_NAME+1];
(*purge_namespace.mboxname_toexternal)(&purge_namespace, name,
"cyrus", mboxname);
printf("Working on %s...\n", mboxname);
}
error = mailbox_open_header(name, 0, &the_box);
if (error != 0) {
syslog(LOG_ERR, "Couldn't find %s, check spelling", name);
return error;
}
if (the_box.header_fd != -1) {
(void) mailbox_lock_header(&the_box);
}
the_box.header_lock_count = 1;
error = chdir(the_box.path);
if (error < 0) {
syslog(LOG_ERR, "Couldn't change directory to %s : %m", the_box.path);
return error;
}
error = mailbox_open_index(&the_box);
if (error != 0) {
mailbox_close(&the_box);
syslog(LOG_ERR, "Couldn't open mailbox index for %s", name);
return error;
}
(void) mailbox_lock_index(&the_box);
the_box.index_lock_count = 1;
mailbox_expunge(&the_box, 1, purge_check, &stats);
mailbox_close(&the_box);
print_stats(&stats);
return 0;
}
void deleteit(bit32 msgsize, mbox_stats_t *stats)
{
stats->deleted++;
stats->deleted_bytes += msgsize;
}
int purge_check(struct mailbox *mailbox __attribute__((unused)),
void *deciderock, char *buf) {
time_t my_time;
mbox_stats_t *stats = (mbox_stats_t *) deciderock;
bit32 senttime;
bit32 msgsize;
bit32 flagged;
senttime = ntohl(*((bit32 *)(buf + datemode)));
msgsize = ntohl(*((bit32 *)(buf + OFFSET_SIZE)));
flagged = ntohl(*((bit32 *)(buf + OFFSET_SYSTEM_FLAGS))) & FLAG_FLAGGED;
stats->total++;
stats->total_bytes += msgsize;
if (skipflagged && flagged)
return 0;
if (exact == 1) {
if (days >= 0) {
my_time = time(0);
if (((my_time - (time_t) senttime)/86400) == (days/86400)) {
if (invertmatch) return 0;
deleteit(msgsize, stats);
return 1;
} else {
if (!invertmatch) return 0;
deleteit(msgsize, stats);
return 1;
}
}
if (size >= 0) {
if (msgsize == size) {
if (invertmatch) return 0;
deleteit(msgsize, stats);
return 1;
} else {
if (!invertmatch) return 0;
deleteit(msgsize, stats);
return 1;
}
}
return 0;
} else {
if (days >= 0) {
my_time = time(0);
if (!invertmatch && ((my_time - (time_t) senttime) > days)) {
deleteit(msgsize, stats);
return 1;
}
if (invertmatch && ((my_time - (time_t) senttime) < days)) {
deleteit(msgsize, stats);
return 1;
}
}
if (size >= 0) {
if (!invertmatch && (msgsize > size)) {
deleteit(msgsize, stats);
return 1;
}
if (invertmatch && (msgsize < size)) {
deleteit(msgsize, stats);
return 1;
}
}
return 0;
}
}
void print_stats(mbox_stats_t *stats)
{
printf("total messages \t\t %d\n",stats->total);
printf("total bytes \t\t %d\n",stats->total_bytes);
printf("Deleted messages \t\t %d\n",stats->deleted);
printf("Deleted bytes \t\t %d\n",stats->deleted_bytes);
printf("Remaining messages\t\t %d\n",stats->total - stats->deleted);
printf("Remaining bytes \t\t %d\n",
stats->total_bytes - stats->deleted_bytes);
}