Makefile.am nntp_head.c nntp_article.c nntp_body.c

added ARTICLE HEAD and BODY

4 files changed, 419 insertions, 0 deletions

diff --git a/mailbox/nntp/Makefile.am b/mailbox/nntp/Makefile.am
new file mode 100644
index 000000000..3b3bc77fa
--- /dev/null
+++ b/mailbox/nntp/Makefile.am
@@ -0,0 +1,41 @@
+## Process this file with GNU Automake to create Makefile.in
+
+##   Copyright (C) 2004 Free Software Foundation, Inc.
+##
+##   GNU Mailutils is free software; you can redistribute it and/or
+##   modify it under the terms of the GNU General Public License as
+##   published by the Free Software Foundation; either version 2, or (at
+##   your option) any later version.
+##
+##   This program is distributed in the hope that it will be useful, but
+##   WITHOUT ANY WARRANTY; without even the implied warranty of
+##   MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the GNU
+##   General Public License for more details.
+##
+##   You should have received a copy of the GNU General Public License
+##   along with this program; if not, write to the Free Software
+##   Foundation, Inc.
+##   59 Temple Place, Suite 330, Boston, MA  02111-1307  USA
+
+INCLUDES = -I${top_srcdir}/include -I${top_srcdir}/mailbox \
+ -I${top_srcdir}/mailbox/include -I${top_builddir}/include/mailutils/gnu \
+ @INTLINCS@
+
+lib_LTLIBRARIES = libmu_nntp.la
+
+libmu_nntp_la_SOURCES = \
+ nntp_carrier.c \
+ nntp_connect.c \
+ nntp_create.c \
+ nntp_debug.c \
+ nntp_destroy.c \
+ nntp_disconnect.c \
+ nntp_readline.c \
+ nntp_response.c \
+ nntp_sendline.c \
+ nntp_stream.c \
+ nntp_timeout.c \
+ nntp_article.c \
+ nntp_head.c \
+ nntp_body.c
+
diff --git a/mailbox/nntp/nntp_article.c b/mailbox/nntp/nntp_article.c
new file mode 100644
index 000000000..c59108d6a
--- /dev/null
+++ b/mailbox/nntp/nntp_article.c
@@ -0,0 +1,126 @@
+/* GNU Mailutils -- a suite of utilities for electronic mail
+   Copyright (C) 1999, 2000, 2001, 2004 Free Software Foundation, Inc.
+
+   This library is free software; you can redistribute it and/or
+   modify it under the terms of the GNU Lesser General Public
+   License as published by the Free Software Foundation; either
+   version 2 of the License, or (at your option) any later version.
+
+   This library is distributed in the hope that it will be useful,
+   but WITHOUT ANY WARRANTY; without even the implied warranty of
+   MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the GNU
+   Lesser General Public License for more details.
+
+   You should have received a copy of the GNU Lesser General Public
+   License along with this library; if not, write to the Free Software
+   Foundation, Inc., 59 Temple Place, Suite 330, Boston, MA 02111-1307  USA  */
+
+#ifdef HAVE_CONFIG_H
+# include <config.h>
+#endif
+
+#include <string.h>
+#include <errno.h>
+#include <mailutils/sys/nntp.h>
+
+int
+mu_nntp_article (mu_nntp_t nntp, unsigned long number, unsigned long *pnum, char **mid, stream_t *pstream)
+{
+  int status;
+  char *message_id = NULL;
+  if (number != 0)
+    {
+      message_id = malloc(128);
+      if (message_id == NULL)
+	{
+	  return ENOMEM;
+	}
+      snprintf(message_id, 127, "%d", number);
+    }
+  status = mu_nntp_article_id (nntp, message_id, pnum, mid, pstream);
+  if (message_id)
+    {
+      free (message_id);
+    }
+  return status;
+}
+
+int
+mu_nntp_article_id (mu_nntp_t nntp, const char *message_id, unsigned long *pnum, char **mid, stream_t *pstream)
+{
+  int status;
+  unsigned long dummy = 0;
+  char *buf;
+
+  if (nntp == NULL)
+    return EINVAL;
+  if (pstream == NULL)
+    return MU_ERR_OUT_PTR_NULL;
+
+  switch (nntp->state)
+    {
+    case MU_NNTP_NO_STATE:
+      if (message_id == NULL || *message_id == '\0')
+	{
+	  status = mu_nntp_writeline (nntp, "ARTICLE\r\n");
+	}
+      else
+	{
+	  status = mu_nntp_writeline (nntp, "ARTICLE %s\r\n", message_id);
+	}
+      MU_NNTP_CHECK_ERROR (nntp, status);
+      mu_NNTP_debug_cmd (nntp);
+      nntp->state = MU_NNTP_ARTICLE;
+
+    case MU_NNTP_ARTICLE:
+      status = mu_nntp_send (nntp);
+      MU_NNTP_CHECK_EAGAIN (nntp, status);
+      nntp->acknowledge = 0;
+      nntp->state = MU_NNTP_ARTICLE_ACK;
+
+    case MU_NNTP_ARTICLE_ACK:
+      status = mu_nntp_response (nntp, NULL, 0, NULL);
+      MU_NNTP_CHECK_EAGAIN (nntp, status);
+      mu_nntp_debug_ack (nntp);
+      MU_NNTP_CHECK_OK (nntp);
+      nntp->state = MU_NNTP_ARTICLE_RX;
+      /* parse the answer now. */
+      if (pnum == NULL)
+	{
+	  pnum = &dummy;
+	}
+      buf = calloc(sizeof(*buf), 128);
+      if (buf == NULL)
+	{
+	  return ENOMEM;
+	}
+      sscanf (nntp->ack.buf, "220 %d %127s", pnum, buf);
+      if (*buf == '\0')
+	{
+	  strcpy (buf, "<0>");
+	}
+      if (mid)
+	{
+	  *mid = buf;
+	}
+      else
+	{
+	  free (buf);
+	}
+
+    case MU_NNTP_ARTICLE_RX:
+      status = mu_nntp_stream_create (nntp, pstream);
+      MU_NNTP_CHECK_ERROR (nntp, status);
+      break;
+
+      /* They must deal with the error first by reopening.  */
+    case MU_NNTP_ERROR:
+      status = ECANCELED;
+      break;
+
+    default:
+      status = EINPROGRESS;
+    }
+
+  return status;
+}
diff --git a/mailbox/nntp/nntp_body.c b/mailbox/nntp/nntp_body.c
new file mode 100644
index 000000000..1d3e6d8d8
--- /dev/null
+++ b/mailbox/nntp/nntp_body.c
@@ -0,0 +1,126 @@
+/* GNU Mailutils -- a suite of utilities for electronic mail
+   Copyright (C) 1999, 2000, 2001, 2004 Free Software Foundation, Inc.
+
+   This library is free software; you can redistribute it and/or
+   modify it under the terms of the GNU Lesser General Public
+   License as published by the Free Software Foundation; either
+   version 2 of the License, or (at your option) any later version.
+
+   This library is distributed in the hope that it will be useful,
+   but WITHOUT ANY WARRANTY; without even the implied warranty of
+   MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the GNU
+   Lesser General Public License for more details.
+
+   You should have received a copy of the GNU Lesser General Public
+   License along with this library; if not, write to the Free Software
+   Foundation, Inc., 59 Temple Place, Suite 330, Boston, MA 02111-1307  USA  */
+
+#ifdef HAVE_CONFIG_H
+# include <config.h>
+#endif
+
+#include <string.h>
+#include <errno.h>
+#include <mailutils/sys/nntp.h>
+
+int
+mu_nntp_body (mu_nntp_t nntp, unsigned long number, unsigned long *pnum, char **mid, stream_t *pstream)
+{
+  int status;
+  char *message_id = NULL;
+  if (number != 0)
+    {
+      message_id = malloc(128);
+      if (message_id == NULL)
+	{
+	  return ENOMEM;
+	}
+      snprintf (message_id, 127, "%d", number);
+    }
+  status = mu_nntp_body_id (nntp, message_id, pnum, mid, pstream);
+  if (message_id)
+    {
+      free (message_id);
+    }
+  return status;
+}
+
+int
+mu_nntp_body_id (mu_nntp_t nntp, const char *message_id, unsigned long *pnum, char **mid, stream_t *pstream)
+{
+  int status;
+  unsigned long dummy = 0;
+  char *buf;
+
+  if (nntp == NULL)
+    return EINVAL;
+  if (pstream == NULL)
+    return MU_ERR_OUT_PTR_NULL;
+
+  switch (nntp->state)
+    {
+    case MU_NNTP_NO_STATE:
+      if (message_id == 0 || *message_id == '\0')
+	{
+	  status = mu_nntp_writeline (nntp, "BODY\r\n");
+	}
+      else
+	{
+	  status = mu_nntp_writeline (nntp, "BODY %s\r\n", message_id);
+	}
+      MU_NNTP_CHECK_ERROR (nntp, status);
+      mu_NNTP_debug_cmd (nntp);
+      nntp->state = MU_NNTP_BODY;
+
+    case MU_NNTP_BODY:
+      status = mu_nntp_send (nntp);
+      MU_NNTP_CHECK_EAGAIN (nntp, status);
+      nntp->acknowledge = 0;
+      nntp->state = MU_NNTP_BODY_ACK;
+
+    case MU_NNTP_BODY_ACK:
+      status = mu_nntp_response (nntp, NULL, 0, NULL);
+      MU_NNTP_CHECK_EAGAIN (nntp, status);
+      mu_nntp_debug_ack (nntp);
+      MU_NNTP_CHECK_OK (nntp);
+      nntp->state = MU_NNTP_BODY_RX;
+      /* parse the answer now. */
+      if (pnum == NULL)
+	{
+	  pnum = &dummy;
+	}
+      buf = calloc(1, 128);
+      if (buf == NULL)
+	{
+	  return ENOMEM;
+	}
+      sscanf (nntp->ack.buf, "222 %d %127s", pnum, buf);
+      if (*buf == '\0')
+	{
+	  strcpy (buf, "<0>");
+	}
+      if (mid)
+	{
+	  *mid = buf;
+	}
+      else
+	{
+	  free (buf);
+	}
+
+    case MU_NNTP_BODY_RX:
+      status = mu_nntp_stream_create (nntp, pstream);
+      MU_NNTP_CHECK_ERROR (nntp, status);
+      break;
+
+      /* They must deal with the error first by reopening.  */
+    case MU_NNTP_ERROR:
+      status = ECANCELED;
+      break;
+
+    default:
+      status = EINPROGRESS;
+    }
+
+  return status;
+}
diff --git a/mailbox/nntp/nntp_head.c b/mailbox/nntp/nntp_head.c
new file mode 100644
index 000000000..5a1f6ee28
--- /dev/null
+++ b/mailbox/nntp/nntp_head.c
@@ -0,0 +1,126 @@
+/* GNU Mailutils -- a suite of utilities for electronic mail
+   Copyright (C) 1999, 2000, 2001, 2004 Free Software Foundation, Inc.
+
+   This library is free software; you can redistribute it and/or
+   modify it under the terms of the GNU Lesser General Public
+   License as published by the Free Software Foundation; either
+   version 2 of the License, or (at your option) any later version.
+
+   This library is distributed in the hope that it will be useful,
+   but WITHOUT ANY WARRANTY; without even the implied warranty of
+   MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the GNU
+   Lesser General Public License for more details.
+
+   You should have received a copy of the GNU Lesser General Public
+   License along with this library; if not, write to the Free Software
+   Foundation, Inc., 59 Temple Place, Suite 330, Boston, MA 02111-1307  USA  */
+
+#ifdef HAVE_CONFIG_H
+# include <config.h>
+#endif
+
+#include <string.h>
+#include <errno.h>
+#include <mailutils/sys/nntp.h>
+
+int
+mu_nntp_head (mu_nntp_t nntp, unsigned long number, unsigned long *pnum, char **mid, stream_t *pstream)
+{
+  int status;
+  char *message_id = NULL;
+  if (number != 0)
+    {
+      message_id = malloc (128);
+      if (message_id == NULL)
+	{
+	  return ENOMEM;
+	}
+      snprintf (message_id, 127, "%d", number);
+    }
+  status = mu_nntp_head_id (nntp, message_id, pnum, mid, pstream);
+  if (message_id)
+    {
+      free (message_id);
+    }
+  return status;
+}
+
+int
+mu_nntp_head_id (mu_nntp_t nntp, const char *message_id, unsigned long *pnum, char **mid, stream_t *pstream)
+{
+  int status;
+  unsigned long dummy = 0;
+  char *buf;
+
+  if (nntp == NULL)
+    return EINVAL;
+  if (pstream == NULL)
+    return MU_ERR_OUT_PTR_NULL;
+
+  switch (nntp->state)
+    {
+    case MU_NNTP_NO_STATE:
+      if (message_id == NULL || *message_id == '\0')
+	{
+	  status = mu_nntp_writeline (nntp, "HEAD\r\n");
+	}
+      else
+	{
+	  status = mu_nntp_writeline (nntp, "HEAD %s\r\n", message_id);
+	}
+      MU_NNTP_CHECK_ERROR (nntp, status);
+      mu_NNTP_debug_cmd (nntp);
+      nntp->state = MU_NNTP_HEAD;
+
+    case MU_NNTP_HEAD:
+      status = mu_nntp_send (nntp);
+      MU_NNTP_CHECK_EAGAIN (nntp, status);
+      nntp->acknowledge = 0;
+      nntp->state = MU_NNTP_HEAD_ACK;
+
+    case MU_NNTP_HEAD_ACK:
+      status = mu_nntp_response (nntp, NULL, 0, NULL);
+      MU_NNTP_CHECK_EAGAIN (nntp, status);
+      mu_nntp_debug_ack (nntp);
+      MU_NNTP_CHECK_OK (nntp);
+      nntp->state = MU_NNTP_HEAD_RX;
+      /* parse the answer now. */
+      if (pnum == NULL)
+	{
+	  pnum = &dummy;
+	}
+      buf = calloc(sizeof(*buf), 128);
+      if (buf == NULL)
+	{
+	  return ENOMEM;
+	}
+      sscanf (nntp->ack.buf, "221 %d %127s", pnum, buf);
+      if (*buf == '\0')
+	{
+	  strcpy(buf, "<0>");
+	}
+      if (mid)
+	{
+	  *mid = buf;
+	}
+      else
+	{
+	  free (buf);
+	}
+
+    case MU_NNTP_HEAD_RX:
+      status = mu_nntp_stream_create (nntp, pstream);
+      MU_NNTP_CHECK_ERROR (nntp, status);
+      break;
+
+      /* They must deal with the error first by reopening.  */
+    case MU_NNTP_ERROR:
+      status = ECANCELED;
+      break;
+
+    default:
+      status = EINPROGRESS;
+    }
+
+  return status;
+}