from django.core.exceptions import ValidationError from django.utils.translation import ugettext_lazy as _ from rest_framework.decorators import action from rest_framework.response import Response from rest_framework.viewsets import ViewSet from c3nav.mapdata.api import api_stats_clean_location_value from c3nav.mapdata.models.access import AccessPermission from c3nav.mapdata.utils.cache.stats import increment_cache_key from c3nav.mapdata.utils.locations import visible_locations_for_request from c3nav.routing.exceptions import LocationUnreachable, NoRouteFound, NotYetRoutable from c3nav.routing.forms import RouteForm from c3nav.routing.locator import Locator from c3nav.routing.models import RouteOptions from c3nav.routing.router import Router class RoutingViewSet(ViewSet): """ /route/ Get routes. /options/ Get or set route options. /locate/ Wifi locate. """ @action(detail=False, methods=['get', 'post']) def route(self, request, *args, **kwargs): params = request.POST if request.method == 'POST' else request.GET form = RouteForm(params, request=request) if not form.is_valid(): return Response({ 'errors': form.errors, }, status=400) options = RouteOptions.get_for_request(request) try: options.update(params, ignore_unknown=True) except ValidationError as e: return Response({ 'errors': (str(e), ), }, status=400) try: route = Router.load().get_route(origin=form.cleaned_data['origin'], destination=form.cleaned_data['destination'], permissions=AccessPermission.get_for_request(request), options=options) except NotYetRoutable: return Response({ 'error': _('Not yet routable, try again shortly.'), }) except LocationUnreachable: return Response({ 'error': _('Unreachable location.'), }) except NoRouteFound: return Response({ 'error': _('No route found.'), }) origin_values = api_stats_clean_location_value(form.cleaned_data['origin'].pk) destination_values = api_stats_clean_location_value(form.cleaned_data['destination'].pk) increment_cache_key('apistats__route') for origin_value in origin_values: for destination_value in destination_values: increment_cache_key('apistats__route_tuple_%s_%s' % (origin_value, destination_value)) for value in origin_values: increment_cache_key('apistats__route_origin_%s' % value) for value in destination_values: increment_cache_key('apistats__route_destination_%s' % value) return Response({ 'request': { 'origin': form.cleaned_data['origin'].pk, 'destination': form.cleaned_data['destination'].pk, }, 'options': options.serialize(), 'result': route.serialize(locations=visible_locations_for_request(request)), }) @action(detail=False, methods=['get', 'post']) def options(self, request, *args, **kwargs): options = RouteOptions.get_for_request(request) if request.method == 'POST': try: options.update(request.POST, ignore_unknown=True) except ValidationError as e: return Response({ 'errors': (str(e),), }, status=400) options.save() return Response(options.serialize()) @action(detail=False, methods=('POST', )) def locate(self, request, *args, **kwargs): try: location = Locator.load().locate(request.data, permissions=AccessPermission.get_for_request(request)) increment_cache_key('apistats__locate__%s' % location.pk) except ValidationError: return Response({ 'errors': (_('Invalid scan data.'),), }, status=400) return Response({'location': None if location is None else location.serialize(simple_geometry=True)})