Merge pull request #77 from Trustless-Work/feature/implement-bk-investor

feat: investor implementation

Author: JoelVR17

apps/backoffice-tokenization/.env.example

@@ -1,8 +1,11 @@
 # Trustless Work API Configuration
-NEXT_PUBLIC_API_KEY=""
+NEXT_PUBLIC_API_KEY=
 
 # Server-side only (for contract deployment)
-SOURCE_SECRET=""
+SOURCE_SECRET=
 
 # Core API URL (NestJS backend)
-NEXT_PUBLIC_CORE_API_URL="http://localhost:4000"
+NEXT_PUBLIC_CORE_API_URL=http://localhost:4000
+
+# Core API Authentication
+NEXT_PUBLIC_BACKOFFICE_API_KEY=

apps/backoffice-tokenization/src/lib/httpClient.ts

@@ -0,0 +1,6 @@
+import { createHttpClient } from "@tokenization/shared/lib/httpClient";
+
+export const httpClient = createHttpClient({
+  baseURL: process.env.NEXT_PUBLIC_CORE_API_URL ?? "http://localhost:4000",
+  apiKey: process.env.NEXT_PUBLIC_BACKOFFICE_API_KEY ?? "",
+});

apps/core/package.json

@@ -32,6 +32,7 @@
     "@stellar/stellar-sdk": "^14.6.1",
     "class-transformer": "^0.5.1",
     "class-validator": "^0.15.1",
+    "dotenv": "^16.6.1",
     "prisma": "^6.19.2",
     "reflect-metadata": "^0.2.2",
     "rxjs": "^7.8.1"

apps/core/src/investments/investments.controller.ts

