Produits Entr'ouvert » Passerelle

# passerelle - uniform access to multiple data sources and services

# Copyright (C) 2016 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 import forms

from .models import FeatureQuery

class FeatureQueryForm(forms.ModelForm):

    class Meta:

        model = FeatureQuery

        widgets = {

            'resource': forms.HiddenInput(),

            'query_filters': forms.Textarea(attrs={'rows': 2}),

            'response_filters': forms.Textarea(attrs={'rows': 2}),

        }

        fields = '__all__'

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

from __future__ import unicode_literals

from django.db import migrations, models

class Migration(migrations.Migration):

    dependencies = [

        ('opengis', '0002_auto_20171129_1814'),

    ]

    operations = [

        migrations.CreateModel(

            name='FeatureQuery',

            fields=[

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

                ('slug', models.SlugField(verbose_name='Name (slug)')),

                ('label', models.CharField(max_length=100, verbose_name='Label')),

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

                ('query_filters', models.TextField(help_text='List of filters (name:expression)', verbose_name='Query Filters', blank=True)),

                ('response_filters', models.TextField(help_text='List of filters (name:expression)', verbose_name='Response Filters', blank=True)),

            ],

            options={

                'ordering': ['slug'],

            },

        ),

        migrations.AddField(

            model_name='featurequery',

            name='resource',

            field=models.ForeignKey(to='opengis.OpenGIS'),

        ),

    ]

class FeatureQuery(models.Model):

    resource = models.ForeignKey('OpenGIS')

    slug = models.SlugField(_('Name (slug)'))

    label = models.CharField(_('Label'), max_length=100)

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

    query_filters = models.TextField(_('Query Filters'), blank=True,

            help_text=_('List of filters (name:expression)'))

    response_filters = models.TextField(_('Response Filters'), blank=True,

            help_text=_('List of filters (name:expression)'))

    class Meta:

        ordering = ['slug']

    def get_list(self, attribute):

        if not getattr(self, attribute):

            return []

        return getattr(self, attribute).strip().splitlines()

    def process_query_filters(self, params):

        filters = {}

        for filter_line in self.get_list('query_filters'):

            name, value = filter_line.split(':', 1)

            filters[name] = eval(value.strip(), {}, params)

        return filters

    def process_response_filters(self, features):

        filters = self.get_list('response_filters')

        if not filters:

            return features

        result = []

        for feature in features:

            filtered_feature = {}

            for line in filters:

                name, value = line.split(':', 1)

                filtered_feature[name] = eval(value.strip(), {}, feature)

            result.append(filtered_feature)

        return result

    @endpoint(perm='can_access', methods=['get'],

              name='feature', pattern='^(?P<query_name>[\w-]+)/$')

    def feature_query(self, request, query_name, **kwargs):

        try:

            query = FeatureQuery.objects.get(resource=self.id, slug=query_name)

        except Query.DoesNotExist:

            raise APIError(u'no such query')

        params = {

            'VERSION': self.get_wfs_service_version(),

            'SERVICE': 'WFS',

            'REQUEST': 'GetFeature',

            'OUTPUTFORMAT': 'json',

        }

        params.update(query.process_query_filters(request.GET.dict()))

        response = self.requests.get(self.wfs_service_url, params=params)

        data = query.process_response_filters(response.json()['features'])

        return {'data': data}

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

{% load i18n %}

{% block breadcrumb %}

{{ block.super }}

<a href="{{ resource.get_absolute_url }}">{{ resource.title }}</a>

<a href="{{ object.id }}">{{ object.slug }}</a>

{% endblock %}

{% block appbar %}

<h2>{% trans 'Feature Query:' %} {{ object.slug }}</h2>

{% endblock %}

{% block content %}

<form method="post">

  {% csrf_token %}

  <p>{% blocktrans %}Are you sure you want to delete this feature query?{% endblocktrans %}</p>

  <div class="buttons">

    <button class="delete-button">{% trans 'Delete' %}</button>

    <a href="{{ resource.get_absolute_url }}" class="cancel">{% trans 'Cancel' %}</a>

  </div>

</form>

{% endblock %}

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

{% load i18n %}

{% block breadcrumb %}

{{ block.super }}

<a href="{{ resource.get_absolute_url }}">{{ resource.title }}</a>

