(self)
| 400 | self.action_event.email_was_sent_to = self.action.email_send_to |
| 401 | |
| 402 | def webhook(self): |
| 403 | """ |
| 404 | |
| 405 | |
| 406 | """ |
| 407 | |
| 408 | logger.debug('[ActionFlow {}] Running Webhook Action'.format(self.workflow.id)) |
| 409 | |
| 410 | # Create Email Notification |
| 411 | # URL to flow |
| 412 | url_webhook = self.action.url_to_post |
| 413 | secret = self.action.secret_webhook |
| 414 | |
| 415 | notification = Notification.new( |
| 416 | session=self.session, |
| 417 | channel_type='webhook', |
| 418 | add_to_session=True, |
| 419 | flush_session=True, |
| 420 | type=self.trigger_event.type, |
| 421 | task_id=self.trigger_event.task_id, |
| 422 | job_id=self.trigger_event.job_id, |
| 423 | input_id=self.trigger_event.input_id, |
| 424 | member_created=self.trigger_event.member_created |
| 425 | ) |
| 426 | if self.workflow.time_window and self.trigger_event.aggregation_window_start_time: |
| 427 | notification.send_to_webhook(session=self.session, |
| 428 | url=url_webhook, |
| 429 | secret=secret, |
| 430 | start_time=self.trigger_event.aggregation_window_start_time) |
| 431 | |
| 432 | else: |
| 433 | notification.send_to_webhook(session=self.session, url=url_webhook, secret=secret) |
| 434 | |
| 435 | # Record Action event |
| 436 |
nothing calls this directly
no test coverage detected