Support/sp-hydra-veil-core
Support/sp-hydra-veil-core
2
0
Fork 0
Code Issues Pull requests 1 Projects Releases Packages Wiki Activity Actions

Let async bulk skip verification if they just came from verification via single api

Browse source
This commit is contained in:
SimplifiedPrivacy 2026-08-05 03:03:52 -04:00
parent b70818f774
commit a5f57f4f5e
1 changed files with 2 additions and 5 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

7
core/services/networking/httpx/connect.py
View file

@ -208,7 +208,7 @@ def bulk_async(wanted_list: list, observer: ConnectionObserver, client_observer:
######################################################## ########################################################
if connection_type == ConnectionChoice.SYSTEM: if connection_type == ConnectionChoice.SYSTEM:
logger.info("We are entering a clearweb async bulk..") logger.info("We are entering a clearweb async bulk..")
return async_parallel(desired_endpoints=desired_endpoints, client_observer=client_observer, port=None) return async_parallel(desired_endpoints=desired_endpoints, client_observer=client_observer, port=None, already_checked=True)
######################################################## ########################################################
@ -216,15 +216,12 @@ def bulk_async(wanted_list: list, observer: ConnectionObserver, client_observer:
######################################################## ########################################################
if _port_used is None: if _port_used is None:
_port_used = Constants.DEFAULT_TOR_PORT _port_used = Constants.DEFAULT_TOR_PORT
already_checked = False
else:
already_checked = True
# check if that (default) port is even listening: # check if that (default) port is even listening:
listening = ports.is_port_in_use(_port_used) listening = ports.is_port_in_use(_port_used)
if listening: if listening:
results = async_parallel(desired_endpoints=desired_endpoints, client_observer=client_observer, port=_port_used, already_checked=already_checked) results = async_parallel(desired_endpoints=desired_endpoints, client_observer=client_observer, port=_port_used, already_checked=True)
else: else:
new_port = just_only_bootstrap_port(port_used=_port_used, observer=observer) new_port = just_only_bootstrap_port(port_used=_port_used, observer=observer)
if new_port: if new_port: