remove unnecessary class

This commit is contained in:
Jack 2016-09-30 00:12:17 -04:00
parent b853656aa6
commit 5c391f4bb4
2 changed files with 14 additions and 38 deletions

View file

@ -6,65 +6,41 @@ class Offer(object):
A rate offer to download blobs from a host A rate offer to download blobs from a host
""" """
RATE_ACCEPTED = "RATE_ACCEPTED"
RATE_TOO_LOW = "RATE_TOO_LOW"
RATE_UNSET = "RATE_UNSET"
def __init__(self, offer): def __init__(self, offer):
self._state = None self._state = None
self.rate = None self.rate = None
if isinstance(offer, float): if isinstance(offer, float):
self.rate = round(offer, 5) self.rate = round(offer, 5)
elif offer == Negotiate.RATE_ACCEPTED: elif offer == Offer.RATE_ACCEPTED:
self.accept() self.accept()
elif offer == Negotiate.RATE_TOO_LOW: elif offer == Offer.RATE_TOO_LOW:
self.reject() self.reject()
@property @property
def accepted(self): def accepted(self):
return self._state is Negotiate.RATE_ACCEPTED return self._state is Offer.RATE_ACCEPTED
@property @property
def too_low(self): def too_low(self):
return self._state is Negotiate.RATE_TOO_LOW return self._state is Offer.RATE_TOO_LOW
@property @property
def message(self): def message(self):
if self.accepted: if self.accepted:
return Negotiate.RATE_ACCEPTED return Offer.RATE_ACCEPTED
elif self.too_low: elif self.too_low:
return Negotiate.RATE_TOO_LOW return Offer.RATE_TOO_LOW
elif self.rate is None: elif self.rate is None:
return Negotiate.RATE_UNSET return Offer.RATE_UNSET
def accept(self): def accept(self):
if self._state is None: if self._state is None:
self._state = Negotiate.RATE_ACCEPTED self._state = Offer.RATE_ACCEPTED
def reject(self): def reject(self):
if self._state is None: if self._state is None:
self._state = Negotiate.RATE_TOO_LOW self._state = Offer.RATE_TOO_LOW
class Negotiate(object):
"""
Helper class for converting to and from Offers
"""
RATE_ACCEPTED = "RATE_ACCEPTED"
RATE_TOO_LOW = "RATE_TOO_LOW"
RATE_UNSET = "RATE_UNSET"
PAYMENT_RATE = "blob_data_payment_rate"
ERROR = "error"
@staticmethod
def get_offer_from_request(request_dict):
error = request_dict.get(Negotiate.ERROR, False)
if error:
raise NegotiationError()
return Offer(request_dict.get(Negotiate.PAYMENT_RATE))
@staticmethod
def make_dict_from_offer(offer):
if offer.message:
request_dict = {Negotiate.PAYMENT_RATE: offer.message}
else:
request_dict = {Negotiate.PAYMENT_RATE: offer.rate}
return request_dict

View file

@ -10,7 +10,7 @@ from lbrynet.core.Error import InvalidResponseError, RequestCanceledError, NoRes
from lbrynet.core.Error import PriceDisagreementError, DownloadCanceledError, InsufficientFundsError from lbrynet.core.Error import PriceDisagreementError, DownloadCanceledError, InsufficientFundsError
from lbrynet.core.client.ClientRequest import ClientRequest, ClientBlobRequest from lbrynet.core.client.ClientRequest import ClientRequest, ClientBlobRequest
from lbrynet.interfaces import IRequestCreator from lbrynet.interfaces import IRequestCreator
from lbrynet.core.Offer import Negotiate, Offer from lbrynet.core.Offer import Offer
log = logging.getLogger(__name__) log = logging.getLogger(__name__)