# Path: mistraldashboard/api.py
# SERVICE_TYPE = 'workflowv2'
# def mistralclient(request):
# def pagination_list(entity, request, marker='', sort_keys='', sort_dirs='asc',
#                     paginate=False, reversed_order=False, selector=None):
# def execution_create(request, **data):
# def execution_get(request, execution_id):
# def execution_update(request, execution_id, field, value):
# def execution_delete(request, execution_name):
# def task_list(request, execution_id=None):
# def task_get(request, task_id=None):
# def workflow_list(request):
# def workflow_get(request, workflow_name):
# def workflow_create(request, workflows_definition):
# def workflow_validate(request, workflow_definition):
# def workflow_delete(request, workflow_name):
# def workflow_update(request, workflows_definition):
# def workbook_list(request):
# def workbook_get(request, workbook_name):
# def workbook_create(request, workbook_definition):
# def workbook_validate(request, workbook_definition):
# def workbook_delete(request, workbook_name):
# def workbook_update(request, workbook_definition):
# def action_list(request):
# def action_get(request, action_name):
# def action_create(request, action_definition):
# def action_update(request, action_definition):
# def action_run(request, action_name, input, params):
# def action_delete(request, action_name):
# def action_executions_list(request, task_execution_id=None):
# def action_execution_get(request, action_execution_id):
# def action_execution_delete(request, action_execution_id):
# def action_execution_update(request, id, state=None, output=None):
# def cron_trigger_list(request):
# def cron_trigger_get(request, cron_trigger_name):
# def cron_trigger_delete(request, cron_trigger_name):
# def cron_trigger_create(
#     request,
#     cron_trigger_name,
#     workflow_ID,
#     workflow_input,
#     workflow_params,
#     pattern,
#     first_time,
#     count
# ):


import json
from django.urls import reverse
from django.utils.translation import ugettext_lazy as _
from horizon import exceptions
from horizon import forms
from horizon import messages
from mistraldashboard import api
    )
    definition_data = forms.CharField(
        label=_('Definition Data'),
        help_text=_('The raw contents of the definition.'),
        widget=forms.widgets.Textarea(
            attrs={'class': 'switched',
                   'data-switch-on': 'definitionsource',
                   'data-required-when-shown': 'true',
                   'data-definitionsource-raw': _('Definition Data'),
                   'rows': 4}
        ),
        required=False
    )

    def clean(self):
        cleaned_data = super(CreateForm, self).clean()

        if cleaned_data.get('definition_upload'):
            files = self.request.FILES
            cleaned_data['definition'] = files['definition_upload'].read()
        elif cleaned_data.get('definition_data'):
            cleaned_data['definition'] = cleaned_data['definition_data']
        else:
            raise forms.ValidationError(
                _('You must specify the definition source.'))

        return cleaned_data

    def handle(self, request, data):
        try:

# Path: mistraldashboard/api.py
# SERVICE_TYPE = 'workflowv2'
# def mistralclient(request):
# def pagination_list(entity, request, marker='', sort_keys='', sort_dirs='asc',
#                     paginate=False, reversed_order=False, selector=None):
# def execution_create(request, **data):
# def execution_get(request, execution_id):
# def execution_update(request, execution_id, field, value):
# def execution_delete(request, execution_name):
# def task_list(request, execution_id=None):
# def task_get(request, task_id=None):
# def workflow_list(request):
# def workflow_get(request, workflow_name):
# def workflow_create(request, workflows_definition):
# def workflow_validate(request, workflow_definition):
# def workflow_delete(request, workflow_name):
# def workflow_update(request, workflows_definition):
# def workbook_list(request):
# def workbook_get(request, workbook_name):
# def workbook_create(request, workbook_definition):
# def workbook_validate(request, workbook_definition):
# def workbook_delete(request, workbook_name):
# def workbook_update(request, workbook_definition):
# def action_list(request):
# def action_get(request, action_name):
# def action_create(request, action_definition):
# def action_update(request, action_definition):
# def action_run(request, action_name, input, params):
# def action_delete(request, action_name):
# def action_executions_list(request, task_execution_id=None):
# def action_execution_get(request, action_execution_id):
# def action_execution_delete(request, action_execution_id):
# def action_execution_update(request, id, state=None, output=None):
# def cron_trigger_list(request):
# def cron_trigger_get(request, cron_trigger_name):
# def cron_trigger_delete(request, cron_trigger_name):
# def cron_trigger_create(
#     request,
#     cron_trigger_name,
#     workflow_ID,
#     workflow_input,
#     workflow_params,
#     pattern,
#     first_time,
#     count
# ):


# Path: mistraldashboard/actions/forms.py
import json
from django.urls import reverse
from django.utils.translation import ugettext_lazy as _
from horizon import exceptions
from horizon import forms
from horizon import messages
from mistraldashboard import api

    )
    definition_data = forms.CharField(
        label=_('Definition Data'),
        help_text=_('The raw contents of the definition.'),
        widget=forms.widgets.Textarea(
            attrs={'class': 'switched',
                   'data-switch-on': 'definitionsource',
                   'data-required-when-shown': 'true',
                   'data-definitionsource-raw': _('Definition Data'),
                   'rows': 4}
        ),
        required=False
    )

    def clean(self):
        cleaned_data = super(CreateForm, self).clean()

        if cleaned_data.get('definition_upload'):
            files = self.request.FILES
            cleaned_data['definition'] = files['definition_upload'].read()
        elif cleaned_data.get('definition_data'):
            cleaned_data['definition'] = cleaned_data['definition_data']
        else:
            raise forms.ValidationError(
                _('You must specify the definition source.'))

        return cleaned_data

    def handle(self, request, data):
        try:

            api.action_create(request, data['definition'])