django-cas-server/cas_server/views.py

713 lines
26 KiB
Python
Raw Normal View History

2015-05-16 21:43:46 +00:00
# ⁻*- coding: utf-8 -*-
2015-05-27 20:10:06 +00:00
# This program is distributed in the hope that it will be useful, but WITHOUT
# ANY WARRANTY; without even the implied warranty of MERCHANTABILITY or FITNESS
# FOR A PARTICULAR PURPOSE. See the GNU General Public License version 3 for
# more details.
#
# You should have received a copy of the GNU General Public License version 3
# along with this program; if not, write to the Free Software Foundation, Inc., 51
# Franklin Street, Fifth Floor, Boston, MA 02110-1301 USA.
#
# (c) 2015 Valentin Samir
2015-05-27 19:56:39 +00:00
"""views for the app"""
from .default_settings import settings
2015-05-16 21:43:46 +00:00
from django.shortcuts import render, redirect
2015-05-27 19:56:39 +00:00
from django.http import HttpResponse, HttpResponseRedirect
2015-05-16 21:43:46 +00:00
from django.contrib import messages
from django.utils.decorators import method_decorator
2015-05-22 15:55:00 +00:00
from django.utils.translation import ugettext as _
2015-05-27 19:56:39 +00:00
from django.utils import timezone
from django.views.decorators.csrf import csrf_exempt
2015-05-29 14:11:10 +00:00
from django.views.generic import View
2015-05-16 21:43:46 +00:00
import requests
2015-05-22 17:31:50 +00:00
from lxml import etree
2015-05-27 19:56:39 +00:00
from datetime import timedelta
2015-05-16 21:43:46 +00:00
import utils
import forms
import models
2015-05-16 21:43:46 +00:00
2015-06-08 00:51:22 +00:00
from .models import ServiceTicket, ProxyTicket, ProxyGrantingTicket
from .models import ServicePattern
class AttributesMixin(object):
"""mixin for the attributs methode"""
# pylint: disable=too-few-public-methods
def attributes(self):
"""regerate attributes list for template rendering"""
attributes = []
for key, value in self.ticket.attributs.items():
if isinstance(value, list):
for elt in value:
attributes.append((key, elt))
else:
attributes.append((key, value))
return attributes
2015-05-29 14:14:27 +00:00
class LogoutMixin(object):
"""destroy CAS session utils"""
2015-05-29 14:11:10 +00:00
def clean_session_variables(self):
"""Clean sessions variables"""
try:
del self.request.session["authenticated"]
except KeyError:
pass
try:
del self.request.session["username"]
except KeyError:
pass
try:
del self.request.session["warn"]
except KeyError:
pass
def logout(self):
"""effectively destroy CAS session"""
try:
2015-06-09 20:04:05 +00:00
user = models.User.objects.get(
username=self.request.session.get("username"),
session_key=self.request.session_key
2015-06-09 20:04:05 +00:00
)
2015-05-29 14:11:10 +00:00
user.logout(self.request)
user.delete()
except models.User.DoesNotExist:
pass
finally:
self.clean_session_variables()
2015-05-29 14:14:27 +00:00
class LogoutView(View, LogoutMixin):
"""destroy CAS session (logout) view"""
request = None
service = None
2015-05-29 14:11:10 +00:00
def get(self, request, *args, **kwargs):
"""methode called on GET request on this view"""
self.request = request
self.service = request.GET.get('service')
2015-06-07 14:53:27 +00:00
self.url = request.GET.get('url')
2015-05-29 14:11:10 +00:00
self.logout()
# if service is set, redirect to service after logout
if self.service:
list(messages.get_messages(request)) # clean messages before leaving the django app
return HttpResponseRedirect(self.service)
2015-06-07 14:53:27 +00:00
elif self.url:
list(messages.get_messages(request)) # clean messages before leaving the django app
return HttpResponseRedirect(self.url)
2015-05-29 14:11:10 +00:00
# else redirect to login page
else:
if settings.CAS_REDIRECT_TO_LOGIN_AFTER_LOGOUT:
messages.add_message(request, messages.SUCCESS, _(u'Successfully logout'))
return redirect("cas_server:login")
else:
return render(request, settings.CAS_LOGOUT_TEMPLATE)
2015-05-29 14:11:10 +00:00
2015-05-29 14:14:27 +00:00
class LoginView(View, LogoutMixin):
2015-05-27 19:56:39 +00:00
"""credential requestor / acceptor"""
2015-05-29 14:11:10 +00:00
# pylint: disable=too-many-instance-attributes
# Nine is reasonable in this case.
2015-05-16 21:43:46 +00:00
user = None
form = None
2015-05-29 14:11:10 +00:00
request = None
service = None
renew = None
gateway = None
method = None
2015-05-16 21:43:46 +00:00
renewed = False
warned = False
2015-05-29 14:11:10 +00:00
def post(self, request, *args, **kwargs):
"""methode called on POST request on this view"""
self.request = request
self.service = request.POST.get('service')
self.renew = True if request.POST.get('renew') else False
self.gateway = request.POST.get('gateway')
self.method = request.POST.get('method')
# save LT for later check
lt_valid = request.session.get('lt')
lt_send = request.POST.get('lt')
# generate a new LT (by posting the LT has been consumed)
request.session['lt'] = utils.gen_lt()
# check if send LT is valid
if lt_valid is None or lt_valid != lt_send:
messages.add_message(
self.request,
messages.ERROR,
_(u"Invalid login ticket")
2015-05-27 19:56:39 +00:00
)
values = request.POST.copy()
# if not set a new LT and fail
values['lt'] = request.session['lt']
self.init_form(values)
elif not request.session.get("authenticated") or self.renew:
self.init_form(request.POST)
2015-05-29 14:11:10 +00:00
if self.form.is_valid():
2015-06-09 20:04:05 +00:00
self.user = models.User.objects.get(
username=self.form.cleaned_data['username'],
session_key=self.request.session_key
2015-06-09 20:04:05 +00:00
)
2015-05-19 16:33:56 +00:00
request.session.set_expiry(0)
2015-05-29 14:11:10 +00:00
request.session["username"] = self.form.cleaned_data['username']
request.session["warn"] = True if self.form.cleaned_data.get("warn") else False
2015-05-16 21:43:46 +00:00
request.session["authenticated"] = True
2015-05-29 14:11:10 +00:00
self.renewed = True
self.warned = True
2015-05-16 21:43:46 +00:00
else:
2015-05-29 14:11:10 +00:00
self.logout()
return self.common()
def get(self, request, *args, **kwargs):
2015-05-29 14:14:27 +00:00
"""methode called on GET request on this view"""
2015-05-29 14:11:10 +00:00
self.request = request
self.service = request.GET.get('service')
self.renew = True if request.GET.get('renew') else False
self.gateway = request.GET.get('gateway')
self.method = request.GET.get('method')
# generate a new LT if none is present
request.session['lt'] = request.session.get('lt', utils.gen_lt())
2015-05-27 19:56:39 +00:00
if not request.session.get("authenticated") or self.renew:
self.init_form()
2015-05-29 14:11:10 +00:00
return self.common()
2015-05-16 21:43:46 +00:00
def init_form(self, values=None):
self.form = forms.UserCredential(
2015-06-09 20:04:05 +00:00
self.request,
values,
initial={
'service':self.service,
'method':self.method,
'warn':self.request.session.get("warn"),
'lt':self.request.session['lt']
}
)
2015-05-29 14:11:10 +00:00
def service_login(self):
"""Perform login agains a service"""
try:
# is the service allowed
2015-06-08 00:51:22 +00:00
service_pattern = ServicePattern.validate(self.service)
2015-05-29 14:11:10 +00:00
# is the current user allowed on this service
service_pattern.check_user(self.user)
# if the user has asked to be warned before any login to a service
if self.request.session.get("warn", True) and not self.warned:
2015-05-27 19:56:39 +00:00
messages.add_message(
2015-05-29 14:11:10 +00:00
self.request,
messages.WARNING,
_(u"Authentication has been required by service %(name)s (%(url)s)") % \
{'name':service_pattern.name, 'url':self.service}
2015-05-27 19:56:39 +00:00
)
2015-05-29 14:11:10 +00:00
return render(
self.request,
settings.CAS_WARN_TEMPLATE,
{'service_ticket_url':self.user.get_service_url(
self.service,
service_pattern,
renew=self.renew
)}
2015-05-27 19:56:39 +00:00
)
2015-05-29 14:11:10 +00:00
else:
# redirect, using method ?
2015-06-07 21:50:25 +00:00
list(messages.get_messages(self.request)) # clean messages before leaving django
2015-05-29 14:11:10 +00:00
return HttpResponseRedirect(
self.user.get_service_url(self.service, service_pattern, renew=self.renew)
2015-05-27 19:56:39 +00:00
)
2015-06-08 00:51:22 +00:00
except ServicePattern.DoesNotExist:
2015-05-29 14:11:10 +00:00
messages.add_message(
self.request,
messages.ERROR,
_(u'Service %(url)s non allowed.') % {'url' : self.service}
)
except models.BadUsername:
messages.add_message(
self.request,
messages.ERROR,
_(u"Username non allowed")
)
except models.BadFilter:
messages.add_message(
self.request,
messages.ERROR,
_(u"User charateristics non allowed")
)
except models.UserFieldNotDefined:
messages.add_message(
self.request,
messages.ERROR,
_(u"The attribut %(field)s is needed to use" \
" that service") % {'field':service_pattern.user_field}
)
# if gateway is set and auth failed redirect to the service without authentication
if self.gateway:
list(messages.get_messages(self.request)) # clean messages before leaving django
return HttpResponseRedirect(self.service)
2015-05-16 21:43:46 +00:00
2015-05-29 14:11:10 +00:00
return render(self.request, settings.CAS_LOGGED_TEMPLATE, {'session':self.request.session})
2015-05-16 21:43:46 +00:00
2015-05-29 14:11:10 +00:00
def authenticated(self):
"""Processing authenticated users"""
try:
2015-06-09 20:04:05 +00:00
self.user = models.User.objects.get(
username=self.request.session.get("username"),
session_key=self.request.session_key
2015-06-09 20:04:05 +00:00
)
2015-05-29 14:11:10 +00:00
except models.User.DoesNotExist:
self.logout()
return utils.redirect_params("cas_server:login", params=self.request.GET)
2015-05-29 14:11:10 +00:00
# if login agains a service is self.requestest
if self.service:
return self.service_login()
else:
return render(
self.request,
settings.CAS_LOGGED_TEMPLATE,
{'session':self.request.session}
)
def not_authenticated(self):
"""Processing non authenticated users"""
if self.service:
2015-05-18 18:30:00 +00:00
try:
2015-06-08 00:51:22 +00:00
service_pattern = ServicePattern.validate(self.service)
2015-05-29 14:11:10 +00:00
if self.gateway:
list(messages.get_messages(self.request))# clean messages before leaving django
return HttpResponseRedirect(self.service)
if self.request.session.get("authenticated") and self.renew:
2015-05-27 19:56:39 +00:00
messages.add_message(
2015-05-29 14:11:10 +00:00
self.request,
2015-05-27 19:56:39 +00:00
messages.WARNING,
2015-05-29 14:11:10 +00:00
_(u"Authentication renewal required by service %(name)s (%(url)s).") %
{'name':service_pattern.name, 'url':self.service}
2015-05-27 19:56:39 +00:00
)
2015-05-18 18:30:00 +00:00
else:
2015-05-27 19:56:39 +00:00
messages.add_message(
2015-05-29 14:11:10 +00:00
self.request,
2015-05-27 19:56:39 +00:00
messages.WARNING,
2015-05-29 14:11:10 +00:00
_(u"Authentication required by service %(name)s (%(url)s).") %
{'name':service_pattern.name, 'url':self.service}
2015-05-27 19:56:39 +00:00
)
2015-06-08 00:51:22 +00:00
except ServicePattern.DoesNotExist:
2015-05-27 19:56:39 +00:00
messages.add_message(
2015-05-29 14:11:10 +00:00
self.request,
2015-05-27 19:56:39 +00:00
messages.ERROR,
2015-05-29 14:11:10 +00:00
_(u'Service %s non allowed') % self.service
2015-05-27 19:56:39 +00:00
)
2015-05-29 14:11:10 +00:00
return render(self.request, settings.CAS_LOGIN_TEMPLATE, {'form':self.form})
2015-05-16 21:43:46 +00:00
2015-05-29 14:11:10 +00:00
def common(self):
"""Part execute uppon GET and POST request"""
# if authenticated and successfully renewed authentication if needed
if self.request.session.get("authenticated") and (not self.renew or self.renewed):
return self.authenticated()
else:
return self.not_authenticated()
2015-05-16 21:43:46 +00:00
class Auth(View):
"""A simple view to validate username/password/service tuple"""
@method_decorator(csrf_exempt)
def dispatch(self, request, *args, **kwargs):
"""dispatch requests based on method GET, POST, ..."""
return super(Auth, self).dispatch(request, *args, **kwargs)
@staticmethod
def post(request):
"""methode called on GET request on this view"""
username = request.POST.get('username')
password = request.POST.get('password')
service = request.POST.get('service')
secret = request.POST.get('secret')
if not settings.CAS_AUTH_SHARED_SECRET:
return HttpResponse("no\nplease set CAS_AUTH_SHARED_SECRET", content_type="text/plain")
if secret != settings.CAS_AUTH_SHARED_SECRET:
return HttpResponse("no\n", content_type="text/plain")
if not username or not password or not service:
return HttpResponse("no\n", content_type="text/plain")
form = forms.UserCredential(
2015-06-09 20:04:05 +00:00
request,
request.POST,
initial={
'service':service,
'method':'POST',
'warn':False
}
)
if form.is_valid():
try:
2015-06-09 20:04:05 +00:00
user = models.User.objects.get(
username=form.cleaned_data['username'],
session_key=self.request.session_key
2015-06-09 20:04:05 +00:00
)
# is the service allowed
2015-06-08 00:51:22 +00:00
service_pattern = ServicePattern.validate(service)
# is the current user allowed on this service
service_pattern.check_user(user)
2015-06-09 20:04:05 +00:00
if not request.session.get("authenticated"):
user.delete()
return HttpResponse("yes\n", content_type="text/plain")
2015-06-08 00:51:22 +00:00
except (ServicePattern.DoesNotExist, ServicePatternException) as error:
return HttpResponse("no\n", content_type="text/plain")
else:
return HttpResponse("no\n", content_type="text/plain")
class Validate(View):
2015-05-27 19:56:39 +00:00
"""service ticket validation"""
@staticmethod
def get(request):
"""methode called on GET request on this view"""
service = request.GET.get('service')
ticket = request.GET.get('ticket')
renew = True if request.GET.get('renew') else False
if service and ticket:
try:
2015-06-08 00:51:22 +00:00
ticket = ServiceTicket.objects.get(
value=ticket,
service=service,
validate=False,
renew=renew,
2015-06-08 00:51:22 +00:00
creation__gt=(timezone.now() - timedelta(seconds=ServiceTicket.VALIDITY))
)
ticket.validate = True
ticket.save()
return HttpResponse("yes\n", content_type="text/plain")
2015-06-08 00:51:22 +00:00
except ServiceTicket.DoesNotExist:
return HttpResponse("no\n", content_type="text/plain")
else:
2015-05-16 21:43:46 +00:00
return HttpResponse("no\n", content_type="text/plain")
2015-05-27 19:56:39 +00:00
class ValidateError(Exception):
"""handle service validation error"""
def __init__(self, code, msg=""):
self.code = code
self.msg = msg
2015-05-29 17:31:04 +00:00
super(ValidateError, self).__init__(code)
def __unicode__(self):
return u"%s" % self.msg
def render(self, request):
"""render the error template for the exception"""
return render(
request,
"cas_server/serviceValidateError.xml",
{'code':self.code, 'msg':self.msg},
content_type="text/xml; charset=utf-8"
)
class ValidateService(View, AttributesMixin):
"""service ticket validation [CAS 2.0] and [CAS 3.0]"""
request = None
service = None
ticket = None
pgt_url = None
renew = None
2015-05-29 17:33:42 +00:00
allow_proxy_ticket = False
2015-05-29 17:33:42 +00:00
def get(self, request):
"""methode called on GET request on this view"""
self.request = request
self.service = request.GET.get('service')
self.ticket = request.GET.get('ticket')
self.pgt_url = request.GET.get('pgtUrl')
self.renew = True if request.GET.get('renew') else False
if not self.service or not self.ticket:
return ValidateError(
'INVALID_REQUEST',
"you must specify a service and a ticket"
).render(request)
2015-05-16 21:43:46 +00:00
else:
try:
self.ticket, proxies = self.process_ticket()
params = {
'username':self.ticket.user.username,
'attributes':self.attributes(),
'proxies':proxies
}
if self.ticket.service_pattern.user_field and \
self.ticket.user.attributs.get(self.ticket.service_pattern.user_field):
params['username'] = self.ticket.user.attributs.get(
self.ticket.service_pattern.user_field
)
if self.pgt_url and self.pgt_url.startswith("https://"):
return self.process_pgturl(params)
else:
return render(
request,
"cas_server/serviceValidate.xml",
params,
content_type="text/xml; charset=utf-8"
)
except ValidateError as error:
return error.render(request)
def process_ticket(self):
"""fetch the ticket angains the database and check its validity"""
2015-05-16 21:43:46 +00:00
try:
proxies = []
2015-06-08 00:51:22 +00:00
if self.ticket.startswith(ServiceTicket.PREFIX):
ticket = ServiceTicket.objects.get(
value=self.ticket,
2015-05-27 19:56:39 +00:00
validate=False,
renew=self.renew,
2015-06-08 00:51:22 +00:00
creation__gt=(timezone.now() - timedelta(seconds=ServiceTicket.VALIDITY))
2015-05-27 19:56:39 +00:00
)
2015-06-08 00:51:22 +00:00
elif self.allow_proxy_ticket and self.ticket.startswith(ProxyTicket.PREFIX):
ticket = ProxyTicket.objects.get(
value=self.ticket,
2015-05-27 19:56:39 +00:00
validate=False,
renew=self.renew,
2015-06-08 00:51:22 +00:00
creation__gt=(timezone.now() - timedelta(seconds=ProxyTicket.VALIDITY))
2015-05-27 19:56:39 +00:00
)
for prox in ticket.proxies.all():
proxies.append(prox.url)
else:
raise ValidateError('INVALID_TICKET')
2015-05-16 21:43:46 +00:00
ticket.validate = True
ticket.save()
if ticket.service != self.service:
raise ValidateError('INVALID_SERVICE')
return ticket, proxies
2015-06-08 00:51:22 +00:00
except (ServiceTicket.DoesNotExist, ProxyTicket.DoesNotExist):
raise ValidateError('INVALID_TICKET', 'ticket not found')
def process_pgturl(self, params):
"""Handle PGT request"""
try:
2015-06-08 00:51:22 +00:00
pattern = ServicePattern.validate(self.pgt_url)
if pattern.proxy_callback:
proxyid = utils.gen_pgtiou()
2015-06-08 00:51:22 +00:00
pticket = ProxyGrantingTicket.objects.create(
user=self.ticket.user,
service=self.pgt_url,
service_pattern=pattern,
single_log_out=pattern.single_log_out
)
url = utils.update_url(self.pgt_url, {'pgtIou':proxyid, 'pgtId':pticket.value})
try:
ret = requests.get(url, verify=settings.CAS_PROXY_CA_CERTIFICATE_PATH)
if ret.status_code == 200:
params['proxyGrantingTicket'] = proxyid
else:
pticket.delete()
return render(
self.request,
"cas_server/serviceValidate.xml",
params,
content_type="text/xml; charset=utf-8"
2015-05-27 19:56:39 +00:00
)
except requests.exceptions.SSLError as error:
error = utils.unpack_nested_exception(error)
raise ValidateError('INVALID_PROXY_CALLBACK', str(error))
2015-05-16 21:43:46 +00:00
else:
raise ValidateError(
'INVALID_PROXY_CALLBACK',
"callback url not allowed by configuration"
2015-05-27 19:56:39 +00:00
)
2015-06-08 00:51:22 +00:00
except ServicePattern.DoesNotExist:
raise ValidateError(
'INVALID_PROXY_CALLBACK',
'callback url not allowed by configuration'
2015-05-27 19:56:39 +00:00
)
2015-05-16 21:43:46 +00:00
class Proxy(View):
2015-05-27 19:56:39 +00:00
"""proxy ticket service"""
request = None
pgt = None
target_service = None
def get(self, request):
"""methode called on GET request on this view"""
self.request = request
self.pgt = request.GET.get('pgt')
self.target_service = request.GET.get('targetService')
try:
if self.pgt and self.target_service:
return self.process_proxy()
else:
raise ValidateError(
'INVALID_REQUEST',
"you must specify and pgt and targetService"
)
except ValidateError as error:
return error.render(request)
def process_proxy(self):
"""handle PT request"""
2015-05-16 21:43:46 +00:00
try:
2015-05-27 19:56:39 +00:00
# is the target service allowed
2015-06-08 00:51:22 +00:00
pattern = ServicePattern.validate(self.target_service)
if not pattern.proxy:
raise ValidateError(
'UNAUTHORIZED_SERVICE',
'the service do not allow proxy ticket'
)
2015-05-27 19:56:39 +00:00
# is the proxy granting ticket valid
2015-06-08 00:51:22 +00:00
ticket = ProxyGrantingTicket.objects.get(
value=self.pgt,
2015-06-08 00:51:22 +00:00
creation__gt=(timezone.now() - timedelta(seconds=ProxyGrantingTicket.VALIDITY))
2015-05-27 19:56:39 +00:00
)
# is the pgt user allowed on the target service
2015-05-17 21:24:41 +00:00
pattern.check_user(ticket.user)
pticket = ticket.user.get_ticket(
2015-06-08 00:51:22 +00:00
ProxyTicket,
self.target_service,
pattern,
renew=False)
2015-05-16 21:43:46 +00:00
pticket.proxies.create(url=ticket.service)
2015-05-27 19:56:39 +00:00
return render(
self.request,
2015-05-27 19:56:39 +00:00
"cas_server/proxy.xml",
{'ticket':pticket.value},
content_type="text/xml; charset=utf-8"
)
2015-06-08 00:51:22 +00:00
except ProxyGrantingTicket.DoesNotExist:
raise ValidateError('INVALID_TICKET', 'PGT not found')
2015-06-08 00:51:22 +00:00
except ServicePattern.DoesNotExist:
raise ValidateError('UNAUTHORIZED_SERVICE')
except (models.BadUsername, models.BadFilter, models.UserFieldNotDefined):
raise ValidateError(
'UNAUTHORIZED_USER',
'%s not allowed on %s' % (ticket.user, self.target_service)
2015-05-27 19:56:39 +00:00
)
2015-05-16 21:43:46 +00:00
class SamlValidateError(Exception):
"""handle saml validation error"""
def __init__(self, code, msg=""):
self.code = code
self.msg = msg
2015-05-29 17:31:04 +00:00
super(SamlValidateError, self).__init__(code)
def __unicode__(self):
return u"%s" % self.msg
def render(self, request):
"""render the error template for the exception"""
return render(
request,
"cas_server/samlValidateError.xml",
{
'code':self.code,
'msg':self.msg,
'IssueInstant':timezone.now().isoformat(),
'ResponseID':utils.gen_saml_id()
},
content_type="text/xml; charset=utf-8"
)
2015-05-22 17:31:50 +00:00
def _saml_validate_error(request, code, msg=""):
"""render the samlValidateError.xml templace using `code` and `msg`"""
return render(
request,
"cas_server/samlValidateError.xml",
{
'code':code,
'msg':msg,
'IssueInstant':timezone.now().isoformat(),
'ResponseID':utils.gen_saml_id()
},
content_type="text/xml; charset=utf-8"
)
class SamlValidate(View, AttributesMixin):
"""SAML ticket validation"""
request = None
target = None
ticket = None
root = None
@method_decorator(csrf_exempt)
def dispatch(self, request, *args, **kwargs):
"""dispatch requests based on method GET, POST, ..."""
2015-05-29 18:07:53 +00:00
return super(SamlValidate, self).dispatch(request, *args, **kwargs)
def post(self, request):
"""methode called on POST request on this view"""
self.request = request
self.target = request.GET.get('TARGET')
self.root = etree.fromstring(request.body)
try:
self.ticket = self.process_ticket()
expire_instant = (self.ticket.creation + \
2015-06-08 00:51:22 +00:00
timedelta(seconds=self.ticket.VALIDITY)).isoformat()
attributes = self.attributes()
params = {
'IssueInstant':timezone.now().isoformat(),
'expireInstant':expire_instant,
'Recipient':self.target,
'ResponseID':utils.gen_saml_id(),
'username':self.ticket.user.username,
'attributes':attributes
}
if self.ticket.service_pattern.user_field and \
self.ticket.user.attributs.get(self.ticket.service_pattern.user_field):
params['username'] = self.ticket.user.attributs.get(
self.ticket.service_pattern.user_field
)
return render(
request,
"cas_server/samlValidate.xml",
params,
content_type="text/xml; charset=utf-8"
)
except SamlValidateError as error:
return error.render(request)
def process_ticket(self):
"""validate ticket from SAML XML body"""
2015-05-22 17:31:50 +00:00
try:
auth_req = self.root.getchildren()[1].getchildren()[0]
2015-05-22 17:31:50 +00:00
ticket = auth_req.getchildren()[0].text
2015-06-08 00:51:22 +00:00
if ticket.startswith(ServiceTicket.PREFIX):
ticket = ServiceTicket.objects.get(
value=ticket,
validate=False,
2015-06-08 00:51:22 +00:00
creation__gt=(timezone.now() - timedelta(seconds=ServiceTicket.VALIDITY))
)
2015-06-08 00:51:22 +00:00
elif ticket.startswith(ProxyTicket.PREFIX):
ticket = ProxyTicket.objects.get(
value=ticket,
validate=False,
2015-06-08 00:51:22 +00:00
creation__gt=(timezone.now() - timedelta(seconds=ProxyTicket.VALIDITY))
)
else:
raise SamlValidateError(
'AuthnFailed',
'ticket should begin with PT- or ST-'
)
2015-05-22 17:31:50 +00:00
ticket.validate = True
ticket.save()
if ticket.service != self.target:
raise SamlValidateError(
'AuthnFailed',
'TARGET do not match ticket service'
)
return ticket
except (IndexError, KeyError):
raise SamlValidateError('VersionMismatch')
2015-06-08 00:51:22 +00:00
except (ServiceTicket.DoesNotExist, ProxyTicket.DoesNotExist):
raise SamlValidateError('AuthnFailed', 'ticket not found')