app.py

from flask import Flask, request, jsonify, flash
import mysql.connector
from flask_cors import CORS, cross_origin
from mysql.connector import Error
import bcrypt
from werkzeug.security import generate_password_hash, check_password_hash
import re
from flask_sqlalchemy import SQLAlchemy
from flask_user import current_user, login_required, roles_required, UserManager, UserMixin
from email_validator import validate_email, EmailNotValidError

app = Flask(__name__)
CORS(app)
app.config['JSON_ADD_STATUS'] = True


@app.route('/sign-in', methods=['POST'])
def sign_in():
    result = [{'msg': 'success'}, {'stat': '200 ok'}]
    if request.method == 'POST':
        sign_in_details = request.get_json()
        email = sign_in_details['email']
        password = sign_in_details['password']

        hashed_value = generate_password_hash(password)
        connection = mysql.connector.connect(host="localhost", user="root", password="1234",
                                             database="sample_project_test_db")
        mycursor = connection.cursor()
        query = "INSERT into sign_in(email,password) "
       
        mycursor.execute(query)
        connection.commit()
        return jsonify({'result': result})
 

@app.route('/sign-in-check-2', methods=['POST'])
def sign_in_check2():
    
    if request.method == 'POST':
        sign_in_details = request.get_json(silent=True,force=True)
        email = sign_in_details['email']
        password = sign_in_details['password']
   
    connection = mysql.connector.connect(host="localhost", user="root", password="1234", database="sample_project_db")
    mycursor = connection.cursor()
    sql = "SELECT password FROM users Where email=%s LIMIT 1 "
    data_search = (email,)
    mycursor.execute(sql, data_search)
    results = mycursor.fetchone()[0]
    connection.commit()
    result = check_password_hash(results, password)
    
    if (result):
    	print("OKEY")
    	sql ="SELECT * FROM payment Where payment_email=%s "
    	data_search = (email,)
    	mycursor.execute(sql, data_search)
    	results = mycursor.fetchall()
    	return jsonify(results)

    else:
    	print("WRONG")
    	return jsonify("user details are invalid")



@app.route("/sign-in-get-all", methods=['POST'])
def sign_in_get_all():
    if request.method == 'POST':
        user_details = request.get_json()
        email = user_details['email']
        password = user_details['password']
        print(user_details)

    connection = mysql.connector.connect(host="localhost", user="root", password="1234", database="sample_project_db")
    mycursor = connection.cursor()
    mycursor.execute("SELECT * FROM users")
    results = mycursor.fetchall()
    connection.commit()
    return jsonify(results)


@app.route("/sign-in-get", methods=['POST'])
def sign_in_get():
    if request.method == 'POST':
        user_details = request.form
        email = user_details['email']
        password = user_details['password']
        print(user_details)

    connection = mysql.connector.connect(host="localhost", user="root", password="1234", database="sample_project_db")
    mycursor = connection.cursor()
    sql = "SELECT password FROM users Where email=%s LIMIT 1 "

    data_search = (email,)

    mycursor.execute(sql, data_search)

    results = mycursor.fetchone()[0]
    print(results)

    connection.commit()
    result = check_password_hash(results, password)
    return str(result)
    return jsonify({'results': result})


@app.route('/<password>', methods=['POST'])
def pasword_hash(password):
    hashed_value = generate_password_hash(password)
    print(hashed_value)
    stored_password = 'pbkdf2:sha256:150000$XDjeRCGn$7c8451de5476ff5c9ffbb038d2128cd0042032170d8b6388f0a8a9bf86f781b4'
    print(stored_password)
    result = check_password_hash(stored_password, password)
    print(result)
    return str(result)


