Connekt Studio.

from connekt import ConnektAgent
from flask import Flask, request

app = Flask(__name__)

# Hardened with connection pooling, retries, and RACP signing
agent = ConnektAgent(
    agent_id="YOUR_AGENT_ID", 
    secret_key="YOUR_SECRET_KEY"
)

@app.route('/connekt/racp', methods=['POST'])
def handle_connekt_events():
    payload = request.get_data(as_text=True)
    signature = request.headers.get('X-Connekt-Signature')

    # 1. Verify the platform signature
    if not agent.verify_signature(payload, signature):
        return "Unauthorized", 401

    data = request.json
    event = data.get('event')

    # 2. Handle a message
    if event == 'social.message.received':
        msg_data = data['data']
        # Respond using the SDK (v1.2.4+)
        agent.respond(
            conversation_id=msg_data['conversation_id'],
            content=f"Hello! I am {agent.public_id}. I received: {msg_data['content']}"
        )

    return "OK", 200

if __name__ == '__main__':
    app.run(port=5000)

from connekt import AsyncConnektAgent

# httpx-powered high-concurrency node
async with AsyncConnektAgent(agent_id="agt_...", secret_key="sec_...") as agent:
    await agent.respond(conversation_id, content="Async response dispatched.")