foxmask /
django-th
| @@ 80-100 (lines=21) @@ | ||
| 77 | return data |
|
| 78 | ||
| 79 | ||
| 80 | def consumer(trigger_id, data): |
|
| 81 | """ |
|
| 82 | call the consumer and handle the data |
|
| 83 | :param trigger_id: |
|
| 84 | :param data: |
|
| 85 | :return: |
|
| 86 | """ |
|
| 87 | # consumer - the service which uses the data |
|
| 88 | default_provider.load_services() |
|
| 89 | service = TriggerService.objects.get(id=trigger_id) |
|
| 90 | ||
| 91 | service_consumer = default_provider.get_service( |
|
| 92 | str(service.consumer.name.name)) |
|
| 93 | kwargs = {'user': service.user} |
|
| 94 | ||
| 95 | data = data_filter(trigger_id, **data) |
|
| 96 | if len(data) > 0: |
|
| 97 | ||
| 98 | getattr(service_consumer, '__init__')(service.consumer.token, |
|
| 99 | **kwargs) |
|
| 100 | getattr(service_consumer, 'save_data')(service.id, **data) |
|
| 101 | ||
| 102 | ||
| 103 | def verify_signature(data, key, signature): |
|
| @@ 11-30 (lines=20) @@ | ||
| 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 | # consumer - the service which uses the data |
|
| 19 | default_provider.load_services() |
|
| 20 | service = TriggerService.objects.get(id=trigger_id) |
|
| 21 | ||
| 22 | service_consumer = default_provider.get_service( |
|
| 23 | str(service.consumer.name.name)) |
|
| 24 | kwargs = {'user': service.user} |
|
| 25 | ||
| 26 | if len(data) > 0: |
|
| 27 | ||
| 28 | getattr(service_consumer, '__init__')(service.consumer.token, |
|
| 29 | **kwargs) |
|
| 30 | getattr(service_consumer, 'save_data')(service.id, **data) |
|
| 31 | ||
| 32 | ||
| 33 | @api_view(['POST']) |
|
