Function dm_send

Scripts/ButSystem.py:13439–13594

Send a DM message (text, file, GIF, and/or voice). Important stability notes: - The message and its attachments are committed atomically (single DB transaction), so other clients never see a "blank" placeholder that requires refresh. - AJAX returns a fully-rendered row for i

(username: str)

    cur.execute(
        "INSERT INTO discussion_files(msg_id, filename, mime, stored_path, size, created_at) VALUES(?,?,?,?,?,?)",
        (msg_id, "gif.gif", "image/gif", "PENDING", 0, now_z()),
    )
    fid = cur.lastrowid
    stored_path = os.path.join(DISC_FILES_DIR, f"discussion_file_{fid}.bin")

    max_bytes = CHAT_MAX_BYTES  # 33 MB
    size = 0
    mime = "image/gif"
    filename = "gif.gif"

    req = urllib.request.Request(
        gif_url,
        headers={
            "User-Agent": "ButSystem/1.0 (+https://example.invalid)",
            "Accept": "image/gif,image/*,video/*,*/*;q=0.8",
        },
        method="GET",
    )
    with _safe_urlopen(req, timeout=12) as resp:
        ctype = (resp.headers.get("Content-Type") or "").split(";")[0].strip().lower()
        if ctype:
            mime = ctype
        if not (mime == "image/gif" or mime.startswith("video/")):
            path = (u.path or "").lower()
            if not (path.endswith(".gif") or path.endswith(".mp4") or path.endswith(".webm")):
                raise ValueError(f"Unsupported GIF mime: {mime}")
            if path.endswith(".mp4"):
                mime = "video/mp4"
            elif path.endswith(".webm"):
                mime = "video/webm"
            else:
                mime = "image/gif"

        if mime == "image/gif":
            filename = f"gif_{fid}.gif"
        elif mime == "video/mp4":
            filename = f"gif_{fid}.mp4"
        elif mime == "video/webm":
            filename = f"gif_{fid}.webm"
        else:
            filename = f"file_{fid}"

        with open(stored_path, "wb") as f:
            while True:
                chunk = resp.read(64 * 1024)
                if not chunk:
                    break
                size += len(chunk)
                if size > max_bytes:
                    raise ValueError("GIF too large")
                f.write(chunk)

    conn.execute(
        "UPDATE discussion_files SET stored_path=?, size=?, mime=?, filename=? WHERE id=?",
        (stored_path, int(size), mime, filename, fid),
    )
    conn.execute("UPDATE discussion_messages SET has_file=1 WHERE id=?", (msg_id,))
    return {"id": fid, "mime": mime, "filename": filename, "size": int(size), "stored_path": stored_path}