Updating workshopt with strong contract structure, pictures for front and backend and ETL job

Author: tebanieo

workshops/modernizr/backend/src/database/migrate.ts

@@ -0,0 +1,70 @@
+#!/usr/bin/env node
+
+import { config } from 'dotenv';
+config();
+
+import fs from 'fs';
+import path from 'path';
+import { pool, closePool } from '../config/database';
+
+async function runMigration(migrationFile: string): Promise<void> {
+  try {
+    console.log(`Running migration: ${migrationFile}`);
+    
+    const migrationPath = path.join(__dirname, 'migrations', migrationFile);
+    
+    if (!fs.existsSync(migrationPath)) {
+      throw new Error(`Migration file not found: ${migrationPath}`);
+    }
+    
+    const migrationSql = fs.readFileSync(migrationPath, 'utf8');
+    
+    // Split the SQL into individual statements
+    const statements = migrationSql
+      .split(';')
+      .map(statement => statement.trim())
+      .filter(statement => statement.length > 0 && !statement.startsWith('--'));
+    
+    const connection = await pool.getConnection();
+    
+    try {
+      for (const statement of statements) {
+        console.log(`Executing: ${statement.substring(0, 50)}...`);
+        await connection.execute(statement);
+      }
+      console.log(`✅ Migration ${migrationFile} completed successfully`);
+    } finally {
+      connection.release();
+    }
+    
+  } catch (error) {
+    console.error(`❌ Migration ${migrationFile} failed:`, error);
+    throw error;
+  }
+}
+
+async function main() {
+  const migrationFile = process.argv[2];
+  
+  if (!migrationFile) {
+    console.log('Usage: npm run db:migrate <migration-file>');
+    console.log('Example: npm run db:migrate add_image_url_to_products.sql');
+    process.exit(1);
+  }
+  
+  try {
+    await runMigration(migrationFile);
+  } catch (error) {
+    console.error('Migration failed:', error);
+    process.exit(1);
+  } finally {
+    await closePool();
+  }
+}
+
+// Run if called directly
+if (require.main === module) {
+  main();
+}
+
+export { runMigration };

workshops/modernizr/backend/src/database/migrations/add_image_url_to_products.sql

@@ -0,0 +1,14 @@
+-- Migration: Add image_url column to products table
+-- This migration adds the image_url field to support product images
+
+ALTER TABLE products 
+ADD COLUMN image_url VARCHAR(500) NULL 
+AFTER inventory_quantity;
+
+-- Add some sample image URLs to existing products if they exist
+UPDATE products SET image_url = 'https://images.unsplash.com/photo-1496181133206-80ce9b88a853?w=500&h=500&fit=crop' WHERE name LIKE '%Laptop%' AND image_url IS NULL;
+UPDATE products SET image_url = 'https://images.unsplash.com/photo-1544947950-fa07a98d237f?w=500&h=500&fit=crop' WHERE name LIKE '%Novel%' AND image_url IS NULL;
+UPDATE products SET image_url = 'https://images.unsplash.com/photo-1578662996442-48f60103fc96?w=500&h=500&fit=crop' WHERE name LIKE '%Mixer%' AND image_url IS NULL;
+UPDATE products SET image_url = 'https://images.unsplash.com/photo-1542272604-787c3835535d?w=500&h=500&fit=crop' WHERE name LIKE '%Jeans%' AND image_url IS NULL;
+UPDATE products SET image_url = 'https://images.unsplash.com/photo-1571019613454-1cb2f99b2d8b?w=500&h=500&fit=crop' WHERE name LIKE '%Dumbbell%' AND image_url IS NULL;
+UPDATE products SET image_url = 'https://images.unsplash.com/photo-1504148455328-c376907d081c?w=500&h=500&fit=crop' WHERE name LIKE '%Drill%' AND image_url IS NULL;

workshops/modernizr/backend/src/database/schema.sql

