abhinavsingh
diff --git a/‎.github/workflows/test-library.yml‎
Lines changed: 2 additions & 0 deletions b/‎.github/workflows/test-library.yml‎
Lines changed: 2 additions & 0 deletions
diff --git a/‎.gitignore‎
Lines changed: 2 additions & 0 deletions b/‎.gitignore‎
Lines changed: 2 additions & 0 deletions
diff --git a/‎.pre-commit-config.yaml‎
Lines changed: 1 addition & 0 deletions b/‎.pre-commit-config.yaml‎
Lines changed: 1 addition & 0 deletions
diff --git a/‎README.md‎
Lines changed: 107 additions & 76 deletions b/‎README.md‎
Lines changed: 107 additions & 76 deletions
diff --git a/‎benchmark/_proxy.py‎
Lines changed: 4 additions & 3 deletions b/‎benchmark/_proxy.py‎
Lines changed: 4 additions & 3 deletions
diff --git a/‎check.py‎
Lines changed: 1 addition & 0 deletions b/‎check.py‎
Lines changed: 1 addition & 0 deletions
diff --git a/‎docs/conf.py‎
Lines changed: 4 additions & 0 deletions b/‎docs/conf.py‎
Lines changed: 4 additions & 0 deletions
diff --git a/‎examples/ssl_echo_server.py‎
Lines changed: 2 additions & 2 deletions b/‎examples/ssl_echo_server.py‎
Lines changed: 2 additions & 2 deletions
diff --git a/‎examples/task.py‎
Lines changed: 123 additions & 0 deletions b/‎examples/task.py‎
Lines changed: 123 additions & 0 deletions
diff --git a/‎examples/tcp_echo_server.py‎
Lines changed: 2 additions & 2 deletions b/‎examples/tcp_echo_server.py‎
Lines changed: 2 additions & 2 deletions
@@ -597,6 +597,8 @@ jobs:
         $CONTAINER_TAG
         --hostname 0.0.0.0
         --enable-web-server
+        --enable-reverse-proxy
+        --plugin proxy.plugin.ReverseProxyPlugin
         &&
         ./tests/integration/test_integration.sh 8899
 
 
@@ -10,6 +10,8 @@
 .tox
 .python-version
 
+__pycache__
+
 coverage.xml
 proxy.py.iml
 
 
@@ -169,6 +169,7 @@ repos:
     - --strict-optional
     - benchmark/
     - examples/
+    - skeleton/
     - proxy/
     - tests/
     pass_filenames: false
 
@@ -22,9 +22,10 @@
             backlog=65536,
             open_file_limit=65536,
             enable_web_server=True,
-            disable_proxy_server=False,
-            num_acceptors=10,
-            local_executor=1,
+            disable_proxy_server=True,
+            num_acceptors=4,
+            num_workers=10,
+            local_executor=0,
             log_file='/dev/null',
     ) as _:
         while True:
 
@@ -37,6 +37,7 @@
     list(REPO_ROOT.glob('*.py')) +
     list((REPO_ROOT / 'proxy').rglob('*.py')) +
     list((REPO_ROOT / 'examples').rglob('*.py')) +
+    list((REPO_ROOT / 'skeleton').rglob('*.py')) +
     list((REPO_ROOT / 'benchmark').rglob('*.py')) +
     list((REPO_ROOT / 'tests').rglob('*.py'))
 )
 
@@ -283,6 +283,7 @@
     (_any_role, 'work_klass'),
     (_py_class_role, '_asyncio.Task'),
     (_py_class_role, 'asyncio.events.AbstractEventLoop'),
+    (_py_class_role, 'BaseListener'),
     (_py_class_role, 'CacheStore'),
     (_py_class_role, 'Channel'),
     (_py_class_role, 'HttpParser'),
@@ -316,7 +317,10 @@
     (_py_class_role, 'connection.Connection'),
     (_py_class_role, 'EventQueue'),
     (_py_class_role, 'T'),
+    (_py_class_role, 'HostPort'),
+    (_py_class_role, 'TcpOrTlsSocket'),
     (_py_obj_role, 'proxy.core.work.threadless.T'),
     (_py_obj_role, 'proxy.core.work.work.T'),
     (_py_obj_role, 'proxy.core.base.tcp_server.T'),
+    (_py_obj_role, 'proxy.core.work.fd.fd.T'),
 ]
@@ -21,8 +21,8 @@ class EchoSSLServerHandler(BaseTcpServerHandler[TcpClientConnection]):
     """Wraps client socket during initialization."""
 
     @staticmethod
-    def create(**kwargs: Any) -> TcpClientConnection:   # pragma: no cover
-        return TcpClientConnection(**kwargs)
+    def create(*args: Any) -> TcpClientConnection:   # pragma: no cover
+        return TcpClientConnection(*args)
 
     def initialize(self) -> None:
         # Acceptors don't perform TLS handshake.  Perform the same
 
