c%2B%2B/socket%2B%2B-1.10/smtp.C

// smtp.C -*- C++ -*- socket library
// Copyright (C) 1992,1993,1994 Gnanasekaran Swaminathan <gs4t@virginia.edu>
// 
// Permission is granted to use at your own risk and distribute this software
// in source and binary forms provided the above copyright
// notice and this paragraph are preserved on all copies.
// This software is provided "as is" with no express or implied warranty.
//
// Version: 17Oct95 1.10

#include <config.h>

#include <smtp.h>
#include <Fork.h>
#include <fcntl.h>
#include <unistd.h>
#include <stdlib.h>
#include <string.h>

void smtp::smtpbuf::get_response ()
     // get all the response that one can get and send all of them to o
{
  // if o is 0, then we trash data.
  while (underflow () != EOF) {
    int n = in_avail ();
    if (n < 5)
      continue;

    // data is of this form: 221 repsonse <CRLF> or 221-response <CRLF>
    char* q = gptr ();
    char* p = q;

    // zap upto <CRLF>
    for (int i = 2; i <= n; i++, p++)
      if (*p == '\r' && *(p+1) == '\n') {
        if (o)
          o->write (q, i);
        gbump (i);
        break;
      }
    
    if (q [3] != '-')
      break;
  }  
}

void smtp::smtpbuf::send_cmd (const char* cmd, const char* s, const char* p)
{
  xsputn (cmd, ::strlen (cmd));
  if (s)
    xsputn (s, ::strlen (s));
  if (p)
    xsputn (p, ::strlen (p));
  xsputn ("\r\n", 2);
  flush_output ();
  
  if (o)
    get_response ();
}

void smtp::smtpbuf::helo ()
{
  if (o) 
    get_response ();
  send_cmd ("HELO ", localhost ());
}

void smtp::smtpbuf::mail (const char* reverse_path)
{
  if (reverse_path)
    send_cmd ("MAIL FROM:<", reverse_path, ">");
  else
    send_cmd ("MAIL FROM:<>");
}

void smtp::smtpbuf::rcpt (const char* forward_path)
{
  if (forward_path)
    send_cmd ("RCPT TO:<", forward_path, ">");
}

void smtp::smtpbuf::help (const char* s)
{
  send_cmd ("HELP ", s);
}

void smtp::smtpbuf::send_buf (const char* buf, int len)
{
  if (buf == 0 || len <= 0)
    return;

  // send line by line
  const unsigned char* p = (const unsigned char*) buf;

#ifdef buggy
// this doesn't work correctly for ".\n" on a line by itself
  if (*p == '.')
    sputc ((unsigned int) '.');
#endif

  for (int i = 0; i < len; i++, p++) {
    if (*p == '\n') {
      sputc ((unsigned int) '\r');
      sputc (*p);
#ifdef buggy
// this doesn't work correctly for "\n.\n" - RGL
      if (*(p+1) == '.')
        sputc ((unsigned int) '.');
#endif
    } else
      sputc (*p);
  }

  // XXX: Need to flush or \r\n.\r\n may not be sent - RGL
  flush_output();
}

void smtp::smtpbuf::data (const char* buf, int len)
{
  data ();
  send_buf (buf, len);
  xsputn ("\r\n.\r\n", 5);
  flush_output ();

  if (o)
    get_response ();
}

void smtp::smtpbuf::data (const char* filename)
{
  data ();

  int  fd = 0;
  char buf [1024];
  int  rcnt;

  if (filename == 0 || (fd = ::open (filename, O_RDONLY )) == -1)
    fd = 0;

  while ((rcnt = ::read (fd, buf, 1024)) > 0)
    send_buf (buf, rcnt);

  xsputn ("\r\n.\r\n", 5);
  flush_output ();

  if (o)
    get_response ();
}

int smtp::get_response (char* buf, int len)
     // same as get line except what it returns
     // return 1 if output continues after this line
     // return 0 if output has terminated
{
  if (len < 8) {
    this->getline (buf, len);
    return 0;
  }

  buf [3] = 0;
  this->getline (buf, len);
  return buf [3] == '-';
}
  
ostream& operator << (ostream& o, smtp& s)
{
  char buf [1024];
  int  cont = 1;
  while (cont) {
    cont = s.get_response (buf, 1024);
    o << buf << endl;
  }
  return o;
}


void smtp::smtpbuf::serve_clients (int portno)
{
}

