| 123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263 |
- from ouroboros.clock import SynchedNTPClock
- from ouroboros.vrf import VRF
- from ouroboros.logger import Logger
- import threading
- import time
- '''
- \class TrustedBeacon
- the trusted beacon is decentralized, such that at the onset of the Epoch,
- the leader of the first slot generated the signed seed, and release the signature,
- proof, and base to the genesis block.
- #TODO implement trustedbeacon as a node
- '''
- class TrustedBeacon(SynchedNTPClock, threading.Thread):
- def __init__(self, node, vrf, epoch_length, genesis_time):
- self.epoch_length=epoch_length # how many slots in a a block
- SynchedNTPClock.__init__(self)
- threading.Thread.__init__(self)
- self.daemon=True
- self.node = node #stakeholder
- self.vrf = vrf
- self.current_slot = self.slot
- self.log = Logger(self, genesis_time)
- self.log.info(f"constructed for node {str(node)}")
- def __repr__(self):
- return f"trustedbeacon"
- def run(self):
- self.log.highlight("thread [start]")
- self.__background()
- self.log.info("thread [end]")
- def __background(self):
- current_epoch = self.slot
- self.log.info('background waiting for the onset of next synched epoch...')
- while True:
- if self.slot != current_epoch:
- current_epoch = self.slot
- self.__callback()
- def __callback(self):
- self.current_slot = self.slot
- if self.current_slot%self.epoch_length!=0:
- self.log.info(f"callback: new slot of idx: {self.current_slot}")
- y, pi = self.vrf.sign(self.current_slot)
- self.log.info(f"callback: signature calculated for {str(self.node)}")
- self.node.new_slot(self.current_slot, y, pi)
- else:
- sigmas = []
- proofs = []
- for i in range(self.epoch_length):
- self.log.info(f"callback: new slot of idx: {self.current_slot}, epoch slot {i}")
- y, pi = self.vrf.sign(self.current_slot)
- self.log.info(f"callback: signature calculated for {str(self.node)}")
- sigmas.append(y)
- proofs.append(pi)
- self.node.new_epoch(self.current_slot, sigmas, proofs)
- def verify(self, y, pi, pk_raw, g):
- return VRF.verify(self.current_slot, y, pi, pk_raw, g)
|
