Lines Matching full:channel
50 channel = smtpd.SMTPChannel(server, conn, addr, decode_data=True)
53 channel.socket.queue_recv(line)
54 channel.handle_read()
81 def send_data(self, channel, data, enable_SMTPUTF8=False): argument
83 channel.socket.queue_recv(line)
84 channel.handle_read()
99 channel = smtpd.SMTPChannel(server, conn, addr, decode_data=True)
101 self.send_data(channel, b'From: test\n\nhello\n')
115 channel = smtpd.SMTPChannel(server, conn, addr)
117 self.send_data(channel, b'From: test\n\nh\xc3\xa9llo\xff\n')
132 channel = smtpd.SMTPChannel(server, conn, addr, enable_SMTPUTF8=True)
134 self.send_data(channel, b'From: test\n\nh\xc3\xa9llo\xff\n')
149 channel = smtpd.SMTPChannel(server, conn, addr, enable_SMTPUTF8=True)
151 self.send_data(channel, b'From: test\n\nh\xc3\xa9llo\xff\n',
201 def write_line(self, channel, line): argument
202 channel.socket.queue_recv(line)
203 channel.handle_read()
208 channel = smtpd.SMTPChannel(server, conn, addr)
209 self.write_line(channel, b'EHLO example')
210 self.write_line(channel, b'MAIL from: <foo@example.com> size=20')
211 self.write_line(channel, b'RCPT to: <foo@example.com> foo=bar')
212 self.assertEqual(channel.socket.last, self.error_response)
217 channel = smtpd.SMTPChannel(server, conn, addr)
218 self.write_line(channel, b'EHLO example')
219 self.write_line(channel, b'MAIL from: <foo@example.com> size=20')
220 self.write_line(channel, b'RCPT to: <foo@example.com>')
221 self.assertEqual(channel.socket.last, b'250 OK\r\n')
238 def write_line(self, channel, line): argument
239 channel.socket.queue_recv(line)
240 channel.handle_read()
245 channel = smtpd.SMTPChannel(server, conn, addr, decode_data=True)
246 self.write_line(channel, b'EHLO example')
253 self.write_line(channel, line)
254 self.assertEqual(channel.socket.last, self.error_response)
255 self.write_line(channel, b'MAIL from: <foo@example.com> size=20')
256 self.assertEqual(channel.socket.last, b'250 OK\r\n')
261 channel = smtpd.SMTPChannel(server, conn, addr)
262 self.write_line(channel, b'EHLO example')
267 self.write_line(channel, line)
268 self.assertEqual(channel.socket.last, self.error_response)
270 channel,
273 channel.socket.last,
276 channel, b'MAIL from: <foo@example.com> size=20 body=8bitmime')
277 self.assertEqual(channel.socket.last, b'250 OK\r\n')
282 channel = smtpd.SMTPChannel(server, conn, addr, enable_SMTPUTF8=True)
283 self.write_line(channel, b'EHLO example')
285 channel,
287 self.assertEqual(channel.socket.last, b'250 OK\r\n')
298 self.channel = smtpd.SMTPChannel(self.server, conn, addr,
307 self.channel.socket.queue_recv(line)
308 self.channel.handle_read()
318 self.server, self.channel.conn, self.channel.addr,
326 self.assertEqual(self.channel.socket.last,
331 self.assertEqual(self.channel.socket.last, b'250 HELP\r\n')
335 self.assertEqual(self.channel.socket.last,
341 self.assertEqual(self.channel.socket.last,
347 self.assertEqual(self.channel.socket.last,
353 self.assertEqual(self.channel.socket.last,
359 self.assertEqual(self.channel.socket.last,
364 self.assertEqual(self.channel.socket.last,
370 self.assertEqual(self.channel.socket.last,
375 self.assertEqual(self.channel.socket.last,
381 self.assertEqual(self.channel.socket.last,
387 self.assertEqual(self.channel.socket.last,
394 self.assertEqual(self.channel.socket.last,
400 self.assertEqual(self.channel.socket.last,
406 self.assertEqual(self.channel.socket.last,
411 self.assertEqual(self.channel.socket.last, b'250 OK\r\n')
416 self.assertEqual(self.channel.socket.last, b'250 OK\r\n')
420 self.assertEqual(self.channel.socket.last,
425 self.assertEqual(self.channel.socket.last, b'221 Bye\r\n')
430 self.assertEqual(self.channel.socket.last, b'221 Bye\r\n')
434 self.assertEqual(self.channel.socket.last, b'221 Bye\r\n')
437 self.channel.smtp_state = 'BAD STATE'
439 self.assertEqual(self.channel.socket.last,
445 b'a' * self.channel.command_size_limit +
447 self.assertEqual(self.channel.socket.last,
452 fill_len = self.channel.command_size_limit - len('MAIL from:<@example>')
456 self.assertEqual(self.channel.socket.last, b'250 OK\r\n')
461 self.assertEqual(self.channel.socket.last,
468 self.assertEqual(self.channel.socket.last[0:1], b'5')
472 self.channel.data_size_limit = 1048
477 self.write_line(b'A' * self.channel.data_size_limit +
479 self.assertEqual(self.channel.socket.last,
485 self.assertEqual(self.channel.socket.last,
491 self.assertEqual(self.channel.socket.last,
497 self.assertEqual(self.channel.socket.last,
502 self.assertEqual(self.channel.socket.last,
506 self.channel.data_size_limit = 1048
509 self.assertEqual(self.channel.socket.last,
515 self.assertEqual(self.channel.socket.last,
521 self.assertEqual(self.channel.socket.last,
527 self.assertEqual(self.channel.socket.last,
533 self.assertEqual(self.channel.socket.last,
539 self.assertEqual(self.channel.socket.last, b'250 OK\r\n')
544 self.assertEqual(self.channel.socket.last, b'250 OK\r\n')
549 self.assertEqual(self.channel.socket.last, b'250 OK\r\n')
550 self.assertEqual(self.channel.mailfrom, '"Fred Blogs"@example.com')
555 self.assertEqual(self.channel.socket.last, b'250 OK\r\n')
556 self.assertEqual(self.channel.mailfrom, '"Fred Blogs"@example.com')
561 self.assertEqual(self.channel.socket.last, b'250 OK\r\n')
562 self.assertEqual(self.channel.mailfrom, '"Fred Blogs"@example.com')
567 self.assertEqual(self.channel.socket.last, b'250 OK\r\n')
568 self.assertEqual(self.channel.mailfrom, '"Fred Blogs"@example.com')
574 self.assertEqual(self.channel.socket.last,
579 self.assertEqual(self.channel.socket.last,
585 self.assertEqual(self.channel.socket.last,
590 self.assertEqual(self.channel.socket.last,
595 self.assertEqual(self.channel.socket.last,
602 self.assertEqual(self.channel.socket.last,
609 self.assertEqual(self.channel.socket.last,
616 self.assertEqual(self.channel.socket.last,
623 self.assertEqual(self.channel.socket.last, b'250 OK\r\n')
627 self.assertEqual(self.channel.socket.last,
633 self.assertEqual(self.channel.socket.last, b'250 OK\r\n')
635 self.assertEqual(self.channel.socket.last, b'250 OK\r\n')
638 self.assertEqual(self.channel.socket.last,
641 self.assertEqual(self.channel.socket.last, b'250 OK\r\n')
653 self.assertEqual(self.channel.socket.last, b'501 Syntax: DATA\r\n')
657 self.assertEqual(self.channel.socket.last,
666 self.assertEqual(self.channel.received_data, '.')
682 # checks that the Channel is able to return a custom status message
688 self.assertEqual(self.channel.socket.last, b'250 Okish\r\n')
695 self.assertEqual(self.channel.socket.last, b'250 OK\r\n')
709 self.assertEqual(self.channel.socket.last, b'250 OK\r\n')
713 self.assertEqual(self.channel.socket.last, b'501 Syntax: RSET\r\n')
717 self.assertEqual(self.channel.socket.last,
723 spam = self.channel._SMTPChannel__server
725 self.channel._SMTPChannel__server = 'spam'
727 spam = self.channel._SMTPChannel__line
729 self.channel._SMTPChannel__line = 'spam'
731 spam = self.channel._SMTPChannel__state
733 self.channel._SMTPChannel__state = 'spam'
735 spam = self.channel._SMTPChannel__greeting
737 self.channel._SMTPChannel__greeting = 'spam'
739 spam = self.channel._SMTPChannel__mailfrom
741 self.channel._SMTPChannel__mailfrom = 'spam'
743 spam = self.channel._SMTPChannel__rcpttos
745 self.channel._SMTPChannel__rcpttos = 'spam'
747 spam = self.channel._SMTPChannel__data
749 self.channel._SMTPChannel__data = 'spam'
751 spam = self.channel._SMTPChannel__fqdn
753 self.channel._SMTPChannel__fqdn = 'spam'
755 spam = self.channel._SMTPChannel__peer
757 self.channel._SMTPChannel__peer = 'spam'
759 spam = self.channel._SMTPChannel__conn
761 self.channel._SMTPChannel__conn = 'spam'
763 spam = self.channel._SMTPChannel__addr
765 self.channel._SMTPChannel__addr = 'spam'
776 self.channel = smtpd.SMTPChannel(self.server, conn, addr,
789 self.channel = smtpd.SMTPChannel(self.server, conn, addr, 32,
798 self.channel.socket.queue_recv(line)
799 self.channel.handle_read()
804 self.assertEqual(self.channel.socket.last, b'250 OK\r\n')
806 self.assertEqual(self.channel.socket.last, b'250 OK\r\n')
809 self.assertEqual(self.channel.socket.last,
812 self.assertEqual(self.channel.socket.last, b'250 OK\r\n')
822 self.assertEqual(self.channel.socket.last, b'250 OK\r\n')
824 self.assertEqual(self.channel.socket.last, b'250 OK\r\n')
827 self.assertEqual(self.channel.socket.last,
830 self.assertEqual(self.channel.socket.last,
842 self.channel = smtpd.SMTPChannel(self.server, conn, addr)
850 self.channel.socket.queue_recv(line)
851 self.channel.handle_read()
860 self.assertEqual(self.channel.received_data, b'plain ascii text')
871 self.channel.received_data,
886 self.channel = smtpd.SMTPChannel(self.server, conn, addr,
895 self.channel.socket.queue_recv(line)
896 self.channel.handle_read()
905 self.assertEqual(self.channel.received_data, 'plain ascii text')
916 self.channel.received_data,
928 self.channel = smtpd.SMTPChannel(self.server, conn, addr,
937 self.channel.socket.queue_recv(line)
938 self.channel.handle_read()
946 self.assertEqual(self.channel.socket.last, b'250 OK\r\n')
952 self.assertEqual(self.channel.socket.last[0:3], b'250')
954 self.assertEqual(self.channel.socket.last[0:3], b'250')
956 self.assertEqual(self.channel.socket.last[0:3], b'354')
959 self.assertEqual(self.channel.socket.last, b'250 OK\r\n')
961 self.assertEqual(self.channel.socket.last,
968 self.assertEqual(self.channel.socket.last[0:3], b'250')
970 self.assertEqual(self.channel.socket.last[0:3], b'250')
972 self.assertEqual(self.channel.socket.last[0:3], b'354')
976 self.channel.received_data,
985 self.assertEqual(self.channel.socket.last,
990 self.assertEqual(self.channel.socket.last, b'250 OK\r\n')
997 self.assertEqual(self.channel.socket.last[0:3], b'500')
999 self.assertEqual(self.channel.socket.last[0:3], b'250')
1001 self.assertEqual(self.channel.socket.last[0:3], b'250')
1003 self.assertEqual(self.channel.socket.last[0:3], b'354')
1005 self.assertEqual(self.channel.socket.last[0:3], b'250')