Admin: editace obsahu

Obsah se ukládá do MySQL (pokud je nastavená), jinak do lokálního fallback JSON.

Tipsport skripty

Otevři tiket-arena, F12 → Konzole, vlož jeden skript. Najednou stačí jeden. Druhý zastaví ten předchozí.

1. Jen zachytávání tiketů

Posílá nové tikety z Právě vsazeno. Výsledky nedohledává.

/**
 * Zachytávání nových tiketů. Vložit do konzole na https://www.tipsport.cz/tiket-arena
 */
(() => {
  if (window.__tipsportLive && window.__tipsportLive.stop) {
    window.__tipsportLive.stop();
  }

  const RECENT_URL = "https://www.tipsport.cz/rest/betting/v1/tickets/recent-tickets?limit=20";
  const DETAIL_URL = "https://www.tipsport.cz/rest/betting/v7/tickets/";
  const ENDPOINT = "https://www.onlinetipy.cz/api/arena-tickets";
  const TOKEN = "onlinetipy-arena-live";
  const WAIT_MS = 3000;
  const TIMEOUT_MS = 5000;
  const BACKOFF_429_MS = 20000;
  const DETAIL_GAP_MS = 400;

  const seen = new Map();
  const sent = new Set();
  let stopped = false;
  let primed = false;
  let timer = null;

  const sleep = (ms) => new Promise((resolve) => setTimeout(resolve, ms));

  const ticketIds = (ticket) =>
    (ticket.ticketLink && ticket.ticketLink.ticketId)
    || (ticket.link && { idu: ticket.link.idu, idb: ticket.link.idb, hash: ticket.link.hash })
    || null;

  const ticketKey = (ticket) => {
    const ids = ticketIds(ticket);
    if (ids && ids.idu != null && ids.hash) {
      return String(ids.idu) + ":" + String(ids.hash);
    }
    return (ticket.ticketLink && ticket.ticketLink.url) || "";
  };

  const fetchJson = async (url) => {
    const controller = new AbortController();
    const timeout = setTimeout(() => controller.abort(), TIMEOUT_MS);
    try {
      const response = await fetch(url, {
        credentials: "include",
        signal: controller.signal,
      });
      if (!response.ok) {
        const error = new Error("HTTP " + response.status);
        error.status = response.status;
        throw error;
      }
      const text = await response.text();
      return text ? JSON.parse(text) : null;
    } finally {
      clearTimeout(timeout);
    }
  };

  const loadDetail = async (ticket) => {
    const ids = ticketIds(ticket);
    if (!ids) {
      return null;
    }
    const detail = await fetchJson(
      DETAIL_URL + ids.idb + "/" + ids.idu + "?hash=" + encodeURIComponent(ids.hash),
    );
    await sleep(DETAIL_GAP_MS);
    return detail;
  };

  const toRow = (ticket, detail) => ({
    id: ticket.ticketArenaId || (ticketIds(ticket) && ticketIds(ticket).idu),
    url: (ticket.ticketLink && ticket.ticketLink.url) || (ticket.link && ticket.link.linkAddress) || "",
    type: ticket.typeName || ticket.type,
    odd: ticket.totalOdd,
    stake: ticket.amountPaid && ticket.amountPaid.amount,
    win: ticket.potentialWin && ticket.potentialWin.amount,
    user: ticket.avatar && ticket.avatar.username,
    match: ticket.summary && ticket.summary.matchName,
    seenAt: new Date().toISOString(),
    detail: detail || null,
  });

  const send = async (tickets) => {
    const controller = new AbortController();
    const timeout = setTimeout(() => controller.abort(), TIMEOUT_MS);
    try {
      const response = await fetch(ENDPOINT, {
        method: "POST",
        headers: { "Content-Type": "application/json" },
        body: JSON.stringify({ token: TOKEN, tickets }),
        signal: controller.signal,
      });
      if (!response.ok) {
        const error = new Error("POST HTTP " + response.status);
        error.status = response.status;
        throw error;
      }
      const text = await response.text();
      return text ? JSON.parse(text) : null;
    } finally {
      clearTimeout(timeout);
    }
  };

  const schedule = (delay) => {
    if (stopped) {
      return;
    }
    timer = setTimeout(() => tick().catch(console.log), delay);
  };

  const tick = async () => {
    if (stopped) {
      return;
    }

    let nextWait = WAIT_MS;
    try {
      const data = await fetchJson(RECENT_URL);
      const tickets = data && data.tickets ? data.tickets : [];

      if (!primed) {
        tickets.forEach((ticket) => {
          const key = ticketKey(ticket);
          if (!key) {
            return;
          }
          sent.add(key);
          seen.set(key, toRow(ticket, null));
        });
        primed = true;
        console.log("Baseline:", sent.size, "tiketů. Další nové už pošlu i s detailem.");
        schedule(nextWait);
        return;
      }

      const pending = [];
      for (const ticket of tickets) {
        const key = ticketKey(ticket);
        if (!key || sent.has(key)) {
          continue;
        }

        let row = seen.get(key);
        if (!row) {
          let detail = null;
          try {
            detail = await loadDetail(ticket);
          } catch (error) {
            if (error.status === 429 || error.status === 403) {
              throw error;
            }
            console.warn("Detail selhal, posílám souhrn:", error.message || error);
          }
          row = toRow(ticket, detail);
          if (!row.url) {
            continue;
          }
          seen.set(key, row);
          console.log("NOVY TIKET", seen.size, (row.stake || "?") + " Kč", row.url);
        }
        pending.push({ key, row });
      }

      if (pending.length) {
        await send(pending.map((item) => item.row));
        pending.forEach((item) => sent.add(item.key));
        console.log("Odesláno:", pending.length, "Zachyceno:", sent.size);
      } else {
        console.log("Zachyceno celkem:", sent.size);
      }
    } catch (error) {
      if (error.name === "AbortError") {
        console.warn("TIMEOUT > " + TIMEOUT_MS / 1000 + " s");
      } else if (error.status === 429 || error.status === 403) {
        nextWait = BACKOFF_429_MS;
        console.warn("Tipsport " + error.status + ", čekám " + BACKOFF_429_MS / 1000 + " s");
      } else {
        console.warn("Chyba:", error.message || error);
      }
    }

    schedule(nextWait);
  };

  tick();
  window.__tipsportLive = {
    stop: () => {
      stopped = true;
      clearTimeout(timer);
      console.log("Zastaveno.");
    },
    urls: () => [...seen.values()].map((item) => item.url),
    pending: () => [...seen.keys()].filter((key) => !sent.has(key)),
  };
  console.log("Běží zachytávání. Stop: __tipsportLive.stop()");
})();

