Supported Platforms

const TWITCH_CLIENT_ID = "kimne78kx3ncx6brgo4mv6wki5h1ko";
const endpoint = "https://gql.twitch.tv/gql";

query GetUserStream($login: String!) {
  user(login: $login) {
    id
    login
    displayName
    description
    profileImageURL(width: 300)
    followers {
      totalCount
    }
    roles {
      isPartner
      isAffiliate
    }
    stream {
      id
      title
      type
      viewersCount
      createdAt
      language
      previewImageURL(width: 640, height: 360)
      game {
        displayName
        boxArtURL(width: 144, height: 192)
      }
      tags {
        localizedName
      }
    }
  }
}

// From twitch.ts:96-173
export async function checkTwitchLive(username: string): Promise<LiveStatus> {
  const response = await fetch("https://gql.twitch.tv/gql", {
    method: "POST",
    headers: {
      "Client-ID": TWITCH_CLIENT_ID,
      "Content-Type": "application/json",
    },
    body: JSON.stringify({
      query: USER_STREAM_QUERY,
      variables: { login: username.toLowerCase() },
    }),
  });

  const data = await response.json();
  const user = data.data?.user;

  if (user.stream && user.stream.type === "live") {
    return {
      isLive: true,
      platform: "twitch",
      username: user.login,
      verified: user.roles?.isPartner ?? false,
      // ...
    };
  }
}

const liveUrl = `https://www.youtube.com/@${username}/live`;

// From youtube.ts:43-164
export async function checkYouTubeLive(username: string): Promise<LiveStatus> {
  const liveUrl = `https://www.youtube.com/@${username}/live`;
  const response = await fetch(liveUrl);
  const html = await response.text();

  // Extract ytInitialData JSON
  const dataMatch = html.match(/var ytInitialData = ({.*?});/s);
  const data = JSON.parse(dataMatch[1]);

  // Navigate to video info
  const contents = data.contents?.twoColumnWatchNextResults?.results?.results?.contents;
  const isLive = primaryInfo?.viewCount?.videoViewCountRenderer?.isLive === true;

  if (isLive) {
    return {
      isLive: true,
      platform: "youtube",
      title: primaryInfo?.title?.runs?.[0]?.text,
      viewers: parseInt(viewCountRenderer.originalViewCount, 10),
      // ...
    };
  }
}

const channelUrl = `https://rumble.com/c/${username}`;
const response = await fetch(channelUrl);
const html = await response.text();

// From rumble.ts:8-108
export async function checkRumbleLive(username: string): Promise<LiveStatus> {
  const response = await fetch(`https://rumble.com/c/${username}`);
  const html = await response.text();

  const isLive =
    html.includes("videostream__status--live") ||
    html.includes("thumbnail__thumb--live");

  if (isLive) {
    // Extract stream data via regex
    const titleMatch = html.match(
      /class=["']thumbnail__title[^"']*["'][^>]*>([^<]+)/
    );
    // ...
  }
}

const url = `https://www.tiktok.com/@${username}/live`;
const html = await response.text();

// Extract SIGI_STATE JSON from script tag
const stateMatch = html.match(
  /<script[^>]*id=["']SIGI_STATE["'][^>]*>({.*?})<\/script>/s
);
const data = JSON.parse(stateMatch[1]);

const liveRoom = data.LiveRoom?.liveRoomUserInfo;
const isLive = liveRoom?.liveRoom?.status === 2;

// From tiktok.ts:47-141
export async function checkTikTokLive(username: string): Promise<LiveStatus> {
  const url = `https://www.tiktok.com/@${username}/live`;
  const response = await fetch(url);
  const html = await response.text();

  const stateMatch = html.match(
    /<script[^>]*id=["']SIGI_STATE["'][^>]*>({.*?})<\/script>/s
  );
  const data = JSON.parse(stateMatch[1]);
  const liveRoom = data.LiveRoom?.liveRoomUserInfo;

  const isLive = liveRoom?.liveRoom?.status === 2;

  if (isLive) {
    return {
      isLive: true,
      platform: "tiktok",
      username: liveRoom.user?.uniqueId,
      title: liveRoom.liveRoom?.title,
      viewers: liveRoom.liveRoom?.liveRoomStats?.userCount,
      // ...
    };
  }
}