Use auth token in /stream requests to get 400 requests an hour instead of 200

Author: tdoshea90

application.py

@@ -1,5 +1,3 @@
-
-import logging
 import os
 
 from flask import Flask, render_template, request, redirect, url_for, session
@@ -10,9 +8,7 @@
 
 application = Flask(__name__)
 app = application
-#app.secret_key = os.environ.get('APP_SECRET_KEY')
-app.secret_key = os.urandom(32)
-#app.permanent_session_lifetime = timedelta(days=1)
+app.secret_key = os.environ.get('APP_SECRET_KEY')
 
 stwrapper = StockTwitsWrapper()
 stwrapper.compile_regex_patterns()
@@ -52,18 +48,12 @@ def auth_redirect_uri():
     session['user_id'] = token_response.user_id
     session['username'] = token_response.username
 
-    logging.info('>>>>>>>>>>>>>>>>>>>>>>>>>>>>')
-    logging.error(token_response.access_token)
-    logging.warn('>>>>>>>>>>>>>>>>>>>>>>>>>>>>')
-
     return redirect(request.url_root)   # go back home after successful auth
 
 
-# Not actually using any ST endpoints that require auth yet
+# Using auth token boosts request limit to 400
 @app.before_request
 def check_session():
-    #session.permanent = True
-    # need to comment out this block and push to prod to use oauth on localhost
     if '/auth_redirect_uri/' != request.path:
         if 'user_id' not in session or 'access_token' not in session:
             auth_code_url = authwrapper.get_auth_code_url(request.url_root)

auth_wrapper.py

@@ -9,8 +9,6 @@ class AuthWrapper:
 
     client_id = '7cc80ecf361d0f13'
     auth_redirect_postfix = 'auth_redirect_uri/'
-    # uncomment along with other 2 lines for local oauth testing
-    #bs_auth_redirect_url = 'https://stocktwitsanalyzer-env.us-west-2.elasticbeanstalk.com/'
 
     @classmethod
     def get_auth_code_url(self, auth_redirect_root):
@@ -19,7 +17,6 @@ def get_auth_code_url(self, auth_redirect_root):
         auth_code_params = dict(
             response_type='code',
             redirect_uri=auth_redirect_root + self.auth_redirect_postfix,
-            #redirect_uri=self.bs_auth_redirect_url + self.auth_redirect_postfix,
             client_id=self.client_id,
             scope='read'
         )
@@ -35,7 +32,6 @@ def get_auth_token(self, auth_code, auth_redirect_root):
         auth_token_params = dict(
             code=auth_code,
             redirect_uri=auth_redirect_root,
-            #redirect_uri=self.bs_auth_redirect_url + self.auth_redirect_postfix,
             client_id=self.client_id,
             client_secret=os.environ.get('ST_API_KEY'),
             grant_type='authorization_code'

stocktwits_wrapper.py

@@ -54,11 +54,13 @@ def get_ticker(self, ticker):
 
         get_ticker_url = 'https://api.stocktwits.com/api/2/streams/symbol/'
         url_postfix = '.json'
+        if 'access_token' in session:
+            url_postfix = '%s?access_token=%s' % (url_postfix, session['access_token'])
 
         # call ST api
         request_url = get_ticker_url + ticker + url_postfix
 
-        # TODO: every hour use ST 'cursor' parameter to only get newest messages
+        # TODO: use 'cursor' parameter to only get newest messages
 
         response = requests.get(request_url)
         response_json = response.json()
@@ -69,9 +71,6 @@ def get_ticker(self, ticker):
         session['rate_remaining'] = rate_remaining
         session['rate_reset'] = rate_reset  # returned in true UTC time
 
-#         print(session['rate_remaining'])
-#         print(session['rate_reset'])
-
         self.__check_response_code(response_json, rate_remaining)
 
         symbol = response_json['symbol']['symbol']