OnlyFans API JavaScript SDK

# Node 16 or earlier only — Node 18+ has fetch built-in
npm install node-fetch

# For ESM usage with node-fetch v3
npm install node-fetch@3

// ofapi.js — shared API client config

const BASE_URL = 'http://157.180.79.226:4024/api/v1';

const headers = {
  'x-api-key': process.env.OFAPI_KEY,
  'Content-Type': 'application/json',
};

async function ofapi(path, options = {}) {
  const res = await fetch(`${BASE_URL}${path}`, {
    ...options,
    headers: { ...headers, ...options.headers },
  });

  if (!res.ok) {
    const err = await res.json().catch(() => ({}));
    throw new Error(err.message ?? `HTTP ${res.status}`);
  }

  return res.json();
}

export { ofapi, BASE_URL, headers };

import { ofapi } from './ofapi.js';

async function getRevenueStats(creatorId) {
  const data = await ofapi(
    `/statistics/overview?creator_id=${creatorId}`
  );
  return data;
}

// Usage
const stats = await getRevenueStats('creator_abc123');
console.log(`Total earnings: $${stats.total_earnings}`);
console.log(`Subscriptions: $${stats.subscriptions}`);
console.log(`Tips: $${stats.tips}`);
console.log(`PPV: $${stats.ppv_messages + stats.ppv_posts}`);

import { ofapi } from './ofapi.js';

async function getTopFans(creatorId, limit = 10) {
  const data = await ofapi(
    `/stats/fans/top?creator_id=${creatorId}&limit=${limit}`
  );
  return data.fans;
}

// Get top 5 fans for a creator
const fans = await getTopFans('creator_abc123', 5);

fans.forEach((fan, i) => {
  console.log(
    `#${i + 1} ${fan.username} — $${fan.total_spent} total`
  );
});

import { ofapi } from './ofapi.js';

async function getPayouts(creatorId, page = 1) {
  const data = await ofapi(
    `/payouts/transactions?creator_id=${creatorId}&page=${page}&limit=20`
  );
  return data;
}

// Calculate total paid out this month
const { transactions } = await getPayouts('creator_abc123');
const now = new Date();
const thisMonth = transactions.filter(t => {
  const d = new Date(t.date);
  return d.getMonth() === now.getMonth()
      && d.getFullYear() === now.getFullYear();
});
const total = thisMonth.reduce((sum, t) => sum + t.amount, 0);
console.log(`Paid out this month: $${total.toFixed(2)}`);

import { ofapi } from './ofapi.js';

async function getTopSubscribers(creatorId, limit = 20) {
  const data = await ofapi(
    `/subscribers/top?creator_id=${creatorId}&limit=${limit}`
  );
  return data.subscribers;
}

// Flag subscribers who haven't purchased PPV in 14+ days
const subs = await getTopSubscribers('creator_abc123');
const cutoff = Date.now() - 14 * 24 * 60 * 60 * 1000;

const atRisk = subs.filter(s =>
  s.total_spent > 200 &&
  new Date(s.last_purchase_at).getTime() < cutoff
);

console.log(`${atRisk.length} high-value subs at churn risk`);

import { ofapi } from './ofapi.js';

async function sendMessage({ creatorId, fanId, text, ppvPrice, mediaIds }) {
  const body = {
    creator_id: creatorId,
    fan_id: fanId,
    text,
    ...(ppvPrice && { ppv_price: ppvPrice }),
    ...(mediaIds?.length && { media_ids: mediaIds }),
  };

  const result = await ofapi('/messages/send', {
    method: 'POST',
    body: JSON.stringify(body),
  });

  return result;
}

// Send a PPV re-engagement message
const result = await sendMessage({
  creatorId: 'creator_abc123',
  fanId: 'fan_001',
  text: 'Hey! I made something special just for you 🔥',
  ppvPrice: 12,
  mediaIds: ['media_xyz789'],
});

console.log(`Message sent: ${result.message_id}`);

import { BASE_URL, headers } from './ofapi.js';

async function safeApiCall(path, options = {}) {
  try {
    const res = await fetch(`${BASE_URL}${path}`, {
      ...options,
      headers: { ...headers, ...options.headers },
    });

    if (res.status === 401) {
      throw new Error('Invalid API key — check OFAPI_KEY env var');
    }
    if (res.status === 403) {
      throw new Error('Creator not on your account');
    }
    if (res.status === 429) {
      // Respect rate limits — back off and retry
      const retryAfter = res.headers.get('Retry-After') ?? '5';
      await new Promise(r => setTimeout(r, parseInt(retryAfter) * 1000));
      return safeApiCall(path, options); // one retry
    }
    if (!res.ok) {
      const err = await res.json().catch(() => ({}));
      throw new Error(err.message ?? `HTTP ${res.status}`);
    }

    return res.json();
  } catch (err) {
    if (err.name === 'TypeError') {
      // Network error — API unreachable
      throw new Error(`Network error reaching OFAPI: ${err.message}`);
    }
    throw err;
  }
}