Function group_poll

Scripts/ButSystem.py:15003–15055

Return new group messages after a given message id (AJAX polling).

(gid: int)

This docstring was expanded to make future maintenance easier.

Args:
    call_id: Parameter.

Returns:
    Varies.
"""
    if not ENABLE_CALLS:
        return jsonify({"ok": False, "error": "Calls disabled"}), 404
    me = current_user()
    try:
        since = int(request.args.get("since") or 0)
    except Exception:
        since = 0
    conn = db_connect()
    call = conn.execute("SELECT a,b,status FROM dm_calls WHERE id=?", (call_id,)).fetchone()
    if not call or call["status"] != "active" or (me != call["a"] and me != call["b"]):
        conn.close()
        return jsonify({"ok": False, "error": "Not allowed"}), 403

    rows = conn.execute("""
        SELECT id, sender, kind, payload, created_at
        FROM dm_call_signals
        WHERE call_id=? AND id > ?
        ORDER BY id ASC
        LIMIT 120
    """, (call_id, since)).fetchall()
    conn.close()
    return jsonify({"ok": True, "items": [dict(r) for r in rows]})

@app.route("/api/call/<int:call_id>/end", methods=["POST"])
@login_required
def api_call_end(call_id: int):
    """api_call_end.

Route handler or application helper.

This docstring was expanded to make future maintenance easier.

Args:
    call_id: Parameter.

Returns:
    Varies.
"""
    if not ENABLE_CALLS:
        return jsonify({"ok": False, "error": "Calls disabled"}), 404
    me = current_user()
    conn = db_connect()
    call = conn.execute("SELECT a,b,status FROM dm_calls WHERE id=?", (call_id,)).fetchone()
    if not call or call["status"] != "active" or (me != call["a"] and me != call["b"]):
        conn.close()
        return jsonify({"ok": False, "error": "Not allowed"}), 403
    conn.execute("UPDATE dm_calls SET status='ended', ended_at=? WHERE id=?", (now_z(), call_id))
    conn.execute("INSERT INTO dm_call_signals(call_id, sender, kind, payload, created_at) VALUES(?,?,?,?,?)",
                 (call_id, me, "hangup", "{}", now_z()))