diff --git a/src/client.py b/src/client.py index 4c4ae4e..0aa6288 100644 --- a/src/client.py +++ b/src/client.py @@ -199,7 +199,7 @@ async def send_messages( capsule_ct = Encrypt(pk, message) # type: ignore for i in range(len(node_ips)): - url = "http://" + node_ips[i][0] + ":8001" + "/user_src?message" + url = "http://" + node_ips[i][0] + ":8001" + "/user_src" print(url) payload = { "source_ip": local_ip, @@ -207,6 +207,7 @@ async def send_messages( "capsule_ct": capsule_ct, "rk": rk_list[i], } + print(payload) response = requests.post(url, json=payload) if response.status_code == 200: @@ -235,7 +236,7 @@ async def request_message(i_m: Request_Message): message_name = i_m.message_name source_ip = get_own_ip() dest_port = "8002" - url = "http://" + dest_ip + ":" + dest_port + "/recieve_request?i_m" + url = "http://" + dest_ip + ":" + dest_port + "/recieve_request" payload = { "dest_ip": dest_ip, "message_name": message_name, diff --git a/src/client_cli.py b/src/client_cli.py index 458de98..3da6a91 100644 --- a/src/client_cli.py +++ b/src/client_cli.py @@ -1,15 +1,14 @@ import argparse import requests + def send_post_request(ip_addr, message_name): - url = f"http://localhost:8002/request_message/?i_m" - data = { - "dest_ip": ip_addr, - "message_name": message_name - } + url = f"http://localhost:8002/request_message/" + data = {"dest_ip": ip_addr, "message_name": message_name} response = requests.post(url, json=data) return response.text + def main(): parser = argparse.ArgumentParser(description="Send POST request to a specified IP.") parser.add_argument("ip_addr", help="IP address to send request to.") @@ -19,5 +18,6 @@ def main(): response = send_post_request(args.ip_addr, args.message_name) print(response) + if __name__ == "__main__": main() diff --git a/src/node.py b/src/node.py index 8fd270b..aa1719a 100644 --- a/src/node.py +++ b/src/node.py @@ -106,9 +106,7 @@ async def send_user_des_message(source_ip: str, dest_ip: str, re_message): # data = {"Tuple": re_message, "ip": source_ip} # 类型不匹配 # 发送 HTTP POST 请求 - response = requests.post( - "http://" + dest_ip + "/receive_messages?message", json=data - ) + response = requests.post("http://" + dest_ip + "/receive_messages", json=data) print(response)