2. Zachytávání + načítání výsledků

To samé jako první skript a navíc průběžně dohledává výsledky otevřených tiketů (asi 15 za pár sekund). Tab musí zůstat otevřený.

/**
 * Jeden skript do konzole na https://www.tipsport.cz/tiket-arena
 */
(() => {
  if (window.__tipsportLive && window.__tipsportLive.stop) {
    window.__tipsportLive.stop();
  }

  const RECENT_URL = "https://www.tipsport.cz/rest/betting/v1/tickets/recent-tickets?limit=20";
  const DETAIL_URL = "https://www.tipsport.cz/rest/betting/v7/tickets/";
  const ENDPOINT = "https://www.onlinetipy.cz/api/arena-tickets";
  const TOKEN = "onlinetipy-arena-live";
  const PENDING_URL = ENDPOINT + "/pending?token=" + encodeURIComponent(TOKEN);
  const WAIT_MS = 3000;
  const DRAIN_MS = 800;
  const TIMEOUT_MS = 5000;
  const BACKOFF_429_MS = 20000;
  const DETAIL_GAP_MS = 350;
  const REFRESH_COOLDOWN_MS = 12 * 60 * 1000;
  const MAX_REFRESH = 15;

  const seen = new Map();
  const sent = new Set();
  const refreshedAt = new Map();
  let stopped = false;
  let primed = false;
  let timer = null;

  const sleep = (ms) => new Promise((resolve) => setTimeout(resolve, ms));

  const ticketIds = (ticket) =>
    (ticket.ticketLink && ticket.ticketLink.ticketId)
    || (ticket.link && { idu: ticket.link.idu, idb: ticket.link.idb, hash: ticket.link.hash })
    || null;

  const ticketKey = (ticket) => {
    const ids = ticketIds(ticket);
    if (ids && ids.idu != null && ids.hash) {
      return String(ids.idu) + ":" + String(ids.hash);
    }
    return (ticket.ticketLink && ticket.ticketLink.url) || "";
  };

  const fetchJson = async (url) => {
    const controller = new AbortController();
    const timeout = setTimeout(() => controller.abort(), TIMEOUT_MS);
    try {
      const response = await fetch(url, {
        credentials: "include",
        signal: controller.signal,
      });
      if (!response.ok) {
        const error = new Error("HTTP " + response.status);
        error.status = response.status;
        throw error;
      }
      const text = await response.text();
      return text ? JSON.parse(text) : null;
    } finally {
      clearTimeout(timeout);
    }
  };

  const loadDetail = async (ticket) => {
    const ids = ticketIds(ticket);
    if (!ids) {
      return null;
    }
    const detail = await fetchJson(
      DETAIL_URL + ids.idb + "/" + ids.idu + "?hash=" + encodeURIComponent(ids.hash),
    );
    await sleep(DETAIL_GAP_MS);
    return detail;
  };

  const ticketFromIds = (item) => ({
    ticketLink: {
      url: item.url,
      ticketId: { idu: item.idu, idb: item.idb, hash: item.hash },
    },
    link: { idu: item.idu, idb: item.idb, hash: item.hash, linkAddress: item.url },
  });

  const toRow = (ticket, detail) => ({
    id: ticket.ticketArenaId || (ticketIds(ticket) && ticketIds(ticket).idu),
    url: (ticket.ticketLink && ticket.ticketLink.url) || (ticket.link && ticket.link.linkAddress) || "",
    type: ticket.typeName || ticket.type,
    odd: ticket.totalOdd,
    stake: ticket.amountPaid && ticket.amountPaid.amount,
    win: ticket.potentialWin && ticket.potentialWin.amount,
    user: ticket.avatar && ticket.avatar.username,
    match: ticket.summary && ticket.summary.matchName,
    seenAt: new Date().toISOString(),
    detail: detail || null,
  });

  const send = async (tickets) => {
    const controller = new AbortController();
    const timeout = setTimeout(() => controller.abort(), TIMEOUT_MS);
    try {
      const response = await fetch(ENDPOINT, {
        method: "POST",
        headers: { "Content-Type": "application/json" },
        body: JSON.stringify({ token: TOKEN, tickets }),
        signal: controller.signal,
      });
      if (!response.ok) {
        const error = new Error("POST HTTP " + response.status);
        error.status = response.status;
        throw error;
      }
      const text = await response.text();
      return text ? JSON.parse(text) : null;
    } finally {
      clearTimeout(timeout);
    }
  };

  const schedule = (delay) => {
    if (stopped) {
      return;
    }
    timer = setTimeout(() => tick().catch(console.log), delay);
  };

  const tick = async () => {
    if (stopped) {
      return;
    }

    let nextWait = WAIT_MS;
    try {
      const data = await fetchJson(RECENT_URL);
      const tickets = data && data.tickets ? data.tickets : [];

      if (!primed) {
        tickets.forEach((ticket) => {
          const key = ticketKey(ticket);
          if (!key) {
            return;
          }
          sent.add(key);
          seen.set(key, toRow(ticket, null));
        });
        primed = true;
        console.log("Baseline:", sent.size, "tiketů. Další nové už pošlu i s detailem.");
        schedule(nextWait);
        return;
      }

      const pending = [];
      for (const ticket of tickets) {
        const key = ticketKey(ticket);
        if (!key || sent.has(key)) {
          continue;
        }

        let row = seen.get(key);
        if (!row) {
          let detail = null;
          try {
            detail = await loadDetail(ticket);
          } catch (error) {
            if (error.status === 429 || error.status === 403) {
              throw error;
            }
            console.warn("Detail selhal, posílám souhrn:", error.message || error);
          }
          row = toRow(ticket, detail);
          if (!row.url) {
            continue;
          }
          seen.set(key, row);
          console.log("NOVY TIKET", seen.size, (row.stake || "?") + " Kč", row.url);
        }
        pending.push({ key, row });
      }

      if (pending.length) {
        await send(pending.map((item) => item.row));
        pending.forEach((item) => sent.add(item.key));
        console.log("Odesláno:", pending.length, "Zachyceno:", sent.size);
      } else {
        console.log("Zachyceno celkem:", sent.size);
      }

      const refreshed = await refreshPending();
      if (refreshed) {
        console.log("Dohledáno výsledků:", refreshed);
        if (refreshed >= MAX_REFRESH) {
          nextWait = DRAIN_MS;
        }
      }
    } catch (error) {
      if (error.name === "AbortError") {
        console.warn("TIMEOUT > " + TIMEOUT_MS / 1000 + " s");
      } else if (error.status === 429 || error.status === 403) {
        nextWait = BACKOFF_429_MS;
        console.warn("Tipsport " + error.status + ", čekám " + BACKOFF_429_MS / 1000 + " s");
      } else {
        console.warn("Chyba:", error.message || error);
      }
    }

    schedule(nextWait);
  };

  const refreshPending = async () => {
    const response = await fetch(PENDING_URL, { method: "GET" });
    if (!response.ok) {
      throw new Error("PENDING HTTP " + response.status);
    }
    const data = await response.json();
    const tickets = (data && data.pending) || [];
    const now = Date.now();
    const due = tickets
      .filter((ticket) => ticket.url && (!refreshedAt.has(ticket.url) || now - refreshedAt.get(ticket.url) >= REFRESH_COOLDOWN_MS))
      .slice(0, MAX_REFRESH);

    if (!due.length) {
      return 0;
    }

    const rows = [];
    for (const ticket of due) {
      refreshedAt.set(ticket.url, now);
      try {
        const detail = await loadDetail(ticketFromIds(ticket));
        if (detail) {
          rows.push(toRow(ticketFromIds(ticket), detail));
        }
      } catch (error) {
        if (error.status === 429 || error.status === 403) {
          throw error;
        }
        console.warn("Refresh detail selhal:", ticket.url, error.message || error);
      }
    }

    if (rows.length) {
      await send(rows);
    }
    return rows.length;
  };

  tick();
  window.__tipsportLive = {
    stop: () => {
      stopped = true;
      clearTimeout(timer);
      console.log("Zastaveno.");
    },
    urls: () => [...seen.values()].map((item) => item.url),
    pending: () => [...seen.keys()].filter((key) => !sent.has(key)),
  };
  console.log("Běží. Stop: __tipsportLive.stop()");
})();