comma

proxy/common/flag.py

@@ -234,7 +234,8 @@ def initialize(
             opts.get('hostname', ipaddress.ip_address(args.hostname)),
         )
         args.unix_socket_path = opts.get(
-            'unix_socket_path', args.unix_socket_path)
+            'unix_socket_path', args.unix_socket_path,
+        )
         # AF_UNIX is not available on Windows
         # See https://bugs.python.org/issue33408
         if os.name != 'nt':

proxy/core/event/dispatcher.py

@@ -104,7 +104,8 @@ def _broadcast(self, ev: Dict[str, Any]) -> None:
                 self.subscribers[sub_id].send(ev)
             except BrokenPipeError:
                 logger.warning(
-                    'Subscriber#%s broken pipe', sub_id)
+                    'Subscriber#%s broken pipe', sub_id,
+                )
                 self.subscribers[sub_id].close()
                 broken_pipes.append(sub_id)
         for sub_id in broken_pipes:

proxy/core/event/subscriber.py

@@ -97,7 +97,8 @@ def subscribe(self) -> None:
     def unsubscribe(self) -> None:
         if self.relay_sub_id is None:
             logger.warning(
-                'Relay called unsubscribe without an active subscription')
+                'Relay called unsubscribe without an active subscription',
+            )
             return
         try:
             self.event_queue.unsubscribe(self.relay_sub_id)
@@ -122,14 +123,17 @@ def relay(
                     ev = channel.recv()
                     if ev['event_name'] == eventNames.SUBSCRIBED:
                         logger.info(
-                            'Subscriber#{0} subscribe ack received'.format(sub_id))
+                            'Subscriber#{0} subscribe ack received'.format(sub_id),
+                        )
                     elif ev['event_name'] == eventNames.UNSUBSCRIBED:
                         logger.info(
-                            'Subscriber#{0} unsubscribe ack received'.format(sub_id))
+                            'Subscriber#{0} unsubscribe ack received'.format(sub_id),
+                        )
                         break
                     elif ev['event_name'] == eventNames.DISPATCHER_SHUTDOWN:
                         logger.info(
-                            'Subscriber#{0} received dispatcher shutdown event'.format(sub_id))
+                            'Subscriber#{0} received dispatcher shutdown event'.format(sub_id),
+                        )
                         break
                     else:
                         callback(ev)
@@ -146,8 +150,10 @@ def _start_relay_thread(self, callback: Callable[[Dict[str, Any]], None]) -> Non
         self.relay_recv, self.relay_send = multiprocessing.Pipe()
         self.relay_thread = threading.Thread(
             target=EventSubscriber.relay,
-            args=(self.relay_sub_id, self.relay_shutdown,
-                  self.relay_recv, callback),
+            args=(
+                self.relay_sub_id, self.relay_shutdown,
+                self.relay_recv, callback,
+            ),
         )
         self.relay_thread.daemon = True
         self.relay_thread.start()

proxy/dashboard/inspect_traffic.py

@@ -41,8 +41,10 @@ def handle_message(self, message: Dict[str, Any]) -> None:
                         WebsocketFrame.text(
                             bytes_(
                                 json.dumps(
-                                    {'id': message['id'],
-                                        'response': 'not enabled'},
+                                    {
+                                        'id': message['id'],
+                                        'response': 'not enabled',
+                                    },
                                 ),
                             ),
                         ),

tests/core/test_acceptor_pool.py

@@ -52,17 +52,22 @@ def test_setup_and_shutdown(
         self.assertEqual(mock_send_handle.call_count, num_acceptors)
 
         self.assertEqual(
-            mock_acceptor.call_args_list[0][1]['idd'], 0)
+            mock_acceptor.call_args_list[0][1]['idd'], 0,
+        )
         self.assertEqual(
-            mock_acceptor.call_args_list[0][1]['fd_queue'], mock_pipe.return_value[1])
+            mock_acceptor.call_args_list[0][1]['fd_queue'], mock_pipe.return_value[1],
+        )
         self.assertEqual(
-            mock_acceptor.call_args_list[0][1]['flags'], flags)
+            mock_acceptor.call_args_list[0][1]['flags'], flags,
+        )
         self.assertEqual(
-            mock_acceptor.call_args_list[0][1]['event_queue'], None)
+            mock_acceptor.call_args_list[0][1]['event_queue'], None,
+        )
         # executor_queues=[],
         # executor_pids=[]
         self.assertEqual(
-            mock_acceptor.call_args_list[1][1]['idd'], 1)
+            mock_acceptor.call_args_list[1][1]['idd'], 1,
+        )
 
         acceptor1.start.assert_called_once()
         acceptor2.start.assert_called_once()

tests/test_main.py

@@ -95,7 +95,8 @@ def test_entry_point(
         entry_point()
         mock_event_manager.assert_not_called()
         mock_listener.assert_called_once_with(
-            flags=mock_initialize.return_value)
+            flags=mock_initialize.return_value,
+        )
         mock_executor_pool.assert_called_once_with(
             flags=mock_initialize.return_value,
             event_queue=None,
@@ -139,7 +140,8 @@ def test_main_with_no_flags(
         main()
         mock_event_manager.assert_not_called()
         mock_listener.assert_called_once_with(
-            flags=mock_initialize.return_value)
+            flags=mock_initialize.return_value,
+        )
         mock_executor_pool.assert_called_once_with(
             flags=mock_initialize.return_value,
             event_queue=None,
@@ -178,7 +180,8 @@ def test_enable_events(
         mock_event_manager.return_value.setup.assert_called_once()
         mock_event_manager.return_value.shutdown.assert_called_once()
         mock_listener.assert_called_once_with(
-            flags=mock_initialize.return_value)
+            flags=mock_initialize.return_value,
+        )
         mock_executor_pool.assert_called_once_with(
             flags=mock_initialize.return_value,
             event_queue=mock_event_manager.return_value.queue,