]> git.cworth.org Git - notmuch/blob - test/smtp-dummy.c
test: Remove #! line from test-lib.sh
[notmuch] / test / smtp-dummy.c
1 /* smtp-dummy - Dummy SMTP server that delivers mail to the given file
2  *
3  * Copyright © 2010 Carl Worth
4  *
5  * This program is free software: you can redistribute it and/or modify
6  * it under the terms of the GNU General Public License as published by
7  * the Free Software Foundation, either version 3 of the License, or
8  * (at your option) any later version.
9  *
10  * This program is distributed in the hope that it will be useful,
11  * but WITHOUT ANY WARRANTY; without even the implied warranty of
12  * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
13  * GNU General Public License for more details.
14  *
15  * You should have received a copy of the GNU General Public License
16  * along with this program.  If not, see http://www.gnu.org/licenses/ .
17  *
18  * Authors: Carl Worth <cworth@cworth.org>
19  */
20
21 /* This (non-compliant) SMTP server listens on localhost, port 25025
22  * and delivers a mail received to the given filename, (specified as a
23  * command-line argument). It exists after the first client connection
24  * completes.
25  *
26  * It implements very little of the SMTP protocol, even less than
27  * specified as the minimum implementation in the SMTP RFC, (not
28  * implementing RSET, NOOP, nor VRFY). And it doesn't do any
29  * error-checking on the input.
30  *
31  * That is to say, if you use this program, you will very likely find
32  * cases where it doesn't do everything your SMTP client expects. You
33  * have been warned.
34  */
35
36 #include <stdio.h>
37 #include <stdlib.h>
38 #include <string.h>
39 #include <errno.h>
40 #include <netinet/ip.h>
41 #include <netdb.h>
42 #include <unistd.h>
43
44 #define STRNCMP_LITERAL(var, literal) \
45     strncmp ((var), (literal), sizeof (literal) - 1)
46
47 static void
48 receive_data_to_file (FILE *peer, FILE *output)
49 {
50         char *line = NULL;
51         size_t line_size;
52         ssize_t line_len;
53
54         while ((line_len = getline (&line, &line_size, peer)) != -1) {
55                 if (STRNCMP_LITERAL (line, ".\r\n") == 0)
56                         break;
57                 if (line_len < 2)
58                         continue;
59                 if (line[line_len-1] == '\n' && line[line_len-2] == '\r') {
60                         line[line_len-2] = '\n';
61                         line[line_len-1] = '\0';
62                 }
63                 fprintf (output, "%s",
64                          line[0] == '.' ? line + 1 : line);
65         }
66
67         free (line);
68 }
69
70 static int
71 process_command (FILE *peer, FILE *output, const char *command)
72 {
73         if (STRNCMP_LITERAL (command, "EHLO ") == 0) {
74                 fprintf (peer, "502 not implemented\r\n");
75                 fflush (peer);
76         } else if (STRNCMP_LITERAL (command, "HELO ") == 0) {
77                 fprintf (peer, "250 localhost\r\n");
78                 fflush (peer);
79         } else if (STRNCMP_LITERAL (command, "MAIL FROM:") == 0 ||
80                    STRNCMP_LITERAL (command, "RCPT TO:") == 0) {
81                 fprintf (peer, "250 OK\r\n");
82                 fflush (peer);
83         } else if (STRNCMP_LITERAL (command, "DATA") == 0) {
84                 fprintf (peer, "354 End data with <CR><LF>.<CR><LF>\r\n");
85                 fflush (peer);
86                 receive_data_to_file (peer, output);
87                 fprintf (peer, "250 OK\r\n");
88                 fflush (peer);
89         } else if (STRNCMP_LITERAL (command, "QUIT") == 0) {
90                 fprintf (peer, "221 BYE\r\n");
91                 fflush (peer);
92                 return 1;
93         } else {
94                 fprintf (stderr, "Unknown command: %s\n", command);
95         }
96         return 0;
97 }
98
99 static void
100 do_smtp_to_file (FILE *peer, FILE *output)
101 {
102         char *line = NULL;
103         size_t line_size;
104         ssize_t line_len;
105
106         fprintf (peer, "220 localhost smtp-dummy\r\n");
107         fflush (peer);
108
109         while ((line_len = getline (&line, &line_size, peer)) != -1) {
110                 if (process_command (peer, output, line))
111                         break;
112         }
113
114         free (line);
115 }
116
117 int
118 main (int argc, char *argv[])
119 {
120         char *output_filename;
121         FILE *peer_file, *output;
122         int sock, peer, err;
123         struct sockaddr_in addr, peer_addr;
124         struct hostent *hostinfo;
125         socklen_t peer_addr_len;
126         int reuse;
127
128         if (argc != 2) {
129                 fprintf (stderr, "Usage: %s <output-file>\n", argv[0]);
130                 return 1;
131         }
132
133         output_filename = argv[1];
134         output = fopen (output_filename, "w");
135         if (output == NULL) {
136                 fprintf (stderr, "Failed to open %s for writing: %s\n",
137                          output_filename, strerror (errno));
138                 return 1;
139         }
140
141         sock = socket (AF_INET, SOCK_STREAM, 0);
142         if (sock == -1) {
143                 fprintf (stderr, "Error: socket() failed: %s\n",
144                          strerror (errno));
145                 return 1;
146         }
147
148         reuse = 1;
149         err = setsockopt (sock, SOL_SOCKET, SO_REUSEADDR, &reuse, sizeof (reuse));
150         if (err) {
151                 fprintf (stderr, "Error: setsockopt() failed: %s\n",
152                          strerror (errno));
153                 return 1;
154         }
155
156         hostinfo = gethostbyname ("localhost");
157         if (hostinfo == NULL) {
158                 fprintf (stderr, "Unknown host: localhost\n");
159                 return 1;
160         }
161
162         memset (&addr, 0, sizeof (addr));
163         addr.sin_family = AF_INET;
164         addr.sin_port = htons (25025);
165         addr.sin_addr = *(struct in_addr *) hostinfo->h_addr;
166         err = bind (sock, (struct sockaddr *) &addr, sizeof(addr));
167         if (err) {
168                 fprintf (stderr, "Error: bind() failed: %s\n",
169                          strerror (errno));
170                 close (sock);
171                 return 1;
172         }
173
174         err = listen (sock, 1);
175         if (err) {
176                 fprintf (stderr, "Error: listen() failed: %s\n",
177                          strerror (errno));
178                 close (sock);
179                 return 1;
180         }
181
182         peer_addr_len = sizeof (peer_addr);
183         peer = accept (sock, (struct sockaddr *) &peer_addr, &peer_addr_len);
184         if (peer == -1) {
185                 fprintf (stderr, "Error: accept() failed: %s\n",
186                          strerror (errno));
187                 return 1;
188         }
189
190         peer_file = fdopen (peer, "w+");
191         if (peer_file == NULL) {
192                 fprintf (stderr, "Error: fdopen() failed: %s\n",
193                          strerror (errno));
194                 return 1;
195         }
196
197         do_smtp_to_file (peer_file, output);
198
199         fclose (output);
200         fclose (peer_file);
201         close (sock);
202
203         return 0;
204 }