# -*- coding: utf-8 -*- """ OnionShare | https://onionshare.org/ Copyright (C) 2014-2022 Micah Lee, et al. This program is free software: you can redistribute it and/or modify it under the terms of the GNU General Public License as published by the Free Software Foundation, either version 3 of the License, or (at your option) any later version. This program is distributed in the hope that it will be useful, but WITHOUT ANY WARRANTY; without even the implied warranty of MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the GNU General Public License for more details. You should have received a copy of the GNU General Public License along with this program. If not, see . """ import os import subprocess import time class Meek(object): """ The Meek object starts the meek-client as a subprocess. This process is used to do domain-fronting to connect to the Tor APIs for censorship circumvention and retrieving bridges, before connecting to Tor. """ def __init__(self, common, get_tor_paths=None): """ Set up the Meek object """ self.common = common self.common.log("Meek", "__init__") # Set the path of the meek binary if not get_tor_paths: get_tor_paths = self.common.get_tor_paths ( self.tor_path, self.tor_geo_ip_file_path, self.tor_geo_ipv6_file_path, self.obfs4proxy_file_path, self.snowflake_file_path, self.meek_client_file_path, ) = get_tor_paths() self.meek_proxies = {} self.meek_url = "https://moat.torproject.org.global.prod.fastly.net/" self.meek_front = "cdn.sstatic.net" self.meek_env = { "TOR_PT_MANAGED_TRANSPORT_VER": "1", "TOR_PT_CLIENT_TRANSPORTS": "meek", } self.meek_host = "127.0.0.1" self.meek_port = None def start(self): """ Start the Meek Client and populate the SOCKS proxies dict for use with requests to the Tor Moat API. """ # Abort early if we can't find the Meek client if self.meek_client_file_path is None or not os.path.exists( self.meek_client_file_path ): raise MeekNotFound(self.common) # Start the Meek Client as a subprocess. self.common.log("Meek", "start", "Starting meek client") if self.common.platform == "Windows": env = os.environ.copy() for key in self.meek_env: env[key] = self.meek_env[key] # In Windows, hide console window when opening meek-client.exe subprocess startupinfo = subprocess.STARTUPINFO() startupinfo.dwFlags |= subprocess.STARTF_USESHOWWINDOW self.meek_proc = subprocess.Popen( [ self.meek_client_file_path, "--url", self.meek_url, "--front", self.meek_front, ], stdout=subprocess.PIPE, stderr=subprocess.PIPE, startupinfo=startupinfo, bufsize=1, env=env, text=True, ) else: self.meek_proc = subprocess.Popen( [ self.meek_client_file_path, "--url", self.meek_url, "--front", self.meek_front, ], stdout=subprocess.PIPE, stderr=subprocess.PIPE, bufsize=1, env=self.meek_env, # Using universal_newlines instead of text because the snap package using python < 3.7 universal_newlines=True, ) # Obtain the host and port that meek is running on for line in iter(self.meek_proc.stdout.readline, b""): if "CMETHOD meek socks5" in line: self.meek_host = line.split(" ")[3].split(":")[0] self.meek_port = line.split(" ")[3].split(":")[1] self.common.log( "Meek", "start", f"Meek running on {self.meek_host}:{self.meek_port}", ) break if "CMETHOD-ERROR" in line: self.cleanup() raise MeekNotRunning(self.common, line) break if self.meek_port: self.meek_proxies = { "http": f"socks5h://{self.meek_host}:{self.meek_port}", "https": f"socks5h://{self.meek_host}:{self.meek_port}", } else: self.cleanup() raise MeekNotRunning(self.common, "Could not obtain the meek port") def cleanup(self): """ Kill any meek subprocesses. """ self.common.log("Meek", "cleanup") if self.meek_proc: self.meek_proc.terminate() time.sleep(0.2) if self.meek_proc.poll() is None: self.common.log( "Meek", "cleanup", "Tried to terminate meek-client process but it's still running", ) try: self.meek_proc.kill() time.sleep(0.2) if self.meek_proc.poll() is None: self.common.log( "Meek", "cleanup", "Tried to kill meek-client process but it's still running", ) except Exception: self.common.log( "Meek", "cleanup", "Exception while killing meek-client process" ) self.meek_proc = None # Reset other Meek settings self.meek_proxies = {} self.meek_port = None class MeekNotRunning(Exception): """ We were unable to start Meek or obtain the port number it started on, in order to do domain fronting. """ def __init__(self, common, info=None): self.common = common msg = "Meek experienced an error starting up" if info: msg = msg + f": {info}" self.common.log("MeekNotRunning", "__init__", msg) class MeekNotFound(Exception): """ We were unable to find the Meek Client binary. """ def __init__(self, common): self.common = common self.common.log("MeekNotFound", "__init__", "Could not find the meek binary")