refactor: sort into mvc structure

__init__.py

+__version__ = "1.0.0"
+
+__all__ = [
+    "api",
+    "controllers",
+    "models",
+    "wrappers",
+    # "workers",
+    "fixtures",
+    "tests",
+    "run",
+]

api/__init__.py

+import os
+
+
+__all__ = [
+    os.path.splitext(os.path.basename(x))[0]
+    for x in os.listdir(os.path.dirname(__file__))
+    if x.endswith(".py") and x != "__init__.py"
+]
\ No newline at end of file

endpoints/notify.py → api/notify.py

@@ -2,7 +2,7 @@ import json
 from flask_restful import request, abort
 from marshmallow import Schema, fields
 import pika
-from endpoints.auth_resource import AuthResource
+from api.auth_resource import AuthResource
 
 
 class NotifySchema(Schema):

endpoints/receive.py → api/receive.py

@@ -3,7 +3,7 @@ from marshmallow import Schema, fields
 import pika
 import json
 from models.token import TokenModel
-from endpoints.auth_resource import AuthResource
+from api.auth_resource import AuthResource
 
 
 class ReceiveQuerySchema(Schema):

endpoints/send.py → api/send.py

@@ -2,7 +2,7 @@ import json
 from flask_restful import request, abort
 from marshmallow import Schema, fields
 import pika
-from endpoints.auth_resource import AuthResource
+from api.auth_resource import AuthResource
 
 class SendSchema(Schema):
     body = fields.Str(required=True)

endpoints/token.py → api/token.py

 import json 
+import pika
 from flask_restful import Resource, request, abort
 from marshmallow import Schema, fields
-import pika
 from models.token import TokenModel
 
 

controllers/__init__.py

+import os
+
+
+__all__ = [
+    os.path.splitext(os.path.basename(x))[0]
+    for x in os.listdir(os.path.dirname(__file__))
+    if x.endswith(".py") and x != "__init__.py"
+]
+

soar_bus.py → controllers/core_bus.py

@@ -10,11 +10,11 @@
 # soar-broadcast - admin messages forwarded to all client-inboxes regardless of subscriptions
 
 import concurrent.futures
-from endpoints.clients import ClientsFile
-from soar_broadcast import broadcast
-from soar_forward import forward
-from soar_publish import publish
-from soar_subscribe import subscribe
+from api.clients import ClientsFile
+from controllers.core_broadcast import broadcast
+from controllers.core_forward import forward
+from controllers.core_publish import publish
+from controllers.core_subscribe import subscribe
 
 THREADS = []
 EXCHANGES = {

endpoints/hello.py

-from flask_restful import Resource
-
-
-class HelloWorld(Resource):
-    def get(self):
-        return {"hello": "world"}

fixtures/__init__.py

+import os
+
+
+__all__ = [
+    os.path.splitext(os.path.basename(x))[0]
+    for x in os.listdir(os.path.dirname(__file__))
+    if x.endswith(".py") and x != "__init__.py"
+]

models/__init__.py

+import os
+
+
+__all__ = [
+    os.path.splitext(os.path.basename(x))[0]
+    for x in os.listdir(os.path.dirname(__file__))
+    if x.endswith(".py") and x != "__init__.py"
+]

requirements.txt

+Flask == 2.2.2
+Flask-RESTful == 0.3.9
+marshmallow == 3.19.0
+cryptography == 39.0.0
+bson == 0.5.10
+pubsubpy == 2.3.0
+pika == 1.3.1
+pyrabbit == 1.1.0
+Flask-Cors == 3.0.10
\ No newline at end of file