(self, peer, mailfrom, rcpttos, data)
| 731 | super(PureProxy, self).__init__(*args, **kwargs) |
| 732 | |
| 733 | def process_message(self, peer, mailfrom, rcpttos, data): |
| 734 | lines = data.split('\n') |
| 735 | # Look for the last header |
| 736 | i = 0 |
| 737 | for line in lines: |
| 738 | if not line: |
| 739 | break |
| 740 | i += 1 |
| 741 | lines.insert(i, 'X-Peer: %s' % peer[0]) |
| 742 | data = NEWLINE.join(lines) |
| 743 | refused = self._deliver(mailfrom, rcpttos, data) |
| 744 | # TBD: what to do with refused addresses? |
| 745 | print('we got some refusals:', refused, file=DEBUGSTREAM) |
| 746 | |
| 747 | def _deliver(self, mailfrom, rcpttos, data): |
| 748 | import smtplib |
no test coverage detected