Dirk Vogt | 62ff7f2 | 2017-05-04 16:07:21 +0200 | [diff] [blame] | 1 | from rest_framework import generics |
| 2 | from rest_framework import serializers |
| 3 | from rest_framework.response import Response |
| 4 | from rest_framework.views import APIView |
Borjan Tchakaloff | fa134bd | 2018-04-09 16:16:11 +0200 | [diff] [blame] | 5 | from crashreports.permissions import ( |
| 6 | HasRightsOrIsDeviceOwnerDeviceCreation, HasStatsAccess) |
Dirk Vogt | 62ff7f2 | 2017-05-04 16:07:21 +0200 | [diff] [blame] | 7 | from django.db import connection |
| 8 | from . import raw_querys |
Dirk Vogt | 1accb67 | 2017-05-10 14:07:42 +0200 | [diff] [blame] | 9 | from crashreport_stats.models import * |
Dirk Vogt | 62ff7f2 | 2017-05-04 16:07:21 +0200 | [diff] [blame] | 10 | import zipfile |
| 11 | from crashreports.models import * |
Dirk Vogt | 1accb67 | 2017-05-10 14:07:42 +0200 | [diff] [blame] | 12 | from django.db.models.expressions import F |
| 13 | import django_filters |
| 14 | from rest_framework import filters |
Dirk Vogt | 62ff7f2 | 2017-05-04 16:07:21 +0200 | [diff] [blame] | 15 | |
| 16 | def dictfetchall(cursor): |
| 17 | "Returns all rows from a cursor as a dict" |
| 18 | desc = cursor.description |
| 19 | return [ |
| 20 | dict(zip([col[0] for col in desc], row)) |
| 21 | for row in cursor.fetchall() |
| 22 | ] |
| 23 | |
| 24 | class DeviceUpdateHistory(APIView): |
| 25 | permission_classes = (HasRightsOrIsDeviceOwnerDeviceCreation, ) |
| 26 | def get(self, request, uuid, format=None): |
| 27 | cursor = connection.cursor() |
| 28 | raw_querys.execute_device_update_history_query( |
| 29 | cursor, |
| 30 | { |
| 31 | 'uuid': uuid |
| 32 | }) |
| 33 | res = dictfetchall(cursor) |
| 34 | return Response(res) |
| 35 | |
| 36 | class DeviceReportHistory(APIView): |
| 37 | permission_classes = (HasRightsOrIsDeviceOwnerDeviceCreation, ) |
| 38 | def get(self, request, uuid, format=None): |
| 39 | cursor = connection.cursor() |
| 40 | raw_querys.execute_device_report_history( |
| 41 | cursor, |
| 42 | { |
| 43 | 'uuid': uuid |
| 44 | }) |
| 45 | res = dictfetchall(cursor) |
| 46 | return Response(res) |
| 47 | |
Dirk Vogt | 571168c | 2017-12-08 16:54:12 +0100 | [diff] [blame] | 48 | class Status(APIView): |
Borjan Tchakaloff | fa134bd | 2018-04-09 16:16:11 +0200 | [diff] [blame] | 49 | permission_classes = (HasStatsAccess,) |
Dirk Vogt | 571168c | 2017-12-08 16:54:12 +0100 | [diff] [blame] | 50 | def get(self, request, format=None, ): |
| 51 | num_devices = Device.objects.count() |
| 52 | num_crashreports = Crashreport.objects.count() |
| 53 | num_heartbeats = HeartBeat.objects.count() |
| 54 | return Response( { |
| 55 | 'devices': num_devices, |
| 56 | 'crashreports': num_crashreports, |
| 57 | 'heartbeats': num_heartbeats |
| 58 | }) |
| 59 | |
Dirk Vogt | 62ff7f2 | 2017-05-04 16:07:21 +0200 | [diff] [blame] | 60 | class DeviceStat(APIView): |
| 61 | permission_classes = (HasRightsOrIsDeviceOwnerDeviceCreation, ) |
| 62 | def get(self, request, uuid, format=None, ): |
| 63 | device = Device.objects.filter(uuid=uuid) |
| 64 | last_active = HeartBeat.objects.filter(device=device).order_by('-date')[0].date |
| 65 | heartbeats = HeartBeat.objects.filter(device=device).count() |
Franz-Xaver Geiger | 0b3a48e | 2018-04-16 15:00:14 +0200 | [diff] [blame] | 66 | crashreports = Crashreport.objects.filter(device=device).filter(boot_reason__in=Crashreport.CRASH_BOOT_REASONS).count() |
Dirk Vogt | 62ff7f2 | 2017-05-04 16:07:21 +0200 | [diff] [blame] | 67 | crashes_per_day = crashreports*1.0/heartbeats if heartbeats > 0 else 0 |
Franz-Xaver Geiger | 0b3a48e | 2018-04-16 15:00:14 +0200 | [diff] [blame] | 68 | smpls = Crashreport.objects.filter(device=device).filter(boot_reason__in=Crashreport.SMPL_BOOT_REASONS).count() |
Dirk Vogt | 62ff7f2 | 2017-05-04 16:07:21 +0200 | [diff] [blame] | 69 | smpl_per_day = smpls*1.0/heartbeats if heartbeats > 0 else 0 |
| 70 | return Response( |
| 71 | { |
| 72 | 'uuid' : uuid, |
| 73 | 'last_active' : last_active, |
| 74 | 'heartbeats' : heartbeats, |
| 75 | 'crashreports' : crashreports, |
| 76 | 'crashes_per_day' : crashes_per_day, |
| 77 | 'smpls' : smpls, |
Dirk Vogt | 7439ee7 | 2017-12-05 15:51:17 +0100 | [diff] [blame] | 78 | 'smpl_per_day' : smpl_per_day, |
| 79 | 'board_date' : device[0].board_date, |
Dirk Vogt | 62ff7f2 | 2017-05-04 16:07:21 +0200 | [diff] [blame] | 80 | }) |
| 81 | |
| 82 | class LogFileDownload(APIView): |
| 83 | permission_classes = (HasRightsOrIsDeviceOwnerDeviceCreation, ) |
| 84 | def get(self, request, id, format=None): |
| 85 | try: |
| 86 | logfile = LogFile.objects.get(id=id) |
| 87 | except: |
| 88 | raise NotFound(detail="Logfile does not exist.") |
| 89 | zf = zipfile.ZipFile(logfile.logfile.path) |
| 90 | ret = {} |
| 91 | for f in zf.filelist: |
| 92 | fo = zf.open(f) |
| 93 | ret[f.filename] = fo.read() |
| 94 | return Response(ret) |
Dirk Vogt | 1accb67 | 2017-05-10 14:07:42 +0200 | [diff] [blame] | 95 | |
Borjan Tchakaloff | 227b431 | 2018-02-23 17:02:16 +0400 | [diff] [blame] | 96 | |
| 97 | class _VersionStatsFilter(filters.FilterSet): |
Dirk Vogt | 1accb67 | 2017-05-10 14:07:42 +0200 | [diff] [blame] | 98 | first_seen_before = django_filters.DateFilter(name="first_seen_on", lookup_expr='lte') |
Borjan Tchakaloff | 227b431 | 2018-02-23 17:02:16 +0400 | [diff] [blame] | 99 | first_seen_after = django_filters.DateFilter(name="first_seen_on", lookup_expr='gte') |
Dirk Vogt | 1accb67 | 2017-05-10 14:07:42 +0200 | [diff] [blame] | 100 | released_before = django_filters.DateFilter(name="released_on", lookup_expr='lte') |
Borjan Tchakaloff | 227b431 | 2018-02-23 17:02:16 +0400 | [diff] [blame] | 101 | released_after = django_filters.DateFilter(name="released_on", lookup_expr='gte') |
Dirk Vogt | 1accb67 | 2017-05-10 14:07:42 +0200 | [diff] [blame] | 102 | |
Borjan Tchakaloff | 227b431 | 2018-02-23 17:02:16 +0400 | [diff] [blame] | 103 | class _VersionStatsSerializer(serializers.ModelSerializer): |
Borjan Tchakaloff | fa134bd | 2018-04-09 16:16:11 +0200 | [diff] [blame] | 104 | permission_classes = (HasStatsAccess,) |
Dirk Vogt | 1accb67 | 2017-05-10 14:07:42 +0200 | [diff] [blame] | 105 | |
Borjan Tchakaloff | 227b431 | 2018-02-23 17:02:16 +0400 | [diff] [blame] | 106 | class _VersionStatsListView(generics.ListAPIView): |
Borjan Tchakaloff | fa134bd | 2018-04-09 16:16:11 +0200 | [diff] [blame] | 107 | permission_classes = (HasStatsAccess,) |
Dirk Vogt | 1accb67 | 2017-05-10 14:07:42 +0200 | [diff] [blame] | 108 | filter_backends = (filters.DjangoFilterBackend,) |
Dirk Vogt | 1accb67 | 2017-05-10 14:07:42 +0200 | [diff] [blame] | 109 | |
Borjan Tchakaloff | 227b431 | 2018-02-23 17:02:16 +0400 | [diff] [blame] | 110 | class _DailyVersionStatsFilter(filters.FilterSet): |
Dirk Vogt | 1accb67 | 2017-05-10 14:07:42 +0200 | [diff] [blame] | 111 | date_start = django_filters.DateFilter(name="date", lookup_expr='gte') |
Borjan Tchakaloff | 227b431 | 2018-02-23 17:02:16 +0400 | [diff] [blame] | 112 | date_end = django_filters.DateFilter(name="date", lookup_expr='lte') |
| 113 | |
| 114 | class _DailyVersionStatsSerializer(serializers.ModelSerializer): |
Borjan Tchakaloff | fa134bd | 2018-04-09 16:16:11 +0200 | [diff] [blame] | 115 | permission_classes = (HasStatsAccess,) |
Borjan Tchakaloff | 227b431 | 2018-02-23 17:02:16 +0400 | [diff] [blame] | 116 | |
| 117 | class _DailyVersionStatsListView(generics.ListAPIView): |
Borjan Tchakaloff | fa134bd | 2018-04-09 16:16:11 +0200 | [diff] [blame] | 118 | permission_classes = (HasStatsAccess,) |
Borjan Tchakaloff | 227b431 | 2018-02-23 17:02:16 +0400 | [diff] [blame] | 119 | filter_backends = (filters.DjangoFilterBackend,) |
| 120 | |
| 121 | |
| 122 | class VersionSerializer(_VersionStatsSerializer): |
| 123 | class Meta: |
| 124 | model = Version |
| 125 | fields = '__all__' |
| 126 | |
| 127 | class VersionFilter(_VersionStatsFilter): |
| 128 | class Meta: |
| 129 | model = Version |
| 130 | fields = '__all__' |
| 131 | |
| 132 | class VersionListView(_VersionStatsListView): |
| 133 | queryset = Version.objects.all().order_by('-heartbeats') |
| 134 | filter_class = VersionFilter |
| 135 | serializer_class = VersionSerializer |
| 136 | |
| 137 | class VersionDailyFilter(_DailyVersionStatsFilter): |
Dirk Vogt | 1accb67 | 2017-05-10 14:07:42 +0200 | [diff] [blame] | 138 | version__build_fingerprint = django_filters.CharFilter() |
| 139 | version__is_official_release = django_filters.BooleanFilter() |
| 140 | version__is_beta_release = django_filters.BooleanFilter() |
Borjan Tchakaloff | 227b431 | 2018-02-23 17:02:16 +0400 | [diff] [blame] | 141 | |
Dirk Vogt | 1accb67 | 2017-05-10 14:07:42 +0200 | [diff] [blame] | 142 | class Meta: |
| 143 | model = VersionDaily |
Borjan Tchakaloff | 227b431 | 2018-02-23 17:02:16 +0400 | [diff] [blame] | 144 | fields = '__all__' |
Dirk Vogt | 1accb67 | 2017-05-10 14:07:42 +0200 | [diff] [blame] | 145 | |
Borjan Tchakaloff | 227b431 | 2018-02-23 17:02:16 +0400 | [diff] [blame] | 146 | class VersionDailySerializer(_DailyVersionStatsSerializer): |
| 147 | build_fingerprint = serializers.CharField() |
| 148 | |
Dirk Vogt | 1accb67 | 2017-05-10 14:07:42 +0200 | [diff] [blame] | 149 | class Meta: |
| 150 | model = VersionDaily |
Borjan Tchakaloff | 227b431 | 2018-02-23 17:02:16 +0400 | [diff] [blame] | 151 | fields = '__all__' |
Dirk Vogt | 1accb67 | 2017-05-10 14:07:42 +0200 | [diff] [blame] | 152 | |
Borjan Tchakaloff | 227b431 | 2018-02-23 17:02:16 +0400 | [diff] [blame] | 153 | class VersionDailyListView(_DailyVersionStatsListView): |
| 154 | queryset = ( |
| 155 | VersionDaily.objects |
| 156 | .annotate(build_fingerprint=F('version__build_fingerprint')) |
| 157 | .all() |
| 158 | .order_by('date') |
| 159 | ) |
| 160 | filter_class = VersionDailyFilter |
| 161 | filter_fields = ( |
| 162 | 'version__build_fingerprint', |
| 163 | 'version__is_official_release', |
| 164 | 'version__is_beta_release', |
| 165 | ) |
Dirk Vogt | 1accb67 | 2017-05-10 14:07:42 +0200 | [diff] [blame] | 166 | serializer_class = VersionDailySerializer |
Borjan Tchakaloff | 1db45c7 | 2018-02-23 17:03:49 +0400 | [diff] [blame] | 167 | |
| 168 | |
| 169 | class RadioVersionSerializer(_VersionStatsSerializer): |
| 170 | class Meta: |
| 171 | model = RadioVersion |
| 172 | fields = '__all__' |
| 173 | |
| 174 | class RadioVersionFilter(_VersionStatsFilter): |
| 175 | class Meta: |
| 176 | model = RadioVersion |
| 177 | fields = '__all__' |
| 178 | |
| 179 | class RadioVersionListView(_VersionStatsListView): |
| 180 | queryset = RadioVersion.objects.all().order_by('-heartbeats') |
| 181 | serializer_class = RadioVersionSerializer |
| 182 | filter_class = RadioVersionFilter |
| 183 | |
| 184 | class RadioVersionDailyFilter(_DailyVersionStatsFilter): |
| 185 | version__radio_version = django_filters.CharFilter() |
| 186 | version__is_official_release = django_filters.BooleanFilter() |
| 187 | version__is_beta_release = django_filters.BooleanFilter() |
| 188 | |
| 189 | class Meta: |
| 190 | model = RadioVersionDaily |
| 191 | fields = '__all__' |
| 192 | |
| 193 | class RadioVersionDailySerializer(_DailyVersionStatsSerializer): |
| 194 | radio_version = serializers.CharField() |
| 195 | |
| 196 | class Meta: |
| 197 | model = RadioVersionDaily |
| 198 | fields = '__all__' |
| 199 | |
| 200 | class RadioVersionDailyListView(_DailyVersionStatsListView): |
| 201 | queryset = ( |
| 202 | RadioVersionDaily.objects |
| 203 | .annotate(radio_version=F('version__radio_version')) |
| 204 | .all() |
| 205 | .order_by('date') |
| 206 | ) |
| 207 | filter_class = RadioVersionDailyFilter |
| 208 | filter_fields = ( |
| 209 | 'version__radio_version', |
| 210 | 'version__is_official_release', |
| 211 | 'version__is_beta_release', |
| 212 | ) |
| 213 | serializer_class = RadioVersionDailySerializer |