12603757498444f518f3781c33c1b2981f199b64
[exim.git] / src / src / spool_mbox.c
1 /*************************************************
2 *     Exim - an Internet mail transport agent    *
3 *************************************************/
4
5 /* Copyright (c) Tom Kistner <tom@duncanthrax.net> 2003 - 2015 */
6 /* License: GPL */
7
8 /* Code for setting up a MBOX style spool file inside a /scan/<msgid>
9 sub directory of exim's spool directory. */
10
11 #include "exim.h"
12 #ifdef WITH_CONTENT_SCAN
13
14 /* externals, we must reset them on unspooling */
15 #ifdef WITH_OLD_DEMIME
16 extern int demime_ok;
17 extern struct file_extension *file_extensions;
18 #endif
19
20 extern int malware_ok;
21 extern int spam_ok;
22
23 int spool_mbox_ok = 0;
24 uschar spooled_message_id[17];
25
26 /* returns a pointer to the FILE, and puts the size in bytes into mbox_file_size
27  * normally, source_file_override is NULL */
28
29 FILE *
30 spool_mbox(unsigned long *mbox_file_size, const uschar *source_file_override)
31 {
32 uschar message_subdir[2];
33 uschar buffer[16384];
34 uschar *temp_string;
35 uschar *mbox_path;
36 FILE *mbox_file = NULL;
37 FILE *data_file = NULL;
38 FILE *yield = NULL;
39 header_line *my_headerlist;
40 struct stat statbuf;
41 int i, j;
42 void *reset_point = store_get(0);
43
44 mbox_path = string_sprintf("%s/scan/%s/%s.eml", spool_directory, message_id,
45   message_id);
46
47 /* Skip creation if already spooled out as mbox file */
48 if (!spool_mbox_ok)
49   {
50   /* create temp directory inside scan dir, directory_make works recursively */
51   temp_string = string_sprintf("scan/%s", message_id);
52   if (!directory_make(spool_directory, temp_string, 0750, FALSE))
53     {
54     log_write(0, LOG_MAIN|LOG_PANIC, "%s", string_open_failed(errno,
55       "scan directory %s/scan/%s", spool_directory, temp_string));
56     goto OUT;
57     }
58
59   /* open [message_id].eml file for writing */
60   mbox_file = modefopen(mbox_path, "wb", SPOOL_MODE);
61   if (mbox_file == NULL)
62     {
63     log_write(0, LOG_MAIN|LOG_PANIC, "%s", string_open_failed(errno,
64       "scan file %s", mbox_path));
65     goto OUT;
66     }
67
68   /* Generate mailbox headers. The $received_for variable is (up to at least
69   Exim 4.64) never set here, because it is only set when expanding the
70   contents of the Received: header line. However, the code below will use it
71   if it should become available in future. */
72
73   temp_string = expand_string(
74     US"From ${if def:return_path{$return_path}{MAILER-DAEMON}} ${tod_bsdinbox}\n"
75     "${if def:sender_address{X-Envelope-From: <${sender_address}>\n}}"
76     "${if def:recipients{X-Envelope-To: ${recipients}\n}}");
77
78   if (temp_string != NULL)
79     {
80     i = fwrite(temp_string, Ustrlen(temp_string), 1, mbox_file);
81     if (i != 1)
82       {
83       log_write(0, LOG_MAIN|LOG_PANIC, "Error/short write while writing \
84           mailbox headers to %s", mbox_path);
85       goto OUT;
86       }
87     }
88
89   /* write all header lines to mbox file */
90   my_headerlist = header_list;
91   for (my_headerlist = header_list; my_headerlist != NULL;
92     my_headerlist = my_headerlist->next)
93     {
94     /* skip deleted headers */
95     if (my_headerlist->type == '*') continue;
96
97     i = fwrite(my_headerlist->text, my_headerlist->slen, 1, mbox_file);
98     if (i != 1)
99       {
100       log_write(0, LOG_MAIN|LOG_PANIC, "Error/short write while writing \
101           message headers to %s", mbox_path);
102       goto OUT;
103       }
104     }
105
106   /* End headers */
107   if (fwrite("\n", 1, 1, mbox_file) != 1)
108     {
109     log_write(0, LOG_MAIN|LOG_PANIC, "Error/short write while writing \
110       message headers to %s", mbox_path);
111     goto OUT;
112     }
113
114   /* copy body file */
115   if (source_file_override == NULL)
116     {
117     message_subdir[1] = '\0';
118     for (i = 0; i < 2; i++)
119       {
120       message_subdir[0] = (split_spool_directory == (i == 0))? message_id[5] : 0;
121       temp_string = string_sprintf("%s/input/%s/%s-D", spool_directory,
122         message_subdir, message_id);
123       data_file = Ufopen(temp_string, "rb");
124       if (data_file != NULL) break;
125       }
126     }
127   else
128     data_file = Ufopen(source_file_override, "rb");
129
130   if (data_file == NULL)
131     {
132     log_write(0, LOG_MAIN|LOG_PANIC, "Could not open datafile for message %s",
133       message_id);
134     goto OUT;
135     }
136
137   /* The code used to use this line, but it doesn't work in Cygwin.
138
139       (void)fread(data_buffer, 1, 18, data_file);
140     
141      What's happening is that spool_mbox used to use an fread to jump over the
142      file header. That fails under Cygwin because the header is locked, but
143      doing an fseek succeeds. We have to output the leading newline
144      explicitly, because the one in the file is parted of the locked area.  */
145
146   if (!source_file_override)
147     (void)fseek(data_file, SPOOL_DATA_START_OFFSET, SEEK_SET);
148
149   do
150     {
151     j = fread(buffer, 1, sizeof(buffer), data_file);
152
153     if (j > 0)
154       {
155       i = fwrite(buffer, j, 1, mbox_file);
156       if (i != 1)
157         {
158         log_write(0, LOG_MAIN|LOG_PANIC, "Error/short write while writing \
159             message body to %s", mbox_path);
160         goto OUT;
161         }
162       }
163     } while (j > 0);
164
165   (void)fclose(mbox_file);
166   mbox_file = NULL;
167
168   Ustrcpy(spooled_message_id, message_id);
169   spool_mbox_ok = 1;
170   }
171
172 /* get the size of the mbox message and open [message_id].eml file for reading*/
173 if (Ustat(mbox_path, &statbuf) != 0 ||
174     (yield = Ufopen(mbox_path,"rb")) == NULL)
175   {
176   log_write(0, LOG_MAIN|LOG_PANIC, "%s", string_open_failed(errno,
177     "scan file %s", mbox_path));
178   goto OUT;
179   }
180
181 *mbox_file_size = statbuf.st_size;
182
183 OUT:
184 if (data_file) (void)fclose(data_file);
185 if (mbox_file) (void)fclose(mbox_file);
186 store_reset(reset_point);
187 return yield;
188 }
189
190
191
192
193 /* remove mbox spool file, demimed files and temp directory */
194
195 void
196 unspool_mbox(void)
197 {
198
199 /* reset all exiscan state variables */
200 #ifdef WITH_OLD_DEMIME
201 demime_ok = 0;
202 demime_errorlevel = 0;
203 demime_reason = NULL;
204 file_extensions = NULL;
205 #endif
206
207 spam_ok = 0;
208 malware_ok = 0;
209
210 if (spool_mbox_ok && !no_mbox_unspool)
211   {
212   uschar *mbox_path;
213   uschar *file_path;
214   int n;
215   struct dirent *entry;
216   DIR *tempdir;
217
218   mbox_path = string_sprintf("%s/scan/%s", spool_directory, spooled_message_id);
219
220   tempdir = opendir(CS mbox_path);
221   if (!tempdir)
222     {
223     debug_printf("Unable to opendir(%s): %s\n", mbox_path, strerror(errno));
224     /* Just in case we still can: */
225     rmdir(CS mbox_path);
226     return;
227     }
228   /* loop thru dir & delete entries */
229   while((entry = readdir(tempdir)) != NULL)
230     {
231     uschar *name = US entry->d_name;
232     if (Ustrcmp(name, US".") == 0 || Ustrcmp(name, US"..") == 0) continue;
233
234     file_path = string_sprintf("%s/%s", mbox_path, name);
235     debug_printf("unspool_mbox(): unlinking '%s'\n", file_path);
236     n = unlink(CS file_path);
237     }
238
239   closedir(tempdir);
240
241   /* remove directory */
242   rmdir(CS mbox_path);
243   store_reset(mbox_path);
244   }
245 spool_mbox_ok = 0;
246 }
247
248 #endif