From db979d36d0b9693cc81ffa0bdd29364c6218fc95 Mon Sep 17 00:00:00 2001
From: Georgios Andreadis <info@gandreadis.com>
Date: Wed, 24 Jun 2020 13:26:56 +0200
Subject: Add working test setup

---
 opendc/util/rest.py | 49 ++++++++++++++++++++++++++-----------------------
 1 file changed, 26 insertions(+), 23 deletions(-)

(limited to 'opendc/util/rest.py')

diff --git a/opendc/util/rest.py b/opendc/util/rest.py
index d892a358..2312b199 100644
--- a/opendc/util/rest.py
+++ b/opendc/util/rest.py
@@ -1,14 +1,12 @@
 import importlib
 import json
+import os
 import sys
 
 from oauth2client import client, crypt
 
 from opendc.util import exceptions, parameter_checker
 
-with open(sys.argv[1]) as f:
-    KEYS = json.load(f)
-
 
 class Request(object):
     """WebSocket message to REST request mapping."""
@@ -45,6 +43,7 @@ class Request(object):
             module_base = 'opendc.api.{}.endpoint'
             module_path = self.path.replace('/', '.')
 
+            print(module_base.format(module_path))
             self.module = importlib.import_module(module_base.format(module_path))
         except ImportError:
             raise exceptions.UnimplementedEndpointError('Unimplemented endpoint: {}.'.format(self.path))
@@ -60,31 +59,14 @@ class Request(object):
 
         # Verify the user
 
+        if "OPENDC_FLASK_TESTING" in os.environ:
+            return
+
         try:
             self.google_id = self._verify_token(self.token)
-
         except crypt.AppIdentityError as e:
             raise exceptions.AuthorizationTokenError(e)
 
-    def _verify_token(self, token):
-        """Return the ID of the signed-in user.
-        
-        Or throw an Exception if the token is invalid.
-        """
-
-        try:
-            idinfo = client.verify_id_token(token, KEYS['OAUTH_CLIENT_ID'])
-        except Exception as e:
-            raise crypt.AppIdentityError('Exception caught trying to verify ID token: {}'.format(e))
-
-        if idinfo['aud'] != KEYS['OAUTH_CLIENT_ID']:
-            raise crypt.AppIdentityError('Unrecognized client.')
-
-        if idinfo['iss'] not in ['accounts.google.com', 'https://accounts.google.com']:
-            raise crypt.AppIdentityError('Wrong issuer.')
-
-        return idinfo['sub']
-
     def check_required_parameters(self, **kwargs):
         """Raise an error if a parameter is missing or of the wrong type."""
 
@@ -108,6 +90,27 @@ class Request(object):
 
         return json.dumps(self.message)
 
+    @staticmethod
+    def _verify_token(token):
+        """Return the ID of the signed-in user.
+
+        Or throw an Exception if the token is invalid.
+        """
+
+        try:
+            id_info = client.verify_id_token(token, os.environ['OPENDC_OAUTH_CLIENT_ID'])
+        except Exception as e:
+            print(e)
+            raise crypt.AppIdentityError('Exception caught trying to verify ID token: {}'.format(e))
+
+        if id_info['aud'] != os.environ['OPENDC_OAUTH_CLIENT_ID']:
+            raise crypt.AppIdentityError('Unrecognized client.')
+
+        if id_info['iss'] not in ['accounts.google.com', 'https://accounts.google.com']:
+            raise crypt.AppIdentityError('Wrong issuer.')
+
+        return id_info['sub']
+
 
 class Response(object):
     """Response to websocket mapping"""
-- 
cgit v1.2.3