kernel/main.c

   1 /* Gateway kernel
   2  * Europagate, 1995
   3  *
   4  * $Log: main.c,v $
   5  * Revision 1.9  1995/02/23 08:32:17  adam
   6  * Changed header.
   7  *
   8  * Revision 1.7  1995/02/22  15:22:33  adam
   9  * Much more checking of run-time state. Show command never retrieves
  10  * more records than indicated by the previous search request. Help
  11  * command available. The maximum number of records retrieved can be
  12  * controlled now.
  13  *
  14  * Revision 1.6  1995/02/22  08:51:34  adam
  15  * Output function can be customized in fml, which is used to print
  16  * the reply to reply_fd.
  17  *
  18  * Revision 1.5  1995/02/20  21:16:20  adam
  19  * FML support. Bug fixes. Profile for drewdb.
  20  *
  21  * Revision 1.4  1995/02/17  17:06:16  adam
  22  * Minor changes.
  23  *
  24  * Revision 1.3  1995/02/16  18:35:09  adam
  25  * First use of Zdist library. Search requests are supported.
  26  * Present requests are not supported yet.
  27  *
  28  * Revision 1.2  1995/02/16  13:21:00  adam
  29  * Organization of resource files for targets and conversion
  30  * language implemented.
  31  *
  32  * Revision 1.1  1995/02/15  17:45:29  adam
  33  * First version of email gateway kernel. Email requests are read
  34  * from stdin. The output is transferred to an MTA if 'From' is
  35  * found in the header - or stdout if absent. No Z39.50 client is used.
  36  *
  37  */
  38
  39 #include <stdio.h>
  40 #include <stdlib.h>
  41 #include <string.h>
  42 #include <assert.h>
  43
  44 #include "kernel.h"
  45
  46 FILE *reply_fd = stdout;
  47
  48 struct gw_kernel_info info;
  49
  50 int main (int argc, char **argv)
  51 {
  52     info.kernel_res = NULL;
  53     info.default_res = "default.res";
  54     info.override_res = NULL;
  55     *info.target = 0;
  56     info.lang = NULL;
  57     info.bibset = NULL;
  58     info.zass = NULL;
  59     info.override_portno = NULL;
  60     info.override_hostname = NULL;
  61     info.databases = NULL;
  62 #if USE_FML
  63     info.fml = NULL;
  64 #endif
  65     info.sets = NULL;
  66
  67     gw_log_init (*argv);
  68     info.kernel_res = gw_res_init ();
  69     while (--argc > 0)
  70     {
  71         if (**++argv == '-')
  72         {
  73             switch (argv[0][1])
  74             {
  75             case 'd':
  76                 gw_log_level (GW_LOG_ALL);
  77                 break;
  78             case 't':
  79                 if (argv[0][2])
  80                     strcpy (info.target, argv[0]+2);
  81                 else if (argc > 0)
  82                 {
  83                     --argc;
  84                     strcpy (info.target, *++argv);
  85                 }
  86                 else
  87                 {
  88                     gw_log (GW_LOG_FATAL, "main", "missing target name");
  89                     exit (1);
  90                 }
  91                 break;
  92             case 'l':
  93                 if (argv[0][2])
  94                     info.lang = argv[0]+2;
  95                 else if (argc > 0)
  96                 {
  97                     --argc;
  98                     info.lang = *++argv;
  99                 }
 100                 else
 101                 {
 102                     gw_log (GW_LOG_FATAL, "main", "missing language name");
 103                     exit (1);
 104                 }
 105                 break;
 106             case 'o':
 107                 if (argv[0][2])
 108                     info.override_res = argv[0]+2;
 109                 else if (argc > 0)
 110                 {
 111                     --argc;
 112                     info.override_res = *++argv;
 113                 }
 114                 else
 115                 {
 116                     gw_log (GW_LOG_FATAL, "main", "missing language name");
 117                     exit (1);
 118                 }
 119                 break;
 120             case 'p':
 121                 if (argv[0][2])
 122                     info.override_portno = argv[0]+2;
 123                 else if (argc > 0)
 124                 {
 125                     --argc;
 126                     info.override_portno = *++argv;
 127                 }
 128                 else
 129                 {
 130                     gw_log (GW_LOG_FATAL, "main", "missing portno");
 131                     exit (1);
 132                 }
 133                 break;
 134             case 'h':
 135                 if (argv[0][2])
 136                     info.override_hostname = argv[0]+2;
 137                 else if (argc > 0)
 138                 {
 139                     --argc;
 140                     info.override_hostname = *++argv;
 141                 }
 142                 else
 143                 {
 144                     gw_log (GW_LOG_FATAL, "main", "missing hostname");
 145                     exit (1);
 146                 }
 147                 break;
 148             case 'g':
 149                 if (argv[0][2])
 150                     gw_log_file (GW_LOG_ALL, argv[0]+2);
 151                 else if (argc > 0)
 152                 {
 153                     --argc;
 154                     gw_log_file (GW_LOG_ALL, *++argv);
 155                 }
 156                 else
 157                 {
 158                     gw_log (GW_LOG_FATAL, "main", "missing log filename");
 159                     exit (1);
 160                 }
 161                 break;
 162             default:
 163                 gw_log (GW_LOG_FATAL, "main", "unknown option %s", *argv);
 164                 exit (1);
 165             }
 166         }
 167         else
 168             info.default_res = *argv;
 169     }
 170     read_kernel_res ();
 171     urp (stdin);
 172     return 0;
 173 }
 174
 175 struct gw_user_set *user_set_add (const char *name, int hits)
 176 {
 177     struct gw_user_set *s;
 178
 179     s = malloc (sizeof (*s));
 180     assert (s);
 181
 182     s->name = gw_strdup (name);
 183     s->hits = hits;
 184     s->prev = info.sets;
 185     info.sets = s;
 186     return s;
 187 }
 188
 189 void user_set_init (void)
 190 {
 191     struct gw_user_set *s, *s1;
 192
 193     for (s = info.sets; s; s = s1)
 194     {
 195         free (s->name);
 196         s1 = s->prev;
 197         free (s);
 198     }
 199     info.sets = NULL;
 200 }
 201
 202 struct gw_user_set *user_set_search (const char *name)
 203 {
 204     struct gw_user_set *s;
 205
 206     if (!name)
 207         return info.sets;
 208     for (s = info.sets; s; s = s->prev)
 209         if (!strcmp (s->name, name))
 210             return s;
 211     return NULL;
 212 }
 213
 214 #if USE_FML
 215 static void fml_inf_write (int ch)
 216 {
 217     putc (ch, reply_fd);
 218 }
 219 static FILE *fml_inf;
 220
 221 static int fml_inf_read (void)
 222 {
 223     return getc (fml_inf);
 224 }
 225 #endif
 226
 227 void read_kernel_res (void)
 228 {
 229     char path_prefix[128];
 230     char fname[160];
 231     const char *v;
 232     char *cp;
 233     char resource_name[256];
 234
 235     user_set_init ();
 236
 237     if (info.bibset)
 238         ccl_qual_rm (&info.bibset);
 239     info.bibset = ccl_qual_mk ();
 240
 241     if (info.kernel_res)
 242         gw_res_close (info.kernel_res);
 243     info.kernel_res = gw_res_init ();
 244
 245     gw_log (GW_LOG_DEBUG, "main", "reading kernel resource, default %s",
 246             info.default_res);
 247     if (*info.target)
 248         gw_log (GW_LOG_DEBUG, "main", "reading kernel resource, target %s",
 249                 info.target);
 250     if (info.lang)
 251         gw_log (GW_LOG_DEBUG, "main", "reading kernel resource, lang %s",
 252                 info.lang);
 253
 254     if (gw_res_merge (info.kernel_res, info.default_res))
 255     {
 256         gw_log (GW_LOG_WARN, "main", "Couldn't read resource file %s",
 257                 info.default_res);
 258         return;
 259     }
 260     strcpy (path_prefix, gw_res_get (info.kernel_res, "gw.path", "."));
 261
 262     if (*info.target)
 263     {
 264         sprintf (resource_name, "gw.target.%s", info.target);
 265         v = gw_res_get (info.kernel_res, resource_name, NULL);
 266         if (v)
 267         {
 268             sprintf (fname, "%s/%s", path_prefix, v);
 269             gw_res_merge (info.kernel_res, fname);
 270         }
 271     }
 272     if (info.lang)
 273     {
 274         sprintf (resource_name, "gw.lang.%s", info.lang);
 275         v = gw_res_get (info.kernel_res, resource_name, NULL);
 276         if (v)
 277         {
 278             sprintf (fname, "%s/%s", path_prefix, v);
 279             gw_res_merge (info.kernel_res, fname);
 280         }
 281     }
 282     if (info.override_res)
 283     {
 284         sprintf (fname, "%s/%s", path_prefix, info.override_res);
 285         gw_res_merge (info.kernel_res, fname);
 286     }
 287     v = gw_res_get (info.kernel_res, "gw.bibset", NULL);
 288     if (v)
 289     {
 290         FILE *bib_inf;
 291
 292         sprintf (fname, "%s/%s", path_prefix, v);
 293         bib_inf = fopen (fname, "r");
 294         if (!bib_inf)
 295             gw_log (GW_LOG_WARN, "main", "cannot open %s", fname);
 296         else
 297         {
 298             gw_log (GW_LOG_DEBUG, "main", "reading bib file %s", fname);
 299             ccl_qual_file (info.bibset, bib_inf);
 300             fclose (bib_inf);
 301         }
 302     }
 303     sprintf (resource_name, "gw.target.%s", info.target);
 304     if (*info.target && ! gw_res_get (info.kernel_res, resource_name, NULL))
 305     {
 306         /* target is there, and there is no sub-resource for it... */
 307         char *split;
 308
 309         if ((split = strchr (info.target, ':')))
 310             *split++ = '\0';
 311         strncpy (info.hostname, info.target, sizeof(info.hostname)-1);
 312         if (split)
 313             info.port = atoi (split);
 314         else
 315             info.port = atoi (gw_res_get
 316                               (info.kernel_res, "gw.portno", "210"));
 317     }
 318     else
 319     {
 320         strncpy (info.hostname, gw_res_get (info.kernel_res,
 321                                             "gw.hostname", "localhost"),
 322                  sizeof(info.hostname)-1);
 323         info.port = atoi (gw_res_get (info.kernel_res,
 324                                       "gw.portno", "210"));
 325     }
 326     if (info.databases)
 327         free (info.databases);
 328     v = gw_res_get (info.kernel_res, "gw.databases", "");
 329     info.databases = gw_strdup (v);
 330     for (cp = info.databases; (cp = strchr (cp, ' ')); cp++)
 331         *cp = ',';
 332     if (info.override_portno)
 333         info.port = atoi (info.override_portno);
 334     if (info.override_hostname)
 335         strncpy (info.hostname, info.override_hostname,
 336                  sizeof(info.hostname)-1);
 337 #if USE_FML
 338     if (!info.fml)
 339     {
 340         v = gw_res_get (info.kernel_res, "gw.fml", "default.fml");
 341         sprintf (fname, "%s/%s", path_prefix, v);
 342         fml_inf = fopen (fname, "r");
 343         if (!fml_inf)
 344             gw_log (GW_LOG_WARN, "main", "cannot open fml script %s", fname);
 345         else
 346         {
 347             info.fml = fml_open ();
 348             info.fml->read_func = fml_inf_read;
 349             info.fml->write_func = fml_inf_write;
 350             fml_preprocess (info.fml);
 351             fml_exec (info.fml);
 352             fclose (fml_inf);
 353         }
 354     }
 355 #endif
 356 }