diff --git a/lbrynet/lbrylive/PaymentRateManager.py b/lbrynet/lbrylive/PaymentRateManager.py index 77ff09030..8234efa31 100644 --- a/lbrynet/lbrylive/PaymentRateManager.py +++ b/lbrynet/lbrylive/PaymentRateManager.py @@ -19,11 +19,13 @@ class LiveStreamPaymentRateManager(object): def accept_rate_live_blob_info(self, peer, payment_rate): return payment_rate >= self.get_effective_min_live_blob_info_payment_rate() - def get_rate_blob_data(self, peer): - return self.get_effective_min_blob_data_payment_rate() + def get_rate_blob_data(self, peer, blobs): + response = self._payment_rate_manager.strategy.make_offer(peer, blobs) + return response.rate - def accept_rate_blob_data(self, peer, payment_rate): - return payment_rate >= self.get_effective_min_blob_data_payment_rate() + def accept_rate_blob_data(self, peer, blobs, offer): + response = self._payment_rate_manager.strategy.respond_to_offer(offer, peer, blobs) + return response.accepted def get_effective_min_blob_data_payment_rate(self): rate = self.min_blob_data_payment_rate @@ -42,4 +44,4 @@ class LiveStreamPaymentRateManager(object): return rate def record_points_paid(self, amount): - self.points_paid += amount \ No newline at end of file + self.points_paid += amount