Automate OnlyFans Chat with Webhooks and Real-Time Messaging API

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

  if (event === 'messages.received') {
    // payload.fromUser = sender profile with subscription info
    // payload.text = message content (HTML)
    // payload.fanData.spending = fan's lifetime spend
    const { fromUser, text, fanData } = payload;

    // Skip if message is from the creator (outgoing)
    if (fromUser.isPerformer) return res.sendStatus(200);

    // Generate AI response (your chatbot logic)
    const aiReply = await yourAIChatbot.generateReply({
      message: text,
      fanName: fromUser.name,
      fanSpend: fanData.spending.total,
    });

    // Show typing indicator for natural feel
    await fetch(
      'https://app.fansapi.com/api/' + account_id + '/chats/' + fromUser.id + '/typing',
      {
        method: 'POST',
        headers: {
          'Authorization': 'Bearer sk_your_api_key',
          'Content-Type': 'application/json'
        }
      }
    );

    // Wait 2-4 seconds to simulate typing
    await new Promise(r => setTimeout(r, 2000 + Math.random() * 2000));

    // Send the reply
    await fetch(
      'https://app.fansapi.com/api/' + account_id + '/chats/' + fromUser.id + '/messages',
      {
        method: 'POST',
        headers: {
          'Authorization': 'Bearer sk_your_api_key',
          'Content-Type': 'application/json'
        },
        body: JSON.stringify({ text: aiReply })
      }
    );
  }

  res.sendStatus(200);
});

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

  if (event === 'subscriptions.new') {
    // payload.user = new subscriber profile
    const chatId = payload.user.id;

    // Step 1: Send immediate welcome message
    await fetch(
      'https://app.fansapi.com/api/' + account_id + '/chats/' + chatId + '/messages',
      {
        method: 'POST',
        headers: {
          'Authorization': 'Bearer sk_your_api_key',
          'Content-Type': 'application/json'
        },
        body: JSON.stringify({
          text: 'Hey! Welcome 💕 So glad you are here. '
            + 'Check your DMs — I have something special for you.'
        })
      }
    );

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

    // Step 3: Send PPV after 30-minute delay
    setTimeout(async () => {
      await fetch(
        'https://app.fansapi.com/api/' + account_id + '/chats/' + chatId + '/messages',
        {
          method: 'POST',
          headers: {
            'Authorization': 'Bearer sk_your_api_key',
            'Content-Type': 'application/json'
          },
          body: JSON.stringify({
            text: 'Here is that special something I promised 🔥',
            price: 9.99,
            mediaFiles: [media.data.id]
          })
        }
      );
    }, 30 * 60 * 1000);
  }

  res.sendStatus(200);
});

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

  if (event === 'tips.received') {
    // payload.user = tipper profile
    // payload.amountGross / payload.amountNet = tip amounts
    // payload.fanData.spending = lifetime spend breakdown
    const { user, amountGross, amountNet } = payload;
    const chatId = user.id;

    // Only upsell if tip is above threshold
    if (amountGross < 5) return res.sendStatus(200);

    // Select PPV content based on tip amount
    let ppvContent, ppvPrice;
    if (amountGross >= 50) {
      ppvContent = 'premium-exclusive.mp4';
      ppvPrice = 25.00;
    } else if (amountGross >= 20) {
      ppvContent = 'special-content.mp4';
      ppvPrice = 15.00;
    } else {
      ppvContent = 'bonus-content.mp4';
      ppvPrice = 9.99;
    }

    // Upload the PPV media
    const mediaResponse = await fetch(
      'https://app.fansapi.com/api/' + account_id + '/media/upload',
      {
        method: 'POST',
        headers: {
          'Authorization': 'Bearer sk_your_api_key',
          'Content-Type': 'application/json'
        },
        body: JSON.stringify({
          file_url: 'https://your-cdn.com/' + ppvContent
        })
      }
    );
    const media = await mediaResponse.json();

    // Send personalized PPV upsell
    await fetch(
      'https://app.fansapi.com/api/' + account_id + '/chats/' + chatId + '/messages',
      {
        method: 'POST',
        headers: {
          'Authorization': 'Bearer sk_your_api_key',
          'Content-Type': 'application/json'
        },
        body: JSON.stringify({
          text: 'Omg thank you so much for the tip!! 😍 '
            + 'You deserve something extra special...',
          price: ppvPrice,
          mediaFiles: [media.data.id]
        })
      }
    );
  }

  res.sendStatus(200);
});