Compare Channel Performance

const API = 'https://app.rybbit.io';
const SITE = '123';
const API_KEY = process.env.RYBBIT_API_KEY;
const PRIMARY_GOAL_ID = 1; // the goal you care about

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

async function get(path, params) {
  const url = new URL(`${API}/api/sites/${SITE}${path}`);
  Object.entries(params).forEach(([k, v]) => url.searchParams.set(k, v));
  const res = await fetch(url, { headers: { Authorization: `Bearer ${API_KEY}` } });
  if (!res.ok) throw new Error(`${path} failed: ${res.status}`);
  return res.json();
}

// 1. All channels with their session counts
async function getChannels() {
  const { data } = await get('/metric', { parameter: 'channel', limit: 20, ...range });
  return data.data; // [{ value: 'Organic Search', count: 5400, ... }]
}

// 2. Conversion rate for one channel, scoped with a filter
async function goalForChannel(channel) {
  const filters = JSON.stringify([{ parameter: 'channel', type: 'equals', value: [channel] }]);
  const { data } = await get('/goals', { filters, ...range });
  return data.find((g) => g.goalId === PRIMARY_GOAL_ID);
}

async function rankChannels() {
  const channels = await getChannels();

  const rows = await Promise.all(
    channels.map(async (c) => {
      const goal = await goalForChannel(c.value);
      return {
        channel: c.value || 'Direct',
        sessions: c.count,
        conversions: goal?.total_conversions ?? 0,
        // conversion_rate comes back as a 0–1 fraction
        conversionRate: (goal?.conversion_rate ?? 0) * 100,
      };
    })
  );

  return rows.sort((a, b) => b.conversionRate - a.conversionRate);
}

rankChannels().then((rows) => {
  console.log('Channel'.padEnd(18), 'Sessions'.padStart(10), 'Conv.'.padStart(8), 'Rate'.padStart(8));
  for (const r of rows) {
    console.log(
      r.channel.padEnd(18),
      r.sessions.toLocaleString().padStart(10),
      String(r.conversions).padStart(8),
      `${r.conversionRate.toFixed(2)}%`.padStart(8)
    );
  }
});

import os, json, requests

API = "https://app.rybbit.io"
SITE = "123"
API_KEY = os.environ["RYBBIT_API_KEY"]
PRIMARY_GOAL_ID = 1  # the goal you care about

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

session = requests.Session()
session.headers["Authorization"] = f"Bearer {API_KEY}"


def get(path, **params):
    res = session.get(f"{API}/api/sites/{SITE}{path}", params=params)
    res.raise_for_status()
    return res.json()


def get_channels():
    # 1. All channels with their session counts
    return get("/metric", parameter="channel", limit=20, **RANGE)["data"]["data"]


def goal_for_channel(channel):
    # 2. Conversion rate for one channel, scoped with a filter
    filters = json.dumps([{"parameter": "channel", "type": "equals", "value": [channel]}])
    goals = get("/goals", filters=filters, **RANGE)["data"]
    return next((g for g in goals if g["goalId"] == PRIMARY_GOAL_ID), None)


def rank_channels():
    rows = []
    for c in get_channels():
        goal = goal_for_channel(c["value"])
        rows.append({
            "channel": c["value"] or "Direct",
            "sessions": c["count"],
            "conversions": goal["total_conversions"] if goal else 0,
            # conversion_rate comes back as a 0–1 fraction
            "conversion_rate": (goal["conversion_rate"] if goal else 0) * 100,
        })
    return sorted(rows, key=lambda r: r["conversion_rate"], reverse=True)


print(f"{'Channel':<18}{'Sessions':>10}{'Conv.':>8}{'Rate':>8}")
for r in rank_channels():
    print(f"{r['channel']:<18}{r['sessions']:>10,}{r['conversions']:>8}{r['conversion_rate']:>7.2f}%")