from flask import session, jsonify #from app.models.loan import Loan from app.utils.logger import logger from app.api.services.base_service import BaseService # from app.api.schemas.eligibility_check import EligibilityCheckSchema from marshmallow import ValidationError # from app.api.enums import TransactionType # from app.api.integrations import SimbrellaIntegration from app.extensions import db from app.models import PasswordReset, Members #from app.api.services.offer_analysis import OfferAnalysis from app.api.helpers.response_helper import ResponseHelper from werkzeug.security import generate_password_hash, check_password_hash from app.api.schemas.login import LoginSchema from app.api.schemas.reset_pass_start import ResetPassStart import datetime import jwt import random from app.config import Config class LoginService(BaseService): @staticmethod def process_reset(data): try: with db.session.begin(): validated_data = LoginService.validate_data(data, ResetPassStart()) username = validated_data.get('username') member = Members.get_member_by_username(username) if not member: invalid_data = { "error_message": "invalid username or password", "message_key": "invalid_username_or_password", } return ResponseHelper.success(data=invalid_data) reset_data = PasswordReset.create_reset(username=username) BaseService.send_resetpass_mail(member.email, str(member.uid), member.id, "FF","LL") #pending_uid, pending_id, firstname, lastname response_data = { "error_message": "invalid username or password 000", "message_key": "invalid_username_or_password", } return ResponseHelper.success(data=response_data) except ValidationError as err: logger.error(f"Validation Error: {getattr(err, 'messages', str(err))}") db.session.rollback() return ResponseHelper.unprocessable_entity(result_description="Validation exception") except ValueError as err: logger.error(f"{getattr(err, 'messages', str(err))}") db.session.rollback() return ResponseHelper.error(result_description=str(err)) except Exception as e: logger.error(f"An error occurred: {str(e)}", exc_info=True) db.session.rollback() return ResponseHelper.internal_server_error() @staticmethod def process_request(data): try: with db.session.begin(): validated_data = LoginService.validate_data(data, LoginSchema()) username = validated_data.get('username') password = validated_data.get('password') member = Members.get_member_by_username(username) # pass22 = generate_password_hash(password) # logger.info("Password generated = > {}".format(pass22) ) if not member: invalid_data = { "error_message": "invalid username or password", "message_key": "invalid_username_or_password", } return ResponseHelper.success(data=invalid_data) pass_check = check_password_hash(member.password, password) logger.info("Password check: {}".format(pass_check)) if not member or not pass_check: invalid_data = { "error_message": "invalid username or password", "message_key": "invalid_username_or_password", } return ResponseHelper.success(data=invalid_data) user_data = {} user_data["id"] = member.id, user_data["member_id"]= member.id, user_data["uid"] = str(member.uid), user_token = jwt.encode( {"user": user_data, 'exp' : datetime.datetime.utcnow() + datetime.timedelta(minutes=3330)}, Config.JWT_SECRET_KEY, algorithm="HS256" ) # Simulate processing response_data = { "member_id": member.id, "uid": str(member.uid), "username": member.username, "account_name": member.account_name, "firstname":member.firstname, "lastname": member.lastname, "room": member.uid, "token": user_token } return ResponseHelper.success(data=response_data) except ValidationError as err: logger.error(f"Validation Error: {getattr(err, 'messages', str(err))}") db.session.rollback() return ResponseHelper.unprocessable_entity(result_description="Validation exception") except ValueError as err: logger.error(f"{getattr(err, 'messages', str(err))}") db.session.rollback() return ResponseHelper.error(result_description=str(err)) except Exception as e: logger.error(f"An error occurred: {str(e)}", exc_info=True) db.session.rollback() return ResponseHelper.internal_server_error() @staticmethod def login_user(username, password): try: member = Members.get_member_by_username(username) if not member: invalid_data = { "error_message": "invalid username or password", "message_key": "invalid_username_or_password", } return ResponseHelper.success(data=invalid_data) pass_check = check_password_hash(member.password, password) logger.info("Password check: {}".format(pass_check)) if not member or not pass_check: invalid_data = { "error_message": "invalid username or password", "message_key": "invalid_username_or_password", } return ResponseHelper.success(data=invalid_data) user_data = {} user_data["id"] = member.id, user_data["member_id"]= member.id, user_data["uid"] = str(member.uid), user_token = jwt.encode( {"user": user_data, 'exp' : datetime.datetime.utcnow() + datetime.timedelta(minutes=3330)}, Config.JWT_SECRET_KEY, algorithm="HS256" ) # Simulate processing response_data = { "member_id": member.id, "uid": str(member.uid), "username": member.username, "account_name": member.account_name, "firstname":member.firstname, "lastname": member.lastname, "room": member.uid, "token": user_token } return ResponseHelper.success(data=response_data) except ValidationError as err: logger.error(f"Validation Error: {getattr(err, 'messages', str(err))}") db.session.rollback() return ResponseHelper.unprocessable_entity(result_description="Validation exception") except ValueError as err: logger.error(f"{getattr(err, 'messages', str(err))}") db.session.rollback() return ResponseHelper.error(result_description=str(err)) except Exception as e: logger.error(f"An error occurred: {str(e)}", exc_info=True) db.session.rollback() return ResponseHelper.internal_server_error() # @staticmethod # def check_loan_limits(customer_id): # """ # Checks if a customer has exceeded the loan limits for given offer. # """ # loan = Loan.get_customer_last_loan(customer_id) # # if not loan: # return True # # offer_id = loan.offer_id[:5] # # offer = Offer.get_offer_by_id(offer_id) # if not offer: # logger.error(f"Offer not found for offer_id: {offer_id} (customer_id: {customer_id})") # return False # # daily_count = Loan.get_daily_loan_count(customer_id, offer.product_id) # # logger.info(f"daily_count: {daily_count}, Max: {offer.max_daily_loans}") # # if offer.max_daily_loans is not None and daily_count >= offer.max_daily_loans: # return False # # return True