midefos/basicswap
1
0
Fork 0
mirror of https://github.com/basicswap/basicswap.git synced 2025-11-05 10:28:10 +01:00
Code Issues Packages Projects Releases Wiki Activity

Update http_server.py

Browse Source
This commit is contained in:
tecnovert
2025-04-04 18:55:23 +00:00
committed by cryptoguard
parent c5908d5e0f
commit 2817d2d8e2
1 changed files with 18 additions and 25 deletions
Download Patch File Download Diff File Expand all files Collapse all files

43
basicswap/http_server.py
View File

@@ -44,6 +44,8 @@ from .js_server import (
) )
from .ui.util import ( from .ui.util import (
getCoinName, getCoinName,
get_data_entry,
get_data_entry_or,
listAvailableCoins, listAvailableCoins,
) )
from .ui.page_automation import ( from .ui.page_automation import (
@@ -189,21 +191,12 @@ class HttpHandler(BaseHTTPRequestHandler):
return os.urandom(8).hex() return os.urandom(8).hex()
def checkForm(self, post_string, name, messages): def checkForm(self, post_string, name, messages):
if not post_string: if post_string == "":
return None return None
post_data_str = ( form_data = parse.parse_qs(post_string)
post_string.decode("utf-8") form_id = form_data[b"formid"][0].decode("utf-8")
if isinstance(post_string, bytes) if self.server.last_form_id.get(name, None) == form_id:
else post_string messages.append("Prevented double submit for form {}.".format(form_id))
)
form_data = parse.parse_qs(post_data_str)
form_id_list = form_data.get("formid", [])
if not form_id_list:
return form_data
form_id = form_id_list[0]
if form_id == self.server.last_form_id.get(name):
messages.append("Form already submitted.")
return None return None
self.server.last_form_id[name] = form_id self.server.last_form_id[name] = form_id
return form_data return form_data
@@ -419,11 +412,11 @@ class HttpHandler(BaseHTTPRequestHandler):
messages = [] messages = []
err_messages = [] err_messages = []
form_data = self.checkForm(post_string, "explorers", err_messages) form_data = self.checkForm(post_string, "explorers", err_messages)
if form_data and form_data is not None: if form_data:
explorer = form_data.get("explorer", ["-1"])[0] explorer = get_data_entry(form_data, "explorer")
action = form_data.get("action", ["-1"])[0] action = get_data_entry(form_data, "action")
args = form_data.get("args", [""])[0] args = get_data_entry_or(form_data, "args", "")
try: try:
c, e = explorer.split("_") c, e = explorer.split("_")
@@ -472,12 +465,12 @@ class HttpHandler(BaseHTTPRequestHandler):
messages = [] messages = []
err_messages = [] err_messages = []
form_data = self.checkForm(post_string, "rpc", err_messages) form_data = self.checkForm(post_string, "rpc", err_messages)
if form_data and form_data is not None: # Check if not None (double submit) if form_data:
try: try:
call_type = form_data.get("call_type", ["cli"])[0] call_type = get_data_entry_or(form_data, "call_type", "cli")
type_map = form_data.get("type_map", [""])[0] type_map = get_data_entry_or(form_data, "type_map", "")
try: try:
coin_type_selected = form_data.get("coin_type", ["-1"])[0] coin_type_selected = get_data_entry(form_data, "coin_type")
coin_type_split = coin_type_selected.split(",") coin_type_split = coin_type_selected.split(",")
coin_type = Coins(int(coin_type_split[0])) coin_type = Coins(int(coin_type_split[0]))
coin_variant = int(coin_type_split[1]) coin_variant = int(coin_type_split[1])
@@ -488,7 +481,7 @@ class HttpHandler(BaseHTTPRequestHandler):
call_type = "http" call_type = "http"
try: try:
cmd = form_data.get("cmd", [""])[0] cmd = get_data_entry(form_data, "cmd")
except Exception: except Exception:
raise ValueError("Invalid command") raise ValueError("Invalid command")
if coin_type in (Coins.XMR, Coins.WOW): if coin_type in (Coins.XMR, Coins.WOW):
@@ -660,7 +653,7 @@ class HttpHandler(BaseHTTPRequestHandler):
self.send_header(header_tuple[0], header_tuple[1]) self.send_header(header_tuple[0], header_tuple[1])
self.end_headers() self.end_headers()
def handle_http(self, status_code, path, post_string=b"", is_json=False): def handle_http(self, status_code, path, post_string="", is_json=False):
swap_client = self.server.swap_client swap_client = self.server.swap_client
parsed = parse.urlparse(self.path) parsed = parse.urlparse(self.path)
url_split = parsed.path.split("/") url_split = parsed.path.split("/")
@@ -720,7 +713,7 @@ class HttpHandler(BaseHTTPRequestHandler):
return b"" return b""
if not post_string and len(parsed.query) > 0: if not post_string and len(parsed.query) > 0:
post_string = parsed.query.encode("utf-8") post_string = parsed.query
if page == "json": if page == "json":
try: try: