pass flake8

.github/workflows/publish.yaml

@@ -1,7 +1,7 @@
 name: Publish
 on:
     workflow_dispatch:
-jobs:        
+jobs:
     publish:
         runs-on: ubuntu-20.04
         steps:

chatbot/src/chatbot/chatbot.py

@@ -1,8 +1,9 @@
 import socket
-from . import responder 
+from . import responder
+
 
 class Chatbot:
-    def __init__( self, peer ):
+    def __init__(self, peer):
         self._peer = peer
         self._responder = responder.Responder()
 

chatbot/test/test_chatbot.py

@@ -1,18 +1,19 @@
 import pytest
 import socket
-from testix.frequentlyused import *
-from testix import patch_module
+from testix.frequentlyused import *  # noqa: F403
+from testix import patch_module  # noqa: F401
 from chatbot import chatbot
 
+
 class TestChatbot:
     @pytest.fixture(autouse=True)
-    def globals_patch(self, patch_module):
-        patch_module( chatbot, 'responder' )
+    def globals_patch(self, patch_module):  # noqa: F811
+        patch_module(chatbot, 'responder')
 
     def construct(self):
         with Scenario() as s:
-            s.responder.Responder() >> Fake( 'responder_' )
-            self.tested = chatbot.Chatbot( Fake( 'sock' ) )
+            s.responder.Responder() >> Fake('responder_')
+            self.tested = chatbot.Chatbot(Fake('sock'))
 
     def test_construction(self):
         self.construct()
@@ -21,8 +22,8 @@ def test_request_response_loop(self):
         self.construct()
         with Scenario() as s:
             for i in range(10):
-                s.sock.recv(4096)                     >> f'request {i}'
-                s.responder_.process(f'request {i}')    >> f'response {i}'
+                s.sock.recv(4096) >> f'request {i}'
+                s.responder_.process(f'request {i}') >> f'response {i}'
                 s.sock.send(f'response {i}')
 
             s.sock.recv(4096) >> Throwing(TestixLoopBreaker)
@@ -33,15 +34,15 @@ def test_request_response_loop_survives_a_recv_exception(self):
         self.construct()
         with Scenario() as s:
             for i in range(10):
-                s.sock.recv(4096)                     >> f'request {i}'
-                s.responder_.process(f'request {i}')    >> f'response {i}'
+                s.sock.recv(4096) >> f'request {i}'
+                s.responder_.process(f'request {i}') >> f'response {i}'
                 s.sock.send(f'response {i}')
 
             s.sock.recv(4096) >> Throwing(socket.error)
 
             for i in range(10):
-                s.sock.recv(4096)                     >> f'request {i}'
-                s.responder_.process(f'request {i}')    >> f'response {i}'
+                s.sock.recv(4096) >> f'request {i}'
+                s.responder_.process(f'request {i}') >> f'response {i}'
                 s.sock.send(f'response {i}')
 
             s.sock.recv(4096) >> Throwing(TestixLoopBreaker)

chatbot/test/test_chatbot_with_unittest_mock.py

@@ -1,13 +1,13 @@
 import pytest
 from unittest.mock import patch
 from unittest.mock import Mock, call
-import socket
 import chatbot.chatbot
 import chatbot.responder
 
+
 class TestChatbot:
     def construct(self, sock, Responder):
-        self.tested = chatbot.chatbot.Chatbot( sock )
+        self.tested = chatbot.chatbot.Chatbot(sock)
         Responder.assert_called_once_with()
 
     @patch('chatbot.responder.Responder')
@@ -19,18 +19,20 @@ def test_construction(self, Responder):
     def test_request_response_loop(self, Responder):
         sock = Mock()
         responder = Mock()
-        Responder.side_effect = [ responder ]
+        Responder.side_effect = [responder]
         self.construct(sock, Responder)
-        class EndTestException(Exception): pass
+
+        class EndTestException(Exception):
+            pass
 
         REQUESTS = [f'request {i}' for i in range(10)]
         RESPONSES = [f'response {i}' for i in range(10)]
         responder.process.side_effect = RESPONSES
         sock.recv.side_effect = REQUESTS + [EndTestException]
-        
+
         with pytest.raises(EndTestException):
             self.tested.go()
 
