How do I search TikTok and YouTube by what happens in a video?

// npm i @modelcontextprotocol/sdk   (Node 24+ runs .ts files directly)   env: UPROCK_API_KEY// node moments.ts "snorkeling with sea turtles"              best moment per video// node moments.ts "snorkeling with sea turtles" 2026-01-01   published since then, newest firstimport { Client } from "@modelcontextprotocol/sdk/client/index.js";import { StreamableHTTPClientTransport } from "@modelcontextprotocol/sdk/client/streamableHttp.js";​// One video_search result: a moment from t0 to t1 (seconds) in one public video.type Moment = {  url: string;  t0: number;  t1: number;  score: number;  title: string;  transcript: string;  source: string; // "youtube", "tiktok" or "instagram"  published_at: number; // unix seconds};​type SearchOptions = {  since?: Date; // published_after  newestFirst?: boolean; // order_by_recency  everyMoment?: boolean; // unique_videos: false returns several moments per video};​const uprock = new Client({ name: "video-moments", version: "1.0.0" });await uprock.connect(  new StreamableHTTPClientTransport(    new URL("https://mcp.uprock.ai/mcp"),    { requestInit: { headers: { Authorization: `Bearer ${process.env.UPROCK_API_KEY}` } } },  ),);​export async function searchMoments(query: string, opts: SearchOptions = {}) {  const args: Record<string, unknown> = {    query,    unique_videos: !opts.everyMoment,    order_by_recency: opts.newestFirst ?? false,  };  if (opts.since) args.published_after = Math.floor(opts.since.getTime() / 1000);  const res = await uprock.callTool({ name: "video_search", arguments: args });  const text =    (res.content as { type: string; text?: string }[]).find((c) => c.type === "text")      ?.text ?? "";  if (res.isError) throw new Error(`UpRock: ${text}`);  return (JSON.parse(text).results ?? []) as Moment[];}​// YouTube links can start at a second. TikTok and Instagram document no such// parameter, so their links open the post and the time is printed next to them.export function linkToMoment(m: Moment) {  const url = new URL(m.url);  if (/(^|\.)youtube\.com$|^youtu\.be$/.test(url.hostname)) {    url.searchParams.set("t", `${Math.floor(m.t0)}s`);  }  return url.toString();}​function clock(seconds: number) {  const s = Math.floor(seconds);  const [h, m, sec] = [Math.floor(s / 3600), Math.floor((s % 3600) / 60), s % 60];  const mmss = `${h ? String(m).padStart(2, "0") : m}:${String(sec).padStart(2, "0")}`;  return h ? `${h}:${mmss}` : mmss;}​const [query = "snorkeling with sea turtles", since] = process.argv.slice(2);try {  const moments = await searchMoments(    query,    since ? { since: new Date(since), newestFirst: true } : {},  );  for (const m of moments) {    const when = `${clock(m.t0)}-${clock(m.t1)}`;    console.log(      `${m.score.toFixed(3)}  ${m.source.padEnd(9)} ${when.padEnd(13)} ${m.title.slice(0, 50)}`,    );    console.log(`       ${linkToMoment(m)}`);  }} finally {  await uprock.close();}

# pip install "mcp>=2.3"   env: UPROCK_API_KEY# python moments.py "snorkeling with sea turtles"              best moment per video# python moments.py "snorkeling with sea turtles" 2026-01-01   published since then, newest firstimport asyncioimport calendarimport jsonimport osimport sysfrom datetime import datefrom urllib.parse import parse_qsl, urlencode, urlsplit, urlunsplit​import httpx2from mcp import Clientfrom mcp.client.streamable_http import streamable_http_client​# The key goes in an Authorization header, set on the HTTP client the MCP client uses.UPROCK = "https://mcp.uprock.ai/mcp"HEADERS = {"Authorization": f"Bearer {os.environ['UPROCK_API_KEY']}"}YOUTUBE = {"youtube.com", "www.youtube.com", "m.youtube.com", "youtu.be"}​​async def search_moments(    client: Client,    query: str,    since: date | None = None,    newest_first: bool = False,    every_moment: bool = False,) -> list[dict]:    args = {        "query": query,        "unique_videos": not every_moment,  # False: several moments per video        "order_by_recency": newest_first,    }    if since:        args["published_after"] = calendar.timegm(since.timetuple())  # midnight UTC    res = await client.call_tool("video_search", args)    text = next((c.text for c in res.content if c.type == "text"), "")    if res.is_error:        raise RuntimeError(f"UpRock: {text}")    return json.loads(text).get("results", [])​​def link_to_moment(m: dict) -> str:    """YouTube links can start at a second; TikTok and Instagram document no such    parameter, so their links open the post and the time is printed next to them."""    parts = urlsplit(m["url"])    if parts.hostname in YOUTUBE:        params = dict(parse_qsl(parts.query)) | {"t": f"{int(m['t0'])}s"}        parts = parts._replace(query=urlencode(params))    return urlunsplit(parts)​​def clock(seconds: float) -> str:    h, rest = divmod(int(seconds), 3600)    m, s = divmod(rest, 60)    return f"{h}:{m:02}:{s:02}" if h else f"{m}:{s:02}"​​async def main() -> None:    query = sys.argv[1] if len(sys.argv) > 1 else "snorkeling with sea turtles"    since = date.fromisoformat(sys.argv[2]) if len(sys.argv) > 2 else None    async with (        httpx2.AsyncClient(headers=HEADERS, timeout=httpx2.Timeout(30, read=300)) as http,        Client(streamable_http_client(UPROCK, http_client=http)) as client,    ):        moments = await search_moments(client, query, since, newest_first=bool(since))    for m in moments:        when = f"{clock(m['t0'])}-{clock(m['t1'])}"        print(f"{m['score']:.3f}  {m['source']:<9} {when:<13} {m['title'][:50]}")        print(f"       {link_to_moment(m)}")​​asyncio.run(main())