app.py

import cloudinary
from flask import Flask, render_template, request, redirect, url_for, jsonify
from cloudinary.uploader import upload
from os import getenv
from dotenv import load_dotenv
from supabase import create_client, Client

load_dotenv()

url: str = getenv("SUPABASE_URL")
key: str = getenv("SUPABASE_KEY")
supabase: Client = create_client(url, key)

app = Flask(__name__)

cloudinary.config(
    cloud_name=getenv("CLOUDINARY_CLOUD_NAME"),
    api_key=getenv("CLOUDINARY_API_KEY"),
    api_secret=getenv("CLOUDINARY_API_SECRET"),
    secure=True,
)

tableName = "new_products_prod"


@app.route("/")
def index():
    return render_template("upload.html")


@app.route("/products")
def products():
    response = supabase.table("new_products_prod").select("*").execute()
    return render_template("products.html", response=response)


@app.route("/upload", methods=["POST"])
def upload_image():
    # Get the uploaded image and other data
    image = request.files["image"]
    name = request.form["name"]
    brand_name = request.form["brand"]
    discounted_price = request.form["discounted_price"]
    category = request.form["category"]
    name = name + " - " + brand_name

    # Upload the image to Cloudinary
    result = upload(image, folder="new_products_dup")
    image_url = result["secure_url"]

    response = (
        supabase.table("extra_data_dup").select("*").eq("category", category).execute()
    )
    product_count = int(response.data[0]["prcount"])

    data, count = (
        supabase.table("new_products_prod")
        .insert(
            {
                "name": name.title(),
                "price": round(int(discounted_price) * 2),
                "disc_price": discounted_price,
                "category": category,
                "photo_url": image_url,
                "cat_sort": product_count + 1,
            }
        )
        .execute()
    )
    data, count = (
        supabase.table("extra_data_dup")
        .update({"prcount": product_count + 1})
        .eq("category", category)
        .execute()
    )
    return redirect(url_for("index"))


@app.route("/wa-upload", methods=["POST"])
def automateUpload():
    # get data from request
    data = request.get_json()
    # Get the uploaded image and other data
    image = data["image"]
    name = data["name"]
    category = data["category"]
    price = round(int(data["discounted_price"]) * 2)
    discounted_price = data["discounted_price"]
    # Upload the image to Cloudinary
    result = upload(image, folder="new_products_dup")
    image_url = result["secure_url"]
    # get count of that particular cateogory from "extra_data_dup" supabase db
    # remove leading and trailing spaces from category
    category = category.strip()
    response = (
        supabase.table("extra_data_dup").select("*").eq("category", category).execute()
    )
    product_count = int(response.data[0]["prcount"])
    data, count = (
        supabase.table(tableName)
        .insert(
            {
                "name": name.title(),
                "price": price,
                "disc_price": discounted_price,
                "category": category,
                "photo_url": image_url,
                "cat_sort": product_count + 1,
            }
        )
        .execute()
    )

    data, count = (
        supabase.table("extra_data_dup")
        .update({"prcount": product_count + 1})
        .eq("category", category)
        .execute()
    )
    return "Done"


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