views.py 30 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478479480481482483484485486487488489490491492493494495496497498499500501502503504505506507508509510511512513514515516517518519520521522523524525526527528529530531532533534535536537538539540541542543544545546547548549550551552553554555556557558559560561562563564565566567568569570571572573574575576577578579580581582583584585586587588589590591592593594595596597598599600601602603604605606607608609610611612613614615616617618619620621622623624625626627628629630631632633634635636637638639640641642643644645646647648649650651652653654655656657658659660661662663664665666667668669670671672673674675676677678679680681682683684685686687688689690691692693694695696697698699700701702703704705706707708709710711712713714715716717718719720721722723724725726727728729730731732733734735736737738739740741742743744745746747748749
  1. import base64
  2. import binascii
  3. from datetime import timedelta
  4. from functools import cached_property
  5. from django.conf import settings
  6. from django.contrib.auth import user_logged_in
  7. from django.contrib.auth.hashers import is_password_usable
  8. from django.core.cache import cache
  9. from django.core.mail import EmailMessage
  10. from django.http import Http404
  11. from django.shortcuts import redirect
  12. from django.template.loader import get_template
  13. from rest_framework import generics, mixins, status, viewsets
  14. from rest_framework.authentication import get_authorization_header
  15. from rest_framework.exceptions import (NotAcceptable, NotFound, PermissionDenied, ValidationError)
  16. from rest_framework.permissions import IsAuthenticated, SAFE_METHODS
  17. from rest_framework.renderers import JSONRenderer, StaticHTMLRenderer
  18. from rest_framework.response import Response
  19. from rest_framework.reverse import reverse
  20. from rest_framework.views import APIView
  21. import desecapi.authentication as auth
  22. from desecapi import metrics, models, serializers
  23. from desecapi.exceptions import ConcurrencyException
  24. from desecapi.pdns import get_serials
  25. from desecapi.pdns_change_tracker import PDNSChangeTracker
  26. from desecapi.permissions import ManageTokensPermission, IsDomainOwner, IsOwner, IsVPNClient, WithinDomainLimitOnPOST
  27. from desecapi.renderers import PlainTextRenderer
  28. def generate_confirmation_link(request, action_serializer, viewname, **kwargs):
  29. action = action_serializer.Meta.model(**kwargs)
  30. action_data = action_serializer(action).data
  31. confirmation_link = reverse(viewname, request=request, args=[action_data['code']])
  32. return confirmation_link, action_serializer.validity_period
  33. class EmptyPayloadMixin:
  34. def initialize_request(self, request, *args, **kwargs):
  35. request = super().initialize_request(request, *args, **kwargs)
  36. try:
  37. no_data = request.stream is None
  38. except:
  39. no_data = True
  40. if no_data:
  41. # In this case, data and files are both empty, so we can set request.data=None (instead of the default {}).
  42. # This allows distinguishing missing payload from empty dict payload.
  43. # See https://github.com/encode/django-rest-framework/pull/7195
  44. request._full_data = None
  45. return request
  46. class IdempotentDestroyMixin:
  47. def destroy(self, request, *args, **kwargs):
  48. try:
  49. # noinspection PyUnresolvedReferences
  50. super().destroy(request, *args, **kwargs)
  51. except Http404:
  52. pass
  53. return Response(status=status.HTTP_204_NO_CONTENT)
  54. class DomainViewMixin:
  55. def get_serializer_context(self):
  56. return {**super().get_serializer_context(), 'domain': self.domain}
  57. def initial(self, request, *args, **kwargs):
  58. # noinspection PyUnresolvedReferences
  59. super().initial(request, *args, **kwargs)
  60. try:
  61. # noinspection PyAttributeOutsideInit, PyUnresolvedReferences
  62. self.domain = self.request.user.domains.get(name=self.kwargs['name'])
  63. except models.Domain.DoesNotExist:
  64. raise Http404
  65. class TokenViewSet(IdempotentDestroyMixin, viewsets.ModelViewSet):
  66. serializer_class = serializers.TokenSerializer
  67. permission_classes = (IsAuthenticated, ManageTokensPermission,)
  68. throttle_scope = 'account_management_passive'
  69. def get_queryset(self):
  70. return self.request.user.auth_tokens.all()
  71. def get_serializer(self, *args, **kwargs):
  72. # When creating a new token, return the plaintext representation
  73. if self.request.method == 'POST':
  74. kwargs.setdefault('include_plain', True)
  75. return super().get_serializer(*args, **kwargs)
  76. def perform_create(self, serializer):
  77. serializer.save(user=self.request.user)
  78. class DomainViewSet(IdempotentDestroyMixin,
  79. mixins.CreateModelMixin,
  80. mixins.RetrieveModelMixin,
  81. mixins.DestroyModelMixin,
  82. mixins.ListModelMixin,
  83. viewsets.GenericViewSet):
  84. serializer_class = serializers.DomainSerializer
  85. permission_classes = (IsAuthenticated, IsOwner, WithinDomainLimitOnPOST)
  86. lookup_field = 'name'
  87. lookup_value_regex = r'[^/]+'
  88. @property
  89. def throttle_scope(self):
  90. return 'dns_api_read' if self.request.method in SAFE_METHODS else 'dns_api_write'
  91. def get_queryset(self):
  92. return self.request.user.domains
  93. def get_serializer(self, *args, **kwargs):
  94. include_keys = (self.action in ['create', 'retrieve'])
  95. return super().get_serializer(*args, include_keys=include_keys, **kwargs)
  96. def perform_create(self, serializer):
  97. with PDNSChangeTracker():
  98. domain = serializer.save(owner=self.request.user)
  99. # TODO this line raises if the local public suffix is not in our database!
  100. PDNSChangeTracker.track(lambda: self.auto_delegate(domain))
  101. @staticmethod
  102. def auto_delegate(domain: models.Domain):
  103. if domain.is_locally_registrable:
  104. parent_domain = models.Domain.objects.get(name=domain.parent_domain_name)
  105. parent_domain.update_delegation(domain)
  106. def perform_destroy(self, instance: models.Domain):
  107. with PDNSChangeTracker():
  108. instance.delete()
  109. if instance.is_locally_registrable:
  110. parent_domain = models.Domain.objects.get(name=instance.parent_domain_name)
  111. with PDNSChangeTracker():
  112. parent_domain.update_delegation(instance)
  113. class SerialList(generics.ListAPIView):
  114. permission_classes = (IsVPNClient,)
  115. throttle_classes = [] # don't break slaves when they ask too often (our cached responses are cheap)
  116. def list(self, request):
  117. key = 'desecapi.views.serials'
  118. serials = cache.get(key)
  119. if serials is None:
  120. serials = get_serials()
  121. cache.get_or_set(key, serials, timeout=15)
  122. return Response(serials)
  123. class RRsetDetail(IdempotentDestroyMixin, DomainViewMixin, generics.RetrieveUpdateDestroyAPIView):
  124. serializer_class = serializers.RRsetSerializer
  125. permission_classes = (IsAuthenticated, IsDomainOwner,)
  126. @property
  127. def throttle_scope(self):
  128. return 'dns_api_read' if self.request.method in SAFE_METHODS else 'dns_api_write'
  129. def get_queryset(self):
  130. return self.domain.rrset_set
  131. def get_object(self):
  132. queryset = self.filter_queryset(self.get_queryset())
  133. filter_kwargs = {k: self.kwargs[k] for k in ['subname', 'type']}
  134. obj = generics.get_object_or_404(queryset, **filter_kwargs)
  135. # May raise a permission denied
  136. self.check_object_permissions(self.request, obj)
  137. return obj
  138. def update(self, request, *args, **kwargs):
  139. response = super().update(request, *args, **kwargs)
  140. if response.data is None:
  141. response.status_code = 204
  142. return response
  143. def perform_update(self, serializer):
  144. with PDNSChangeTracker():
  145. super().perform_update(serializer)
  146. def perform_destroy(self, instance):
  147. with PDNSChangeTracker():
  148. super().perform_destroy(instance)
  149. class RRsetList(EmptyPayloadMixin, DomainViewMixin, generics.ListCreateAPIView, generics.UpdateAPIView):
  150. serializer_class = serializers.RRsetSerializer
  151. permission_classes = (IsAuthenticated, IsDomainOwner,)
  152. @property
  153. def throttle_scope(self):
  154. return 'dns_api_read' if self.request.method in SAFE_METHODS else 'dns_api_write'
  155. def get_queryset(self):
  156. rrsets = models.RRset.objects.filter(domain=self.domain)
  157. for filter_field in ('subname', 'type'):
  158. value = self.request.query_params.get(filter_field)
  159. if value is not None:
  160. # TODO consider moving this
  161. if filter_field == 'type' and value in models.RR_SET_TYPES_AUTOMATIC:
  162. raise PermissionDenied("You cannot tinker with the %s RRset." % value)
  163. rrsets = rrsets.filter(**{'%s__exact' % filter_field: value})
  164. return rrsets
  165. def get_object(self):
  166. # For this view, the object we're operating on is the queryset that one can also GET. Serializing a queryset
  167. # is fine as per https://www.django-rest-framework.org/api-guide/serializers/#serializing-multiple-objects.
  168. # We skip checking object permissions here to avoid evaluating the queryset. The user can access all his RRsets
  169. # anyways.
  170. return self.filter_queryset(self.get_queryset())
  171. def get_serializer(self, *args, **kwargs):
  172. kwargs = kwargs.copy()
  173. if 'many' not in kwargs:
  174. if self.request.method in ['POST']:
  175. kwargs['many'] = isinstance(kwargs.get('data'), list)
  176. elif self.request.method in ['PATCH', 'PUT']:
  177. kwargs['many'] = True
  178. return super().get_serializer(*args, **kwargs)
  179. def perform_create(self, serializer):
  180. with PDNSChangeTracker():
  181. super().perform_create(serializer)
  182. def perform_update(self, serializer):
  183. with PDNSChangeTracker():
  184. super().perform_update(serializer)
  185. class Root(APIView):
  186. def get(self, request, *_):
  187. if self.request.user.is_authenticated:
  188. routes = {
  189. 'account': {
  190. 'show': reverse('account', request=request),
  191. 'delete': reverse('account-delete', request=request),
  192. 'change-email': reverse('account-change-email', request=request),
  193. 'reset-password': reverse('account-reset-password', request=request),
  194. },
  195. 'logout': reverse('logout', request=request),
  196. 'tokens': reverse('token-list', request=request),
  197. 'domains': reverse('domain-list', request=request),
  198. }
  199. else:
  200. routes = {
  201. 'register': reverse('register', request=request),
  202. 'login': reverse('login', request=request),
  203. 'reset-password': reverse('account-reset-password', request=request),
  204. }
  205. return Response(routes)
  206. class DynDNS12Update(generics.GenericAPIView):
  207. authentication_classes = (auth.TokenAuthentication, auth.BasicTokenAuthentication, auth.URLParamAuthentication,)
  208. renderer_classes = [PlainTextRenderer]
  209. throttle_scope = 'dyndns'
  210. def _find_ip(self, params, version):
  211. if version == 4:
  212. look_for = '.'
  213. elif version == 6:
  214. look_for = ':'
  215. else:
  216. raise Exception
  217. # Check URL parameters
  218. for p in params:
  219. if p in self.request.query_params:
  220. if not len(self.request.query_params[p]):
  221. return None
  222. if look_for in self.request.query_params[p]:
  223. return self.request.query_params[p]
  224. # Check remote IP address
  225. client_ip = self.request.META.get('REMOTE_ADDR')
  226. if look_for in client_ip:
  227. return client_ip
  228. # give up
  229. return None
  230. @cached_property
  231. def qname(self):
  232. # hostname parameter
  233. try:
  234. if self.request.query_params['hostname'] != 'YES':
  235. return self.request.query_params['hostname'].lower()
  236. except KeyError:
  237. pass
  238. # host_id parameter
  239. try:
  240. return self.request.query_params['host_id'].lower()
  241. except KeyError:
  242. pass
  243. # http basic auth username
  244. try:
  245. domain_name = base64.b64decode(
  246. get_authorization_header(self.request).decode().split(' ')[1].encode()).decode().split(':')[0]
  247. if domain_name and '@' not in domain_name:
  248. return domain_name.lower()
  249. except (binascii.Error, IndexError, UnicodeDecodeError):
  250. pass
  251. # username parameter
  252. try:
  253. return self.request.query_params['username'].lower()
  254. except KeyError:
  255. pass
  256. # only domain associated with this user account
  257. try:
  258. return self.request.user.domains.get().name
  259. except models.Domain.MultipleObjectsReturned:
  260. raise ValidationError(detail={
  261. "detail": "Request does not properly specify domain for update.",
  262. "code": "domain-unspecified"
  263. })
  264. except models.Domain.DoesNotExist:
  265. metrics.get('desecapi_dynDNS12_domain_not_found').inc()
  266. raise NotFound('nohost')
  267. @cached_property
  268. def domain(self):
  269. try:
  270. return models.Domain.objects.filter_qname(self.qname, owner=self.request.user).order_by('-name_length')[0]
  271. except (IndexError, ValueError):
  272. raise NotFound('nohost')
  273. @property
  274. def subname(self):
  275. return self.qname.rpartition(f'.{self.domain.name}')[0]
  276. def get_queryset(self):
  277. return self.domain.rrset_set.filter(subname=self.subname, type__in=['A', 'AAAA'])
  278. def get(self, request, *_):
  279. instances = self.get_queryset().all()
  280. ipv4 = self._find_ip(['myip', 'myipv4', 'ip'], version=4)
  281. ipv6 = self._find_ip(['myipv6', 'ipv6', 'myip', 'ip'], version=6)
  282. data = [
  283. {'type': 'A', 'subname': self.subname, 'ttl': 60, 'records': [ipv4] if ipv4 else []},
  284. {'type': 'AAAA', 'subname': self.subname, 'ttl': 60, 'records': [ipv6] if ipv6 else []},
  285. ]
  286. context = {'domain': self.domain, 'minimum_ttl': 60}
  287. serializer = serializers.RRsetSerializer(instances, data=data, many=True, partial=True, context=context)
  288. try:
  289. serializer.is_valid(raise_exception=True)
  290. except ValidationError as e:
  291. if any(
  292. any(
  293. getattr(non_field_error, 'code', '') == 'unique'
  294. for non_field_error
  295. in err.get('non_field_errors', [])
  296. )
  297. for err in e.detail
  298. ):
  299. raise ConcurrencyException from e
  300. raise e
  301. with PDNSChangeTracker():
  302. serializer.save()
  303. return Response('good', content_type='text/plain')
  304. class DonationList(generics.CreateAPIView):
  305. serializer_class = serializers.DonationSerializer
  306. def perform_create(self, serializer):
  307. instance = self.serializer_class.Meta.model(**serializer.validated_data)
  308. context = {
  309. 'donation': instance,
  310. 'creditoridentifier': settings.SEPA['CREDITOR_ID'],
  311. 'creditorname': settings.SEPA['CREDITOR_NAME'],
  312. }
  313. # internal desec notification
  314. content_tmpl = get_template('emails/donation/desec-content.txt')
  315. subject_tmpl = get_template('emails/donation/desec-subject.txt')
  316. attachment_tmpl = get_template('emails/donation/desec-attachment-jameica.txt')
  317. from_tmpl = get_template('emails/from.txt')
  318. email = EmailMessage(subject_tmpl.render(context),
  319. content_tmpl.render(context),
  320. from_tmpl.render(context),
  321. ['donation@desec.io'],
  322. attachments=[
  323. ('jameica-directdebit.xml',
  324. attachment_tmpl.render(context),
  325. 'text/xml')
  326. ])
  327. email.send()
  328. # donor notification
  329. if instance.email:
  330. content_tmpl = get_template('emails/donation/donor-content.txt')
  331. subject_tmpl = get_template('emails/donation/donor-subject.txt')
  332. footer_tmpl = get_template('emails/footer.txt')
  333. email = EmailMessage(subject_tmpl.render(context),
  334. content_tmpl.render(context) + footer_tmpl.render(),
  335. from_tmpl.render(context),
  336. [instance.email])
  337. email.send()
  338. class AccountCreateView(generics.CreateAPIView):
  339. serializer_class = serializers.RegisterAccountSerializer
  340. throttle_scope = 'account_management_active'
  341. def create(self, request, *args, **kwargs):
  342. # Create user and send trigger email verification.
  343. # Alternative would be to create user once email is verified, but this could be abused for bulk email.
  344. serializer = self.get_serializer(data=request.data)
  345. activation_required = settings.USER_ACTIVATION_REQUIRED
  346. try:
  347. serializer.is_valid(raise_exception=True)
  348. except ValidationError as e:
  349. # Hide existing users
  350. email_detail = e.detail.pop('email', [])
  351. email_detail = [detail for detail in email_detail if detail.code != 'unique']
  352. if email_detail:
  353. e.detail['email'] = email_detail
  354. if e.detail:
  355. raise e
  356. else:
  357. # create user
  358. user = serializer.save(is_active=(not activation_required))
  359. # send email if needed
  360. domain = serializer.validated_data.get('domain')
  361. if domain or activation_required:
  362. link, validity_period = generate_confirmation_link(request,
  363. serializers.AuthenticatedActivateUserActionSerializer,
  364. 'confirm-activate-account', user=user, domain=domain)
  365. user.send_email('activate-with-domain' if domain else 'activate', context={
  366. 'confirmation_link': link,
  367. 'link_expiration_hours': validity_period // timedelta(hours=1),
  368. 'domain': domain,
  369. })
  370. # This request is unauthenticated, so don't expose whether we did anything.
  371. message = 'Welcome! Please check your mailbox.' if activation_required else 'Welcome!'
  372. return Response(data={'detail': message}, status=status.HTTP_202_ACCEPTED)
  373. class AccountView(generics.RetrieveAPIView):
  374. permission_classes = (IsAuthenticated,)
  375. serializer_class = serializers.UserSerializer
  376. throttle_scope = 'account_management_passive'
  377. def get_object(self):
  378. return self.request.user
  379. class AccountDeleteView(generics.GenericAPIView):
  380. authentication_classes = (auth.EmailPasswordPayloadAuthentication,)
  381. permission_classes = (IsAuthenticated,)
  382. response_still_has_domains = Response(
  383. data={'detail': 'To delete your user account, first delete all of your domains.'},
  384. status=status.HTTP_409_CONFLICT,
  385. )
  386. throttle_scope = 'account_management_active'
  387. def post(self, request, *args, **kwargs):
  388. if self.request.user.domains.exists():
  389. return self.response_still_has_domains
  390. link, validity_period = generate_confirmation_link(request,
  391. serializers.AuthenticatedDeleteUserActionSerializer,
  392. 'confirm-delete-account', user=self.request.user)
  393. request.user.send_email('delete-user', context={
  394. 'confirmation_link': link,
  395. 'link_expiration_hours': validity_period // timedelta(hours=1),
  396. })
  397. return Response(data={'detail': 'Please check your mailbox for further account deletion instructions.'},
  398. status=status.HTTP_202_ACCEPTED)
  399. class AccountLoginView(generics.GenericAPIView):
  400. authentication_classes = (auth.EmailPasswordPayloadAuthentication,)
  401. permission_classes = (IsAuthenticated,)
  402. throttle_scope = 'account_management_passive'
  403. def post(self, request, *args, **kwargs):
  404. user = self.request.user
  405. token = models.Token.objects.create(user=user, name="login", perm_manage_tokens=True,
  406. max_age=timedelta(days=7), max_unused_period=timedelta(hours=1))
  407. user_logged_in.send(sender=user.__class__, request=self.request, user=user)
  408. data = serializers.TokenSerializer(token, include_plain=True).data
  409. return Response(data)
  410. class AccountLogoutView(generics.GenericAPIView, mixins.DestroyModelMixin):
  411. authentication_classes = (auth.TokenAuthentication,)
  412. permission_classes = (IsAuthenticated,)
  413. throttle_classes = [] # always allow people to log out
  414. def get_object(self):
  415. # self.request.auth contains the hashed key as it is stored in the database
  416. return models.Token.objects.get(key=self.request.auth)
  417. def post(self, request, *args, **kwargs):
  418. return self.destroy(request, *args, **kwargs)
  419. class AccountChangeEmailView(generics.GenericAPIView):
  420. authentication_classes = (auth.EmailPasswordPayloadAuthentication,)
  421. permission_classes = (IsAuthenticated,)
  422. serializer_class = serializers.ChangeEmailSerializer
  423. throttle_scope = 'account_management_active'
  424. def post(self, request, *args, **kwargs):
  425. # Check password and extract email
  426. serializer = self.get_serializer(data=request.data)
  427. serializer.is_valid(raise_exception=True)
  428. new_email = serializer.validated_data['new_email']
  429. link, validity_period = generate_confirmation_link(request,
  430. serializers.AuthenticatedChangeEmailUserActionSerializer,
  431. 'confirm-change-email', user=request.user, new_email=new_email)
  432. request.user.send_email('change-email', recipient=new_email, context={
  433. 'confirmation_link': link,
  434. 'link_expiration_hours': validity_period // timedelta(hours=1),
  435. 'old_email': request.user.email,
  436. 'new_email': new_email,
  437. })
  438. # At this point, we know that we are talking to the user, so we can tell that we sent an email.
  439. return Response(data={'detail': 'Please check your mailbox to confirm email address change.'},
  440. status=status.HTTP_202_ACCEPTED)
  441. class AccountResetPasswordView(generics.GenericAPIView):
  442. serializer_class = serializers.ResetPasswordSerializer
  443. throttle_scope = 'account_management_active'
  444. def post(self, request, *args, **kwargs):
  445. serializer = self.get_serializer(data=request.data)
  446. serializer.is_valid(raise_exception=True)
  447. try:
  448. email = serializer.validated_data['email']
  449. user = models.User.objects.get(email=email, is_active=True)
  450. except models.User.DoesNotExist:
  451. pass
  452. else:
  453. self.send_reset_token(user, request)
  454. # This request is unauthenticated, so don't expose whether we did anything.
  455. return Response(data={'detail': 'Please check your mailbox for further password reset instructions. '
  456. 'If you did not receive an email, please contact support.'},
  457. status=status.HTTP_202_ACCEPTED)
  458. @staticmethod
  459. def send_reset_token(user, request):
  460. link, validity_period = generate_confirmation_link(request,
  461. serializers.AuthenticatedResetPasswordUserActionSerializer,
  462. 'confirm-reset-password', user=user)
  463. user.send_email('reset-password', context={
  464. 'confirmation_link': link,
  465. 'link_expiration_hours': validity_period // timedelta(hours=1),
  466. })
  467. class AuthenticatedActionView(generics.GenericAPIView):
  468. """
  469. Abstract class. Deserializes the given payload according the serializers specified by the view extending
  470. this class. If the `serializer.is_valid`, `act` is called on the action object.
  471. Summary of the behavior depending on HTTP method and Accept: header:
  472. GET POST other method
  473. Accept: text/html forward to `self.html_url` if any perform action 405 Method Not Allowed
  474. else HTTP 406 Not Acceptable perform action 405 Method Not Allowed
  475. """
  476. action = None
  477. html_url = None # Redirect GET requests to this webapp GUI URL
  478. http_method_names = ['get', 'post'] # GET is for redirect only
  479. renderer_classes = [JSONRenderer, StaticHTMLRenderer]
  480. @property
  481. def authentication_classes(self):
  482. # This prevents both code evaluation and user-specific throttling when we only want a redirect
  483. return () if self.request.method in SAFE_METHODS else (auth.AuthenticatedBasicUserActionAuthentication,)
  484. @property
  485. def throttle_scope(self):
  486. return 'account_management_passive' if self.request.method in SAFE_METHODS else 'account_management_active'
  487. def get_serializer_context(self):
  488. return {
  489. **super().get_serializer_context(),
  490. 'code': self.kwargs['code'],
  491. 'validity_period': self.get_serializer_class().validity_period,
  492. }
  493. def get(self, request, *args, **kwargs):
  494. # Redirect browsers to frontend if available
  495. is_redirect = (request.accepted_renderer.format == 'html') and self.html_url is not None
  496. if is_redirect:
  497. # Careful: This can generally lead to an open redirect if values contain slashes!
  498. # However, it cannot happen for Django view kwargs.
  499. return redirect(self.html_url.format(**kwargs))
  500. else:
  501. raise NotAcceptable
  502. def post(self, request, *args, **kwargs):
  503. super().perform_authentication(request)
  504. serializer = self.get_serializer(data=request.data)
  505. serializer.is_valid(raise_exception=True)
  506. try:
  507. self.action = serializer.Meta.model(**serializer.validated_data)
  508. except ValueError: # this happens when state cannot be verified
  509. ex = ValidationError('This action cannot be carried out because another operation has been performed, '
  510. 'invalidating this one. (Are you trying to perform this action twice?)')
  511. ex.status_code = status.HTTP_409_CONFLICT
  512. raise ex
  513. self.action.act()
  514. return self.finalize()
  515. def finalize(self):
  516. raise NotImplementedError
  517. class AuthenticatedActivateUserActionView(AuthenticatedActionView):
  518. html_url = '/confirm/activate-account/{code}/'
  519. serializer_class = serializers.AuthenticatedActivateUserActionSerializer
  520. def finalize(self):
  521. if not self.action.domain:
  522. return self._finalize_without_domain()
  523. else:
  524. domain = self._create_domain()
  525. return self._finalize_with_domain(domain)
  526. def _create_domain(self):
  527. serializer = serializers.DomainSerializer(
  528. data={'name': self.action.domain},
  529. context=self.get_serializer_context()
  530. )
  531. try:
  532. serializer.is_valid(raise_exception=True)
  533. except ValidationError as e: # e.g. domain name unavailable
  534. self.action.user.delete()
  535. reasons = ', '.join([detail.code for detail in e.detail.get('name', [])])
  536. raise ValidationError(
  537. f'The requested domain {self.action.domain} could not be registered (reason: {reasons}). '
  538. f'Please start over and sign up again.'
  539. )
  540. # TODO the following line is subject to race condition and can fail, as for the domain name, we have that
  541. # time-of-check != time-of-action
  542. return PDNSChangeTracker.track(lambda: serializer.save(owner=self.action.user))
  543. def _finalize_without_domain(self):
  544. if not is_password_usable(self.action.user.password):
  545. AccountResetPasswordView.send_reset_token(self.action.user, self.request)
  546. return Response({
  547. 'detail': 'Success! We sent you instructions on how to set your password.'
  548. })
  549. login_url = self.request.build_absolute_uri(reverse('v1:login'))
  550. return Response({
  551. 'detail': f'Success! Please log in at {login_url}.'
  552. })
  553. def _finalize_with_domain(self, domain):
  554. if domain.is_locally_registrable:
  555. # TODO the following line raises Domain.DoesNotExist under unknown conditions
  556. PDNSChangeTracker.track(lambda: DomainViewSet.auto_delegate(domain))
  557. token = models.Token.objects.create(user=domain.owner, name='dyndns')
  558. return Response({
  559. 'detail': 'Success! Here is the password ("token") to configure your router (or any other dynDNS '
  560. 'client). This password is different from your account password for security reasons.',
  561. 'domain': serializers.DomainSerializer(domain).data,
  562. **serializers.TokenSerializer(token, include_plain=True).data,
  563. })
  564. else:
  565. return Response({
  566. 'detail': 'Success! Please check the docs for the next steps, https://desec.readthedocs.io/.',
  567. 'domain': serializers.DomainSerializer(domain, include_keys=True).data,
  568. })
  569. class AuthenticatedChangeEmailUserActionView(AuthenticatedActionView):
  570. html_url = '/confirm/change-email/{code}/'
  571. serializer_class = serializers.AuthenticatedChangeEmailUserActionSerializer
  572. def finalize(self):
  573. return Response({
  574. 'detail': f'Success! Your email address has been changed to {self.action.user.email}.'
  575. })
  576. class AuthenticatedResetPasswordUserActionView(AuthenticatedActionView):
  577. html_url = '/confirm/reset-password/{code}/'
  578. serializer_class = serializers.AuthenticatedResetPasswordUserActionSerializer
  579. def finalize(self):
  580. login_url = self.request.build_absolute_uri(reverse('v1:login'))
  581. return Response({'detail': f'Success! Your password has been changed. Log in at {login_url}.'})
  582. class AuthenticatedDeleteUserActionView(AuthenticatedActionView):
  583. html_url = '/confirm/delete-account/{code}/'
  584. serializer_class = serializers.AuthenticatedDeleteUserActionSerializer
  585. def post(self, request, *args, **kwargs):
  586. if self.request.user.domains.exists():
  587. return AccountDeleteView.response_still_has_domains
  588. return super().post(request, *args, **kwargs)
  589. def finalize(self):
  590. return Response({'detail': 'All your data has been deleted. Bye bye, see you soon! <3'})
  591. class AuthenticatedRenewDomainBasicUserActionView(AuthenticatedActionView):
  592. html_url = '/confirm/renew-domain/{code}/'
  593. serializer_class = serializers.AuthenticatedRenewDomainBasicUserActionSerializer
  594. def finalize(self):
  595. return Response({'detail': f'We recorded that your domain {self.action.domain} is still in use.'})
  596. class CaptchaView(generics.CreateAPIView):
  597. serializer_class = serializers.CaptchaSerializer
  598. throttle_scope = 'account_management_passive'