Support per-plugin config sections in the config file

Author: matburt

receptor/config.py

@@ -204,7 +204,8 @@ def __init__(self, args=None):
             key='delay',
             default_value=0,
             value_type='float',
-            hint='The delay (in seconds) to wait between pings. If unspecified here or in a config file pings will be sent as soon as the previous response is received.',
+            hint='The delay (in seconds) to wait between pings. If unspecified here or in a'
+                 'config file pings will be sent as soon as the previous response is received.',
         )
         self.add_config_option(
             section='ping',
@@ -368,6 +369,11 @@ def parse_options(self, args):
             # because env variables and configparser do not enforce the
             # value type, we do it now to ensure we have the type we want
             self._enforce_entry_type(entry)
+        # Parse plugin_ sections to populate plugin configuration
+        self._config_options['plugins'] = {}
+        if self._config_file:
+            for section in filter(lambda x: x.startswith("plugin_"), self._config_file.sections()):
+                self._config_options['plugins'][section.replace("plugin_", "")] = dict(self._config_file[section])
 
     def _enforce_entry_type(self, entry):
         if entry.value is not None:

receptor/protocol.py

@@ -223,4 +223,3 @@ def _data_received_callback(self, inner_env, fut):
                 code=1,
             )
             self.emit_response(err_resp)
-

receptor/work.py

@@ -48,7 +48,7 @@ async def handle(self, inner_env):
                 logger.exception(f'Could not load action {action} from {namespace}')
                 raise exceptions.InvalidDirectiveAction(f'Invalid action {action} for {namespace}')
             self.add_work(inner_env)
-            responses = action_method(inner_env)
+            responses = action_method(inner_env, self.receptor.config.plugins.get("namespace", {}))
             async for response in responses:
                 serial += 1
                 logger.debug(f'Response emitted for {inner_env.message_id}, serial {serial}')