From 49c26a76b49325bffb5a15f434dc82826dbf8337 Mon Sep 17 00:00:00 2001 From: Jack Date: Mon, 25 Jul 2016 22:28:01 -0400 Subject: [PATCH] remove fee checking from autofetcher script --- .../daemon_scripts/Autofetcher.py | 22 ------------------- 1 file changed, 22 deletions(-) diff --git a/lbrynet/lbrynet_daemon/daemon_scripts/Autofetcher.py b/lbrynet/lbrynet_daemon/daemon_scripts/Autofetcher.py index 92ea9f9f1..cd7ed02cb 100644 --- a/lbrynet/lbrynet_daemon/daemon_scripts/Autofetcher.py +++ b/lbrynet/lbrynet_daemon/daemon_scripts/Autofetcher.py @@ -2,13 +2,10 @@ import json import logging.handlers import sys import os -import requests -from datetime import datetime from appdirs import user_data_dir from twisted.internet.task import LoopingCall from twisted.internet import reactor -from twisted.internet.threads import deferToThread if sys.platform != "darwin": @@ -42,15 +39,11 @@ class Autofetcher(object): def __init__(self, api): self._api = api self._checker = LoopingCall(self._check_for_new_claims) - self._price_checker = LoopingCall(self._update_price) self.best_block = None - self.last_price = None - self.price_updated = None def start(self): reactor.addSystemEventTrigger('before', 'shutdown', self.stop) self._checker.start(5) - self._price_checker.start(30) def stop(self): log.info("Stopping autofetcher") @@ -66,24 +59,9 @@ class Autofetcher(object): c = self._api.get_claims_for_tx({'txid': t}) if len(c): for i in c: - if 'fee' in json.loads(i['value']): - log.info("Downloading stream for claim txid: %s" % t) self._api.get({'name': t, 'stream_info': json.loads(i['value'])}) - def _update_price(self): - def _check_bittrex(): - try: - r = requests.get("https://bittrex.com/api/v1.1/public/getticker", {'market': 'BTC-LBC'}) - self.last_price = json.loads(r.text)['result']['Last'] - self.price_updated = datetime.now() - log.info("Updated exchange rate, last BTC-LBC trade: %f" % self.last_price) - except: - log.info("Failed to update exchange rate") - self.last_price = None - self.price_updated = datetime.now() - return deferToThread(_check_bittrex) - def run(api): fetcher = Autofetcher(api)