-
Notifications
You must be signed in to change notification settings - Fork 55
Commit
This commit does not belong to any branch on this repository, and may belong to a fork outside of the repository.
Updates in support of group multisig endpoints for Agents (#550)
* Add support for reloading a SignifyGroupHab from the HabitatRecord. * Update end role authorization handling to support multiple end roles per rpy * Undo previous commit * `kli ends add` and `kli multisig ends add` command added to support exposing multiple endpoint role authorizations for a group multisig AID. * Removing some new exceptions that were in for debugging purposes.
- Loading branch information
1 parent
a10762b
commit a40c63c
Showing
13 changed files
with
447 additions
and
58 deletions.
There are no files selected for viewing
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| Original file line number | Diff line number | Diff line change |
|---|---|---|
| @@ -0,0 +1,102 @@ | ||
| # -*- encoding: utf-8 -*- | ||
| """ | ||
| KERI | ||
| keri.kli.commands module | ||
| """ | ||
| import argparse | ||
|
|
||
| from hio import help | ||
| from hio.base import doing | ||
|
|
||
| from keri import kering | ||
| from keri.app import habbing | ||
| from keri.app.agenting import WitnessPublisher | ||
| from keri.app.cli.common import existing | ||
| from keri.core import parsing | ||
|
|
||
| logger = help.ogler.getLogger() | ||
|
|
||
| parser = argparse.ArgumentParser(description='Add new endpoint role authorization.') | ||
| parser.set_defaults(handler=lambda args: add_end(args), | ||
| transferable=True) | ||
| parser.add_argument('--name', '-n', help='keystore name and file location of KERI keystore', required=True) | ||
| parser.add_argument('--base', '-b', help='additional optional prefix to file location of KERI keystore', | ||
| required=False, default="") | ||
| parser.add_argument('--alias', '-a', help='human readable alias for the new identifier prefix', required=True) | ||
| parser.add_argument('--passcode', '-p', help='22 character encryption passcode for keystore (is not saved)', | ||
| dest="bran", default=None) # passcode => bran | ||
| parser.add_argument("--role", "-r", help="KERI enpoint authorization role.", | ||
| required=True) | ||
| parser.add_argument("--eid", "-e", help="qualified base64 of AID to authorize with new role for the AID identified " | ||
| "by alias", | ||
| required=True) | ||
|
|
||
|
|
||
| def add_end(args): | ||
| """ Command line tool for adding endpoint role authorizations | ||
| """ | ||
| ld = RoleDoer(name=args.name, | ||
| base=args.base, | ||
| alias=args.alias, | ||
| bran=args.bran, | ||
| role=args.role, | ||
| eid=args.eid) | ||
| return [ld] | ||
|
|
||
|
|
||
| class RoleDoer(doing.DoDoer): | ||
|
|
||
| def __init__(self, name, base, alias, bran, role, eid): | ||
| self.role = role | ||
| self.eid = eid | ||
|
|
||
| self.hby = existing.setupHby(name=name, base=base, bran=bran) | ||
| self.hab = self.hby.habByName(alias) | ||
| self.witpub = WitnessPublisher(hby=self.hby) | ||
|
|
||
| if self.hab is None: | ||
| raise kering.ConfigurationError(f"unknown alias={alias}") | ||
|
|
||
| doers = [self.witpub, doing.doify(self.roleDo)] | ||
|
|
||
| super(RoleDoer, self).__init__(doers=doers) | ||
|
|
||
| def roleDo(self, tymth, tock=0.0): | ||
| """ Export any end reply messages previous saved for the provided AID | ||
| Parameters: | ||
| tymth (function): injected function wrapper closure returned by .tymen() of | ||
| Tymist instance. Calling tymth() returns associated Tymist .tyme. | ||
| tock (float): injected initial tock value | ||
| Returns: doifiable Doist compatible generator method | ||
| """ | ||
| # enter context | ||
| self.wind(tymth) | ||
| self.tock = tock | ||
| _ = (yield self.tock) | ||
| if isinstance(self.hab, habbing.GroupHab): | ||
| raise ValueError("group AIDs not supported, try `kli multisig ends add` instead.") | ||
|
|
||
| data = dict(cid=self.hab.pre, role=self.role, eid=self.eid) | ||
|
|
||
| route = "/end/role/add" | ||
| msg = self.hab.reply(route=route, data=data) | ||
|
|
||
| parsing.Parser().parse(ims=bytes(msg), kvy=self.hab.kvy, rvy=self.hab.rvy) | ||
|
|
||
| while not self.hab.loadEndRole(cid=self.hab.pre, role=self.role, eid=self.eid): | ||
| yield self.tock | ||
|
|
||
| self.witpub.msgs.append(dict(pre=self.hab.pre, msg=bytes(msg))) | ||
|
|
||
| while not self.witpub.cues: | ||
| yield self.tock | ||
|
|
||
| print(f"End role authorization added for role {self.role}") | ||
|
|
||
| self.remove([self.witpub]) | ||
| return |
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| Original file line number | Diff line number | Diff line change |
|---|---|---|
| @@ -0,0 +1,76 @@ | ||
| # -*- encoding: utf-8 -*- | ||
| """ | ||
| KERI | ||
| keri.kli.commands module | ||
| """ | ||
| import argparse | ||
| import json | ||
|
|
||
| from hio import help | ||
| from hio.base import doing | ||
|
|
||
| from keri import kering | ||
| from keri.app import indirecting, habbing, forwarding, grouping | ||
| from keri.app.cli.common import existing | ||
| from keri.core import eventing, parsing, coring | ||
|
|
||
| logger = help.ogler.getLogger() | ||
|
|
||
| parser = argparse.ArgumentParser(description='Add new endpoint role authorization.') | ||
| parser.set_defaults(handler=lambda args: add_end(args), | ||
| transferable=True) | ||
| parser.add_argument('--name', '-n', help='keystore name and file location of KERI keystore', required=True) | ||
| parser.add_argument('--base', '-b', help='additional optional prefix to file location of KERI keystore', | ||
| required=False, default="") | ||
| parser.add_argument('--alias', '-a', help='human readable alias for the new identifier prefix', required=True) | ||
| parser.add_argument('--passcode', '-p', help='22 character encryption passcode for keystore (is not saved)', | ||
| dest="bran", default=None) # passcode => bran | ||
| parser.add_argument("--aid", help="qualified base64 of AID to export rpy messages for all endpoints.", | ||
| required=True) | ||
|
|
||
|
|
||
| def add_end(args): | ||
| """ Command line tool for adding endpoint role authorizations | ||
| """ | ||
| ld = RoleDoer(name=args.name, | ||
| base=args.base, | ||
| alias=args.alias, | ||
| bran=args.bran, | ||
| aid=args.aid) | ||
| return [ld] | ||
|
|
||
|
|
||
| class RoleDoer(doing.DoDoer): | ||
|
|
||
| def __init__(self, name, base, alias, bran, aid): | ||
| self.hby = existing.setupHby(name=name, base=base, bran=bran) | ||
| self.hab = self.hby.habByName(alias) | ||
| if self.hab is None: | ||
| raise kering.ConfigurationError(f"unknown alias={alias}") | ||
|
|
||
| self.aid = aid | ||
| doers = [doing.doify(self.roleDo)] | ||
|
|
||
| super(RoleDoer, self).__init__(doers=doers) | ||
|
|
||
| def roleDo(self, tymth, tock=0.0): | ||
| """ Export any end reply messages previous saved for the provided AID | ||
| Parameters: | ||
| tymth (function): injected function wrapper closure returned by .tymen() of | ||
| Tymist instance. Calling tymth() returns associated Tymist .tyme. | ||
| tock (float): injected initial tock value | ||
| Returns: doifiable Doist compatible generator method | ||
| """ | ||
| # enter context | ||
| self.wind(tymth) | ||
| self.tock = tock | ||
| _ = (yield self.tock) | ||
|
|
||
| ends = self.hab.endsFor(self.aid) | ||
| print(json.dumps(ends, indent=1)) | ||
| return |
Empty file.
Oops, something went wrong.