From 721339ca9b606caa6387cd06df907b1f83d3b196 Mon Sep 17 00:00:00 2001 From: bsiggel Date: Sun, 1 Mar 2026 23:28:29 +0000 Subject: [PATCH] Update flow names for Advoware and VMH steps to improve clarity and organization --- service-account.json | 13 +++++++++++++ steps/advoware_cal_sync/calendar_sync_all_step.py | 2 +- steps/advoware_cal_sync/calendar_sync_api_step.py | 2 +- steps/advoware_cal_sync/calendar_sync_cron_step.py | 2 +- steps/advoware_cal_sync/calendar_sync_event_step.py | 2 +- .../advoware_api_proxy_delete_step.py | 2 +- steps/advoware_proxy/advoware_api_proxy_get_step.py | 2 +- .../advoware_proxy/advoware_api_proxy_post_step.py | 2 +- steps/advoware_proxy/advoware_api_proxy_put_step.py | 2 +- steps/vmh/bankverbindungen_sync_event_step.py | 2 +- steps/vmh/beteiligte_sync_cron_step.py | 2 +- steps/vmh/beteiligte_sync_event_step.py | 2 +- .../vmh/webhook/bankverbindungen_create_api_step.py | 2 +- .../vmh/webhook/bankverbindungen_delete_api_step.py | 2 +- .../vmh/webhook/bankverbindungen_update_api_step.py | 2 +- steps/vmh/webhook/beteiligte_create_api_step.py | 2 +- steps/vmh/webhook/beteiligte_delete_api_step.py | 2 +- steps/vmh/webhook/beteiligte_update_api_step.py | 2 +- 18 files changed, 30 insertions(+), 17 deletions(-) create mode 100644 service-account.json diff --git a/service-account.json b/service-account.json new file mode 100644 index 0000000..8c3e524 --- /dev/null +++ b/service-account.json @@ -0,0 +1,13 @@ +{ + "type": "service_account", + "project_id": "bitbylaw-475919", + "private_key_id": "1b83e57147852a870e34df41fbcfec281dccaf33", + "private_key": "-----BEGIN PRIVATE KEY-----\nMIIEvAIBADANBgkqhkiG9w0BAQEFAASCBKYwggSiAgEAAoIBAQDCYbRo/sgisHAp\noMCZ4c1ijpJ6igaKv6b9DmB8nH+DZeiJiGIYpOSVvpbTGLX4C4bg8lzrP/cYMhwm\ni2LATOEi8fMQX4/9v4yxr6lc+341/6bZ5Zp0qepqhJazFjJOhty2KovqJebiAJXE\n4AtDV4kgNJHZKAi9bSx3N6ltTP/qUS5BRuws2nrC3iaI+pHWIjG4vhH7Sjp/Ga86\nI05IcLGDG/SUX3oqqwpjACNGI+9/8hCfeqyMUjPhn82xivGzw+z4nC2iwcnRgsHB\nFxr5kpamJMmNOiWtZaYOBJzIa5EL4cu7VCMVt80VbA/Ezci+WvpJJ7nn2gS0KJGP\nXcdXGsrNAgMBAAECggEAByQfGaBf6o5VgIysUWWZ7bNT2aFKfjxuPmu8dbeAzmtR\nsK52/srIBGGnxCzrOn1J65Jb1t9XDOeCYJQhq548wyjlB3FLUUTWlAyNCffJ+jfg\nga7NZC3TM9iXz2UoXKQtuu+Ii7CaxoDDqnjvUP5dRkvyyRSPGvkbd2xvEq86fk7Z\nbeqZoW3pmIqr4IMNRRRnXCq6bwCYg4paQZiyTnrX8JnnIq03hsSxcFEQsk78bsaF\nVBF76wtsjTFlcLTqzVzJDep15BXN/KP12bSgzlTC2P1lB97+XmrI+6/Cj6cv3Vda\nISgmEBZbeph+rBzJ4M+5R4wM9ygP2aGhsORTmzFMrQKBgQDu91WL8IXS9ZPUO26e\nutorkTlIAb1Jih8N5s4q07XF8SzScDw/E7ZdXAvylfHpnxLv1B6zi8r/MGAamHS9\n0iFzvrxE81s2h8U2bIhyADhkjGLQFXPK+cW62ym3ZATGExxWoQL9jpczsgNOv78d\n384w1bf4MBudlHhXj7Wt+dpK0wKBgQDQPMpm7l7lSBHRPOV2+Th0G1ExJAHhqrTC\nbx/X8e6WABsJ+o/N9ttrPsHlZ4lzhuNw5v0hYrPV0YrXRg98QqYUbKTrAHRIq4gL\nhnrmVDywTUPeU4PEoW0of8rQeQUzVCdw3dKhKTs6H9LN7VUy3mEu5L78mdPYQL2E\nwwNPZOHP3wKBgGg8dRFcslMqEfiyj/cnFEGK0EyrjZDFcfRTaDzgKlsUb3O/x1fQ\nVmz02LVRWLuKSu1YPqgc40hbJqCTPeELBtKBMYh2CqSHpqutvfrUQ8UAQ532rZKt\nTuXJ8bFwLHDmJydWhoJpr2S6Up0IIOp8FGnS37Of8HvVJoUzR5GC+ghHAoGAZLrj\nVcM9GEAyjjqc7V5FFrUYI2M9ncILynoitz0KonjOm5ce9QzSuyASfzwEW2QGpVi3\nXez2/RltxhDX8M30tLCRXjRMC9Md7iVRUhWxfb8Cc4uGlBlaSlr26r1/7IJqycgj\n2V2ujsFSIdcKfZ7g9+QjFuH6fgNjKdODyGYObZUCgYBTePTscIghcfq5aJiEcNR0\nGaCaVnXLMbWIXMNYBrDotD30j4J7TyPny2b3xv5tfSud/c+gWzzJy3QLQY56ab1s\n89gG0KHSNvsMK+pJsB+3b9C+pFMRIlzJPXS++tIyBSf3gwV5PInytkE1ZgB+EpEQ\nAmAF5lUQ4XydjX3MTT1S4A==\n-----END PRIVATE KEY-----\n", + "client_email": "bitbylaw-advoware-snyc@bitbylaw-475919.iam.gserviceaccount.com", + "client_id": "104069107394434106127", + "auth_uri": "https://accounts.google.com/o/oauth2/auth", + "token_uri": "https://oauth2.googleapis.com/token", + "auth_provider_x509_cert_url": "https://www.googleapis.com/oauth2/v1/certs", + "client_x509_cert_url": "https://www.googleapis.com/robot/v1/metadata/x509/bitbylaw-advoware-snyc%40bitbylaw-475919.iam.gserviceaccount.com", + "universe_domain": "googleapis.com" +} diff --git a/steps/advoware_cal_sync/calendar_sync_all_step.py b/steps/advoware_cal_sync/calendar_sync_all_step.py index e314215..4c9344c 100644 --- a/steps/advoware_cal_sync/calendar_sync_all_step.py +++ b/steps/advoware_cal_sync/calendar_sync_all_step.py @@ -25,7 +25,7 @@ from services.advoware_service import AdvowareService config = { 'name': 'Calendar Sync All Step', 'description': 'Receives sync-all event and emits individual events for oldest employees', - 'flows': ['advoware'], + 'flows': ['advoware-calendar-sync'], 'triggers': [ queue('calendar_sync_all') ], diff --git a/steps/advoware_cal_sync/calendar_sync_api_step.py b/steps/advoware_cal_sync/calendar_sync_api_step.py index d56dcef..bb59972 100644 --- a/steps/advoware_cal_sync/calendar_sync_api_step.py +++ b/steps/advoware_cal_sync/calendar_sync_api_step.py @@ -15,7 +15,7 @@ from motia import http, ApiRequest, ApiResponse, FlowContext config = { 'name': 'Calendar Sync API Trigger', 'description': 'API endpoint for manual calendar sync triggering', - 'flows': ['advoware'], + 'flows': ['advoware-calendar-sync'], 'triggers': [ http('POST', '/advoware/calendar/sync') ], diff --git a/steps/advoware_cal_sync/calendar_sync_cron_step.py b/steps/advoware_cal_sync/calendar_sync_cron_step.py index d99c2ae..31e0cb4 100644 --- a/steps/advoware_cal_sync/calendar_sync_cron_step.py +++ b/steps/advoware_cal_sync/calendar_sync_cron_step.py @@ -15,7 +15,7 @@ from motia import cron, FlowContext config = { 'name': 'Calendar Sync Cron Job', 'description': 'Runs calendar sync automatically every 15 minutes', - 'flows': ['advoware'], + 'flows': ['advoware-calendar-sync'], 'triggers': [ cron("0 */15 * * * *") # Every 15 minutes (6-field: sec min hour day month weekday) ], diff --git a/steps/advoware_cal_sync/calendar_sync_event_step.py b/steps/advoware_cal_sync/calendar_sync_event_step.py index 4bff0b1..f93013d 100644 --- a/steps/advoware_cal_sync/calendar_sync_event_step.py +++ b/steps/advoware_cal_sync/calendar_sync_event_step.py @@ -937,7 +937,7 @@ async def process_updates(state, conn, service, calendar_id: str, kuerzel: str, config = { "name": "Calendar Sync Event Step", "description": "Handles bidirectional calendar sync between Advoware and Google Calendar using Postgres as hub", - "flows": ["advoware"], + "flows": ["advoware-calendar-sync"], "triggers": [ queue("calendar_sync_employee") ], diff --git a/steps/advoware_proxy/advoware_api_proxy_delete_step.py b/steps/advoware_proxy/advoware_api_proxy_delete_step.py index 91bf5b1..bf8bf4e 100644 --- a/steps/advoware_proxy/advoware_api_proxy_delete_step.py +++ b/steps/advoware_proxy/advoware_api_proxy_delete_step.py @@ -7,7 +7,7 @@ from services.advoware import AdvowareAPI config = { "name": "Advoware Proxy DELETE", "description": "Universal proxy for Advoware API (DELETE requests)", - "flows": ["advoware"], + "flows": ["advoware-proxy"], "triggers": [ http("DELETE", "/advoware/proxy") ], diff --git a/steps/advoware_proxy/advoware_api_proxy_get_step.py b/steps/advoware_proxy/advoware_api_proxy_get_step.py index dc86dd6..820fdcd 100644 --- a/steps/advoware_proxy/advoware_api_proxy_get_step.py +++ b/steps/advoware_proxy/advoware_api_proxy_get_step.py @@ -7,7 +7,7 @@ from services.advoware import AdvowareAPI config = { "name": "Advoware Proxy GET", "description": "Universal proxy for Advoware API (GET requests)", - "flows": ["advoware"], + "flows": ["advoware-proxy"], "triggers": [ http("GET", "/advoware/proxy") ], diff --git a/steps/advoware_proxy/advoware_api_proxy_post_step.py b/steps/advoware_proxy/advoware_api_proxy_post_step.py index 91bc29e..bc20a48 100644 --- a/steps/advoware_proxy/advoware_api_proxy_post_step.py +++ b/steps/advoware_proxy/advoware_api_proxy_post_step.py @@ -7,7 +7,7 @@ from services.advoware import AdvowareAPI config = { "name": "Advoware Proxy POST", "description": "Universal proxy for Advoware API (POST requests)", - "flows": ["advoware"], + "flows": ["advoware-proxy"], "triggers": [ http("POST", "/advoware/proxy") ], diff --git a/steps/advoware_proxy/advoware_api_proxy_put_step.py b/steps/advoware_proxy/advoware_api_proxy_put_step.py index 4c9c12c..2618ced 100644 --- a/steps/advoware_proxy/advoware_api_proxy_put_step.py +++ b/steps/advoware_proxy/advoware_api_proxy_put_step.py @@ -7,7 +7,7 @@ from services.advoware import AdvowareAPI config = { "name": "Advoware Proxy PUT", "description": "Universal proxy for Advoware API (PUT requests)", - "flows": ["advoware"], + "flows": ["advoware-proxy"], "triggers": [ http("PUT", "/advoware/proxy") ], diff --git a/steps/vmh/bankverbindungen_sync_event_step.py b/steps/vmh/bankverbindungen_sync_event_step.py index 4e547bc..2679e48 100644 --- a/steps/vmh/bankverbindungen_sync_event_step.py +++ b/steps/vmh/bankverbindungen_sync_event_step.py @@ -23,7 +23,7 @@ import os config = { "name": "VMH Bankverbindungen Sync Handler", "description": "Zentraler Sync-Handler für Bankverbindungen (Webhooks + Cron Events)", - "flows": ["vmh"], + "flows": ["vmh-bankverbindungen"], "triggers": [ {"type": "queue", "topic": "vmh.bankverbindungen.create"}, {"type": "queue", "topic": "vmh.bankverbindungen.update"}, diff --git a/steps/vmh/beteiligte_sync_cron_step.py b/steps/vmh/beteiligte_sync_cron_step.py index 9209c36..a05b3da 100644 --- a/steps/vmh/beteiligte_sync_cron_step.py +++ b/steps/vmh/beteiligte_sync_cron_step.py @@ -17,7 +17,7 @@ import datetime config = { "name": "VMH Beteiligte Sync Cron", "description": "Prüft alle 15 Minuten welche Beteiligte synchronisiert werden müssen", - "flows": ["vmh"], + "flows": ["vmh-beteiligte"], "triggers": [ cron("0 */15 * * * *") # Alle 15 Minuten (6-field format!) ], diff --git a/steps/vmh/beteiligte_sync_event_step.py b/steps/vmh/beteiligte_sync_event_step.py index ee948b0..33ef795 100644 --- a/steps/vmh/beteiligte_sync_event_step.py +++ b/steps/vmh/beteiligte_sync_event_step.py @@ -24,7 +24,7 @@ import os config = { "name": "VMH Beteiligte Sync Handler", "description": "Zentraler Sync-Handler für Beteiligte (Webhooks + Cron Events)", - "flows": ["vmh"], + "flows": ["vmh-beteiligte"], "triggers": [ {"type": "queue", "topic": "vmh.beteiligte.create"}, {"type": "queue", "topic": "vmh.beteiligte.update"}, diff --git a/steps/vmh/webhook/bankverbindungen_create_api_step.py b/steps/vmh/webhook/bankverbindungen_create_api_step.py index 653a195..74e453d 100644 --- a/steps/vmh/webhook/bankverbindungen_create_api_step.py +++ b/steps/vmh/webhook/bankverbindungen_create_api_step.py @@ -8,7 +8,7 @@ from motia import FlowContext, http, ApiRequest, ApiResponse config = { "name": "VMH Webhook Bankverbindungen Create", "description": "Empfängt Create-Webhooks von EspoCRM für Bankverbindungen", - "flows": ["vmh"], + "flows": ["vmh-bankverbindungen"], "triggers": [ http("POST", "/vmh/webhook/bankverbindungen/create") ], diff --git a/steps/vmh/webhook/bankverbindungen_delete_api_step.py b/steps/vmh/webhook/bankverbindungen_delete_api_step.py index 6d928f2..b02d716 100644 --- a/steps/vmh/webhook/bankverbindungen_delete_api_step.py +++ b/steps/vmh/webhook/bankverbindungen_delete_api_step.py @@ -8,7 +8,7 @@ from motia import FlowContext, http, ApiRequest, ApiResponse config = { "name": "VMH Webhook Bankverbindungen Delete", "description": "Empfängt Delete-Webhooks von EspoCRM für Bankverbindungen", - "flows": ["vmh"], + "flows": ["vmh-bankverbindungen"], "triggers": [ http("POST", "/vmh/webhook/bankverbindungen/delete") ], diff --git a/steps/vmh/webhook/bankverbindungen_update_api_step.py b/steps/vmh/webhook/bankverbindungen_update_api_step.py index 41cbadd..1e2544c 100644 --- a/steps/vmh/webhook/bankverbindungen_update_api_step.py +++ b/steps/vmh/webhook/bankverbindungen_update_api_step.py @@ -8,7 +8,7 @@ from motia import FlowContext, http, ApiRequest, ApiResponse config = { "name": "VMH Webhook Bankverbindungen Update", "description": "Empfängt Update-Webhooks von EspoCRM für Bankverbindungen", - "flows": ["vmh"], + "flows": ["vmh-bankverbindungen"], "triggers": [ http("POST", "/vmh/webhook/bankverbindungen/update") ], diff --git a/steps/vmh/webhook/beteiligte_create_api_step.py b/steps/vmh/webhook/beteiligte_create_api_step.py index fe3ca27..b5fde55 100644 --- a/steps/vmh/webhook/beteiligte_create_api_step.py +++ b/steps/vmh/webhook/beteiligte_create_api_step.py @@ -8,7 +8,7 @@ from motia import FlowContext, http, ApiRequest, ApiResponse config = { "name": "VMH Webhook Beteiligte Create", "description": "Empfängt Create-Webhooks von EspoCRM für Beteiligte", - "flows": ["vmh"], + "flows": ["vmh-beteiligte"], "triggers": [ http("POST", "/vmh/webhook/beteiligte/create") ], diff --git a/steps/vmh/webhook/beteiligte_delete_api_step.py b/steps/vmh/webhook/beteiligte_delete_api_step.py index a8a1f47..cc277d3 100644 --- a/steps/vmh/webhook/beteiligte_delete_api_step.py +++ b/steps/vmh/webhook/beteiligte_delete_api_step.py @@ -8,7 +8,7 @@ from motia import FlowContext, http, ApiRequest, ApiResponse config = { "name": "VMH Webhook Beteiligte Delete", "description": "Empfängt Delete-Webhooks von EspoCRM für Beteiligte", - "flows": ["vmh"], + "flows": ["vmh-beteiligte"], "triggers": [ http("POST", "/vmh/webhook/beteiligte/delete") ], diff --git a/steps/vmh/webhook/beteiligte_update_api_step.py b/steps/vmh/webhook/beteiligte_update_api_step.py index 9308b98..53b0ac9 100644 --- a/steps/vmh/webhook/beteiligte_update_api_step.py +++ b/steps/vmh/webhook/beteiligte_update_api_step.py @@ -8,7 +8,7 @@ from motia import FlowContext, http, ApiRequest, ApiResponse config = { "name": "VMH Webhook Beteiligte Update", "description": "Empfängt Update-Webhooks von EspoCRM für Beteiligte", - "flows": ["vmh"], + "flows": ["vmh-beteiligte"], "triggers": [ http("POST", "/vmh/webhook/beteiligte/update") ],