* Europagate, 1995
*
* $Log: urp.c,v $
- * Revision 1.1 1995/02/15 17:45:30 adam
+ * Revision 1.3 1995/02/16 18:35:09 adam
+ * First use of Zdist library. Search requests are supported.
+ * Present requests are not supported yet.
+ *
+ * Revision 1.2 1995/02/16 13:21:00 adam
+ * Organization of resource files for targets and conversion
+ * language implemented.
+ *
+ * Revision 1.1 1995/02/15 17:45:30 adam
* First version of email gateway kernel. Email requests are read
* from stdin. The output is transferred to an MTA if 'From' is
* found in the header - or stdout if absent. No Z39.50 client is used.
#define LINE_MAX 256
+static int reopen_target (void)
+{
+ const char *v;
+ if (info.zass)
+ gw_log (GW_LOG_WARN, "urp", "Zass free...");
+ info.zass = zass_open (info.hostname, info.port);
+ if (!info.zass)
+ {
+ fprintf (reply_fd, "%s %s:%d\n",
+ gw_res_get (info.kernel_res, "gw.err.connect",
+ "Cannot connect to target"),
+ info.hostname, info.port);
+ return -1;
+ }
+ v = gw_res_get (info.kernel_res, "gw.description", NULL);
+ if (v)
+ fprintf (reply_fd, "%s\n", v);
+ fprintf (reply_fd, "%s %s:%d\n %s\n",
+ gw_res_get (info.kernel_res, "gw.msg.databases",
+ "Available databases on"),
+ info.hostname, info.port, info.databases);
+ return 0;
+}
+
static char line_buf[LINE_MAX+1];
static struct command_word {
{ "continue", "continue" },
{ "status", "status" },
{ "cancel", "cancel" },
+{ "target", "target" },
{ NULL, NULL }
};
sprintf (resource_name, "%s%s", resource_prefix,
tab->resource_suffix);
- v = gw_res_get (kernel_res, resource_name, tab->default_value);
+ v = gw_res_get (info.kernel_res, resource_name, tab->default_value);
assert (v);
strcpy (command_names, v);
cp = command_names;
return 0;
}
+static struct error_no_struct {
+ int no;
+ char *resource_name;
+} error_ccl_tab[] = {
+{ CCL_ERR_OK, "ok"},
+{ CCL_ERR_TERM_EXPECTED, "term.expected" },
+{ CCL_ERR_RP_EXPECTED, "rp.expected" },
+{ CCL_ERR_SETNAME_EXPECTED, "setname.expected" },
+{ CCL_ERR_OP_EXPECTED, "op.expected" },
+{ CCL_ERR_BAD_RP, "bad.rp" },
+{ CCL_ERR_UNKNOWN_QUAL, "unknown.qual" },
+{ CCL_ERR_DOUBLE_QUAL, "double.qual" },
+{ CCL_ERR_EQ_EXPECTED, "eq.expected" },
+{ CCL_ERR_BAD_RELATION, "bad.relation" },
+{ CCL_ERR_TRUNC_NOT_LEFT, "trunc.not.left" },
+{ CCL_ERR_TRUNC_NOT_BOTH, "trunc.not.both" },
+{ CCL_ERR_TRUNC_NOT_RIGHT, "trunc.not.right" },
+{ 0, NULL }
+};
+
+static char *error_no_search (struct error_no_struct *tab, int no)
+{
+ struct error_no_struct *p = tab;
+ while (p->resource_name)
+ {
+ if (no == p->no)
+ return p->resource_name;
+ p++;
+ }
+ return NULL;
+}
+
static int email_header (FILE *inf, char *from_str)
{
*from_str = '\0';
static int exec_find (struct ccl_token *list)
{
+ const struct zass_searchent *p;
+
struct ccl_rpn_node *rpn;
int error;
const char *pos;
- rpn = ccl_find (bibset, list, &error, &pos);
+ rpn = ccl_find (info.bibset, list, &error, &pos);
if (!rpn)
{
- fprintf (reply_fd, " %*s^ - ", pos - line_buf, " ");
- fprintf (reply_fd, "%s\n", ccl_err_msg (error));
+ const char *v = NULL, *n;
+ char name[128];
+
+ fprintf (reply_fd, " %*s^ - ", pos - line_buf, " ");
+
+ n = error_no_search (error_ccl_tab, error);
+ if (n)
+ {
+ sprintf (name, "gw.err.%s", n);
+ v = gw_res_get (info.kernel_res, name, NULL);
+ }
+ if (!v)
+ v = ccl_err_msg (error);
+ fprintf (reply_fd, "%s\n", v);
return -1;
}
ccl_pr_tree (rpn, reply_fd);
fprintf (reply_fd, "\n");
+
+ if (!info.zass)
+ return -2;
+ p = zass_search (info.zass, rpn, "Default", info.databases);
+ if (!p)
+ return -1;
+ fprintf (reply_fd, "%d %s\n", p->num,
+ gw_res_get (info.kernel_res, "gw.msg.hits", "hit(s)"));
+ if (p->errcode != -1)
+ fprintf (reply_fd, "%s %d: %s\n",
+ gw_res_get (info.kernel_res, "gw.msg.z39errcode",
+ "Z39.50 error code"),
+ p->errcode, p->errstring);
return 0;
}
+static int exec_target (struct ccl_token *list)
+{
+ if (list->kind == CCL_TOK_EOL)
+ return -1;
+ memcpy (info.target, list->name, list->len);
+ info.target [list->len] = '\0';
+
+ read_kernel_res ();
+ return reopen_target ();
+}
+
static int exec_command (const char *str)
{
struct ccl_token *cmd = ccl_tokenize (str);
int no;
- ccl_token_and = gw_res_get (kernel_res, "ccl.token.and", "and");
- ccl_token_or = gw_res_get (kernel_res, "ccl.token.or", "or");
- ccl_token_not = gw_res_get (kernel_res, "ccl.token.not", "not");
- ccl_token_set = gw_res_get (kernel_res, "ccl.token.set", "set");
-
- fprintf (reply_fd, "> %s", str);
- if (cmd->kind == CCL_TOK_TERM &&
+ if (cmd->kind != CCL_TOK_EOL &&
(no = command_search (command_tab, cmd, "ccl.command.")))
{
+ if (!info.zass && no != 9)
+ reopen_target ();
+ fprintf (reply_fd, "\n> %s", str);
switch (no)
{
case 1:
return exec_find (cmd->next);
break;
- case 2:
- fprintf (reply_fd, " show found\n");
+ case 9:
+ return exec_target (cmd->next);
break;
default:
- fprintf (reply_fd, " unimplemented command\n");
+ fprintf (reply_fd, "%s\n",
+ gw_res_get (info.kernel_res, "gw.err.unimplemented",
+ "Not implemented yet"));
}
}
else
- fprintf (reply_fd, " ^ unknown command\n");
+ {
+ fprintf (reply_fd, " ^ %s\n",
+ gw_res_get (info.kernel_res, "gw.err.unknown.command",
+ "unknown command"));
+ }
return 0;
}
}
if (*from_str)
{
- reply_fname = tempnam (gw_res_get (kernel_res,
+ reply_fname = tempnam (gw_res_get (info.kernel_res,
"gw.reply.tmp.dir", NULL),
- gw_res_get (kernel_res,
+ gw_res_get (info.kernel_res,
"gw.reply.tmp.prefix", "gwr"));
reply_fd = fopen (reply_fname, "w");
return -1;
}
}
- fprintf (reply_fd, "%s\n", gw_res_get (kernel_res, "gw.msg.greeting",
+ else
+ gw_log (GW_LOG_WARN, "urp", "No From in email header");
+ fprintf (reply_fd, "%s\n", gw_res_get (info.kernel_res, "gw.msg.greeting",
"Email->Z39.50 gateway"));
while (fgets (line_buf, LINE_MAX, inf))
{
if (line_buf[0] == '\n')
break;
+ ccl_token_and = gw_res_get (info.kernel_res, "ccl.token.and", "and");
+ ccl_token_or = gw_res_get (info.kernel_res, "ccl.token.or", "or");
+ ccl_token_not = gw_res_get (info.kernel_res, "ccl.token.not", "not");
+ ccl_token_set = gw_res_get (info.kernel_res, "ccl.token.set", "set");
if (isalpha (line_buf[0]))
exec_command (line_buf);
command_no++;
}
if (!command_no)
- fprintf (reply_fd, "%s\n", gw_res_get (kernel_res, "gw.err.nullbody",
+ fprintf (reply_fd, "%s\n", gw_res_get (info.kernel_res,
+ "gw.err.nullbody",
"No body"));
if (*from_str)
{
fclose (reply_fd);
reply_fd = stdout;
- mta = gw_res_get (kernel_res, "gw.reply.mta", "/usr/lib/sendmail");
+ mta = gw_res_get (info.kernel_res, "gw.reply.mta",
+ "/usr/lib/sendmail");
sprintf (cmd, "%s %s < %s", mta, from_str, reply_fname);
mta_code = system (cmd);
projects / egate.git / blobdiff