यह गाइड Synapse का उपयोग करके एक ऐसे LLM एजेंट को बनाने की प्रक्रिया बताती है जो सत्रों में संदर्भ परसिस्ट करता है। अंत तक, आपका एजेंट:
\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└──────────────┘# Register and get 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# Create mind and get 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. Recall all memories\n r = requests.get(\n f"{URL}/memory/recall",\n headers={"Authorization": f"Bearer {MIND_KEY}"}\n )\n memories = r.text # plain text summary\n \n # 2. Check for unread chat messages\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. Check in-progress tasks\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# Build system prompt with this contextजब भी एजेंट कुछ याद रखने योग्य सीखे:
\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# Examples\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# Multi-session workflow\ntask_id = create_task("Deploy v1.6.0", "Push docs system to production", "high")\nupdate_task(task_id, status="in_progress")\n# ... work across multiple sessions ...\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# Main loop\nwhile working:\n # Poll for human messages\n for msg in poll_messages():\n print(f"Human: {msg['content']}")\n reply(f"Got it: {msg['content']}. Working on it.")\n \n # Do one unit of work\n do_work()\n \n time.sleep(30) # don't poll too frequentlyसत्र समाप्त होने पर, अंतिम संदर्भ स्टोर करें:
\ndef session_end():\n """Call this before terminating the session."""\n # Store what we accomplished\n remember("context", "last_session_summary",\n f"Session ended at {time.now()}. Accomplished: ...",\n tags=["session"], priority="normal")\n \n # Update task statuses\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. Recall context\n context = self.session_start()\n \n # 2. Process unread messages\n for msg in context["unread_messages"]:\n self.handle_message(msg)\n \n # 3. Resume active tasks\n for task in context["active_tasks"]:\n self.continue_task(task)\n \n # 4. Do new work\n self.do_work()\n \n # 5. Persist state\n self.session_end()