feat: add public seller directory

This commit is contained in:
2026-09-08 19:36:13 -04:00
parent 206bb18da6
commit a76d777a6b
11 changed files with 152 additions and 2 deletions
+5
View File
@@ -11,6 +11,7 @@ import { registerPublicListingRoutes } from '../modules/listings/routes/public-l
import { registerAdminProductRoutes } from '../modules/products/routes/admin-product-routes.js';
import { registerPublicProductRoutes } from '../modules/products/routes/public-product-routes.js';
import { registerPublicSearchRoutes } from '../modules/search/routes/public-search-routes.js';
import { registerPublicSellerRoutes } from '../modules/sellers/routes/public-seller-routes.js';
export function buildApp(dependencies) {
const app = Fastify();
@@ -70,6 +71,10 @@ export function buildApp(dependencies) {
...dependencies,
prefix: '/api/v1',
});
app.register(registerPublicSellerRoutes, {
...dependencies,
prefix: '/api/v1',
});
return app;
}
+4
View File
@@ -28,6 +28,8 @@ import { createProductRepository } from '../modules/products/repositories/produc
import { createProductService } from '../modules/products/services/product-service.js';
import { createPublicProductService } from '../modules/products/services/public-product-service.js';
import { createSearchService } from '../modules/search/services/search-service.js';
import { createSellerRepository } from '../modules/sellers/repositories/seller-repository.js';
import { createPublicSellerService } from '../modules/sellers/services/public-seller-service.js';
function parsePort(value) {
const port = Number.parseInt(value ?? '3000', 10);
@@ -46,6 +48,7 @@ async function startServer() {
const inventoryItemRepository = createInventoryItemRepository(database.db);
const inventoryImageRepository = createInventoryImageRepository(database.db);
const listingRepository = createListingRepository(database.db);
const sellerRepository = createSellerRepository(database.db);
const conditionRepository = createConditionRepository(database.db);
const userRepository = createUserRepository(database.db);
const sessionRepository = createSessionRepository(database.db);
@@ -93,6 +96,7 @@ async function startServer() {
productService: createProductService({ productRepository }),
publicProductService: createPublicProductService({ productRepository }),
searchService: createSearchService({ listingRepository }),
publicSellerService: createPublicSellerService({ sellerRepository }),
});
app.addHook('onClose', async () => {
@@ -0,0 +1,32 @@
import { and, asc, eq, inArray } from 'drizzle-orm';
import {
inventoryItems,
listings,
products,
sellers,
} from '../../../infrastructure/database/schema.js';
export function createSellerRepository(db) {
return {
async listPublic() {
return db
.select({
id: sellers.id,
displayName: sellers.displayName,
createdAt: sellers.createdAt,
updatedAt: sellers.updatedAt,
})
.from(sellers)
.innerJoin(products, eq(products.sellerId, sellers.id))
.innerJoin(inventoryItems, eq(inventoryItems.productId, products.id))
.innerJoin(listings, eq(listings.inventoryItemId, inventoryItems.id))
.where(and(
eq(inventoryItems.status, 'ACTIVE'),
inArray(listings.status, ['AVAILABLE', 'PENDING']),
))
.groupBy(sellers.id, sellers.displayName, sellers.createdAt, sellers.updatedAt)
.orderBy(asc(sellers.displayName));
},
};
}
@@ -0,0 +1,9 @@
import { toPublicSellerDto } from '@pokemon-inventory/contracts/public-seller';
export async function registerPublicSellerRoutes(app, options) {
const { publicSellerService } = options;
app.get('/public/sellers', async () => ({
data: (await publicSellerService.list()).map(toPublicSellerDto),
}));
}
@@ -0,0 +1,7 @@
export function createPublicSellerService({ sellerRepository }) {
return {
async list() {
return sellerRepository.listPublic();
},
};
}
@@ -0,0 +1,16 @@
import assert from 'node:assert/strict';
import test from 'node:test';
import { createPublicSellerService } from '../../src/modules/sellers/services/public-seller-service.js';
test('lists sellers associated with publicly visible listings', async () => {
const service = createPublicSellerService({
sellerRepository: {
async listPublic() {
return [{ id: 'seller-1', displayName: 'Catalog Owner' }];
},
},
});
assert.deepEqual(await service.list(), [{ id: 'seller-1', displayName: 'Catalog Owner' }]);
});
@@ -0,0 +1,32 @@
import assert from 'node:assert/strict';
import test from 'node:test';
import { buildApp } from '../../src/app/build-app.js';
test('returns only public seller identity fields', async (testContext) => {
const app = buildApp({
publicSellerService: {
async list() {
return [{
id: 'seller-1',
userId: 'private-user-id',
displayName: 'Catalog Owner',
createdAt: new Date('2026-09-07T00:00:00.000Z'),
updatedAt: new Date('2026-09-07T00:00:00.000Z'),
}];
},
},
});
testContext.after(() => app.close());
const response = await app.inject({ method: 'GET', url: '/api/v1/public/sellers' });
assert.equal(response.statusCode, 200);
assert.deepEqual(response.json().data[0], {
id: 'seller-1',
displayName: 'Catalog Owner',
createdAt: '2026-09-07T00:00:00.000Z',
updatedAt: '2026-09-07T00:00:00.000Z',
});
assert.equal('userId' in response.json().data[0], false);
});
@@ -8,9 +8,11 @@ import {
categories,
conditionProfiles,
conditions,
inventoryItems,
listings,
mfaMethods,
passwordResetTokens,
products,
securityAuditEvents,
sellers,
sessions,
@@ -23,6 +25,7 @@ import { createPasswordResetRepository } from '../../src/modules/auth/repositori
import { createMfaMethodRepository } from '../../src/modules/auth/repositories/mfa-method-repository.js';
import { createInventoryItemRepository } from '../../src/modules/inventory/repositories/inventory-item-repository.js';
import { createProductRepository } from '../../src/modules/products/repositories/product-repository.js';
import { createSellerRepository } from '../../src/modules/sellers/repositories/seller-repository.js';
const connectionString = process.env.TEST_DATABASE_URL;
@@ -36,6 +39,7 @@ if (!new URL(connectionString).pathname.endsWith('_test')) {
const database = createDatabase(connectionString);
const productRepository = createProductRepository(database.db);
const sellerRepository = createSellerRepository(database.db);
const inventoryItemRepository = createInventoryItemRepository(database.db);
const sessionRepository = createSessionRepository(database.db);
const passwordResetRepository = createPasswordResetRepository(database.db);
@@ -190,6 +194,33 @@ test('finds only products with active inventory and a public listing', async ()
assert.equal(await productRepository.findPublicBySlug(product.slug), null);
});
test('lists only sellers with publicly visible inventory', async () => {
const { seller, category, condition } = await createCatalogPrerequisites();
const [product] = await database.db.insert(products).values({
sellerId: seller.id,
categoryId: category.id,
name: 'Public Seller Product',
slug: 'public-seller-product',
}).returning();
const [inventoryItem] = await database.db.insert(inventoryItems).values({
productId: product.id,
conditionId: condition.id,
}).returning();
await database.db.insert(listings).values({
inventoryItemId: inventoryItem.id,
productName: product.name,
categoryId: category.id,
conditionId: condition.id,
askingPriceMinor: 1999,
status: 'AVAILABLE',
});
assert.deepEqual((await sellerRepository.listPublic()).map(({ id }) => id), [seller.id]);
await database.db.update(listings).set({ status: 'CLOSED' });
assert.deepEqual(await sellerRepository.listPublic(), []);
});
test('retrieves only non-revoked, non-expired sessions', async () => {
const { user, seller } = await createCatalogPrerequisites();
const tokenHash = 'a hashed session token';