bsiggel/motia-iii
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

feat(webhooks): update EspoCRM webhook configurations to use VMH naming and endpoints

Browse Source
This commit is contained in:
bsiggel
2026-03-02 17:34:17 +00:00
parent bc917bd885
commit cb0e170ee9
3 changed files with 18 additions and 18 deletions
Download Patch File Download Diff File Expand all files Collapse all files

12
steps/espocrm_webhooks/document_create_webhook_api_step.py
View File

@@ -10,13 +10,13 @@ from motia import FlowContext, http, ApiRequest, ApiResponse
config = { config = {
"name": "EspoCRM Document Create Webhook", "name": "VMH Webhook Document Create",
"description": "Empfängt Create-Webhooks von EspoCRM für Document Entities", "description": "Empfängt Create-Webhooks von EspoCRM für Document Entities",
"flows": ["espocrm-documents"], "flows": ["vmh-documents"],
"triggers": [ "triggers": [
http("POST", "/api/espocrm/document/create") http("POST", "/vmh/webhook/document/create")
], ],
"enqueues": ["espocrm.document.create"], "enqueues": ["vmh.document.create"],
} }
@@ -153,7 +153,7 @@ async def handler(request: ApiRequest, ctx: FlowContext[Any]) -> ApiResponse:
# Emit events für Queue-Processing (Deduplizierung erfolgt im Event-Handler via Lock) # Emit events für Queue-Processing (Deduplizierung erfolgt im Event-Handler via Lock)
for entity_id in entity_ids: for entity_id in entity_ids:
await ctx.enqueue({ await ctx.enqueue({
'topic': 'espocrm.document.create', 'topic': 'vmh.document.create',
'data': { 'data': {
'entity_id': entity_id, 'entity_id': entity_id,
'action': 'create', 'action': 'create',
@@ -161,7 +161,7 @@ async def handler(request: ApiRequest, ctx: FlowContext[Any]) -> ApiResponse:
'timestamp': datetime.datetime.now().isoformat() 'timestamp': datetime.datetime.now().isoformat()
} }
}) })
ctx.logger.info(f"✅ Event emittiert: espocrm.document.create für ID {entity_id}") ctx.logger.info(f"✅ Event emittiert: vmh.document.create für ID {entity_id}")
ctx.logger.info("\n" + "=" * 80) ctx.logger.info("\n" + "=" * 80)
ctx.logger.info(f"✅ WEBHOOK VERARBEITUNG ABGESCHLOSSEN") ctx.logger.info(f"✅ WEBHOOK VERARBEITUNG ABGESCHLOSSEN")

12
steps/espocrm_webhooks/document_delete_webhook_api_step.py
View File

@@ -10,13 +10,13 @@ from motia import FlowContext, http, ApiRequest, ApiResponse
config = { config = {
"name": "EspoCRM Document Delete Webhook", "name": "VMH Webhook Document Delete",
"description": "Empfängt Delete-Webhooks von EspoCRM für Document Entities", "description": "Empfängt Delete-Webhooks von EspoCRM für Document Entities",
"flows": ["espocrm-documents"], "flows": ["vmh-documents"],
"triggers": [ "triggers": [
http("POST", "/api/espocrm/document/delete") http("POST", "/vmh/webhook/document/delete")
], ],
"enqueues": ["espocrm.document.delete"], "enqueues": ["vmh.document.delete"],
} }
@@ -130,7 +130,7 @@ async def handler(request: ApiRequest, ctx: FlowContext[Any]) -> ApiResponse:
# Emit events für Queue-Processing # Emit events für Queue-Processing
for entity_id in entity_ids: for entity_id in entity_ids:
await ctx.enqueue({ await ctx.enqueue({
'topic': 'espocrm.document.delete', 'topic': 'vmh.document.delete',
'data': { 'data': {
'entity_id': entity_id, 'entity_id': entity_id,
'action': 'delete', 'action': 'delete',
@@ -138,7 +138,7 @@ async def handler(request: ApiRequest, ctx: FlowContext[Any]) -> ApiResponse:
'timestamp': datetime.datetime.now().isoformat() 'timestamp': datetime.datetime.now().isoformat()
} }
}) })
ctx.logger.info(f"✅ Event emittiert: espocrm.document.delete für ID {entity_id}") ctx.logger.info(f"✅ Event emittiert: vmh.document.delete für ID {entity_id}")
ctx.logger.info("\n" + "=" * 80) ctx.logger.info("\n" + "=" * 80)
ctx.logger.info(f"✅ WEBHOOK VERARBEITUNG ABGESCHLOSSEN") ctx.logger.info(f"✅ WEBHOOK VERARBEITUNG ABGESCHLOSSEN")

12
steps/espocrm_webhooks/document_update_webhook_api_step.py
View File

@@ -10,13 +10,13 @@ from motia import FlowContext, http, ApiRequest, ApiResponse
config = { config = {
"name": "EspoCRM Document Update Webhook", "name": "VMH Webhook Document Update",
"description": "Empfängt Update-Webhooks von EspoCRM für Document Entities", "description": "Empfängt Update-Webhooks von EspoCRM für Document Entities",
"flows": ["espocrm-documents"], "flows": ["vmh-documents"],
"triggers": [ "triggers": [
http("POST", "/api/espocrm/document/update") http("POST", "/vmh/webhook/document/update")
], ],
"enqueues": ["espocrm.document.update"], "enqueues": ["vmh.document.update"],
} }
@@ -152,7 +152,7 @@ async def handler(request: ApiRequest, ctx: FlowContext[Any]) -> ApiResponse:
# Emit events für Queue-Processing # Emit events für Queue-Processing
for entity_id in entity_ids: for entity_id in entity_ids:
await ctx.enqueue({ await ctx.enqueue({
'topic': 'espocrm.document.update', 'topic': 'vmh.document.update',
'data': { 'data': {
'entity_id': entity_id, 'entity_id': entity_id,
'action': 'update', 'action': 'update',
@@ -160,7 +160,7 @@ async def handler(request: ApiRequest, ctx: FlowContext[Any]) -> ApiResponse:
'timestamp': datetime.datetime.now().isoformat() 'timestamp': datetime.datetime.now().isoformat()
} }
}) })
ctx.logger.info(f"✅ Event emittiert: espocrm.document.update für ID {entity_id}") ctx.logger.info(f"✅ Event emittiert: vmh.document.update für ID {entity_id}")
ctx.logger.info("\n" + "=" * 80) ctx.logger.info("\n" + "=" * 80)
ctx.logger.info(f"✅ WEBHOOK VERARBEITUNG ABGESCHLOSSEN") ctx.logger.info(f"✅ WEBHOOK VERARBEITUNG ABGESCHLOSSEN")