1 files changed, 95 insertions, 0 deletions
diff --git a/blenderkit/rerequests.py b/blenderkit/rerequests.py
new file mode 100644
index 00000000..d58214bc
--- /dev/null
+++ b/blenderkit/rerequests.py
@@ -0,0 +1,95 @@
+# ##### BEGIN GPL LICENSE BLOCK #####
+#
+#  This program is free software; you can redistribute it and/or
+#  modify it under the terms of the GNU General Public License
+#  as published by the Free Software Foundation; either version 2
+#  of the License, or (at your option) any later version.
+#
+#  This program is distributed in the hope that it will be useful,
+#  but WITHOUT ANY WARRANTY; without even the implied warranty of
+#  MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
+#  GNU General Public License for more details.
+#
+#  You should have received a copy of the GNU General Public License
+#  along with this program; if not, write to the Free Software Foundation,
+#  Inc., 51 Franklin Street, Fifth Floor, Boston, MA 02110-1301, USA.
+#
+# ##### END GPL LICENSE BLOCK #####
+
+if "bpy" in locals():
+    from importlib import reload
+
+    ui = reload(ui)
+    utils = reload(utils)
+    paths = reload(paths)
+    tasks_queue = reload(tasks_queue)
+    bkit_oauth = reload(bkit_oauth)
+else:
+    from blenderkit import ui, utils, paths, tasks_queue, bkit_oauth
+
+import requests
+import bpy
+
+
+def rerequest(method, url, **kwargs):
+    # first get any additional args from kwargs
+    immediate = False
+    if kwargs.get('immediate'):
+        immediate = kwargs['immediate']
+        kwargs.pop('immediate')
+    # first normal attempt
+    response = requests.request(method, url, **kwargs)
+
+    utils.p(url)
+    utils.p(response.status_code)
+
+    if response.status_code == 401:
+        try:
+            rdata = response.json()
+        except:
+            rdata = {}
+
+        tasks_queue.add_task((ui.add_report, (method + ' request Failed.' + str(rdata.get('detail')),)))
+
+        if rdata.get('detail') == 'Invalid token.':
+            user_preferences = bpy.context.preferences.addons['blenderkit'].preferences
+            if user_preferences.api_key != '':
+                if user_preferences.enable_oauth:
+                    tasks_queue.add_task((ui.add_report, ('refreshing token.',)))
+                    refresh_url = paths.get_bkit_url()
+                    auth_token, refresh_token = bkit_oauth.refresh_token(user_preferences.api_key_refresh, refresh_url)
+
+                    # utils.p(auth_token, refresh_token)
+                    if auth_token is not None:
+                        if immediate == True:
+                            # this can write tokens occasionally into prefs. used e.g. in upload. Only possible
+                            #  in non-threaded tasks
+                            bpy.context.preferences.addons['blenderkit'].preferences.api_key = auth_token
+                            bpy.context.preferences.addons['blenderkit'].preferences.api_key_refresh = refresh_token
+
+                        kwargs['headers'] = utils.get_headers(auth_token)
+                        response = requests.request(method, url, **kwargs)
+                        utils.p('reresult', response.status_code)
+                        if response.status_code >= 400:
+                            utils.p('reresult', response.text)
+    return response
+
+
+def get(url, **kwargs):
+    response = rerequest('get', url, **kwargs)
+    return response
+
+
+def post(url, **kwargs):
+    response = rerequest('post', url, **kwargs)
+    return response
+
+
+def put(url, **kwargs):
+    response = rerequest('put', url, **kwargs)
+    return response
+
+
+def patch(url, **kwargs):
+    response = rerequest('patch', url, **kwargs)
+    return response