views.py 3.2 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172
  1. from django.db.models import ObjectDoesNotExist
  2. from django.urls.exceptions import Http404
  3. from rest_framework import viewsets, views
  4. from rest_framework.exceptions import PermissionDenied
  5. from rest_framework.response import Response
  6. from .models import ProgrammedReport
  7. from .serializers import ProgrammedReportSerializer
  8. from .permissions import IsOmixomUser
  9. from rest_framework import status
  10. # API de Programmed Reports:
  11. # Requisitos:
  12. # - Especificar el TOKEN del usuario en el HTTP Header "AUTHORIZATION".
  13. # - Las requests deben ser JSON.
  14. # - No es necesario enviar el field user_id, esto es seteado automaticamente al recibir el TOKEN.
  15. # Endpoints: (BASE_URL: /api/preports)
  16. # - (List) GET / -> Obtener la lista de todos los Programmed Report
  17. # - (Create) POST / -> Crear un nuevo Programmed Report
  18. # - (Retrieve) GET /{id}/ -> Obtener la informacion de un Programmed Report
  19. # - (Update) PUT /{id}/ -> Actualizar un Programmed Report (requiere todos los fields)
  20. # - (Partial_Update) PATCH /{id}/ -> Actualizar algunos fields de un Programmed Report
  21. # - (Delete) DELETE /{id}/ -> Elimina un Programmed Report
  22. class SendReportNow(views.APIView):
  23. permission_classes = [IsOmixomUser]
  24. def get(self, request, pk):
  25. """
  26. Send report right now, regardless of if it should be sent.
  27. """
  28. user_id = request.data["user_id"]
  29. try:
  30. preport: ProgrammedReport = ProgrammedReport.objects.get(pk=pk)
  31. except ObjectDoesNotExist:
  32. raise Http404
  33. if(int(preport.user_id) != int(user_id)):
  34. raise PermissionDenied(f"Su usuario no es dueño de este reporte({preport.user_id} != {user_id})")
  35. sent = preport.send_report_now()
  36. print("Se envio" if sent else "No se pudo enviar","el Programmed Report ID:", preport.id)
  37. if not sent:
  38. return Response("Error al comunicarse con clima", status.HTTP_500_INTERNAL_SERVER_ERROR)
  39. return Response("Ok", status.HTTP_200_OK)
  40. class ProgrammedReportViewSet(viewsets.ModelViewSet):
  41. # El ViewSet solo es valido si el Token enviado es de un usuario de Omixom.
  42. permission_classes = [IsOmixomUser]
  43. serializer_class = ProgrammedReportSerializer
  44. # Solo se devuelven los modelos para el user_id asociado al token. (Ver IsOmixomUser)
  45. def get_queryset(self):
  46. user_id = self.request.data["user_id"]
  47. qs = ProgrammedReport.objects.filter(user_id=user_id)
  48. return qs
  49. # Endpoint para la confirmacion de envio de un reporte programado por parte de Clima:
  50. # Por el momento no es usado:
  51. # class ProgrammedReportSentConfirmation(views.APIView):
  52. # parser_classes = [JSONParser]
  53. # def post(self, request, format=None):
  54. # if(settings.PROGRAMMED_REPORTS_SERVICE_AUTH_TOKEN != request.META.get("HTTP_AUTHORIZATION")):
  55. # return Response("Invalid Access Credentials.", status.HTTP_403_FORBIDDEN)
  56. # report = ProgrammedReport.objects.filter(id=request.data.get("id")).first()
  57. # if report is None:
  58. # return Response("Invalid Report.", status.HTTP_400_BAD_REQUEST)
  59. # report.last_report_date = timezone.now()
  60. # report.save()
  61. # return Response("Ok", status.HTTP_200_OK)