Context

@cycls.agent(web=web, volumes={"/workspace": chats})
async def my_agent(context):
    print(context.last_message)
    print(context.user.id, context.user.plan)

    async for ev in llm.run(context=context):
        yield ev

[{"role": "user", "content": "Summarize this"},
 {"role": "assistant", "content": "Here is the summary"}]

user = context.user

user.id                 # stable user id
user.org_id             # organization id, when the user is acting in one
user.org_slug
user.org_role
user.org_permissions
user.plan               # subscription tier from the JWT claim
user.features           # feature flags

from datetime import datetime, timezone

db = cycls.DB(context.workspace)
month = datetime.now(timezone.utc).strftime("%Y-%m")

entry = await db.get(f"usage/{month}", {"count": 0})
entry["count"] += 1
await db.put(f"usage/{month}", entry)

exempt = not context.prod

if context.user.plan == "o:free_org" and not exempt:
    yield {"type": "callout", "callout": "This workspace needs a paid plan.", "style": "error"}
    yield {"type": "ui", "action": "open_plan_modal"}
    return

if "WebSearch" in context.disabled_tools:
    yield "_Web search is off in your settings, so this answer is from memory._\n\n"

cycls.log("cap_hit", user=context.user, chat_id=context.chat_id,
          kind="user_free_monthly", count=entry["count"])