feat: add public product catalog boundary

This commit is contained in:
2026-09-08 18:20:04 -04:00
parent f29629c712
commit 43f4f69894
11 changed files with 233 additions and 9 deletions
@@ -1,6 +1,10 @@
import { and, asc, eq } from 'drizzle-orm';
import { and, asc, eq, inArray } from 'drizzle-orm';
import { products } from '../../../infrastructure/database/schema.js';
import {
inventoryItems,
listings,
products,
} from '../../../infrastructure/database/schema.js';
export function createProductRepository(db) {
return {
@@ -18,6 +22,22 @@ export function createProductRepository(db) {
return product ?? null;
},
async findPublicBySlug(slug) {
const [result] = await db
.select({ product: products })
.from(products)
.innerJoin(inventoryItems, eq(inventoryItems.productId, products.id))
.innerJoin(listings, eq(listings.inventoryItemId, inventoryItems.id))
.where(and(
eq(products.slug, slug),
eq(inventoryItems.status, 'ACTIVE'),
inArray(listings.status, ['AVAILABLE', 'PENDING']),
))
.limit(1);
return result?.product ?? null;
},
async findBySellerIdAndSlug(sellerId, slug) {
const [product] = await db
.select()
@@ -0,0 +1,10 @@
import { toPublicProductDto } from '@pokemon-inventory/contracts/public-product';
export async function registerPublicProductRoutes(app, options) {
const { publicProductService } = options;
app.get('/public/products/:slug', async (request) => {
const product = await publicProductService.getBySlug(request.params.slug);
return { data: toPublicProductDto(product) };
});
}
@@ -0,0 +1,15 @@
import { createApplicationError } from '../../../shared/errors/application-error.js';
export function createPublicProductService({ productRepository }) {
return {
async getBySlug(slug) {
const product = await productRepository.findPublicBySlug(slug);
if (!product) {
throw createApplicationError('PRODUCT_NOT_FOUND', 'Product was not found.', 404);
}
return product;
},
};
}