foxmask /
django-th
| @@ 144-167 (lines=24) @@ | ||
| 141 | return data |
|
| 142 | ||
| 143 | ||
| 144 | def consumer(trigger_id, data): |
|
| 145 | """ |
|
| 146 | call the consumer and handle the data |
|
| 147 | :param trigger_id: |
|
| 148 | :param data: |
|
| 149 | :return: |
|
| 150 | """ |
|
| 151 | status = True |
|
| 152 | # consumer - the service which uses the data |
|
| 153 | default_provider.load_services() |
|
| 154 | service = TriggerService.objects.get(id=trigger_id) |
|
| 155 | ||
| 156 | service_consumer = default_provider.get_service( |
|
| 157 | str(service.consumer.name.name)) |
|
| 158 | kwargs = {'user': service.user} |
|
| 159 | ||
| 160 | data = data_filter(trigger_id, **data) |
|
| 161 | if len(data) > 0: |
|
| 162 | ||
| 163 | getattr(service_consumer, '__init__')(service.consumer.token, |
|
| 164 | **kwargs) |
|
| 165 | status = getattr(service_consumer, 'save_data')(service.id, **data) |
|
| 166 | ||
| 167 | return status |
|
| 168 | ||
| 169 | ||
| 170 | def verify_signature(data, key, signature): |
|
| @@ 11-33 (lines=23) @@ | ||
| 8 | from th_slack.models import Slack |
|
| 9 | ||
| 10 | ||
| 11 | def consumer(trigger_id, data): |
|
| 12 | """ |
|
| 13 | call the consumer and handle the data |
|
| 14 | :param trigger_id: |
|
| 15 | :param data: |
|
| 16 | :return: |
|
| 17 | """ |
|
| 18 | status = True |
|
| 19 | # consumer - the service which uses the data |
|
| 20 | default_provider.load_services() |
|
| 21 | service = TriggerService.objects.get(id=trigger_id) |
|
| 22 | ||
| 23 | service_consumer = default_provider.get_service( |
|
| 24 | str(service.consumer.name.name)) |
|
| 25 | kwargs = {'user': service.user} |
|
| 26 | ||
| 27 | if len(data) > 0: |
|
| 28 | ||
| 29 | getattr(service_consumer, '__init__')(service.consumer.token, |
|
| 30 | **kwargs) |
|
| 31 | status = getattr(service_consumer, 'save_data')(service.id, **data) |
|
| 32 | ||
| 33 | return status |
|
| 34 | ||
| 35 | ||
| 36 | @api_view(['POST']) |
|