@app.route("/sign-in-get-without-hash", methods=['GET'])
def sign_in_get_hash():
    sign_in_get_details = request.get_json()
    email = sign_in_get_details['email']
    password = sign_in_get_details['password']
    print(sign_in_get_details)

    connection = mysql.connector.connect(host="localhost", user="root", password="1234", database="sample_project_db")
    mycursor = connection.cursor()
    sql = "SELECT email,password FROM users Where email=%s AND password=%s "

    data_search = (email, password)

    mycursor.execute(sql, data_search)
    results = mycursor.fetchone()[0]
    print(results)

    connection.commit()
    result = check_password_hash(results, password)
    return str(result)
    return jsonify({'results': result})




@app.route('/sign-up', methods=['POST'])
def sign_up_get():
    result = [{'msg': 'success'}, {'stat': '200 ok'}]
    if request.method == 'POST':
        sign_up_details = request.get_json()
        email = sign_up_details['email']
        password = sign_up_details['password']
        firstname = sign_up_details['firstname']
        lastname = sign_up_details['lastname']

        hashed_value = generate_password_hash(password)
        connection = mysql.connector.connect(host="localhost", user="root", password="1234",
                                             database="sample_project_db")
        mycursor = connection.cursor()
        sql = "SELECT email FROM users Where email=%s"
        data_search = (email,)

        mycursor.execute(sql, data_search)
        results = mycursor.fetchall()
        print(results)
        if (results == []):
            
            regex = '(^[a-zA-Z0-9_.+-]+@[a-zA-Z0-9-]+\.[a-zA-Z0-9-.]+$)'

            # for custom mails use: '^[a-z0-9]+[\._]?[a-z0-9]+[@]\w+[.]\w+$'

            # Define a function for
            # for validating an Email
            # pass the regular expression
            # and the string in search() method
            if (re.search(regex, email)):
                print("Valid Email")

                l, u, p, d = 0, 0, 0, 0
                s = password
                if (len(s) >= 8):
                    for i in s:

                        # counting lowercase alphabets
                        if (i.islower()):
                            l += 1

                            # counting uppercase alphabets
                        if (i.isupper()):
                            u += 1

                            # counting digits
                        if (i.isdigit()):
                            d += 1

                            # counting the mentioned special characters
                        if (i == '@' or i == '$' or i == '_'):
                            p += 1
                if (l >= 1 and u >= 1 and p >= 1 and d >= 1 and l + p + u + d == len(s)):
                    print("Valid Password")

                    hashed_value = generate_password_hash(password)

                    connection = mysql.connector.connect(host="localhost", user="root", password="1234",
                                                         database="sample_project_db")
                    mycursor = connection.cursor()
                    query = "INSERT INTO users(first_name,last_name,email, password) VALUES (%s,%s,%s,%s)"
                    val = (firstname, lastname, email, hashed_value)
                    mycursor.execute(query, val)
                    connection.commit()
                    return "OKEY"
                else:
                    print("Please Try Again")
                    return "Invalid Password"


            else:
                print("Invalid Email")
                return "Enter Valid Email"

            l, u, p, d = 0, 0, 0, 0
            s = password
            if (len(s) >= 8):
                for i in s:

                    # counting lowercase alphabets
                    if (i.islower()):
                        l += 1

                        # counting uppercase alphabets
                    if (i.isupper()):
                        u += 1

                        # counting digits
                    if (i.isdigit()):
                        d += 1

                        # counting the mentioned special characters
                    if (i == '@' or i == '$' or i == '_'):
                        p += 1
            if (l >= 1 and u >= 1 and p >= 1 and d >= 1 and l + p + u + d == len(s)):
                print("Valid Password")

                hashed_value = generate_password_hash(password)

                connection = mysql.connector.connect(host="localhost", user="root", password="1234",
                                                     database="sample_project_db")
                mycursor = connection.cursor()
                query = "INSERT INTO users(first_name,last_name,email, password) VALUES (%s,%s,%s,%s)"
                val = (firstname, lastname, email, hashed_value)
                mycursor.execute(query, val)
                connection.commit()
                return jsonify({'result': result})
            else:
                print("Please Try Again")
                return "Invalid Password"



        else:
            print("user already exists in the database")
            return 'Please enter another email'



    connection.commit()
    return jsonify({'results': results})


