package main

import (
	"log"

	_ "github.com/jackc/pgx/v5/stdlib"
	"github.com/jmoiron/sqlx"
	"github.com/saveinmed/backend-go/internal/config"
)

func main() {
	cfg := config.Load()

	log.Printf("Connecting to DB: %s", cfg.DatabaseURL)
	db, err := sqlx.Connect("pgx", cfg.DatabaseURL)
	if err != nil {
		log.Fatalf("Connection failed: %v", err)
	}
	defer db.Close()

	query := `
	ALTER TABLE cart_items ADD COLUMN IF NOT EXISTS batch TEXT;
	ALTER TABLE cart_items ADD COLUMN IF NOT EXISTS expires_at DATE;

	ALTER TABLE products ADD COLUMN IF NOT EXISTS batch TEXT DEFAULT '';
	ALTER TABLE products ADD COLUMN IF NOT EXISTS stock BIGINT DEFAULT 0;
	ALTER TABLE products ADD COLUMN IF NOT EXISTS expires_at DATE DEFAULT CURRENT_DATE;
	
	`

	log.Println("Executing Schema Fix (Adding batch/expires_at to cart_items)...")
	_, err = db.Exec(query)
	if err != nil {
		log.Fatalf("Migration failed: %v", err)
	}

	log.Println("SUCCESS: Schema updated.")
}