Produits Entr'ouvert » Passerelle

# passerelle - uniform access to multiple data sources and services

# Copyright (C) 2020 Entr'ouvert

#

# This program is free software: you can redistribute it and/or modify it

# under the terms of the GNU Affero General Public License as published

# by the Free Software Foundation, either version 3 of the License, or

# (at your option) any later version.

#

# This program is distributed in the hope that it will be useful,

# but WITHOUT ANY WARRANTY; without even the implied warranty of

# MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the

# GNU Affero General Public License for more details.

#

# You should have received a copy of the GNU Affero General Public License

# along with this program.  If not, see <http://www.gnu.org/licenses/>.

from xml.etree import ElementTree as ET

from django import forms

from django.utils.translation import ugettext_lazy as _

from . import models

class QueryForm(forms.ModelForm):

    class Meta:

        model = models.Query

        widgets = {

            'filter_expression': forms.Textarea(),

        }

        fields = '__all__'

        exclude = ['resource']

    def clean_filter_expression(self):

        filter_expression = self.cleaned_data['filter_expression']

        try:

            ET.fromstring(filter_expression)

        except ET.ParseError:

            raise forms.ValidationError(_('Filter is not valid XML.'))

        return filter_expression

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

# Generated by Django 1.11.18 on 2020-04-01 08:32

from __future__ import unicode_literals

from django.db import migrations, models

import django.db.models.deletion

class Migration(migrations.Migration):

    dependencies = [

        ('opengis', '0006_auto_20181118_0807'),

    ]

    operations = [

        migrations.CreateModel(

            name='Query',

            fields=[

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

                ('name', models.CharField(max_length=128, verbose_name='Name')),

                ('slug', models.SlugField(max_length=128, verbose_name='Slug')),

                ('description', models.TextField(blank=True, verbose_name='Description')),

                ('typename', models.CharField(blank=True, max_length=256, verbose_name='Feature type')),

                ('filter_expression', models.CharField(blank=True, max_length=4096, verbose_name='XML filter')),

            ],

            options={

                'ordering': ['name'],

                'abstract': False,

            },

        ),

        migrations.AlterField(

            model_name='opengis',

            name='projection',

            field=models.CharField(choices=[('EPSG:2154', 'EPSG:2154 (Lambert-93)'), ('EPSG:3857', 'EPSG:3857 (WGS 84 / Pseudo-Mercator)'), ('EPSG:3945', 'EPSG:3945 (CC45)'), ('EPSG:4326', 'EPSG:4326 (WGS 84)')], default='EPSG:3857', max_length=16, verbose_name='GIS projection'),

        ),

        migrations.AddField(

            model_name='query',

            name='resource',

            field=models.ForeignKey(on_delete=django.db.models.deletion.CASCADE, related_name='queries', to='opengis.OpenGIS', verbose_name='Resource'),

        ),

        migrations.AlterUniqueTogether(

            name='query',

            unique_together=set([('resource', 'name'), ('resource', 'slug')]),

        ),

    ]

import copy

from django.shortcuts import get_object_or_404

from django.urls import reverse

from passerelle.base.models import BaseResource, BaseQuery

    def build_get_features_params(self, typename=None, property_name=None, cql_filter=None,

                                  xml_filter=None):

        if property_name:

            params['propertyName'] = property_name

        if xml_filter:

            params['filter'] = xml_filter

                  },

                  'xml_filter': {

                      'description': _('Filter applied to the query'),

                      'example_value': '<Filter><PropertyIsEqualTo><PropertyName>typeparking'

                      '</PropertyName></PropertyIsEqualTo></Filter>'

                 filter_property_name=None, q=None, case_insensitive=False,

                 xml_filter=None, **kwargs):

        params = self.build_get_features_params(type_names, property_name, cql_filter, xml_filter)

            response = response.json()

        for feature in response['features']:

    @endpoint(name='query',

              description=_('Query'),

              pattern=r'^(?P<query_slug>[\w:_-]+)/$',

              perm='can_access',

              show=False)

    def query(self, request, query_slug):

        query = get_object_or_404(Query, resource=self, slug=query_slug)

        return query.q(request)

    def export_json(self):

        d = super(OpenGIS, self).export_json()

        d['queries'] = [query.export_json() for query in self.queries.all()]

        return d

    @classmethod

    def import_json_real(cls, overwrite, instance, d, **kwargs):

        queries = d.pop('queries', [])

        instance = super(OpenGIS, cls).import_json_real(overwrite, instance, d, **kwargs)

        new = []

        if instance and overwrite:

            Query.objects.filter(resource=instance).delete()

        for query in queries:

            q = Query.import_json(query)

            q.resource = instance

            new.append(q)

        Query.objects.bulk_create(new)

        return instance

    def create_query_url(self):

        return reverse('opengis-query-new', kwargs={'slug': self.slug})