-        sock.recv.assert_has_calls( [ call(4096) ] * 10 )
-        responder.process.assert_has_calls( [ call(request) for request in REQUESTS ] )
-        sock.send.assert_has_calls( [ call( response ) for response in RESPONSES ] )
+        sock.recv.assert_has_calls([call(4096)] * 10)
+        responder.process.assert_has_calls([call(request) for request in REQUESTS])
+        sock.send.assert_has_calls([call(response) for response in RESPONSES])

docs/chatapp/tests/e2e/pseudo/test_send_and_receive_messages_1.py

@@ -12,5 +12,3 @@ def test_send_and_receive_messages():
 
     assert alice_messages == ['hi Alice']
     assert bob_messages == ['hi Bob']
-
-

docs/chatapp/tests/e2e/pseudo/test_send_and_receive_messages_2.py

@@ -1,12 +1,14 @@
 import chatapp.client
 
+
 class OnMessage:
     def __init__(self):
         self.messages = []
 
     def __call__(self, client, message, peer):
         self.messages.append({'message': message, 'peer': peer})
 
+
 def test_send_and_receive_messages():
     alice_callback = OnMessage()
     bob_callback = OnMessage()
@@ -17,4 +19,4 @@ def test_send_and_receive_messages():
     bob.send('hi Alice', to='Alice')
 
     assert alice_callback.messages == [{'message': 'hi Alice', 'peer': 'Bob'}]
-    assert bob_callback.messages   == [{'message': 'hi Bob',   'peer': 'Alice'}]
+    assert bob_callback.messages == [{'message': 'hi Bob', 'peer': 'Alice'}]

docs/chatapp/tests/e2e/pseudo/test_send_and_receive_messages_3.py

@@ -1,13 +1,15 @@
 import chatapp.client
 import time
 
+
 class OnMessage:
     def __init__(self):
         self.messages = []
 
     def __call__(self, client, message, peer):
         self.messages.append({'message': message, 'peer': peer})
 
+
 def test_send_and_receive_messages():
     alice_callback = OnMessage()
     bob_callback = OnMessage()
@@ -21,4 +23,4 @@ def test_send_and_receive_messages():
     time.sleep(LET_SERVER_RELAY_MESSAGES)
 
     assert alice_callback.messages == [{'message': 'hi Alice', 'peer': 'Bob'}]
-    assert bob_callback.messages   == [{'message': 'hi Bob',   'peer': 'Alice'}]
+    assert bob_callback.messages == [{'message': 'hi Bob', 'peer': 'Alice'}]

docs/chatapp/tests/e2e/pseudo/test_send_and_receive_messages_4.py

@@ -3,20 +3,23 @@
 import chatapp.server
 import time
 
+
 class OnMessage:
     def __init__(self):
         self.messages = []
 
     def __call__(self, client, message, peer):
         self.messages.append({'message': message, 'peer': peer})
 
+
 @pytest.fixture
 def chat_app_server():
     server = chatapp.server.Server(bind_to=('', 3333))
     server.start()
     yield 'http://localhost:3333'
     server.stop()
 
+
 def test_send_and_receive_messages(chat_app_server):
     alice_callback = OnMessage()
     bob_callback = OnMessage()
@@ -30,4 +33,4 @@ def test_send_and_receive_messages(chat_app_server):
     time.sleep(LET_SERVER_RELAY_MESSAGES)
 
     assert alice_callback.messages == [{'message': 'hi Alice', 'peer': 'Bob'}]
-    assert bob_callback.messages   == [{'message': 'hi Bob',   'peer': 'Alice'}]
+    assert bob_callback.messages == [{'message': 'hi Bob', 'peer': 'Alice'}]

docs/common.rst

@@ -6,4 +6,3 @@
 .. |RED| replace:: :boldred:`RED`
 .. |GREEN| replace:: :boldgreen:`GREEN`
 .. |REFACTOR| replace:: :boldblue:`REFACTOR`
-

docs/conf.py

@@ -36,6 +36,7 @@
 # The theme to use for HTML and HTML Help pages.  See the documentation for
 # a list of builtin themes.
 import sphinx_theme
+
 html_theme = 'stanford_theme'
 html_theme_path = [sphinx_theme.get_html_theme_path('stanford-theme')]
 #

docs/index.rst

@@ -17,7 +17,7 @@ The Test-First Mocking Framework
 
 |testix| is special because it allows you to specify what your mock objects do,
 and it then enforces your specifications automatically. It also reduces (albeit
-not entirely) mock setup. 
+not entirely) mock setup.
 
 Other frameworks usually have a flow like this:
 
