Implement INTERNALDATE in IMAP.

+2001-05-10  Alain Magloire
+
+	* imap4d/fetch.c: Implemented INTERNALDATE.
+	* mailbox/mbx_imap.c (imap_envelope_date): ctime() always
+	append a newline, nuke it.
+	* mailbox/stream.c (stream_read): If the amount requested is bigger
+	then the buffer cache size, bypass the buffering mechanism.
+
 2001-05-09  Alain Magloire
 2001-05-09  Alain Magloire
 
 
 	Take the missing pieces from the pop3d and make the
 	Take the missing pieces from the pop3d and make the

@@ -371,6 +371,48 @@ fetch_flags (struct fetch_command *command, char *arg)
 }
 }
 
 
 /* The internal date of the message.  */
 /* The internal date of the message.  */
+static const char *MONTHS[] =
+{
+  "Jan", "Feb", "Mar", "Apr", "May", "Jun",
+  "Jul", "Aug", "Sep", "Oct", "Nov", "Dec"
+};
+#if 0
+/* The week day is recompute by mktime().  */
+static const char *WEEKDAYS[] =
+{
+ "Sun", "Mon",  "Tue", "Wed", "Thu", "Fri", "Sat"
+};
+#endif
+
+static const char *
+get_timezone (const struct tm *tptr)
+{
+  char tz[5];
+  tz[0] = '\0';
+  strftime (tz, sizeof (tz), "%Z", tptr);
+  if (strcasecmp (tz, "UT") == 0)
+    return "+0000";
+  else if (strcasecmp (tz, "GMT") == 0)
+    return "+0000";
+  else if (strcasecmp (tz, "EDT") == 0)
+    return "-0400";
+  else if (strcasecmp (tz, "EST") == 0)
+    return "-0500";
+  else if (strcasecmp (tz, "CDT") == 0)
+    return "-0500";
+  else if (strcasecmp (tz, "CST") == 0)
+    return "-0600";
+  else if (strcasecmp (tz, "MDT") == 0)
+    return "-0600";
+  else if (strcasecmp (tz, "MST") == 0)
+    return "-0700";
+  else if (strcasecmp (tz, "PDT") == 0)
+    return "-0700";
+  else if (strcasecmp (tz, "PST") == 0)
+    return "-0800";
+  return "-0000"; /* Oops.  */
+}
+
 /* FIXME: Wrong format?  */
 /* FIXME: Wrong format?  */
 static int
 static int
 fetch_internaldate (struct fetch_command *command, char *arg)
 fetch_internaldate (struct fetch_command *command, char *arg)
@@ -378,14 +420,71 @@ fetch_internaldate (struct fetch_command *command, char *arg)
   char date[512];
   char date[512];
   envelope_t env = NULL;
   envelope_t env = NULL;
   message_t msg = NULL;
   message_t msg = NULL;
+  struct tm tm;
+  struct tm *tptr;
+  (void)arg;
   mailbox_get_message (mbox, command->msgno, &msg);
   mailbox_get_message (mbox, command->msgno, &msg);
   message_get_envelope (msg, &env);
   message_get_envelope (msg, &env);
   date[0] = '\0';
   date[0] = '\0';
   envelope_date (env, date, sizeof (date), NULL);
   envelope_date (env, date, sizeof (date), NULL);
+  {
+    int year, mon, day, hour, min, sec;
+    int offt;
+    int i;
+    time_t now;
+    char month[5];
+    char wday[5];
+
+    month[0] = '\0';
+    wday[0] = '\0';
+    day = mon = year = hour = min = sec = offt = 0;
+
+    sscanf (date, "%3s %3s %2d %2d:%2d:%2d %d\n", wday, month, &day,
+	    &hour, &min, &sec, &year);
+    tm.tm_sec = sec;
+    tm.tm_min = min;
+    tm.tm_hour = hour;
+    for (i = 0; i < 12; i++)
+      {
+	if (strncasecmp(month, MONTHS[i], 3) == 0)
+	  {
+	    mon = i;
+	    break;
+	  }
+      }
+    /* No need the week day is recompute by mktime.  */
+#if 0
+    for (i = 0; i < 7; i++)
+      {
+	if (strncasecmp(wday, WEEKDAYS[i], 3) == 0)
+	  {
+	    /* day = i; */
+	    break;
+	  }
+      }
+#endif
+    tm.tm_mday = day;
+    tm.tm_mon = mon;
+    tm.tm_year = (year > 1900) ? year - 1900 : year;
+    tm.tm_yday = 0; /* unknown. */
+    tm.tm_wday = 0; /* unknown. */
+    tm.tm_isdst = -1; /* unknown. */
+    /* What to do the timezone?  */
+    now = mktime (&tm);
+    if (now == (time_t)-1)
+      {
+	/* Fall back to localtime.  */
+	now = time (NULL);
+	tptr = localtime (&now);
+      }
+    else
+      tptr = &tm;
+  }
+  strftime (date, sizeof (date), "%d-%b-%Y %X", &tm);
   util_send ("%s", command->name);
   util_send ("%s", command->name);
   if (date[strlen (date) - 1] == '\n')
   if (date[strlen (date) - 1] == '\n')
     date[strlen (date) - 1] = '\0';
     date[strlen (date) - 1] = '\0';
