How to Integrate Bolt.new with Agorapulse

1// lib/social-apis.ts
2export async function fetchFacebookInsights(
3  pageId: string,
4  metric: string = 'page_impressions,page_engaged_users',
5  period: string = 'week'
6) {
7  const token = process.env.FACEBOOK_PAGE_ACCESS_TOKEN;
8  const url = `https://graph.facebook.com/v19.0/${pageId}/insights?metric=${metric}&period=${period}&access_token=${token}`;
9
10  try {
11    const res = await fetch(url);
12    if (!res.ok) return null;
13    return res.json();
14  } catch {
15    console.error('Facebook API error');
16    return null;
17  }
18}
19
20export async function fetchTwitterMentions(userId: string) {
21  const token = process.env.TWITTER_BEARER_TOKEN;
22  const url = `https://api.twitter.com/2/users/${userId}/mentions?tweet.fields=public_metrics,created_at&max_results=20`;
23
24  try {
25    const res = await fetch(url, {
26      headers: { Authorization: `Bearer ${token}` },
27    });
28    if (!res.ok) return null;
29    return res.json();
30  } catch {
31    console.error('Twitter API error');
32    return null;
33  }
34}
35
36export async function fetchInstagramMedia(userId: string) {
37  const token = process.env.INSTAGRAM_ACCESS_TOKEN;
38  const url = `https://graph.instagram.com/${userId}/media?fields=id,caption,media_type,timestamp,like_count,comments_count&access_token=${token}`;
39
40  try {
41    const res = await fetch(url);
42    if (!res.ok) return null;
43    return res.json();
44  } catch {
45    console.error('Instagram API error');
46    return null;
47  }
48}
49
50// If/when Agorapulse API is available:
51export async function fetchAgorapulseProfiles() {
52  const token = process.env.AGORAPULSE_ACCESS_TOKEN;
53  if (!token) return null;
54
55  try {
56    const res = await fetch('https://app.agorapulse.com/api/v1/profiles', {
57      headers: { Authorization: `Bearer ${token}` },
58    });
59    if (!res.ok) return null;
60    return res.json();
61  } catch {
62    return null;
63  }
64}

1// app/api/social/inbox/route.ts
2import { NextRequest, NextResponse } from 'next/server';
3import { fetchFacebookInsights, fetchTwitterMentions, fetchInstagramMedia } from '@/lib/social-apis';
4
5interface SocialItem {
6  id: string;
7  platform: 'facebook' | 'twitter' | 'instagram';
8  type: 'comment' | 'mention' | 'message';
9  author: string;
10  content: string;
11  timestamp: string;
12  url: string;
13}
14
15export async function GET(request: NextRequest) {
16  const { searchParams } = new URL(request.url);
17  const pageId = searchParams.get('page_id');
18  const twitterUserId = searchParams.get('twitter_user_id');
19  const instagramUserId = searchParams.get('instagram_user_id');
20
21  const [fbResult, twResult, igResult] = await Promise.allSettled([
22    pageId
23      ? fetch(
24          `https://graph.facebook.com/v19.0/${pageId}/feed?fields=comments{message,from,created_time}&access_token=${process.env.FACEBOOK_PAGE_ACCESS_TOKEN}`
25        ).then((r) => r.json())
26      : Promise.resolve(null),
27    twitterUserId ? fetchTwitterMentions(twitterUserId) : Promise.resolve(null),
28    instagramUserId ? fetchInstagramMedia(instagramUserId) : Promise.resolve(null),
29  ]);
30
31  const items: SocialItem[] = [];
32
33  // Normalize and merge — actual field mapping depends on platform API response structure
34  if (twResult.status === 'fulfilled' && twResult.value?.data) {
35    for (const tweet of twResult.value.data) {
36      items.push({
37        id: tweet.id,
38        platform: 'twitter',
39        type: 'mention',
40        author: tweet.author_id,
41        content: tweet.text,
42        timestamp: tweet.created_at,
43        url: `https://twitter.com/i/web/status/${tweet.id}`,
44      });
45    }
46  }
47
48  items.sort((a, b) => new Date(b.timestamp).getTime() - new Date(a.timestamp).getTime());
49
50  return NextResponse.json({ items, total: items.length });
51}

1// app/api/social/publish/route.ts
2import { NextRequest, NextResponse } from 'next/server';
3
4async function publishToFacebook(pageId: string, content: string, imageUrl?: string) {
5  const token = process.env.FACEBOOK_PAGE_ACCESS_TOKEN;
6  const body: Record<string, string> = { message: content };
7  if (imageUrl) body.picture = imageUrl;
8
9  const res = await fetch(`https://graph.facebook.com/v19.0/${pageId}/feed`, {
10    method: 'POST',
11    headers: { 'Content-Type': 'application/json' },
12    body: JSON.stringify({ ...body, access_token: token }),
13  });
14  return res.json();
15}
16
17async function publishToTwitter(content: string) {
18  // Note: Twitter v2 write access requires Elevated or Pro tier
19  const res = await fetch('https://api.twitter.com/2/tweets', {
20    method: 'POST',
21    headers: {
22      Authorization: `Bearer ${process.env.TWITTER_BEARER_TOKEN}`,
23      'Content-Type': 'application/json',
24    },
25    body: JSON.stringify({ text: content }),
26  });
27  return res.json();
28}
29
30export async function POST(request: NextRequest) {
31  const { content, image_url, platforms } = await request.json();
32
33  if (!content || !platforms?.length) {
34    return NextResponse.json({ error: 'content and platforms are required' }, { status: 400 });
35  }
36
37  const pageId = process.env.FACEBOOK_PAGE_ID;
38  const results: Record<string, { success: boolean; id?: string; error?: string }> = {};
39
40  const tasks = platforms.map(async (platform: string) => {
41    try {
42      if (platform === 'facebook' && pageId) {
43        const data = await publishToFacebook(pageId, content, image_url);
44        results[platform] = { success: !!data.id, id: data.id, error: data.error?.message };
45      } else if (platform === 'twitter') {
46        const data = await publishToTwitter(content);
47        results[platform] = { success: !!data.data?.id, id: data.data?.id };
48      }
49    } catch (e) {
50      results[platform] = { success: false, error: String(e) };
51    }
52  });
53
54  await Promise.allSettled(tasks);
55  return NextResponse.json(results);
56}

1// app/settings/page.tsx
2'use client';
3import { useEffect, useState } from 'react';
4
5interface IntegrationStatus {
6  name: string;
7  configured: boolean;
8  label: string;
9}
10
11export default function SettingsPage() {
12  const [statuses, setStatuses] = useState<IntegrationStatus[]>([]);
13
14  useEffect(() => {
15    fetch('/api/social/status').then((r) => r.json()).then(setStatuses);
16  }, []);
17
18  return (
19    <div className="p-8">
20      <h1 className="text-2xl font-bold mb-6">Social Media Integrations</h1>
21      <div className="space-y-3">
22        {statuses.map((s) => (
23          <div key={s.name} className="flex items-center justify-between p-4 border rounded-lg">
24            <span className="font-medium">{s.label}</span>
25            <span className={`text-sm font-semibold ${s.configured ? 'text-green-600' : 'text-red-500'}`}>
26              {s.configured ? 'Connected' : 'Not configured'}
27            </span>
28          </div>
29        ))}
30      </div>
31    </div>
32  );
33}