Files
mayan-edms/mayan/apps/document_states/workflow_actions.py
Roberto Rosario 3669d7f3f2 Add HTTP Post workflow action.
Signed-off-by: Roberto Rosario <roberto.rosario.gonzalez@gmail.com>
2017-08-25 02:10:29 -04:00

85 lines
2.6 KiB
Python

from __future__ import absolute_import, unicode_literals
import logging
import json
import requests
from django.template import Template, Context
from django.utils.translation import ugettext_lazy as _
from .classes import WorkflowAction
__all__ = ('HTTPPostAction',)
logger = logging.getLogger(__name__)
class HTTPPostAction(WorkflowAction):
fields = (
{
'name': 'url', 'label': _('URL'),
'class': 'django.forms.CharField', 'kwargs': {
'help_text': _(
'Can be an IP address, a domain or a template. Templates '
'receive the workflow log entry instance as part of '
'their context via the variable "entry_log". '
'The "entry_log" in turn provides the '
'"workflow_instance", "datetime", "transition", "user", '
'and "comment" attributes.'
),
'required': True
},
}, {
'name': 'payload', 'label': _('Payload'),
'class': 'django.forms.CharField', 'kwargs': {
'help_text': _(
'A JSON document to include in the request. Can also be '
'a template that return a JSON document. Templates '
'receive the workflow log entry instance as part of '
'their context via the variable "entry_log". '
'The "entry_log" in turn provides the '
'"workflow_instance", "datetime", "transition", "user", '
'and "comment" attributes.'
), 'required': False
}
},
)
label = _('Perform a POST request')
widgets = {
'payload': {
'class': 'django.forms.widgets.Textarea', 'kwargs': {
'attrs': {'rows': '10'},
}
}
}
def __init__(self, url=None, payload=None):
self.url = url
self.payload = payload
def get_form_schema(self, request):
return {
'fields': self.fields,
'widgets': self.widgets
}
def execute(self, context):
url = Template(self.url).render(
context=Context(context)
)
logger.debug('URL template result: %s', url)
result = Template(self.payload or '{}').render(
context=Context(context)
)
logger.debug('payload template result: %s', result)
payload = json.loads(result)
logger.debug('payload json result: %s', payload)
response = requests.post(url=url, data=payload)