* Europagate, 1995
*
* $Log: urp.c,v $
- * Revision 1.10 1995/02/22 08:51:35 adam
+ * Revision 1.13 1995/02/22 16:54:42 adam
+ * Qualifiers of LOC target updated. More logging messages.
+ *
+ * Revision 1.12 1995/02/22 15:51:51 adam
+ * Bug fix: swap of parameter number and offset in function present.
+ *
+ * Revision 1.11 1995/02/22 15:22:33 adam
+ * Much more checking of run-time state. Show command never retrieves
+ * more records than indicated by the previous search request. Help
+ * command available. The maximum number of records retrieved can be
+ * controlled now.
+ *
+ * Revision 1.10 1995/02/22 08:51:35 adam
* Output function can be customized in fml, which is used to print
* the reply to reply_fd.
*
#define LINE_MAX 256
+static void put_esc_str (const char *s)
+{
+ int escape_flag = 0;
+ while (*s)
+ {
+ if (*s == '\\' && s[1])
+ {
+ switch (*++s)
+ {
+ case 'n':
+ fputc ('\n', reply_fd);
+ break;
+ case 't':
+ fputc ('\t', reply_fd);
+ break;
+ default:
+ fputc (*s, reply_fd);
+ break;
+ }
+ escape_flag = 1;
+ }
+ else
+ {
+ if (*s != ' ' || !escape_flag)
+ fputc (*s, reply_fd);
+ escape_flag = 0;
+ }
+ s++;
+ }
+}
+
static int reopen_target (void)
{
const char *v;
return 1;
}
+static void help_general (void)
+{
+ put_esc_str (gw_res_get (info.kernel_res, "gw.help.general",
+ "Commands available in this service:\n"));
+}
+
+static int exec_help (struct ccl_token *list)
+{
+ help_general ();
+
+#if 0
+ put_esc_str (gw_res_get (info.kernel_res, "gw.help.target",
+ "target <name> - selects a given target\n"));
+
+ put_esc_str (gw_res_get (info.kernel_res, "gw.help.base",
+ "base <base>.. - selects databases\n"));
+
+ put_esc_str (gw_res_get (info.kernel_res, "gw.help.find",
+ "find <query> - performs a search request\n"));
+
+ put_esc_str (gw_res_get (info.kernel_res, "gw.help.show",
+ "show <spec> - retrieves and displays "
+ "records\n"));
+ put_esc_str (gw_res_get (info.kernel_res, "gw.help.help",
+ "help - displays help\n"));
+#endif
+ return 0;
+}
+
static int exec_find (struct ccl_token *list)
{
const struct zass_searchent *p;
+ struct gw_user_set *us;
struct ccl_rpn_node *rpn;
int error;
const char *pos;
+ us = user_set_add ("Default", -1);
rpn = ccl_find (info.bibset, list, &error, &pos);
if (!rpn)
{
ccl_pr_tree (rpn, reply_fd);
fprintf (reply_fd, "\n");
- if (!info.zass)
- return -2;
if (!*info.databases)
{
fprintf (reply_fd, "%s\n",
}
gw_log (GW_LOG_DEBUG, "urp", "Searching in database %s",
info.databases);
+ assert (info.zass);
p = zass_search (info.zass, rpn, "Default", info.databases);
if (!p)
return -1;
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);
- else
- fprintf (reply_fd, "%d %s\n", p->num,
- gw_res_get (info.kernel_res, "gw.msg.hits", "hit(s)"));
+ return -2;
+ }
+ fprintf (reply_fd, "%d %s\n", p->num,
+ gw_res_get (info.kernel_res, "gw.msg.hits", "hit(s)"));
+ us->hits = p->num;
return 0;
}
struct ccl_token *li = list;
int len = 0;
+ assert (info.zass);
if (list->kind == CCL_TOK_EOL)
return -1;
free (info.databases);
{ NULL, NULL }
};
-static int exec_show (struct ccl_token *list)
+static void present (const char *set, int offset, int number,
+ struct ccl_token *format_token)
{
const struct zass_presentent *zp;
- char num_str[20];
+ int len;
+ int max_number;
+ char format_str[40];
+
+ max_number = atoi (gw_res_get (info.kernel_res, "gw.max.show",
+ "200"));
+ if (number > max_number)
+ number = max_number;
+ gw_log (GW_LOG_DEBUG, "urp", "present in set %s", set);
+ gw_log (GW_LOG_DEBUG, "urp", "present of %d records from offset %d",
+ number, offset);
+ zp = zass_present(info.zass, (char *) set, offset, number);
+ if (zp)
+ {
+ int i;
+ zass_record *pp;
+
+ fprintf (reply_fd, gw_res_get (info.kernel_res,
+ "gw.msg.records",
+ "Got %d records"),
+ zp->num);
+ fprintf (reply_fd, "\n");
+ for (i = 0, pp = zp->records; pp; pp = pp->next, i++)
+ {
+ Iso2709Rec rec;
+#if USE_FML
+ const char *arg_ar[5];
+#endif
+ fprintf (reply_fd, "--- %d/%d ---\n",
+ i+offset, offset+zp->num-1);
+ if (!gw_res_get (info.kernel_res, "gw.ignore.which", NULL))
+ {
+ if (pp->which == ZASS_REC_DIAG)
+ {
+ fprintf (reply_fd, "Record error %d: %s\n",
+ pp->errcode, pp->errstring);
+ continue;
+ }
+ else if (pp->which != ZASS_REC_USMARC)
+ {
+ fprintf (reply_fd, "Unknown record kind %d\n",
+ pp->which);
+ continue;
+ }
+ }
+ rec = iso2709_cvt (pp->record);
+ if (rec)
+ {
+#if USE_FML
+ if (format_token)
+ {
+ len = format_token->len;
+ memcpy (format_str, format_token->name, len);
+ format_str[len] = '\0';
+ }
+ if (info.fml && format_token &&
+ (!strcmp (format_str, "0") || !strcmp (format_str, "1")))
+ {
+ arg_ar[0] = "\\f";
+ arg_ar[1] = format_str;
+ arg_ar[2] = " \\list";
+ arg_ar[3] = marc_to_str (info.fml, rec);
+ arg_ar[4] = NULL;
+ fml_exec_call_argv (info.fml, arg_ar);
+ }
+ else
+ iso2709_display (rec, reply_fd);
+#else
+ iso2709_display (rec, reply_fd);
+#endif
+ iso2709_rm (rec);
+ }
+ else
+ fprintf (reply_fd, "Not a MARC record\n");
+ }
+ }
+}
+
+static int exec_show (struct ccl_token *list)
+{
+ char tmp_str[20];
struct ccl_token *set_token = NULL;
struct ccl_token *format_token = NULL;
struct ccl_token *li = list;
+ int no_of_present = 0;
- if (list->kind == CCL_TOK_EOL)
- return -1;
- if (!info.zass)
- return -2;
+ assert (info.zass);
while (li->kind != CCL_TOK_EOL)
{
int modifier_no = 0;
&& li->next->next != CCL_TOK_EOL)
{
len = li->len;
- memcpy (num_str, li->name, len);
- num_str [len] = '\0';
- offset = atoi (num_str);
+ memcpy (tmp_str, li->name, len);
+ tmp_str [len] = '\0';
+ offset = atoi (tmp_str);
li = li->next->next;
len = li->len;
- memcpy (num_str, li->name, len);
- num_str [len] = '\0';
- number = atoi (num_str) - offset + 1;
+ memcpy (tmp_str, li->name, len);
+ tmp_str [len] = '\0';
+ number = atoi (tmp_str) - offset + 1;
}
else
{
len = li->len;
- memcpy (num_str, li->name, len);
- num_str [len] = '\0';
- offset = atoi (num_str);
+ memcpy (tmp_str, li->name, len);
+ tmp_str [len] = '\0';
+ offset = atoi (tmp_str);
number = 1;
}
}
else
{
len = li->len;
- memcpy (num_str, li->name, len);
- num_str[len] = '\0';
- number = atoi (num_str);
+ memcpy (tmp_str, li->name, len);
+ tmp_str[len] = '\0';
+ number = atoi (tmp_str);
offset = 1;
li = li->next;
}
if (offset > 0 && number > 0)
{
+ struct gw_user_set *us;
+
if (set_token)
{
len = set_token->len;
- memcpy (num_str, set_token->name, len);
- num_str[len] = '\0';
+ memcpy (tmp_str, set_token->name, len);
+ tmp_str[len] = '\0';
+ us = user_set_search (tmp_str);
}
else
- strcpy (num_str, "Default");
- gw_log (GW_LOG_DEBUG, "urp", "zass_present of %d records from"
- " offset %d in set %s", number, offset, num_str);
- zp = zass_present(info.zass, num_str, offset, number);
- if (zp)
+ us = user_set_search (NULL);
+ if (us && us->hits != -1) /* proper result-set? */
{
- int i;
- zass_record *pp;
-
- fprintf (reply_fd, gw_res_get (info.kernel_res,
- "gw.msg.records",
- "Got %d records"),
- zp->num);
- fprintf (reply_fd, "\n");
- for (i = 0, pp = zp->records; pp; pp = pp->next, i++)
+ if (offset <= us->hits)
{
- Iso2709Rec rec;
-#if USE_FML
- const char *arg_ar[5];
-#endif
- fprintf (reply_fd, "--- %d/%d ---\n",
- i+offset, offset+zp->num-1);
-#if 0
- if (pp->which == ZASS_REC_DIAG)
- {
- fprintf (reply_fd, "Record error %d: %s\n",
- pp->errcode, pp->errstring);
- continue;
- }
- else if (pp->which != ZASS_REC_USMARC)
- {
- fprintf (reply_fd, "Unknown record kind %d\n",
- pp->which);
- continue;
- }
-#endif
- rec = iso2709_cvt (pp->record);
-#if USE_FML
- if (format_token)
- {
- len = format_token->len;
- memcpy (num_str, format_token->name, len);
- num_str[len] = '\0';
- }
- if (format_token &&
- (!strcmp (num_str, "0") || !strcmp (num_str, "1")))
- {
- arg_ar[0] = "\\f";
- arg_ar[1] = num_str;
- arg_ar[2] = " \\list";
- arg_ar[3] = marc_to_str (info.fml, rec);
- arg_ar[4] = NULL;
- fml_exec_call_argv (info.fml, arg_ar);
- }
- else
- iso2709_display (rec, reply_fd);
-#else
- iso2709_display (rec, reply_fd);
-#endif
- iso2709_rm (rec);
+ if (offset+number-1 > us->hits)
+ number = us->hits - offset+1;
+ present (us->name, offset, number, format_token);
}
}
+ else if (!no_of_present) /* display error message once! */
+ {
+ fprintf (reply_fd, "%s\n",
+ gw_res_get (info.kernel_res, "gw.err.no.set",
+ "No result-set generated"));
+ }
+ no_of_present++;
}
}
-#if 0
- len = list->len;
- memcpy (num_str, list->name, len);
- num_str[len] = '\0';
-
- num = atoi (num_str);
- if (!num)
- return -3;
- gw_log (GW_LOG_DEBUG, "urp", "zass_present of %d records", num);
- zp = zass_present(info.zass, "Default", 1, num);
- if (zp)
+ if (!no_of_present) /* no records shown so far? */
{
- int i;
- zass_record *pp;
-
- fprintf (reply_fd, gw_res_get (info.kernel_res,
- "gw.msg.records", "Got %d records"),
- zp->num);
- fprintf (reply_fd, "\n");
- for (i = 1, pp = zp->records; pp; pp = pp->next, i++)
- {
-#if USE_FML
- const char *arg_ar[3];
-#endif
- Iso2709Rec rec = iso2709_cvt (pp->record);
-
- fprintf (reply_fd, "--- %d/%d ---\n", i, zp->num);
-#if USE_FML
- arg_ar[0] = "\\f0 \\list";
- arg_ar[1] = marc_to_str (info.fml, rec);
- arg_ar[2] = NULL;
- fml_exec_call_argv (info.fml, arg_ar);
-#else
- iso2709_display (rec, reply_fd);
-#endif
- iso2709_rm (rec);
- }
+ struct gw_user_set *us;
+ int default_show;
+
+ us = user_set_search (NULL);
+ if (us && us->hits != -1) /* proper result-set? */
+ {
+ default_show = atoi (gw_res_get (info.kernel_res,
+ "gw.default.show", "20"));
+ if (us->hits > default_show)
+ present (us->name, 1, default_show, format_token);
+ else if (us->hits > 0)
+ present (us->name, 1, us->hits, format_token);
+ }
+ else /* display error message */
+ {
+ fprintf (reply_fd, "%s\n",
+ gw_res_get (info.kernel_res, "gw.err.no.set",
+ "No result-set generated"));
+ return -3;
+ }
}
-#endif
return 0;
}
if (cmd->kind != CCL_TOK_EOL &&
(no = command_search (command_tab, cmd, "ccl.command.")))
{
- if (!info.zass && no != 9)
+ if (!info.zass && no != 9 && no != 4)
reopen_target ();
fprintf (reply_fd, "\n> %s", str);
+ if (!info.zass && (no == 1 || no == 2 || no == 3))
+ {
+ fprintf (reply_fd, "%s\n",
+ gw_res_get (info.kernel_res, "gw.err.no.target",
+ "No connection established - "
+ "command ignored"));
+ return 0;
+ }
switch (no)
{
case 1:
return exec_show (cmd->next);
case 3:
return exec_base (cmd->next);
+ case 4:
+ return exec_help (cmd->next);
case 9:
return exec_target (cmd->next);
default:
fprintf (reply_fd, "\n> %s", str);
fprintf (reply_fd, " ^ %s\n",
gw_res_get (info.kernel_res, "gw.err.unknown.command",
- "unknown command"));
+ "unknown command. "
+ "Use help to see list of commands"));
}
return 0;
}
"gw.msg.subject",
"Your Query"));
fprintf (reply_fd, "\n");
+ gw_log (GW_LOG_DEBUG, "urp", "Mail from %s", from_str);
}
else
gw_log (GW_LOG_WARN, "urp", "No From in email header");
command_no++;
}
if (!command_no)
+ {
fprintf (reply_fd, "%s\n", gw_res_get (info.kernel_res,
"gw.err.nullbody",
"No body"));
+ help_general ();
+ }
if (*from_str)
{
const char *mta;
gw_log (GW_LOG_FATAL, "urp", "Reply '%s' got exit code %d",
cmd, mta_code);
unlink (reply_fname);
+ gw_log (GW_LOG_DEBUG, "urp", "Normal session end of %s", from_str);
}
return 0;
}