views.py 31 KB

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