@app.route('/address', methods=['POST'])
def address():
    result = [{'msg': 'success'}, {'stat': '200 ok'}]
    if request.method == 'POST':
        address_details = request.get_json()
        line1 = address_details['line1']
        line2 = address_details['line2']
        postalcode = address_details['postalcode']
        city = address_details['city']
        state = address_details['state']
        country = address_details['country']

        connection = mysql.connector.connect(host="localhost", user="root", password="1234",
                                             database="sample_project_db")
        mycursor = connection.cursor()
        query = "INSERT INTO  address(line1,line2,postal_code,city,state,country) VALUES (%s,%s,%s,%s,%s,%s)"
        val = (line1, line2, postalcode, city, state, country)
        mycursor.execute(query, val)
        connection.commit()
        return jsonify({'result': result})


@app.route('/payment', methods=['POST'])
def payment():
    result = [{'msg': 'success'}, {'stat': '200 ok'}]
    if request.method == 'POST':
        payment_details = request.get_json()
        paymenttype = payment_details['paymenttype']
        paymentamount = payment_details['paymentamount']
        paymentemail = payment_details['paymentemail']
        paymentownername = payment_details['paymentownername']
        
        

        connection = mysql.connector.connect(host="localhost", user="root", password="1234",
                                             database="sample_project_db")
        mycursor = connection.cursor()

        sql = "SELECT email FROM users Where email=%s"
        data_search = (paymentemail,)

        mycursor.execute(sql, data_search)
        results = mycursor.fetchall()
      
        if(results==[]):
        	return jsonify("Enter Valid email you Sign In")

        else:
        	query = "INSERT INTO  payment(payment_type,payment_amount,payment_email,payment_owner_name) VALUES (%s,%s,%s,%s)"
        	val = (paymenttype,paymentamount, paymentemail, paymentownername)
        	mycursor.execute(query, val)
        	connection.commit()
        	return jsonify("Payment Details successfully Entered Into the Database")


@app.route("/address-get", methods=['GET'])
def address_get():
    try:
        connection = mysql.connector.connect(host='localhost', database='sample_project_db', user='root',
                                             password='1234')
        sql_select_Query = "select * from address"
        cursor = connection.cursor()
        cursor.execute(sql_select_Query)
        records = cursor.fetchall()
        return jsonify({'records': records})

    except Error as e:
        print("Error reading data from MySQL table", e)
    finally:
        if (connection.is_connected()):
            connection.close()
            cursor.close()
            print("MySQL connection is closed")


@app.route('/business', methods=['POST'])
def business():
    result = [{'msg': 'success'}, {'stat': '200 ok'}]
    if request.method == 'POST':
        business_details = request.get_json()
        businessname = business_details['businessname']
        businessownername = business_details['businessownername']
        businessregno = business_details['businessregno']
        contactno = business_details['contactno']

        connection = mysql.connector.connect(host="localhost", user="root", password="1234",
                                             database="sample_project_db")
        mycursor = connection.cursor()
        query = "INSERT INTO  business(business_name,business_owner_name,business_reg_no,contact_no) VALUES (%s,%s,%s,%s)"
        val = (businessname, businessownername, businessregno, contactno)
        mycursor.execute(query, val)
        connection.commit()
        return jsonify({'result': result})


@app.route("/business-get", methods=['GET'])
def business_get():
    try:
        connection = mysql.connector.connect(host='localhost', database='sample_project_db', user='root',
                                             password='1234')
        sql_select_Query = "select * from business"
        cursor = connection.cursor()
        cursor.execute(sql_select_Query)
        records = cursor.fetchall()
        return jsonify({'records': records})

    except Error as e:
        print("Error reading data from MySQL table", e)
    finally:
        if (connection.is_connected()):
            connection.close()
            cursor.close()
            print("MySQL connection is closed")


if __name__ == "__main__":
    app.run(debug=True)