How to Integrate Bolt.new with LinkedIn Ads

1// lib/linkedin.ts
2const LINKEDIN_AUTH_URL = 'https://www.linkedin.com/oauth/v2/authorization';
3const LINKEDIN_TOKEN_URL = 'https://www.linkedin.com/oauth/v2/accessToken';
4
5export function buildAuthUrl(state: string): string {
6  const params = new URLSearchParams({
7    response_type: 'code',
8    client_id: process.env.LINKEDIN_CLIENT_ID!,
9    redirect_uri: process.env.LINKEDIN_REDIRECT_URI!,
10    state,
11    scope: 'r_ads r_ads_reporting',
12  });
13  return `${LINKEDIN_AUTH_URL}?${params.toString()}`;
14}
15
16export async function exchangeCodeForTokens(code: string) {
17  const response = await fetch(LINKEDIN_TOKEN_URL, {
18    method: 'POST',
19    headers: { 'Content-Type': 'application/x-www-form-urlencoded' },
20    body: new URLSearchParams({
21      grant_type: 'authorization_code',
22      code,
23      redirect_uri: process.env.LINKEDIN_REDIRECT_URI!,
24      client_id: process.env.LINKEDIN_CLIENT_ID!,
25      client_secret: process.env.LINKEDIN_CLIENT_SECRET!,
26    }),
27  });
28  if (!response.ok) throw new Error(`Token exchange failed: ${await response.text()}`);
29  return response.json() as Promise<{
30    access_token: string;
31    expires_in: number;
32    refresh_token: string;
33    refresh_token_expires_in: number;
34  }>;
35}
36
37export async function callLinkedInAPI(endpoint: string, accessToken: string) {
38  const response = await fetch(`https://api.linkedin.com/v2${endpoint}`, {
39    headers: {
40      'Authorization': `Bearer ${accessToken}`,
41      'LinkedIn-Version': '202401',
42      'X-Restli-Protocol-Version': '2.0.0',
43    },
44  });
45  if (!response.ok) throw new Error(`LinkedIn API error: ${response.status} ${await response.text()}`);
46  return response.json();
47}

1// app/api/auth/linkedin/callback/route.ts
2import { NextRequest, NextResponse } from 'next/server';
3import { exchangeCodeForTokens } from '@/lib/linkedin';
4import { cookies } from 'next/headers';
5
6export async function GET(request: NextRequest) {
7  const { searchParams } = new URL(request.url);
8  const code = searchParams.get('code');
9  const state = searchParams.get('state');
10  const error = searchParams.get('error');
11
12  if (error) {
13    return NextResponse.redirect(new URL('/login?error=linkedin_denied', request.url));
14  }
15
16  // Validate CSRF state
17  const cookieStore = await cookies();
18  const savedState = cookieStore.get('linkedin_oauth_state')?.value;
19  if (!state || state !== savedState) {
20    return NextResponse.redirect(new URL('/login?error=invalid_state', request.url));
21  }
22
23  if (!code) {
24    return NextResponse.redirect(new URL('/login?error=no_code', request.url));
25  }
26
27  const tokens = await exchangeCodeForTokens(code);
28
29  const response = NextResponse.redirect(new URL('/dashboard', request.url));
30  // Store tokens in HTTP-only cookies (production: encrypt with NEXTAUTH_SECRET)
31  response.cookies.set('linkedin_access_token', tokens.access_token, {
32    httpOnly: true,
33    secure: true,
34    maxAge: tokens.expires_in,
35    path: '/',
36  });
37  response.cookies.set('linkedin_refresh_token', tokens.refresh_token, {
38    httpOnly: true,
39    secure: true,
40    maxAge: tokens.refresh_token_expires_in,
41    path: '/',
42  });
43  // Clear the state cookie
44  response.cookies.delete('linkedin_oauth_state');
45
46  return response;
47}

1// app/api/linkedin/analytics/route.ts
2import { NextRequest, NextResponse } from 'next/server';
3import { cookies } from 'next/headers';
4
5export async function GET(request: NextRequest) {
6  const cookieStore = await cookies();
7  const accessToken = cookieStore.get('linkedin_access_token')?.value;
8
9  if (!accessToken) {
10    return NextResponse.json({ error: 'Not authenticated' }, { status: 401 });
11  }
12
13  const { searchParams } = new URL(request.url);
14  const accountId = searchParams.get('accountId');
15  const daysBack = parseInt(searchParams.get('days') || '30');
16
17  const endDate = new Date();
18  const startDate = new Date();
19  startDate.setDate(startDate.getDate() - daysBack);
20
21  const params = new URLSearchParams({
22    q: 'analytics',
23    pivot: 'CAMPAIGN',
24    dateRange: JSON.stringify({
25      start: { day: startDate.getDate(), month: startDate.getMonth() + 1, year: startDate.getFullYear() },
26      end: { day: endDate.getDate(), month: endDate.getMonth() + 1, year: endDate.getFullYear() },
27    }),
28    timeGranularity: 'MONTHLY',
29    accounts: `List(urn:li:sponsoredAccount:${accountId})`,
30    fields: 'impressions,clicks,externalWebsiteConversions,costInLocalCurrency,dateRange',
31  });
32
33  const response = await fetch(`https://api.linkedin.com/v2/adAnalyticsV2?${params}`, {
34    headers: {
35      'Authorization': `Bearer ${accessToken}`,
36      'LinkedIn-Version': '202401',
37      'X-Restli-Protocol-Version': '2.0.0',
38    },
39  });
40
41  if (!response.ok) {
42    return NextResponse.json({ error: await response.text() }, { status: response.status });
43  }
44
45  const raw = await response.json();
46  // LinkedIn spend is in micro-currency — divide by 1,000,000 for USD
47  const data = (raw.elements || []).map((el: Record<string, unknown>) => ({
48    ...el,
49    spendUSD: Number(el.costInLocalCurrency) / 1_000_000,
50    ctr: el.impressions ? ((Number(el.clicks) / Number(el.impressions)) * 100).toFixed(2) : '0.00',
51  }));
52
53  return NextResponse.json({ data });
54}