How to Integrate Bolt.new with Bing Ads (Microsoft Advertising)

1// lib/bing-ads.ts
2const TOKEN_ENDPOINT = 'https://login.microsoftonline.com/common/oauth2/v2.0/token';
3const SCOPE = 'https://ads.microsoft.com/ads.manage offline_access';
4
5let cachedToken: { token: string; expiresAt: number } | null = null;
6
7export async function getMicrosoftAdsToken(): Promise<string> {
8  // Return cached token if not expired (with 60s buffer)
9  if (cachedToken && Date.now() < cachedToken.expiresAt - 60_000) {
10    return cachedToken.token;
11  }
12
13  const clientId = process.env.MICROSOFT_ADS_CLIENT_ID;
14  const clientSecret = process.env.MICROSOFT_ADS_CLIENT_SECRET;
15  const refreshToken = process.env.MICROSOFT_ADS_REFRESH_TOKEN;
16
17  if (!clientId || !clientSecret || !refreshToken) {
18    throw new Error(
19      'Missing Microsoft Advertising credentials. Set MICROSOFT_ADS_CLIENT_ID, ' +
20      'MICROSOFT_ADS_CLIENT_SECRET, and MICROSOFT_ADS_REFRESH_TOKEN in .env'
21    );
22  }
23
24  const response = await fetch(TOKEN_ENDPOINT, {
25    method: 'POST',
26    headers: { 'Content-Type': 'application/x-www-form-urlencoded' },
27    body: new URLSearchParams({
28      client_id: clientId,
29      client_secret: clientSecret,
30      refresh_token: refreshToken,
31      grant_type: 'refresh_token',
32      scope: SCOPE,
33    }),
34  });
35
36  const data = await response.json() as {
37    access_token?: string;
38    expires_in?: number;
39    error?: string;
40    error_description?: string;
41  };
42
43  if (!response.ok || !data.access_token) {
44    throw new Error(`Token refresh failed: ${data.error_description || data.error}`);
45  }
46
47  cachedToken = {
48    token: data.access_token,
49    expiresAt: Date.now() + (data.expires_in || 3600) * 1000,
50  };
51
52  return cachedToken.token;
53}
54
55export async function getMicrosoftAdsHeaders(): Promise<Record<string, string>> {
56  const token = await getMicrosoftAdsToken();
57  const customerId = process.env.MICROSOFT_ADS_CUSTOMER_ID;
58  const accountId = process.env.MICROSOFT_ADS_ACCOUNT_ID;
59
60  return {
61    Authorization: `Bearer ${token}`,
62    'CustomerId': customerId || '',
63    'CustomerAccountId': accountId || '',
64    'Content-Type': 'application/json',
65    'DeveloperToken': process.env.MICROSOFT_ADS_DEVELOPER_TOKEN || '',
66  };
67}

1// app/api/bing/device-auth/route.ts
2import { NextResponse } from 'next/server';
3
4export async function GET() {
5  const clientId = process.env.MICROSOFT_ADS_CLIENT_ID;
6  if (!clientId) {
7    return NextResponse.json({ error: 'MICROSOFT_ADS_CLIENT_ID not configured' }, { status: 500 });
8  }
9
10  const response = await fetch(
11    'https://login.microsoftonline.com/common/oauth2/v2.0/devicecode',
12    {
13      method: 'POST',
14      headers: { 'Content-Type': 'application/x-www-form-urlencoded' },
15      body: new URLSearchParams({
16        client_id: clientId,
17        scope: 'https://ads.microsoft.com/ads.manage offline_access',
18      }),
19    }
20  );
21
22  const data = await response.json() as {
23    user_code?: string;
24    device_code?: string;
25    verification_uri?: string;
26    expires_in?: number;
27    interval?: number;
28    error?: string;
29  };
30
31  if (!response.ok || !data.device_code) {
32    return NextResponse.json({ error: data.error || 'Device code request failed' }, { status: 500 });
33  }
34
35  return NextResponse.json({
36    userCode: data.user_code,
37    verificationUri: data.verification_uri,
38    deviceCode: data.device_code,
39    expiresIn: data.expires_in,
40    message: `1. Visit ${data.verification_uri} in your browser. 2. Enter code: ${data.user_code}. 3. Call /api/bing/device-auth/token?deviceCode=${data.device_code} to get your refresh token.`,
41  });
42}