-  util_send (" \"%s\"", date);
+  util_send (" \"%s %s\"", date, get_timezone (&tm));
   return RESP_OK;
   return RESP_OK;
 }
 }
 
 

@@ -1275,9 +1275,13 @@ imap_envelope_date (envelope_t envelope, char *buffer, size_t buflen,
   now = mktime (&tm);
   now = mktime (&tm);
   if (now == (time_t)-1)
   if (now == (time_t)-1)
     {
     {
+      size_t len;
       /* Fall back to localtime.  */
       /* Fall back to localtime.  */
       now = time (NULL);
       now = time (NULL);
       snprintf (buffer, buflen, "%s", ctime(&now));
       snprintf (buffer, buflen, "%s", ctime(&now));
+      len = strlen (buffer);
+      if (len && buffer[len - 1] == '\n')
+	buffer[len - 1] = '\0';
     }
     }
   else
   else
     {
     {

@@ -133,12 +133,16 @@ stream_setbufsiz (stream_t stream, size_t size)
 }
 }
 
 
 /* We have to be clear about the buffering scheme, it is not designed to be
 /* We have to be clear about the buffering scheme, it is not designed to be
-   use as a fully fledge buffer mechanism.  It is rather turn for networking.
-   Lots of code between POP and IMAP can be share this way.
-   - First caveat; the offset as no meaning, it is up to the concrete
-   _read() to return EISPIPE when error.
+   use as a fully fledge buffer mechanism.  It is a simple mechanims for
+   networking. Lots of code between POP and IMAP can be share this way.
+   - First caveat; the offset as no meaning i.e. the code does move back or
+   up the buffer, if the offset is different then the maintain interanl offset
+   the buffer is flush out and new read from the asking offset is done.  It
+   is up to the concrete _read() to return EISPIPE when error.
+
    - Again, this is targeting networking stream to make readline()
    - Again, this is targeting networking stream to make readline()
    a little bit more efficient, instead of reading a char at a time.  */
    a little bit more efficient, instead of reading a char at a time.  */
+
 int
 int
 stream_read (stream_t is, char *buf, size_t count,
 stream_read (stream_t is, char *buf, size_t count,
 	     off_t offset, size_t *pnread)
 	     off_t offset, size_t *pnread)
@@ -166,9 +170,30 @@ stream_read (stream_t is, char *buf, size_t count,
       size_t residue = count;
       size_t residue = count;
       int r;
       int r;
 
 
+      /* If the amount requested is bigger then the buffer cache size
+	 bypass it.  Do no waste time and let it through.  */
+      if (count > is->rbuffer.bufsiz)
+	{
+	  r = 0;
+	  /* Drain the buffer first.  */
+	  if (is->rbuffer.count > 0 && offset == is->rbuffer.offset)
+	    {
+	      (void)memcpy(buf, is->rbuffer.ptr, is->rbuffer.count);
+	      is->rbuffer.offset += is->rbuffer.count;
+	      residue -= is->rbuffer.count;
+	      buf += is->rbuffer.count;
+	      offset += is->rbuffer.count;
+	    }
+	  is->rbuffer.count = 0;
+	  status = is->_read (is, buf, residue, offset, &r);
+	  is->rbuffer.offset += r;
+	  residue -= r;
+	  if (pnread)
+	    *pnread = count - residue;
+	  return status;
+	}
+
       /* Fill the buffer, do not want to start empty hand.  */
       /* Fill the buffer, do not want to start empty hand.  */
-      /*      if (is->rbuffer.count <= 0 || offset < is->rbuffer.offset */
-      /*  || offset > (is->rbuffer.offset + is->rbuffer.count)) */
       if (is->rbuffer.count <= 0 || offset != is->rbuffer.offset)
       if (is->rbuffer.count <= 0 || offset != is->rbuffer.offset)
 	{
 	{
 	  status = refill (is, offset);
 	  status = refill (is, offset);