Merge pull request #81 from mijinummi/feat/lease-badge-minting

On-Chain Lease Badge Minting Service (#40)

Author: elizabetheonoja-art

src/controllers/badge.controller.js

@@ -0,0 +1,26 @@
+const badgeService = require('../services/badge.service');
+
+class BadgeController {
+  async mintBadge(req, res) {
+    try {
+      const { leaseId } = req.body;
+      const userId = req.user.id;
+      const badge = await badgeService.mintBadge(userId, leaseId);
+      res.status(201).json(badge);
+    } catch (err) {
+      res.status(400).json({ error: err.message });
+    }
+  }
+
+  async listBadges(req, res) {
+    try {
+      const userId = req.user.id;
+      const badges = await badgeService.listBadges(userId);
+      res.json(badges);
+    } catch (err) {
+      res.status(500).json({ error: err.message });
+    }
+  }
+}
+
+module.exports = new BadgeController();

src/jobs/badge-mint.job.js

@@ -0,0 +1,19 @@
+const badgeService = require('../services/badge.service');
+const db = require('../db');
+
+async function runBadgeMintJob() {
+  const leases = await db('leases')
+    .where({ status: 'closed', durationMonths: 12 })
+    .andWhereNotExists(db('tenant_badges').whereRaw('tenant_badges.leaseId = leases.id'));
+
+  for (const lease of leases) {
+    try {
+      await badgeService.mintBadge(lease.userId, lease.id);
+      console.log(`Minted badge for lease ${lease.id}`);
+    } catch (err) {
+      console.error(`Failed to mint badge for lease ${lease.id}: ${err.message}`);
+    }
+  }
+}
+
+module.exports = { runBadgeMintJob };

src/routes/badge.routes.js

@@ -0,0 +1,9 @@
+const express = require('express');
+const router = express.Router();
+const badgeController = require('../controllers/badge.controller');
+const { authMiddleware } = require('../services/auth.service');
+
+router.post('/badges/mint', authMiddleware, (req, res) => badgeController.mintBadge(req, res));
+router.get('/badges', authMiddleware, (req, res) => badgeController.listBadges(req, res));
+
+module.exports = router;

src/services/badge.service.js

@@ -0,0 +1,61 @@
+const stellar = require('stellar-sdk');
+const db = require('../db');
+
+class BadgeService {
+  constructor() {
+    this.server = new stellar.Server('https://horizon.stellar.org');
+    this.issuerSecret = process.env.BADGE_ISSUER_SECRET;
+    this.issuerKeypair = stellar.Keypair.fromSecret(this.issuerSecret);
+  }
+
+  async mintBadge(userId, leaseId) {
+    // Verify lease completion
+    const lease = await db('leases').where({ id: leaseId, userId }).first();
+    if (!lease || lease.status !== 'closed' || lease.durationMonths < 12) {
+      throw new Error('Lease not eligible for badge');
+    }
+
+    const tenant = await db('tenants').where({ id: userId }).first();
+    if (!tenant) throw new Error('Tenant not found');
+
+    // Build NFT asset
+    const assetCode = `LEASEBADGE-${leaseId}`;
+    const asset = new stellar.Asset(assetCode, this.issuerKeypair.publicKey());
+
+    // Create trustline and payment (simplified)
+    const account = await this.server.loadAccount(tenant.stellarAddress);
+    const tx = new stellar.TransactionBuilder(account, {
+      fee: await this.server.fetchBaseFee(),
+      networkPassphrase: stellar.Networks.PUBLIC,
+    })
+      .addOperation(stellar.Operation.changeTrust({ asset }))
+      .addOperation(stellar.Operation.payment({
+        destination: tenant.stellarAddress,
+        asset,
+        amount: '1',
+      }))
+      .setTimeout(30)
+      .build();
+
+    tx.sign(this.issuerKeypair);
+    await this.server.submitTransaction(tx);
+
+    // Archive badge record
+    const [badge] = await db('tenant_badges')
+      .insert({
+        userId,
+        leaseId,
+        assetCode,
+        mintedAt: new Date(),
+      })
+      .returning('*');
+
+    return badge;
+  }
+
+  async listBadges(userId) {
+    return db('tenant_badges').where({ userId });
+  }
+}
+
+module.exports = new BadgeService();

tests/badge.e2e-spec.js

@@ -0,0 +1,21 @@
+const request = require('supertest');
+const app = require('../index');
+
+describe('Lease Badge Minting API', () => {
+  it('POST /badges/mint mints badge for eligible lease', async () => {
+    const res = await request(app)
+      .post('/badges/mint')
+      .set('Authorization', 'Bearer tenantToken')
+      .send({ leaseId: 'lease-123' });
+    expect(res.status).toBe(201);
+    expect(res.body).toHaveProperty('assetCode');
+  });
+
+  it('GET /badges lists tenant badges', async () => {
+    const res = await request(app)
+      .get('/badges')
+      .set('Authorization', 'Bearer tenantToken');
+    expect(res.status).toBe(200);
+    expect(Array.isArray(res.body)).toBe(true);
+  });
+});