1// app/api/bing/campaigns/route.ts
2import { NextResponse } from 'next/server';
3import { getMicrosoftAdsHeaders } from '@/lib/bing-ads';
4
5const REPORTING_BASE = 'https://reporting.api.bingads.microsoft.com/Reporting/v13';
6
7async function submitReportRequest(
8  headers: Record<string, string>,
9  startDate: string,
10  endDate: string,
11  accountId: string
12): Promise<string> {
13  const [startYear, startMonth, startDay] = startDate.split('-').map(Number);
14  const [endYear, endMonth, endDay] = endDate.split('-').map(Number);
15
16  const body = {
17    ReportRequest: {
18      Format: 'Tsv',
19      Language: 'English',
20      ReportName: 'CampaignPerformance',
21      ReturnOnlyCompleteData: false,
22      Type: 'CampaignPerformanceReport',
23      Aggregation: 'Summary',
24      Columns: [
25        'CampaignName', 'CampaignId', 'CampaignStatus',
26        'Spend', 'Impressions', 'Clicks', 'AverageCpc',
27        'Ctr', 'QualityScore', 'Conversions', 'CostPerConversion',
28      ],
29      Scope: { AccountIds: [parseInt(accountId, 10)] },
30      Time: {
31        CustomDateRangeStart: { Day: startDay, Month: startMonth, Year: startYear },
32        CustomDateRangeEnd: { Day: endDay, Month: endMonth, Year: endYear },
33      },
34    },
35  };
36
37  const response = await fetch(`${REPORTING_BASE}/GenerateReport`, {
38    method: 'POST',
39    headers,
40    body: JSON.stringify(body),
41  });
42
43  const data = await response.json() as { ReportRequestId?: string; Error?: { Message: string } };
44  if (!data.ReportRequestId) {
45    throw new Error(data.Error?.Message || 'Failed to submit report request');
46  }
47  return data.ReportRequestId;
48}
49
50async function pollReport(
51  headers: Record<string, string>,
52  requestId: string,
53  maxAttempts = 6
54): Promise<string> {
55  for (let attempt = 0; attempt < maxAttempts; attempt++) {
56    if (attempt > 0) await new Promise((r) => setTimeout(r, 5000));
57
58    const response = await fetch(
59      `${REPORTING_BASE}/PollGenerateReport?ReportRequestId=${requestId}`,
60      { headers }
61    );
62
63    const data = await response.json() as {
64      ReportRequestStatus?: { Status: string; ReportDownloadUrl?: string };
65    };
66
67    const status = data.ReportRequestStatus?.Status;
68    if (status === 'Success' && data.ReportRequestStatus?.ReportDownloadUrl) {
69      return data.ReportRequestStatus.ReportDownloadUrl;
70    }
71    if (status === 'Error') throw new Error('Report generation failed');
72  }
73  throw new Error('Report timed out after 30 seconds');
74}
75
76function parseTsv(tsv: string): Record<string, string>[] {
77  const lines = tsv.trim().split('\n');
78  const headers = lines[1]?.split('\t') || []; // Line 0 = report metadata, Line 1 = headers
79  return lines.slice(2).map((line) => {
80    const values = line.split('\t');
81    return Object.fromEntries(headers.map((h, i) => [h.trim(), (values[i] || '').trim()]));
82  }).filter((row) => row['Campaign name'] || row['CampaignName']);
83}
84
85export async function GET(request: Request) {
86  const { searchParams } = new URL(request.url);
87  const accountId = process.env.MICROSOFT_ADS_ACCOUNT_ID;
88  if (!accountId) {
89    return NextResponse.json({ error: 'MICROSOFT_ADS_ACCOUNT_ID not configured' }, { status: 500 });
90  }
91
92  const endDate = new Date().toISOString().split('T')[0];
93  const startDate = new Date(Date.now() - 30 * 86400000).toISOString().split('T')[0];
94
95  try {
96    const headers = await getMicrosoftAdsHeaders();
97    const requestId = await submitReportRequest(
98      headers,
99      searchParams.get('startDate') || startDate,
100      searchParams.get('endDate') || endDate,
101      accountId
102    );
103
104    const downloadUrl = await pollReport(headers, requestId);
105    const reportText = await fetch(downloadUrl).then((r) => r.text());
106    const rows = parseTsv(reportText);
107
108    const campaigns = rows.map((row) => ({
109      name: row['CampaignName'] || row['Campaign name'] || '',
110      id: row['CampaignId'] || row['Campaign ID'] || '',
111      status: row['CampaignStatus'] || row['Campaign status'] || '',
112      spend: parseFloat(row['Spend'] || '0'),
113      impressions: parseInt(row['Impressions'] || '0', 10),
114      clicks: parseInt(row['Clicks'] || '0', 10),
115      avgCpc: parseFloat(row['AverageCpc'] || row['Avg. CPC'] || '0'),
116      ctr: parseFloat(row['Ctr'] || row['CTR'] || '0'),
117      qualityScore: parseInt(row['QualityScore'] || row['Quality score'] || '0', 10),
118      conversions: parseInt(row['Conversions'] || '0', 10),
119      costPerConversion: parseFloat(row['CostPerConversion'] || row['Cost per conversion'] || '0'),
120    }));
121
122    campaigns.sort((a, b) => b.spend - a.spend);
123
124    const totals = campaigns.reduce(
125      (acc, c) => ({ spend: acc.spend + c.spend, impressions: acc.impressions + c.impressions, clicks: acc.clicks + c.clicks, conversions: acc.conversions + c.conversions }),
126      { spend: 0, impressions: 0, clicks: 0, conversions: 0 }
127    );
128
129    return NextResponse.json({ campaigns, totals });
130  } catch (err) {
131    const message = err instanceof Error ? err.message : 'Failed to fetch Bing Ads data';
132    return NextResponse.json({ error: message }, { status: 500 });
133  }
134}

1# Production environment variables — add to Netlify or Bolt Cloud
2# All must be server-side only (no NEXT_PUBLIC_ prefix)
3
4MICROSOFT_ADS_CLIENT_ID=your_azure_app_client_id
5MICROSOFT_ADS_CLIENT_SECRET=your_azure_app_client_secret
6MICROSOFT_ADS_REFRESH_TOKEN=your_refresh_token_from_device_flow
7MICROSOFT_ADS_CUSTOMER_ID=your_customer_id
8MICROSOFT_ADS_ACCOUNT_ID=your_account_id
9MICROSOFT_ADS_DEVELOPER_TOKEN=your_developer_token