Add web api

Author: pjialin

config.toml.example

@@ -1,6 +1,10 @@
 [app]
 env = "production"
 
+[web]
+host = "127.0.0.1"
+port = 8080
+
 [redis]
 address = "redis://127.0.0.1:6379"
 db = 1

main.py

@@ -1,4 +1,6 @@
 import asyncio
+
+from src.app.web import Web
 from src.app.ip_checker import IPChecker
 from src.sites import *
 from src.app.ip_get import IPGet
@@ -9,6 +11,7 @@ def main():
     tasks = []
     tasks.append(IPGet.share().run())
     tasks.append(IPChecker().run())
+    Web().start()
     loop.run_until_complete(asyncio.wait(tasks))
 
 

src/app/main.py

@@ -18,6 +18,10 @@ class AppEnvType:
     # Coroutine count
     COROUTINE_COUNT_IP_CHECK = 20
 
+    WEB = {
+        'host': '0.0.0.0',
+        'port': 8008
+    }
     # Config
     REDIS = {
         'address': '127.0.0.1:6379',
@@ -61,6 +65,10 @@ def load(cls):
         if redis:
             cls.REDIS.update(redis)
 
+        web = configs.get('web')
+        if redis:
+            cls.WEB.update(web)
+
         app = configs.get('app')
         if app:
             cls.APP_ENV = app.get('env', cls.APP_ENV)

src/app/web.py

@@ -0,0 +1,25 @@
+from sanic import Sanic
+from sanic.response import json
+from multiprocessing import Process
+
+from src.app.ip_factory import IPFactory
+from src.app.main import Config
+
+app = Sanic()
+
+
+class Web(Process):
+
+    def run(self):
+        app.run(**Config.WEB)
+
+
+@app.route('/get_ip')
+async def get_ip(request):
+    ip = await IPFactory.get_random_ip(bool(request.raw_args.get('https', False)))
+    return json({
+        'ip': ip.ip,
+        'port': ip.port,
+        # 'https': ip.https,
+        'http': ip.to_http(),
+    })

src/lib/structs.py

@@ -3,11 +3,11 @@
 
 
 class IPData(DataHelper):
-    ip: str
-    port: int
-    delay: float
-    http: bool
-    https: bool
+    ip: str = ''
+    port: int = 0
+    delay: float = 0.0
+    http: bool = False
+    https: bool = False
     score: float = Config.DEFAULT_SCORE
 
     @classmethod