From 89e1909e939cf54a4abbd13a14a7f421e1c2474c Mon Sep 17 00:00:00 2001 From: =?UTF-8?q?St=C3=A9phane=20Brunner?= Date: Tue, 19 Nov 2024 11:40:58 +0100 Subject: [PATCH] Adapt dispatch_publish from first events --- .../module/dispatch_publishing/__init__.py | 20 +++++++++++-------- 1 file changed, 12 insertions(+), 8 deletions(-) diff --git a/github_app_geo_project/module/dispatch_publishing/__init__.py b/github_app_geo_project/module/dispatch_publishing/__init__.py index da6018cd57..7c35dae69f 100644 --- a/github_app_geo_project/module/dispatch_publishing/__init__.py +++ b/github_app_geo_project/module/dispatch_publishing/__init__.py @@ -67,6 +67,12 @@ def get_json_schema(self) -> dict[str, Any]: """Get the JSON schema for the configuration.""" return {} + def get_github_application_permissions(self) -> module.GitHubApplicationPermissions: + """Get the GitHub application permissions needed by the module.""" + return module.GitHubApplicationPermissions( + permissions={"contents": "write"}, events={"repository_dispatch"} + ) + def get_actions(self, context: module.GetActionContext) -> list[module.Action[None]]: """ Get the action related to the module and the event. @@ -74,16 +80,13 @@ def get_actions(self, context: module.GetActionContext) -> list[module.Action[No Usually the only action allowed to be done in this method is to set the pull request checks status Note that this function is called in the web server Pod who has low resources, and this call should be fast """ - if context.event_name == "repository_dispatch" and context.event_data.get("event_type") == "publish": + if ( + context.event_name == " repository_dispatch.published" + and context.event_data.get("action") == "published" + ): return [module.Action(None)] return [] - def get_github_application_permissions(self) -> module.GitHubApplicationPermissions: - """Get the GitHub application permissions needed by the module.""" - return module.GitHubApplicationPermissions( - permissions={"contents": "write"}, events={"repository_dispatch"} - ) - async def process( self, context: module.ProcessContext[None, None, None], @@ -93,8 +96,9 @@ async def process( Note that this method is called in the queue consuming Pod """ + content = context.event_data.get("client_payload", {}).get("content", {}) + for destination in CONFIG.destinations: - content = context.event_data.get("payloads", {}).get("content", {}) if destination.version_type and destination.package_type != content.get("version_type"): continue