| 742 | super(PureProxy, self).__init__(*args, **kwargs) |
| 743 | |
| 744 | def process_message(self, peer, mailfrom, rcpttos, data): |
| 745 | lines = data.split('\n') |
| 746 | # Look for the last header |
| 747 | i = 0 |
| 748 | for line in lines: |
| 749 | if not line: |
| 750 | break |
| 751 | i += 1 |
| 752 | lines.insert(i, 'X-Peer: %s' % peer[0]) |
| 753 | data = NEWLINE.join(lines) |
| 754 | refused = self._deliver(mailfrom, rcpttos, data) |
| 755 | # TBD: what to do with refused addresses? |
| 756 | print('we got some refusals:', refused, file=DEBUGSTREAM) |
| 757 | |
| 758 | def _deliver(self, mailfrom, rcpttos, data): |
| 759 | import smtplib |