Produits Entr'ouvert » Passerelle

# -*- coding: utf-8 -*-

from __future__ import unicode_literals

from django.db import migrations, models

import jsonfield.fields

class Migration(migrations.Migration):

    dependencies = [

        ('base', '0002_auto_20151009_0326'),

    ]

    operations = [

        migrations.CreateModel(

            name='ResourceLog',

            fields=[

                ('id', models.AutoField(verbose_name='ID', serialize=False, auto_created=True, primary_key=True)),

                ('timestamp', models.DateTimeField(auto_now_add=True)),

                ('connector', models.CharField(max_length=128, verbose_name=b'connector')),

                ('loglevel', models.CharField(max_length=16, verbose_name=b'log level')),

                ('ipsource', models.GenericIPAddressField(unpack_ipv4=True, null=True, verbose_name='IP Address', blank=True)),

                ('message', models.TextField(max_length=2048, verbose_name=b'message')),

                ('extra', jsonfield.fields.JSONField(default={}, verbose_name=b'extras')),

            ],

        ),

    ]

import jsonfield

    # LOG Helpers

    def _log(self, levelname, message, request=None, **extra):

        connector = '%s-%s' % (slugify(unicode(self.__class__.__name__)), self.slug)

        if 'HTTP_X_FORWARDED_FOR' in request.META:

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

        else:

            ipsource = request.META.get('REMOTE_ADDR')

        # Resource Custom DB Loggger

        ResourceLog.objects.create(connector=connector, loglevel=levelname,

                                   ipsource=ipsource, message=message, extra=extra.get('extra', {}))

        # Default Resource Logger

        getattr(self.logger, levelname)(message, extra=extra.get('extra', {}))

    def log_debug(self, message, request=None, **extra):

        self._log('debug', message, request, **extra)

    def log_info(self, message, request=None, **extra):

        self._log('info', message, request, **extra)

    def log_warn(self, message, request=None, **extra):

        self._log('warning', message, request, **extra)

    def log_error(self, message, request=None, **extra):

        self._log('error', message, request, **extra)

class ResourceLog(models.Model):

    timestamp = models.DateTimeField(auto_now_add=True)

    connector = models.CharField(max_length=128, verbose_name='connector')

    loglevel = models.CharField(max_length=16, verbose_name='log level')

    ipsource = models.GenericIPAddressField(blank=True, null=True, unpack_ipv4=True,

                                            verbose_name=_('IP Address'))

    message = models.TextField(max_length=2048, verbose_name='message')

    extra = jsonfield.JSONField(verbose_name='extras', default={})

            'class': 'logging.StreamHandler'

        },

        connector.log_debug('endpoint %s %s (%r) ' %

                               request=request,

from passerelle.base.models import ResourceLog

from passerelle.contrib.arcgis.models import Arcgis

@pytest.fixture

def arcgis(db):

    return utils.setup_access_rights(Arcgis.objects.create(slug='test'))

        # assert record.module == 'views'

@mock.patch('passerelle.utils.LoggedRequest.get')

def test_get_district(mocked_get, caplog, app, arcgis):

    payload = file(os.path.join(os.path.dirname(__file__), 'data', 'nancy_arcgis', 'sigresponse.json')).read()

    mocked_get.return_value = utils.FakedResponse(content=payload, status_code=200)

    resp = app.get('/arcgis/test/district', {'lon': 6.172122, 'lat': 48.673836}, status=200)

    # Resource Custom DB Logger

    log = ResourceLog.objects.first()

    assert log.connector == 'arcgis-test'

    assert log.loglevel == 'debug'

    assert log.ipsource == '127.0.0.1'

    assert log.extra['connector'] == 'arcgis'

    assert log.extra['connector_endpoint'] == 'district'

    assert log.extra['connector_endpoint_method'] == 'GET'

    assert log.extra['connector_endpoint_url'] == '/arcgis/test/district?lat=48.673836&lon=6.172122'

    # Resource Generic Logger

    assert len(caplog.records()) == 1

    for record in caplog.records():

        assert record.levelno == 10

        assert record.levelname == 'DEBUG'

        assert record.name == 'passerelle.resource.arcgis.test'

        assert record.message == u"endpoint GET /arcgis/test/district?lat=48.673836&lon=6.172122 ('') "

    data = resp.json['data']

    assert data['id'] == 4

    assert data['text'] == 'HAUSSONVILLE / BLANDAN / MON DESERT / SAURUPT'