Skip to content

Commit

Permalink
update
Browse files Browse the repository at this point in the history
Signed-off-by: jamshale <[email protected]>
  • Loading branch information
jamshale committed Feb 28, 2024
1 parent 650dc5d commit 2690a55
Show file tree
Hide file tree
Showing 2 changed files with 6 additions and 2 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -17,6 +17,7 @@
from ....messaging.schemas.util import notify_schema_event
from ....revocation.util import (
notify_revocation_entry_endorsed_event,
notify_revocation_published_event,
notify_revocation_reg_endorsed_event,
)
from ....storage.error import StorageError, StorageNotFoundError
Expand Down Expand Up @@ -861,7 +862,7 @@ async def endorsed_txn_post_processing(
)

elif ledger_response["result"]["txn"]["type"] == "114":
logging.debug(
self._logger.debug(
"---------------------------- Revocation registry entry transaction"
)
# revocation entry transaction
Expand All @@ -878,6 +879,9 @@ async def endorsed_txn_post_processing(
await notify_revocation_entry_endorsed_event(
self._profile, rev_reg_id, meta_data, revoked
)
await notify_revocation_published_event(
self._profile, rev_reg_id, revoked
)

elif ledger_response["result"]["txn"]["type"] == "1":
# write DID to ledger
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -51,10 +51,10 @@ async def on_revocation_published(profile: Profile, event: Event):

for record in records:
await record.delete_record(session)
LOGGER.debug(record.to_message() + " : " + record.connection_id)
await responder.send(
record.to_message(), connection_id=record.connection_id
)
LOGGER.debug("sent message to : " + record.connection_id)

except StorageNotFoundError:
LOGGER.info(
Expand Down

0 comments on commit 2690a55

Please sign in to comment.