recctrl/rectext.c

   1 /* $Id: rectext.c,v 1.28 2005-06-14 20:27:33 adam Exp $
   2    Copyright (C) 1995-2005
   3    Index Data ApS
   4
   5 This file is part of the Zebra server.
   6
   7 Zebra is free software; you can redistribute it and/or modify it under
   8 the terms of the GNU General Public License as published by the Free
   9 Software Foundation; either version 2, or (at your option) any later
  10 version.
  11
  12 Zebra is distributed in the hope that it will be useful, but WITHOUT ANY
  13 WARRANTY; without even the implied warranty of MERCHANTABILITY or
  14 FITNESS FOR A PARTICULAR PURPOSE.  See the GNU General Public License
  15 for more details.
  16
  17 You should have received a copy of the GNU General Public License
  18 along with Zebra; see the file LICENSE.zebra.  If not, write to the
  19 Free Software Foundation, 59 Temple Place - Suite 330, Boston, MA
  20 02111-1307, USA.
  21 */
  22
  23
  24 #include <stdio.h>
  25 #include <assert.h>
  26 #include <ctype.h>
  27
  28 #include <idzebra/util.h>
  29 #include <idzebra/recctrl.h>
  30
  31 struct filter_info {
  32     char *sep;
  33 };
  34
  35 static void *filter_init (Res res, RecType recType)
  36 {
  37     struct filter_info *tinfo = (struct filter_info *) xmalloc(sizeof(*tinfo));
  38     tinfo->sep = 0;
  39     return tinfo;
  40 }
  41
  42 static void filter_config(void *clientData, Res res, const char *args)
  43 {
  44     struct filter_info *tinfo = (struct marc_info*) clientData;
  45     xfree(tinfo->sep);
  46     tinfo->sep = 0;
  47     if (args && *args)
  48         tinfo->sep = xstrdup(args);
  49 }
  50
  51 static void filter_destroy (void *clientData)
  52 {
  53     struct filter_info *tinfo = clientData;
  54     xfree (tinfo->sep);
  55     xfree (tinfo);
  56 }
  57
  58 struct buf_info {
  59     struct recExtractCtrl *p;
  60     char *buf;
  61     int offset;
  62     int max;
  63 };
  64
  65 static struct buf_info *buf_open (struct recExtractCtrl *p)
  66 {
  67     struct buf_info *fi = (struct buf_info *) xmalloc (sizeof(*fi));
  68
  69     fi->p = p;
  70     fi->buf = (char *) xmalloc (4096);
  71     fi->offset = 1;
  72     fi->max = 1;
  73     return fi;
  74 }
  75
  76 static int buf_getchar (struct filter_info *tinfo, struct buf_info *fi, char *dst)
  77 {
  78     if (fi->offset >= fi->max)
  79     {
  80         if (fi->max <= 0)
  81             return 0;
  82         fi->max = (*fi->p->readf)(fi->p->fh, fi->buf, 4096);
  83         fi->offset = 0;
  84         if (fi->max <= 0)
  85             return 0;
  86     }
  87     *dst = fi->buf[(fi->offset)++];
  88     if (tinfo->sep && *dst == *tinfo->sep)
  89     {
  90         off_t off = (*fi->p->tellf)(fi->p->fh);
  91         (*fi->p->endf)(fi->p->fh, off - (fi->max - fi->offset));
  92         return 0;
  93     }
  94     return 1;
  95 }
  96
  97 static void buf_close (struct buf_info *fi)
  98 {
  99     xfree (fi->buf);
 100     xfree (fi);
 101 }
 102
 103 static int filter_extract (void *clientData, struct recExtractCtrl *p)
 104 {
 105     struct filter_info *tinfo = clientData;
 106     char w[512];
 107     RecWord recWord;
 108     int r;
 109     struct buf_info *fi = buf_open (p);
 110     int no_read = 0;
 111
 112 #if 0
 113     yaz_log(YLOG_LOG, "filter_extract off=%ld",
 114             (long) (*fi->p->tellf)(fi->p->fh));
 115 #endif
 116     (*p->init)(p, &recWord);
 117     recWord.reg_type = 'w';
 118     do
 119     {
 120         int i = 0;
 121
 122         r = buf_getchar (tinfo, fi, w);
 123         while (r > 0 && i < 511 && w[i] != '\n' && w[i] != '\r')
 124         {
 125             i++;
 126             r = buf_getchar (tinfo, fi, w + i);
 127         }
 128         if (i)
 129         {
 130             no_read += i;
 131             recWord.term_buf = w;
 132             recWord.term_len = i;
 133             (*p->tokenAdd)(&recWord);
 134         }
 135     } while (r > 0);
 136     buf_close (fi);
 137     if (no_read == 0)
 138         return RECCTRL_EXTRACT_EOF;
 139     return RECCTRL_EXTRACT_OK;
 140 }
 141
 142 static int filter_retrieve (void *clientData, struct recRetrieveCtrl *p)
 143 {
 144     int r, filter_ptr = 0;
 145     static char *filter_buf = NULL;
 146     static int filter_size = 0;
 147     int make_header = 1;
 148     int make_body = 1;
 149     const char *elementSetName = NULL;
 150     int no_lines = 0;
 151
 152     if (p->comp && p->comp->which == Z_RecordComp_simple &&
 153         p->comp->u.simple->which == Z_ElementSetNames_generic)
 154         elementSetName = p->comp->u.simple->u.generic;
 155
 156     if (elementSetName)
 157     {
 158         /* don't make header for the R(aw) element set name */
 159         if (!strcmp(elementSetName, "R"))
 160         {
 161             make_header = 0;
 162             make_body = 1;
 163         }
 164         /* only make header for the H(eader) element set name */
 165         else if (!strcmp(elementSetName, "H"))
 166         {
 167             make_header = 1;
 168             make_body = 0;
 169         }
 170     }
 171     while (1)
 172     {
 173         if (filter_ptr + 4096 >= filter_size)
 174         {
 175             char *nb;
 176
 177             filter_size = 2*filter_size + 8192;
 178             nb = (char *) xmalloc (filter_size);
 179             if (filter_buf)
 180             {
 181                 memcpy (nb, filter_buf, filter_ptr);
 182                 xfree (filter_buf);
 183             }
 184             filter_buf = nb;
 185         }
 186         if (make_header && filter_ptr == 0)
 187         {
 188             if (p->score >= 0)
 189             {
 190                 sprintf (filter_buf, "Rank: %d\n", p->score);
 191                 filter_ptr = strlen(filter_buf);
 192             }
 193             sprintf (filter_buf + filter_ptr, "Local Number: " ZINT_FORMAT "\n",
 194                      p->localno);
 195             filter_ptr = strlen(filter_buf);
 196             if (p->fname)
 197             {
 198                 sprintf (filter_buf + filter_ptr, "Filename: %s\n", p->fname);
 199                 filter_ptr = strlen(filter_buf);
 200             }
 201             strcpy(filter_buf+filter_ptr++, "\n");
 202         }
 203         if (!make_body)
 204             break;
 205         r = (*p->readf)(p->fh, filter_buf + filter_ptr, 4096);
 206         if (r <= 0)
 207             break;
 208         filter_ptr += r;
 209     }
 210     filter_buf[filter_ptr] = '\0';
 211     if (elementSetName)
 212     {
 213         if (!strcmp (elementSetName, "B"))
 214             no_lines = 4;
 215         if (!strcmp (elementSetName, "M"))
 216             no_lines = 20;
 217     }
 218     if (no_lines)
 219     {
 220         char *p = filter_buf;
 221         int i = 0;
 222
 223         while (++i <= no_lines && (p = strchr (p, '\n')))
 224             p++;
 225         if (p)
 226         {
 227             p[1] = '\0';
 228             filter_ptr = p-filter_buf;
 229         }
 230     }
 231     p->output_format = VAL_SUTRS;
 232     p->rec_buf = filter_buf;
 233     p->rec_len = filter_ptr;
 234     return 0;
 235 }
 236
 237 static struct recType filter_type = {
 238     0,
 239     "text",
 240     filter_init,
 241     filter_config,
 242     filter_destroy,
 243     filter_extract,
 244     filter_retrieve
 245 };
 246
 247 RecType
 248 #ifdef IDZEBRA_STATIC_TEXT
 249 idzebra_filter_text
 250 #else
 251 idzebra_filter
 252 #endif
 253
 254 [] = {
 255     &filter_type,
 256     0,
 257 };