move mitmproxy

1 files changed, 138 insertions, 0 deletions

diff --git a/mitmproxy/libmproxy/main.py b/mitmproxy/libmproxy/main.py
new file mode 100644
index 00000000..ef135754
--- /dev/null
+++ b/mitmproxy/libmproxy/main.py
@@ -0,0 +1,138 @@
+from __future__ import print_function, absolute_import
+import os
+import signal
+import sys
+import thread
+from netlib.version_check import check_pyopenssl_version, check_mitmproxy_version
+from . import version, cmdline
+from .exceptions import ServerException
+from .proxy.server import DummyServer, ProxyServer
+from .proxy.config import process_proxy_options
+
+
+def assert_utf8_env():
+    spec = ""
+    for i in ["LANG", "LC_CTYPE", "LC_ALL"]:
+        spec += os.environ.get(i, "").lower()
+    if "utf" not in spec:
+        print(
+            "Error: mitmproxy requires a UTF console environment.",
+            file=sys.stderr
+        )
+        print(
+            "Set your LANG enviroment variable to something like en_US.UTF-8",
+            file=sys.stderr
+        )
+        sys.exit(1)
+
+
+def get_server(dummy_server, options):
+    if dummy_server:
+        return DummyServer(options)
+    else:
+        try:
+            return ProxyServer(options)
+        except ServerException as v:
+            print(str(v), file=sys.stderr)
+            sys.exit(1)
+
+
+def mitmproxy(args=None):  # pragma: no cover
+    if os.name == "nt":
+        print("Error: mitmproxy's console interface is not supported on Windows. "
+              "You can run mitmdump or mitmweb instead.", file=sys.stderr)
+        sys.exit(1)
+    from . import console
+
+    check_pyopenssl_version()
+    check_mitmproxy_version(version.IVERSION)
+    assert_utf8_env()
+
+    parser = cmdline.mitmproxy()
+    options = parser.parse_args(args)
+    if options.quiet:
+        options.verbose = 0
+
+    proxy_config = process_proxy_options(parser, options)
+    console_options = console.Options(**cmdline.get_common_options(options))
+    console_options.palette = options.palette
+    console_options.palette_transparent = options.palette_transparent
+    console_options.eventlog = options.eventlog
+    console_options.follow = options.follow
+    console_options.intercept = options.intercept
+    console_options.limit = options.limit
+    console_options.no_mouse = options.no_mouse
+
+    server = get_server(console_options.no_server, proxy_config)
+
+    m = console.ConsoleMaster(server, console_options)
+    try:
+        m.run()
+    except (KeyboardInterrupt, thread.error):
+        pass
+
+
+def mitmdump(args=None):  # pragma: no cover
+    from . import dump
+
+    check_pyopenssl_version()
+    check_mitmproxy_version(version.IVERSION)
+
+    parser = cmdline.mitmdump()
+    options = parser.parse_args(args)
+    if options.quiet:
+        options.verbose = 0
+        options.flow_detail = 0
+
+    proxy_config = process_proxy_options(parser, options)
+    dump_options = dump.Options(**cmdline.get_common_options(options))
+    dump_options.flow_detail = options.flow_detail
+    dump_options.keepserving = options.keepserving
+    dump_options.filtstr = " ".join(options.args) if options.args else None
+
+    server = get_server(dump_options.no_server, proxy_config)
+
+    try:
+        master = dump.DumpMaster(server, dump_options)
+
+        def cleankill(*args, **kwargs):
+            master.shutdown()
+
+        signal.signal(signal.SIGTERM, cleankill)
+        master.run()
+    except dump.DumpError as e:
+        print("mitmdump: %s" % e, file=sys.stderr)
+        sys.exit(1)
+    except (KeyboardInterrupt, thread.error):
+        pass
+
+
+def mitmweb(args=None):  # pragma: no cover
+    from . import web
+
+    check_pyopenssl_version()
+    check_mitmproxy_version(version.IVERSION)
+
+    parser = cmdline.mitmweb()
+
+    options = parser.parse_args(args)
+    if options.quiet:
+        options.verbose = 0
+
+    proxy_config = process_proxy_options(parser, options)
+    web_options = web.Options(**cmdline.get_common_options(options))
+    web_options.intercept = options.intercept
+    web_options.wdebug = options.wdebug
+    web_options.wiface = options.wiface
+    web_options.wport = options.wport
+    web_options.wsingleuser = options.wsingleuser
+    web_options.whtpasswd = options.whtpasswd
+    web_options.process_web_options(parser)
+
+    server = get_server(web_options.no_server, proxy_config)
+
+    m = web.WebMaster(server, web_options)
+    try:
+        m.run()
+    except (KeyboardInterrupt, thread.error):
+        pass