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 }),
  });
  const { data } = await res.json();
  return data; // array of { step_number, step_name, visitors, 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 journeysFrom(page) {
  const stepFilters = JSON.stringify({ '0': page });
  const url = new URL(`${API}/api/sites/${SITE}/journeys`);
  url.searchParams.set('steps', '2');
  url.searchParams.set('limit', '10');
  url.searchParams.set('stepFilters', stepFilters);
  Object.entries(range).forEach(([k, v]) => url.searchParams.set(k, v));

  const res = await fetch(url, { headers: { Authorization: `Bearer ${API_KEY}` } });
  const { journeys } = await res.json();
  return journeys;
}

// The leaky step's page — '/pricing' in our example
const leakyPage = funnelSteps[leak.step_number - 2].value;
const journeys = await journeysFrom(leakyPage);

console.log(`Where users go after ${leakyPage}:`);
journeys
  .filter((j) => j.path[1] && j.path[1] !== '/signup') // exclude the intended next step
  .slice(0, 5)
  .forEach((j) => console.log(`  → ${j.path[1]}  (${j.count} sessions, ${j.percentage}%)`));

import json


def journeys_from(page):
    res = requests.get(
        f"{API}/api/sites/{SITE}/journeys",
        params={"steps": 2, "limit": 10, "stepFilters": json.dumps({"0": page}), **RANGE},
        headers={"Authorization": f"Bearer {API_KEY}"},
    )
    res.raise_for_status()
    return res.json()["journeys"]


# The leaky step's page — '/pricing' in our example
leaky_page = FUNNEL_STEPS[leak["step_number"] - 2]["value"]
journeys = journeys_from(leaky_page)

print(f"Where users go after {leaky_page}:")
for j in [j for j in journeys if len(j["path"]) > 1 and j["path"][1] != "/signup"][:5]:
    print(f'  → {j["path"][1]}  ({j["count"]} sessions, {j["percentage"]}%)')