Merge pull request #79 from mijinummi/feat/tenant-benefit-marketplace

Tenant Benefit Marketplace API (#38)

Author: elizabetheonoja-art

src/controllers/marketplace.controller.js

@@ -0,0 +1,26 @@
+const marketplaceService = require('../services/marketplace.service');
+
+class MarketplaceController {
+  async listDeals(req, res) {
+    try {
+      const userId = req.user.id;
+      const deals = await marketplaceService.listDeals(userId);
+      res.json(deals);
+    } catch (err) {
+      res.status(403).json({ error: err.message });
+    }
+  }
+
+  async getDeal(req, res) {
+    try {
+      const userId = req.user.id;
+      const dealId = req.params.id;
+      const deal = await marketplaceService.getDeal(userId, dealId);
+      res.json(deal);
+    } catch (err) {
+      res.status(403).json({ error: err.message });
+    }
+  }
+}
+
+module.exports = new MarketplaceController();

src/routes/marketplace.routes.js

@@ -0,0 +1,9 @@
+const express = require('express');
+const router = express.Router();
+const marketplaceController = require('../controllers/marketplace.controller');
+const { authMiddleware } = require('../services/auth.service');
+
+router.get('/marketplace/deals', authMiddleware, (req, res) => marketplaceController.listDeals(req, res));
+router.get('/marketplace/deals/:id', authMiddleware, (req, res) => marketplaceController.getDeal(req, res));
+
+module.exports = router;

src/services/marketplace.service.js

@@ -0,0 +1,31 @@
+const db = require('../db');
+
+class MarketplaceService {
+  async listDeals(userId) {
+    // Fetch tenant score
+    const tenant = await db('tenants').where({ id: userId }).first();
+    if (!tenant) throw new Error('Tenant not found');
+
+    // Only high-score tenants qualify (e.g. score >= 700)
+    const score = tenant.creditScore;
+    const deals = await db('partner_deals').select('*');
+
+    return deals.filter(d => score >= d.minScore);
+  }
+
+  async getDeal(userId, dealId) {
+    const tenant = await db('tenants').where({ id: userId }).first();
+    if (!tenant) throw new Error('Tenant not found');
+
+    const deal = await db('partner_deals').where({ id: dealId }).first();
+    if (!deal) throw new Error('Deal not found');
+
+    if (tenant.creditScore < deal.minScore) {
+      throw new Error('Unauthorized: tenant score too low');
+    }
+
+    return deal;
+  }
+}
+
+module.exports = new MarketplaceService();

tests/marketplace.e2e-spec.js

@@ -0,0 +1,27 @@
+const request = require('supertest');
+const app = require('../index');
+
+describe('Tenant Benefit Marketplace API', () => {
+  it('GET /marketplace/deals returns deals for high-score tenant', async () => {
+    const res = await request(app)
+      .get('/marketplace/deals')
+      .set('Authorization', 'Bearer highScoreTenantToken');
+    expect(res.status).toBe(200);
+    expect(Array.isArray(res.body)).toBe(true);
+  });
+
+  it('GET /marketplace/deals/:id returns deal if tenant qualifies', async () => {
+    const res = await request(app)
+      .get('/marketplace/deals/deal-123')
+      .set('Authorization', 'Bearer highScoreTenantToken');
+    expect(res.status).toBe(200);
+    expect(res.body).toHaveProperty('id', 'deal-123');
+  });
+
+  it('GET /marketplace/deals/:id denies low-score tenant', async () => {
+    const res = await request(app)
+      .get('/marketplace/deals/deal-123')
+      .set('Authorization', 'Bearer lowScoreTenantToken');
+    expect(res.status).toBe(403);
+  });
+});