chore: cleanup and add LICENSE

Author: Joel Lee

LICENSE

@@ -0,0 +1,21 @@
+MIT License
+
+Copyright (c) 2022 Joel Lee
+
+Permission is hereby granted, free of charge, to any person obtaining a copy
+of this software and associated documentation files (the "Software"), to deal
+in the Software without restriction, including without limitation the rights
+to use, copy, modify, merge, publish, distribute, sublicense, and/or sell
+copies of the Software, and to permit persons to whom the Software is
+furnished to do so, subject to the following conditions:
+
+The above copyright notice and this permission notice shall be included in all
+copies or substantial portions of the Software.
+
+THE SOFTWARE IS PROVIDED "AS IS", WITHOUT WARRANTY OF ANY KIND, EXPRESS OR
+IMPLIED, INCLUDING BUT NOT LIMITED TO THE WARRANTIES OF MERCHANTABILITY,
+FITNESS FOR A PARTICULAR PURPOSE AND NONINFRINGEMENT. IN NO EVENT SHALL THE
+AUTHORS OR COPYRIGHT HOLDERS BE LIABLE FOR ANY CLAIM, DAMAGES OR OTHER
+LIABILITY, WHETHER IN AN ACTION OF CONTRACT, TORT OR OTHERWISE, ARISING FROM,
+OUT OF OR IN CONNECTION WITH THE SOFTWARE OR THE USE OR OTHER DEALINGS IN THE
+SOFTWARE.

supafunc/supafunc.py

@@ -1,37 +1,58 @@
 from typing import Dict
 import httpx
-import asyncio
+
 
 class FunctionsClient:
     def __init__(self, url: str, headers: Dict):
         self.url = url
         self.headers = headers
 
-    async def invoke(self, function_name: str, invoke_options: Dict):
+    def set_auth(self, token: str) -> None:
+        """Updates the authorization header
+
+        Parameters
+        ----------
+        token : str
+            the new jwt token sent in the authorisation header
+        """
+
+        self.headers["Authorization"] = f"Bearer {token}"
+
+    async def invoke(self, function_name: str, invoke_options: Dict) -> Dict:
+        """Invokes a function
+
+        Parameters
+        ----------
+        function_name : the name of the function to invoke
+        invoke_options : object with the following properties
+            `headers`: object representing the headers to send with the request
+            `body`: the body of the request
+            `responseType`: how the response should be parsed. The default is `json`
+
+        Returns
+        -------
+        Dict
+            Dictionary with data and/or error message
+        """
         try:
             headers = invoke_options.get('headers')
             body = invoke_options.get('body')
-            response = httpx.post(f"{self.url}/{function_name}", headers=headers)
+            response_type = invoke_options.get('responseType')
+            response = httpx.post(
+                f"{self.url}/{function_name}", headers=headers)
             is_relay_error = response.headers.get('x-relay-header')
             if is_relay_error and is_relay_error == 'true':
                 return {
                     "data": None,
                     "error": response.text
                 }
-            # TODO: Convert type accordingly
-
-            return {"data": response.data, "error": None}
+            if response_type == 'json':
+                data = response.json()
+            else:
+                data = response.data
+            return {"data": data, "error": None}
         except Exception as e:
             return {
                 "data": None,
                 "error": e
             }
-
-async def run_func():
-    fc = FunctionsClient("https://aipvgapcvmokjooimzlr.functions.supabase.co", {})
-    res = await fc.invoke("payment-sheet", {"responseType": "json"})
-
-if __name__ == "__main__":
-    asyncio.run(run_func())
-
-