From d40f448f18d70dfdeb5fa2e94389edf27caf3d0c Mon Sep 17 00:00:00 2001
From: DualFroz <me@dualfroz.com>
Date: Mon, 24 Aug 2026 14:13:30 +0200
Subject: [PATCH] feat(data): add product repository

---
 src/Repositories/ProductRepository.php | 152 +++++++++++++++++++++++++
 1 file changed, 152 insertions(+)
 create mode 100644 src/Repositories/ProductRepository.php

diff --git a/src/Repositories/ProductRepository.php b/src/Repositories/ProductRepository.php
new file mode 100644
index 0000000..479f8d9
--- /dev/null
+++ b/src/Repositories/ProductRepository.php
@@ -0,0 +1,152 @@
+<?php
+
+namespace Bazaar\Repositories;
+
+use Bazaar\Core\Database;
+
+final class ProductRepository
+{
+    public function __construct(private readonly Database $db)
+    {
+    }
+
+    public function find(int $id): ?array
+    {
+        return $this->db->selectOne('SELECT * FROM products WHERE id = ?', [$id]);
+    }
+
+    public function findActive(int $id): ?array
+    {
+        return $this->db->selectOne('SELECT * FROM products WHERE id = ? AND isActive = 1', [$id]);
+    }
+
+    public function findBySlug(string $slug): ?array
+    {
+        return $this->db->selectOne(
+            'SELECT p.*, c.name AS categoryName, c.slug AS categorySlug
+             FROM products p
+             LEFT JOIN categories c ON c.id = p.categoryId
+             WHERE p.slug = ? AND p.isActive = 1',
+            [$slug]
+        );
+    }
+
+    public function search(?string $categorySlug, ?string $term, string $sort = 'newest'): array
+    {
+        $sql = 'SELECT p.*, c.name AS categoryName, c.slug AS categorySlug
+                FROM products p
+                LEFT JOIN categories c ON c.id = p.categoryId
+                WHERE p.isActive = 1';
+        $bindings = [];
+
+        if ($categorySlug !== null && $categorySlug !== '') {
+            $sql .= ' AND c.slug = ?';
+            $bindings[] = $categorySlug;
+        }
+        if ($term !== null && trim($term) !== '') {
+            $sql .= ' AND (p.name LIKE ? OR p.description LIKE ?)';
+            $like = '%' . trim($term) . '%';
+            $bindings[] = $like;
+            $bindings[] = $like;
+        }
+
+        $sql .= match ($sort) {
+            'priceAsc' => ' ORDER BY p.priceCents ASC',
+            'priceDesc' => ' ORDER BY p.priceCents DESC',
+            'name' => ' ORDER BY p.name ASC',
+            default => ' ORDER BY p.createdAt DESC, p.id DESC',
+        };
+
+        return $this->db->select($sql, $bindings);
+    }
+
+    public function featured(int $limit = 6): array
+    {
+        return $this->db->select(
+            'SELECT p.*, c.name AS categoryName, c.slug AS categorySlug
+             FROM products p
+             LEFT JOIN categories c ON c.id = p.categoryId
+             WHERE p.isActive = 1
+             ORDER BY p.createdAt DESC, p.id DESC
+             LIMIT ?',
+            [$limit]
+        );
+    }
+
+    public function allForAdmin(): array
+    {
+        return $this->db->select(
+            'SELECT p.*, c.name AS categoryName
+             FROM products p
+             LEFT JOIN categories c ON c.id = p.categoryId
+             ORDER BY p.createdAt DESC, p.id DESC'
+        );
+    }
+
+    public function create(array $fields): int
+    {
+        return $this->db->insert(
+            'INSERT INTO products
+                (categoryId, name, slug, description, priceCents, stockQuantity, imageUrl, isActive, createdAt)
+             VALUES (?, ?, ?, ?, ?, ?, ?, ?, ?)',
+            [
+                $fields['categoryId'],
+                $fields['name'],
+                $fields['slug'],
+                $fields['description'],
+                $fields['priceCents'],
+                $fields['stockQuantity'],
+                $fields['imageUrl'],
+                $fields['isActive'] ? 1 : 0,
+                gmdate('c'),
+            ]
+        );
+    }
+
+    public function update(int $id, array $fields): void
+    {
+        $this->db->statement(
+            'UPDATE products SET
+                categoryId = ?, name = ?, slug = ?, description = ?,
+                priceCents = ?, stockQuantity = ?, imageUrl = ?, isActive = ?
+             WHERE id = ?',
+            [
+                $fields['categoryId'],
+                $fields['name'],
+                $fields['slug'],
+                $fields['description'],
+                $fields['priceCents'],
+                $fields['stockQuantity'],
+                $fields['imageUrl'],
+                $fields['isActive'] ? 1 : 0,
+                $id,
+            ]
+        );
+    }
+
+    public function delete(int $id): void
+    {
+        $this->db->statement('DELETE FROM products WHERE id = ?', [$id]);
+    }
+
+    public function count(): int
+    {
+        return (int) $this->db->scalar('SELECT COUNT(*) FROM products');
+    }
+
+    public function lowStock(int $threshold = 5): array
+    {
+        return $this->db->select(
+            'SELECT * FROM products WHERE stockQuantity <= ? ORDER BY stockQuantity ASC',
+            [$threshold]
+        );
+    }
+
+    public function decrementStock(int $id, int $quantity): void
+    {
+        $this->db->statement(
+            'UPDATE products SET stockQuantity = stockQuantity - ? WHERE id = ?',
+            [$quantity, $id]
+        );
+    }
+}