Find Where Users Drop Off

const API = 'https://app.rybbit.io';
const SITE = '123';
const API_KEY = process.env.RYBBIT_API_KEY;

const range = { start_date: '2024-01-01', end_date: '2024-01-31', time_zone: 'America/New_York' };

const funnelSteps = [
  { type: 'page',  value: '/',                 name: 'Homepage' },
  { type: 'page',  value: '/pricing',          name: 'Pricing' },
  { type: 'page',  value: '/signup',           name: 'Signup' },
  { type: 'event', value: 'signup_complete',   name: 'Complete' },
];

async function analyzeFunnel() {
  const url = new URL(`${API}/api/sites/${SITE}/funnels/analyze`);
  Object.entries(range).forEach(([k, v]) => url.searchParams.set(k, v));

  const res = await fetch(url, {
    method: 'POST',
    headers: {
      Authorization: `Bearer ${API_KEY}`,
      'Content-Type': 'application/json',
    },
    body: JSON.stringify({ steps: funnelSteps }),
  });
  if (!res.ok) throw new Error(`Funnel analysis failed: HTTP ${res.status}`);
  const { data } = await res.json();
  return data; // array of { step_number, step_name, sessions, conversion_rate, dropoff_rate }
}

import os, requests

API = "https://app.rybbit.io"
SITE = "123"
API_KEY = os.environ["RYBBIT_API_KEY"]

RANGE = {"start_date": "2024-01-01", "end_date": "2024-01-31", "time_zone": "America/New_York"}

FUNNEL_STEPS = [
    {"type": "page",  "value": "/",               "name": "Homepage"},
    {"type": "page",  "value": "/pricing",        "name": "Pricing"},
    {"type": "page",  "value": "/signup",         "name": "Signup"},
    {"type": "event", "value": "signup_complete", "name": "Complete"},
]


def analyze_funnel():
    res = requests.post(
        f"{API}/api/sites/{SITE}/funnels/analyze",
        params=RANGE,
        json={"steps": FUNNEL_STEPS},
        headers={"Authorization": f"Bearer {API_KEY}"},
    )
    res.raise_for_status()
    return res.json()["data"]  # list of step results

function biggestLeak(steps) {
  // Skip step 1 — it always has 0% drop-off
  return steps
    .filter((s) => s.step_number > 1)
    .reduce((worst, s) => (s.dropoff_rate > worst.dropoff_rate ? s : worst));
}

const steps = await analyzeFunnel();
const leak = biggestLeak(steps);
const enteredStep = steps[leak.step_number - 2]; // the step they were on before leaving

console.log(
  `Worst leak: ${leak.dropoff_rate}% of users left after "${enteredStep.step_name}" ` +
  `instead of reaching "${leak.step_name}".`
);

def biggest_leak(steps):
    # Skip step 1 — it always has 0% drop-off
    return max((s for s in steps if s["step_number"] > 1), key=lambda s: s["dropoff_rate"])


steps = analyze_funnel()
leak = biggest_leak(steps)
entered_step = steps[leak["step_number"] - 2]  # the step they were on before leaving

print(
    f'Worst leak: {leak["dropoff_rate"]}% of users left after "{entered_step["step_name"]}" '
    f'instead of reaching "{leak["step_name"]}".'
)

async function droppedSessions(stepNumber, pages = 5) {
  const sessions = [];
  for (let page = 1; page <= pages; page++) {
    const url = new URL(`${API}/api/sites/${SITE}/funnels/${stepNumber}/sessions`);
    url.searchParams.set('mode', 'dropped');
    url.searchParams.set('limit', '100');
    url.searchParams.set('page', String(page));
    Object.entries(range).forEach(([k, v]) => url.searchParams.set(k, v));

    const res = await fetch(url, {
      method: 'POST',
      headers: { Authorization: `Bearer ${API_KEY}`, 'Content-Type': 'application/json' },
      body: JSON.stringify({ steps: funnelSteps }),
    });
    if (!res.ok) throw new Error(`Step sessions failed: HTTP ${res.status}`);
    const { data } = await res.json();
    sessions.push(...data);
    if (data.length < 100) break; // last page
  }
  return sessions;
}

// Sessions that reached the step before the leak ('Pricing') but not the next one
const dropped = await droppedSessions(enteredStep.step_number);

const exits = {};
for (const s of dropped) exits[s.exit_page] = (exits[s.exit_page] || 0) + 1;

console.log(`Last page viewed by ${dropped.length} sessions that left after ${enteredStep.step_name}:`);
Object.entries(exits)
  .sort((a, b) => b[1] - a[1])
  .slice(0, 5)
  .forEach(([page, n]) => console.log(`  ${page}  (${n} sessions, ${((n / dropped.length) * 100).toFixed(1)}%)`));

from collections import Counter


def dropped_sessions(step_number, pages=5):
    sessions = []
    for page in range(1, pages + 1):
        res = requests.post(
            f"{API}/api/sites/{SITE}/funnels/{step_number}/sessions",
            params={"mode": "dropped", "limit": 100, "page": page, **RANGE},
            json={"steps": FUNNEL_STEPS},
            headers={"Authorization": f"Bearer {API_KEY}"},
        )
        res.raise_for_status()
        data = res.json()["data"]
        sessions.extend(data)
        if len(data) < 100:  # last page
            break
    return sessions


# Sessions that reached the step before the leak ('Pricing') but not the next one
dropped = dropped_sessions(entered_step["step_number"])
exits = Counter(s["exit_page"] for s in dropped)

print(f'Last page viewed by {len(dropped)} sessions that left after {entered_step["step_name"]}:')
for page, n in exits.most_common(5):
    print(f"  {page}  ({n} sessions, {n / len(dropped) * 100:.1f}%)")