Commit 2e7dd14f authored by ibuler's avatar ibuler

Merge branch 'dev' into test

parents 98db81c9 1e10d275
...@@ -3,6 +3,7 @@ ...@@ -3,6 +3,7 @@
import threading import threading
import datetime import datetime
import weakref import weakref
import time
from . import char from . import char
from . import utils from . import utils
...@@ -250,7 +251,10 @@ class WSProxy: ...@@ -250,7 +251,10 @@ class WSProxy:
continue continue
if len(data) == 0: if len(data) == 0:
self.close() self.close()
self.ws.emit("data", {'data': data.decode("utf-8"), 'room': self.connection}, room=self.room) data = data.decode(errors="ignore")
self.ws.emit("data", {'data': data, 'room': self.connection}, room=self.room)
if len(data) == BUF_SIZE:
time.sleep(0.1)
def auto_forward(self): def auto_forward(self):
thread = threading.Thread(target=self.forward, args=()) thread = threading.Thread(target=self.forward, args=())
......
...@@ -87,10 +87,12 @@ class ProxyServer: ...@@ -87,10 +87,12 @@ class ProxyServer:
pass pass
def get_proxy_sock(self, asset): def get_proxy_sock(self, asset):
sock = None
domain = self.app.service.get_domain_detail_with_gateway( domain = self.app.service.get_domain_detail_with_gateway(
asset.domain asset.domain
) )
sock = None if not domain.gateways:
return None
for i in domain.gateways: for i in domain.gateways:
gateway = domain.random_gateway() gateway = domain.random_gateway()
proxy_command = [ proxy_command = [
......
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment