API-Manager/apimanager/connectormethod/views.py

# -*- coding: utf-8 -*-
"""
Views of config app
"""

import json
from django.contrib import messages
from django.contrib.auth.mixins import LoginRequiredMixin
from django.http import HttpResponseRedirect, HttpResponse
from django.views.generic import FormView
from obp.api import API, APIError
from django.urls import reverse, reverse_lazy
from base.utils import exception_handle, error_once_only
from .forms import ConnectorMethodForm
from django.views.decorators.csrf import csrf_exempt


class IndexView(LoginRequiredMixin, FormView):
    """Index view for config"""
    template_name = r"connectormethod/index.html"
    form_class = ConnectorMethodForm
    success_url = reverse_lazy('connectormethod-index')

    def get_context_data(self, **kwargs):
        context = super(IndexView, self).get_context_data(**kwargs)
        api = API(self.request.session.get('obp'))
        urlpath = '/management/connector-methods'
        connectormethod =[]
        try:
            response = api.get(urlpath)
            if 'code' in response and response['code'] >= 400:
                error_once_only(self.request, response['message'])
            else:
                connectormethod=response['connector_methods']
        except APIError as err:
            messages.error(self.request, err)
        except Exception as err:
            error_once_only(self.request, err)
        else:
            default_connector_method_endpoint = {
                            "connector_method_name": "Method Name",
                            "programming_lang": "Scala",
                            "Method Body":"Enter Your Method Body"
                        }
            connectormethod.insert(0,json.dumps(default_connector_method_endpoint))

            context.update({
                'connectormethods': connectormethod
            })
        return context

@exception_handle
@csrf_exempt
def connectormethod_save(request):
    api = API(request.session.get('obp'))
    urlpath = '/management/connector-methods'
    payload = {
        'method_name': request.POST.get('connector_method_name').strip(),
        'programming_lang': request.POST.get('connector_method_programming_lang'),
        'method_body': request.POST.get('connector_method_body').strip()
    }
    result = api.post(urlpath, payload = payload)
    return result


@exception_handle
@csrf_exempt
def connectormethod_update(request):
    connector_method_id = request.POST.get('connector_method_id').strip()
    urlpath = '/management/connector-methods/{}'.format(connector_method_id)
    api = API(request.session.get('obp'))
    payload = {
        'programming_lang': request.POST.get('connector_method_programming_lang_update'),
        'method_body': request.POST.get('connector_method_body_update').strip()
    }
    result = api.put(urlpath, payload=payload)
    return result