kernel/urp.c

   1 /* Gateway kernel
   2  * Europagate, 1995
   3  *
   4  * $Log: urp.c,v $
   5  * Revision 1.5  1995/02/17 14:22:13  adam
   6  * First steps of CCL show command. Not finished yet.
   7  *
   8  * Revision 1.4  1995/02/17  09:08:36  adam
   9  * Reply with subject. CCL base command implemented.
  10  *
  11  * Revision 1.3  1995/02/16  18:35:09  adam
  12  * First use of Zdist library. Search requests are supported.
  13  * Present requests are not supported yet.
  14  *
  15  * Revision 1.2  1995/02/16  13:21:00  adam
  16  * Organization of resource files for targets and conversion
  17  * language implemented.
  18  *
  19  * Revision 1.1  1995/02/15  17:45:30  adam
  20  * First version of email gateway kernel. Email requests are read
  21  * from stdin. The output is transferred to an MTA if 'From' is
  22  * found in the header - or stdout if absent. No Z39.50 client is used.
  23  *
  24  */
  25
  26 #include <stdio.h>
  27 #include <stdlib.h>
  28 #include <assert.h>
  29 #include <ctype.h>
  30 #include <string.h>
  31 #include <unistd.h>
  32
  33 #include "kernel.h"
  34
  35 #define LINE_MAX 256
  36
  37 static int reopen_target (void)
  38 {
  39     const char *v;
  40     if (info.zass)
  41         gw_log (GW_LOG_WARN, "urp", "Zass free...");
  42     info.zass = zass_open (info.hostname, info.port);
  43     if (!info.zass)
  44     {
  45         fprintf (reply_fd, "%s %s:%d\n",
  46                  gw_res_get (info.kernel_res, "gw.err.connect",
  47                              "Cannot connect to target"),
  48                  info.hostname, info.port);
  49         return -1;
  50     }
  51     v = gw_res_get (info.kernel_res, "gw.description", NULL);
  52     if (v)
  53         fprintf (reply_fd, "%s\n", v);
  54     fprintf (reply_fd, "%s %s:%d\n %s\n",
  55              gw_res_get (info.kernel_res, "gw.msg.databases",
  56                          "Available databases on"),
  57              info.hostname, info.port, info.databases);
  58     return 0;
  59 }
  60
  61 static char line_buf[LINE_MAX+1];
  62
  63 static struct command_word {
  64     char *default_value;
  65     char *resource_suffix;
  66 } command_tab [] =
  67 {
  68 {   "find", "find"},
  69 {   "show", "show"},
  70 {   "base", "base" },
  71 {   "help", "help" },
  72 {   "info", "info" },
  73 {   "continue", "continue" },
  74 {   "status", "status" },
  75 {   "cancel", "cancel" },
  76 {   "target", "target" },
  77 {   NULL, NULL }
  78 };
  79
  80 static int command_search (struct command_word *tab, struct ccl_token *cmd,
  81 const char *resource_prefix)
  82 {
  83     int no = 1;
  84
  85     assert (resource_prefix);
  86     assert (tab);
  87     assert (cmd);
  88     while (tab->default_value)
  89     {
  90         char *cp, command_names[60];
  91         char resource_name[60];
  92         const char *v;
  93
  94         sprintf (resource_name, "%s%s", resource_prefix,
  95                  tab->resource_suffix);
  96         v = gw_res_get (info.kernel_res, resource_name, tab->default_value);
  97         assert (v);
  98         strcpy (command_names, v);
  99         cp = command_names;
 100         while (1)
 101         {
 102             char *split;
 103
 104             if ((split = strchr (cp, ' ')))
 105                 *split = '\0';
 106             if (cmd->len == strlen(cp) &&
 107                 !memcmp (cmd->name, cp, cmd->len))
 108                 return no;
 109             if (!split)
 110                 break;
 111             cp = split+1;
 112         }
 113         no++;
 114         tab++;
 115     }
 116     return 0;
 117 }
 118
 119 static struct error_no_struct {
 120     int no;
 121     char *resource_name;
 122 } error_ccl_tab[] = {
 123 {  CCL_ERR_OK, "ok"},
 124 {  CCL_ERR_TERM_EXPECTED, "term.expected" },
 125 {  CCL_ERR_RP_EXPECTED, "rp.expected" },
 126 {  CCL_ERR_SETNAME_EXPECTED, "setname.expected" },
 127 {  CCL_ERR_OP_EXPECTED, "op.expected" },
 128 {  CCL_ERR_BAD_RP, "bad.rp" },
 129 {  CCL_ERR_UNKNOWN_QUAL, "unknown.qual" },
 130 {  CCL_ERR_DOUBLE_QUAL, "double.qual" },
 131 {  CCL_ERR_EQ_EXPECTED, "eq.expected" },
 132 {  CCL_ERR_BAD_RELATION, "bad.relation" },
 133 {  CCL_ERR_TRUNC_NOT_LEFT, "trunc.not.left" },
 134 {  CCL_ERR_TRUNC_NOT_BOTH, "trunc.not.both" },
 135 {  CCL_ERR_TRUNC_NOT_RIGHT, "trunc.not.right" },
 136 {  0, NULL }
 137 };
 138
 139 static char *error_no_search (struct error_no_struct *tab, int no)
 140 {
 141     struct error_no_struct *p = tab;
 142     while (p->resource_name)
 143     {
 144         if (no == p->no)
 145             return p->resource_name;
 146         p++;
 147     }
 148     return NULL;
 149 }
 150
 151 static int email_header (FILE *inf, char *from_str, char *subject_str)
 152 {
 153     *from_str = '\0';
 154     *subject_str = '\0';
 155     while (fgets (line_buf, LINE_MAX, inf))
 156     {
 157         if (line_buf[0] == '\n')
 158             return 0;
 159         if (strncmp (line_buf, "From ", 5) == 0)
 160             sscanf (line_buf+4, "%s", from_str);
 161         if (strncmp (line_buf, "Subject: ", 9) == 0 &&
 162             sscanf (line_buf+9, "%s", subject_str+1) == 1)
 163             strcpy (subject_str, line_buf+9);
 164     }
 165     return 1;
 166 }
 167
 168 static int exec_find (struct ccl_token *list)
 169 {
 170     const struct zass_searchent *p;
 171
 172     struct ccl_rpn_node *rpn;
 173     int error;
 174     const char *pos;
 175
 176     rpn = ccl_find (info.bibset, list, &error, &pos);
 177     if (!rpn)
 178     {
 179         const char *v = NULL, *n;
 180         char name[128];
 181
 182         fprintf (reply_fd, "  %*s^ - ", pos - line_buf, " ");
 183
 184         n = error_no_search (error_ccl_tab, error);
 185         if (n)
 186         {
 187             sprintf (name, "gw.err.%s", n);
 188             v = gw_res_get (info.kernel_res, name, NULL);
 189         }
 190         if (!v)
 191             v = ccl_err_msg (error);
 192         fprintf (reply_fd, "%s\n", v);
 193         return -1;
 194     }
 195     ccl_pr_tree (rpn, reply_fd);
 196     fprintf (reply_fd, "\n");
 197
 198     if (!info.zass)
 199         return -2;
 200     p = zass_search (info.zass, rpn, "Default", info.databases);
 201     if (!p)
 202         return -1;
 203     fprintf (reply_fd, "%d %s\n", p->num,
 204              gw_res_get (info.kernel_res, "gw.msg.hits", "hit(s)"));
 205     if (p->errcode != -1)
 206         fprintf (reply_fd, "%s %d: %s\n",
 207                  gw_res_get (info.kernel_res, "gw.msg.z39errcode",
 208                              "Z39.50 error code"),
 209                  p->errcode, p->errstring);
 210     return 0;
 211 }
 212
 213 static int exec_target (struct ccl_token *list)
 214 {
 215     int len;
 216     if (list->kind == CCL_TOK_EOL)
 217         return -1;
 218     len = list->len;
 219     memcpy (info.target, list->name, len);
 220     info.target [len] = '\0';
 221
 222     read_kernel_res ();
 223     return reopen_target ();
 224 }
 225
 226 static int exec_base (struct ccl_token *list)
 227 {
 228     struct ccl_token *li = list;
 229     int len = 0;
 230
 231     if (list->kind == CCL_TOK_EOL)
 232         return -1;
 233     free (info.databases);
 234     while (li->kind != CCL_TOK_EOL)
 235     {
 236         len += li->len + 1;
 237         li = li->next;
 238         if (li->kind == CCL_TOK_COMMA)
 239             li = li->next;
 240     }
 241     info.databases = malloc (len);
 242     assert (info.databases);
 243     len = 0;
 244     li = list;
 245     while (li->kind != CCL_TOK_EOL)
 246     {
 247         memcpy (info.databases+len, li->name, li->len);
 248         len += li->len;
 249         info.databases[len++] = ',';
 250         li = li->next;
 251         if (li->kind == CCL_TOK_COMMA)
 252             li = li->next;
 253     }
 254     info.databases[len-1] = '\0';
 255     return 0;
 256 }
 257
 258 static int exec_show (struct ccl_token *list)
 259 {
 260     const struct zass_presentent *zp;
 261     char num_str[20];
 262     int num;
 263
 264     if (list->kind == CCL_TOK_EOL)
 265         return -1;
 266     if (!info.zass)
 267         return -2;
 268
 269     memcpy (num_str, list->name, list->len);
 270     num_str[list->len] = '\0';
 271
 272     num = atoi (num_str);
 273     if (!num)
 274         return -3;
 275     gw_log (GW_LOG_DEBUG, "urp", "zass_present of %d records", num);
 276     zp = zass_present(info.zass, "Default", 1, num);
 277     return 0;
 278 }
 279
 280 static int exec_command (const char *str)
 281 {
 282     struct ccl_token *cmd = ccl_tokenize (str);
 283     int no;
 284
 285     if (cmd->kind != CCL_TOK_EOL &&
 286         (no = command_search (command_tab, cmd, "ccl.command.")))
 287     {
 288         if (!info.zass && no != 9)
 289             reopen_target ();
 290         fprintf (reply_fd, "\n> %s", str);
 291         switch (no)
 292         {
 293         case 1:
 294             return exec_find (cmd->next);
 295         case 2:
 296             return exec_show (cmd->next);
 297         case 3:
 298             return exec_base (cmd->next);
 299         case 9:
 300             return exec_target (cmd->next);
 301         default:
 302             fprintf (reply_fd, "%s\n",
 303                      gw_res_get (info.kernel_res, "gw.err.unimplemented",
 304                                  "Not implemented yet"));
 305         }
 306     }
 307     else
 308     {
 309         fprintf (reply_fd, "\n> %s", str);
 310         fprintf (reply_fd, "  ^ %s\n",
 311                  gw_res_get (info.kernel_res, "gw.err.unknown.command",
 312                              "unknown command"));
 313     }
 314     return 0;
 315 }
 316
 317 int urp (FILE *inf)
 318 {
 319     char from_str[128];
 320     char subject_str[128];
 321     int command_no = 0;
 322     char *reply_fname = NULL;
 323
 324     if (email_header (inf, from_str, subject_str))
 325     {
 326         gw_log (GW_LOG_WARN, "urp", "No message body");
 327         return -1;
 328     }
 329     if (*from_str)
 330     {
 331         reply_fname = tempnam (gw_res_get (info.kernel_res,
 332                                            "gw.reply.tmp.dir", NULL),
 333                                gw_res_get (info.kernel_res,
 334                                            "gw.reply.tmp.prefix", "gwr"));
 335
 336         reply_fd = fopen (reply_fname, "w");
 337         if (!reply_fd)
 338         {
 339             gw_log (GW_LOG_FATAL, "urp", "Cannot create %s",
 340                     reply_fname);
 341             return -1;
 342         }
 343         fprintf (reply_fd, "Subject: ");
 344         if (*subject_str)
 345             fprintf (reply_fd, "Z39.50 Re: %s", subject_str);
 346         else
 347             fprintf (reply_fd, "%s\n", gw_res_get (info.kernel_res,
 348                                                    "gw.msg.subject",
 349                                                    "Your Z39.50 Query"));
 350         fprintf (reply_fd, "\n");
 351     }
 352     else
 353         gw_log (GW_LOG_WARN, "urp", "No From in email header");
 354     fprintf (reply_fd, "%s\n", gw_res_get (info.kernel_res, "gw.msg.greeting",
 355                                            "Email->Z39.50 gateway"));
 356     while (fgets (line_buf, LINE_MAX, inf))
 357     {
 358         if (line_buf[0] == '\n')
 359             break;
 360         ccl_token_and = gw_res_get (info.kernel_res, "ccl.token.and", "and");
 361         ccl_token_or = gw_res_get (info.kernel_res, "ccl.token.or", "or");
 362         ccl_token_not = gw_res_get (info.kernel_res, "ccl.token.not", "not");
 363         ccl_token_set = gw_res_get (info.kernel_res, "ccl.token.set", "set");
 364         if (isalpha (line_buf[0]))
 365             exec_command (line_buf);
 366         command_no++;
 367     }
 368     if (!command_no)
 369         fprintf (reply_fd, "%s\n", gw_res_get (info.kernel_res,
 370                                                "gw.err.nullbody",
 371                                                "No body"));
 372     if (*from_str)
 373     {
 374         const char *mta;
 375         char cmd[256];
 376         int mta_code;
 377
 378         assert (reply_fname);
 379         fclose (reply_fd);
 380         reply_fd = stdout;
 381
 382         mta = gw_res_get (info.kernel_res, "gw.reply.mta",
 383                           "/usr/lib/sendmail");
 384         sprintf (cmd, "%s %s < %s", mta, from_str, reply_fname);
 385
 386         mta_code = system (cmd);
 387         if (mta_code)
 388             gw_log (GW_LOG_FATAL, "urp", "Reply '%s' got exit code %d",
 389                     cmd, mta_code);
 390         unlink (reply_fname);
 391     }
 392     return 0;
 393 }