forked from LBRYCommunity/lbry-sdk
update LiveStreamPaymentRateManager
This commit is contained in:
parent
180d981ed8
commit
dc2f0adb3e
1 changed files with 7 additions and 5 deletions
|
@ -19,11 +19,13 @@ class LiveStreamPaymentRateManager(object):
|
||||||
def accept_rate_live_blob_info(self, peer, payment_rate):
|
def accept_rate_live_blob_info(self, peer, payment_rate):
|
||||||
return payment_rate >= self.get_effective_min_live_blob_info_payment_rate()
|
return payment_rate >= self.get_effective_min_live_blob_info_payment_rate()
|
||||||
|
|
||||||
def get_rate_blob_data(self, peer):
|
def get_rate_blob_data(self, peer, blobs):
|
||||||
return self.get_effective_min_blob_data_payment_rate()
|
response = self._payment_rate_manager.strategy.make_offer(peer, blobs)
|
||||||
|
return response.rate
|
||||||
|
|
||||||
def accept_rate_blob_data(self, peer, payment_rate):
|
def accept_rate_blob_data(self, peer, blobs, offer):
|
||||||
return payment_rate >= self.get_effective_min_blob_data_payment_rate()
|
response = self._payment_rate_manager.strategy.respond_to_offer(offer, peer, blobs)
|
||||||
|
return response.accepted
|
||||||
|
|
||||||
def get_effective_min_blob_data_payment_rate(self):
|
def get_effective_min_blob_data_payment_rate(self):
|
||||||
rate = self.min_blob_data_payment_rate
|
rate = self.min_blob_data_payment_rate
|
||||||
|
|
Loading…
Reference in a new issue