diff --git a/apps/ailbl-admin_profile-insert-get-update-delete.py b/apps/ailbl-admin_profile-insert-get-update-delete.py index b8786b0..b7eb01b 100644 --- a/apps/ailbl-admin_profile-insert-get-update-delete.py +++ b/apps/ailbl-admin_profile-insert-get-update-delete.py @@ -34,8 +34,13 @@ def main(): def make_insert_request(): try: + user_id = request.headers.get("X-Fission-Params-UserId") + if not user_id: + return jsonify({"error": "user_id is required"}), 400 + # Lấy dữ liệu từ body của request (thông tin hồ sơ người dùng) + data = request.get_json() - response, status = crud + response, status = crud.insert_profile(user_id, data) return jsonify(response), status except Exception as e: return jsonify({"error": str(e)}), 500 @@ -43,8 +48,13 @@ def make_insert_request(): def make_update_request(): try: + user_id = request.headers.get("X-Fission-Params-UserId") + if not user_id: + return jsonify({"error": "user_id is required"}), 400 + # Lấy dữ liệu từ body của request (thông tin hồ sơ người dùng) + data = request.get_json() - response, status = crud# Call CRUD function to update avatar + response, status = crud.update_profile(user_id, data) return jsonify(response), status except Exception as e: return jsonify({"error": str(e)}), 500 @@ -52,8 +62,11 @@ def make_update_request(): def make_delete_request(): try: - - response, status = crud + user_id = request.headers.get("X-Fission-Params-UserId") + if not user_id: + return jsonify({"error": "user_id is required"}), 400 + # Call CRUD function to delete profile + response, status = crud.delete_profile(user_id) return jsonify(response), status except Exception as e: return jsonify({"error": str(e)}), 500 @@ -61,8 +74,10 @@ def make_delete_request(): def make_get_request(): try: - - return crud - # return jsonify(response), status + user_id = request.headers.get("X-Fission-Params-UserId") + if not user_id: + return jsonify({"error": "user_id is required"}), 400 + response, status = crud.get_profile(user_id) + return jsonify(response), status except Exception as e: return jsonify({"error": str(e)}), 500 diff --git a/apps/ailbl-users_profile-insert-get-update.py b/apps/ailbl-users_profile-insert-get-update.py index a0ca532..9b8c221 100644 --- a/apps/ailbl-users_profile-insert-get-update.py +++ b/apps/ailbl-users_profile-insert-get-update.py @@ -1,6 +1,6 @@ import crud from flask import jsonify, request -from helpers import init_db_connection +from helpers import init_db_connection, CORS_HEADERS @@ -33,9 +33,11 @@ def main(): def make_insert_request(): try: - data = request.get_json() # Lay du lieu json tu request body - if not data.get("user_id"): - return jsonify({"error": "user_id is required"}), 400 + user_id = request.headers.get("X-UserId") + if not user_id: + return jsonify({"errorCode": "USER_ID_REQUIRED"}), 400, CORS_HEADERS + # Lấy dữ liệu từ body của request (thông tin hồ sơ người dùng) + data = request.get_json() response, status = crud.insert_profile(data) @@ -47,8 +49,8 @@ def make_insert_request(): def make_update_request(): try: data = request.get_json() # Lay du lieu json tu request body - user_id = data.get("user_id") + user_id = data.get("user_id") if not user_id: return jsonify({"error": "user_id is required"}), 400