@@ -43,6 +43,7 @@ CREATE TABLE IF NOT EXISTS products (
     description TEXT,
     price DECIMAL(10,2) NOT NULL,
     inventory_quantity INT NOT NULL DEFAULT 0,
+    image_url VARCHAR(500) NULL,
     created_at TIMESTAMP DEFAULT CURRENT_TIMESTAMP,
     updated_at TIMESTAMP DEFAULT CURRENT_TIMESTAMP ON UPDATE CURRENT_TIMESTAMP,
 

workshops/modernizr/backend/src/database/seed.ts

@@ -220,6 +220,7 @@ async function seedProducts(): Promise<void> {
       description: 'High-performance laptop with advanced processor, 14-inch display, 16GB RAM, 512GB SSD. Perfect for professional work and creative projects.',
       price: 1999.99,
       inventory_quantity: 15,
+      image_url: 'https://images.unsplash.com/photo-1541807084-5c52b6b3adef?w=600&h=600&fit=crop&auto=format',
       category_id: laptopCategoryId,
       seller_id: adminId
     },
@@ -228,6 +229,7 @@ async function seedProducts(): Promise<void> {
       description: 'A timeless story about the Jazz Age exploring themes of wealth, love, and the American Dream. A must-read classic.',
       price: 12.99,
       inventory_quantity: 50,
+      image_url: 'https://images.unsplash.com/photo-1543002588-bfa74002ed7e?w=600&h=600&fit=crop&auto=format',
       category_id: booksCategoryId,
       seller_id: adminId
     },
@@ -236,6 +238,7 @@ async function seedProducts(): Promise<void> {
       description: 'Professional 5-quart stand mixer with 10 speeds. Includes dough hook, flat beater, and wire whip. Perfect for baking enthusiasts.',
       price: 299.99,
       inventory_quantity: 8,
+      image_url: 'https://images.unsplash.com/photo-1578643463396-0997cb5328c1?w=600&h=600&fit=crop&auto=format',
       category_id: kitchenCategoryId,
       seller_id: adminId
     },
@@ -244,6 +247,7 @@ async function seedProducts(): Promise<void> {
       description: 'Classic straight-leg jeans in dark wash. Made from 100% cotton denim. Timeless style and comfortable fit.',
       price: 89.99,
       inventory_quantity: 25,
+      image_url: 'https://images.unsplash.com/photo-1582552938357-32b906df40cb?w=600&h=600&fit=crop&auto=format',
       category_id: clothingCategoryId,
       seller_id: adminId
     },
@@ -252,6 +256,7 @@ async function seedProducts(): Promise<void> {
       description: 'Space-saving adjustable dumbbells with weight range from 5-50 lbs per dumbbell. Quick-change system for efficient workouts.',
       price: 449.99,
       inventory_quantity: 12,
+      image_url: 'https://images.unsplash.com/photo-1586401100295-7a8096fd231a?w=600&h=600&fit=crop&auto=format',
       category_id: sportsCategoryId,
       seller_id: adminId
     },
@@ -260,6 +265,7 @@ async function seedProducts(): Promise<void> {
       description: '20V MAX cordless drill with 2 batteries, charger, and carrying case. 1/2-inch chuck, LED light, and 15 clutch settings.',
       price: 129.99,
       inventory_quantity: 20,
+      image_url: 'https://images.unsplash.com/photo-1504148455328-c376907d081c?w=600&h=600&fit=crop&auto=format',
       category_id: gardenCategoryId,
       seller_id: adminId
     }
@@ -270,15 +276,16 @@ async function seedProducts(): Promise<void> {
       try {
         await pool.execute(
           `INSERT IGNORE INTO products 
-           (seller_id, category_id, name, description, price, inventory_quantity) 
-           VALUES (?, ?, ?, ?, ?, ?)`,
+           (seller_id, category_id, name, description, price, inventory_quantity, image_url) 
+           VALUES (?, ?, ?, ?, ?, ?, ?)`,
           [
             product.seller_id,
             product.category_id,
             product.name,
             product.description,
             product.price,
-            product.inventory_quantity
+            product.inventory_quantity,
+            product.image_url || null
           ]
         );
         console.log(`✓ Inserted product: ${product.name} (category_id: ${product.category_id})`);

workshops/modernizr/backend/src/models/Product.ts

@@ -6,6 +6,7 @@ export interface Product {
   description?: string;
   price: number;
   inventory_quantity: number;
+  image_url?: string;
   created_at: Date;
   updated_at: Date;
 }
@@ -22,6 +23,7 @@ export interface CreateProductRequest {
   category_id: number;
   price: number;
   inventory_quantity: number;
+  image_url?: string;
 }
 
 export interface UpdateProductRequest {
@@ -30,6 +32,7 @@ export interface UpdateProductRequest {
   category_id?: number;
   price?: number;
   inventory_quantity?: number;
+  image_url?: string;
 }
 
 export interface ProductSearchFilters {
@@ -83,6 +86,7 @@ export function toProductResponse(product: ProductWithDetails): any {
     description: product.description,
     price: Number(product.price),
     inventory_quantity: product.inventory_quantity,
+    imageUrl: product.image_url, // Map database field to frontend field
     category: {
       id: product.category_id,
       name: product.category_name || 'Uncategorized'
@@ -126,6 +130,12 @@ export function validateCreateProductRequest(data: any): CreateProductRequest {
     errors.push('Inventory quantity cannot exceed 999,999');
   }
 
+  if (data.image_url && typeof data.image_url !== 'string') {
+    errors.push('Image URL must be a string');
+  } else if (data.image_url && data.image_url.length > 500) {
+    errors.push('Image URL must be 500 characters or less');
+  }
+
   if (errors.length > 0) {
     throw new Error(errors.join(', '));
   }
@@ -136,6 +146,7 @@ export function validateCreateProductRequest(data: any): CreateProductRequest {
     category_id: Number(data.category_id),
     price: Number(data.price),
     inventory_quantity: Number(data.inventory_quantity),
+    image_url: data.image_url?.trim() || undefined,
   };
 }
 
@@ -191,6 +202,16 @@ export function validateUpdateProductRequest(data: any): UpdateProductRequest {
     }
   }
 
+  if (data.image_url !== undefined) {
+    if (data.image_url !== null && typeof data.image_url !== 'string') {
+      errors.push('Image URL must be a string or null');
+    } else if (data.image_url && data.image_url.length > 500) {
+      errors.push('Image URL must be 500 characters or less');
+    } else {
+      update.image_url = data.image_url?.trim() || undefined;
+    }
+  }
+
   if (errors.length > 0) {
     throw new Error(errors.join(', '));
   }

workshops/modernizr/backend/src/repositories/OrderRepository.ts

@@ -98,6 +98,7 @@ export class OrderRepository {
           p.description as product_description,
           p.price as current_price,
           p.inventory_quantity as product_inventory,
+          p.image_url as product_image_url,
           p.created_at as product_created_at,
           p.updated_at as product_updated_at,
           c.name as category_name,
@@ -126,6 +127,7 @@ export class OrderRepository {
           description: row.product_description,
           price: parseFloat(row.current_price),
           inventory_quantity: row.product_inventory,
+          image_url: row.product_image_url,
           category_name: row.category_name,
           seller_username: row.seller_username,
           seller_email: row.seller_email,
@@ -180,6 +182,7 @@ export class OrderRepository {
             p.description as product_description,
             p.price as current_price,
             p.inventory_quantity as product_inventory,
+            p.image_url as product_image_url,
             p.created_at as product_created_at,
             p.updated_at as product_updated_at,
             c.name as category_name,
@@ -208,6 +211,7 @@ export class OrderRepository {
             description: row.product_description,
             price: parseFloat(row.current_price),
             inventory_quantity: row.product_inventory,
+            image_url: row.product_image_url,
             category_name: row.category_name,
             seller_username: row.seller_username,
             seller_email: row.seller_email,
@@ -293,6 +297,7 @@ export class OrderRepository {
             p.description as product_description,
             p.price as current_price,
             p.inventory_quantity as product_inventory,
+            p.image_url as product_image_url,
             p.created_at as product_created_at,
             p.updated_at as product_updated_at,
             c.name as category_name,
@@ -321,6 +326,7 @@ export class OrderRepository {
             description: row.product_description,
             price: parseFloat(row.current_price),
             inventory_quantity: row.product_inventory,
+            image_url: row.product_image_url,
             category_name: row.category_name,
             seller_username: row.seller_username,
             seller_email: row.seller_email,

workshops/modernizr/backend/src/repositories/ProductRepository.ts

@@ -29,15 +29,16 @@ export class ProductRepository {
 
       // Insert the product
       const [result] = await connection.execute(
-        `INSERT INTO products (seller_id, category_id, name, description, price, inventory_quantity)
-         VALUES (?, ?, ?, ?, ?, ?)`,
+        `INSERT INTO products (seller_id, category_id, name, description, price, inventory_quantity, image_url)
+         VALUES (?, ?, ?, ?, ?, ?, ?)`,
         [
           sellerId,
           productData.category_id,
           productData.name,
           productData.description || null,
           productData.price,
-          productData.inventory_quantity
+          productData.inventory_quantity,
+          productData.image_url || null
         ]
       );
 
@@ -70,6 +71,7 @@ export class ProductRepository {
            description,
            price,
            inventory_quantity,
+           image_url,
            created_at,
            updated_at
          FROM products WHERE id = ?`,
@@ -94,7 +96,16 @@ export class ProductRepository {
     try {
       const [rows] = await connection.execute(
         `SELECT 
-           p.*,
+           p.id,
+           p.seller_id,
+           p.category_id,
+           p.name,
+           p.description,
+           p.price,
+           p.inventory_quantity,
+           p.image_url,
+           p.created_at,
+           p.updated_at,
            c.name as category_name,
            u.username as seller_username,
            u.email as seller_email
@@ -171,6 +182,11 @@ export class ProductRepository {
         updateValues.push(updateData.inventory_quantity);
       }
 
+      if (updateData.image_url !== undefined) {
+        updateFields.push('image_url = ?');
+        updateValues.push(updateData.image_url);
+      }
+      
       if (updateFields.length === 0) {
         // No fields to update, return existing product
         return existingProduct;
@@ -291,6 +307,7 @@ export class ProductRepository {
           p.description,
           p.price,
           p.inventory_quantity,
+          p.image_url,
           p.created_at,
           p.updated_at,
           c.name as category_name,

workshops/modernizr/backend/src/repositories/ShoppingCartRepository.ts

@@ -77,6 +77,7 @@ export class ShoppingCartRepository {
           p.description as product_description,
           p.price as product_price,
           p.inventory_quantity as product_inventory,
+          p.image_url as product_image_url,
           p.created_at as product_created_at,
           p.updated_at as product_updated_at,
           c.name as category_name,
@@ -106,6 +107,7 @@ export class ShoppingCartRepository {
           description: row.product_description,
           price: parseFloat(row.product_price),
           inventory_quantity: row.product_inventory,
+          image_url: row.product_image_url,
           category_name: row.category_name,
           seller_username: row.seller_username,
           seller_email: row.seller_email,