searchlog.c

Go to the documentation of this file.

#include <unistd.h>
#include "getln.h"
#include "case.h"
#include "scan.h"
#include "stralloc.h"
#include "str.h"
#include "open.h"
#include "datetime.h"
#include "date822fmt.h"
#include "buffer.h"
#include "readwrite.h"
#include "error.h"
#include "errtxt.h"
#include "subscribe.h"
#include "idx.h"
#include "logmsg.h"
 
#define WHO "searchlog"

 
static stralloc line = {0};
static stralloc outline = {0};
static char date[DATE822FMT];
static datetime_sec when;
static buffer bi;
static char inbuf[256];
 
static void die_nomem() { logmsg(WHO,111,FATAL,ERR_NOMEM); }
 
static void lineout(int subwrite())
{
  struct datetime dt;
  (void) scan_ulong(line.s,&when);
  datetime_tai(&dt,when);        /* there is always at least a '\n' */
  if (!stralloc_copyb(&outline,date,date822fmt(date,&dt) - 1))
    die_nomem();
  if (!stralloc_cats(&outline,": ")) die_nomem();
  if (!stralloc_catb(&outline,line.s,line.len - 1)) die_nomem();
  if (subwrite(outline.s,outline.len) == -1)
    logmsg(WHO,111,FATAL,B(ERR_WRITE,"output"));
  return;
}

 
void searchlog(const char *dir,char *search,int subwrite())
{
 
  unsigned char x;
  unsigned char y;
  unsigned char *cp;
  unsigned char *cpsearch;
  unsigned char *cps;
  unsigned char ch;
  unsigned char *cplast, *cpline;
  unsigned int searchlen;
  int fd,match;
 
  searchlen = str_len(search);
  case_lowerb(search,searchlen);
  cps = (unsigned char *) search;
 
  while ((ch = *(cps++))) {            /* search is potentially hostile */
    if (ch >= 'a' && ch <= 'z') continue;
    if (ch >= '0' && ch <= '9') continue;
    if (ch == '.' || ch == '_') continue;
    *(cps - 1) = '_';                  /* will [also] match char specified */
  }
 
  if (!stralloc_copys(&line,dir)) die_nomem();
  if (!stralloc_cats(&line,"/Log")) die_nomem();
  if (!stralloc_0(&line)) die_nomem();
  fd = open_read(line.s);
  if (fd == -1)
    if (errno != ENOENT)
      logmsg(WHO,111,FATAL,B(ERR_OPEN,line.s));
    else
      logmsg(WHO,100,FATAL,B(line.s,ERR_NOEXIST));
 
  buffer_init(&bi,buffer_unixread,fd,inbuf,sizeof(inbuf));
 
  for (;;) {
    if (getln(&bi,&line,&match,'\n') == -1)
      logmsg(WHO,111,FATAL,ERR_READ_INPUT);
    if (!match) break;
    if (!searchlen) {
      lineout(subwrite);
    } else {                                     /* simple case-insensitive search */
      cpline = (unsigned char *) line.s - 1;
      cplast = cpline + line.len - searchlen;    /* line has \0 at the end */
 
      while ((cp = ++cpline) <= cplast) {
        cpsearch = (unsigned char *) search;
        for (;;) {
          x = *cpsearch++;
          if (!x) break;
          y = *cp++ - 'A';
          if (y <= 'Z' - 'A') y += 'a'; else y += 'A';
          if (x != y && x != '_') break;         /* '_' = wildcard */
        }
 
        if (!x) {
          lineout(subwrite);
          break;
        }
      }
    }
  }
  close(fd);
}