agent: @U0AJM7X8FBR API - MPP • actual: using x402 for many endpoints • require

app/api/accounts/[id]/route.ts

@@ -23,6 +23,7 @@ export async function OPTIONS() {
  * - id (required): The unique identifier of the account (UUID)
  *
  * @param request - The request object
+ * @param params.params
  * @param params - Route params containing the account ID
  * @returns A NextResponse with account data
  */

app/api/admins/privy/route.ts

@@ -8,11 +8,16 @@ import { getPrivyLoginsHandler } from "@/lib/admins/privy/getPrivyLoginsHandler"
  * Returns Privy login statistics for the requested time period.
  * Supports daily (last 24h), weekly (last 7 days), and monthly (last 30 days) periods.
  * Requires admin authentication.
+ *
+ * @param request
  */
 export async function GET(request: NextRequest): Promise<NextResponse> {
   return getPrivyLoginsHandler(request);
 }
 
+/**
+ *
+ */
 export async function OPTIONS(): Promise<NextResponse> {
   return new NextResponse(null, { status: 204, headers: getCorsHeaders() });
 }

app/api/coding-agent/[platform]/route.ts

@@ -10,6 +10,7 @@ import "@/lib/coding-agent/handlers/registerHandlers";
  * Handles webhook verification handshakes (e.g. WhatsApp hub.challenge).
  *
  * @param request - The incoming verification request
+ * @param params.params
  * @param params - Route params containing the platform name
  */
 export async function GET(
@@ -34,6 +35,7 @@ export async function GET(
  * Handles Slack and WhatsApp webhooks via dynamic [platform] segment.
  *
  * @param request - The incoming webhook request
+ * @param params.params
  * @param params - Route params containing the platform name
  */
 export async function POST(

app/api/image/generate/route.ts

@@ -1,6 +1,6 @@
 import { NextRequest, NextResponse } from "next/server";
 import { getCorsHeaders } from "@/lib/networking/getCorsHeaders";
-import { x402GenerateImage } from "@/lib/x402/recoup/x402GenerateImage";
+import { mppGenerateImage } from "@/lib/mpp/recoup/mppGenerateImage";
 import { validateGenerateImageQuery } from "@/lib/image/validateGenerateImageQuery";
 
 /**
@@ -17,7 +17,7 @@ export async function OPTIONS() {
 
 /**
  * GET handler for image generation endpoint.
- * Accepts prompt and account_id, and fetches from the x402-protected endpoint.
+ * Accepts prompt and account_id, and fetches from the MPP-protected endpoint.
  *
  * @param request - The request object containing query parameters.
  * @returns {Promise<NextResponse>} JSON response matching the Recoup API format.
@@ -34,7 +34,7 @@ export async function GET(request: NextRequest) {
     const files = searchParams.get("files");
 
     const baseUrl = request.nextUrl.origin;
-    const data = await x402GenerateImage(prompt, baseUrl, account_id, files);
+    const data = await mppGenerateImage(prompt, baseUrl, account_id, files);
 
     return NextResponse.json(data, {
       status: 200,

app/api/mpp/image/generate/route.ts

@@ -0,0 +1,104 @@
+import { NextRequest, NextResponse } from "next/server";
+import generateImage from "@/lib/ai/generateImage";
+import { getCorsHeaders } from "@/lib/networking/getCorsHeaders";
+import { uploadImageAndCreateMoment } from "@/lib/arweave/uploadImageAndCreateMoment";
+import { getPayerAddress } from "@/lib/mpp/getPayerAddress";
+import { parseFilesFromQuery } from "@/lib/files/parseFilesFromQuery";
+import { getMppServer } from "@/lib/mpp/getMppServer";
+
+const mppx = getMppServer();
+
+/**
+ * OPTIONS handler for CORS preflight requests.
+ *
+ * @returns A NextResponse with CORS headers.
+ */
+export async function OPTIONS() {
+  return new NextResponse(null, {
+    status: 200,
+    headers: getCorsHeaders(),
+  });
+}
+
+/**
+ * GET handler for image generation endpoint (MPP protected).
+ * Requires a valid MPP payment credential via the Authorization header.
+ *
+ * @param request - The request object containing query parameters.
+ * @returns {Promise<NextResponse>} JSON response with generated image data or error.
+ */
+export async function GET(request: NextRequest) {
+  try {
+    const result = await mppx.charge({ amount: "1" })(request);
+
+    if (result.status === 402) {
+      return result.challenge;
+    }
+
+    const { searchParams } = new URL(request.url);
+    const prompt = searchParams.get("prompt");
+    const filesParam = searchParams.get("files");
+    const account = getPayerAddress(request);
+
+    if (!prompt) {
+      return result.withReceipt(
+        NextResponse.json(
+          { error: "prompt query parameter is required" },
+          { status: 400, headers: getCorsHeaders() },
+        ),
+      );
+    }
+
+    let files;
+    try {
+      files = parseFilesFromQuery(filesParam);
+    } catch (error) {
+      return result.withReceipt(
+        NextResponse.json(
+          {
+            error: "Invalid files parameter.",
+            details:
+              error instanceof Error ? error.message : "Format must be: url1:type1|url2:type2",
+          },
+          { status: 400, headers: getCorsHeaders() },
+        ),
+      );
+    }
+
+    const { image, usage } = await generateImage(prompt, files);
+
+    if (!image) {
+      return result.withReceipt(
+        NextResponse.json(
+          { error: "Failed to generate image" },
+          { status: 500, headers: getCorsHeaders() },
+        ),
+      );
+    }
+
+    const {
+      arweaveResult,
+      imageUrl,
+      moment: momentResult,
+      arweaveError,
+    } = await uploadImageAndCreateMoment({ image, prompt, account });
+
+    return result.withReceipt(
+      NextResponse.json(
+        {
+          image,
+          usage,
+          imageUrl,
+          arweaveResult,
+          moment: momentResult,
+          ...(arweaveError && { arweaveError }),
+        },
+        { status: 200, headers: getCorsHeaders() },
+      ),
+    );
+  } catch (error) {
+    console.error("Error in MPP image generation endpoint:", error);
+    const errorMessage = error instanceof Error ? error.message : "Unknown error occurred";
+    return NextResponse.json({ error: errorMessage }, { status: 500, headers: getCorsHeaders() });
+  }
+}

app/api/songs/analyze/presets/route.ts

@@ -28,6 +28,7 @@ export async function OPTIONS() {
  * - status: "success"
  * - presets: Array of { name, label, description, requiresAudio, responseFormat }
  *
+ * @param request
  * @returns A NextResponse with the list of available presets
  */
 export async function GET(request: NextRequest): Promise<NextResponse> {

app/api/transcribe/route.ts

@@ -2,6 +2,10 @@ import { NextRequest, NextResponse } from "next/server";
 import { processAudioTranscription } from "@/lib/transcribe/processAudioTranscription";
 import { formatTranscriptionError } from "@/lib/transcribe/types";
 
+/**
+ *
+ * @param req
+ */
 export async function POST(req: NextRequest) {
   try {
     const body = await req.json();

lib/admins/emails/__tests__/validateGetAdminEmailsQuery.test.ts

@@ -12,6 +12,10 @@ vi.mock("@/lib/admins/validateAdminAuth", () => ({
   validateAdminAuth: vi.fn(),
 }));
 
+/**
+ *
+ * @param url
+ */
 function createMockRequest(url: string): NextRequest {
   return {
     url,

lib/admins/privy/__tests__/getPrivyLoginsHandler.test.ts

@@ -2,6 +2,9 @@ import { describe, it, expect, vi, beforeEach } from "vitest";
 import { NextRequest, NextResponse } from "next/server";
 import { getPrivyLoginsHandler } from "../getPrivyLoginsHandler";
 
+import { validateGetPrivyLoginsQuery } from "../validateGetPrivyLoginsQuery";
+import { fetchPrivyLogins } from "../fetchPrivyLogins";
+
 vi.mock("@/lib/networking/getCorsHeaders", () => ({
   getCorsHeaders: vi.fn(() => ({ "Access-Control-Allow-Origin": "*" })),
 }));
@@ -14,9 +17,6 @@ vi.mock("../fetchPrivyLogins", () => ({
   fetchPrivyLogins: vi.fn(),
 }));
 
-import { validateGetPrivyLoginsQuery } from "../validateGetPrivyLoginsQuery";
-import { fetchPrivyLogins } from "../fetchPrivyLogins";
-
 const now = Date.now();
 const ONE_HOUR_AGO = Math.floor((now - 60 * 60 * 1000) / 1000);
 const TWO_HOURS_AGO = Math.floor((now - 2 * 60 * 60 * 1000) / 1000);
@@ -42,6 +42,10 @@ const mockLogins = [
   },
 ];
 
+/**
+ *
+ * @param period
+ */
 function makeRequest(period = "daily") {
   return new NextRequest(`https://example.com/api/admins/privy?period=${period}`);
 }

lib/admins/privy/__tests__/validateGetPrivyLoginsQuery.test.ts

@@ -2,6 +2,8 @@ import { describe, it, expect, vi, beforeEach } from "vitest";
 import { NextRequest, NextResponse } from "next/server";
 import { validateGetPrivyLoginsQuery } from "../validateGetPrivyLoginsQuery";
 
+import { validateAdminAuth } from "@/lib/admins/validateAdminAuth";
+
 vi.mock("@/lib/networking/getCorsHeaders", () => ({
   getCorsHeaders: vi.fn(() => ({ "Access-Control-Allow-Origin": "*" })),
 }));
@@ -10,10 +12,12 @@ vi.mock("@/lib/admins/validateAdminAuth", () => ({
   validateAdminAuth: vi.fn(),
 }));
 
-import { validateAdminAuth } from "@/lib/admins/validateAdminAuth";
-
 const mockAuth = { accountId: "test-account", orgId: null, authToken: "token" };
 
+/**
+ *
+ * @param period
+ */
 function makeRequest(period?: string) {
   const url = period
     ? `https://example.com/api/admins/privy?period=${period}`

lib/admins/privy/countNewAccounts.ts

@@ -5,6 +5,9 @@ import { getCutoffMs } from "./getCutoffMs";
 
 /**
  * Counts how many users in the list were created within the cutoff period.
+ *
+ * @param users
+ * @param period
  */
 export function countNewAccounts(users: User[], period: PrivyLoginsPeriod): number {
   const cutoffMs = getCutoffMs(period);

lib/admins/privy/fetchPrivyLogins.ts

@@ -20,6 +20,10 @@ export type FetchPrivyLoginsResult = {
   totalPrivyUsers: number;
 };
 
+/**
+ *
+ * @param period
+ */
 export async function fetchPrivyLogins(period: PrivyLoginsPeriod): Promise<FetchPrivyLoginsResult> {
   const isAll = period === "all";
   const cutoffMs = getCutoffMs(period);