Produits Entr'ouvert » Passerelle

import traceback

import base64

import itertools

from django.apps import apps

from django.conf import settings

    def __init__(self, *args, **kwargs):

        super(BaseResource, self).__init__(*args, **kwargs)

    def __str__(self):

        return self.title

class ProxyLogger(object):

        self.connector = connector

        self.appname = connector.get_connector_slug()

        self.slug = connector.slug

        self.extra = extra or {}

        logger_name = 'passerelle.resource.%s.%s' % (self.appname, self.slug)

        self._logger = logging.getLogger(logger_name)

        self._logger.setLevel(connector.log_level)

                return isinstance(value, (list, dict, bool) + six.integer_types + six.string_types)

            attr['extra'] = {key: value for key, value in extra.items() if is_json_serializable(value)}

            if getattr(request, 'META', None):

                if 'HTTP_X_FORWARDED_FOR' in request.META:

                    sourceip = request.META.get('HTTP_X_FORWARDED_FOR', '').split(",")[0].strip()

<div class="log-dialog">

<table>

{% for key, value in logline.extra.items %}

<tr>

  <td>{{key}}</td>

  <td>{% for key2, value2 in value.items %}

      {% endwith %}

      {% endfor %}</td>

</tr>

{% endfor %}

</table>

</div>

    @csrf_exempt

    def dispatch(self, request, *args, **kwargs):

        self.init_stuff(request, *args, **kwargs)

        self.endpoint = None

            if not hasattr(method, 'endpoint_info'):

                continue

            if not method.endpoint_info.name == kwargs.get('endpoint'):

                self.endpoint = method

        if not self.endpoint:

            raise Http404()

            # hide automatic up endpoint if check_status method is not implemented

            raise Http404()

        return super(GenericEndpointView, self).dispatch(request, *args, **kwargs)

        perm = self.endpoint.endpoint_info.perm

        if not perm:

            return True

    def perform(self, request, *args, **kwargs):

        if request.method.lower() not in self.endpoint.endpoint_info.methods:

        # auto log request's inputs

        connector_name, endpoint_name = kwargs['connector'], kwargs['endpoint']

        url = request.get_full_path()

        try:

            payload = payload.decode('utf-8')

        except UnicodeDecodeError:

            payload = '<BINARY PAYLOAD>'

                              (request.method, url, payload),

                              extra={

                                  'request': request,

            kwargs['other_params'] = match.kwargs

        elif kwargs.get('rest'):

            raise Http404()

    def post(self, request, *args, **kwargs):

        return self.get(request, *args, **kwargs)

    assert ResourceLog.objects.last().levelno == 30

class FakeConnectorBase(object):

    slug = 'connector'

    resp.form['q'] = ''

    resp = resp.form.submit()

    assert resp.text.count('<td class="timestamp">') == 4

    log_pk = re.findall(r'data-pk="(.*)"', resp.text)[0]

    base_url = re.findall(r'data-log-base-url="(.*)"', resp.text)[0]

    resp = app.get(base_url + log_pk + '/')

    resp = app.get(base_url + '12345' + '/', status=404)

def test_logging_parameters(app, admin_user):

class FakedResponse(mock.Mock):

    def json(self):

        return json_loads(self.content)