تسک‌ها، استخراج ورودی و Apps در MCP

service = TaskService(directory)       # TaskStore مبتنی بر فایل
created = service.dispatch(make_request(1, "tools/call",
    {"name": "generate_report", "arguments": {"size": "large"}}))
task_id = created["result"]["taskId"]  # resultType task، working
service = TaskService(directory)       # نمونه جدید آن را بازخوانی می‌کند
service.advance_worker(task_id)        # working به input_required
service.dispatch(make_request(3, "tasks/get", {"taskId": task_id}))
service.dispatch(make_request(4, "tasks/update", {"taskId": task_id,
    "inputResponses": {"approve_outline": {"action": "accept",
                                           "content": {"approved": True}}}}))
service.advance_worker(task_id)        # مرحله 2 به completed
body, headers = make_http_request(5, "tasks/get", {"taskId": task_id})
headers["Mcp-Name"]                    # برابر با params.taskId

ledger = MutationLedger(Path(directory) / "mutations.sqlite3")
ledger.charge("acct-7", 1200, rpc_id=41, idempotency_key="checkout-7")
ledger.charge("acct-7", 1200, rpc_id=42, idempotency_key="checkout-7")
ledger.executions                                       # یک اجرا، همان رسید
classify_retry(side_effect=True, idempotency_key=None)  # ناامن
buffer = BoundedSseBuffer(3)                            # ظرفیت حداقل دو مورد
buffer.push_final(response)                             # پاسخ نهایی هرگز دور ریخته نمی‌شود
reconnect_plan(previous_subscription_id, affected_resources,
               unsafe_mutation_was_in_flight=True)      # sendLastEventId معادل False
retry_delay_ms("<client>", attempt)                     # محدود به 8000 میلی‌ثانیه