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, 5 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 :)
#	Content
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