class Query(BaseQuery):

    resource = models.ForeignKey(

        to=OpenGIS,

        on_delete=models.CASCADE,

        related_name='queries',

        verbose_name=_('Resource'))

    typename = models.CharField(

        verbose_name=_('Feature type'),

        max_length=256,

        blank=True)

    filter_expression = models.CharField(

        verbose_name=_('XML filter'),

        max_length=4096,

        blank=True)

    delete_view = 'opengis-query-delete'

    edit_view = 'opengis-query-edit'

    def as_endpoint(self):

        resource_endpoint = self.resource.query.endpoint_info

        endpoint = super(Query, self).as_endpoint(path=resource_endpoint.name)

        # use parameters added by resource endpoint

        endpoint.func = resource_endpoint.func

        endpoint.show_undocumented_params = False

        endpoint.parameters = copy.deepcopy(resource_endpoint.parameters)

        return endpoint

    def q(self, request):

        return self.resource.features(request, self.typename, property_name=None,

                             xml_filter=self.filter_expression)

{% extends "passerelle/manage/resource_child_confirm_delete.html" %}

{% extends "passerelle/manage/resource_child_form.html" %}

# passerelle - uniform access to multiple data sources and services

# Copyright (C) 2020 Entr'ouvert

#

# This program is free software: you can redistribute it and/or modify it

# under the terms of the GNU Affero General Public License as published

# by the Free Software Foundation, either version 3 of the License, or

# (at your option) any later version.

#

# This program is distributed in the hope that it will be useful,

# but WITHOUT ANY WARRANTY; without even the implied warranty of

# MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the

# GNU Affero General Public License for more details.

#

# You should have received a copy of the GNU Affero General Public License

# along with this program.  If not, see <http://www.gnu.org/licenses/>.

from django.conf.urls import url

from . import views

management_urlpatterns = [

    url(r'^(?P<slug>[\w,-]+)/query/new/$',

        views.QueryNew.as_view(), name='opengis-query-new'),

    url(r'^(?P<slug>[\w,-]+)/query/(?P<pk>\d+)/$',

        views.QueryEdit.as_view(), name='opengis-query-edit'),

    url(r'^(?P<slug>[\w,-]+)/query/(?P<pk>\d+)/delete/$',

        views.QueryDelete.as_view(), name='opengis-query-delete'),

]

# passerelle - uniform access to multiple data sources and services

# Copyright (C) 2020 Entr'ouvert

#

# This program is free software: you can redistribute it and/or modify it

# under the terms of the GNU Affero General Public License as published

# by the Free Software Foundation, either version 3 of the License, or

# (at your option) any later version.

#

# This program is distributed in the hope that it will be useful,

# but WITHOUT ANY WARRANTY; without even the implied warranty of

# MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the

# GNU Affero General Public License for more details.

#

# You should have received a copy of the GNU Affero General Public License

# along with this program.  If not, see <http://www.gnu.org/licenses/>.

from django.views.generic import UpdateView, CreateView, DeleteView

from passerelle.base.mixins import ResourceChildViewMixin

from . import models

from .forms import QueryForm

class QueryNew(ResourceChildViewMixin, CreateView):

    model = models.Query

    form_class = QueryForm

    def form_valid(self, form):

        form.instance.resource = self.resource

        return super(QueryNew, self).form_valid(form)

    def get_changed_url(self):

        return self.object.get_absolute_url()

class QueryEdit(ResourceChildViewMixin, UpdateView):

    model = models.Query

    form_class = QueryForm

class QueryDelete(ResourceChildViewMixin, DeleteView):

    model = models.Query