Nucypher
/
nucypher
mirror of https://github.com/nucypher/nucypher.git
1
0
Fork 0
Code Issues Projects Releases Wiki Activity

Add logging when revoking

pull/521/head
tuxxy 2018-11-28 16:46:29 -07:00
parent 0c474883f0
commit ce05b9706d
1 changed files with 5 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

6
nucypher/network/server.py
View File

@ -265,6 +265,7 @@ class ProxyRESTRoutes:
from nucypher.policy.models import Revocation from nucypher.policy.models import Revocation
revocation = Revocation.from_bytes(request.body) revocation = Revocation.from_bytes(request.body)
self.log.info("Received revocation: {} -- for arrangement {}".format(bytes(revocation), id_as_hex))
try: try:
with ThreadedSession(self.db_engine) as session: with ThreadedSession(self.db_engine) as session:
# Verify the Notice was signed by Alice # Verify the Notice was signed by Alice
@ -275,13 +276,16 @@ class ProxyRESTRoutes:
# Check that the request is the same for the provided revocation # Check that the request is the same for the provided revocation
if id_as_hex != revocation.arrangement_id.hex(): if id_as_hex != revocation.arrangement_id.hex():
self.log.debug("Couldn't identify an arrangement with id {}".format(id_as_hex))
return Response(status_code=400) return Response(status_code=400)
elif revocation.verify_signature(alice_pubkey): elif revocation.verify_signature(alice_pubkey):
self.datastore.del_policy_arrangement( self.datastore.del_policy_arrangement(
id_as_hex.encode(), session=session) id_as_hex.encode(), session=session)
except (NotFound, InvalidSignature): except (NotFound, InvalidSignature) as e:
self.log.debug("Exception attempting to revoke: {}".format(e))
return Response(content='KFrag not found or revocation signature is invalid.', status_code=404) return Response(content='KFrag not found or revocation signature is invalid.', status_code=404)
else: else:
self.log.info("KFrag successfully removed.")
return Response(content='KFrag deleted!', status_code=200) return Response(content='KFrag deleted!', status_code=200)
def reencrypt_via_rest(self, id_as_hex, request: Request): def reencrypt_via_rest(self, id_as_hex, request: Request):