自由式の書き方

lambda: states.phase == 1

lambda: [msg for msg in values.history[-10:] if msg.role in ['assistant', 'user']] + [msg for msg in values.history[:-10] if msg.role == 'user']

lambda: (datetime.now() - datetime.fromtimestamp(states.start_timestamp)) >= timedelta(minutes=10)

async def process(input_msg, output_msg):
    history = await input_msg.dialog.get_recent(limit=10)
    result = process_history(history)
    await output_msg.update("result", result, is_last=True)

async def wait_for_completion(input_msg, output_msg):
    async for update in input_msg.updated():
        # 更新を処理
        if input_msg.is_last():
            break
    await output_msg.update("result", result, is_last=True)

values.name          # ドットアクセス
values.count         # ドットアクセス
values.history       # リストや辞書もドットアクセス

input_msg.values.name.x        # ドットアクセス（.xで値を取得）
input_msg.values.count.x       # ドットアクセス
input_msg.values.history.x     # リストや辞書もドットアクセス

states.phase                    # ドットアクセス
states.conversation.count       # 階層的なドットアクセス
states.get('key')               # 未定義の場合は、`None`が返る

async def process(input_msg, output_msg):
    # statesに新しい変数を追加・更新
    await input_msg.state.update_state({
        "user.name": "Alice",           # 新しい変数を追加
        "conversation.count": 5,        # 既存の変数を更新
        "settings.theme": "dark"        # ネストした変数も可能
    })

    await output_msg.update("result", "done", is_last=True)

# phaseが変化したかどうかを判定
lambda: prev_states and prev_states.conversation.phase != states.conversation.phase

dialog.get_recent(limit=10)     # メソッド呼び出し（事前実行される）
dialog.get(index=-1, role="user")  # メソッド呼び出し

# 読み取り
await input_msg.dialog.get_recent(limit=10)  # input_msg経由で非同期アクセス
await input_msg.dialog.get(index=-1, role="user")

# 書き込み（会話履歴にエントリを追加）
entry = DialogEntry(role="assistant", text="こんにちは")
step = await input_msg.dialog.add_entry(entry)  # 会話履歴に追加

# metaを含めた書き込み
entry = DialogEntry(
    role="system",
    text="これはシステムメッセージです",
    meta={"source": "tool", "timestamp": 1234567890}
)
await input_msg.dialog.add_entry(entry)

truncate(text, max_tokens, position='middle')

lambda: truncate(states.user.prompt, 100, position='middle')

count_tokens(text)

async def my_func(input_message, output_message):
    # buffer は realtime モードで自動的に提供される辞書
    # 初回呼び出し時に初期化
    if 'count' not in buffer:
        buffer['count'] = 0
        buffer['prev_text'] = ""

    # 状態を更新
    buffer['count'] += 1

    # 処理...

# StateSetChain: 値が空の場合は状態更新をスキップ
{
  "user.name": "lambda: values.name if values.name else Skip()"
}

# EventResponseChain: 条件に合致しない場合は送信をスキップ
{
  "message": "lambda: values.text if values.enabled else Skip()"
}

# ClassifierChain (realtime): 【】が閉じるまで待機
async def get_text_when_ready(input_msg, output_msg):
    text = input_msg.values.response.x or ''

    # 【】が閉じていない場合はContinue()
    if '【' in text and '】' not in text:
        return Continue()

    # 【】が閉じている場合、xxxを抽出
    import re
    match = re.search(r'【(.+?)】', text)
    return match.group(1) if match else text

# ClassifierChain (realtime): 終了マーカーでループ終了
async def get_text_with_end_marker(input_msg, output_msg):
    text = input_msg.values.response.x or ''

    # 終了マーカーがある場合はループを終了
    if '[END]' in text:
        return Break()

    return text