Function _discussion_store_remote_gif_tx

Scripts/ButSystem.py:12555–12626

Download and store a remote GIF/clip for discussion within an existing DB transaction.

(conn, msg_id: int, gif_url: str)

    chunk = request.files.get("chunk")
    if not re.fullmatch(r"[A-Za-z0-9_-]{20,128}", upload_id or "") or chunk is None: return jsonify({"ok": False, "error": "bad_request"}), 400
    meta_path = _upload_meta_path(upload_id)
    with UPLOAD_LOCK:
        try: meta = json.loads(open(meta_path, "r", encoding="utf-8").read())
        except Exception: return jsonify({"ok": False, "error": "not_found"}), 404
        if meta.get("u") != current_user(): return jsonify({"ok": False, "error": "forbidden"}), 403
        if total != int(meta.get("total_chunks") or 0) or idx != int(meta.get("received") or 0): return jsonify({"ok": False, "error": "out_of_order", "expected": int(meta.get("received") or 0)}), 409
        tmp_path = _upload_tmp_path(upload_id); mode = "ab" if os.path.exists(tmp_path) else "wb"
        with open(tmp_path, mode) as out: shutil.copyfileobj(chunk.stream, out, length=8 * 1024 * 1024)
        written = os.path.getsize(tmp_path)
        if written > int(meta.get("total_size") or 0) or written > FILES_MAX_BYTES or not _disk_allows_upload(os.path.dirname(meta["destination"]), int(meta["total_size"]), written):
            for fp in (tmp_path, meta_path):
                try: os.remove(fp)
                except Exception: pass
            return jsonify({"ok": False, "error": "storage_or_size"}), 507
        meta["received"] = idx + 1
        temp_meta = meta_path + ".tmp"
        with open(temp_meta, "w", encoding="utf-8") as fh: json.dump(meta, fh)
        os.replace(temp_meta, meta_path)
        done = meta["received"] >= total
        if done:
            if written != int(meta.get("total_size") or 0): return jsonify({"ok": False, "error": "size_mismatch"}), 400
            destination = meta["destination"]
            if os.path.exists(destination) and not meta.get("replace"):
                destination = _unique_destination(os.path.dirname(destination), os.path.basename(destination))
            os.replace(tmp_path, destination); os.remove(meta_path)
            item_rel = os.path.relpath(destination, user_root(current_user())).replace(os.sep, "/")
            _log_file_activity(current_user(), "file_uploaded", item_rel, human_size(written))
        return jsonify({"ok": True, "done": done, "received": meta["received"], "total": total})


@app.route("/files/rename", methods=["GET", "POST"])
@login_required
def file_rename():
    rel = request.values.get("p", "") or ""
    try:
        rel = safe_relpath(rel); source = abs_user_path(current_user(), rel)
        if not rel or not os.path.exists(source): raise ValueError
    except Exception: abort(404)
    parent = "/".join(rel.split("/")[:-1])
    if request.method == "POST":
        try:
            new_name = _validate_entry_name(request.form.get("new_name", "")); destination = os.path.join(os.path.dirname(source), new_name)
            if os.path.exists(destination): raise FileExistsError
            os.rename(source, destination); new_rel = safe_relpath(f"{parent}/{new_name}" if parent else new_name); _remap_file_metadata(current_user(), rel, new_rel); _log_file_activity(current_user(), "entry_renamed", new_rel, f"from /{rel}"); flash("Entry renamed."); return redirect(url_for("files", p=parent))
        except FileExistsError: flash("An entry with that name already exists.")
        except Exception: flash("Rename failed.")
    return render_template("file_rename.html", relpath=rel, parent_relpath=parent, name=os.path.basename(source))


@app.route("/files/move", methods=["GET", "POST"])
@login_required
def file_move():
    rel = request.values.get("p", "") or ""
    try:
        rel = safe_relpath(rel); source = abs_user_path(current_user(), rel)
        if not rel or not os.path.exists(source): raise ValueError
    except Exception: abort(404)
    parent = "/".join(rel.split("/")[:-1])