Revision:	1.2
Committed:	Mon Jun 10 14:10:44 2002 UTC (22 years, 3 months ago) by tdb
Content type:	text/plain
Branch:	MAIN
CVS Tags:	HEAD
Changes since 1.1:	+0 -0 lines
State:	*FILE REMOVED*
Log Message:	Tidy up of files. These are all old things that are not only no longer used but are also probably useless to anyone other than us. This saves checking them out all the time, and makes the "cms/source" tree contain only current stuff. They'll still exist in the attic's though :)
#	User	Rev	Content
1	ab11	1.1	// smtp.C -- C++ -- socket library
2			// Copyright (C) 1992,1993,1994 Gnanasekaran Swaminathan <gs4t@virginia.edu>
3			//
4			// Permission is granted to use at your own risk and distribute this software
5			// in source and binary forms provided the above copyright
6			// notice and this paragraph are preserved on all copies.
7			// This software is provided "as is" with no express or implied warranty.
8			//
9			// Version: 17Oct95 1.10
10
11			#include <config.h>
12
13			#include <smtp.h>
14			#include <Fork.h>
15			#include <fcntl.h>
16			#include <unistd.h>
17			#include <stdlib.h>
18			#include <string.h>
19
20			void smtp::smtpbuf::get_response ()
21			// get all the response that one can get and send all of them to o
22			{
23			// if o is 0, then we trash data.
24			while (underflow () != EOF) {
25			int n = in_avail ();
26			if (n < 5)
27			continue;
28
29			// data is of this form: 221 repsonse <CRLF> or 221-response <CRLF>
30			char* q = gptr ();
31			char* p = q;
32
33			// zap upto <CRLF>
34			for (int i = 2; i <= n; i++, p++)
35			if (p == '\r' && (p+1) == '\n') {
36			if (o)
37			o->write (q, i);
38			gbump (i);
39			break;
40			}
41
42			if (q [3] != '-')
43			break;
44			}
45			}
46
47			void smtp::smtpbuf::send_cmd (const char* cmd, const char* s, const char* p)
48			{
49			xsputn (cmd, ::strlen (cmd));
50			if (s)
51			xsputn (s, ::strlen (s));
52			if (p)
53			xsputn (p, ::strlen (p));
54			xsputn ("\r\n", 2);
55			flush_output ();
56
57			if (o)
58			get_response ();
59			}
60
61			void smtp::smtpbuf::helo ()
62			{
63			if (o)
64			get_response ();
65			send_cmd ("HELO ", localhost ());
66			}
67
68			void smtp::smtpbuf::mail (const char* reverse_path)
69			{
70			if (reverse_path)
71			send_cmd ("MAIL FROM:<", reverse_path, ">");
72			else
73			send_cmd ("MAIL FROM:<>");
74			}
75
76			void smtp::smtpbuf::rcpt (const char* forward_path)
77			{
78			if (forward_path)
79			send_cmd ("RCPT TO:<", forward_path, ">");
80			}
81
82			void smtp::smtpbuf::help (const char* s)
83			{
84			send_cmd ("HELP ", s);
85			}
86
87			void smtp::smtpbuf::send_buf (const char* buf, int len)
88			{
89			if (buf == 0 \|\| len <= 0)
90			return;
91
92			// send line by line
93			const unsigned char* p = (const unsigned char*) buf;
94
95			#ifdef buggy
96			// this doesn't work correctly for ".\n" on a line by itself
97			if (*p == '.')
98			sputc ((unsigned int) '.');
99			#endif
100
101			for (int i = 0; i < len; i++, p++) {
102			if (*p == '\n') {
103			sputc ((unsigned int) '\r');
104			sputc (*p);
105			#ifdef buggy
106			// this doesn't work correctly for "\n.\n" - RGL
107			if (*(p+1) == '.')
108			sputc ((unsigned int) '.');
109			#endif
110			} else
111			sputc (*p);
112			}
113
114			// XXX: Need to flush or \r\n.\r\n may not be sent - RGL
115			flush_output();
116			}
117
118			void smtp::smtpbuf::data (const char* buf, int len)
119			{
120			data ();
121			send_buf (buf, len);
122			xsputn ("\r\n.\r\n", 5);
123			flush_output ();
124
125			if (o)
126			get_response ();
127			}
128
129			void smtp::smtpbuf::data (const char* filename)
130			{
131			data ();
132
133			int fd = 0;
134			char buf [1024];
135			int rcnt;
136
137			if (filename == 0 \|\| (fd = ::open (filename, O_RDONLY )) == -1)
138			fd = 0;
139
140			while ((rcnt = ::read (fd, buf, 1024)) > 0)
141			send_buf (buf, rcnt);
142
143			xsputn ("\r\n.\r\n", 5);
144			flush_output ();
145
146			if (o)
147			get_response ();
148			}
149
150			int smtp::get_response (char* buf, int len)
151			// same as get line except what it returns
152			// return 1 if output continues after this line
153			// return 0 if output has terminated
154			{
155			if (len < 8) {
156			this->getline (buf, len);
157			return 0;
158			}
159
160			buf [3] = 0;
161			this->getline (buf, len);
162			return buf [3] == '-';
163			}
164
165			ostream& operator << (ostream& o, smtp& s)
166			{
167			char buf [1024];
168			int cont = 1;
169			while (cont) {
170			cont = s.get_response (buf, 1024);
171			o << buf << endl;
172			}
173			return o;
174			}
175
176
177			void smtp::smtpbuf::serve_clients (int portno)
178			{
179			}
180