import dotenv from "dotenv";
import multer from "multer";
import multerS3 from "multer-s3";
import { S3Client, DeleteObjectCommand } from "@aws-sdk/client-s3";
import path from "path";

dotenv.config();

// Initialize S3 client
const s3 = new S3Client({
  credentials: {
    accessKeyId: process.env.ENV_AWS_ACCESS_KEY || "",
    secretAccessKey: process.env.ENV_AWS_SECRET_KEY || "",
  },
  region: process.env.ENV_AWS_REGION || "",
});

const BUCKET_NAME = process.env.ENV_AWS_BUCKET_NAME || "";

// Function to delete an image from S3
export const deleteImageFromS3 = async (imageKey: string) => {
  if (!imageKey) {
    throw new Error("Missing image key for deletion.");
  }
  if (!BUCKET_NAME) {
    throw new Error("S3 bucket name is not defined in environment variables.");
  }

  try {
    const deleteParams = { Bucket: BUCKET_NAME, Key: imageKey };
    const deleteCommand = new DeleteObjectCommand(deleteParams);
    await s3.send(deleteCommand);

    console.log(`Successfully deleted image: ${imageKey}`);
    return { success: true, message: `Deleted ${imageKey}` };
  } catch (error: any) {
    console.error("Error deleting image from S3:", error);
    return { success: false, error: error.message };
  }
};

// Set up multer with S3 storage
export const uploadImage = multer({
  storage: multerS3({
    s3: s3,
    bucket: BUCKET_NAME,
    metadata: (req, file, cb) => {
      cb(null, { fieldName: file.fieldname });
    },
    key: (req, file, cb) => {
      const fileName = `images/${file.fieldname}_${Date.now()}${path.extname(
        file.originalname
      )}`;
      cb(null, fileName);
    },
  }),
  fileFilter: (req, file, cb) => {
    const allowedMimeTypes = ["image/jpeg", "image/jpg", "image/png"];
    allowedMimeTypes.includes(file.mimetype)
      ? cb(null, true)
      : cb(new Error("Invalid file type. Only JPEG and PNG are allowed."));
  },
  limits: { fileSize: 5 * 1024 * 1024 }, // 5 MB max file size
});

router.post("/:shop_id/new", uploadImage.single("product_image"), addProduct);

export async function addProduct(req: Request, res: Response): Promise<void> {
  const { shop_id } = req.params;
  const payload = req.body;

  const fileUrl = req.file.location ?? null;


  try {
    // Validate shop_id
    if (!shop_id || isNaN(Number(shop_id))) {
      res.status(400).json({ message: "Invalid shop ID" });
      return;
    }

    // Validate required fields
    if (!payload.product_name || !payload.product_price) {
      res.status(400).json({ message: "Product name and price are required" });
      return;
    }

    // Check if the shop exists
    const checkQuery = "SELECT * FROM shop WHERE shop_id = ?";
    const [checkResult]: any = await pool.query(checkQuery, [shop_id]);

    if (checkResult.length === 0) {
      res.status(404).json({ message: "Shop not found" });
      return;
    }

    // Insert product into the database
    const queryText = `INSERT INTO product (product_name, product_description, product_price, product_image, shop_id)
                         VALUES (?, ?, ?, ?, ?)`;

    const [result]: any = await pool.query(queryText, [
      payload.product_name,
      payload.product_description || null,
      Number(payload.product_price),
      payload.product_image || null,
      shop_id,
    ]);

    res.status(201).json({
      message: "Product added successfully",
    });
  } catch (error) {
    console.error("Error adding product:", error);
    res.status(500).json({ message: "Internal server error" });
  }
}