diff --git a/src/keria/app/agenting.py b/src/keria/app/agenting.py index e03b565..1868797 100644 --- a/src/keria/app/agenting.py +++ b/src/keria/app/agenting.py @@ -26,6 +26,8 @@ from keri.core.coring import Ilks, randomNonce from keri.db import dbing from keri.db.basing import OobiRecord +from keri.vc import protocoling + from keria.end import ending from keri.help import helping, ogler from keri.peer import exchanging @@ -324,6 +326,7 @@ def __init__(self, hby, rgy, agentHab, agency, caid, **opts): handlers = [challengeHandler] self.exc = exchanging.Exchanger(hby=hby, handlers=handlers) grouping.loadHandlers(exc=self.exc, mux=self.mux) + protocoling.loadHandlers(hby=self.hby, exc=self.exc, rgy=self.rgy, notifier=self.notifier) self.rvy = routing.Revery(db=hby.db, cues=self.cues) self.kvy = eventing.Kevery(db=hby.db, diff --git a/src/keria/app/aiding.py b/src/keria/app/aiding.py index ebc8054..1f81a4d 100644 --- a/src/keria/app/aiding.py +++ b/src/keria/app/aiding.py @@ -694,6 +694,16 @@ class EndRoleCollectionEnd: @staticmethod def on_get(req, rep, name=None, aid=None, role=None): + """ GET endpoint for end role collection + + Parameters: + req (Request): falcon HTTP request object + rep (Response): falcon HTTP response object + name (str): human readable alias for AID + aid (str): aid to use instead of name + role (str): optional role to search for + + """ agent = req.context.agent if name is not None: @@ -721,7 +731,7 @@ def on_get(req, rep, name=None, aid=None, role=None): @staticmethod def on_post(req, rep, name, aid=None, role=None): - """ + """ POST endpoint for end role collection Args: req (Request): Falcon HTTP request object @@ -761,21 +771,6 @@ def on_post(req, rep, name, aid=None, role=None): except kering.UnverifiedReplyError: pass - if isinstance(hab, habbing.SignifyGroupHab): - seal = eventing.SealEvent(i=hab.kever.prefixer.qb64, - s=hex(hab.kever.lastEst.s), - d=hab.kever.lastEst.d) - msg = eventing.messagize(serder=rserder, - sigers=rsigers, - seal=seal, - pipelined=True) - atc = bytes(msg[rserder.size:]) - - others = [smid for smid in hab.db.signingMembers(hab.pre) if smid != hab.mhab.pre] - for o in others: - agent.postman.send(hab=agent.agentHab, dest=o, topic="multisig", serder=rserder, - attachment=atc) - oid = ".".join([pre, role, eid]) op = agent.monitor.submit(oid, longrunning.OpTypes.endrole, metadata=dict(cid=pre, role=role, eid=eid))