Timeout (idletime) adjustable. Minor changes in kernel.

[egate.git] / kernel / urp.c

diff --git a/kernel/urp.c b/kernel/urp.c
index 1197a6c..aaba374 100644 (file)
--- a/kernel/urp.c
+++ b/kernel/urp.c
@@ -1,8 +1,11 @@
-/* Gateway kernel
+/* Gateway kernel - User Request Processor
  * Europagate, 1995
  *
  * $Log: urp.c,v $
- * Revision 1.24  1995/03/28 11:42:35  adam
+ * Revision 1.25  1995/04/17 09:34:33  adam
+ * Timeout (idletime) adjustable. Minor changes in kernel.
+ *
+ * Revision 1.24  1995/03/28  11:42:35  adam
  * First use of string-queue utility.
  *
  * Revision 1.23  1995/03/28  08:01:28  adam
@@ -91,10 +94,10 @@
 #include <unistd.h>
 #include <fcntl.h>
 
+#include <ttyemit.h>
 #include <strqueue.h>
 #include "kernel.h"
 
-#define LINE_MAX 1024
 static char line_buf[LINE_MAX+1];
 
 static void put_esc_str (const char *s)
@@ -734,32 +737,31 @@ static int exec_command (const char *str)
     return 0;
 }
 
-int urp (struct str_queue *queue)
+int urp_start (int continuation, struct str_queue *queue)
 {
-    char from_str[128];
     char subject_str[128];
-    int command_no = 0;
-    char *reply_fname = NULL;
-    char *cp;
 
-    if (email_header (queue, from_str, subject_str))
+    info.command_no = 0;
+    info.reply_fname = NULL;
+
+    if (email_header (queue, info.from_str, subject_str))
     {
         gw_log (GW_LOG_WARN, KERNEL_LOG, "No message body");
         return -1;
     }
     tty_init (stdout, 40, 70);
-    if (*from_str)
+    if (*info.from_str)
     {
-        reply_fname = tempnam (gw_res_get (info.kernel_res,
+        info.reply_fname = tempnam (gw_res_get (info.kernel_res,
                                            "gw.reply.tmp.dir", NULL),
                                gw_res_get (info.kernel_res,
                                            "gw.reply.tmp.prefix", "gwr"));
                                                  
-        reply_fd = fopen (reply_fname, "w");
+        reply_fd = fopen (info.reply_fname, "w");
         if (!reply_fd)
         {
             gw_log (GW_LOG_FATAL|GW_LOG_ERRNO, KERNEL_LOG, "Cannot create %s",
-                    reply_fname);
+                    info.reply_fname);
             return -1;
         }
         tty_init (reply_fd, 0, 0);
@@ -773,16 +775,31 @@ int urp (struct str_queue *queue)
                                                    "gw.msg.subject",
                                                    "Your Query"));
         fprintf (reply_fd, "\n");
-        gw_log (GW_LOG_ACCT, KERNEL_LOG, "User start %s", from_str);
+        gw_log (GW_LOG_ACCT, KERNEL_LOG, "User start %s", info.from_str);
     }
     else
         gw_log (GW_LOG_WARN, KERNEL_LOG, "No From in email header");
     fprintf (reply_fd, "%s\n", gw_res_get (info.kernel_res, "gw.msg.greeting",
                                            "Email->Z39.50 gateway"));
+    if (continuation)
+        fprintf (reply_fd, "%s\n", gw_res_get (info.kernel_res,
+                                              "gw.msg.cont",
+                                              "Continued..."));
+    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");
+    return 0;
+}
+
+int urp_command (struct str_queue *queue)
+{
+    char *cp;
+
     while (str_queue_deq (queue, line_buf, LINE_MAX))
     {
         if (line_buf[0] == '\n')
-            if (command_no)
+            if (info.command_no)
            {
                while (str_queue_deq (queue, 0, 0))
                    ;
@@ -793,41 +810,42 @@ int urp (struct str_queue *queue)
         if ((cp = strchr (line_buf, '\n')))
             *cp = '\0';
         gw_log (GW_LOG_ACCT, KERNEL_LOG, "cmd: %s", line_buf);
-        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++;
+        info.command_no++;
     }
-    if (!command_no)
+    return 0;
+}
+
+void urp_end (void)
+{
+    if (!info.command_no)
     {
-        fprintf (reply_fd, "%s\n", gw_res_get (info.kernel_res,
-                                               "gw.err.nullbody",
-                                               "No body"));
+        fprintf (reply_fd, "%s\n", 
+                gw_res_get (info.kernel_res, "gw.err.nullbody", "No body"));
         help_general ();
     }
-    if (*from_str)
+    if (*info.from_str)
     {
         const char *mta;
         char cmd[256];
         int mta_code;
 
-        assert (reply_fname);
+        assert (info.reply_fname);
         fclose (reply_fd);
         reply_fd = stdout;
 
         mta = gw_res_get (info.kernel_res, "gw.reply.mta",
-                          "/usr/lib/sendmail");
-        sprintf (cmd, "%s %s < %s", mta, from_str, reply_fname);
+                         "/usr/lib/sendmail");
+        sprintf (cmd, "%s %s < %s", mta, info.from_str, info.reply_fname);
         
         mta_code = system (cmd);
         if (mta_code)
             gw_log (GW_LOG_FATAL, KERNEL_LOG,
                     "Reply '%s' got exit code %d", cmd, mta_code);
-        unlink (reply_fname);        
-        gw_log (GW_LOG_ACCT, KERNEL_LOG, "User end %s", from_str);
+       else
+            unlink (info.reply_fname);        
+        gw_log (GW_LOG_ACCT, KERNEL_LOG, "User end %s", info.from_str);
     }
-    return 0;
 }
+