@@ -129,7 +129,6 @@ async def get_hourly_average(ts_key: str, top_of_the_hour: int):
 )
 # Return the average without the timestamp. The response is a list
 # of the structure [timestamp, average].
-print(response)
 return response[0][1]
 
 
@@ -187,6 +186,15 @@ async def bitcoin(keys: Keys = Depends(make_keys)):
 await refresh_hourly_cache(keys)
 
 
+def get_direction(last_three_hours, key: str):
+if last_three_hours[0][key] < last_three_hours[-1][key]:
+return 'rising'
+elif last_three_hours[0][key] > last_three_hours[-1][key]:
+return 'falling'
+else:
+return 'flat'
+
+
 @app.get('/is-bitcoin-lit')
 async def bitcoin(keys: Keys = Depends(make_keys)):
 now = datetime.utcnow()
@@ -205,7 +213,13 @@ async def bitcoin(keys: Keys = Depends(make_keys)):
 'time': datetime.fromtimestamp(data[0][0] / 1000, tz=timezone.utc),
 }
 for data in zip(price, sentiment)]
-return past_hours + [current_hour_stats_cached]
+last_three_hours = past_hours + [current_hour_stats_cached]
+
+return {
+'hourly_average_of_averages': last_three_hours,
+'sentiment_direction': get_direction(last_three_hours, 'sentiment'),
+'price_direction': get_direction(last_three_hours, 'price'),
+}
 
 
 async def make_timeseries(key):

@@ -1,3 +1,7 @@
+import json
+import os.path
+from unittest import mock
+
 import pytest
 from aioredis import Redis
 from httpx import AsyncClient
@@ -6,13 +10,35 @@
 REFRESH_URL = '/refresh'
 URL = '/is-bitcoin-lit'
 EXPECTED_FIELDS = (
-'lit', 'time', 'mean_of_means_sentiment',
-'mean_of_means_price',
+'hourly_average_of_averages',
+'sentiment_direction',
+'price_direction',
+)
+JSON_FIXTURE = os.path.join(
+os.path.dirname(os.path.realpath(__file__)),
+'fixtures',
+'sentiment_response.json',
 )
 
 
+@pytest.fixture
+def mock_bitcoin_api():
+with mock.('requests.get') as mock_get:
+with mock.('requests.Response') as mock_response:
+# Mock out Response.json()
+m = mock.MagicMock()
+with open(JSON_FIXTURE) as f:
+m.return_value = json.loads(f.read())
+mock_response.json = m
+
+# Make get() return our fake Response.
+mock_get.return_value = mock_response
+
+yield mock_get
+
+
 @pytest.mark.asyncio
-async def test_api(client: AsyncClient):
+async def test_api(client: AsyncClient, mock_bitcoin_api: mock.MagicMock):
 await client.get(REFRESH_URL)
 res = await client.get(URL)
 summary = res.json()
@@ -24,7 +50,10 @@ async def test_api(client: AsyncClient):
 
 
 @pytest.mark.asyncio
-async def test_api_timeseries(client: AsyncClient, redis: Redis):
+async def test_api_timeseries(
+client: AsyncClient, redis: Redis,
+mock_bitcoin_api: mock.MagicMock
+):
 await client.get(REFRESH_URL)
 data = await client.get(URL)
 summary = data.json()