Send Targeted Mass Messages and PPV Campaigns via API

// Step 1: Upload media to OnlyFans CDN
const mediaResponse = await fetch(
  'https://app.fansapi.com/api/acct_XXXX/media/upload',
  {
    method: 'POST',
    headers: {
      'Authorization': 'Bearer sk_your_api_key',
      'Content-Type': 'application/json'
    },
    body: JSON.stringify({
      file_url: 'https://your-cdn.com/exclusive-content.mp4'
    })
  }
);
const media = await mediaResponse.json();

// Step 2: Send mass PPV message to a user list
const massMessageResponse = await fetch(
  'https://app.fansapi.com/api/acct_XXXX/mass-messaging',
  {
    method: 'POST',
    headers: {
      'Authorization': 'Bearer sk_your_api_key',
      'Content-Type': 'application/json'
    },
    body: JSON.stringify({
      text: 'Exclusive content just for you 🔥',
      price: 15.00,
      mediaFiles: [media.data.id],
      userLists: ['top_spenders_list_id']
    })
  }
);
const campaign = await massMessageResponse.json();
console.log('Campaign sent:', campaign.data.id);

// Webhook handler: messages.ppv.unlocked
app.post('/webhooks/onlyfans', async (req, res) => {
  const { event, account_id, payload } = req.body;

  if (event === 'messages.ppv.unlocked') {
    // payload.user = buyer profile
    // payload.fanData.spending = lifetime spend breakdown
    // payload.replacePairs['{AMOUNT}'] = purchase amount
    const { user, fanData, replacePairs } = payload;
    const purchaseAmount = replacePairs['{AMOUNT}'];

    // Log the PPV unlock
    console.log(
      user.username + ' unlocked PPV for ' + purchaseAmount
    );

    // Update campaign revenue in your database
    await db.campaigns.updateRevenue({
      eventId: payload.id,
      fanId: user.id,
      fanUsername: user.username,
      purchaseAmount: purchaseAmount,
      fanLifetimeSpend: fanData.spending.total,
      fanTipSpend: fanData.spending.tips,
      fanMessageSpend: fanData.spending.messages,
    });

    // If whale spender, send a personalized follow-up
    if (fanData.spending.total > 500) {
      await fetch(
        'https://app.fansapi.com/api/' + account_id + '/chats/' + user.id + '/messages',
        {
          method: 'POST',
          headers: {
            'Authorization': 'Bearer sk_your_api_key',
            'Content-Type': 'application/json'
          },
          body: JSON.stringify({
            text: 'Thanks for the support! Here is a bonus 💎'
          })
        }
      );
    }
  }

  res.sendStatus(200);
});

// Get mass messaging overview
const overviewResponse = await fetch(
  'https://app.fansapi.com/api/acct_XXXX/mass-messaging/overview',
  {
    headers: {
      'Authorization': 'Bearer sk_your_api_key',
      'Content-Type': 'application/json'
    }
  }
);
const overview = await overviewResponse.json();
console.log('Total campaigns:', overview.data);

// Get engagement stats for mass messages
const engagementResponse = await fetch(
  'https://app.fansapi.com/api/acct_XXXX/engagement/messages/mass-messages',
  {
    headers: {
      'Authorization': 'Bearer sk_your_api_key',
      'Content-Type': 'application/json'
    }
  }
);
const engagement = await engagementResponse.json();

// Get the top revenue-generating message
const topMessageResponse = await fetch(
  'https://app.fansapi.com/api/acct_XXXX/engagement/messages/top-message',
  {
    headers: {
      'Authorization': 'Bearer sk_your_api_key',
      'Content-Type': 'application/json'
    }
  }
);
const topMessage = await topMessageResponse.json();
console.log('Top message:', topMessage.data);

// Get buyer list for a specific message
const buyersResponse = await fetch(
  'https://app.fansapi.com/api/acct_XXXX/engagement/messages/'
    + topMessage.data.id + '/buyers',
  {
    headers: {
      'Authorization': 'Bearer sk_your_api_key',
      'Content-Type': 'application/json'
    }
  }
);
const buyers = await buyersResponse.json();
console.log('Buyers:', buyers.data);