Function group_send

Scripts/ButSystem.py:14887–14996

Send a group message (text and/or voice) without forcing a page refresh when called via AJAX. Stability: - Commit the group message + voice attachment atomically (single transaction) so polling clients never see a blank placeholder voice row.

(gid: int)

    conn.commit()
    conn.close()
    return jsonify({"ok": True})

# ---------------------------
# Video call signaling (WebRTC)
# ---------------------------

@app.route("/api/call/start/<peer>", methods=["POST"])
@login_required
def api_call_start(peer: str):
    """api_call_start.

Route handler or application helper.

This docstring was expanded to make future maintenance easier.

Args:
    peer: Parameter.

Returns:
    Varies.
"""
    if not ENABLE_CALLS:
        return jsonify({"ok": False, "error": "Calls disabled"}), 404
    me = current_user()
    peer = peer.strip()
    if peer == me:
        return jsonify({"ok": False, "error": "Invalid peer"}), 400
    conn = db_connect()
    exists = conn.execute("SELECT 1 FROM users WHERE username=?", (peer,)).fetchone()
    if not exists:
        conn.close()
        return jsonify({"ok": False, "error": "User not found"}), 404

    # Reuse any active call between the two users
    row = conn.execute("""
        SELECT id FROM dm_calls
        WHERE status='active' AND ((a=? AND b=?) OR (a=? AND b=?))
        ORDER BY id DESC LIMIT 1
    """, (me, peer, peer, me)).fetchone()
    if row:
        call_id = row["id"]
    else:
        cur = conn.cursor()
        cur.execute("INSERT INTO dm_calls(a,b,status,created_at) VALUES(?,?, 'active', ?)", (me, peer, now_z()))
        call_id = cur.lastrowid
        conn.commit()
    conn.close()
    return jsonify({"ok": True, "call_id": call_id})

@app.route("/api/call/peek/<peer>")
@login_required
def api_call_peek(peer: str):
    """If there is an active call between me and peer, return call_id (used to start polling)."""
    if not ENABLE_CALLS:
        return jsonify({"ok": False, "error": "Calls disabled"}), 404
    me = current_user()
    peer = peer.strip()
    conn = db_connect()