@@ -0,0 +1,123 @@
+# -*- coding: utf-8 -*-
+"""
+    proxy.py
+    ~~~~~~~~
+    ⚡⚡⚡ Fast, Lightweight, Pluggable, TLS interception capable proxy server focused on
+    Network monitoring, controls & Application development, testing, debugging.
+
+    :copyright: (c) 2013-present by Abhinav Singh and contributors.
+    :license: BSD, see LICENSE for more details.
+"""
+import time
+import argparse
+import threading
+import multiprocessing
+from typing import Any
+
+from proxy.core.work import (
+    Work, ThreadlessPool, BaseLocalExecutor, BaseRemoteExecutor,
+)
+from proxy.common.flag import FlagParser
+from proxy.common.backports import NonBlockingQueue
+
+
+class Task:
+    """This will be our work object."""
+
+    def __init__(self, payload: bytes) -> None:
+        self.payload = payload
+        print(payload)
+
+
+class TaskWork(Work[Task]):
+    """This will be our handler class, created for each received work."""
+
+    @staticmethod
+    def create(*args: Any) -> Task:
+        """Work core doesn't know how to create work objects for us, so
+        we must provide an implementation of create method here."""
+        return Task(*args)
+
+
+class LocalTaskExecutor(BaseLocalExecutor):
+    """We'll define a local executor which is capable of receiving
+    log lines over a non blocking queue."""
+
+    def work(self, *args: Any) -> None:
+        task_id = int(time.time())
+        uid = '%s-%s' % (self.iid, task_id)
+        self.works[task_id] = self.create(uid, *args)
+
+
+class RemoteTaskExecutor(BaseRemoteExecutor):
+
+    def work(self, *args: Any) -> None:
+        task_id = int(time.time())
+        uid = '%s-%s' % (self.iid, task_id)
+        self.works[task_id] = self.create(uid, *args)
+
+
+def start_local(flags: argparse.Namespace) -> None:
+    work_queue = NonBlockingQueue()
+    executor = LocalTaskExecutor(iid=1, work_queue=work_queue, flags=flags)
+
+    t = threading.Thread(target=executor.run)
+    t.daemon = True
+    t.start()
+
+    try:
+        i = 0
+        while True:
+            work_queue.put(('%d' % i).encode('utf-8'))
+            i += 1
+    except KeyboardInterrupt:
+        pass
+    finally:
+        executor.running.set()
+        t.join()
+
+
+def start_remote(flags: argparse.Namespace) -> None:
+    pipe = multiprocessing.Pipe()
+    work_queue = pipe[0]
+    executor = RemoteTaskExecutor(iid=1, work_queue=pipe[1], flags=flags)
+
+    p = multiprocessing.Process(target=executor.run)
+    p.daemon = True
+    p.start()
+
+    try:
+        i = 0
+        while True:
+            work_queue.send(('%d' % i).encode('utf-8'))
+            i += 1
+    except KeyboardInterrupt:
+        pass
+    finally:
+        executor.running.set()
+        p.join()
+
+
+def start_remote_pool(flags: argparse.Namespace) -> None:
+    with ThreadlessPool(flags=flags, executor_klass=RemoteTaskExecutor) as pool:
+        try:
+            i = 0
+            while True:
+                work_queue = pool.work_queues[i % flags.num_workers]
+                work_queue.send(('%d' % i).encode('utf-8'))
+                i += 1
+        except KeyboardInterrupt:
+            pass
+
+
+# TODO: TaskWork, LocalTaskExecutor, RemoteTaskExecutor
+# should not be needed, abstract those pieces out in the core
+# for stateless tasks.
+if __name__ == '__main__':
+    flags = FlagParser.initialize(
+        ['--disable-http-proxy'],
+        work_klass=TaskWork,
+    )
+    start_remote_pool(flags)
+    # start_remote(flags)
+    # start_local(flags)
@@ -20,8 +20,8 @@ class EchoServerHandler(BaseTcpServerHandler[TcpClientConnection]):
     """Sets client socket to non-blocking during initialization."""
 
     @staticmethod
-    def create(**kwargs: Any) -> TcpClientConnection:   # pragma: no cover
-        return TcpClientConnection(**kwargs)
+    def create(*args: Any) -> TcpClientConnection:   # pragma: no cover
+        return TcpClientConnection(*args)
 
     def initialize(self) -> None:
         self.work.connection.setblocking(False)
Original file line number	Diff line number	Diff line change
`@@ -37,6 +37,7 @@`
`37`	`37`	`list(REPO_ROOT.glob('*.py')) +`
`38`	`38`	`list((REPO_ROOT / 'proxy').rglob('*.py')) +`
`39`	`39`	`list((REPO_ROOT / 'examples').rglob('*.py')) +`
	`40`	`+ list((REPO_ROOT / 'skeleton').rglob('*.py')) +`
`40`	`41`	`list((REPO_ROOT / 'benchmark').rglob('*.py')) +`
`41`	`42`	`list((REPO_ROOT / 'tests').rglob('*.py'))`
`42`	`43`	`)`