(self, *args, **kwargs)
| 84 | |
| 85 | class WebhooksController(object): |
| 86 | def __init__(self, *args, **kwargs): |
| 87 | self._hooks = HooksHolder() |
| 88 | self._base_url = "/webhooks/" |
| 89 | self._trigger_types = list(WEBHOOK_TRIGGER_TYPES.keys()) |
| 90 | |
| 91 | self._trigger_dispatcher_service = TriggerDispatcherService(LOG) |
| 92 | queue_suffix = self.__class__.__name__ |
| 93 | self._trigger_watcher = TriggerWatcher( |
| 94 | create_handler=self._handle_create_trigger, |
| 95 | update_handler=self._handle_update_trigger, |
| 96 | delete_handler=self._handle_delete_trigger, |
| 97 | trigger_types=self._trigger_types, |
| 98 | queue_suffix=queue_suffix, |
| 99 | exclusive=True, |
| 100 | ) |
| 101 | self._trigger_watcher.start() |
| 102 | self._register_webhook_trigger_types() |
| 103 | |
| 104 | def get_all(self): |
| 105 | # Return only the hooks known by this controller. |
nothing calls this directly
no test coverage detected