Replace wrong encoded characters in header values
This commit is contained in:
@@ -166,7 +166,7 @@ class HeaderMilter(Milter.Base):
|
|||||||
|
|
||||||
@Milter.noreply
|
@Milter.noreply
|
||||||
def header(self, name, value):
|
def header(self, name, value):
|
||||||
self.headers.append((name, value))
|
self.headers.append((name, value.encode(errors="replace").decode()))
|
||||||
return Milter.CONTINUE
|
return Milter.CONTINUE
|
||||||
|
|
||||||
def eom(self):
|
def eom(self):
|
||||||
@@ -188,16 +188,20 @@ class HeaderMilter(Milter.Base):
|
|||||||
self.addheader(name, value, 1)
|
self.addheader(name, value, 1)
|
||||||
else:
|
else:
|
||||||
if action == "mod":
|
if action == "mod":
|
||||||
|
old_line = "{}: {}".format(name, self.headers[index][1])
|
||||||
|
new_line = "{}: {}".format(name, value)
|
||||||
if log:
|
if log:
|
||||||
self.logger.info("{}: modify: header: {}".format(self.queueid, "{}: {}".format(name, self.headers[index][1])[0:50]))
|
self.logger.info("{}: modify: header: {}: {}".format(
|
||||||
|
self.queueid, old_line[0:40], new_line[0:40]))
|
||||||
else:
|
else:
|
||||||
self.logger.debug("{}: modify: header (occ. {}): {}".format(self.queueid, occurrence, "{}: {}".format(name, self.headers[index][1])[0:50]))
|
self.logger.debug("{}: modify: header (occ. {}): {}: {}: {}".format(
|
||||||
|
self.queueid, occurrence, name, old_line, new_line))
|
||||||
self.headers[index] = (name, value)
|
self.headers[index] = (name, value)
|
||||||
elif action == "del":
|
elif action == "del":
|
||||||
if log:
|
if log:
|
||||||
self.logger.info("{}: delete: header: {}".format(self.queueid, "{}: {}".format(name, self.headers[index][1])[0:50]))
|
self.logger.info("{}: delete: header: {}".format(self.queueid, "{}: {}".format(name, self.headers[index][1]))[0:50])
|
||||||
else:
|
else:
|
||||||
self.logger.debug("{}: delete: header (occ. {}): {}".format(self.queueid, occurrence, "{}: {}".format(name, self.headers[index][1])[0:50]))
|
self.logger.debug("{}: delete: header (occ. {}): {}".format(self.queueid, occurrence, "{}: {}".format(name, self.headers[index][1]))[0:50])
|
||||||
del self.headers[index]
|
del self.headers[index]
|
||||||
self.chgheader(name, occurrence, value)
|
self.chgheader(name, occurrence, value)
|
||||||
return Milter.ACCEPT
|
return Milter.ACCEPT
|
||||||
|
|||||||
2
setup.py
2
setup.py
@@ -5,7 +5,7 @@ def read_file(fname):
|
|||||||
return f.read()
|
return f.read()
|
||||||
|
|
||||||
setup(name = "pyheadermilter",
|
setup(name = "pyheadermilter",
|
||||||
version = "0.0.1",
|
version = "0.0.2",
|
||||||
author = "Thomas Oettli",
|
author = "Thomas Oettli",
|
||||||
author_email = "spacefreak@noop.ch",
|
author_email = "spacefreak@noop.ch",
|
||||||
description = "A pymilter based sendmail/postfix pre-queue filter.",
|
description = "A pymilter based sendmail/postfix pre-queue filter.",
|
||||||
|
|||||||
Reference in New Issue
Block a user