From 8b42bd47a64a3dca7faf7ef92168ab2974c10138 Mon Sep 17 00:00:00 2001
From: Kenneth Reitz <me@kennethreitz.org>
Date: Thu, 31 Aug 2017 00:32:48 -0400
Subject: [PATCH] graphs!!!!

Signed-off-by: Kenneth Reitz <me@kennethreitz.org>
---
 graph.py       |  2 +-
 predictions.py | 38 +++++++++++++++++++++++++++-----------
 server.py      |  9 ++++++++-
 3 files changed, 36 insertions(+), 13 deletions(-)

diff --git a/graph.py b/graph.py
index 3925de4..7f2fb7b 100644
--- a/graph.py
+++ b/graph.py
@@ -29,7 +29,7 @@ class Coin(graphene.ObjectType):
 
 class Query(graphene.ObjectType):
     coin = graphene.Field(Coin, name=graphene.String())
-    # recent_top_packages = graphene.List(Package)
+    recent_top_coins = graphene.List(Coin)
 
     @graphene.resolve_only_args
     def resolve_coin(self, name=None, ticker=None):
diff --git a/predictions.py b/predictions.py
index eeb341f..b46adc8 100644
--- a/predictions.py
+++ b/predictions.py
@@ -1,4 +1,5 @@
 import time
+import uuid
 
 import records
 import os
@@ -6,13 +7,24 @@ import os
 import maya
 import numpy as np
 import pandas as pd
+
+# Matplotlib hack.
+import matplotlib
+matplotlib.use('agg')
+
 from fbprophet import Prophet
 
 from scraper import Coin, MWT, convert_to_decimal
 
 
+PERIODS = 365
+
+
 @MWT(timeout=300)
-def get_predictions(coin):
+def get_predictions(coin, render=False):
+    """Returns a list of predictions, unless render is True.
+    Otherwise, returns the path of a rendered image.
+    """
 
     c = Coin(coin)
 
@@ -31,9 +43,16 @@ def get_predictions(coin):
     model = Prophet(weekly_seasonality=True, yearly_seasonality=True)
     model.fit(df)
 
-    future_data = model.make_future_dataframe(periods=30, freq='d')
+    future_data = model.make_future_dataframe(periods=PERIODS, freq='d')
     forecast_data = model.predict(future_data)
-    print(forecast_data[['ds', 'yhat', 'yhat_lower', 'yhat_upper']].tail())
+
+    if render:
+        f_name = str(uuid.uuid4())
+
+        matplotlib.pyplot.gcf()
+        model.plot(forecast_data).savefig(f_name)
+
+        return f'{f_name}.png'
 
     forecast_data_orig = forecast_data  # make sure we save the original forecast data
     forecast_data_orig['yhat'] = np.exp(forecast_data_orig['yhat'])
@@ -46,20 +65,17 @@ def get_predictions(coin):
     # print(forecast_data_orig)
     d = forecast_data_orig['yhat'].to_dict()
     predictions = []
-    for i, k in enumerate(list(d.keys())[-30:]):
+
+    for i, k in enumerate(list(d.keys())[-PERIODS:]):
         w = maya.when(f'{i+1} days from now')
         predictions.append({
             'when': w.slang_time(),
             'timestamp': w.iso8601(),
             'usd': convert_to_decimal(d[k]),
         })
+
     return predictions
 
 
-# results = list(zip(*[forecast_data_orig[c].values.tolist() for c in forecast_data_orig]))[-6:]
-# for result in results:
-#     dt = maya.MayaDT(result[0])
-#     _min = result[7]
-#     _max = result[8]
-#     _prediction = result[16]
-#     print(dt.slang_time(), _min, _max, _prediction)
+if __name__ == '__main__':
+    print(get_predictions('btc'))
diff --git a/server.py b/server.py
index 7a38c75..fd7aa0a 100644
--- a/server.py
+++ b/server.py
@@ -4,7 +4,7 @@ from scraper import get_coins, get_coin, Coin, convert_to_decimal
 from predictions import get_predictions
 from graph import schema
 
-from flask import Flask, jsonify, render_template, request
+from flask import Flask, jsonify, render_template, request, send_file
 from flask_graphql import GraphQLView
 from flask_cache import Cache
 from flask_common import Common
@@ -15,6 +15,7 @@ import maya
 import requests
 import records
 
+
 API_KEYS = os.environ.get('API_KEYS', '').split(':')
 
 db = records.Database()
@@ -61,6 +62,12 @@ def get_forecast(coin):
     return jsonify(forecast=get_predictions(coin.lower()))
 
 
+@app.route('/<coin>/forecast/graph')
+def get_forecast_graph(coin):
+    f_name = get_predictions(coin.lower(), render=True)
+    return send_file(f_name, mimetype='image/png')
+
+
 @app.route('/<coin>/<float:n>')
 def get_value(coin, n):
     c = Coin(coin.lower())