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

New find_n_ursulas method for Policy.

pull/145/head
jMyles 2017-12-14 11:40:23 -08:00
parent 56b2fab5bc
commit f5abf099af
1 changed files with 14 additions and 13 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

27
nkms/policy/models.py
View File

@ -100,19 +100,6 @@ class PolicyGroup(object):
def pfrag(self):
return self.policies[0].pfrag
def find_n_ursulas(self, networky_stuff, offer: PolicyOffer):
"""
:param networky_stuff: A compliant interface (maybe a Client instance) to be used to engage the DHT swarm.
"""
for policy in self.policies:
try:
ursula, result = networky_stuff.find_ursula(self.id, offer)
# TODO: Here, we need to assess the result and see if we're actually good to go.
if result.was_accepted:
policy.activate(ursula, result)
except networky_stuff.NotEnoughQualifiedUrsulas:
pass # Tell Alice to either wait or lower the value of n.
def hrac(self):
"""
A convenience method for generating an hrac for this instance.
@ -294,6 +281,20 @@ class Policy(object):
def craft_offer(self, deposit, expiration):
return PolicyOffer(self.n, deposit, expiration)
def find_n_ursulas(self, networky_stuff, offer: PolicyOffer):
"""
:param networky_stuff: A compliant interface (maybe a Client instance) to be used to engage the DHT swarm.
"""
for kfrag in self.kfrags:
try:
ursula, result = networky_stuff.find_ursula(offer)
# TODO: Here, we need to assess the result and see if we're actually good to go.
if result.was_accepted:
offer.activate(kfrag, ursula, result)
self._active_ursulas[kfrag] = offer
except networky_stuff.NotEnoughQualifiedUrsulas:
pass # TODO: Tell Alice to either wait or lower the value of n.
class TreasureMap(object):
def __init__(self, ursula_interface_ids=None):