from rest_framework.views import APIView from rest_framework.response import Response from rest_framework import status from django.contrib.auth.hashers import make_password, check_password from rest_framework_simplejwt.tokens import RefreshToken # from rest_framework.permission import IsAuthentication from .authentication import authenticated from .models import User from user_panel.models import * from admin_panel.models import * from passlib.hash import django_pbkdf2_sha256 as handler import random from django.conf import settings from django.template.loader import render_to_string from django.core.mail import send_mail # Create your views here. from django.core import mail from admin_panel.functions import * from admin_panel.views import * from datetime import datetime #Register# class userRegister(APIView): def post(self, request): email = request.data.get("email") password = request.data.get("password") if not email: return Response({"message": 'email is required'}, status=status.HTTP_400_BAD_REQUEST) if not password: return Response({"message": 'password is required'}, status=status.HTTP_400_BAD_REQUEST) if EndUser.objects.filter(email=email).exists(): return Response({"message": "User with this email already exists"}, status=status.HTTP_400_BAD_REQUEST) user = EndUser.objects.create( email=email, password=make_password(password) ) return Response({"message": "User registered successfully"}, status=status.HTTP_201_CREATED) #loginpage# class loginUser(APIView): def post(self,request): email = request.data.get('email') password = request.data.get('password') if not email: return Response({"message":'email is required'},status=status.HTTP_400_BAD_REQUEST) if not password: return Response({"message":'password is required'},status=status.HTTP_400_BAD_REQUEST) try: user = EndUser.objects.get(email=email) except EndUser.DoesNotExist: return Response({"message": "Invalid credentials"}, status=status.HTTP_401_UNAUTHORIZED) if not check_password(password, user.password): return Response({"message": "Invalid credentials"}, status=status.HTTP_401_UNAUTHORIZED) refresh = RefreshToken.for_user(user) return Response({ "message": "Login successful", "access": str(refresh.access_token), "refresh": str(refresh) }, status=status.HTTP_200_OK) #UserChangepasword# class userChangePassword(APIView): def post(self,request): try: try: uid = authenticated(request) except Exception as e: return Response({'message': str(e)}, status=status.HTTP_401_UNAUTHORIZED) user_obj = EndUser.objects.filter(id=uid).first() if not user_obj: return Response({'message': 'user not found'}, status=status.HTTP_404_NOT_FOUND) admin_obj = SuperAdmin.objects.all().first() if user_obj.status == False: return Response({"message":'Your account has been Inactive, Please contact to admin.',"email":admin_obj.email},status=status.HTTP_406_NOT_ACCEPTABLE) old_password = request.data.get('old_password') if not old_password: return Response({'message':'old password is required'},status=status.HTTP_400_BAD_REQUEST) new_password = request.data.get('new_password') if not new_password: return Response({'message':'new password is required'},status=status.HTTP_400_BAD_REQUEST) check_password = user_obj.password check = handler.verify(old_password,check_password) if check == False: return Response({'message':'Old password is incorrect'},status=status.HTTP_403_FORBIDDEN) password = new_password encrypt_password = handler.hash(password) user_obj.password = encrypt_password user_obj.save() return Response({'message':'Success'}) except Exception as e: return Response({'message':str(e)},status=status.HTTP_500_INTERNAL_SERVER_ERROR) # #forgetpassword# class userForgetPassword(APIView): def post(self,request): try: data = request.data email = data.get('email').strip().lower() if not email: return Response({"message":'Email is required'}) user = EndUser.objects.filter(email=email).count() if user == 0: return Response({"message":'This email does not exist in our database, please enter the valid email address.'},status=status.HTTP_404_NOT_FOUND) user_obj = EndUser.objects.filter(email=email).first() if user_obj: theotp=random.randrange(1000, 9999, 5) user_obj.forgot_password_otp=theotp user_obj.save() print("------------",user_obj,"the otp") to_email = user_obj.email subject = "Forget Password OTP" html_message = render_to_string('forget_password_otp.html', {'otp': theotp}) plain_message = html_message from_email = settings.EMAIL_HOST_USER mail.send_mail(subject, plain_message, from_email, [to_email], html_message=html_message) return Response({ "message": "Rendered HTML", "html": html_message }) # return Response({"message":'Reset Password OTP has been sent to this email address'}) else: return Response({"message":'Email not exists'}) except Exception as e: print(e) return Response({"message":str(e)},status=status.HTTP_500_INTERNAL_SERVER_ERROR) # #verifyforgetpassword# class verifyForgetPasswordOTP (APIView): def post(self,request): try: email = request.data.get('email').strip().lower() if not email: return Response({'status_code':status.HTTP_400_BAD_REQUEST,'status_message':'Email is required'},status=status.HTTP_400_BAD_REQUEST) otp = request.data.get('otp') if not otp: return Response({'status_code':status.HTTP_400_BAD_REQUEST,'status_message':'otp is Required'},status =status.HTTP_400_BAD_REQUEST) check_email = EndUser.objects.filter(email = email).filter() if not check_email : return Response({'status_code':status.HTTP_400_BAD_REQUEST,'status_message':'Email not exist'},status=status.HTTP_400_BAD_REQUEST) user_obj = EndUser.objects.filter(email= email,forget_password_otp = otp) if user_obj: return Response({'status_code':status.HTTP_200_OK,'status_message':'Successfully Verified'}) else: return Response({'status_code':status.HTTP_400_BAD_REQUEST,'status_message':'Invalid otp'}) except Exception as e: return Response({'status_code':status.HTTP_500_INTERNAL_SERVER_ERROR,'status_message':str(e)},status=status.HTTP_500_INTERNAL_SERVER_ERROR) class changeForgetPassword(APIView): def post(self,request): try: email = request.data.get('email').strip().lower() if not email: return Response({'message': 'email is required'}, status=status.HTTP_404_NOT_FOUND) user_obj = EndUser.objects.filter(email=email).first() if not user_obj: return Response({'message': 'user not found'}, status=status.HTTP_404_NOT_FOUND) admin_obj = SuperAdmin.objects.all().first() if user_obj.status == False: return Response({"message":'Your account has been Inactive, Please contact to admin.',"email":admin_obj.email},status=status.HTTP_406_NOT_ACCEPTABLE) new_password = request.data.get('new_password') if not new_password: return Response({'message':'new password is required'},status=status.HTTP_400_BAD_REQUEST) confirm_password = request.data.get('confirm_password') if not confirm_password: return Response({'message':'confirm password is required'},status=status.HTTP_400_BAD_REQUEST) if new_password != confirm_password: return Response({'message':'Password and confirm password are not same.'},status=status.HTTP_403_FORBIDDEN) encrypt_password = handler.hash(confirm_password) user_obj.password = encrypt_password user_obj.save() return Response({'message':'Success'}) except Exception as e: return Response({'message':str(e)},status=status.HTTP_500_INTERNAL_SERVER_ERROR) class updateProfile(APIView): def get(self,request): try: try: uid = authenticated(request) print("=================",uid) except Exception as e : return Response({'message':str(e)},status=status.HTTP_401_UNAUTHORIZED) user_obj = EndUser.objects.filter(id=uid).first() if not user_obj: return Response({'message': 'user not found'}, status=status.HTTP_404_NOT_FOUND) print("=================",user_obj) all_data ={ "name":user_obj.name, "gender":user_obj.gender, "phone_number":user_obj.phone_number, "image":user_obj.image } return Response({'status_code':status.HTTP_200_OK,'status_message':'Fetched Successfully','all_data':all_data}) except Exception as e: return Response({'message':str(e)},status=status.HTTP_500_INTERNAL_SERVER_ERROR) def post(self,request): try: try: uid = authenticated(request) except Exception as e : return Response({'message':str(e)},status=status.HTTP_401_UNAUTHORIZED) user_obj = EndUser.objects.filter(id=uid).first() if not user_obj: return Response({'message': 'user not found'}, status=status.HTTP_404_NOT_FOUND) name = request.data.get("name") gender = request.data.get("gender") phone_number =request.data.get("phone_number") image = request.data.get("image") # if request.FILES.get("image"): # uploaded_image = request.FILES["image"] # file_url = uploadTheImages(uploaded_image) # Your custom image upload function # user_obj.image = "/" + file_url # Save path in DB user_obj.name = name user_obj.gender = gender user_obj.phone_number = phone_number user_obj.image = image user_obj.save() print("user_obj",user_obj) return Response({'status_code':status.HTTP_200_OK,'status_message':'Profile updated successfully'}) except Exception as e: return Response({'message':str(e)},status=status.HTTP_500_INTERNAL_SERVER_ERROR) class UploadImages(APIView): def post(self,request): try: data = request.data images = data.getlist('image') image_urls = [] for image in images: image_path = uploadTheDocument(image) image_urls.append(image_path) return Response({'status_code':status.HTTP_200_OK,'status_message':'Success','data':image_urls}) except Exception as e: return Response({'message': str(e)}, status=status.HTTP_500_INTERNAL_SERVER_ERROR) class chatBot(APIView): def get(self,request): try: try: uid = authenticated(request) except Exception as e : return Response({'message':str(e)},status=status.HTTP_401_UNAUTHORIZED) user_obj = EndUser.objects.filter(id = uid).first() if not user_obj: return Response({'message': 'user not found'}, status=status.HTTP_404_NOT_FOUND) chatBots = chatBot_setting.objects.filter(user_id = str(uid)) chatbot_listing =[] for bot in chatBots: chatbot_listing.append({ "id":bot.id, "user_id":bot.user_id, "chatbot_name":bot.chatbot_name, "categories_name":bot.categories_name, "description":bot.description, "pdf_data":bot.pdf_data, "created_at":bot.created_at }) return Response({'message': 'Success', 'data': chatbot_listing}, status=status.HTTP_200_OK) except Exception as e: return Response({'message': 'Internal server error', 'details': str(e)}, status=status.HTTP_500_INTERNAL_SERVER_ERROR) def post(self,request): try: try: uid = authenticated(request) except Exception as e : return Response({'message':str(e)},status=status.HTTP_401_UNAUTHORIZED) user_obj = EndUser.objects.filter(id=uid).first() if not user_obj: return Response({'message': 'user not found'}, status=status.HTTP_404_NOT_FOUND) data= request.data chatbot = chatBot_setting.objects.create( user_id = user_obj, chatbot_name = data.get('chatbot_name'), categories_name = data.get('categories_name'), description = data.get('description'), pdf_data = data.get('pdf_data'), created_at = data.get('created_at'), ) return Response({'message': 'Chatbot setting created', 'chatbot_id': chatbot.id}, status=status.HTTP_201_CREATED) except Exception as e: return Response({'message': 'Internal server error', 'details': str(e)}, status=status.HTTP_500_INTERNAL_SERVER_ERROR)