refactor: make backends extensible (#2)

* refactor: add black for formatting and some half-way refactorings, not functional yet.

* refactor: use hatch

* fix: some fixes to get stuff working

* fix: get some xray functionality working

* fix: get user addition/removal/update working

* fix: xray logs

* fix: xray core restart

* fix: user usages

* feat: log user modifications

.gitignore

@@ -169,3 +169,5 @@ xray-core
 *config.json
 bin/
 pyvenv.cfg
+_version.py
+

marznode.py

@@ -4,6 +4,6 @@
 
 from marznode.marznode import main
 
-if __name__ == '__main__':
+if __name__ == "__main__":
     loop = asyncio.new_event_loop()
     loop.run_until_complete(main())

marznode/__init__.py

@@ -1,4 +1,5 @@
 """Initiate logger for marznode"""
+
 import logging
 
 from marznode import config

marznode/backends/base.py

@@ -0,0 +1,37 @@
+"""What a vpn server should do"""
+
+from abc import ABC, abstractmethod
+from collections.abc import AsyncIterator
+from typing import Any
+
+from marznode.models import User, Inbound
+
+
+class VPNBackend(ABC):
+    @abstractmethod
+    def contains_tag(self, tag: str) -> bool:
+        raise NotImplementedError
+
+    @abstractmethod
+    async def start(self) -> None:
+        raise NotImplementedError
+
+    @abstractmethod
+    async def restart(self, backend_config: Any) -> None:
+        raise NotImplementedError
+
+    @abstractmethod
+    async def add_user(self, user: User, inbound: Inbound) -> None:
+        raise NotImplementedError
+
+    @abstractmethod
+    async def remove_user(self, user: User, inbound: Inbound) -> None:
+        raise NotImplementedError
+
+    @abstractmethod
+    def get_logs(self, include_buffer: bool) -> AsyncIterator:
+        raise NotImplementedError
+
+    @abstractmethod
+    async def get_usages(self):
+        raise NotImplementedError