Skip to content

Commit

Permalink
Refactor Sealer to Anchorer
Browse files Browse the repository at this point in the history
  • Loading branch information
SmithSamuelM committed Apr 4, 2024
1 parent 2a0c19f commit fb7c6b2
Show file tree
Hide file tree
Showing 5 changed files with 22 additions and 22 deletions.
4 changes: 2 additions & 2 deletions setup.py
Original file line number Diff line number Diff line change
Expand Up @@ -75,8 +75,8 @@
],
python_requires='>=3.12.1',
install_requires=[
'hio>=0.6.9',
'keri @ git+https://[email protected]/weboftrust/keripy.git@development',
'hio>=0.6.12',
'keri>=1.1.0',
'mnemonic>=0.20',
'multicommand>=1.0.0',
'falcon>=3.1.3',
Expand Down
4 changes: 2 additions & 2 deletions src/keria/app/agenting.py
Original file line number Diff line number Diff line change
Expand Up @@ -149,7 +149,7 @@ def createHttpServer(port, app, keypath=None, certpath=None, cafilepath=None):
class Agency(doing.DoDoer):
"""
Agency
"""

def __init__(self, name, bran, base="", configFile=None, configDir=None, adb=None, temp=False):
Expand Down Expand Up @@ -287,7 +287,7 @@ def __init__(self, hby, rgy, agentHab, agency, caid, **opts):
self.agency = agency
self.caid = caid

self.swain = delegating.Sealer(hby=hby, proxy=agentHab)
self.swain = delegating.Anchorer(hby=hby, proxy=agentHab)
self.counselor = Counselor(hby=hby, swain=self.swain, proxy=agentHab)
self.org = connecting.Organizer(hby=hby)

Expand Down
4 changes: 2 additions & 2 deletions src/keria/app/delegating.py
Original file line number Diff line number Diff line change
Expand Up @@ -5,7 +5,7 @@
from keri.db import dbing


class Sealer(doing.DoDoer):
class Anchorer(doing.DoDoer):
"""
Sends messages to Delegator of an identifier and wait for the anchoring event to
be processed to ensure the inception or rotation event has been approved by the delegator.
Expand All @@ -32,7 +32,7 @@ def __init__(self, hby, proxy=None, **kwa):
self.witDoer = agenting.Receiptor(hby=self.hby)
self.proxy = proxy

super(Sealer, self).__init__(doers=[self.witq, self.witDoer, self.postman, doing.doify(self.escrowDo)],
super(Anchorer, self).__init__(doers=[self.witq, self.witDoer, self.postman, doing.doify(self.escrowDo)],
**kwa)

def delegation(self, pre, sn=None, proxy=None):
Expand Down
8 changes: 4 additions & 4 deletions src/keria/core/longrunning.py
Original file line number Diff line number Diff line change
Expand Up @@ -88,7 +88,7 @@ class Monitor:
Attributes:
hby (Habery): identifier database environment
opr(Operator): long running operations database
swain(Sealer): Delegation processes tracker
swain(Anchorer): Delegation processes tracker
"""

Expand All @@ -98,7 +98,7 @@ def __init__(self, hby, swain, counselor=None, registrar=None, exchanger=None, c
Parameters:
hby (Habery): identifier database environment
swain(Sealer): Delegation processes tracker
swain(Anchorer): Delegation processes tracker
opr (Operator): long running operations database
"""
Expand Down Expand Up @@ -410,8 +410,8 @@ def status(self, op):
class OperationCollectionEnd:
@staticmethod
def on_get(req, rep):
""" Get list of long running operations
""" Get list of long running operations
Parameters:
req (Request): Falcon HTTP Request object
rep (Response): Falcon HTTP Response object
Expand Down
24 changes: 12 additions & 12 deletions tests/app/test_delegating.py
Original file line number Diff line number Diff line change
Expand Up @@ -3,7 +3,7 @@
KERIA
keria.app.delegating module
Testing the Mark II Agent Sealer
Testing the Mark II Agent Anchorer
"""
import pytest
from hio.base import doing
Expand All @@ -14,14 +14,14 @@
from keria.app import delegating


def test_sealer():
def test_anchorer():
with habbing.openHby(name="p1", temp=True) as hby:
# Create Sealer to test
sealer = delegating.Sealer(hby=hby)
# Create Anchorer to test
anchorer = delegating.Anchorer(hby=hby)

# Doer hierarchy
doist = doing.Doist(tock=0.03125, real=True)
deeds = doist.enter(doers=[sealer])
deeds = doist.enter(doers=[anchorer])

# Create delegator and delegate Habs
delegator = hby.makeHab("delegator")
Expand All @@ -30,34 +30,34 @@ def test_sealer():

# Try with a bad AID
with pytest.raises(kering.ValidationError):
sealer.delegation(pre="EHgwVwQT15OJvilVvW57HE4w0-GPs_Stj2OFoAHZSysY")
anchorer.delegation(pre="EHgwVwQT15OJvilVvW57HE4w0-GPs_Stj2OFoAHZSysY")

# Needs a proxy
with pytest.raises(kering.ValidationError):
sealer.delegation(pre=delegate.pre)
anchorer.delegation(pre=delegate.pre)

# Run delegation to escrow inception event
sealer.delegation(pre=delegate.pre, proxy=proxy)
anchorer.delegation(pre=delegate.pre, proxy=proxy)
doist.recur(deeds=deeds)

prefixer = coring.Prefixer(qb64=delegate.pre)
seqner = coring.Seqner(sn=0)
assert sealer.complete(prefixer=prefixer, seqner=seqner) is False
assert anchorer.complete(prefixer=prefixer, seqner=seqner) is False

# Anchor the seal in delegator's KEL, approving the delegation
seal = eventing.SealEvent(prefixer.qb64, "0", prefixer.qb64)
delegator.interact(data=[seal._asdict()])

while sealer.complete(prefixer=prefixer, seqner=seqner) is False:
while anchorer.complete(prefixer=prefixer, seqner=seqner) is False:
doist.recur(deeds=deeds)

# Will raise with a bad digest
with pytest.raises(kering.ValidationError):
# Create saider for the wrong event
saider = coring.Saider(qb64=delegator.kever.serder.said)
sealer.complete(prefixer=prefixer, seqner=seqner, saider=saider)
anchorer.complete(prefixer=prefixer, seqner=seqner, saider=saider)

assert sealer.complete(prefixer=prefixer, seqner=seqner) is True
assert anchorer.complete(prefixer=prefixer, seqner=seqner) is True



Expand Down

0 comments on commit fb7c6b2

Please sign in to comment.