mirror of
https://github.com/Flowseal/tg-ws-proxy.git
synced 2026-09-06 01:57:01 +00:00
TODOs
This commit is contained in:
@@ -14,11 +14,14 @@ from .utils import ws_domains, DC_DEFAULT_IPS
|
|||||||
|
|
||||||
log = logging.getLogger('tg-mtproto-proxy')
|
log = logging.getLogger('tg-mtproto-proxy')
|
||||||
|
|
||||||
|
# TODO: domains handling is completely broken: wrong is_media flag causes tcp_reset,
|
||||||
|
# but initial connection is still established no matter what is is_media flag is set to
|
||||||
class _WsPool:
|
class _WsPool:
|
||||||
WS_POOL_MAX_AGE = 120.0
|
WS_POOL_MAX_AGE = 120.0
|
||||||
WS_POOL_CHECK_INTERVAL = 5.0
|
WS_POOL_CHECK_INTERVAL = 5.0
|
||||||
REFILL_BACKOFF_INITIAL = 60.0
|
REFILL_BACKOFF_INITIAL = 60.0
|
||||||
REFILL_BACKOFF_MAX = 3600.0
|
REFILL_BACKOFF_MAX = 3600.0
|
||||||
|
# TODO: Lower refill backoff timer
|
||||||
|
|
||||||
def __init__(self):
|
def __init__(self):
|
||||||
self._idle: Dict[Tuple[int, bool], deque] = {}
|
self._idle: Dict[Tuple[int, bool], deque] = {}
|
||||||
|
|||||||
@@ -339,6 +339,10 @@ async def _handle_client(reader, writer, secret: bytes):
|
|||||||
ws_timed_out = False
|
ws_timed_out = False
|
||||||
all_redirects = True
|
all_redirects = True
|
||||||
|
|
||||||
|
# TODO: Sometimes connection is established, and sometimes its timed out
|
||||||
|
# So we don't need to fully restrict pool refill, let it try connecting
|
||||||
|
# in the background. May be remove direct connection there completely and
|
||||||
|
# only use pool for them? But need to fix domains handling first
|
||||||
allow_pool_refill = now >= ip_fail_until.get(target, 0)
|
allow_pool_refill = now >= ip_fail_until.get(target, 0)
|
||||||
ws = await ws_pool.get(
|
ws = await ws_pool.get(
|
||||||
dc, is_media, target, domains,
|
dc, is_media, target, domains,
|
||||||
|
|||||||
Reference in New Issue
Block a user