diff options
Diffstat (limited to '')
| -rw-r--r-- | src/spool_mbox.c | 247 |
1 files changed, 247 insertions, 0 deletions
diff --git a/src/spool_mbox.c b/src/spool_mbox.c new file mode 100644 index 0000000..8b2aae3 --- /dev/null +++ b/src/spool_mbox.c @@ -0,0 +1,247 @@ +/************************************************* +* Exim - an Internet mail transport agent * +*************************************************/ + +/* Copyright (c) Tom Kistner <tom@duncanthrax.net> 2003 - 2015 + * License: GPL + * Copyright (c) The Exim Maintainers 2016 - 2021 + */ + +/* Code for setting up a MBOX style spool file inside a /scan/<msgid> +sub directory of exim's spool directory. */ + +#include "exim.h" +#ifdef WITH_CONTENT_SCAN + +extern int malware_ok; +extern int spam_ok; + +int spool_mbox_ok = 0; +uschar spooled_message_id[MESSAGE_ID_LENGTH+1]; + +/* +Create an MBOX-style message file from the spooled files. + +Returns a pointer to the FILE, and puts the size in bytes into mbox_file_size. +If mbox_fname is non-null, fill in a pointer to the name. +Normally, source_file_override is NULL +*/ + +FILE * +spool_mbox(unsigned long *mbox_file_size, const uschar *source_file_override, + uschar ** mbox_fname) +{ +uschar message_subdir[2]; +uschar buffer[16384]; +uschar *temp_string; +uschar *mbox_path; +FILE *mbox_file = NULL, *l_data_file = NULL, *yield = NULL; +struct stat statbuf; +int j; +rmark reset_point; + +mbox_path = string_sprintf("%s/scan/%s/%s.eml", + spool_directory, message_id, message_id); +if (mbox_fname) *mbox_fname = mbox_path; + +reset_point = store_mark(); + +/* Skip creation if already spooled out as mbox file */ +if (!spool_mbox_ok) + { + /* create temp directory inside scan dir, directory_make works recursively */ + temp_string = string_sprintf("scan/%s", message_id); + if (!directory_make(spool_directory, temp_string, 0750, FALSE)) + { + log_write(0, LOG_MAIN|LOG_PANIC, "%s", + string_open_failed("scan directory %s/scan/%s", spool_directory, temp_string)); + goto OUT; + } + + /* open [message_id].eml file for writing */ + + if (!(mbox_file = modefopen(mbox_path, "wb", SPOOL_MODE))) + { + log_write(0, LOG_MAIN|LOG_PANIC, "%s", + string_open_failed("scan file %s", mbox_path)); + goto OUT; + } + + /* Generate mailbox headers. The $received_for variable is (up to at least + Exim 4.64) never set here, because it is only set when expanding the + contents of the Received: header line. However, the code below will use it + if it should become available in future. */ + + temp_string = expand_string( + US"From ${if def:return_path{$return_path}{MAILER-DAEMON}} ${tod_bsdinbox}\n" + "${if def:sender_address{X-Envelope-From: <${sender_address}>\n}}" + "${if def:recipients{X-Envelope-To: ${recipients}\n}}"); + + if (temp_string) + if (fwrite(temp_string, Ustrlen(temp_string), 1, mbox_file) != 1) + { + log_write(0, LOG_MAIN|LOG_PANIC, "Error/short write while writing \ + mailbox headers to %s", mbox_path); + goto OUT; + } + + /* write all non-deleted header lines to mbox file */ + + for (header_line * my_headerlist = header_list; my_headerlist; + my_headerlist = my_headerlist->next) + if (my_headerlist->type != '*') + if (fwrite(my_headerlist->text, my_headerlist->slen, 1, mbox_file) != 1) + { + log_write(0, LOG_MAIN|LOG_PANIC, "Error/short write while writing \ + message headers to %s", mbox_path); + goto OUT; + } + + /* End headers */ + if (fwrite("\n", 1, 1, mbox_file) != 1) + { + log_write(0, LOG_MAIN|LOG_PANIC, "Error/short write while writing \ + message headers to %s", mbox_path); + goto OUT; + } + + /* Copy body file. If the main receive still has it open then it is holding + a lock, and we must not close it (which releases the lock), so just use the + global file handle. */ + if (source_file_override) + l_data_file = Ufopen(source_file_override, "rb"); + else if (spool_data_file) + l_data_file = spool_data_file; + else + { + message_subdir[1] = '\0'; + for (int i = 0; i < 2; i++) + { + set_subdir_str(message_subdir, message_id, i); + temp_string = spool_fname(US"input", message_subdir, message_id, US"-D"); + if ((l_data_file = Ufopen(temp_string, "rb"))) break; + } + } + + if (!l_data_file) + { + log_write(0, LOG_MAIN|LOG_PANIC, "Could not open datafile for message %s", + message_id); + goto OUT; + } + + /* The code used to use this line, but it doesn't work in Cygwin. + + (void)fread(data_buffer, 1, 18, l_data_file); + + What's happening is that spool_mbox used to use an fread to jump over the + file header. That fails under Cygwin because the header is locked, but + doing an fseek succeeds. We have to output the leading newline + explicitly, because the one in the file is parted of the locked area. */ + + if (!source_file_override) + (void)fseek(l_data_file, SPOOL_DATA_START_OFFSET, SEEK_SET); + + do + { + uschar * s; + + if (!f.spool_file_wireformat || source_file_override) + j = fread(buffer, 1, sizeof(buffer), l_data_file); + else /* needs CRLF -> NL */ + if ((s = US fgets(CS buffer, sizeof(buffer), l_data_file))) + { + uschar * p = s + Ustrlen(s) - 1; + + if (*p == '\n' && p[-1] == '\r') + *--p = '\n'; + else if (*p == '\r') + ungetc(*p--, l_data_file); + + j = p - buffer; + } + else + j = 0; + + if (j > 0) + if (fwrite(buffer, j, 1, mbox_file) != 1) + { + log_write(0, LOG_MAIN|LOG_PANIC, "Error/short write while writing \ + message body to %s", mbox_path); + goto OUT; + } + } while (j > 0); + + (void)fclose(mbox_file); + mbox_file = NULL; + + Ustrncpy(spooled_message_id, message_id, sizeof(spooled_message_id)); + spooled_message_id[sizeof(spooled_message_id)-1] = '\0'; + spool_mbox_ok = 1; + } + +/* get the size of the mbox message and open [message_id].eml file for reading*/ + +if ( !(yield = Ufopen(mbox_path,"rb")) + || fstat(fileno(yield), &statbuf) != 0 + ) + log_write(0, LOG_MAIN|LOG_PANIC, "%s", + string_open_failed( "scan file %s", mbox_path)); +else + *mbox_file_size = statbuf.st_size; + +OUT: +if (l_data_file && !spool_data_file) (void)fclose(l_data_file); +if (mbox_file) (void)fclose(mbox_file); +store_reset(reset_point); +return yield; +} + + + + + +/* remove mbox spool file and temp directory */ +void +unspool_mbox(void) +{ +spam_ok = 0; +malware_ok = 0; + +if (spool_mbox_ok && !f.no_mbox_unspool) + { + uschar *file_path; + DIR *tempdir; + rmark reset_point = store_mark(); + uschar * mbox_path = string_sprintf("%s/scan/%s", spool_directory, spooled_message_id); + + if (!(tempdir = exim_opendir(mbox_path))) + { + debug_printf("Unable to opendir(%s): %s\n", mbox_path, strerror(errno)); + /* Just in case we still can: */ + (void) rmdir(CS mbox_path); + return; + } + /* loop thru dir & delete entries */ + for (struct dirent *entry; entry = readdir(tempdir); ) + { + uschar *name = US entry->d_name; + if (Ustrcmp(name, US".") == 0 || Ustrcmp(name, US"..") == 0) continue; + + file_path = string_sprintf("%s/%s", mbox_path, name); + debug_printf("unspool_mbox(): unlinking '%s'\n", file_path); + if (unlink(CS file_path) != 0) + log_write(0, LOG_MAIN|LOG_PANIC, "unlink(%s): %s", file_path, strerror(errno)); + } + + closedir(tempdir); + + /* remove directory */ + if (rmdir(CS mbox_path) != 0) + log_write(0, LOG_MAIN|LOG_PANIC, "rmdir(%s): %s", mbox_path, strerror(errno)); + store_reset(reset_point); + } +spool_mbox_ok = 0; +} + +#endif |