forked from sangge/tpre-python
test: test
This commit is contained in:
parent
1c41ab94b2
commit
558552a441
@ -112,8 +112,8 @@ async def receive_messages(message: C):
|
|||||||
return:
|
return:
|
||||||
status_code
|
status_code
|
||||||
"""
|
"""
|
||||||
C_tuple = message.Tuple
|
a,b = message.Tuple
|
||||||
|
C_tuple = (a, b.to_bytes(32))
|
||||||
ip = message.ip
|
ip = message.ip
|
||||||
if not C_tuple or not ip:
|
if not C_tuple or not ip:
|
||||||
raise HTTPException(status_code=400, detail="Invalid input data")
|
raise HTTPException(status_code=400, detail="Invalid input data")
|
||||||
|
@ -95,10 +95,11 @@ async def user_src(message: Req):
|
|||||||
source_ip = message.source_ip
|
source_ip = message.source_ip
|
||||||
dest_ip = message.dest_ip
|
dest_ip = message.dest_ip
|
||||||
capsule, ct = message.capsule_ct
|
capsule, ct = message.capsule_ct
|
||||||
capsule_ct = (capsule, ct.to_bytes())
|
capsule_ct = (capsule, ct.to_bytes(32))
|
||||||
rk = message.rk
|
rk = message.rk
|
||||||
|
|
||||||
processed_message = ReEncrypt(rk, capsule_ct)
|
a, b = ReEncrypt(rk, capsule_ct)
|
||||||
|
processed_message = (a, int.from_bytes(b))
|
||||||
await send_user_des_message(source_ip, dest_ip, processed_message)
|
await send_user_des_message(source_ip, dest_ip, processed_message)
|
||||||
return HTTPException(status_code=200, detail="message recieved")
|
return HTTPException(status_code=200, detail="message recieved")
|
||||||
|
|
||||||
|
Loading…
x
Reference in New Issue
Block a user