example: add hello and proxy/sockproxy

Author: zoumingzhe

example/hello.py

@@ -0,0 +1,29 @@
+# coding:utf-8
+
+import os
+
+from flask import Flask
+from flask import render_template_string
+
+from xhtml import Template
+
+BASE: str = os.path.dirname(__file__)
+TEMPLATE: Template = Template()
+
+
+app = Flask(__name__)
+
+
+@app.route("/favicon.ico", methods=["GET"])
+def favicon():
+    return app.response_class(TEMPLATE.favicon.loadb(), mimetype='image/vnd.microsoft.icon')  # noqa:E501
+
+
+@app.route("/", defaults={"path": ""}, methods=["GET"])
+@app.route("/<path:path>", methods=["GET"])
+def hello(path: str):
+    return render_template_string(TEMPLATE.seek("hello.html").loads())
+
+
+if __name__ == "__main__":
+    app.run(host="0.0.0.0", port=9000)

example/proxy/sockproxy.py

@@ -0,0 +1,70 @@
+# coding:utf-8
+
+import socket
+
+from xkits import ThreadPool
+
+# TARGET_HOST = "example.com"
+# TARGET_PORT = 80
+TARGET_HOST = "localhost"
+TARGET_PORT = 9000
+
+
+class SockRequestHandler():
+    def __init__(self, client_socket: socket.socket):
+        self.__client_socket: socket.socket = client_socket
+        self.__server_socket: socket.socket = socket.create_connection((TARGET_HOST, TARGET_PORT))  # noqa:E501
+
+    def __del__(self):
+        self.server_socket.close()
+        self.client_socket.close()
+
+    @property
+    def server_socket(self) -> socket.socket:
+        return self.__server_socket
+
+    @property
+    def client_socket(self) -> socket.socket:
+        return self.__client_socket
+
+    def send_to_server(self):
+        while (data := self.client_socket.recv(1048576)):
+            print(f"send {len(data)} to server")
+            self.server_socket.sendall(data)
+            # print(data)
+        print("send to server end")
+
+    def send_to_client(self):
+        while (data := self.server_socket.recv(1048576)):
+            print(f"send {len(data)} to client")
+            self.client_socket.sendall(data)
+            # print(data)
+        print("send to client end")
+
+    def run(self):
+        print("socket run")
+        tpool: ThreadPool = ThreadPool()
+        tpool.submit(self.send_to_server)
+        tpool.submit(self.send_to_client)
+        for thd in tpool._threads:
+            print(f"wait thread {thd}")
+            thd.join()
+        print("socket end")
+
+
+def listen(host: str, port: int):
+    server_socket = socket.socket(socket.AF_INET, socket.SOCK_STREAM)
+    server_socket.setsockopt(socket.SOL_SOCKET, socket.SO_REUSEADDR, 1)
+    server_socket.bind((host, port))
+    server_socket.listen(5)
+
+    print(f"Listening on {host}:{port}")
+
+    while True:
+        client_socket, _ = server_socket.accept()
+        print(f"Client Socket: {client_socket}")
+        SockRequestHandler(client_socket).run()
+
+
+if __name__ == "__main__":
+    listen("0.0.0.0", 8000)