views.py 30 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478479480481482483484485486487488489490491492493494495496497498499500501502503504505506507508509510511512513514515516517518519520521522523524525526527528529530531532533534535536537538539540541542543544545546547548549550551552553554555556557558559560561562563564565566567568569570571572573574575576577578579580581582583584585586587588589590591592593594595596597598599600601602603604605606607608609610611612613614615616617618619620621622623624625626627628629630631632633634635636637638639640641642643644645646647648649650651652653654655656657658659660661662663664665666667668669670671672673674675676677678679680681682683684685686687688689690691692693694695696697698699700701702703704705706707708709710711712713714715716717718719720721722723724725726727728729730731732733734735736737738739740741742743744745746747748
  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 initial(self, request, *args, **kwargs):
  55. # noinspection PyUnresolvedReferences
  56. super().initial(request, *args, **kwargs)
  57. try:
  58. # noinspection PyAttributeOutsideInit, PyUnresolvedReferences
  59. self.domain = self.request.user.domains.get(name=self.kwargs['name'])
  60. except models.Domain.DoesNotExist:
  61. raise Http404
  62. class TokenViewSet(IdempotentDestroyMixin, viewsets.ModelViewSet):
  63. serializer_class = serializers.TokenSerializer
  64. permission_classes = (IsAuthenticated, ManageTokensPermission,)
  65. throttle_scope = 'account_management_passive'
  66. def get_queryset(self):
  67. return self.request.user.auth_tokens.all()
  68. def get_serializer(self, *args, **kwargs):
  69. # When creating a new token, return the plaintext representation
  70. if self.request.method == 'POST':
  71. kwargs.setdefault('include_plain', True)
  72. return super().get_serializer(*args, **kwargs)
  73. def perform_create(self, serializer):
  74. serializer.save(user=self.request.user)
  75. class DomainViewSet(IdempotentDestroyMixin,
  76. mixins.CreateModelMixin,
  77. mixins.RetrieveModelMixin,
  78. mixins.DestroyModelMixin,
  79. mixins.ListModelMixin,
  80. viewsets.GenericViewSet):
  81. serializer_class = serializers.DomainSerializer
  82. permission_classes = (IsAuthenticated, IsOwner, WithinDomainLimitOnPOST)
  83. lookup_field = 'name'
  84. lookup_value_regex = r'[^/]+'
  85. @property
  86. def throttle_scope(self):
  87. return 'dns_api_read' if self.request.method in SAFE_METHODS else 'dns_api_write'
  88. def get_queryset(self):
  89. return self.request.user.domains
  90. def get_serializer(self, *args, **kwargs):
  91. include_keys = (self.action in ['create', 'retrieve'])
  92. return super().get_serializer(*args, include_keys=include_keys, **kwargs)
  93. def perform_create(self, serializer):
  94. with PDNSChangeTracker():
  95. domain = serializer.save(owner=self.request.user)
  96. # TODO this line raises if the local public suffix is not in our database!
  97. PDNSChangeTracker.track(lambda: self.auto_delegate(domain))
  98. @staticmethod
  99. def auto_delegate(domain: models.Domain):
  100. if domain.is_locally_registrable:
  101. parent_domain = models.Domain.objects.get(name=domain.parent_domain_name)
  102. parent_domain.update_delegation(domain)
  103. def perform_destroy(self, instance: models.Domain):
  104. with PDNSChangeTracker():
  105. instance.delete()
  106. if instance.is_locally_registrable:
  107. parent_domain = models.Domain.objects.get(name=instance.parent_domain_name)
  108. with PDNSChangeTracker():
  109. parent_domain.update_delegation(instance)
  110. class SerialList(generics.ListAPIView):
  111. permission_classes = (IsVPNClient,)
  112. throttle_classes = [] # don't break slaves when they ask too often (our cached responses are cheap)
  113. def list(self, request):
  114. key = 'desecapi.views.serials'
  115. serials = cache.get(key)
  116. if serials is None:
  117. serials = get_serials()
  118. cache.get_or_set(key, serials, timeout=15)
  119. return Response(serials)
  120. class RRsetDetail(IdempotentDestroyMixin, DomainViewMixin, generics.RetrieveUpdateDestroyAPIView):
  121. serializer_class = serializers.RRsetSerializer
  122. permission_classes = (IsAuthenticated, IsDomainOwner,)
  123. @property
  124. def throttle_scope(self):
  125. return 'dns_api_read' if self.request.method in SAFE_METHODS else 'dns_api_write'
  126. def get_queryset(self):
  127. return self.domain.rrset_set
  128. def get_object(self):
  129. queryset = self.filter_queryset(self.get_queryset())
  130. filter_kwargs = {k: self.kwargs[k] for k in ['subname', 'type']}
  131. obj = generics.get_object_or_404(queryset, **filter_kwargs)
  132. # May raise a permission denied
  133. self.check_object_permissions(self.request, obj)
  134. return obj
  135. def get_serializer(self, *args, **kwargs):
  136. return super().get_serializer(domain=self.domain, *args, **kwargs)
  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(domain=self.domain, *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. serializer = serializers.RRsetSerializer(instances, domain=domain, data=data, many=True, partial=True)
  286. try:
  287. serializer.is_valid(raise_exception=True)
  288. except ValidationError as e:
  289. if any('ttl' in error for error in e.detail):
  290. raise PermissionDenied({'detail': 'Domain not eligible for dynamic updates, please contact support.'})
  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. """
  472. action = None
  473. authentication_classes = (auth.AuthenticatedBasicUserActionAuthentication,)
  474. html_url = None # Redirect GET requests to this webapp GUI URL
  475. http_method_names = ['get', 'post'] # GET is for redirect only
  476. renderer_classes = [JSONRenderer, StaticHTMLRenderer]
  477. @property
  478. def throttle_scope(self):
  479. return 'account_management_passive' if self.request.method in SAFE_METHODS else 'account_management_active'
  480. def get_serializer_context(self):
  481. return {
  482. **super().get_serializer_context(),
  483. 'code': self.kwargs['code'],
  484. 'validity_period': self.get_serializer_class().validity_period,
  485. }
  486. def perform_authentication(self, request):
  487. # Delay authentication until request.auth or request.user is first accessed.
  488. # This allows returning a redirect or status 405 without validating the action code.
  489. pass
  490. def get(self, request, *args, **kwargs):
  491. # Redirect browsers to frontend if available
  492. is_redirect = (request.accepted_renderer.format == 'html') and self.html_url is not None
  493. if is_redirect:
  494. # Careful: This can generally lead to an open redirect if values contain slashes!
  495. # However, it cannot happen for Django view kwargs.
  496. return redirect(self.html_url.format(**kwargs))
  497. else:
  498. raise NotAcceptable
  499. def post(self, request, *args, **kwargs):
  500. super().perform_authentication(request)
  501. serializer = self.get_serializer(data=request.data)
  502. serializer.is_valid(raise_exception=True)
  503. try:
  504. self.action = serializer.Meta.model(**serializer.validated_data)
  505. except ValueError: # this happens when state cannot be verified
  506. ex = ValidationError('This action cannot be carried out because another operation has been performed, '
  507. 'invalidating this one. (Are you trying to perform this action twice?)')
  508. ex.status_code = status.HTTP_409_CONFLICT
  509. raise ex
  510. self.action.act()
  511. return self.finalize()
  512. def finalize(self):
  513. raise NotImplementedError
  514. class AuthenticatedActivateUserActionView(AuthenticatedActionView):
  515. html_url = '/confirm/activate-account/{code}/'
  516. serializer_class = serializers.AuthenticatedActivateUserActionSerializer
  517. def finalize(self):
  518. if not self.action.domain:
  519. return self._finalize_without_domain()
  520. else:
  521. domain = self._create_domain()
  522. return self._finalize_with_domain(domain)
  523. def _create_domain(self):
  524. serializer = serializers.DomainSerializer(
  525. data={'name': self.action.domain},
  526. context=self.get_serializer_context()
  527. )
  528. try:
  529. serializer.is_valid(raise_exception=True)
  530. except ValidationError as e: # e.g. domain name unavailable
  531. self.action.user.delete()
  532. reasons = ', '.join([detail.code for detail in e.detail.get('name', [])])
  533. raise ValidationError(
  534. f'The requested domain {self.action.domain} could not be registered (reason: {reasons}). '
  535. f'Please start over and sign up again.'
  536. )
  537. # TODO the following line is subject to race condition and can fail, as for the domain name, we have that
  538. # time-of-check != time-of-action
  539. return PDNSChangeTracker.track(lambda: serializer.save(owner=self.action.user))
  540. def _finalize_without_domain(self):
  541. if not is_password_usable(self.action.user.password):
  542. AccountResetPasswordView.send_reset_token(self.action.user, self.request)
  543. return Response({
  544. 'detail': 'Success! We sent you instructions on how to set your password.'
  545. })
  546. login_url = self.request.build_absolute_uri(reverse('v1:login'))
  547. return Response({
  548. 'detail': f'Success! Please log in at {login_url}.'
  549. })
  550. def _finalize_with_domain(self, domain):
  551. if domain.is_locally_registrable:
  552. # TODO the following line raises Domain.DoesNotExist under unknown conditions
  553. PDNSChangeTracker.track(lambda: DomainViewSet.auto_delegate(domain))
  554. token = models.Token.objects.create(user=domain.owner, name='dyndns')
  555. return Response({
  556. 'detail': 'Success! Here is the password ("token") to configure your router (or any other dynDNS '
  557. 'client). This password is different from your account password for security reasons.',
  558. 'domain': serializers.DomainSerializer(domain).data,
  559. **serializers.TokenSerializer(token, include_plain=True).data,
  560. })
  561. else:
  562. return Response({
  563. 'detail': 'Success! Please check the docs for the next steps, https://desec.readthedocs.io/.',
  564. 'domain': serializers.DomainSerializer(domain, include_keys=True).data,
  565. })
  566. class AuthenticatedChangeEmailUserActionView(AuthenticatedActionView):
  567. html_url = '/confirm/change-email/{code}/'
  568. serializer_class = serializers.AuthenticatedChangeEmailUserActionSerializer
  569. def finalize(self):
  570. return Response({
  571. 'detail': f'Success! Your email address has been changed to {self.action.user.email}.'
  572. })
  573. class AuthenticatedResetPasswordUserActionView(AuthenticatedActionView):
  574. html_url = '/confirm/reset-password/{code}/'
  575. serializer_class = serializers.AuthenticatedResetPasswordUserActionSerializer
  576. def finalize(self):
  577. login_url = self.request.build_absolute_uri(reverse('v1:login'))
  578. return Response({'detail': f'Success! Your password has been changed. Log in at {login_url}.'})
  579. class AuthenticatedDeleteUserActionView(AuthenticatedActionView):
  580. html_url = '/confirm/delete-account/{code}/'
  581. serializer_class = serializers.AuthenticatedDeleteUserActionSerializer
  582. def post(self, request, *args, **kwargs):
  583. if self.request.user.domains.exists():
  584. return AccountDeleteView.response_still_has_domains
  585. return super().post(request, *args, **kwargs)
  586. def finalize(self):
  587. return Response({'detail': 'All your data has been deleted. Bye bye, see you soon! <3'})
  588. class AuthenticatedRenewDomainBasicUserActionView(AuthenticatedActionView):
  589. html_url = '/confirm/renew-domain/{code}/'
  590. serializer_class = serializers.AuthenticatedRenewDomainBasicUserActionSerializer
  591. def finalize(self):
  592. return Response({'detail': f'We recorded that your domain {self.action.domain} is still in use.'})
  593. class CaptchaView(generics.CreateAPIView):
  594. serializer_class = serializers.CaptchaSerializer
  595. throttle_scope = 'account_management_passive'