jeans/core
jeans/core
1
0
Fork 0
mirror of https://github.com/home-assistant/core.git synced 2025-07-23 21:27:38 +00:00
Code Issues Packages Projects Releases Wiki Activity

use throttle as balloob suggested

Browse Source
This commit is contained in:
Fabian Affolter 2015-05-18 23:38:46 +02:00
parent 397336e03c
commit 9392f9b512
1 changed files with 22 additions and 11 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

33
homeassistant/components/sensor/bitcoin.py
View File

@ -58,7 +58,7 @@ currency
The currency to exchange to. Eg. CHF, USD, EUR,etc. The currency to exchange to. Eg. CHF, USD, EUR,etc.
display_options display_options
*Required *Optional
An array specifying the variables to display. An array specifying the variables to display.
These are the variables for the display_options array. See the configuration These are the variables for the display_options array. See the configuration
@ -67,6 +67,8 @@ example above for a list of all available variables.
import logging import logging
from datetime import timedelta from datetime import timedelta
from blockchain import statistics, exchangerates
from homeassistant.util import Throttle from homeassistant.util import Throttle
from homeassistant.helpers.entity import Entity from homeassistant.helpers.entity import Entity
@ -98,7 +100,7 @@ OPTION_TYPES = {
} }
# Return cached results if last scan was less then this time ago # Return cached results if last scan was less then this time ago
MIN_TIME_BETWEEN_UPDATES = timedelta(seconds=120) MIN_TIME_BETWEEN_UPDATES = timedelta(seconds=30)
def setup_platform(hass, config, add_devices, discovery_info=None): def setup_platform(hass, config, add_devices, discovery_info=None):
@ -131,16 +133,16 @@ def setup_platform(hass, config, add_devices, discovery_info=None):
_LOGGER.error(error) _LOGGER.error(error)
wallet = None wallet = None
data = BitcoinData()
dev = [] dev = []
if wallet is not None and password: if wallet is not None and password:
dev.append(BitcoinSensor('wallet', currency, wallet)) dev.append(BitcoinSensor(data, 'wallet', currency, wallet))
for variable in config['display_options']: for variable in config['display_options']:
if variable not in OPTION_TYPES: if variable not in OPTION_TYPES:
_LOGGER.error('Option type: "%s" does not exist', variable) _LOGGER.error('Option type: "%s" does not exist', variable)
else: else:
print("############ ", variable) dev.append(BitcoinSensor(data, variable, currency))
dev.append(BitcoinSensor(variable, currency))
add_devices(dev) add_devices(dev)
@ -149,8 +151,8 @@ def setup_platform(hass, config, add_devices, discovery_info=None):
class BitcoinSensor(Entity): class BitcoinSensor(Entity):
""" Implements a Bitcoin sensor. """ """ Implements a Bitcoin sensor. """
def __init__(self, option_type, currency, wallet=''): def __init__(self, data, option_type, currency, wallet=''):
self.data = data
self._name = OPTION_TYPES[option_type][0] self._name = OPTION_TYPES[option_type][0]
self._unit_of_measurement = OPTION_TYPES[option_type][1] self._unit_of_measurement = OPTION_TYPES[option_type][1]
self._currency = currency self._currency = currency
@ -174,13 +176,12 @@ class BitcoinSensor(Entity):
return self._unit_of_measurement return self._unit_of_measurement
# pylint: disable=too-many-branches # pylint: disable=too-many-branches
@Throttle(MIN_TIME_BETWEEN_UPDATES)
def update(self): def update(self):
""" Gets the latest data and updates the states. """ """ Gets the latest data and updates the states. """
from blockchain import statistics, exchangerates
stats = statistics.get() self.data.update()
ticker = exchangerates.get_ticker() stats = self.data.stats
ticker = self.data.ticker
# pylint: disable=no-member # pylint: disable=no-member
if self.type == 'wallet' and self._wallet is not None: if self.type == 'wallet' and self._wallet is not None:
@ -232,3 +233,13 @@ class BitcoinSensor(Entity):
0.00000001) 0.00000001)
elif self.type == 'market_price_usd': elif self.type == 'market_price_usd':
self._state = '{0:.2f}'.format(stats.market_price_usd) self._state = '{0:.2f}'.format(stats.market_price_usd)
class BitcoinData(object):
def __init__(self):
self.stats = None
self.ticker = None
@Throttle(MIN_TIME_BETWEEN_UPDATES)
def update(self):
self.stats = statistics.get()
self.ticker = exchangerates.get_ticker()