sangge/tpre-python
2
1
Fork 1
Code Issues 6 Pull Requests Packages Projects 1 Activity

Merge pull request 'main' (#23) from dqy/mimajingsai:main into main
All checks were successful
Test CI / test speed (push) Successful in 19s
Details

Browse Source 
Reviewed-on: sangge/mimajingsai#23
This commit is contained in:
sangge 2023-11-19 20:57:53 +08:00
commit 141860e56d
1 changed files with 13 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

15
src/client.py
View File

@ -15,6 +15,13 @@ import pickle
from fastapi.responses import JSONResponse from fastapi.responses import JSONResponse
import asyncio import asyncio
# 测试文本
test_msessgaes = {
"name": b"proxy re-encryption",
"environment": b"distributed environment",
"usage": b"data sharing",
}
@asynccontextmanager @asynccontextmanager
async def lifespan(app: FastAPI): async def lifespan(app: FastAPI):
@ -211,7 +218,7 @@ def check_merge(ct: int, ip: str):
print("pk:", type(pk)) print("pk:", type(pk))
print("pk_sender:", type(pk_sender)) print("pk_sender:", type(pk_sender))
print("cfrags:", type(cfrags)) print("cfrags:", type(cfrags))
message = DecryptFrags(sk, pk, pk_sender, cfrags) message = DecryptFrags(sk, pk, pk_sender, cfrags) # type: ignore
print("merge success", message) print("merge success", message)
node_response = True node_response = True
@ -359,7 +366,11 @@ async def receive_request(i_m: IP_Message):
# message name # message name
# message_name = i_m.message_name # message_name = i_m.message_name
# message = xxxxx # message = xxxxx
message = b"hello world" + random.randbytes(8)
# 根据message name到测试文本查找对应值
message = test_msessgaes[i_m.message_name]
# message = b"hello world" + random.randbytes(8)
print(f"Generated message: {message}") print(f"Generated message: {message}")
# send message to nodes # send message to nodes