address commands. See manual page for more information.
"""
-VERSION = "1.2.1"
+VERSION = "1.2.4"
PLUGIN_INTERFACE_VERSION = "1"
import getopt
def md5sum_as_hex(s):
return md5.new(s).hexdigest()
+
+def forkexec(argv, text):
+ """Run a command (given as argv array) and write text to its stdin"""
+ (r, w) = os.pipe()
+ pid = os.fork()
+ if pid == -1:
+ raise Exception("fork failed")
+ elif pid == 0:
+ os.dup2(r, 0)
+ os.close(r)
+ os.close(w)
+ fd = os.open("/dev/null", os.O_RDWR)
+ os.dup2(fd, 1)
+ os.dup2(fd, 2)
+ os.execvp(argv[0], argv)
+ sys.exit(1)
+ else:
+ os.close(r)
+ os.write(w, text)
+ os.close(w)
+ (pid2, exit) = os.waitpid(pid, 0)
+ if pid != pid2:
+ raise Exception("os.waitpid for %d returned for %d" % (pid, pid2))
+ if exit != 0:
+ raise Exception("subprocess failed, exit=0x%x" % exit)
+ return exit
+
+
environ = None
def set_environ(new_environ):
error("Error sending QMQP mail, mail probably not sent")
sys.exit(1)
else:
- recipients = string.join(recipients, " ")
- f = os.popen("%s -oi -f '%s' %s" %
- (self.sendmail,
- envelope_sender,
- recipients),
- "w")
- f.write(text)
- status = f.close()
- if status != 0:
- error("%s returned %d, mail sending probably failed" %
+ status = forkexec([self.sendmail, "-oi", "-f",
+ envelope_sender] + recipients, text)
+ if status:
+ error("%s returned %s, mail sending probably failed" %
(self.sendmail, status))
sys.exit((status >> 8) & 0xff)
else:
def read_stdin(self):
data = sys.stdin.read()
+ # Convert CRLF to plain LF
+ data = "\n".join(data.split("\r\n"))
# Skip Unix mbox "From " mail start indicator
if data[:5] == "From ":
data = string.split(data, "\n", 1)[1]
return "\n".join(headers) + "\n\n" + body
except:
- error("Cannot MIME encode header, using original ones, sorry")
+ warning("Cannot MIME encode header, using original ones, sorry")
return text
def template(self, template_name, dict):