diff --git a/Builder/Brook.py b/Builder/Brook.py index 37b1eb5..2154d65 100644 --- a/Builder/Brook.py +++ b/Builder/Brook.py @@ -35,5 +35,4 @@ def load(proxyInfo: dict, socksInfo: dict, configFile: str) -> tuple[list, str, }[proxyInfo['stream']['type']](proxyInfo) + [ '--socks5', '%s:%i' % (hostFormat(socksInfo['addr'], v6Bracket = True), socksInfo['port']) ] - print(brookCommand) return brookCommand, 'Config file %s no need' % configFile, {} diff --git a/Tester/Brook.py b/Tester/Brook.py new file mode 100644 index 0000000..30eb8c7 --- /dev/null +++ b/Tester/Brook.py @@ -0,0 +1,102 @@ +#!/usr/bin/env python3 +# -*- coding: utf-8 -*- + +import copy +import itertools +from Builder import Brook +from Basis.Logger import logging +from Basis.Process import Process +from Basis.Functions import genFlag +from Basis.Functions import hostFormat +from Basis.Functions import getAvailablePort + +settings = { + 'serverBind': '127.0.0.1', + 'clientBind': '127.0.0.1', + # 'serverBind': '::1', + # 'clientBind': '::1', + 'workDir': '/tmp/ProxyC', + 'host': '343.re', + 'cert': '/etc/ssl/certs/343.re/fullchain.pem', + 'key': '/etc/ssl/certs/343.re/privkey.pem', +} + + +def originStream(isUot: bool) -> dict: + return { + 'caption': 'original' + (' (UDP over TCP)' if isUot else ''), + 'info': { + 'type': 'origin', + 'uot': isUot, + }, + 'command': lambda proxyInfo: ['server'] + [ # callback function for loading brook command + '--listen', '%s:%i' % (hostFormat(proxyInfo['server'], v6Bracket = True), proxyInfo['port']), + '--password', proxyInfo['passwd'], + ] + } + + +def loadWsCommand(proxyInfo: dict) -> list: # load start command for brook server + return ([ + 'wsserver', '--listen', '%s:%i' % (hostFormat(proxyInfo['server'], v6Bracket = True), proxyInfo['port']) + ] if proxyInfo['stream']['secure'] is None else [ + 'wssserver', '--domainaddress', '%s:%i' % (proxyInfo['stream']['host'], proxyInfo['port']) + ]) + [ + '--path', proxyInfo['stream']['path'], + '--password', proxyInfo['passwd'], + ] + ([] if proxyInfo['stream']['secure'] is None else [ + '--cert', settings['cert'], + '--certkey', settings['key'], + ]) + (['--withoutBrookProtocol'] if proxyInfo['stream']['raw'] else []) + + +def wsStream(isRaw: bool, isSecure: bool): + return { + 'caption': 'websocket' + (' (with tls)' if isSecure else '') + (' (without brook)' if isRaw else ''), + 'info': { + 'type': 'ws', + 'host': settings['host'], + 'path': '/' + genFlag(length = 6), + 'raw': isRaw, + 'secure': {'verify': True} if isSecure else None, + }, + 'command': loadWsCommand # callback function for loading brook command + } + + +def loadTest(stream: dict) -> dict: + proxyInfo = { + 'server': settings['serverBind'], + 'port': getAvailablePort(), + 'passwd': genFlag(), + 'stream': stream['info'] + } + socksInfo = { # socks5 interface for test + 'addr': settings['clientBind'], + 'port': getAvailablePort() + } + clientCommand, _, _ = Brook.load(proxyInfo, socksInfo, '') + serverCommand = ['brook', '--debug', '--listen', ':'] + stream['command'](proxyInfo) + testInfo = { # release test info + 'title': 'Brook test: ' + stream['caption'], + 'client': Process(settings['workDir'], cmd = clientCommand, isStart = False), + 'server': Process(settings['workDir'], cmd = serverCommand, isStart = False), + 'socks': socksInfo, # exposed socks5 address + 'interface': { + 'addr': proxyInfo['server'], + 'port': proxyInfo['port'], + } + } + logging.debug('New brook test -> %s' % testInfo) + return testInfo + + +def load(): + streams = [] + addStream = lambda x: streams.append(copy.deepcopy(x)) + for isUot in [False, True]: + addStream(originStream(isUot)) # origin stream test + for isSecure, isRaw in itertools.product([False, True], [False, True]): + addStream(wsStream(isRaw, isSecure)) # websocket stream test + for stream in streams: + yield loadTest(stream) diff --git a/test.py b/test.py index 1bc2e00..acc31d3 100755 --- a/test.py +++ b/test.py @@ -5,6 +5,7 @@ import time import requests from threading import Thread +from Tester import Brook from Tester import VMess from Tester import VLESS from Tester import Trojan @@ -101,6 +102,7 @@ vmess = VMess.load() vless = VLESS.load() trojan = Trojan.load() trojanGo = TrojanGo.load() +brook = Brook.load() logging.critical('test start') # runTest(ss, 64) @@ -108,5 +110,6 @@ logging.critical('test start') # runTest(vmess, 64) # runTest(vless, 64) # runTest(trojan, 64) -runTest(trojanGo, 64) +# runTest(trojanGo, 64) +runTest(brook, 64) logging.critical('test complete')