aboutsummaryrefslogtreecommitdiffstats
path: root/pathod/pathod.py
diff options
context:
space:
mode:
Diffstat (limited to 'pathod/pathod.py')
-rw-r--r--pathod/pathod.py28
1 files changed, 15 insertions, 13 deletions
diff --git a/pathod/pathod.py b/pathod/pathod.py
index 0f659d40..a8658361 100644
--- a/pathod/pathod.py
+++ b/pathod/pathod.py
@@ -4,16 +4,18 @@ import os
import sys
import threading
-from netlib import tcp
-from netlib import certutils
-from netlib import websockets
-from netlib import version
+from mitmproxy.net import tcp
+from mitmproxy import certs as mcerts
+from mitmproxy.net import websockets
+from mitmproxy import version
import urllib
-from netlib.exceptions import HttpException, HttpReadDisconnect, TcpTimeout, TcpDisconnect, \
- TlsException
+from mitmproxy import exceptions
-from . import language, utils, log, protocols
+from pathod import language
+from pathod import utils
+from pathod import log
+from pathod import protocols
DEFAULT_CERT_DOMAIN = b"pathod.net"
@@ -52,7 +54,7 @@ class SSLOptions:
self.ssl_options = ssl_options
self.ciphers = ciphers
self.alpn_select = alpn_select
- self.certstore = certutils.CertStore.from_store(
+ self.certstore = mcerts.CertStore.from_store(
os.path.expanduser(confdir),
CERTSTORE_BASENAME
)
@@ -128,9 +130,9 @@ class PathodHandler(tcp.BaseHandler):
with logger.ctx() as lg:
try:
req = self.protocol.read_request(self.rfile)
- except HttpReadDisconnect:
+ except exceptions.HttpReadDisconnect:
return None, None
- except HttpException as s:
+ except exceptions.HttpException as s:
s = str(s)
lg(s)
return None, dict(type="error", msg=s)
@@ -252,7 +254,7 @@ class PathodHandler(tcp.BaseHandler):
options=self.server.ssloptions.ssl_options,
alpn_select=self.server.ssloptions.alpn_select,
)
- except TlsException as v:
+ except exceptions.TlsException as v:
s = str(v)
self.server.add_log(
dict(
@@ -384,7 +386,7 @@ class Pathod(tcp.TCPServer):
try:
h.handle()
h.finish()
- except TcpDisconnect: # pragma: no cover
+ except exceptions.TcpDisconnect: # pragma: no cover
log.write_raw(self.logfp, "Disconnect")
self.add_log(
dict(
@@ -393,7 +395,7 @@ class Pathod(tcp.TCPServer):
)
)
return
- except TcpTimeout:
+ except exceptions.TcpTimeout:
log.write_raw(self.logfp, "Timeout")
self.add_log(
dict(