{"title":"Webhook Automation Guide","slug":"webhook-automation","category":"guides","summary":"","audience":["human"],"tags":[],"word_count":251,"read_minutes":1,"llm_context":"Practical patterns for using Synapse webhooks to automate workflows. Covers logging, summarization, external tool integration, sync to note-taking apps, and monitoring. Events: memory.created, memory.updated, memory.deleted, memory.verified, memory.unverified, task.updated, chat.message_sent.","lang":"en","translated":true,"requested_lang":"en","content_markdown":"# Webhook Automation Guide\n\nPractical patterns for automating workflows with Synapse webhooks.\n\n## Pattern 1: Memory Log\n\nLog every new memory to a file or external service.\n\n### Setup\n\n```python\nfrom flask import Flask, request, jsonify\nimport hashlib, hmac\n\napp = Flask(__name__)\nWEBHOOK_SECRET = 'your-webhook-secret'\n\n@app.route('/webhook', methods=['POST'])\ndef webhook():\n # Verify signature\n sig = request.headers.get('X-Synapse-Signature', '')\n expected = 'sha256=' + hmac.new(WEBHOOK_SECRET.encode(), request.get_data(), hashlib.sha256).hexdigest()\n if not hmac.compare_digest(sig, expected):\n return jsonify({'error': 'invalid signature'}), 401\n\n event = request.headers.get('X-Synapse-Event')\n if event == 'memory.created':\n data = request.get_json()\n with open('memory-log.txt', 'a') as f:\n f.write(f\"{data['event']}: {data['data']['key']} = {data['data']['content'][:100]}\\n\")\n return jsonify({'status': 'ok'}), 200\n return jsonify({'status': 'ignored'}), 200\n```\n\n### Explanation\n\nThe handler listens for `memory.created` events and logs each new memory's key and a content preview to a file. This is useful for auditing, debugging, or creating a secondary backup of important memories.\n\n## Pattern 2: Memory Summary\n\nSummarize new memories using an LLM and store the summary.\n\n### Setup\n\n```python\nfrom flask import Flask, request, jsonify\nimport hashlib, hmac\n\napp = Flask(__name__)\nWEBHOOK_SECRET = 'your-webhook-secret'\n\n@app.route('/webhook', methods=['POST'])\ndef webhook():\n sig = request.headers.get('X-Synapse-Signature', '')\n expected = 'sha256=' + hmac.new(WEBHOOK_SECRET.encode(), request.get_data(), hashlib.sha256).hexdigest()\n if not hmac.compare_digest(sig, expected):\n return jsonify({'error': 'invalid signature'}), 401\n\n event = request.headers.get('X-Synapse-Event')\n if event in ('memory.created', 'memory.updated'):\n data = request.get_json()\n content = data['data']['content']\n # Send to your LLM for summarization\n summary = summarize_with_llm(content) # your function\n store_summary(data['data']['key'], summary)\n return jsonify({'status': 'summarized'}), 200\n return jsonify({'status': 'ignored'}), 200\n```\n\n### Explanation\n\nThis pattern captures both `memory.created` and `memory.updated` events, sends the content to an LLM for summarization, and stores the result. Useful for maintaining a condensed knowledge base.\n\n## Pattern 3: Sync to Note-Taking App\n\nForward new memories to Notion, Obsidian, or similar tools.\n\n### Setup\n\n```python\nfrom flask import Flask, request, jsonify\nimport hashlib, hmac, requests\n\napp = Flask(__name__)\nWEBHOOK_SECRET = 'your-webhook-secret'\nNOTION_API_KEY = 'your-notion-key'\nNOTION_DATABASE_ID = 'your-database-id'\n\n@app.route('/webhook', methods=['POST'])\ndef webhook():\n sig = request.headers.get('X-Synapse-Signature', '')\n expected = 'sha256=' + hmac.new(WEBHOOK_SECRET.encode(), request.get_data(), hashlib.sha256).hexdigest()\n if not hmac.compare_digest(sig, expected):\n return jsonify({'error': 'invalid signature'}), 401\n\n event = request.headers.get('X-Synapse-Event')\n if event == 'memory.created':\n data = request.get_json()\n # Create Notion page\n requests.post('https://api.notion.com/v1/pages', headers={\n 'Authorization': f'Bearer {NOTION_API_KEY}',\n 'Content-Type': 'application/json',\n 'Notion-Version': '2022-06-28',\n }, json={\n 'parent': {'database_id': NOTION_DATABASE_ID},\n 'properties': {\n 'Title': {'title': [{'text': {'content': data['data']['key']}}]},\n 'Content': {'rich_text': [{'text': {'content': data['data']['content'][:2000]}}]},\n 'Category': {'select': {'name': data['data'].get('category', 'note')}},\n },\n })\n return jsonify({'status': 'synced'}), 200\n return jsonify({'status': 'ignored'}), 200\n```\n\n### Explanation\n\nThis pattern forwards each new memory to a Notion database, preserving the key as the title, content as a text property, and category as a select field. Adapt the API call for Obsidian, Logseq, or other tools.\n\n## Pattern 4: Monitoring & Alerting\n\nGet notified when memories are deleted or when tasks fail.\n\n### Setup\n\n```python\nfrom flask import Flask, request, jsonify\nimport hashlib, hmac\n\napp = Flask(__name__)\nWEBHOOK_SECRET = 'your-webhook-secret'\n\n@app.route('/webhook', methods=['POST'])\ndef webhook():\n sig = request.headers.get('X-Synapse-Signature', '')\n expected = 'sha256=' + hmac.new(WEBHOOK_SECRET.encode(), request.get_data(), hashlib.sha256).hexdigest()\n if not hmac.compare_digest(sig, expected):\n return jsonify({'error': 'invalid signature'}), 401\n\n event = request.headers.get('X-Synapse-Event')\n data = request.get_json()\n\n if event == 'memory.deleted':\n send_alert(f\"Memory deleted: {data['data']['key']}\")\n elif event == 'task.updated':\n task_data = data['data']\n if task_data.get('status') == 'failed':\n send_alert(f\"Task failed: {task_data.get('name', 'unknown')}\")\n\n return jsonify({'status': 'ok'}), 200\n\ndef send_alert(message):\n # Send to Slack, Discord, email, etc.\n print(f'ALERT: {message}')\n```\n\n### Explanation\n\nThis pattern monitors for `memory.deleted` and `task.updated` events. When a memory is deleted or a task fails, it triggers an alert. Useful for monitoring and ensuring data integrity.\n\n## Pattern 5: Chat Message Relay\n\nForward chat messages to an external system for logging or analysis.\n\n### Setup\n\n```python\nfrom flask import Flask, request, jsonify\nimport hashlib, hmac\n\napp = Flask(__name__)\nWEBHOOK_SECRET = 'your-webhook-secret'\n\n@app.route('/webhook', methods=['POST'])\ndef webhook():\n sig = request.headers.get('X-Synapse-Signature', '')\n expected = 'sha256=' + hmac.new(WEBHOOK_SECRET.encode(), request.get_data(), hashlib.sha256).hexdigest()\n if not hmac.compare_digest(sig, expected):\n return jsonify({'error': 'invalid signature'}), 401\n\n event = request.headers.get('X-Synapse-Event')\n if event == 'chat.message_sent':\n data = request.get_json()\n # Process chat message\n log_chat_message(data['data'])\n return jsonify({'status': 'ok'}), 200\n return jsonify({'status': 'ignored'}), 200\n```\n\n### Explanation\n\nThis pattern listens for `chat.message_sent` events and forwards them to an external logging or analysis system. Useful for conversation analytics, compliance logging, or integration with CRM systems.\n","content_html":"

Webhook Automation Guide

\n

Practical patterns for automating workflows with Synapse webhooks.

\n

Pattern 1: Memory Log

\n

Log every new memory to a file or external service.

\n

Setup

\n
from flask import Flask, request, jsonify\nimport hashlib, hmac\n\napp = Flask(__name__)\nWEBHOOK_SECRET = 'your-webhook-secret'\n\n@app.route('/webhook', methods=['POST'])\ndef webhook():\n    # Verify signature\n    sig = request.headers.get('X-Synapse-Signature', '')\n    expected = 'sha256=' + hmac.new(WEBHOOK_SECRET.encode(), request.get_data(), hashlib.sha256).hexdigest()\n    if not hmac.compare_digest(sig, expected):\n        return jsonify({'error': 'invalid signature'}), 401\n\n    event = request.headers.get('X-Synapse-Event')\n    if event == 'memory.created':\n        data = request.get_json()\n        with open('memory-log.txt', 'a') as f:\n            f.write(f"{data['event']}: {data['data']['key']} = {data['data']['content'][:100]}\\n")\n        return jsonify({'status': 'ok'}), 200\n    return jsonify({'status': 'ignored'}), 200

Explanation

\n

The handler listens for memory.created events and logs each new memory's key and a content preview to a file. This is useful for auditing, debugging, or creating a secondary backup of important memories.

\n

Pattern 2: Memory Summary

\n

Summarize new memories using an LLM and store the summary.

\n

Setup

\n
from flask import Flask, request, jsonify\nimport hashlib, hmac\n\napp = Flask(__name__)\nWEBHOOK_SECRET = 'your-webhook-secret'\n\n@app.route('/webhook', methods=['POST'])\ndef webhook():\n    sig = request.headers.get('X-Synapse-Signature', '')\n    expected = 'sha256=' + hmac.new(WEBHOOK_SECRET.encode(), request.get_data(), hashlib.sha256).hexdigest()\n    if not hmac.compare_digest(sig, expected):\n        return jsonify({'error': 'invalid signature'}), 401\n\n    event = request.headers.get('X-Synapse-Event')\n    if event in ('memory.created', 'memory.updated'):\n        data = request.get_json()\n        content = data['data']['content']\n        # Send to your LLM for summarization\n        summary = summarize_with_llm(content)  # your function\n        store_summary(data['data']['key'], summary)\n        return jsonify({'status': 'summarized'}), 200\n    return jsonify({'status': 'ignored'}), 200

Explanation

\n

This pattern captures both memory.created and memory.updated events, sends the content to an LLM for summarization, and stores the result. Useful for maintaining a condensed knowledge base.

\n

Pattern 3: Sync to Note-Taking App

\n

Forward new memories to Notion, Obsidian, or similar tools.

\n

Setup

\n
from flask import Flask, request, jsonify\nimport hashlib, hmac, requests\n\napp = Flask(__name__)\nWEBHOOK_SECRET = 'your-webhook-secret'\nNOTION_API_KEY = 'your-notion-key'\nNOTION_DATABASE_ID = 'your-database-id'\n\n@app.route('/webhook', methods=['POST'])\ndef webhook():\n    sig = request.headers.get('X-Synapse-Signature', '')\n    expected = 'sha256=' + hmac.new(WEBHOOK_SECRET.encode(), request.get_data(), hashlib.sha256).hexdigest()\n    if not hmac.compare_digest(sig, expected):\n        return jsonify({'error': 'invalid signature'}), 401\n\n    event = request.headers.get('X-Synapse-Event')\n    if event == 'memory.created':\n        data = request.get_json()\n        # Create Notion page\n        requests.post('https://api.notion.com/v1/pages', headers={\n            'Authorization': f'Bearer {NOTION_API_KEY}',\n            'Content-Type': 'application/json',\n            'Notion-Version': '2022-06-28',\n        }, json={\n            'parent': {'database_id': NOTION_DATABASE_ID},\n            'properties': {\n                'Title': {'title': [{'text': {'content': data['data']['key']}}]},\n                'Content': {'rich_text': [{'text': {'content': data['data']['content'][:2000]}}]},\n                'Category': {'select': {'name': data['data'].get('category', 'note')}},\n            },\n        })\n        return jsonify({'status': 'synced'}), 200\n    return jsonify({'status': 'ignored'}), 200

Explanation

\n

This pattern forwards each new memory to a Notion database, preserving the key as the title, content as a text property, and category as a select field. Adapt the API call for Obsidian, Logseq, or other tools.

\n

Pattern 4: Monitoring & Alerting

\n

Get notified when memories are deleted or when tasks fail.

\n

Setup

\n
from flask import Flask, request, jsonify\nimport hashlib, hmac\n\napp = Flask(__name__)\nWEBHOOK_SECRET = 'your-webhook-secret'\n\n@app.route('/webhook', methods=['POST'])\ndef webhook():\n    sig = request.headers.get('X-Synapse-Signature', '')\n    expected = 'sha256=' + hmac.new(WEBHOOK_SECRET.encode(), request.get_data(), hashlib.sha256).hexdigest()\n    if not hmac.compare_digest(sig, expected):\n        return jsonify({'error': 'invalid signature'}), 401\n\n    event = request.headers.get('X-Synapse-Event')\n    data = request.get_json()\n\n    if event == 'memory.deleted':\n        send_alert(f"Memory deleted: {data['data']['key']}")\n    elif event == 'task.updated':\n        task_data = data['data']\n        if task_data.get('status') == 'failed':\n            send_alert(f"Task failed: {task_data.get('name', 'unknown')}")\n\n    return jsonify({'status': 'ok'}), 200\n\ndef send_alert(message):\n    # Send to Slack, Discord, email, etc.\n    print(f'ALERT: {message}')

Explanation

\n

This pattern monitors for memory.deleted and task.updated events. When a memory is deleted or a task fails, it triggers an alert. Useful for monitoring and ensuring data integrity.

\n

Pattern 5: Chat Message Relay

\n

Forward chat messages to an external system for logging or analysis.

\n

Setup

\n
from flask import Flask, request, jsonify\nimport hashlib, hmac\n\napp = Flask(__name__)\nWEBHOOK_SECRET = 'your-webhook-secret'\n\n@app.route('/webhook', methods=['POST'])\ndef webhook():\n    sig = request.headers.get('X-Synapse-Signature', '')\n    expected = 'sha256=' + hmac.new(WEBHOOK_SECRET.encode(), request.get_data(), hashlib.sha256).hexdigest()\n    if not hmac.compare_digest(sig, expected):\n        return jsonify({'error': 'invalid signature'}), 401\n\n    event = request.headers.get('X-Synapse-Event')\n    if event == 'chat.message_sent':\n        data = request.get_json()\n        # Process chat message\n        log_chat_message(data['data'])\n        return jsonify({'status': 'ok'}), 200\n    return jsonify({'status': 'ignored'}), 200

Explanation

\n

This pattern listens for chat.message_sent events and forwards them to an external logging or analysis system. Useful for conversation analytics, compliance logging, or integration with CRM systems.

\n","urls":{"html":"/docs/guides/webhook-automation","text":"/docs/guides/webhook-automation?format=text","json":"/docs/guides/webhook-automation?format=json","llm":"/docs/guides/webhook-automation?format=llm"},"translations_available":["en","zh","hi","es","fr","ar","pt","ru","ja","de","it","ko","nl","pl","tr","sv","vi","th","id","uk"]}