Lines Matching refs:channel

51         channel = smtpd.SMTPChannel(server, conn, addr, decode_data=True)
54 channel.socket.queue_recv(line)
55 channel.handle_read()
82 def send_data(self, channel, data, enable_SMTPUTF8=False):
84 channel.socket.queue_recv(line)
85 channel.handle_read()
100 channel = smtpd.SMTPChannel(server, conn, addr, decode_data=True)
102 self.send_data(channel, b'From: test\n\nhello\n')
116 channel = smtpd.SMTPChannel(server, conn, addr)
118 self.send_data(channel, b'From: test\n\nh\xc3\xa9llo\xff\n')
133 channel = smtpd.SMTPChannel(server, conn, addr, enable_SMTPUTF8=True)
135 self.send_data(channel, b'From: test\n\nh\xc3\xa9llo\xff\n')
150 channel = smtpd.SMTPChannel(server, conn, addr, enable_SMTPUTF8=True)
152 self.send_data(channel, b'From: test\n\nh\xc3\xa9llo\xff\n',
202 def write_line(self, channel, line):
203 channel.socket.queue_recv(line)
204 channel.handle_read()
209 channel = smtpd.SMTPChannel(server, conn, addr)
210 self.write_line(channel, b'EHLO example')
211 self.write_line(channel, b'MAIL from: <foo@example.com> size=20')
212 self.write_line(channel, b'RCPT to: <foo@example.com> foo=bar')
213 self.assertEqual(channel.socket.last, self.error_response)
218 channel = smtpd.SMTPChannel(server, conn, addr)
219 self.write_line(channel, b'EHLO example')
220 self.write_line(channel, b'MAIL from: <foo@example.com> size=20')
221 self.write_line(channel, b'RCPT to: <foo@example.com>')
222 self.assertEqual(channel.socket.last, b'250 OK\r\n')
239 def write_line(self, channel, line):
240 channel.socket.queue_recv(line)
241 channel.handle_read()
246 channel = smtpd.SMTPChannel(server, conn, addr, decode_data=True)
247 self.write_line(channel, b'EHLO example')
254 self.write_line(channel, line)
255 self.assertEqual(channel.socket.last, self.error_response)
256 self.write_line(channel, b'MAIL from: <foo@example.com> size=20')
257 self.assertEqual(channel.socket.last, b'250 OK\r\n')
262 channel = smtpd.SMTPChannel(server, conn, addr)
263 self.write_line(channel, b'EHLO example')
268 self.write_line(channel, line)
269 self.assertEqual(channel.socket.last, self.error_response)
271 channel,
274 channel.socket.last,
277 channel, b'MAIL from: <foo@example.com> size=20 body=8bitmime')
278 self.assertEqual(channel.socket.last, b'250 OK\r\n')
283 channel = smtpd.SMTPChannel(server, conn, addr, enable_SMTPUTF8=True)
284 self.write_line(channel, b'EHLO example')
286 channel,
288 self.assertEqual(channel.socket.last, b'250 OK\r\n')
299 self.channel = smtpd.SMTPChannel(self.server, conn, addr,
308 self.channel.socket.queue_recv(line)
309 self.channel.handle_read()
319 self.server, self.channel.conn, self.channel.addr,
327 self.assertEqual(self.channel.socket.last,
332 self.assertEqual(self.channel.socket.last, b'250 HELP\r\n')
336 self.assertEqual(self.channel.socket.last,
342 self.assertEqual(self.channel.socket.last,
348 self.assertEqual(self.channel.socket.last,
354 self.assertEqual(self.channel.socket.last,
360 self.assertEqual(self.channel.socket.last,
365 self.assertEqual(self.channel.socket.last,
371 self.assertEqual(self.channel.socket.last,
376 self.assertEqual(self.channel.socket.last,
382 self.assertEqual(self.channel.socket.last,
388 self.assertEqual(self.channel.socket.last,
395 self.assertEqual(self.channel.socket.last,
401 self.assertEqual(self.channel.socket.last,
407 self.assertEqual(self.channel.socket.last,
412 self.assertEqual(self.channel.socket.last, b'250 OK\r\n')
417 self.assertEqual(self.channel.socket.last, b'250 OK\r\n')
421 self.assertEqual(self.channel.socket.last,
426 self.assertEqual(self.channel.socket.last, b'221 Bye\r\n')
431 self.assertEqual(self.channel.socket.last, b'221 Bye\r\n')
435 self.assertEqual(self.channel.socket.last, b'221 Bye\r\n')
438 self.channel.smtp_state = 'BAD STATE'
440 self.assertEqual(self.channel.socket.last,
446 b'a' * self.channel.command_size_limit +
448 self.assertEqual(self.channel.socket.last,
453 fill_len = self.channel.command_size_limit - len('MAIL from:<@example>')
457 self.assertEqual(self.channel.socket.last, b'250 OK\r\n')
462 self.assertEqual(self.channel.socket.last,
469 self.assertEqual(self.channel.socket.last[0:1], b'5')
473 self.channel.data_size_limit = 1048
478 self.write_line(b'A' * self.channel.data_size_limit +
480 self.assertEqual(self.channel.socket.last,
486 self.assertEqual(self.channel.socket.last,
492 self.assertEqual(self.channel.socket.last,
498 self.assertEqual(self.channel.socket.last,
503 self.assertEqual(self.channel.socket.last,
507 self.channel.data_size_limit = 1048
510 self.assertEqual(self.channel.socket.last,
516 self.assertEqual(self.channel.socket.last,
522 self.assertEqual(self.channel.socket.last,
528 self.assertEqual(self.channel.socket.last,
534 self.assertEqual(self.channel.socket.last,
540 self.assertEqual(self.channel.socket.last, b'250 OK\r\n')
545 self.assertEqual(self.channel.socket.last, b'250 OK\r\n')
550 self.assertEqual(self.channel.socket.last, b'250 OK\r\n')
551 self.assertEqual(self.channel.mailfrom, '"Fred Blogs"@example.com')
556 self.assertEqual(self.channel.socket.last, b'250 OK\r\n')
557 self.assertEqual(self.channel.mailfrom, '"Fred Blogs"@example.com')
562 self.assertEqual(self.channel.socket.last, b'250 OK\r\n')
563 self.assertEqual(self.channel.mailfrom, '"Fred Blogs"@example.com')
568 self.assertEqual(self.channel.socket.last, b'250 OK\r\n')
569 self.assertEqual(self.channel.mailfrom, '"Fred Blogs"@example.com')
575 self.assertEqual(self.channel.socket.last,
580 self.assertEqual(self.channel.socket.last,
586 self.assertEqual(self.channel.socket.last,
591 self.assertEqual(self.channel.socket.last,
596 self.assertEqual(self.channel.socket.last,
603 self.assertEqual(self.channel.socket.last,
610 self.assertEqual(self.channel.socket.last,
617 self.assertEqual(self.channel.socket.last,
624 self.assertEqual(self.channel.socket.last, b'250 OK\r\n')
628 self.assertEqual(self.channel.socket.last,
634 self.assertEqual(self.channel.socket.last, b'250 OK\r\n')
636 self.assertEqual(self.channel.socket.last, b'250 OK\r\n')
639 self.assertEqual(self.channel.socket.last,
642 self.assertEqual(self.channel.socket.last, b'250 OK\r\n')
654 self.assertEqual(self.channel.socket.last, b'501 Syntax: DATA\r\n')
658 self.assertEqual(self.channel.socket.last,
667 self.assertEqual(self.channel.received_data, '.')
689 self.assertEqual(self.channel.socket.last, b'250 Okish\r\n')
696 self.assertEqual(self.channel.socket.last, b'250 OK\r\n')
710 self.assertEqual(self.channel.socket.last, b'250 OK\r\n')
714 self.assertEqual(self.channel.socket.last, b'501 Syntax: RSET\r\n')
718 self.assertEqual(self.channel.socket.last,
724 spam = self.channel._SMTPChannel__server
726 self.channel._SMTPChannel__server = 'spam'
728 spam = self.channel._SMTPChannel__line
730 self.channel._SMTPChannel__line = 'spam'
732 spam = self.channel._SMTPChannel__state
734 self.channel._SMTPChannel__state = 'spam'
736 spam = self.channel._SMTPChannel__greeting
738 self.channel._SMTPChannel__greeting = 'spam'
740 spam = self.channel._SMTPChannel__mailfrom
742 self.channel._SMTPChannel__mailfrom = 'spam'
744 spam = self.channel._SMTPChannel__rcpttos
746 self.channel._SMTPChannel__rcpttos = 'spam'
748 spam = self.channel._SMTPChannel__data
750 self.channel._SMTPChannel__data = 'spam'
752 spam = self.channel._SMTPChannel__fqdn
754 self.channel._SMTPChannel__fqdn = 'spam'
756 spam = self.channel._SMTPChannel__peer
758 self.channel._SMTPChannel__peer = 'spam'
760 spam = self.channel._SMTPChannel__conn
762 self.channel._SMTPChannel__conn = 'spam'
764 spam = self.channel._SMTPChannel__addr
766 self.channel._SMTPChannel__addr = 'spam'
777 self.channel = smtpd.SMTPChannel(self.server, conn, addr,
790 self.channel = smtpd.SMTPChannel(self.server, conn, addr, 32,
799 self.channel.socket.queue_recv(line)
800 self.channel.handle_read()
805 self.assertEqual(self.channel.socket.last, b'250 OK\r\n')
807 self.assertEqual(self.channel.socket.last, b'250 OK\r\n')
810 self.assertEqual(self.channel.socket.last,
813 self.assertEqual(self.channel.socket.last, b'250 OK\r\n')
823 self.assertEqual(self.channel.socket.last, b'250 OK\r\n')
825 self.assertEqual(self.channel.socket.last, b'250 OK\r\n')
828 self.assertEqual(self.channel.socket.last,
831 self.assertEqual(self.channel.socket.last,
843 self.channel = smtpd.SMTPChannel(self.server, conn, addr)
851 self.channel.socket.queue_recv(line)
852 self.channel.handle_read()
861 self.assertEqual(self.channel.received_data, b'plain ascii text')
872 self.channel.received_data,
887 self.channel = smtpd.SMTPChannel(self.server, conn, addr,
896 self.channel.socket.queue_recv(line)
897 self.channel.handle_read()
906 self.assertEqual(self.channel.received_data, 'plain ascii text')
917 self.channel.received_data,
929 self.channel = smtpd.SMTPChannel(self.server, conn, addr,
938 self.channel.socket.queue_recv(line)
939 self.channel.handle_read()
947 self.assertEqual(self.channel.socket.last, b'250 OK\r\n')
953 self.assertEqual(self.channel.socket.last[0:3], b'250')
955 self.assertEqual(self.channel.socket.last[0:3], b'250')
957 self.assertEqual(self.channel.socket.last[0:3], b'354')
960 self.assertEqual(self.channel.socket.last, b'250 OK\r\n')
962 self.assertEqual(self.channel.socket.last,
969 self.assertEqual(self.channel.socket.last[0:3], b'250')
971 self.assertEqual(self.channel.socket.last[0:3], b'250')
973 self.assertEqual(self.channel.socket.last[0:3], b'354')
977 self.channel.received_data,
986 self.assertEqual(self.channel.socket.last,
991 self.assertEqual(self.channel.socket.last, b'250 OK\r\n')
998 self.assertEqual(self.channel.socket.last[0:3], b'500')
1000 self.assertEqual(self.channel.socket.last[0:3], b'250')
1002 self.assertEqual(self.channel.socket.last[0:3], b'250')
1004 self.assertEqual(self.channel.socket.last[0:3], b'354')
1006 self.assertEqual(self.channel.socket.last[0:3], b'250')