How to Integrate ShipStation with V0

1// app/api/shipstation/orders/route.ts
2import { NextRequest, NextResponse } from 'next/server';
3
4const SHIPSTATION_BASE = 'https://ssapi.shipstation.com';
5
6function getAuthHeader() {
7  const credentials = `${process.env.SHIPSTATION_API_KEY}:${process.env.SHIPSTATION_API_SECRET}`;
8  return `Basic ${Buffer.from(credentials).toString('base64')}`;
9}
10
11export async function GET(request: NextRequest) {
12  const { searchParams } = new URL(request.url);
13  const orderStatus = searchParams.get('orderStatus') || 'awaiting_shipment';
14  const pageSize = searchParams.get('pageSize') || '50';
15  const page = searchParams.get('page') || '1';
16
17  try {
18    const url = new URL(`${SHIPSTATION_BASE}/orders`);
19    url.searchParams.set('orderStatus', orderStatus);
20    url.searchParams.set('pageSize', pageSize);
21    url.searchParams.set('page', page);
22
23    const response = await fetch(url.toString(), {
24      headers: {
25        'Authorization': getAuthHeader(),
26        'Content-Type': 'application/json',
27      },
28      // Cache for 30 seconds to reduce API calls
29      next: { revalidate: 30 },
30    });
31
32    if (response.status === 429) {
33      return NextResponse.json(
34        { error: 'Rate limit exceeded. Please wait before retrying.' },
35        { status: 429 }
36      );
37    }
38
39    if (!response.ok) {
40      return NextResponse.json(
41        { error: `ShipStation API error: ${response.status}` },
42        { status: response.status }
43      );
44    }
45
46    const data = await response.json();
47
48    return NextResponse.json({
49      orders: data.orders,
50      total: data.total,
51      page: data.page,
52      pages: data.pages,
53    });
54  } catch (error) {
55    console.error('ShipStation orders error:', error);
56    return NextResponse.json({ error: 'Failed to fetch orders' }, { status: 500 });
57  }
58}

1// app/api/shipstation/label/route.ts
2import { NextRequest, NextResponse } from 'next/server';
3
4function getAuthHeader() {
5  const credentials = `${process.env.SHIPSTATION_API_KEY}:${process.env.SHIPSTATION_API_SECRET}`;
6  return `Basic ${Buffer.from(credentials).toString('base64')}`;
7}
8
9export async function POST(request: NextRequest) {
10  try {
11    const body = await request.json();
12    const { orderId, carrierCode, serviceCode, packageCode, weight } = body;
13
14    if (!orderId) {
15      return NextResponse.json({ error: 'orderId is required' }, { status: 400 });
16    }
17
18    const labelPayload = {
19      orderId,
20      carrierCode: carrierCode || 'stamps_com',
21      serviceCode: serviceCode || 'usps_priority_mail',
22      packageCode: packageCode || 'package',
23      confirmation: 'none',
24      shipDate: new Date().toISOString().split('T')[0],
25      weight: weight || { value: 1, units: 'pounds' },
26      testLabel: process.env.SHIPSTATION_TEST_MODE === 'true',
27    };
28
29    const response = await fetch(
30      'https://ssapi.shipstation.com/orders/createlabelfororder',
31      {
32        method: 'POST',
33        headers: {
34          'Authorization': getAuthHeader(),
35          'Content-Type': 'application/json',
36        },
37        body: JSON.stringify(labelPayload),
38      }
39    );
40
41    const result = await response.json();
42
43    if (!response.ok) {
44      return NextResponse.json(
45        { error: result.ExceptionMessage || 'Label creation failed' },
46        { status: response.status }
47      );
48    }
49
50    return NextResponse.json({
51      shipmentId: result.shipmentId,
52      trackingNumber: result.trackingNumber,
53      carrierCode: result.carrierCode,
54      serviceCode: result.serviceCode,
55      labelData: result.labelData, // Base64 PDF
56    });
57  } catch (error) {
58    console.error('ShipStation label error:', error);
59    return NextResponse.json({ error: 'Label creation failed' }, { status: 500 });
60  }
61}

1// app/api/shipstation/webhook/route.ts
2import { NextRequest, NextResponse } from 'next/server';
3
4export async function POST(request: NextRequest) {
5  try {
6    const webhookToken = request.nextUrl.searchParams.get('token');
7    if (webhookToken !== process.env.SHIPSTATION_WEBHOOK_TOKEN) {
8      return NextResponse.json({ error: 'Unauthorized' }, { status: 401 });
9    }
10
11    const body = await request.json();
12    const { resource_url, resource_type } = body;
13
14    // Fetch the actual updated resource from ShipStation
15    const credentials = `${process.env.SHIPSTATION_API_KEY}:${process.env.SHIPSTATION_API_SECRET}`;
16    const authHeader = `Basic ${Buffer.from(credentials).toString('base64')}`;
17
18    const resourceResponse = await fetch(resource_url, {
19      headers: { 'Authorization': authHeader },
20    });
21    const resourceData = await resourceResponse.json();
22
23    // TODO: Update your database with the new order/shipment status
24    console.log(`ShipStation ${resource_type} update:`, resourceData);
25
26    return NextResponse.json({ received: true });
27  } catch (error) {
28    console.error('ShipStation webhook error:', error);
29    return NextResponse.json({ error: 'Webhook processing failed' }, { status: 500 });
30  }
31}