@@ -29,7 +29,7 @@ Other frameworks usually have a flow like this:
 
 #. setup mock objects
 #. specify *exactly* what should happen to them using a Scenario context
-  
+
 
 Quick Example
 -------------
@@ -86,10 +86,10 @@ Advantages
 #. Readability - the expectations are very similar to the actual code that they
    test (compare ``s.sock.recv(4096)`` with the standard ``sock.recv.assert_called_once_with(4096)``
 #. Test Driven Development friendliness: if you use ``sock.recv.assert_called_once_with(4096)``, you must
-   use it after the code has run. With |testix|, you specify what you *expect*, and the asserting 
+   use it after the code has run. With |testix|, you specify what you *expect*, and the asserting
    is done for you by magic.
 
-What are you waiting for? 
+What are you waiting for?
 
 
 Go to the :doc:`reference<reference/index>` or read the :doc:`Tutorial<tutorial/index>`

docs/line_monitor/source/12/line_monitor.py

@@ -2,6 +2,7 @@
 import pty
 import select
 
+
 class LineMonitor:
     def __init__(self):
         self._callback = None

docs/line_monitor/source/14/line_monitor.py

@@ -2,6 +2,7 @@
 import pty
 import select
 
+
 class LineMonitor:
     def __init__(self):
         self._callback = None

docs/line_monitor/source/16/line_monitor.py

@@ -2,6 +2,7 @@
 import pty
 import select
 
+
 class LineMonitor:
     def __init__(self):
         self._callback = None

docs/line_monitor/source/17/line_monitor.py

@@ -2,6 +2,7 @@
 import pty
 import select
 
+
 class LineMonitor:
     def __init__(self):
         self._callback = None

docs/line_monitor/source/19/line_monitor.py

@@ -2,6 +2,7 @@
 import pty
 import select
 
+
 class LineMonitor:
     def __init__(self):
         self._callback = None

docs/line_monitor/source/2/line_monitor.py

@@ -1,6 +1,7 @@
 import subprocess
 import pty
 
+
 class LineMonitor:
     def register_callback(self, callback):
         pass

docs/line_monitor/source/21/line_monitor.py

@@ -2,6 +2,7 @@
 import pty
 import select
 
+
 class LineMonitor:
     def __init__(self):
         self._callback = None

docs/line_monitor/source/23/line_monitor.py

@@ -2,6 +2,7 @@
 import pty
 import select
 
+
 class LineMonitor:
     def __init__(self):
         self._callback = None

docs/line_monitor/source/25/line_monitor.py

@@ -2,6 +2,7 @@
 import pty
 import select
 
+
 class LineMonitor:
     def __init__(self):
         self._callback = None

docs/line_monitor/source/26/line_monitor.py

@@ -2,6 +2,7 @@
 import pty
 import select
 
+
 class LineMonitor:
     def __init__(self):
         self._callback = None

docs/line_monitor/source/5/line_monitor.py

@@ -1,6 +1,7 @@
 import subprocess
 import pty
 
+
 class LineMonitor:
     def __init__(self):
         self._callback = None

docs/line_monitor/source/7/line_monitor.py

@@ -1,6 +1,7 @@
 import subprocess
 import pty
 
+
 class LineMonitor:
     def __init__(self):
         self._callback = None

docs/line_monitor/source/9/line_monitor.py

@@ -1,6 +1,7 @@
 import subprocess
 import pty
 
+
 class LineMonitor:
     def __init__(self):
         self._callback = None

docs/line_monitor/tests/e2e/test_line_monitor.py

@@ -1,5 +1,6 @@
 import line_monitor
 
+
 def test_line_monitor():
     captured_lines = []
     tested = line_monitor.LineMonitor()

docs/line_monitor/tests/unit/1/test_line_monitor.py

@@ -2,10 +2,12 @@
 import pytest
 import line_monitor
 
+
 @pytest.fixture
 def override_imports(patch_module):
-    patch_module(line_monitor, 'subprocess') # this replaces the subprocess object inside line_monitor with a Fake("subprocess") object
-    patch_module(line_monitor, 'pty') # does the same for the pty module
+    patch_module(line_monitor, 'subprocess')  # this replaces the subprocess object inside line_monitor with a Fake("subprocess") object
+    patch_module(line_monitor, 'pty')  # does the same for the pty module
+
 
 def test_lauch_subprocess_with_pseudoterminal(override_imports):
     tested = line_monitor.LineMonitor()