يأخذك هذا الدليل خلال بناء وكيل LLM يحفظ السياق عبر\nالجلسات باستخدام Synapse. بنهايته، سيكون وكيلك:
\n┌──────────────┐ recall/store ┌──────────┐\n│ LLM Agent │ ◀──────────────▶ │ Synapse │\n│ (your code) │ │ API │\n└──────────────┘ └──────────┘\n │\n │ poll/reply\n ▼\n┌──────────────┐\n│ Human │ (browser or chat UI)\n└──────────────┘# سجّل واحصل على JWT\nJWT=$(curl -s -X POST https://synapse.schaefer.zone/register \\\n -H "Content-Type: application/json" \\\n -d '{"email":"agent@example.com","password":"secret"}' | jq -r .jwt)\n\n# أنشئ عقلًا واحصل على Mind Key\nMIND_KEY=$(curl -s -X POST https://synapse.schaefer.zone/minds \\\n -H "Authorization: Bearer $JWT" \\\n -H "Content-Type: application/json" \\\n -d '{"name":"persistent-agent","description":"My persistent agent"}' | jq -r .mind_key)\n\necho "Save this: $MIND_KEY"في بداية كل جلسة، استدعِ جميع الذكريات:
\nimport os\nimport requests\n\nMIND_KEY = os.environ["SYNAPSE_MIND_KEY"]\nURL = "https://synapse.schaefer.zone"\n\ndef session_start():\n """Call this at the start of every session."""\n # 1. استدعِ جميع الذكريات\n r = requests.get(\n f"{URL}/memory/recall",\n headers={"Authorization": f"Bearer {MIND_KEY}"}\n )\n memories = r.text # ملخص نصي عادي\n \n # 2. تحقق من رسائل الدردشة غير المقروءة\n r = requests.get(\n f"{URL}/chat/poll",\n headers={"Authorization": f"Bearer {MIND_KEY}"}\n )\n messages = r.json().get("messages", [])\n \n # 3. تحقق من المهام قيد التقدم\n r = requests.get(\n f"{URL}/mind/tasks?status=in_progress",\n headers={"Authorization": f"Bearer {MIND_KEY}"}\n )\n tasks = r.json().get("tasks", [])\n \n return {\n "memories": memories,\n "unread_messages": messages,\n "active_tasks": tasks,\n }\n\ncontext = session_start()\n# ابنِ system prompt بهذا السياقكلما تعلّم الوكيل شيئًا يستحق التذكر:
\ndef remember(category, key, content, tags=None, priority="normal"):\n """Store a memory."""\n requests.post(\n f"{URL}/memory",\n headers={\n "Authorization": f"Bearer {MIND_KEY}",\n "Content-Type": "application/json",\n },\n json={\n "category": category,\n "key": key,\n "content": content,\n "tags": tags or [],\n "priority": priority,\n }\n )\n\n# أمثلة\nremember("identity", "user_name", "User is Michael Schäfer", \n tags=["person"], priority="critical")\nremember("preference", "communication_style", \n "User prefers concise technical responses",\n tags=["communication"])\nremember("project", "current_project", \n "Building Synapse v1.6.0 with docs system",\n tags=["synapse", "docs"], priority="high")\nremember("mistake", "npm_version_bump", \n "Always bump package.json version after changes",\n tags=["npm", "ci"], priority="high")تتبع العمل متعدد الخطوات عبر الجلسات:
\ndef create_task(title, description="", priority="normal"):\n r = requests.post(\n f"{URL}/mind/task",\n headers={"Authorization": f"Bearer {MIND_KEY}",\n "Content-Type": "application/json"},\n json={"title": title, "description": description, "priority": priority}\n )\n return r.json()["id"]\n\ndef update_task(task_id, status=None, description=None):\n payload = {}\n if status: payload["status"] = status\n if description: payload["description"] = description\n requests.put(\n f"{URL}/mind/task/{task_id}",\n headers={"Authorization": f"Bearer {MIND_KEY}",\n "Content-Type": "application/json"},\n json=payload\n )\n\n# سير عمل متعدد الجلسات\ntask_id = create_task("Deploy v1.6.0", "Push docs system to production", "high")\nupdate_task(task_id, status="in_progress")\n# ... عمل عبر عدة جلسات ...\nupdate_task(task_id, status="done")استطلع للرسائل بين استدعاءات الأدوات:
\nimport time\n\ndef poll_messages():\n r = requests.get(\n f"{URL}/chat/poll",\n headers={"Authorization": f"Bearer {MIND_KEY}"}\n )\n return r.json().get("messages", [])\n\ndef reply(content):\n requests.post(\n f"{URL}/chat/reply",\n headers={"Authorization": f"Bearer {MIND_KEY}",\n "Content-Type": "application/json"},\n json={"content": content}\n )\n\n# الحلقة الرئيسية\nwhile working:\n # استطلع لرسائل الإنسان\n for msg in poll_messages():\n print(f"Human: {msg['content']}")\n reply(f"Got it: {msg['content']}. Working on it.")\n \n # نفّذ وحدة عمل واحدة\n do_work()\n \n time.sleep(30) # لا تستطلع بشكل متكرر جدًاعند نهاية الجلسة، خزّن السياق النهائي:
\ndef session_end():\n """Call this before terminating the session."""\n # خزّن ما أنجزناه\n remember("context", "last_session_summary",\n f"Session ended at {time.now()}. Accomplished: ...",\n tags=["session"], priority="normal")\n \n # حدّث حالات المهام\n for task in get_active_tasks():\n if task_in_progress(task):\n update_task(task["id"], description=f"In progress: {current_step}")\n\nsession_end()class PersistentAgent:\n def __init__(self):\n self.mind_key = os.environ["SYNAPSE_MIND_KEY"]\n self.url = "https://synapse.schaefer.zone"\n \n def run(self):\n # 1. استدعِ السياق\n context = self.session_start()\n \n # 2. عالج الرسائل غير المقروءة\n for msg in context["unread_messages"]:\n self.handle_message(msg)\n \n # 3. استأنف المهام النشطة\n for task in context["active_tasks"]:\n self.continue_task(task)\n \n # 4. نفّذ عملًا جديدًا\n self.do_work()\n \n # 5. احفظ الحالة\n self.session_end()