made backends package

mapping_provider/__init__.py

@@ -10,8 +10,9 @@ from functools import partial
 
 from fastapi import FastAPI
 
-from mapping_provider import config, correlator, environment, services
+from mapping_provider import config, environment
 from mapping_provider.api import common, map
+from mapping_provider.backends import correlator, services
 
 logger = logging.getLogger(__name__)
 

mapping_provider/correlator.py → mapping_provider/backends/correlator.py

@@ -12,7 +12,7 @@ if TYPE_CHECKING:
 
 from pika.exchange_type import ExchangeType
 
-from mapping_provider.rmq.exchange import RabbitMQClient, default_rmq_connection_params
+from .rmq.exchange import RabbitMQClient, default_rmq_connection_params
 
 logger = logging.getLogger(__name__)
 

pyproject.toml

@@ -14,6 +14,6 @@ warn_return_any = true
 [tool.coverage.run]
 source = ["mapping_provider"]
 omit = [
-    "mapping_provider/rmq/*",
+    "mapping_provider/backends/rmq/*",
     "test/*"
 ]
\ No newline at end of file

test/test_correlator.py

@@ -2,7 +2,7 @@ import json
 import os
 import tempfile
 
-from mapping_provider.correlator import handle_correlator_state_broadcast
+from mapping_provider.backends.correlator import handle_correlator_state_broadcast
 
 
 def test_handle_correlator_state_broadcast():

test/test_services.py

@@ -5,7 +5,7 @@ import tempfile
 
 import responses
 
-from mapping_provider.services import _load_and_process_services
+from mapping_provider.backends.services import _load_and_process_services
 
 from .common import load_test_data