foo

backend/app.py

@@ -46,7 +46,7 @@ Migrate(app, db)
 db.init_app(app)
 
 
-app.logger.setLevel(logging.INFO)
+app.logger.setLevel(logging.DEBUG)
 
 app.register_blueprint(api_v1)
 app.register_blueprint(web)

backend/areas/auth/auth.py

@@ -8,14 +8,12 @@ from areas.apps import App, AppRole
 from config import *
 from helpers import HydraOauth, BadRequest, KratosApi
 
-
 @api_v1.route("/login", methods=["POST"])
 @cross_origin()
 def login():
     authorization_url = HydraOauth.authorize()
     return jsonify({"authorizationUrl": authorization_url})
 
-
 @api_v1.route("/hydra/callback")
 @cross_origin()
 def hydra_callback():

backend/areas/auth/lit_auth.py

@@ -1,14 +1,23 @@
 from multiprocessing import current_process
 from flask import jsonify, request
-from flask_jwt_extended import create_access_token
+from flask_jwt_extended import create_access_token, jwt_required
 from flask_cors import cross_origin
 from datetime import timedelta
+from helpers.authentik_api import AuthentikApi
 
 from areas import api_v1
 from config import *
 from helpers import LITOauth, BadRequest
 
 
+@api_v1.route("/logout", methods=["POST"])
+@cross_origin()
+@jwt_required()
+def logout():
+    res = AuthentikApi.post("/flows/executor/default-invalidation-flow/")
+    print(res)
+    return jsonify({})
+
 @api_v1.route("/login", methods=["POST"])
 @cross_origin()
 def login():

backend/helpers/authentik_api.py

@@ -31,6 +31,20 @@ class AuthentikApi:  # TODO: check if can be replaced with apispec generated api
         except:
             raise AuthentikError()
 
+    @staticmethod
+    def post(url, data=[]):
+        try:
+            res = requests.post(f"{AUTHENTIK_BASEURL}{url}", headers={
+                "Authorization": f"Bearer {AuthentikApi.__token()}"}, data=data)
+            AuthentikApi.__handleError(res)
+            if ("pagination" in res.json()):
+                return AuthentikApi.__paginate(res)
+            return res.json()
+        except AuthentikError as err:
+            raise err
+        except:
+            raise AuthentikError()
+
     @staticmethod
     def __paginate(res: requests.Response):  # TODO: test this
         results = res.json()["results"]