Auto-post a Telegram channel to X and Bluesky

import os, requests

BOT = os.environ["TELEGRAM_BOT_TOKEN"]
TG, TG_FILE = f"https://api.telegram.org/bot{BOT}", f"https://api.telegram.org/file/bot{BOT}"
CHANNEL_ID = os.environ.get("TELEGRAM_CHANNEL_ID", "")
OT = "https://opentweet.io/api/v1"
AUTH = {"Authorization": f"Bearer {os.environ['OPENTWEET_API_KEY']}"}
PLATFORMS = ["x", "bluesky"]    # add "linkedin" if you want it there too
LIMIT = 260                     # under X's 280, room for emoji (2) and links (23)
OFFSET_FILE = "telegram_offset.txt"

def split(text):
    parts, cur = [], ""
    for word in text.split(" "):
        if cur and len(cur) + 1 + len(word) > LIMIT:
            parts.append(cur)
            cur = word
        else:
            cur = f"{cur} {word}" if cur else word
    parts.append(cur)
    return parts[:25]           # OpenTweet caps a thread at 25 tweets

def upload_photo(sizes):
    biggest = max(sizes, key=lambda p: p["width"])
    info = requests.get(f"{TG}/getFile", params={"file_id": biggest["file_id"]}, timeout=30).json()
    img = requests.get(f"{TG_FILE}/{info['result']['file_path']}", timeout=60).content
    r = requests.post(f"{OT}/upload", headers=AUTH,
                      files={"file": ("photo.jpg", img, "image/jpeg")}, timeout=120)
    r.raise_for_status()
    return r.json()["url"]

def forward(msg):
    text = (msg.get("text") or msg.get("caption") or "").strip()
    if not text:
        return                  # stickers, polls, uncaptioned album photos
    parts = split(text)
    body = {"text": parts[0], "platforms": PLATFORMS, "publish_now": True}
    if len(parts) > 1:
        body["is_thread"], body["thread_tweets"] = True, parts[1:]
    if msg.get("photo"):
        body["media_urls"] = [upload_photo(msg["photo"])]
    r = requests.post(f"{OT}/posts", headers=AUTH, json=body, timeout=90)
    print(r.status_code, r.text[:300])

offset = int(open(OFFSET_FILE).read()) if os.path.exists(OFFSET_FILE) else 0
while True:
    r = requests.post(f"{TG}/getUpdates", json={
        "offset": offset, "timeout": 50, "allowed_updates": ["channel_post"]}, timeout=60)
    for update in r.json().get("result", []):
        offset = update["update_id"] + 1
        msg = update.get("channel_post")
        if msg and not CHANNEL_ID:
            print("channel id:", msg["chat"]["id"], msg["chat"].get("title"))
        elif msg and str(msg["chat"]["id"]) == CHANNEL_ID:
            try:
                forward(msg)
            except Exception as e:
                print("skipped update", update["update_id"], e)
        with open(OFFSET_FILE, "w") as f:
            f.write(str(offset))

201 {"success":true,"count":1,"posts":[{"id":"...","status":"posted",
  "url":"https://x.com/i/status/...","platforms":["x","bluesky"],
  "results":[{"platform":"x","status":"published","url":"..."},
             {"platform":"bluesky","status":"published","url":"..."}]}],
  "message":"Post published successfully"}