BrinPage CPM — Install & Quick Start (Next.js App Router)

npx create-next-app@latest
# Name: brinpage-quickstart
# Accept defaults
cd brinpage-quickstart

# Inside your Next.js project
npm i @brinpage/cpm

BRINPAGE_LICENSE_KEY=bp_xxxx
BRINPAGE_API_BASE=https://cloud.brinpage.com

# Start CPM (bin: "brinpage")
npx brinpage cpm

# CPM panel/API at:
# http://localhost:3027

// lib/cpm.ts
export type ChatMessage = { role: 'system' | 'user' | 'assistant'; content: string };

const CLOUD = process.env.BRINPAGE_API_BASE || 'https://cloud.brinpage.com';
const LICENSE =
  process.env.BRINPAGE_LICENSE_KEY ||
  process.env.BRINPAGE_API_KEY ||
  process.env.BRINPAGE_KEY ||
  '';

const LOCAL = process.env.BRINPAGE_SDK_ORIGIN || process.env.IA_STUDIO_ORIGIN || 'http://localhost:3027';

function resolveAskUrl() {
  if (LICENSE) return `${CLOUD}/api/sdk/ask`;
  return `${LOCAL}/api/ask`;
}

function toQuestion(messages?: ChatMessage[]) {
  if (!messages?.length) return '';
  for (let i = messages.length - 1; i >= 0; i--) {
    const m = messages[i];
    if (m.role === 'user' && m.content?.trim()) return m.content.trim();
  }
  return messages.map(m => `${m.role}: ${m.content}`).join('\n').trim();
}

export async function ask(opts: {
  question?: string;
  messages?: ChatMessage[];
  provider?: string;
  model?: string;
  stream?: boolean;
  context?: Record<string, unknown>;
  extraPrompts?: string[];
  tags?: string[];        // <-- include tags so they reach CPM/Cloud
  debugEcho?: boolean;
}) {
  const q = (opts.question ?? toQuestion(opts.messages)).trim();
  if (!q) throw new Error("Missing 'question' input");

  const url = resolveAskUrl();
  const headers: Record<string, string> = {
    'content-type': 'application/json',
    'accept': 'application/json',
  };
  if (url.includes('/api/sdk/ask')) {
    if (!LICENSE) throw new Error('Missing BRINPAGE_LICENSE_KEY to call Cloud');
    headers['authorization'] = `Bearer ${LICENSE}`;
  }

  const res = await fetch(url, {
    method: 'POST',
    headers,
    body: JSON.stringify({
      question: q,
      provider: opts.provider,
      model: opts.model,
      stream: Boolean(opts.stream),
      context: opts.context ?? {},
      extraPrompts: opts.extraPrompts,
      tags: opts.tags,          // <-- now forwarded
      debugEcho: opts.debugEcho,
    }),
    cache: 'no-store',
  });

  const rawText = await res.text();
  let data: any = null; try { data = rawText ? JSON.parse(rawText) : null; } catch {}

  if (!res.ok) {
    const msg = (data && (data.error || data.message)) || (rawText && rawText.slice(0, 400)) || `ask failed (${res.status})`;
    throw new Error(msg);
  }

  return {
    text: (data?.text ?? data?.answer ?? data?.message ?? data?.output ?? '').toString(),
    raw: data ?? rawText,
  };
}

// app/api/chat/route.ts
import { NextResponse } from 'next/server';
import { ask, type ChatMessage } from '@/lib/cpm';

export const dynamic = 'force-dynamic';

function deriveHeuristics(input: string) {
  const q = (input || '').toLowerCase();

  const shouldPinApple =
    /(^|\W)(apple|squircle|esquina|esquinas)(\W|$)/i.test(input);

  const extraPrompts: string[] = shouldPinApple ? ['apple-context-check.md'] : [];

  const tags: string[] = [];
  if (/apple|ui|ux|squircle/i.test(input)) {
    tags.push('apple', 'ui', 'context');
  }
  if (/finstacking|finanzas|fintech/i.test(input)) {
    tags.push('finstacking', 'finance');
  }

  return { extraPrompts, tags };
}

export async function GET(req: Request) {
  try {
    const { searchParams } = new URL(req.url);
    const q = (searchParams.get('q') ?? '').trim() || 'Hello';

    const { extraPrompts, tags } = deriveHeuristics(q);

    const { text, raw } = await ask({
      question: q,
      provider: process.env.CPM_PROVIDER || 'openai',
      model: process.env.CPM_MODEL || 'gpt-4o-mini',
      ...(extraPrompts.length ? { extraPrompts } : {}),
      ...(tags.length ? { tags } : {}),
      debugEcho: true,
    });

    return NextResponse.json({ ok: true, text, raw });
  } catch (err: any) {
    return NextResponse.json({ ok: false, error: err?.message || 'unexpected error' }, { status: 500 });
  }
}

export async function POST(req: Request) {
  try {
    const body = (await req.json().catch(() => ({}))) as {
      question?: string; q?: string; messages?: ChatMessage[];
      provider?: string; model?: string; stream?: boolean; context?: Record<string, unknown>;
      tags?: string[]; extraPrompts?: string[];
    };

    const question =
      (typeof body?.question === 'string' && body.question) ||
      (typeof body?.q === 'string' && body.q) ||
      '';

    const derived = deriveHeuristics(question);
    const extraPrompts = Array.isArray(body?.extraPrompts) ? body!.extraPrompts : derived.extraPrompts;
    const tags = Array.isArray(body?.tags) ? body!.tags : derived.tags;

    const { text, raw } = await ask({
      question,
      messages: body?.messages,
      provider: body?.provider ?? process.env.CPM_PROVIDER ?? 'openai',
      model: body?.model ?? process.env.CPM_MODEL ?? 'gpt-4o-mini',
      stream: body?.stream,
      context: body?.context,
      ...(extraPrompts.length ? { extraPrompts } : {}),
      ...(tags.length ? { tags } : {}),
      debugEcho: true,
    });

    return NextResponse.json({ ok: true, text, raw });
  } catch (err: any) {
    return NextResponse.json({ ok: false, error: err?.message || 'unexpected error' }, { status: 500 });
  }
}

npx brinpage cpm
# http://localhost:3027

npm run dev
# http://localhost:3000

BRINPAGE_LICENSE_KEY=bp_xxxx 
BRINPAGE_API_BASE=https://cloud.brinpage.com

your-project/
  app/
    api/
      chat/
        route.ts        ← created (full file)
    page.tsx            ← replaced (full file)
  lib/
    cpm.ts              ← created (full file)
  next.config.ts        ← optional (full file or snippet)
  .env            
  package.json