views.py 30 KB

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