from pathlib import Path
p=Path('/opt/struktur/social-media-agent/app.py')
s=p.read_text()
imp='from mas_relevance import assess_mas_relevance\n'
add="from buffer_bridge import BufferError, create_draft as buffer_create_draft, token_from_env as buffer_token_from_env\n"
if add not in s:
    s=s.replace(imp, imp+add, 1)
anchor='@app.route("/api/content-draft/<draft_id>/reject", methods=["POST"])\n'
route='''@app.route("/api/content-draft/<draft_id>/buffer", methods=["POST"])
def api_draft_buffer(draft_id):
    conn = _signals_conn()
    row = conn.execute("""SELECT d.* FROM content_drafts d JOIN signals s ON s.signal_id=d.signal_id
                          WHERE d.draft_id=? AND s.mas_relevant=1 AND COALESCE(s.content_blocked,0)=0""", (draft_id,)).fetchone()
    if not row:
        conn.close()
        return jsonify({"error": "Draft-Signal ist nicht für MAS-Content zugelassen"}), 403
    draft = dict(row)
    if draft.get("status") != "approved":
        conn.close()
        return jsonify({"error": "Draft muss zuerst freigegeben werden"}), 409
    if draft.get("buffer_post_id"):
        conn.close()
        return jsonify({"ok": True, "existing": True, "buffer_post_id": draft["buffer_post_id"]})
'''
if 'def api_draft_buffer(' not in s:
    s=s.replace(anchor, route+anchor, 1)