feat(reports): expand reports dashboard with KYC, fleet, and user tabs, per-tab filters, table previews, and CSV exports

app/api/admin/reports/export/route.ts

@@ -12,7 +12,7 @@ import User from "@/models/User"
 import Vehicle from "@/models/Vehicle"
 import InvestmentPool from "@/models/InvestmentPool"
 
-type ExportType = "deposits" | "investments" | "repayments"
+type ExportType = "deposits" | "investments" | "repayments" | "kyc" | "fleet" | "users"
 type RangeType = "7d" | "30d" | "90d" | "all" | "custom"
 
 function csvEscape(value: unknown): string {
@@ -97,13 +97,14 @@ export async function GET(request: Request) {
 
     const { searchParams } = new URL(request.url)
     const type = (searchParams.get("type") || "deposits") as ExportType
-    if (!["deposits", "investments", "repayments"].includes(type)) {
+    if (!["deposits", "investments", "repayments", "kyc", "fleet", "users"].includes(type)) {
       return NextResponse.json({ message: "Invalid export type" }, { status: 400 })
     }
 
     const range = parseRange(searchParams.get("range"))
     const { startDate, endDate } = buildWindow(range, searchParams.get("from"), searchParams.get("to"))
 
+    // ── deposits ────────────────────────────────────────────────────────────
     if (type === "deposits") {
       const deposits = await Transaction.find({
         type: { $in: ["deposit", "wallet_funding"] },
@@ -146,6 +147,7 @@ export async function GET(request: Request) {
       return shouldRefreshSession ? withSessionRefresh(response, user) : response
     }
 
+    // ── investments ──────────────────────────────────────────────────────────
     if (type === "investments") {
       const [poolInvestments, legacyInvestments] = await Promise.all([
         PoolInvestment.find({
@@ -228,51 +230,164 @@ export async function GET(request: Request) {
       return shouldRefreshSession ? withSessionRefresh(response, user) : response
     }
 
-    const repayments = await DriverPayment.find({
-      status: "CONFIRMED",
-      ...dateMatch("createdAt", startDate, endDate),
-    })
-      .select("driverUserId contractId amountNgn appliedAmountNgn method paystackRef status createdAt")
-      .sort({ createdAt: -1 })
-      .lean()
+    // ── repayments ───────────────────────────────────────────────────────────
+    if (type === "repayments") {
+      const repayments = await DriverPayment.find({
+        status: "CONFIRMED",
+        ...dateMatch("createdAt", startDate, endDate),
+      })
+        .select("driverUserId contractId amountNgn appliedAmountNgn method paystackRef status createdAt")
+        .sort({ createdAt: -1 })
+        .lean()
+
+      const userIds = collectObjectIds(repayments.map((item: any) => item.driverUserId))
+      const contractIds = collectObjectIds(repayments.map((item: any) => item.contractId))
+
+      const [users, contracts] = await Promise.all([
+        userIds.length ? User.find({ _id: { $in: userIds } }).select("name fullName email").lean() : Promise.resolve([]),
+        contractIds.length
+          ? HirePurchaseContract.find({ _id: { $in: contractIds } }).select("vehicleDisplayName").lean()
+          : Promise.resolve([]),
+      ])
+
+      const userById = new Map(users.map((entry: any) => [entry._id.toString(), entry]))
+      const contractById = new Map(contracts.map((entry: any) => [entry._id.toString(), entry]))
+
+      const csv = toCsv(
+        ["Date", "Driver", "Email", "Vehicle/Contract", "Amount (NGN)", "Applied Amount (NGN)", "Method", "Reference", "Status"],
+        repayments.map((item: any) => {
+          const userEntry = userById.get(item.driverUserId?.toString?.() || "")
+          const contract = contractById.get(item.contractId?.toString?.() || "")
+          return [
+            item.createdAt ? new Date(item.createdAt).toISOString() : "",
+            getUserName(userEntry),
+            userEntry?.email || "",
+            contract?.vehicleDisplayName || "Contract",
+            Number(item.amountNgn || 0),
+            Number(item.appliedAmountNgn || 0),
+            item.method || "PAYSTACK",
+            item.paystackRef || "",
+            item.status || "unknown",
+          ]
+        }),
+      )
+
+      const response = new NextResponse(csv, {
+        status: 200,
+        headers: {
+          "Content-Type": "text/csv; charset=utf-8",
+          "Content-Disposition": `attachment; filename="repayments-${range}.csv"`,
+        },
+      })
+      return shouldRefreshSession ? withSessionRefresh(response, user) : response
+    }
+
+    // ── kyc ──────────────────────────────────────────────────────────────────
+    if (type === "kyc") {
+      const kycStatusFilter = searchParams.get("status") || ""
+      const kycQuery: Record<string, unknown> = {
+        kycStatus: { $ne: "none" },
+        ...dateMatch("createdAt", startDate, endDate),
+      }
+      if (["pending", "approved", "rejected"].includes(kycStatusFilter)) {
+        kycQuery.kycStatus = kycStatusFilter
+      }
+
+      const kycUsers = await User.find(kycQuery)
+        .select("name fullName email role kycStatus kycVerified createdAt")
+        .sort({ createdAt: -1 })
+        .lean()
+
+      const csv = toCsv(
+        ["Date Joined", "Name", "Email", "Role", "KYC Status", "KYC Verified"],
+        kycUsers.map((u: any) => [
+          u.createdAt ? new Date(u.createdAt).toISOString() : "",
+          getUserName(u),
+          u.email || "",
+          u.role || "",
+          u.kycStatus || "none",
+          u.kycVerified ? "Yes" : "No",
+        ]),
+      )
 
-    const userIds = collectObjectIds(repayments.map((item: any) => item.driverUserId))
-    const contractIds = collectObjectIds(repayments.map((item: any) => item.contractId))
+      const response = new NextResponse(csv, {
+        status: 200,
+        headers: {
+          "Content-Type": "text/csv; charset=utf-8",
+          "Content-Disposition": `attachment; filename="kyc-report-${range}.csv"`,
+        },
+      })
+      return shouldRefreshSession ? withSessionRefresh(response, user) : response
+    }
 
-    const [users, contracts] = await Promise.all([
-      userIds.length ? User.find({ _id: { $in: userIds } }).select("name fullName email").lean() : Promise.resolve([]),
-      contractIds.length
-        ? HirePurchaseContract.find({ _id: { $in: contractIds } }).select("vehicleDisplayName").lean()
-        : Promise.resolve([]),
-    ])
+    // ── fleet ─────────────────────────────────────────────────────────────────
+    if (type === "fleet") {
+      const vehicleStatusFilter = searchParams.get("vstatus") || ""
+      const vehicleQuery: Record<string, unknown> = {}
+      if (["Available", "Financed", "Reserved", "Maintenance", "Retired"].includes(vehicleStatusFilter)) {
+        vehicleQuery.status = vehicleStatusFilter
+      }
+
+      const vehicles = await Vehicle.find(vehicleQuery)
+        .select("name identifier type year price status fundingStatus totalFundedAmount addedDate")
+        .sort({ addedDate: -1 })
+        .lean()
 
-    const userById = new Map(users.map((entry: any) => [entry._id.toString(), entry]))
-    const contractById = new Map(contracts.map((entry: any) => [entry._id.toString(), entry]))
+      const csv = toCsv(
+        ["Date Added", "Name", "Identifier", "Type", "Year", "Price (NGN)", "Status", "Funding Status", "Total Funded (NGN)"],
+        vehicles.map((v: any) => [
+          v.addedDate ? new Date(v.addedDate).toISOString() : "",
+          v.name || "",
+          v.identifier || "",
+          v.type || "",
+          v.year || "",
+          Number(v.price || 0),
+          v.status || "",
+          v.fundingStatus || "",
+          Number(v.totalFundedAmount || 0),
+        ]),
+      )
+
+      const response = new NextResponse(csv, {
+        status: 200,
+        headers: {
+          "Content-Type": "text/csv; charset=utf-8",
+          "Content-Disposition": `attachment; filename="fleet-report-${range}.csv"`,
+        },
+      })
+      return shouldRefreshSession ? withSessionRefresh(response, user) : response
+    }
+
+    // ── users ─────────────────────────────────────────────────────────────────
+    const roleFilter = searchParams.get("role") || ""
+    const userQuery: Record<string, unknown> = {
+      ...dateMatch("createdAt", startDate, endDate),
+    }
+    if (["driver", "investor", "admin"].includes(roleFilter)) {
+      userQuery.role = roleFilter
+    }
+
+    const platformUsers = await User.find(userQuery)
+      .select("name fullName email role kycVerified createdAt")
+      .sort({ createdAt: -1 })
+      .lean()
 
     const csv = toCsv(
-      ["Date", "Driver", "Email", "Vehicle/Contract", "Amount (NGN)", "Applied Amount (NGN)", "Method", "Reference", "Status"],
-      repayments.map((item: any) => {
-        const userEntry = userById.get(item.driverUserId?.toString?.() || "")
-        const contract = contractById.get(item.contractId?.toString?.() || "")
-        return [
-          item.createdAt ? new Date(item.createdAt).toISOString() : "",
-          getUserName(userEntry),
-          userEntry?.email || "",
-          contract?.vehicleDisplayName || "Contract",
-          Number(item.amountNgn || 0),
-          Number(item.appliedAmountNgn || 0),
-          item.method || "PAYSTACK",
-          item.paystackRef || "",
-          item.status || "unknown",
-        ]
-      }),
+      ["Date Joined", "Name", "Email", "Role", "KYC Verified"],
+      platformUsers.map((u: any) => [
+        u.createdAt ? new Date(u.createdAt).toISOString() : "",
+        getUserName(u),
+        u.email || "",
+        u.role || "",
+        u.kycVerified ? "Yes" : "No",
+      ]),
     )
 
     const response = new NextResponse(csv, {
       status: 200,
       headers: {
         "Content-Type": "text/csv; charset=utf-8",
-        "Content-Disposition": `attachment; filename="repayments-${range}.csv"`,
+        "Content-Disposition": `attachment; filename="users-report-${range}.csv"`,
       },
     })
     return shouldRefreshSession ? withSessionRefresh(response, user) : response
@@ -281,4 +396,3 @@ export async function GET(request: Request) {
     return NextResponse.json({ message: "Failed to export report." }, { status: 500 })
   }
 }
-

app/dashboard/admin/reports/loading.tsx

@@ -1,5 +1,5 @@
 import { DashboardRouteLoading } from "@/components/dashboard/dashboard-route-loading"
 
 export default function Loading() {
-  return <DashboardRouteLoading title="Loading admin dashboard" description="Preparing metrics, records, and governance data." />
-}
+  return <DashboardRouteLoading title="Loading admin dashboard" description="Loading reports, metrics, filters, and export options." />
+}