ezmlm-sub.c

Go to the documentation of this file.

#include <sys/types.h>
#include <sys/stat.h>
#include <unistd.h>
#include "subscribe.h"
#include "getoptb.h"
#include "stralloc.h"
#include "buffer.h"
#include "readwrite.h"
#include "getln.h"
#include "scan.h"
#include "errtxt.h"
#include "idx.h"
#include "auto_version.h"
#include "logmsg.h"
 
#define WHO "ezmlm-subunsub"

 
stralloc line = {0};
 
static void die_nomem() { logmsg(WHO,111,FATAL,ERR_NOMEM); }
static void die_usage(void) { logmsg(WHO,100,USAGE,"ezmlm-sub [-mMvV] [-h hash] [-n] dir [box@domain [name]] ..."); };
 
int main (int argc,char **argv)
{
  char *dir;
  char *addr;
  char *comment;
  char *cp;
  char ch;
  int match;
  int flagmysql = 1;            /* use mysql if supported */
  int forcehash = -1;
  int flagname = 0;
  int submode = 1;              // subscribe
  unsigned long u;
  int opt;
  char manual[8] = "+manual";
 
  manual[0] = submode ? '+' : '-';
 
  umask(022);
  while ((opt = getoptb(argc,argv,"h:HmMnNvV")) != opteof)
    switch(opt) {
      case 'h': scan_ulong(optarg,&u); forcehash = 0; break;
      case 'H': forcehash = -1; break;
      case 'm': flagmysql = 1; break;
      case 'M': flagmysql = 0; break;
      case 'n': flagname = 1; break;
      case 'N': flagname = 0; break;
      case 'v':
      case 'V': logmsg(WHO,0,VERSION,auto_version);
      default:  die_usage();
    }
 
  dir = argv[optind++];
  if (!dir) die_usage();
 
  if (dir[0] != '/')
    logmsg(WHO,100,FATAL,B(ERR_SLASH,dir));
 
  if (chdir(dir) == -1)
    logmsg(WHO,111,FATAL,B(ERR_SWITCH,dir));
 
  if (forcehash == 0) forcehash = (int) u;
 
  if (argv[optind]) {
    if (flagname) {
        /* allow repeats and last addr doesn't need comment */
      while ((addr = argv[optind++])) {
        subscribe(dir,addr,submode,argv[optind],manual,flagmysql,forcehash,(char *) 0);
        if (!argv[optind++]) break;
      }
    } else {
      while ((addr = argv[optind++]))
        subscribe(dir,addr,submode,"",manual,flagmysql,forcehash,(char *) 0);
    }
  } else {                   /* stdin */
    for (;;) {
      if (getln(buffer_0,&line,&match,'\n') == -1)
        logmsg(WHO,111,FATAL,ERR_READ_INPUT);
      if (!match) break;
      if (line.len == 1 || *line.s == '#') continue;
      line.s[line.len - 1] = '\0';
      comment = (char *) 0;
      if (flagname) {
        cp = line.s;
        while ((ch = *cp)) {
          if (ch == '\\') {
            if (!*(++cp)) break;
           } else 
            if (ch == ' ' || ch == '\t' || ch == ',') break;
           cp++;
        }
        if (ch) {
          *cp = '\0';
          comment = cp + 1;
        }
      }
      subscribe(dir,line.s,submode,comment,manual,flagmysql,forcehash,(char *) 0);
    }
  }
  closesql();
  _exit(0);
}