| 708 | |
| 709 | |
| 710 | class WebhookManager(ResourceManager): |
| 711 | @add_auth_token_to_kwargs_from_env |
| 712 | def post_generic_webhook(self, trigger, payload=None, trace_tag=None, **kwargs): |
| 713 | url = "/webhooks/st2" |
| 714 | |
| 715 | headers = {} |
| 716 | data = {"trigger": trigger, "payload": payload or {}} |
| 717 | |
| 718 | if trace_tag: |
| 719 | headers["St2-Trace-Tag"] = trace_tag |
| 720 | |
| 721 | response = self.client.post(url, data=data, headers=headers, **kwargs) |
| 722 | |
| 723 | if response.status_code != http_client.OK: |
| 724 | self.handle_error(response) |
| 725 | |
| 726 | return parse_api_response(response) |
| 727 | |
| 728 | @add_auth_token_to_kwargs_from_env |
| 729 | def match(self, instance, **kwargs): |
| 730 | url = "/%s/match" % self.resource.get_url_path_name() |
| 731 | response = self.client.post(url, instance.serialize(), **kwargs) |
| 732 | if response.status_code != http_client.OK: |
| 733 | self.handle_error(response) |
| 734 | match = parse_api_response(response) |
| 735 | return ( |
| 736 | self.resource.deserialize(match["actionalias"]), |
| 737 | match["representation"], |
| 738 | ) |
| 739 | |
| 740 | |
| 741 | class StreamManager(ResourceManager): |