@@ -4,23 +4,28 @@ import { CreateInvestmentDto } from './dto/create-investment.dto';
 
 @Controller('investments')
 export class InvestmentsController {
-  constructor(private readonly investmentsService: InvestmentsService) {}
+  constructor(private readonly investmentsService: InvestmentsService) { }
 
   @Get()
   findAll() {
     return this.investmentsService.findAll();
   }
 
-  @Get(':id')
-  findOne(@Param('id') id: string) {
-    return this.investmentsService.findOne(id);
+  @Get('investor/:address')
+  findByInvestor(@Param('address') address: string) {
+    return this.investmentsService.findByInvestor(address);
   }
 
   @Get('campaign/:campaignId')
   findByCampaign(@Param('campaignId') campaignId: string) {
     return this.investmentsService.findByCampaign(campaignId);
   }
 
+  @Get(':id')
+  findOne(@Param('id') id: string) {
+    return this.investmentsService.findOne(id);
+  }
+
   @Post()
   create(@Body() dto: CreateInvestmentDto) {
     return this.investmentsService.create(dto);

apps/core/src/investments/investments.service.ts

@@ -24,6 +24,14 @@ export class InvestmentsService {
     return investment;
   }
 
+  findByInvestor(investorAddress: string) {
+    return this.prisma.investment.findMany({
+      where: { investorAddress },
+      orderBy: { createdAt: 'desc' },
+      include: { campaign: true },
+    });
+  }
+
   findByCampaign(campaignId: string) {
     return this.prisma.investment.findMany({
       where: { campaignId },

apps/core/src/main.ts

@@ -1,3 +1,5 @@
+import 'dotenv/config';
+
 import { NestFactory } from '@nestjs/core';
 import { ValidationPipe } from '@nestjs/common';
 import { AppModule } from './app.module';
@@ -16,5 +18,6 @@ async function bootstrap() {
 
   app.useGlobalGuards(new ApiKeyGuard());
   await app.listen(process.env.PORT ?? 4000);
+  console.log(`Core API is running on port ${process.env.PORT ?? 4000}`);
 }
 bootstrap();

apps/core/src/prisma/prisma.service.ts

@@ -1,11 +1,25 @@
 import { Injectable, OnModuleInit, OnModuleDestroy } from '@nestjs/common';
 import { PrismaClient } from '@prisma/client';
 
+function buildDatasourceUrl(): string | undefined {
+  const raw = process.env.DATABASE_URL;
+  if (!raw) return undefined;
+  if (raw.includes('pgbouncer=true')) return raw;
+  const separator = raw.includes('?') ? '&' : '?';
+  return `${raw}${separator}pgbouncer=true`;
+}
+
 @Injectable()
 export class PrismaService
   extends PrismaClient
   implements OnModuleInit, OnModuleDestroy
 {
+  constructor() {
+    super({
+      datasources: { db: { url: buildDatasourceUrl() } },
+    });
+  }
+
   async onModuleInit() {
     await this.$connect();
   }

apps/core/src/token-sale/token-sale.controller.ts

@@ -7,7 +7,7 @@ import { SetAdminDto } from './dto/set-admin.dto';
 
 @Controller('token-sale')
 export class TokenSaleController {
-  constructor(private readonly tokenSaleService: TokenSaleService) {}
+  constructor(private readonly tokenSaleService: TokenSaleService) { }
 
   // ── POST endpoints (writes) ──
 

apps/investor-tokenization/.env.example

@@ -7,4 +7,8 @@ NEXT_PUBLIC_DEFAULT_USDC_ADDRESS=
 NEXT_PUBLIC_API_KEY=
 
 # Server-side only (for contract deployment)
-SOURCE_SECRET=
+SOURCE_SECRET=
+
+# Core API Authentication
+NEXT_PUBLIC_INVESTORS_API_KEY=
+NEXT_PUBLIC_CORE_API_URL=http://localhost:4000

apps/investor-tokenization/src/app/my-investments/page.tsx

@@ -1,26 +1,117 @@
 "use client";
 
-import { useState, useMemo } from "react";
+import { useState, useMemo, useCallback } from "react";
 import { SectionTitle } from "@/components/shared/section-title";
 import { CampaignToolbar } from "@/features/roi/components/campaign-toolbar";
 import { CampaignList } from "@/features/roi/components/campaign-list";
-import { mockCampaigns } from "@/features/roi/data/mock-campaigns";
-import type { CampaignStatus } from "@/features/roi/types/campaign.types";
+import type { Campaign, CampaignStatus } from "@/features/roi/types/campaign.types";
+import { useUserInvestments } from "@/features/investments/hooks/useUserInvestments.hook";
+import type { InvestmentFromApi } from "@/features/investments/services/investment.service";
+import { ClaimROIService } from "@/features/claim-roi/services/claim.service";
+import { useWalletContext } from "@tokenization/tw-blocks-shared/src/wallet-kit/WalletProvider";
+import { signTransaction } from "@tokenization/tw-blocks-shared/src/wallet-kit/wallet-kit";
+import { SendTransactionService } from "@/lib/sendTransactionService";
+import { toastSuccessWithTx } from "@/lib/toastWithTx";
+import { toast } from "sonner";
+
+function toCampaign(inv: InvestmentFromApi): Campaign {
+  return {
+    id: inv.campaign.id,
+    title: inv.campaign.name,
+    description: inv.campaign.description ?? "",
+    status: inv.campaign.status as CampaignStatus,
+    loansCompleted: 0,
+    minInvestCents: Number(inv.usdcAmount) * 100,
+    currency: "USD",
+    vaultId: inv.campaign.vaultId ?? null,
+  };
+}
+
+function deduplicateByCampaign(investments: InvestmentFromApi[]): Campaign[] {
+  const seen = new Set<string>();
+  const campaigns: Campaign[] = [];
+  for (const inv of investments) {
+    if (!seen.has(inv.campaign.id)) {
+      seen.add(inv.campaign.id);
+      campaigns.push(toCampaign(inv));
+    }
+  }
+  return campaigns;
+}
 
 export default function MyInvestmentsPage() {
   const [search, setSearch] = useState("");
   const [filter, setFilter] = useState<CampaignStatus | "all">("all");
+  const { data: investments, isLoading } = useUserInvestments();
+  const { walletAddress } = useWalletContext();
+
+  const campaigns = useMemo(
+    () => deduplicateByCampaign(investments ?? []),
+    [investments],
+  );
 
   const filteredCampaigns = useMemo(() => {
-    return mockCampaigns.filter((c) => {
+    return campaigns.filter((c) => {
       const matchesStatus = filter === "all" || c.status === filter;
       const matchesSearch =
         search.trim() === "" ||
         c.title.toLowerCase().includes(search.toLowerCase()) ||
         c.description.toLowerCase().includes(search.toLowerCase());
       return matchesStatus && matchesSearch;
     });
-  }, [search, filter]);
+  }, [campaigns, search, filter]);
+
+  const handleClaimRoi = useCallback(
+    async (campaignId: string) => {
+      const campaign = campaigns.find((c) => c.id === campaignId);
+
+      if (!campaign?.vaultId) {
+        toast.error("Vault contract not available for this campaign.");
+        return;
+      }
+
+      if (!walletAddress) {
+        toast.error("Please connect your wallet to claim ROI.");
+        return;
+      }
+
+      try {
+        const svc = new ClaimROIService();
+        const claimResponse = await svc.claimROI({
+          vaultContractId: campaign.vaultId,
+          beneficiaryAddress: walletAddress,
+        });
+
+        if (!claimResponse?.success || !claimResponse?.xdr) {
+          throw new Error(
+            claimResponse?.message ?? "Failed to build claim transaction.",
+          );
+        }
+
+        const signedTxXdr = await signTransaction({
+          unsignedTransaction: claimResponse.xdr,
+          address: walletAddress,
+        });
+
+        const sender = new SendTransactionService();
+        const submitResponse = await sender.sendTransaction({
+          signedXdr: signedTxXdr,
+        });
+
+        if (submitResponse.status !== "SUCCESS") {
+          throw new Error(
+            submitResponse.message ?? "Transaction submission failed.",
+          );
+        }
+
+        toastSuccessWithTx("ROI claimed successfully!", submitResponse.hash);
+      } catch (e) {
+        const msg = e instanceof Error ? e.message : "Unexpected error while claiming ROI.";
+        toast.error(msg);
+      }
+    },
+    [campaigns, walletAddress],
+  );
 
   return (
     <div className="flex flex-col gap-6">
@@ -32,7 +123,13 @@ export default function MyInvestmentsPage() {
         onSearchChange={setSearch}
         onFilterChange={setFilter}
       />
-      <CampaignList campaigns={filteredCampaigns} />
+      {isLoading ? (
+        <p className="text-sm text-muted-foreground text-center py-8">
+          Loading your investments...
+        </p>
+      ) : (
+        <CampaignList campaigns={filteredCampaigns} onClaimRoi={handleClaimRoi} />
+      )}
     </div>
   );
 }