{% if object.id %}

<a href="{{ object.id }}">{{ object.slug }}</a>

{% else %}

<a href="#">{% trans 'Add Feature Query' %}</a>

{% endif %}

{% endblock %}

{% block appbar %}

<h2>{% if object.id %}{% trans 'Feature Query:' %} {{ object.slug }}{% else %}{% trans 'New Feature Query' %}{% endif %}</h2>

{% endblock %}

{% block content %}

 <form method="post" enctype="multipart/form-data">

   <div id="form-content">

     {% csrf_token %}

     {{ form.as_p }}

   </div>

   {% block buttons %}

   <div class="buttons">

     <button class="submit-button">{% trans "Save" %}</button>

     <a class="cancel" href="{{ resource.get_absolute_url }}">{% trans 'Cancel' %}</a>

   </div>

   {% endblock %}

 </form>

{% endblock %}

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

{% load i18n passerelle %}

{% block endpoints %}

{{ block.super }}

<ul>

  {% for query in object.featurequery_set.all %}

  <li>{{ query.label }}:

    {% url 'generic-endpoint' connector='opengis' slug=object.slug endpoint='feature' rest=query.slug as query_url %}

    <a href="{{ query_url }}/">{{ query_url }}/</a>

    {% if query.description %}— {{ query.description }}{% endif %}

  </li>

  {% endfor %}

  </ul>

{% if object|can_edit:request.user %}

<div id="queries">

<h3>{% trans 'Feature queries' %}</h3>

<div>

{% if object.featurequery_set.count %}

<ul class="objects-list single-links">

{% for query in object.featurequery_set.all %}

  <li><a href="{% url 'opengis-edit-featurequery' connector_slug=object.slug pk=query.id %}">{{ query.slug }}</a>

      <a rel="popup" class="delete" href="{% url 'opengis-delete-featurequery' connector_slug=object.slug pk=query.id %}">{% trans "delete query" %}</a>

  </li>

{% endfor %}

</ul>

{% else %}

<p>{% trans 'No feature queries are defined.' %}</p>

{% endif %}

<p>

<a class="icon-plus button" href="{% url 'opengis-new-featurequery' connector_slug=object.slug %}">{% trans 'New Feature Query' %}</a>

</p>

</div>

</div>

{% endif %}

{% endblock %}

# passerelle - uniform access to multiple data sources and services

# Copyright (C) 2017 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 .views import *

management_urlpatterns = [

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

        NewFeatureQueryView.as_view(), name='opengis-new-featurequery'),

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

        UpdateFeatureQueryView.as_view(), name='opengis-edit-featurequery'),

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

        DeleteFeatureQueryView.as_view(), name='opengis-delete-featurequery'),

]

# passerelle - uniform access to multiple data sources and services

# Copyright (C) 2017 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 .forms import FeatureQueryForm

from .models import OpenGIS, FeatureQuery

class FeatureQueryView(object):

    model = FeatureQuery

    def get_success_url(self):

        return self.object.resource.get_absolute_url()

    def get_context_data(self, **kwargs):

        ctx = super(FeatureQueryView, self).get_context_data(**kwargs)

        ctx['resource'] = OpenGIS.objects.get(slug=self.kwargs['connector_slug'])

        return ctx

class NewFeatureQueryView(FeatureQueryView, CreateView):

    form_class = FeatureQueryForm

    template_name = 'opengis/featurequery_form.html'

    def get_context_data(self, **kwargs):

        ctx = super(NewFeatureQueryView, self).get_context_data(**kwargs)

        ctx['resource'] = OpenGIS.objects.get(slug=self.kwargs['connector_slug'])

        return ctx

    def get_initial(self):

        return {'resource': OpenGIS.objects.get(slug=self.kwargs['connector_slug']).id}

class UpdateFeatureQueryView(FeatureQueryView, UpdateView):

    form_class = FeatureQueryForm

    template_name = 'opengis/featurequery_form.html'

    def get_context_data(self, **kwargs):

        ctx = super(UpdateFeatureQueryView, self).get_context_data(**kwargs)

        ctx['resource'] = OpenGIS.objects.get(slug=self.kwargs['connector_slug'])

        return ctx

class DeleteFeatureQueryView(FeatureQueryView, DeleteView):

    pass