4 Commits

Author SHA1 Message Date
43e7695eac Update the basic documentation. 2023-03-08 15:19:20 +01:00
844dc84974 Ignore backup files. 2023-03-07 16:54:41 +01:00
ee2489483b Code cleanup and indentation.
C source files (with the exception of third-party files, i.e. getopt and
md5) have been indented with GNU indent.

The indentation "standard" has been documented in the readme file.
2023-03-07 16:51:33 +01:00
882a38f908 Refinement of the TODO list. 2023-03-01 20:53:15 +01:00
23 changed files with 773 additions and 666 deletions

2
.gitignore vendored
View File

@@ -3,4 +3,6 @@ config.h
config.log config.log
config.status config.status
src/*.o src/*.o
src/*.c~
src/*.h~
src/mboxgrep src/mboxgrep

View File

22
INSTALL.md Normal file
View File

@@ -0,0 +1,22 @@
# How to compile and install mboxgrep
mboxgrep should compile on a modern Unix-like operating system, such as GNU/Linux or FreeBSD.
It uses autoconf, so the most basic compilation procedure consists of:
```
./configure
make
make install # root rights probably needed here, prefix with sudo in such case
```
To see the list of flags accepted by the configure script, run:
```
./configure --help
```
Optionally, `mboxgrep` can be linked with the following libraries:
- PCRE, to enable support for regular expressions compatible with Perl 5;
- zlib and bzlib, to enable support for compressed mbox folders.

View File

@@ -1,4 +1,7 @@
mboxgrep - displays e-mail messages matching a pattern # mboxgrep - selects e-mail messages matching a pattern
`mboxgrep` is a `grep(1)`-like tool which scans mailboxes and selects
e-mail messages matching pattern.
Full description of mboxgrep is contained in the documentation, Full description of mboxgrep is contained in the documentation,
which is provided both in manpage and texinfo format, to satisfy which is provided both in manpage and texinfo format, to satisfy
@@ -11,5 +14,8 @@ are welcome.
If you intend to bundle mboxgrep with an operating system (such as a If you intend to bundle mboxgrep with an operating system (such as a
GNU/Linux distrubution, for example), please drop me a line about it. GNU/Linux distrubution, for example), please drop me a line about it.
For build instructions, read the file "INSTALL", and run For build instructions, read the file `INSTALL.md`, and run
`./configure --help`. `./configure --help`.
This project aims to follow the [GNU coding style](https://www.gnu.org/prep/standards/html_node/Formatting.html),
at least loosely. The code should be indented with `indent -gnu -nut -ppi2`.

View File

@@ -10,7 +10,8 @@
- [x] recursive search through directories - [x] recursive search through directories
- [x] writing selected messages to a new folder - [x] writing selected messages to a new folder
- [x] deleting selected messages - [x] deleting selected messages
- [ ] literal date matching - [ ] basic time and date matching
- [ ] more advanced time and date matching, with strings such as "yesterday"
- [x] reading messages from standard input - [x] reading messages from standard input
- [x] run-time selection of file locking method - [x] run-time selection of file locking method
- [x] add a debug function - [x] add a debug function
@@ -24,6 +25,8 @@
- [ ] support for XZ-format compression - [ ] support for XZ-format compression
- [ ] support for mail folder conversion - [ ] support for mail folder conversion
- [ ] use a more modern hash function than MD5 - [ ] use a more modern hash function than MD5
- [ ] improve error detection when a directory is not a Maildir or MH folder
- [ ] document criteria for folder format detection
## Miscellaneous ## Miscellaneous

View File

@@ -36,7 +36,8 @@ print_wrap (char *str, int len, int *n)
fprintf (stdout, "\n"); fprintf (stdout, "\n");
*n = 0; *n = 0;
} }
else fprintf (stdout, " "); else
fprintf (stdout, " ");
} }
void void
@@ -66,7 +67,8 @@ version (void)
#else #else
# ifdef HAVE_FTW # ifdef HAVE_FTW
print_wrap ("HAVE_FTW", 8, &n); print_wrap ("HAVE_FTW", 8, &n);
# endif /* HAVE_FTW */ # endif
/* HAVE_FTW */
#endif /* HAVE_FTS_OPEN */ #endif /* HAVE_FTS_OPEN */
/* /*
fprintf (stdout, "HAVE_LIBLOCKFILE "); fprintf (stdout, "HAVE_LIBLOCKFILE ");
@@ -100,15 +102,15 @@ version (void)
#endif /* HAVE_LIBDMALLOC */ #endif /* HAVE_LIBDMALLOC */
fprintf (stdout, "\n"); fprintf (stdout, "\n");
exit(0); exit (0);
} }
void void
help (void) help (void)
{ {
fprintf(stdout, "%s %s - search MAILBOX for messages matching PATTERN\n\n", fprintf (stdout, "%s %s - search MAILBOX for messages matching PATTERN\n\n",
APPNAME, VERSION); APPNAME, VERSION);
fprintf(stdout, fprintf (stdout,
"Miscellaneous:\n\n" "Miscellaneous:\n\n"
" -h, --help\t\t\tThis help screen\n" " -h, --help\t\t\tThis help screen\n"
" -V, --version\t\tDisplay version, copyright and\n" " -V, --version\t\tDisplay version, copyright and\n"
@@ -126,10 +128,10 @@ help (void)
" -E, --extended-regexp\tPATTERN is an extended regular expression\n" " -E, --extended-regexp\tPATTERN is an extended regular expression\n"
" -G, --basic-regexp\t\tPATTERN is a basic regular expression\n"); " -G, --basic-regexp\t\tPATTERN is a basic regular expression\n");
#ifdef HAVE_LIBPCRE #ifdef HAVE_LIBPCRE
fprintf(stdout, fprintf (stdout,
" -P, --perl-regexp\t\tPATTERN is a Perl regular expression\n"); " -P, --perl-regexp\t\tPATTERN is a Perl regular expression\n");
#endif /* HAVE_LIBPCRE */ #endif /* HAVE_LIBPCRE */
fprintf(stdout, fprintf (stdout,
" -e, --regexp=PATTERN\t\tUse PATTERN as a regular expression\n" " -e, --regexp=PATTERN\t\tUse PATTERN as a regular expression\n"
" -i, --ignore-case\t\tIgnore case distinctions\n" " -i, --ignore-case\t\tIgnore case distinctions\n"
" -v, --invert-match\t\tSelect non-matching messages\n\n" " -v, --invert-match\t\tSelect non-matching messages\n\n"
@@ -141,27 +143,27 @@ help (void)
" -l, --file-lock=METHOD\tSelect file locking METHOD\n" " -l, --file-lock=METHOD\tSelect file locking METHOD\n"
"\t\t\t\tMETHOD is"); "\t\t\t\tMETHOD is");
#ifdef HAVE_FCNTL #ifdef HAVE_FCNTL
fprintf(stdout, " `fcntl',"); fprintf (stdout, " `fcntl',");
#endif /* HAVE_FCNTL */ #endif /* HAVE_FCNTL */
#ifdef HAVE_FLOCK #ifdef HAVE_FLOCK
fprintf(stdout, " `flock',"); fprintf (stdout, " `flock',");
#endif /* HAVE_FLOCK */ #endif /* HAVE_FLOCK */
fprintf(stdout, " or `none'\n\n" fprintf (stdout, " or `none'\n\n"
"Mailbox type selection:\n\n" "Mailbox type selection:\n\n"
" -m, --mailbox-format=TYPE\tSelect mailbox TYPE\n" " -m, --mailbox-format=TYPE\tSelect mailbox TYPE\n"
"\t\t\t\tTYPE is `mbox', "); "\t\t\t\tTYPE is `mbox', ");
#ifdef HAVE_LIBZ #ifdef HAVE_LIBZ
fprintf(stdout, "`zmbox', "); fprintf (stdout, "`zmbox', ");
#endif /* HAVE_LIBZ */ #endif /* HAVE_LIBZ */
#ifdef HAVE_LIBBZ2 #ifdef HAVE_LIBBZ2
fprintf(stdout, "`bz2mbox', "); fprintf (stdout, "`bz2mbox', ");
#endif /* HAVE_LIBBZ2 */ #endif /* HAVE_LIBBZ2 */
fprintf(stdout, fprintf (stdout,
"`mh',\n" "`mh',\n"
"\t\t\t\t`nnml', `nnmh', or `maildir'.\n\n" "\t\t\t\t`nnml', `nnmh', or `maildir'.\n\n"
"Mail bug reports and flames to <%s>.\n", BUGREPORT_ADDR); "Mail bug reports and flames to <%s>.\n", BUGREPORT_ADDR);
exit(0); exit (0);
} }
void void

