kernel/main.c

   1 /* Gateway kernel
   2  * Europagate, 1995
   3  *
   4  * $Log: main.c,v $
   5  * Revision 1.5  1995/02/20 21:16:20  adam
   6  * FML support. Bug fixes. Profile for drewdb.
   7  *
   8  * Revision 1.4  1995/02/17  17:06:16  adam
   9  * Minor changes.
  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:29  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 <string.h>
  29 #include <assert.h>
  30
  31 #include "kernel.h"
  32
  33 FILE *reply_fd = stdout;
  34
  35 struct gw_kernel_info info;
  36
  37 int main (int argc, char **argv)
  38 {
  39     info.kernel_res = NULL;
  40     info.default_res = "default.res";
  41     info.override_res = NULL;
  42     *info.target = 0;
  43     info.lang = NULL;
  44     info.bibset = NULL;
  45     info.zass = NULL;
  46     info.override_portno = NULL;
  47     info.override_hostname = NULL;
  48     info.databases = NULL;
  49 #if USE_FML
  50     info.fml = NULL;
  51 #endif
  52
  53     gw_log_init (*argv);
  54     info.kernel_res = gw_res_init ();
  55     while (--argc > 0)
  56     {
  57         if (**++argv == '-')
  58         {
  59             switch (argv[0][1])
  60             {
  61             case 'd':
  62                 gw_log_level (GW_LOG_ALL);
  63                 break;
  64             case 't':
  65                 if (argv[0][2])
  66                     strcpy (info.target, argv[0]+2);
  67                 else if (argc > 0)
  68                 {
  69                     --argc;
  70                     strcpy (info.target, *++argv);
  71                 }
  72                 else
  73                 {
  74                     gw_log (GW_LOG_FATAL, "main", "missing target name");
  75                     exit (1);
  76                 }
  77                 break;
  78             case 'l':
  79                 if (argv[0][2])
  80                     info.lang = argv[0]+2;
  81                 else if (argc > 0)
  82                 {
  83                     --argc;
  84                     info.lang = *++argv;
  85                 }
  86                 else
  87                 {
  88                     gw_log (GW_LOG_FATAL, "main", "missing language name");
  89                     exit (1);
  90                 }
  91                 break;
  92             case 'o':
  93                 if (argv[0][2])
  94                     info.override_res = argv[0]+2;
  95                 else if (argc > 0)
  96                 {
  97                     --argc;
  98                     info.override_res = *++argv;
  99                 }
 100                 else
 101                 {
 102                     gw_log (GW_LOG_FATAL, "main", "missing language name");
 103                     exit (1);
 104                 }
 105                 break;
 106             case 'p':
 107                 if (argv[0][2])
 108                     info.override_portno = argv[0]+2;
 109                 else if (argc > 0)
 110                 {
 111                     --argc;
 112                     info.override_portno = *++argv;
 113                 }
 114                 else
 115                 {
 116                     gw_log (GW_LOG_FATAL, "main", "missing portno");
 117                     exit (1);
 118                 }
 119                 break;
 120             case 'h':
 121                 if (argv[0][2])
 122                     info.override_hostname = argv[0]+2;
 123                 else if (argc > 0)
 124                 {
 125                     --argc;
 126                     info.override_hostname = *++argv;
 127                 }
 128                 else
 129                 {
 130                     gw_log (GW_LOG_FATAL, "main", "missing hostname");
 131                     exit (1);
 132                 }
 133                 break;
 134             case 'g':
 135                 if (argv[0][2])
 136                     gw_log_file (GW_LOG_ALL, argv[0]+2);
 137                 else if (argc > 0)
 138                 {
 139                     --argc;
 140                     gw_log_file (GW_LOG_ALL, *++argv);
 141                 }
 142                 else
 143                 {
 144                     gw_log (GW_LOG_FATAL, "main", "missing log filename");
 145                     exit (1);
 146                 }
 147                 break;
 148             default:
 149                 gw_log (GW_LOG_FATAL, "main", "unknown option %s", *argv);
 150                 exit (1);
 151             }
 152         }
 153         else
 154             info.default_res = *argv;
 155     }
 156     read_kernel_res ();
 157     urp (stdin);
 158     return 0;
 159 }
 160 #if USE_FML
 161 static FILE *fml_inf;
 162
 163 static int fml_inf_read (void)
 164 {
 165     return getc (fml_inf);
 166 }
 167 #endif
 168
 169 void read_kernel_res (void)
 170 {
 171     char path_prefix[128];
 172     char fname[160];
 173     const char *v;
 174     char *cp;
 175     char resource_name[256];
 176
 177     if (info.bibset)
 178         ccl_qual_rm (&info.bibset);
 179     info.bibset = ccl_qual_mk ();
 180
 181     if (info.kernel_res)
 182         gw_res_close (info.kernel_res);
 183     info.kernel_res = gw_res_init ();
 184
 185     gw_log (GW_LOG_DEBUG, "main", "reading kernel resource, default %s",
 186             info.default_res);
 187     if (*info.target)
 188         gw_log (GW_LOG_DEBUG, "main", "reading kernel resource, target %s",
 189                 info.target);
 190     if (info.lang)
 191         gw_log (GW_LOG_DEBUG, "main", "reading kernel resource, lang %s",
 192                 info.lang);
 193
 194     if (gw_res_merge (info.kernel_res, info.default_res))
 195     {
 196         gw_log (GW_LOG_WARN, "main", "Couldn't read resource file %s",
 197                 info.default_res);
 198         return;
 199     }
 200     strcpy (path_prefix, gw_res_get (info.kernel_res, "gw.path", "."));
 201
 202     if (*info.target)
 203     {
 204         sprintf (resource_name, "gw.target.%s", info.target);
 205         v = gw_res_get (info.kernel_res, resource_name, NULL);
 206         if (v)
 207         {
 208             sprintf (fname, "%s/%s", path_prefix, v);
 209             gw_res_merge (info.kernel_res, fname);
 210         }
 211     }
 212     if (info.lang)
 213     {
 214         sprintf (resource_name, "gw.lang.%s", info.lang);
 215         v = gw_res_get (info.kernel_res, resource_name, NULL);
 216         if (v)
 217         {
 218             sprintf (fname, "%s/%s", path_prefix, v);
 219             gw_res_merge (info.kernel_res, fname);
 220         }
 221     }
 222     if (info.override_res)
 223     {
 224         sprintf (fname, "%s/%s", path_prefix, info.override_res);
 225         gw_res_merge (info.kernel_res, fname);
 226     }
 227     v = gw_res_get (info.kernel_res, "gw.bibset", NULL);
 228     if (v)
 229     {
 230         FILE *bib_inf;
 231
 232         sprintf (fname, "%s/%s", path_prefix, v);
 233         bib_inf = fopen (fname, "r");
 234         if (!bib_inf)
 235             gw_log (GW_LOG_WARN, "main", "cannot open %s", fname);
 236         else
 237         {
 238             gw_log (GW_LOG_DEBUG, "main", "reading bib file %s", fname);
 239             ccl_qual_file (info.bibset, bib_inf);
 240             fclose (bib_inf);
 241         }
 242     }
 243     sprintf (resource_name, "gw.target.%s", info.target);
 244     if (*info.target && ! gw_res_get (info.kernel_res, resource_name, NULL))
 245     {
 246         /* target is there, and there is no sub-resource for it... */
 247         char *split;
 248
 249         if ((split = strchr (info.target, ':')))
 250             *split++ = '\0';
 251         strncpy (info.hostname, info.target, sizeof(info.hostname)-1);
 252         if (split)
 253             info.port = atoi (split);
 254         else
 255             info.port = atoi (gw_res_get
 256                               (info.kernel_res, "gw.portno", "210"));
 257     }
 258     else
 259     {
 260         strncpy (info.hostname, gw_res_get (info.kernel_res,
 261                                             "gw.hostname", "localhost"),
 262                  sizeof(info.hostname)-1);
 263         info.port = atoi (gw_res_get (info.kernel_res,
 264                                       "gw.portno", "210"));
 265     }
 266     if (info.databases)
 267         free (info.databases);
 268     v = gw_res_get (info.kernel_res, "gw.databases", "");
 269     info.databases = malloc (1+strlen(v));
 270     assert (info.databases);
 271     strcpy (info.databases, v);
 272     for (cp = info.databases; (cp = strchr (cp, ' ')); cp++)
 273         *cp = ',';
 274     if (info.override_portno)
 275         info.port = atoi (info.override_portno);
 276     if (info.override_hostname)
 277         strncpy (info.hostname, info.override_hostname,
 278                  sizeof(info.hostname)-1);
 279 #if USE_FML
 280     if (!info.fml)
 281     {
 282         v = gw_res_get (info.kernel_res, "gw.fml", "default.fml");
 283         sprintf (fname, "%s/%s", path_prefix, v);
 284         fml_inf = fopen (fname, "r");
 285         if (!fml_inf)
 286             gw_log (GW_LOG_WARN, "main", "cannot open fml script %s", fname);
 287         else
 288         {
 289             info.fml = fml_open ();
 290             info.fml->read_func = fml_inf_read;
 291             fml_preprocess (info.fml);
 292             fml_exec (info.fml);
 293             fclose (fml_inf);
 294         }
 295     }
 296 #endif
 297 }