View File

@@ -18,7 +18,7 @@
*/ */
#ifndef INFO_H #ifndef INFO_H
#define INFO_H # define INFO_H
void print_wrap (char *str, int len, int *n); void print_wrap (char *str, int len, int *n);
void version (void); void version (void);

View File

@@ -30,13 +30,16 @@
# define NAMLEN(dirent) (dirent)->d_namlen # define NAMLEN(dirent) (dirent)->d_namlen
# ifdef HAVE_SYS_NDIR_H # ifdef HAVE_SYS_NDIR_H
# include <sys/ndir.h> # include <sys/ndir.h>
# endif /* HAVE_SYS_NDIR_H */ # endif
/* HAVE_SYS_NDIR_H */
# ifdef HAVE_SYS_DIR_H # ifdef HAVE_SYS_DIR_H
# include <sys/dir.h> # include <sys/dir.h>
# endif /* HAVE_SYS_DIR_H */ # endif
/* HAVE_SYS_DIR_H */
# ifdef HAVE_NDIR_H # ifdef HAVE_NDIR_H
# include <ndir.h> # include <ndir.h>
# endif /* HAVE_NDIR_H */ # endif
/* HAVE_NDIR_H */
#endif /* HAVE_DIRENT_H */ #endif /* HAVE_DIRENT_H */
#include <stdlib.h> #include <stdlib.h>
@@ -52,7 +55,7 @@
#include "wrap.h" #include "wrap.h"
#ifdef HAVE_LIBDMALLOC #ifdef HAVE_LIBDMALLOC
#include <dmalloc.h> # include <dmalloc.h>
#endif /* HAVE_LIBDMALLOC */ #endif /* HAVE_LIBDMALLOC */
maildir_t * maildir_t *
@@ -75,9 +78,9 @@ maildir_open (const char *path)
return NULL; return NULL;
} }
dirname = (char *) xmalloc((sizeof (char) * (strlen (path) + 5))); dirname = (char *) xmalloc ((sizeof (char) * (strlen (path) + 5)));
mp = (maildir_t *) xmalloc(sizeof (maildir_t)); mp = (maildir_t *) xmalloc (sizeof (maildir_t));
sprintf (dirname, "%s/new", path); sprintf (dirname, "%s/new", path);
mp->new = m_opendir (dirname); mp->new = m_opendir (dirname);
if (mp->new == NULL) if (mp->new == NULL)
@@ -111,7 +114,7 @@ maildir_open (const char *path)
} /* maildir_open */ } /* maildir_open */
message_t * message_t *
maildir_read_message (maildir_t *mdp) maildir_read_message (maildir_t * mdp)
{ {
int isheaders = 1; int isheaders = 1;
int have_from = 0, have_to = 0, have_message_id = 0, have_sender = 0, int have_from = 0, have_to = 0, have_message_id = 0, have_sender = 0,
@@ -124,7 +127,7 @@ maildir_read_message (maildir_t *mdp)
message = allocate_message (); message = allocate_message ();
for(;;) for (;;)
{ {
if (mdp->new != NULL) if (mdp->new != NULL)
{ {
@@ -156,8 +159,9 @@ maildir_read_message (maildir_t *mdp)
continue; continue;
filename = filename =
(char *) xmalloc ((sizeof (char)*((strlen (d_content->d_name)) (char *) xmalloc ((sizeof (char) * ((strlen (d_content->d_name))
+ (strlen (config.boxname)) + 6))); + (strlen (config.boxname)) +
6)));
/* /*
filename = filename =
@@ -173,7 +177,7 @@ maildir_read_message (maildir_t *mdp)
free (filename); free (filename);
isheaders = 1; isheaders = 1;
fp = m_fopen(message->filename, "r"); fp = m_fopen (message->filename, "r");
if (fp == NULL) if (fp == NULL)
continue; continue;
@@ -199,11 +203,12 @@ maildir_read_message (maildir_t *mdp)
if (0 == strncasecmp ("Message-ID: ", buffer, 12)) if (0 == strncasecmp ("Message-ID: ", buffer, 12))
have_message_id = 1; have_message_id = 1;
if (0 == strncasecmp ("Return-Path: ", buffer, 13)) if (0 == strncasecmp ("Return-Path: ", buffer, 13))
message->from = parse_return_path(buffer); message->from = parse_return_path (buffer);
message->headers = message->headers =
(char *) xrealloc (message->headers, (char *) xrealloc (message->headers,
((1 + s + message->hbytes) * sizeof (char))); ((1 + s +
message->hbytes) * sizeof (char)));
strcpy (message->headers + message->hbytes, buffer); strcpy (message->headers + message->hbytes, buffer);
message->hbytes += s; message->hbytes += s;
@@ -212,7 +217,8 @@ maildir_read_message (maildir_t *mdp)
{ {
message->body = message->body =
(char *) xrealloc (message->body, (char *) xrealloc (message->body,
((1 + s + message->bbytes) * sizeof (char))); ((1 + s +
message->bbytes) * sizeof (char)));
strcpy (message->body + message->bbytes, buffer); strcpy (message->body + message->bbytes, buffer);
message->bbytes += s; message->bbytes += s;
} /* else */ } /* else */
@@ -220,22 +226,22 @@ maildir_read_message (maildir_t *mdp)
/* if (!have_from || !have_to || !have_message_id) */ /* if (!have_from || !have_to || !have_message_id) */
if ((!have_from && !have_sender)|| !have_date) if ((!have_from && !have_sender) || !have_date)
{ {
if (config.merr) if (config.merr)
fprintf(stderr, "%s: %s: Not a RFC 2822 message\n", fprintf (stderr, "%s: %s: Not a RFC 2822 message\n",
APPNAME, message->filename); APPNAME, message->filename);
fclose(fp); fclose (fp);
continue; continue;
} }
fclose(fp); fclose (fp);
return message; return message;
} /* for */ } /* for */
} /* maildir_read_message */ } /* maildir_read_message */
void void
maildir_write_message (message_t *m, const char *path) maildir_write_message (message_t * m, const char *path)
{ {
char bla[BUFSIZ], *s1, *s2; char bla[BUFSIZ], *s1, *s2;
int t; int t;
@@ -247,9 +253,9 @@ maildir_write_message (message_t *m, const char *path)
sprintf (bla, "%i.%i_%i.%s", sprintf (bla, "%i.%i_%i.%s",
t, config.pid, runtime.maildir_count, config.hostname); t, config.pid, runtime.maildir_count, config.hostname);
s1 = (char *) xmalloc ((strlen (path) + strlen (bla) + 6) * sizeof (char)); s1 = (char *) xmalloc ((strlen (path) + strlen (bla) + 6) * sizeof (char));
sprintf(s1, "%s/tmp/%s", path, bla); sprintf (s1, "%s/tmp/%s", path, bla);
s2 = (char *) xmalloc ((strlen (path) + strlen (bla) + 6) * sizeof (char)); s2 = (char *) xmalloc ((strlen (path) + strlen (bla) + 6) * sizeof (char));
sprintf(s2, "%s/new/%s", path, bla); sprintf (s2, "%s/new/%s", path, bla);
f1 = m_fopen (s1, "w"); f1 = m_fopen (s1, "w");
fprintf (f1, "%s\n%s", m->headers, m->body); fprintf (f1, "%s\n%s", m->headers, m->body);
@@ -268,18 +274,24 @@ maildir_check (const char *path)
sprintf (s, "%s/cur", path); sprintf (s, "%s/cur", path);
i = stat (s, &fs); i = stat (s, &fs);
if (-1 == i) return -1; if (-1 == i)
if (! S_ISDIR (fs.st_mode)) return -1; return -1;
if (!S_ISDIR (fs.st_mode))
return -1;
sprintf (s, "%s/new", path); sprintf (s, "%s/new", path);
i = stat (s, &fs); i = stat (s, &fs);
if (-1 == i) return -1; if (-1 == i)
if (! S_ISDIR (fs.st_mode)) return -1; return -1;
if (!S_ISDIR (fs.st_mode))
return -1;
sprintf(s, "%s/tmp", path); sprintf (s, "%s/tmp", path);
i = stat (s, &fs); i = stat (s, &fs);
if (-1 == i) return -1; if (-1 == i)
if (! S_ISDIR (fs.st_mode)) return -1; return -1;
if (!S_ISDIR (fs.st_mode))
return -1;
free (s); free (s);
@@ -292,24 +304,24 @@ maildir_create (const char *path)
char *s; char *s;
int i; int i;
s = (char *) xmalloc ((strlen (path) + 4) * sizeof(char)); s = (char *) xmalloc ((strlen (path) + 4) * sizeof (char));
errno = 0; errno = 0;
for (;;) for (;;)
{ {
sprintf(s, "%s", path); sprintf (s, "%s", path);
i = mkdir (s, S_IRWXU); i = mkdir (s, S_IRWXU);
if (-1 == i) if (-1 == i)
break; break;
sprintf(s, "%s/new", path); sprintf (s, "%s/new", path);
i = mkdir (s, S_IRWXU); i = mkdir (s, S_IRWXU);
if (-1 == i) if (-1 == i)
break; break;
sprintf(s, "%s/cur", path); sprintf (s, "%s/cur", path);
i = mkdir (s, S_IRWXU); i = mkdir (s, S_IRWXU);
if (-1 == i) if (-1 == i)
break; break;
sprintf(s, "%s/tmp", path); sprintf (s, "%s/tmp", path);
i = mkdir (s, S_IRWXU); i = mkdir (s, S_IRWXU);
if (-1 == i) if (-1 == i)
break; break;
@@ -321,7 +333,7 @@ maildir_create (const char *path)
{ {
if (config.merr) if (config.merr)
{ {
fprintf(stderr, "%s:%s: ", APPNAME, s); fprintf (stderr, "%s:%s: ", APPNAME, s);
perror (NULL); perror (NULL);
} }
} }

View File

@@ -18,28 +18,32 @@
*/ */
#ifndef MAILDIR_H #ifndef MAILDIR_H
#define MAILDIR_H # define MAILDIR_H
#include <config.h> # include <config.h>
#ifdef HAVE_DIRENT_H # ifdef HAVE_DIRENT_H
# include <dirent.h> # include <dirent.h>
# define NAMLEN(dirent) strlen((dirent)->d_name) # define NAMLEN(dirent) strlen((dirent)->d_name)
#else # else
# define dirent direct # define dirent direct
# define NAMLEN(dirent) (dirent)->d_namlen # define NAMLEN(dirent) (dirent)->d_namlen
# ifdef HAVE_SYS_NDIR_H # ifdef HAVE_SYS_NDIR_H
# include <sys/ndir.h> # include <sys/ndir.h>
# endif /* HAVE_SYS_NDIR_H */ # endif
/* HAVE_SYS_NDIR_H */
# ifdef HAVE_SYS_DIR_H # ifdef HAVE_SYS_DIR_H
# include <sys/dir.h> # include <sys/dir.h>
# endif /* HAVE_SYS_DIR_H */ # endif
/* HAVE_SYS_DIR_H */
# ifdef HAVE_NDIR_H # ifdef HAVE_NDIR_H
# include <ndir.h> # include <ndir.h>
# endif /* HAVE_NDIR_H */ # endif
#endif /* HAVE_DIRENT_H */ /* HAVE_NDIR_H */
# endif
/* HAVE_DIRENT_H */
#include "mboxgrep.h" # include "mboxgrep.h"
typedef struct typedef struct
{ {
@@ -50,8 +54,8 @@ typedef struct
maildir_t *maildir_open (const char *path); maildir_t *maildir_open (const char *path);
int maildir_check (const char *path); int maildir_check (const char *path);
void maildir_create (const char *path); void maildir_create (const char *path);
void maildir_close (maildir_t *mdp); void maildir_close (maildir_t * mdp);
message_t *maildir_read_message (maildir_t *mdp); message_t *maildir_read_message (maildir_t * mdp);
void maildir_write_message (message_t *m, const char *path); void maildir_write_message (message_t * m, const char *path);
#endif /* MAILDIR_H */ #endif /* MAILDIR_H */

View File

@@ -26,7 +26,7 @@
#include <stdlib.h> #include <stdlib.h>
#include <unistd.h> #include <unistd.h>
#ifdef HAVE_LIBZ #ifdef HAVE_LIBZ
#include <zlib.h> # include <zlib.h>
#endif /* HAVE_LIBZ */ #endif /* HAVE_LIBZ */
#include "getopt.h" #include "getopt.h"
@@ -40,7 +40,7 @@
#include "re.h" #include "re.h"
#ifdef HAVE_LIBDMALLOC #ifdef HAVE_LIBDMALLOC
#include <dmalloc.h> # include <dmalloc.h>
#endif /* HAVE_LIBDMALLOC */ #endif /* HAVE_LIBDMALLOC */
option_t config; option_t config;
@@ -54,8 +54,7 @@ main (int argc, char **argv)
runtime.count = 0; runtime.count = 0;
runtime.maildir_count = 0; runtime.maildir_count = 0;
static struct option long_options[] = static struct option long_options[] = {
{
{"count", 0, 0, 'c'}, {"count", 0, 0, 'c'},
{"delete", 0, 0, 'd'}, {"delete", 0, 0, 'd'},
/* {"date", 1, 0, 'D'}, */ /* {"date", 1, 0, 'D'}, */
@@ -65,7 +64,7 @@ main (int argc, char **argv)
{"help", 0, 0, 'h'}, {"help", 0, 0, 'h'},
{"ignore-case", 0, 0, 'i'}, {"ignore-case", 0, 0, 'i'},
{"mailbox-format", 1, 0, 'm'}, {"mailbox-format", 1, 0, 'm'},
{"no", 1, 0, 'n' }, {"no", 1, 0, 'n'},
{"pipe", 1, 0, 'p'}, {"pipe", 1, 0, 'p'},
{"regexp", 1, 0, 'e'}, {"regexp", 1, 0, 'e'},
{"invert-match", 0, 0, 'v'}, {"invert-match", 0, 0, 'v'},
@@ -102,7 +101,7 @@ main (int argc, char **argv)
runtime.cs->md5 = (char **) xcalloc (1, sizeof (char **)); runtime.cs->md5 = (char **) xcalloc (1, sizeof (char **));
runtime.cs->n = 0; runtime.cs->n = 0;
if (optind < argc && ! config.haveregex) if (optind < argc && !config.haveregex)
{ {
config.regex_s = xstrdup (argv[optind]); config.regex_s = xstrdup (argv[optind]);
config.haveregex = 1; config.haveregex = 1;
@@ -161,7 +160,7 @@ main (int argc, char **argv)
++optind; ++optind;
} }
if (! havemailbox) if (!havemailbox)
{ {
config.format = MBOX; config.format = MBOX;
scan_mailbox ("-"); scan_mailbox ("-");

View File

@@ -30,13 +30,13 @@
#include <errno.h> #include <errno.h>
#include <time.h> #include <time.h>
#ifdef HAVE_FLOCK #ifdef HAVE_FLOCK
#include <sys/file.h> # include <sys/file.h>
#endif /* HAVE_FLOCK */ #endif /* HAVE_FLOCK */
#ifdef HAVE_LIBZ #ifdef HAVE_LIBZ
#include <zlib.h> # include <zlib.h>
#endif /* HAVE_LIBZ */ #endif /* HAVE_LIBZ */
#ifdef HAVE_LIBBZ2 #ifdef HAVE_LIBBZ2
#include <bzlib.h> # include <bzlib.h>
#endif /* HAVE_LIBBZ2 */ #endif /* HAVE_LIBBZ2 */
#define BUFLEN 16384 #define BUFLEN 16384
@@ -46,7 +46,7 @@
#include "wrap.h" #include "wrap.h"
#ifdef HAVE_LIBDMALLOC #ifdef HAVE_LIBDMALLOC
#include <dmalloc.h> # include <dmalloc.h>
#endif /* HAVE_LIBDMALLOC */ #endif /* HAVE_LIBDMALLOC */
mbox_t * mbox_t *
@@ -193,7 +193,8 @@ mbox_open (const char *path, const char *mode)
fprintf (stderr, "%s: (standard input): Not a mbox folder\n", fprintf (stderr, "%s: (standard input): Not a mbox folder\n",
APPNAME); APPNAME);
else else
fprintf (stderr, "%s: %s: Not a mbox folder\n", APPNAME, path); fprintf (stderr, "%s: %s: Not a mbox folder\n", APPNAME,
path);
} }
if (config.format == MBOX) if (config.format == MBOX)
fclose (mp->fp); fclose (mp->fp);
@@ -367,7 +368,7 @@ tmpfile_name (const char *path)
void void
mbox_write_message (message_t *msg, mbox_t *mbox) mbox_write_message (message_t * msg, mbox_t * mbox)
{ {
if (config.format == MBOX) if (config.format == MBOX)
fprintf (mbox->fp, "%s\n%s", msg->headers, msg->body); fprintf (mbox->fp, "%s\n%s", msg->headers, msg->body);
@@ -375,7 +376,7 @@ mbox_write_message (message_t *msg, mbox_t *mbox)
else if (config.format == ZMBOX) else if (config.format == ZMBOX)
{ {
gzwrite_loop (mbox->fp, msg->headers); gzwrite_loop (mbox->fp, msg->headers);
gzwrite(mbox->fp, "\n", 1); gzwrite (mbox->fp, "\n", 1);
gzwrite_loop (mbox->fp, msg->body); gzwrite_loop (mbox->fp, msg->body);
} }
#endif /* HAVE_LIBZ */ #endif /* HAVE_LIBZ */
@@ -402,11 +403,14 @@ tmpfile_mod_own (const int fd, const char *path)
if (stat (path, &s) != -1) if (stat (path, &s) != -1)
{ {
if (fchown (fd, s.st_uid, s.st_gid) == -1) if (fchown (fd, s.st_uid, s.st_gid) == -1)
if (config.merr) perror (config.tmpfilename); if (config.merr)
perror (config.tmpfilename);
if (fchmod (fd, s.st_mode) == -1) if (fchmod (fd, s.st_mode) == -1)
if (config.merr) perror (config.tmpfilename); if (config.merr)
perror (config.tmpfilename);
} }
else if (config.merr) perror (path); else if (config.merr)
perror (path);
} }
} }

View File

@@ -18,11 +18,11 @@
*/ */
#ifndef MBOX_H #ifndef MBOX_H
#define MBOX_H 1 # define MBOX_H 1
#include <config.h> # include <config.h>
#include "message.h" # include "message.h"
typedef struct typedef struct
{ {
@@ -39,6 +39,6 @@ void tmpfile_mod_own (const int fd, const char *path);
int tmpfile_create (void); int tmpfile_create (void);
void mbox_close (mbox_t * mbp); void mbox_close (mbox_t * mbp);
message_t *mbox_read_message (mbox_t * mp); message_t *mbox_read_message (mbox_t * mp);
void mbox_write_message (message_t *m, mbox_t *mbox); void mbox_write_message (message_t * m, mbox_t * mbox);
#endif /* MBOX_H */ #endif /* MBOX_H */

View File

@@ -18,9 +18,9 @@
*/ */
#ifndef MESSAGE_H #ifndef MESSAGE_H
#define MESSAGE_H 1 # define MESSAGE_H 1
#include <config.h> # include <config.h>
typedef struct typedef struct
{ {

View File

@@ -29,13 +29,16 @@
# define NAMLEN(dirent) (dirent)->d_namlen # define NAMLEN(dirent) (dirent)->d_namlen
# ifdef HAVE_SYS_NDIR_H # ifdef HAVE_SYS_NDIR_H
# include <sys/ndir.h> # include <sys/ndir.h>
# endif /* HAVE_SYS_NDIR_H */ # endif
/* HAVE_SYS_NDIR_H */
# ifdef HAVE_SYS_DIR_H # ifdef HAVE_SYS_DIR_H
# include <sys/dir.h> # include <sys/dir.h>
# endif /* HAVE_SYS_DIR_H */ # endif
/* HAVE_SYS_DIR_H */
# ifdef HAVE_NDIR_H # ifdef HAVE_NDIR_H
# include <ndir.h> # include <ndir.h>
# endif /* HAVE_NDIR_H */ # endif
/* HAVE_NDIR_H */
#endif /* HAVE_DIRENT_H */ #endif /* HAVE_DIRENT_H */
#include <sys/types.h> #include <sys/types.h>
@@ -54,7 +57,8 @@
extern option_t config; extern option_t config;
DIR *mh_open (const char *path) DIR *
mh_open (const char *path)
{ {
DIR *dp; DIR *dp;
@@ -72,12 +76,14 @@ DIR *mh_open (const char *path)
return dp; return dp;
} /* mh_open */ } /* mh_open */
void mh_close (DIR *dp) void
mh_close (DIR * dp)
{ {
closedir (dp); closedir (dp);
} /* mh_close */ } /* mh_close */
message_t *mh_read_message (DIR *dp) message_t *
mh_read_message (DIR * dp)
{ {
int isheaders = 1; int isheaders = 1;
int have_from = 0, have_date = 0, have_sender = 0; int have_from = 0, have_date = 0, have_sender = 0;
@@ -91,10 +97,11 @@ message_t *mh_read_message (DIR *dp)
filename = NULL; filename = NULL;
for(;;) for (;;)
{ {
d_content = readdir(dp); d_content = readdir (dp);
if (d_content == NULL) return NULL; if (d_content == NULL)
return NULL;
if (d_content->d_name[0] == '.') if (d_content->d_name[0] == '.')
continue; continue;
@@ -161,7 +168,8 @@ message_t *mh_read_message (DIR *dp)
message->headers = message->headers =
(char *) realloc (message->headers, (char *) realloc (message->headers,
((1 + s + message->hbytes) * sizeof (char))); ((1 + s +
message->hbytes) * sizeof (char)));
strcpy (message->headers + message->hbytes, buffer); strcpy (message->headers + message->hbytes, buffer);
message->hbytes += s; message->hbytes += s;
} /* if */ } /* if */
@@ -169,13 +177,14 @@ message_t *mh_read_message (DIR *dp)
{ {
message->body = message->body =
(char *) realloc (message->body, (char *) realloc (message->body,
((1 + s + message->bbytes) * sizeof (char))); ((1 + s +
message->bbytes) * sizeof (char)));
strcpy (message->body + message->bbytes, buffer); strcpy (message->body + message->bbytes, buffer);
message->bbytes += s; message->bbytes += s;
} /* else */ } /* else */
} /* while */ } /* while */
if ((!have_from && !have_sender)|| !have_date) if ((!have_from && !have_sender) || !have_date)
{ {
if (config.merr) if (config.merr)
fprintf (stderr, "%s: %s: Not a RFC 2822 message\n", fprintf (stderr, "%s: %s: Not a RFC 2822 message\n",
@@ -201,12 +210,14 @@ message_t *mh_read_message (DIR *dp)
} /* for */ } /* for */
} /* mh_read_message */ } /* mh_read_message */
void mh_write_message (message_t *m, const char *path) void
mh_write_message (message_t * m, const char *path)
{ {
struct dirent *dc; struct dirent *dc;
int x, y = 0; int x, y = 0;
char s1[BUFSIZ]; char s1[BUFSIZ];
DIR *d; FILE *f; DIR *d;
FILE *f;
d = m_opendir (path); d = m_opendir (path);
rewinddir (d); rewinddir (d);

View File

@@ -18,29 +18,33 @@
*/ */
#ifndef MH_H #ifndef MH_H
#define MH_H 1 # define MH_H 1
#include <config.h> # include <config.h>
#ifdef HAVE_DIRENT_H # ifdef HAVE_DIRENT_H
# include <dirent.h> # include <dirent.h>
#else # else
# ifdef HAVE_SYS_NDIR_H # ifdef HAVE_SYS_NDIR_H
# include <sys/ndir.h> # include <sys/ndir.h>
# endif /* HAVE_SYS_NDIR_H */ # endif
/* HAVE_SYS_NDIR_H */
# ifdef HAVE_SYS_DIR_H # ifdef HAVE_SYS_DIR_H
# include <sys/dir.h> # include <sys/dir.h>
# endif /* HAVE_SYS_DIR_H */ # endif
/* HAVE_SYS_DIR_H */
# ifdef HAVE_NDIR_H # ifdef HAVE_NDIR_H
# include <ndir.h> # include <ndir.h>
# endif /* HAVE_NDIR_H */ # endif
#endif /* HAVE_DIRENT_H */ /* HAVE_NDIR_H */
# endif
/* HAVE_DIRENT_H */
#include "mboxgrep.h" # include "mboxgrep.h"
DIR *mh_open (const char *path); DIR *mh_open (const char *path);
void mh_close (DIR *dp); void mh_close (DIR * dp);
message_t *mh_read_message (DIR *dp); message_t *mh_read_message (DIR * dp);
void mh_write_message (message_t *m, const char *path); void mh_write_message (message_t * m, const char *path);
#endif /* MH_H */ #endif /* MH_H */

View File

@@ -68,7 +68,8 @@ folder_format (const char *name)
return f; return f;
} }
lockmethod_t lock_method (const char *name) lockmethod_t
lock_method (const char *name)
{ {
lockmethod_t l; lockmethod_t l;
@@ -122,17 +123,19 @@ time_t parse_date(char *datestr)
} }
*/ */
char * parse_return_path(char *rpath) char *
parse_return_path (char *rpath)
{ {
char *blah1, blah2[BUFSIZ]; char *blah1, blah2[BUFSIZ];
sscanf(rpath, "Return-Path: <%[^\r\n>]>", blah2); sscanf (rpath, "Return-Path: <%[^\r\n>]>", blah2);
blah1 = xstrdup (blah2); blah1 = xstrdup (blah2);
return blah1; return blah1;
} }
void * allocate_message (void) void *
allocate_message (void)
{ {
message_t *message; message_t *message;
@@ -151,7 +154,8 @@ void * allocate_message (void)
return message; return message;
} }
void postmark_print (message_t *msg) void
postmark_print (message_t * msg)
{ {
time_t tt; time_t tt;
struct tm *ct; struct tm *ct;
@@ -200,7 +204,7 @@ get_runtime_options (int *argc, char **argv, struct option *long_options)
switch (c) switch (c)
{ {
case '?': case '?':
usage(); usage ();
case 'c': case 'c':
config.action = COUNT; config.action = COUNT;
break; break;
@@ -226,10 +230,10 @@ get_runtime_options (int *argc, char **argv, struct option *long_options)
config.extended = 0; config.extended = 0;
config.perl = 1; config.perl = 1;
#else #else
fprintf(stderr, fprintf (stderr,
"%s: Support for Perl regular expressions not " "%s: Support for Perl regular expressions not "
"compiled in\n", APPNAME); "compiled in\n", APPNAME);
exit(2); exit (2);
#endif /* HAVE_LIBPCRE */ #endif /* HAVE_LIBPCRE */
break; break;
case 'h': case 'h':
@@ -288,9 +292,9 @@ get_runtime_options (int *argc, char **argv, struct option *long_options)
config.lock = 0; config.lock = 0;
break; break;
default: default:
fprintf(stderr, "%s: invalid option -- n%c\n", fprintf (stderr, "%s: invalid option -- n%c\n",
APPNAME, optarg[0]); APPNAME, optarg[0]);
exit(2); exit (2);
} }
} }
} /* switch */ } /* switch */

View File

@@ -18,20 +18,21 @@
*/ */
#ifndef MISC_H #ifndef MISC_H
#define MISC_H 1 # define MISC_H 1
#include "mboxgrep.h" # include "mboxgrep.h"
#include "getopt.h" # include "getopt.h"
#include "message.h" # include "message.h"
/* #include <time.h> */ /* #include <time.h> */
format_t folder_format (const char *name); format_t folder_format (const char *name);
lockmethod_t lock_method (const char *name); lockmethod_t lock_method (const char *name);
/* time_t parse_date(char *datestr); */ /* time_t parse_date(char *datestr); */
char * parse_return_path(char *rpath); char *parse_return_path (char *rpath);
void * allocate_message (void); void *allocate_message (void);
void postmark_print (message_t *msg); void postmark_print (message_t * msg);
void set_default_options (void); void set_default_options (void);
void get_runtime_options (int *argc, char **argv, struct option *long_options); void get_runtime_options (int *argc, char **argv,
struct option *long_options);
#endif /* MISC_H */ #endif /* MISC_H */

View File

@@ -22,7 +22,7 @@
#include <string.h> #include <string.h>
#include <regex.h> #include <regex.h>
#ifdef HAVE_LIBPCRE #ifdef HAVE_LIBPCRE
#include <pcre.h> # include <pcre.h>
#endif /* HAVE_LIBPCRE */ #endif /* HAVE_LIBPCRE */
#include "mboxgrep.h" #include "mboxgrep.h"
#include "message.h" #include "message.h"
@@ -42,14 +42,13 @@ pcre_init (void)
if (config.pcre_pattern == NULL) if (config.pcre_pattern == NULL)
{ {
if (config.merr) if (config.merr)
fprintf (stderr, "%s: %s: %s\n", APPNAME, config.regex_s, fprintf (stderr, "%s: %s: %s\n", APPNAME, config.regex_s, error);
error); exit (2);
exit(2);
} }
} }
void void
pcre_match (message_t *msg) pcre_match (message_t * msg)
{ {
int of[BUFSIZ]; int of[BUFSIZ];
@@ -57,14 +56,12 @@ pcre_match (message_t *msg)
config.res1 = config.res1 =
pcre_exec ((pcre *) config.pcre_pattern, pcre_exec ((pcre *) config.pcre_pattern,
(pcre_extra *) config.pcre_hints, (pcre_extra *) config.pcre_hints,
msg->headers, msg->headers, (int) strlen (msg->headers), 0, 0, of, BUFSIZ);
(int) strlen (msg->headers), 0, 0, of, BUFSIZ);
if (config.body) if (config.body)
config.res2 = config.res2 =
pcre_exec ((pcre *) config.pcre_pattern, pcre_exec ((pcre *) config.pcre_pattern,
(pcre_extra *) config.pcre_hints, (pcre_extra *) config.pcre_hints,
msg->body, msg->body, (int) strlen (msg->body), 0, 0, of, BUFSIZ);
(int) strlen (msg->body), 0, 0, of, BUFSIZ);
config.res1 = config.res1 ^ 1; config.res1 = config.res1 ^ 1;
config.res2 = config.res2 ^ 1; config.res2 = config.res2 ^ 1;
@@ -85,12 +82,13 @@ regex_init (void)
config.posix_pattern = (regex_t *) xmalloc (sizeof (regex_t)); config.posix_pattern = (regex_t *) xmalloc (sizeof (regex_t));
errcode = regcomp ((regex_t *) config.posix_pattern, config.regex_s, errcode = regcomp ((regex_t *) config.posix_pattern, config.regex_s,
(flag1 | flag2 | REG_NEWLINE )); (flag1 | flag2 | REG_NEWLINE));
if (0 != errcode) if (0 != errcode)
{ {
if (config.merr) if (config.merr)
{ {
regerror (errcode, (regex_t *) config.posix_pattern, errbuf, BUFSIZ); regerror (errcode, (regex_t *) config.posix_pattern, errbuf,
BUFSIZ);
fprintf (stderr, "%s: %s: %s\n", APPNAME, config.regex_s, errbuf); fprintf (stderr, "%s: %s: %s\n", APPNAME, config.regex_s, errbuf);
} }
exit (2); exit (2);
@@ -98,7 +96,7 @@ regex_init (void)
} }
void void
regex_match (message_t *msg) regex_match (message_t * msg)
{ {
if (config.headers) if (config.headers)
config.res1 = regexec ((regex_t *) config.posix_pattern, config.res1 = regexec ((regex_t *) config.posix_pattern,

View File

@@ -21,7 +21,7 @@
#ifdef HAVE_LIBPCRE #ifdef HAVE_LIBPCRE
void pcre_init (void); void pcre_init (void);
void pcre_match (message_t *msg); void pcre_match (message_t * msg);
#endif /* HAVE_LIBPCRE */ #endif /* HAVE_LIBPCRE */
void regex_init (void); void regex_init (void);
void regex_match (message_t *msg); void regex_match (message_t * msg);

View File

@@ -1,6 +1,6 @@
/* -*- C -*- /*
mboxgrep - scan mailbox for messages matching a regular expression mboxgrep - scan mailbox for messages matching a regular expression
Copyright (C) 2000, 2001, 2002, 2003, 2004, 2006 Daniel Spiljar Copyright (C) 2000 - 2004, 2006, 2023 Daniel Spiljar
Mboxgrep is free software; you can redistribute it and/or modify it Mboxgrep is free software; you can redistribute it and/or modify it
under the terms of the GNU General Public License as published by under the terms of the GNU General Public License as published by
@@ -15,8 +15,7 @@
You should have received a copy of the GNU General Public License You should have received a copy of the GNU General Public License
along with mboxgrep; if not, write to the Free Software Foundation, along with mboxgrep; if not, write to the Free Software Foundation,
Inc., 59 Temple Place, Suite 330, Boston, MA 02111-1307 USA Inc., 59 Temple Place, Suite 330, Boston, MA 02111-1307 USA
*/
$Id: scan.c,v 1.32 2006-10-22 23:34:49 dspiljar Exp $ */
#include <config.h> #include <config.h>
@@ -33,13 +32,16 @@
# define NAMLEN(dirent) (dirent)->d_namlen # define NAMLEN(dirent) (dirent)->d_namlen
# ifdef HAVE_SYS_NDIR_H # ifdef HAVE_SYS_NDIR_H
# include <sys/ndir.h> # include <sys/ndir.h>
# endif /* HAVE_SYS_NDIR_H */ # endif
/* HAVE_SYS_NDIR_H */
# ifdef HAVE_SYS_DIR_H # ifdef HAVE_SYS_DIR_H
# include <sys/dir.h> # include <sys/dir.h>
# endif /* HAVE_SYS_DIR_H */ # endif
/* HAVE_SYS_DIR_H */
# ifdef HAVE_NDIR_H # ifdef HAVE_NDIR_H
# include <ndir.h> # include <ndir.h>
# endif /* HAVE_NDIR_H */ # endif
/* HAVE_NDIR_H */
#endif /* HAVE_DIRENT_H */ #endif /* HAVE_DIRENT_H */
#include <time.h> #include <time.h>
@@ -62,15 +64,16 @@
#else #else
# ifdef HAVE_FTW # ifdef HAVE_FTW
# include <ftw.h> # include <ftw.h>
# endif /* HAVE_FTW */ # endif
/* HAVE_FTW */
#endif /* HAVE_FTS_OPEN */ #endif /* HAVE_FTS_OPEN */
#ifdef HAVE_LIBDMALLOC #ifdef HAVE_LIBDMALLOC
#include <dmalloc.h> # include <dmalloc.h>
#endif /* HAVE_LIBDMALLOC */ #endif /* HAVE_LIBDMALLOC */
void scan_mailbox (char path[]) void
/* {{{ */ scan_mailbox (char path[])
{ {
static FILE *outf; static FILE *outf;
static mbox_t *mbox, *out; static mbox_t *mbox, *out;
@@ -85,7 +88,8 @@ void scan_mailbox (char path[])
foo = opendir (config.outboxname); /* do NOT change this to m_opendir! */ foo = opendir (config.outboxname); /* do NOT change this to m_opendir! */
if (foo == NULL && errno == ENOENT) if (foo == NULL && errno == ENOENT)
maildir_create (config.outboxname); maildir_create (config.outboxname);
else closedir (foo); else
closedir (foo);
if (-1 == maildir_check (config.outboxname)) if (-1 == maildir_check (config.outboxname))
{ {
@@ -100,22 +104,26 @@ void scan_mailbox (char path[])
if (config.action == DELETE) if (config.action == DELETE)
delete = 1; delete = 1;
if ((config.format == MBOX) || (config.format == ZMBOX) || if ((config.format == MBOX) || (config.format == ZMBOX)
(config.format == BZ2MBOX)) || (config.format == BZ2MBOX))
{ {
mbox = (mbox_t *) mbox_open (path, "r"); mbox = (mbox_t *) mbox_open (path, "r");
if (mbox == NULL) return; if (mbox == NULL)
return;
} }
else if ((config.format == MH) || (config.format == NNMH) || else if ((config.format == MH) || (config.format == NNMH)
(config.format == NNML)) || (config.format == NNML))
{ {
boxd = mh_open (path); boxd = mh_open (path);
if (boxd == NULL) return; if (boxd == NULL)
return;
} }
else if (config.format == MAILDIR) else if (config.format == MAILDIR)
{ {
maildird = maildir_open (path); maildird = maildir_open (path);
if (maildird == NULL) return;
if (maildird == NULL)
return;
} }
for (;;) for (;;)
@@ -123,18 +131,20 @@ void scan_mailbox (char path[])
config.res1 = 1; config.res1 = 1;
config.res2 = 1; config.res2 = 1;
if ((config.format == MBOX) || (config.format == ZMBOX) || if ((config.format == MBOX) || (config.format == ZMBOX)
(config.format == BZ2MBOX)) || (config.format == BZ2MBOX))
msg = (message_t *) mbox_read_message (mbox); msg = (message_t *) mbox_read_message (mbox);
else if ((config.format == MH) || (config.format == NNMH) || else if ((config.format == MH) || (config.format == NNMH)
(config.format == NNML)) || (config.format == NNML))
msg = (message_t *) mh_read_message (boxd); msg = (message_t *) mh_read_message (boxd);
else if (config.format == MAILDIR) else if (config.format == MAILDIR)
msg = (message_t *) maildir_read_message (maildird); msg = (message_t *) maildir_read_message (maildird);
if (msg == NULL) break; if (msg == NULL)
break;
if (msg->from == NULL) msg->from = (char *) xstrdup ("nobody"); if (msg->from == NULL)
msg->from = (char *) xstrdup ("nobody");
#ifdef HAVE_LIBPCRE #ifdef HAVE_LIBPCRE
if (config.perl) if (config.perl)
@@ -156,17 +166,18 @@ void scan_mailbox (char path[])
&& config.format != BZ2MBOX && config.format != BZ2MBOX
&& 0 != strncmp ("From ", msg->headers, 5)) && 0 != strncmp ("From ", msg->headers, 5))
postmark_print (msg); postmark_print (msg);
fprintf (stdout, "%s\n%s", msg->headers, msg->body); fprintf (stdout, "%s\n%s", msg->headers, msg->body);
} }
else if (config.action == WRITE) else if (config.action == WRITE)
{ {
if (config.format == MAILDIR) if (config.format == MAILDIR)
maildir_write_message (msg, config.outboxname); maildir_write_message (msg, config.outboxname);
else if (config.format == MH || config.format == NNMH || else if (config.format == MH || config.format == NNMH
config.format == NNML) || config.format == NNML)
mh_write_message (msg, config.outboxname); mh_write_message (msg, config.outboxname);
else if ((config.format == MBOX) || (config.format == ZMBOX) || else if ((config.format == MBOX) || (config.format == ZMBOX)
(config.format == BZ2MBOX)) || (config.format == BZ2MBOX))
{ {
out = mbox_open (config.outboxname, "w"); out = mbox_open (config.outboxname, "w");
/* fprintf (out->fp, "%s\n%s", msg->headers, msg->body); */ /* fprintf (out->fp, "%s\n%s", msg->headers, msg->body); */
@@ -192,33 +203,33 @@ void scan_mailbox (char path[])
else if (config.action == COUNT) else if (config.action == COUNT)
runtime.count++; runtime.count++;
else if (config.action == DELETE && else if (config.action == DELETE &&
((config.format == MBOX) || (config.format == ZMBOX) || ((config.format == MBOX) || (config.format == ZMBOX)
(config.format == BZ2MBOX))) || (config.format == BZ2MBOX)))
mbox_write_message (msg, runtime.tmp_mbox); mbox_write_message (msg, runtime.tmp_mbox);
} }
else if (((((config.res1 == 0) | (config.res2 == 0)) ^ else
config.invert) && delete) && if (((((config.res1 == 0) | (config.res2 == 0)) ^ config.invert)
((config.format == MH) || (config.format == NNMH) || && delete) && ((config.format == MH) || (config.format == NNMH)
(config.format == NNML) || (config.format == MAILDIR))) || (config.format == NNML)
m_unlink(msg->filename); || (config.format == MAILDIR)))
m_unlink (msg->filename);
free(msg->body); free (msg->body);
free(msg->headers); free (msg->headers);
free(msg); free (msg);
} /* for */ } /* for */
if ((config.format == MBOX) || (config.format == ZMBOX) ||
(config.format == BZ2MBOX)) if ((config.format == MBOX) || (config.format == ZMBOX)
|| (config.format == BZ2MBOX))
mbox_close (mbox); mbox_close (mbox);
else if ((config.format == MH) || (config.format == NNMH) || else if ((config.format == MH) || (config.format == NNMH)
(config.format == NNML)) || (config.format == NNML))
mh_close(boxd); mh_close (boxd);
} }
/* }}} */
void recursive_scan (char path[])
/* {{{ */
void
recursive_scan (char path[])
{ {
#ifdef HAVE_FTS_OPEN #ifdef HAVE_FTS_OPEN
FTS *ftsfoo; FTS *ftsfoo;
@@ -237,7 +248,7 @@ void recursive_scan (char path[])
if (ftsfoo == NULL) if (ftsfoo == NULL)
{ {
/* fixme (?) */ /* fixme (?) */
perror(APPNAME); perror (APPNAME);
exit (2); exit (2);
} }
@@ -251,34 +262,34 @@ void recursive_scan (char path[])
#endif /* HAVE_FTS_OPEN */ #endif /* HAVE_FTS_OPEN */
} }
/* }}} */ int
md5_check_message (char *body, checksum_t * chksum)
int md5_check_message (char *body, checksum_t *chksum)
/* {{{ */
{ {
struct md5_ctx a; struct md5_ctx a;
char b[16]; char b[16];
int i; int i;
md5_init_ctx (&a); md5_init_ctx (&a);
if (body == NULL) if (body == NULL)
md5_process_bytes ("", 0, &a); md5_process_bytes ("", 0, &a);
else else
md5_process_bytes (body, strlen(body), &a); md5_process_bytes (body, strlen (body), &a);
md5_finish_ctx(&a, b);
md5_finish_ctx (&a, b);
for (i = 0; i < chksum->n; i++) for (i = 0; i < chksum->n; i++)
{ {
if (0 == strncmp ((char *)chksum->md5[i], b, 16)) if (0 == strncmp ((char *) chksum->md5[i], b, 16))
return 1; return 1;
} }
chksum->md5 = chksum->md5 =
(char **) xrealloc (chksum->md5, (1 + chksum->n) * sizeof (char *)); (char **) xrealloc (chksum->md5, (1 + chksum->n) * sizeof (char *));
chksum->md5[chksum->n] = xstrdup (b); chksum->md5[chksum->n] = xstrdup (b);
(chksum->n)++; (chksum->n)++;
return 0; return 0;
} }
/* }}} */

View File

@@ -18,12 +18,12 @@
*/ */
#ifndef SCAN_H #ifndef SCAN_H
#define SCAN_H 1 # define SCAN_H 1
#include "mboxgrep.h" # include "mboxgrep.h"
void scan_mailbox (char path[]); void scan_mailbox (char path[]);
void recursive_scan (char path[]); void recursive_scan (char path[]);
int md5_check_message (char *body, checksum_t *chksum); int md5_check_message (char *body, checksum_t * chksum);
#endif /* SCAN_H */ #endif /* SCAN_H */

View File

@@ -31,19 +31,22 @@
# define NAMLEN(dirent) (dirent)->d_namlen # define NAMLEN(dirent) (dirent)->d_namlen
# ifdef HAVE_SYS_NDIR_H # ifdef HAVE_SYS_NDIR_H
# include <sys/ndir.h> # include <sys/ndir.h>
# endif /* HAVE_SYS_NDIR_H */ # endif
/* HAVE_SYS_NDIR_H */
# ifdef HAVE_SYS_DIR_H # ifdef HAVE_SYS_DIR_H
# include <sys/dir.h> # include <sys/dir.h>
# endif /* HAVE_SYS_DIR_H */ # endif
/* HAVE_SYS_DIR_H */
# ifdef HAVE_NDIR_H # ifdef HAVE_NDIR_H
# include <ndir.h> # include <ndir.h>
# endif /* HAVE_NDIR_H */ # endif
/* HAVE_NDIR_H */
#endif /* HAVE_DIRENT_H */ #endif /* HAVE_DIRENT_H */
#ifdef HAVE_LIBZ #ifdef HAVE_LIBZ
#include <zlib.h> # include <zlib.h>
#endif /* HAVE_LIBZ */ #endif /* HAVE_LIBZ */
#ifdef HAVE_LIBBZ2 #ifdef HAVE_LIBBZ2
#include <bzlib.h> # include <bzlib.h>
#endif /* HAVE_LIBBZ2 */ #endif /* HAVE_LIBBZ2 */
#include <sys/types.h> #include <sys/types.h>
@@ -54,12 +57,13 @@
#include "mboxgrep.h" #include "mboxgrep.h"
#ifndef APPNAME #ifndef APPNAME
#define APPNAME "mboxgrep" # define APPNAME "mboxgrep"
#endif #endif
#define BUFLEN 16384 #define BUFLEN 16384
int m_open (const char *pathname, int flags, mode_t mode) int
m_open (const char *pathname, int flags, mode_t mode)
{ {
int blah; int blah;
@@ -78,7 +82,8 @@ int m_open (const char *pathname, int flags, mode_t mode)
return blah; return blah;
} }
FILE *m_fopen (const char *path, const char *mode) FILE *
m_fopen (const char *path, const char *mode)
{ {
FILE *blah; FILE *blah;
@@ -96,7 +101,8 @@ FILE *m_fopen (const char *path, const char *mode)
return blah; return blah;
} }
FILE *m_fdopen (int fildes, const char *mode) FILE *
m_fdopen (int fildes, const char *mode)
{ {
FILE *blah; FILE *blah;
@@ -111,7 +117,8 @@ FILE *m_fdopen (int fildes, const char *mode)
#ifdef HAVE_LIBZ #ifdef HAVE_LIBZ
gzFile m_gzdopen (int fildes, const char *mode) gzFile
m_gzdopen (int fildes, const char *mode)
{ {
gzFile blah; gzFile blah;
@@ -126,7 +133,8 @@ gzFile m_gzdopen (int fildes, const char *mode)
#endif /* HAVE_LIBZ */ #endif /* HAVE_LIBZ */
DIR *m_opendir (const char *name) DIR *
m_opendir (const char *name)
{ {
DIR *blah; DIR *blah;
@@ -144,7 +152,8 @@ DIR *m_opendir (const char *name)
#ifndef HAVE_LIBDMALLOC #ifndef HAVE_LIBDMALLOC
void *xmalloc (size_t size) void *
xmalloc (size_t size)
{ {
void *foo; void *foo;
@@ -158,7 +167,8 @@ void *xmalloc (size_t size)
return foo; return foo;
} }
void *xrealloc (void *ptr, size_t size) void *
xrealloc (void *ptr, size_t size)
{ {
void *foo; void *foo;
@@ -172,7 +182,8 @@ void *xrealloc (void *ptr, size_t size)
return foo; return foo;
} }
void *xcalloc (size_t nmemb, size_t size) void *
xcalloc (size_t nmemb, size_t size)
{ {
void *foo; void *foo;
@@ -186,7 +197,8 @@ void *xcalloc (size_t nmemb, size_t size)
return foo; return foo;
} }
char *xstrdup (const char *s) char *
xstrdup (const char *s)
{ {
char *foo; char *foo;
@@ -202,7 +214,8 @@ char *xstrdup (const char *s)
#endif /* HAVE_LIBDMALLOC */ #endif /* HAVE_LIBDMALLOC */
int m_unlink (const char *pathname) int
m_unlink (const char *pathname)
{ {
int baz; int baz;
@@ -220,7 +233,8 @@ int m_unlink (const char *pathname)
#ifdef HAVE_LIBZ #ifdef HAVE_LIBZ
void gzwrite_loop (void *fp, char *str) void
gzwrite_loop (void *fp, char *str)
{ {
int quux, len, baz; int quux, len, baz;
@@ -228,7 +242,7 @@ void gzwrite_loop (void *fp, char *str)
baz = strlen (str); baz = strlen (str);
for (;;) for (;;)
{ {
len = gzwrite (fp, (str+quux), len = gzwrite (fp, (str + quux),
(((quux + BUFLEN) < baz) ? BUFLEN : (baz - quux))); (((quux + BUFLEN) < baz) ? BUFLEN : (baz - quux)));
quux += len; quux += len;
if (quux == baz) if (quux == baz)
@@ -240,7 +254,8 @@ void gzwrite_loop (void *fp, char *str)
#ifdef HAVE_LIBBZ2 #ifdef HAVE_LIBBZ2
void bzwrite_loop (void *fp, char *str) void
bzwrite_loop (void *fp, char *str)
{ {
int quux, len, baz; int quux, len, baz;
@@ -248,7 +263,7 @@ void bzwrite_loop (void *fp, char *str)
baz = strlen (str); baz = strlen (str);
for (;;) for (;;)
{ {
len = BZ2_bzwrite (fp, (str+quux), len = BZ2_bzwrite (fp, (str + quux),
(((quux + BUFLEN) < baz) ? BUFLEN : (baz - quux))); (((quux + BUFLEN) < baz) ? BUFLEN : (baz - quux)));
quux += len; quux += len;
if (quux == baz) if (quux == baz)

View File

@@ -22,55 +22,64 @@
/* wrappers around certain std functions */ /* wrappers around certain std functions */
#ifndef WRAP_H #ifndef WRAP_H
#define WRAP_H # define WRAP_H
#include <config.h> # include <config.h>
#include <stdio.h> # include <stdio.h>
#include <sys/types.h> # include <sys/types.h>
#ifdef HAVE_DIRENT_H # ifdef HAVE_DIRENT_H
# include <dirent.h> # include <dirent.h>
#else # else
# ifdef HAVE_SYS_NDIR_H # ifdef HAVE_SYS_NDIR_H
# include <sys/ndir.h> # include <sys/ndir.h>
# endif /* HAVE_SYS_NDIR_H */ # endif
/* HAVE_SYS_NDIR_H */
# ifdef HAVE_SYS_DIR_H # ifdef HAVE_SYS_DIR_H
# include <sys/dir.h> # include <sys/dir.h>
# endif /* HAVE_SYS_DIR_H */ # endif
/* HAVE_SYS_DIR_H */
# ifdef HAVE_NDIR_H # ifdef HAVE_NDIR_H
# include <ndir.h> # include <ndir.h>
# endif /* HAVE_NDIR_H */ # endif
#endif /* HAVE_DIRENT_H */ /* HAVE_NDIR_H */
#ifdef HAVE_LIBZ # endif
#include <zlib.h> /* HAVE_DIRENT_H */
#endif /* HAVE_LIBZ */ # ifdef HAVE_LIBZ
# include <zlib.h>
# endif
/* HAVE_LIBZ */
#include <stdlib.h> # include <stdlib.h>
#ifdef HAVE_LIBDMALLOC # ifdef HAVE_LIBDMALLOC
# include <dmalloc.h> # include <dmalloc.h>
#endif /* HAVE_LIBDMALLOC */ # endif
/* HAVE_LIBDMALLOC */
int m_open (const char *pathname, int flags, mode_t mode); int m_open (const char *pathname, int flags, mode_t mode);
FILE *m_fopen (const char *path, const char *mode); FILE *m_fopen (const char *path, const char *mode);
FILE *m_fdopen (int fildes, const char *mode); FILE *m_fdopen (int fildes, const char *mode);
#ifdef HAVE_LIBZ # ifdef HAVE_LIBZ
gzFile m_gzdopen (int fildes, const char *mode); gzFile m_gzdopen (int fildes, const char *mode);
void gzwrite_loop (void *fp, char *str); void gzwrite_loop (void *fp, char *str);
#endif /* HAVE_LIBZ */ # endif
#ifdef HAVE_LIBBZ2 /* HAVE_LIBZ */
# ifdef HAVE_LIBBZ2
void bzwrite_loop (void *fp, char *str); void bzwrite_loop (void *fp, char *str);
#endif /* HAVE_LIBBZ2 */ # endif
/* HAVE_LIBBZ2 */
DIR *m_opendir (const char *name); DIR *m_opendir (const char *name);
#ifndef HAVE_LIBDMALLOC # ifndef HAVE_LIBDMALLOC
void *xmalloc (size_t size); void *xmalloc (size_t size);
void *xrealloc (void *ptr, size_t size); void *xrealloc (void *ptr, size_t size);
void *xcalloc (size_t nmemb, size_t size); void *xcalloc (size_t nmemb, size_t size);
char *xstrdup (const char *s); char *xstrdup (const char *s);
#endif /* HAVE_LIBDMALLOC */ # endif
/* HAVE_LIBDMALLOC */
int m_unlink (const char *pathname); int m_unlink (const char *pathname);