get_firebase_playback() - Code Metrics - Inspection of "* https://stackoverflow.com/a/36553583/3872976" - Deathangel908/pychat - Measure and Improve Code Quality continuously with Scrutinizer

Completed

Push — master ( ded4cb...5b64a2 )

by Andrew

created 2018-02-18 14:37 UTC

get_firebase_playback() B

↳ Parent: Project

Complexity

Conditions

Size

Total Lines

Duplication

Lines	0
Ratio	0 %

Importance

Changes	5
Bugs	0	Features	0

Metric	Value
cc	1
c	5
b	0
f	0
dl	0
loc	24
rs	8.9713

# -*- encoding: utf-8 -*-
import datetime
import json
import logging

import os
from django.conf import settings
from django.contrib.auth import authenticate
from django.contrib.auth import login as djangologin
from django.contrib.auth import logout as djangologout
from django.core.mail import send_mail, mail_admins

from chat.templatetags.md5url import md5url

try:
	from django.template.context_processors import csrf
except ImportError:
	from django.core.context_processors import csrf
from django.core.exceptions import ObjectDoesNotExist, ValidationError
from django.db import transaction
from django.db.models import Count, Q, F
from django.http import Http404
from django.utils.timezone import utc
from django.http import HttpResponse
from django.http import HttpResponseRedirect
from django.shortcuts import render_to_response
from django.template import RequestContext
from django.views.decorators.http import require_http_methods
from django.views.generic import View
from chat import utils
from chat.decorators import login_required_no_redirect
from chat.forms import UserProfileForm, UserProfileReadOnlyForm
from chat.models import Issue, IssueDetails, IpAddress, UserProfile, Verification, Message, Subscription, \
	SubscriptionMessages, RoomUsers
from django.conf import settings
from chat.utils import hide_fields, check_user, check_password, check_email, extract_photo, send_sign_up_email, \
	create_user_model, check_captcha, send_reset_password_email, get_client_ip, get_or_create_ip

logger = logging.getLogger(__name__)
RECAPTCHA_SITE_KEY = getattr(settings, "RECAPTCHA_SITE_KEY", None)
RECAPTHCA_SITE_URL = getattr(settings, "RECAPTHCA_SITE_URL", None)
GOOGLE_OAUTH_2_CLIENT_ID = getattr(settings, "GOOGLE_OAUTH_2_CLIENT_ID", None)
GOOGLE_OAUTH_2_JS_URL = getattr(settings, "GOOGLE_OAUTH_2_JS_URL", None)
FACEBOOK_APP_ID = getattr(settings, "FACEBOOK_APP_ID", None)
FACEBOOK_JS_URL = getattr(settings, "FACEBOOK_JS_URL", None)

# TODO doesn't work
def handler404(request):
	return HttpResponse("Page not found", content_type='text/plain')


@require_http_methods(['POST'])
def validate_email(request):
	"""
	POST only, validates email during registration
	"""
	email = request.POST.get('email')
	try:
		utils.check_email(email)
		response = settings.VALIDATION_IS_OK
	except ValidationError as e:
		response = e.message
	return HttpResponse(response, content_type='text/plain')


@require_http_methods(['POST'])
@login_required_no_redirect(False)
def save_room_settings(request):
	"""
	POST only, validates email during registration
	"""
	logger.debug('save_room_settings request,  %s', request.POST)
	room_id = request.POST['roomId']
	updated = RoomUsers.objects.filter(room_id=room_id, user_id=request.user.id).update(
		volume=request.POST['volume'],
		notifications=request.POST['notifications'] == 'true',
	)
	return HttpResponse(settings.VALIDATION_IS_OK if updated == 1 else "Nothing updated", content_type='text/plain')


@require_http_methods('GET')
@transaction.atomic
def get_firebase_playback(request):
	registration_id = request.META['HTTP_AUTH']
	logger.debug('Firebase playback, id %s', registration_id)
	query_sub_message = SubscriptionMessages.objects.filter(subscription__registration_id=registration_id, received=False).order_by('-message__time')[:1]
	sub_message = query_sub_message[0]
	SubscriptionMessages.objects.filter(id=sub_message.id).update(received=True)
	message = Message.objects.select_related("sender__username", "room__name").get(id=sub_message.message_id)
	data = {
		'title': message.sender.username,
		'options': {
			'body': message.content,
			'icon': md5url('images/favicon.ico'),
			'data': {
				'id': sub_message.message_id,
				'sender': message.sender.username,
				'room': message.room.name,
				'roomId': message.room_id
			},
			'requireInteraction': True
		},
	}
	return HttpResponse(json.dumps(data), content_type='application/json')


def test(request):
	return HttpResponse(settings.VALIDATION_IS_OK, content_type='text/plain')


@require_http_methods('POST')
def register_subscription(request):
	logger.debug('Subscription request,  %s', request)
	registration_id = request.POST['registration_id']
	agent = request.POST['agent']
	is_mobile = request.POST['is_mobile']
	ip = get_or_create_ip(get_client_ip(request), logger)
	Subscription.objects.update_or_create(
		registration_id=registration_id,
		defaults={
			'user': request.user,
			'inactive': False,
			'updated': datetime.datetime.now(),
			'agent': agent,
			'is_mobile': is_mobile == 'true',
			'ip': ip
		}
	)
	return HttpResponse(settings.VALIDATION_IS_OK, content_type='text/plain')

@require_http_methods('POST')
def validate_user(request):
	"""
	Validates user during registration
	"""
	try:
		username = request.POST.get('username')
		utils.check_user(username)
		# hardcoded ok check in register.js
		message = settings.VALIDATION_IS_OK
	except ValidationError as e:
		message = e.message
	return HttpResponse(message, content_type='text/plain')


def get_service_worker(request):  # this stub is only for development, this is replaced in nginx for prod
	worker = open(os.path.join(settings.STATIC_ROOT, 'js', 'sw.js'), 'rb')
	response = HttpResponse(content=worker)
	response['Content-Type'] = 'application/javascript'
	return response

@require_http_methods('GET')
@login_required_no_redirect(False)
def home(request):
	"""
	Login or logout navbar is creates by means of create_nav_page
	@return:  the x intercept of the line M{y=m*x+b}.
	"""
	context = csrf(request)
	up = UserProfile.objects.defer('suggestions', 'highlight_code', 'embedded_youtube', 'online_change_sound', 'incoming_file_call_sound', 'message_sound', 'theme').get(id=request.user.id)
	context['suggestions'] = up.suggestions
	context['highlight_code'] = up.highlight_code
	context['message_sound'] = up.message_sound
	context['incoming_file_call_sound'] = up.incoming_file_call_sound
	context['online_change_sound'] = up.online_change_sound
	context['theme'] = up.theme
	context['embedded_youtube'] = up.embedded_youtube
	context['extensionId'] = settings.EXTENSION_ID
	context['extensionUrl'] = settings.EXTENSION_INSTALL_URL
	context['defaultRoomId'] = settings.ALL_ROOM_ID
	context['manifest'] = hasattr(settings, 'FIREBASE_API_KEY')
	return render_to_response('chat.html', context, context_instance=RequestContext(request))


@login_required_no_redirect(True)
def logout(request):
	"""
	POST. Logs out into system.
	"""
	registration_id = request.POST.get('registration_id')
	if registration_id is not None:
		Subscription.objects.filter(registration_id=registration_id).delete()
	djangologout(request)
	return HttpResponse(settings.VALIDATION_IS_OK, content_type='text/plain')

@require_http_methods(['POST'])
def auth(request):
	"""
	Logs in into system.
	"""
	username = request.POST.get('username')
	password = request.POST.get('password')
	user = authenticate(username=username, password=password)
	if user is not None:
		djangologin(request, user)
		message = settings.VALIDATION_IS_OK
	else:
		message = 'Login or password is wrong'
	logger.debug('Auth request %s ; Response: %s', hide_fields(request.POST, ('password',)), message)
	return HttpResponse(message, content_type='text/plain')


def send_restore_password(request):
	"""
	Sends email verification code
	"""
	logger.debug('Recover password request %s', request)
	try:
		username_or_password = request.POST.get('username_or_password')
		check_captcha(request)
		user_profile = UserProfile.objects.get(Q(username=username_or_password) | Q(email=username_or_password))
		if not user_profile.email:
			raise ValidationError("You didn't specify email address for this user")
		verification = Verification(type_enum=Verification.TypeChoices.password, user_id=user_profile.id)
		verification.save()
		send_reset_password_email(request, user_profile, verification)
		message = settings.VALIDATION_IS_OK
		logger.debug('Verification email has been send for token %s to user %s(id=%d)',
				verification.token, user_profile.username, user_profile.id)
	except UserProfile.DoesNotExist:
		message = "User with this email or username doesn't exist"
		logger.debug("Skipping password recovery request for nonexisting user")
	except (UserProfile.DoesNotExist, ValidationError) as e:
		logger.debug('Not sending verification email because %s', e)
		message = 'Unfortunately we were not able to send you restore password email because {}'.format(e)
	return HttpResponse(message, content_type='text/plain')


def get_html_restore_pass():
	""""""

class RestorePassword(View):

	def get_user_by_code(self, token):
		"""
		:param token: token code to verify
		:type token: str
		:raises ValidationError: if token is not usable
		:return: UserProfile, Verification: if token is usable
		"""
		try:
			v = Verification.objects.get(token=token)
			if v.type_enum != Verification.TypeChoices.password:
				raise ValidationError("it's not for this operation ")
			if v.verified:
				raise ValidationError("it's already used")
			# TODO move to sql query or leave here?
			if v.time < datetime.datetime.utcnow().replace(tzinfo=utc) - datetime.timedelta(days=1):
				raise ValidationError("it's expired")
			return UserProfile.objects.get(id=v.user_id), v
		except Verification.DoesNotExist:
			raise ValidationError('Unknown verification token')

	@transaction.atomic
	def post(self, request):
		"""
		Sends email verification token
		"""
		token = request.POST.get('token', False)
		try:
			logger.debug('Proceed Recover password with token %s', token)
			user, verification = self.get_user_by_code(token)
			password = request.POST.get('password')
			check_password(password)
			user.set_password(password)
			user.save(update_fields=('password',))
			verification.verified = True
			verification.save(update_fields=('verified',))
			logger.info('Password has been change for token %s user %s(id=%d)', token, user.username, user.id)
			response = settings.VALIDATION_IS_OK
		except ValidationError as e:
			logger.debug('Rejecting verification token %s because %s', token, e)
			response = "".join(("You can't reset password with this token because ", str(e)))
		return HttpResponse(response, content_type='text/plain')

	def get(self, request):
		token = request.GET.get('token', False)
		logger.debug('Rendering restore password page with token  %s', token)
		try:
			user = self.get_user_by_code(token)[0]
			response = {
				'message': settings.VALIDATION_IS_OK,
				'restore_user': user.username,
				'token': token
			}
		except ValidationError as e:
			logger.debug('Rejecting verification token %s because %s', token, e)
			response = {'message': "Unable to confirm email with token {} because {}".format(token, e)}
		return render_to_response('reset_password.html', response, context_instance=RequestContext(request))


@require_http_methods('GET')
def confirm_email(request):
	"""
	Accept the verification token sent to email
	"""
	token = request.GET.get('token', False)
	logger.debug('Processing email confirm with token  %s', token)
	try:
		try:
			v = Verification.objects.get(token=token)
		except Verification.DoesNotExist:
			raise ValidationError('Unknown verification token')
		if v.type_enum != Verification.TypeChoices.register:
			raise ValidationError('This is not confirm email token')
		if v.verified:
			raise ValidationError('This verification token already accepted')
		user = UserProfile.objects.get(id=v.user_id)
		if user.email_verification_id != v.id:
			raise ValidationError('Verification token expired because you generated another one')
		v.verified = True
		v.save(update_fields=['verified'])
		message = settings.VALIDATION_IS_OK
		logger.info('Email verification token %s has been accepted for user %s(id=%d)', token, user.username, user.id)
	except Exception as e:
		logger.debug('Rejecting verification token %s because %s', token, e)
		message = ("Unable to confirm email with token {} because {}".format(token, e))
	response = {'message': message}
	return render_to_response('confirm_mail.html', response, context_instance=RequestContext(request))


@require_http_methods('GET')
def show_profile(request, profile_id):
	try:
		user_profile = UserProfile.objects.get(pk=profile_id)
		form = UserProfileReadOnlyForm(instance=user_profile)
		form.username = user_profile.username
		return render_to_response(
			'show_profile.html',
			{'form': form},
			context_instance=RequestContext(request)
		)
	except ObjectDoesNotExist:
		raise Http404


@require_http_methods('GET')
def statistics(request):
	pie_data = IpAddress.objects.values('country').filter(country__isnull=False).annotate(count=Count("country"))
	return HttpResponse(json.dumps(list(pie_data)), content_type='application/json')


@login_required_no_redirect()
@transaction.atomic
def report_issue(request):
	logger.info('Saving issue: %s', hide_fields(request.POST, ('log',), huge=True))
	issue_text = request.POST['issue']
	issue = Issue.objects.get_or_create(content=issue_text)[0]
	issue_details = IssueDetails(
		sender_id=request.user.id,
		browser=request.POST.get('browser'),
		issue=issue,
		log=request.POST.get('log')
	)
	try:
		mail_admins("{} reported issue".format(request.user.username), issue_text, fail_silently=True)
	except Exception as e:
		logging.error("Failed to send issue email because {}".format(e))
	issue_details.save()
	return HttpResponse(settings.VALIDATION_IS_OK, content_type='text/plain')


class ProfileView(View):

	@login_required_no_redirect()
	def get(self, request):
		user_profile = UserProfile.objects.get(pk=request.user.id)
		form = UserProfileForm(instance=user_profile)
		c = csrf(request)
		c['form'] = form
		c['date_format'] = settings.DATE_INPUT_FORMATS_JS
		return render_to_response('change_profile.html', c, context_instance=RequestContext(request))

	@login_required_no_redirect()
	def post(self, request):
		logger.info('Saving profile: %s', hide_fields(request.POST, ("base64_image", ), huge=True))
		user_profile = UserProfile.objects.get(pk=request.user.id)
		image_base64 = request.POST.get('base64_image')

		if image_base64 is not None:
			image = extract_photo(image_base64)
			request.FILES['photo'] = image

		form = UserProfileForm(request.POST, request.FILES, instance=user_profile)
		if form.is_valid():
			profile = form.save()
			response = profile. photo.url if 'photo' in  request.FILES else settings.VALIDATION_IS_OK
		else:
			response = form.errors
		return HttpResponse(response, content_type='text/plain')


class RegisterView(View):

	def get(self, request):
		logger.debug(
			'Rendering register page with captcha site key %s and oauth key %s',
			RECAPTCHA_SITE_KEY, GOOGLE_OAUTH_2_CLIENT_ID
		)
		c = csrf(request)
		c['captcha_key'] = RECAPTCHA_SITE_KEY
		c['captcha_url'] = RECAPTHCA_SITE_URL
		c['oauth_url'] = GOOGLE_OAUTH_2_JS_URL
		c['oauth_token'] = GOOGLE_OAUTH_2_CLIENT_ID
		c['fb_app_id'] = FACEBOOK_APP_ID
		c['fb_js_url'] = FACEBOOK_JS_URL
		return render_to_response("register.html", c, context_instance=RequestContext(request))

	@transaction.atomic
	def post(self, request):
		try:
			rp = request.POST
			logger.info('Got register request %s', hide_fields(rp, ('password', 'repeatpassword')))
			(username, password, email) = (rp.get('username'), rp.get('password'), rp.get('email'))
			check_user(username)
			check_password(password)
			check_email(email)
			user_profile = UserProfile(username=username, email=email, sex_str=rp.get('sex'))
			user_profile.set_password(password)
			create_user_model(user_profile)
			# You must call authenticate before you can call login
			auth_user = authenticate(username=username, password=password)
			message = settings.VALIDATION_IS_OK  # redirect
			if email:
				send_sign_up_email(user_profile, request.get_host(), request)
			djangologin(request, auth_user)
		except ValidationError as e:
			message = e.message
			logger.debug('Rejecting request because "%s"', message)
		return HttpResponse(message, content_type='text/plain')


1			# -- encoding: utf-8 --
2			import datetime
3			import json
4			import logging
5
6			import os
7			from django.conf import settings
8			from django.contrib.auth import authenticate
9			from django.contrib.auth import login as djangologin
10			from django.contrib.auth import logout as djangologout
11			from django.core.mail import send_mail, mail_admins
12
13			from chat.templatetags.md5url import md5url
14
15			try:
16			from django.template.context_processors import csrf
17			except ImportError:
18			from django.core.context_processors import csrf
19			from django.core.exceptions import ObjectDoesNotExist, ValidationError
20			from django.db import transaction
21			from django.db.models import Count, Q, F
22			from django.http import Http404
23			from django.utils.timezone import utc
24			from django.http import HttpResponse
25			from django.http import HttpResponseRedirect
26			from django.shortcuts import render_to_response
27			from django.template import RequestContext
28			from django.views.decorators.http import require_http_methods
29			from django.views.generic import View
30			from chat import utils
31			from chat.decorators import login_required_no_redirect
32			from chat.forms import UserProfileForm, UserProfileReadOnlyForm
33			from chat.models import Issue, IssueDetails, IpAddress, UserProfile, Verification, Message, Subscription, \
34			SubscriptionMessages, RoomUsers
35			from django.conf import settings
36			from chat.utils import hide_fields, check_user, check_password, check_email, extract_photo, send_sign_up_email, \
37			create_user_model, check_captcha, send_reset_password_email, get_client_ip, get_or_create_ip
38
39			logger = logging.getLogger(__name__)
40			RECAPTCHA_SITE_KEY = getattr(settings, "RECAPTCHA_SITE_KEY", None)
41			RECAPTHCA_SITE_URL = getattr(settings, "RECAPTHCA_SITE_URL", None)
42			GOOGLE_OAUTH_2_CLIENT_ID = getattr(settings, "GOOGLE_OAUTH_2_CLIENT_ID", None)
43			GOOGLE_OAUTH_2_JS_URL = getattr(settings, "GOOGLE_OAUTH_2_JS_URL", None)
44			FACEBOOK_APP_ID = getattr(settings, "FACEBOOK_APP_ID", None)
45			FACEBOOK_JS_URL = getattr(settings, "FACEBOOK_JS_URL", None)
46
47			# TODO doesn't work
48			def handler404(request):
49			return HttpResponse("Page not found", content_type='text/plain')
50
51
52			@require_http_methods(['POST'])
53			def validate_email(request):
54			"""
55			POST only, validates email during registration
56			"""
57			email = request.POST.get('email')
58			try:
59			utils.check_email(email)
60			response = settings.VALIDATION_IS_OK
61			except ValidationError as e:
62			response = e.message
63			return HttpResponse(response, content_type='text/plain')
64
65
66			@require_http_methods(['POST'])
67			@login_required_no_redirect(False)
68			def save_room_settings(request):
69			"""
70			POST only, validates email during registration
71			"""
72			logger.debug('save_room_settings request, %s', request.POST)
73			room_id = request.POST['roomId']
74			updated = RoomUsers.objects.filter(room_id=room_id, user_id=request.user.id).update(
75			volume=request.POST['volume'],
76			notifications=request.POST['notifications'] == 'true',
77			)
78			return HttpResponse(settings.VALIDATION_IS_OK if updated == 1 else "Nothing updated", content_type='text/plain')
79
80
81			@require_http_methods('GET')
82			@transaction.atomic
83			def get_firebase_playback(request):
84			registration_id = request.META['HTTP_AUTH']
85			logger.debug('Firebase playback, id %s', registration_id)
86			query_sub_message = SubscriptionMessages.objects.filter(subscription__registration_id=registration_id, received=False).order_by('-message__time')[:1]
87			sub_message = query_sub_message[0]
88			SubscriptionMessages.objects.filter(id=sub_message.id).update(received=True)
89			message = Message.objects.select_related("sender__username", "room__name").get(id=sub_message.message_id)
90			data = {
91			'title': message.sender.username,
92			'options': {
93			'body': message.content,
94			'icon': md5url('images/favicon.ico'),
95			'data': {
96			'id': sub_message.message_id,
97			'sender': message.sender.username,
98			'room': message.room.name,
99			'roomId': message.room_id
100			},
101			'requireInteraction': True
102			},
103			}
104			return HttpResponse(json.dumps(data), content_type='application/json')
105
106
107			def test(request):
108			return HttpResponse(settings.VALIDATION_IS_OK, content_type='text/plain')
109
110
111			@require_http_methods('POST')
112			def register_subscription(request):
113			logger.debug('Subscription request, %s', request)
114			registration_id = request.POST['registration_id']
115			agent = request.POST['agent']
116			is_mobile = request.POST['is_mobile']
117			ip = get_or_create_ip(get_client_ip(request), logger)
118			Subscription.objects.update_or_create(
119			registration_id=registration_id,
120			defaults={
121			'user': request.user,
122			'inactive': False,
123			'updated': datetime.datetime.now(),
124			'agent': agent,
125			'is_mobile': is_mobile == 'true',
126			'ip': ip
127			}
128			)
129			return HttpResponse(settings.VALIDATION_IS_OK, content_type='text/plain')
130
131			@require_http_methods('POST')
132			def validate_user(request):
133			"""
134			Validates user during registration
135			"""
136			try:
137			username = request.POST.get('username')
138			utils.check_user(username)
139			# hardcoded ok check in register.js
140			message = settings.VALIDATION_IS_OK
141			except ValidationError as e:
142			message = e.message
143			return HttpResponse(message, content_type='text/plain')
144
145
146			def get_service_worker(request): # this stub is only for development, this is replaced in nginx for prod
147			worker = open(os.path.join(settings.STATIC_ROOT, 'js', 'sw.js'), 'rb')
148			response = HttpResponse(content=worker)
149			response['Content-Type'] = 'application/javascript'
150			return response
151
152			@require_http_methods('GET')
153			@login_required_no_redirect(False)
154			def home(request):
155			"""
156			Login or logout navbar is creates by means of create_nav_page
157			@return: the x intercept of the line M{y=m*x+b}.
158			"""
159			context = csrf(request)
160			up = UserProfile.objects.defer('suggestions', 'highlight_code', 'embedded_youtube', 'online_change_sound', 'incoming_file_call_sound', 'message_sound', 'theme').get(id=request.user.id)
161			context['suggestions'] = up.suggestions
162			context['highlight_code'] = up.highlight_code
163			context['message_sound'] = up.message_sound
164			context['incoming_file_call_sound'] = up.incoming_file_call_sound
165			context['online_change_sound'] = up.online_change_sound
166			context['theme'] = up.theme
167			context['embedded_youtube'] = up.embedded_youtube
168			context['extensionId'] = settings.EXTENSION_ID
169			context['extensionUrl'] = settings.EXTENSION_INSTALL_URL
170			context['defaultRoomId'] = settings.ALL_ROOM_ID
171			context['manifest'] = hasattr(settings, 'FIREBASE_API_KEY')
172			return render_to_response('chat.html', context, context_instance=RequestContext(request))
173
174
175			@login_required_no_redirect(True)
176			def logout(request):
177			"""
178			POST. Logs out into system.
179			"""
180			registration_id = request.POST.get('registration_id')
181			if registration_id is not None:
182			Subscription.objects.filter(registration_id=registration_id).delete()
183			djangologout(request)
184			return HttpResponse(settings.VALIDATION_IS_OK, content_type='text/plain')
185
186			@require_http_methods(['POST'])
187			def auth(request):
188			"""
189			Logs in into system.
190			"""
191			username = request.POST.get('username')
192			password = request.POST.get('password')
193			user = authenticate(username=username, password=password)
194			if user is not None:
195			djangologin(request, user)
196			message = settings.VALIDATION_IS_OK
197			else:
198			message = 'Login or password is wrong'
199			logger.debug('Auth request %s ; Response: %s', hide_fields(request.POST, ('password',)), message)
200			return HttpResponse(message, content_type='text/plain')
201
202
203			def send_restore_password(request):
204			"""
205			Sends email verification code
206			"""
207			logger.debug('Recover password request %s', request)
208			try:
209			username_or_password = request.POST.get('username_or_password')
210			check_captcha(request)
211			user_profile = UserProfile.objects.get(Q(username=username_or_password) \| Q(email=username_or_password))
212			if not user_profile.email:
213			raise ValidationError("You didn't specify email address for this user")
214			verification = Verification(type_enum=Verification.TypeChoices.password, user_id=user_profile.id)
215			verification.save()
216			send_reset_password_email(request, user_profile, verification)
217			message = settings.VALIDATION_IS_OK
218			logger.debug('Verification email has been send for token %s to user %s(id=%d)',
219			verification.token, user_profile.username, user_profile.id)
220			except UserProfile.DoesNotExist:
221			message = "User with this email or username doesn't exist"
222			logger.debug("Skipping password recovery request for nonexisting user")
223			except (UserProfile.DoesNotExist, ValidationError) as e:
224			logger.debug('Not sending verification email because %s', e)
225			message = 'Unfortunately we were not able to send you restore password email because {}'.format(e)
226			return HttpResponse(message, content_type='text/plain')
227
228
229			def get_html_restore_pass():
230			""""""
231
232			class RestorePassword(View):
233
234			def get_user_by_code(self, token):
235			"""
236			:param token: token code to verify
237			:type token: str
238			:raises ValidationError: if token is not usable
239			:return: UserProfile, Verification: if token is usable
240			"""
241			try:
242			v = Verification.objects.get(token=token)
243			if v.type_enum != Verification.TypeChoices.password:
244			raise ValidationError("it's not for this operation ")
245			if v.verified:
246			raise ValidationError("it's already used")
247			# TODO move to sql query or leave here?
248			if v.time < datetime.datetime.utcnow().replace(tzinfo=utc) - datetime.timedelta(days=1):
249			raise ValidationError("it's expired")
250			return UserProfile.objects.get(id=v.user_id), v
251			except Verification.DoesNotExist:
252			raise ValidationError('Unknown verification token')
253
254			@transaction.atomic
255			def post(self, request):
256			"""
257			Sends email verification token
258			"""
259			token = request.POST.get('token', False)
260			try:
261			logger.debug('Proceed Recover password with token %s', token)
262			user, verification = self.get_user_by_code(token)
263			password = request.POST.get('password')
264			check_password(password)
265			user.set_password(password)
266			user.save(update_fields=('password',))
267			verification.verified = True
268			verification.save(update_fields=('verified',))
269			logger.info('Password has been change for token %s user %s(id=%d)', token, user.username, user.id)
270			response = settings.VALIDATION_IS_OK
271			except ValidationError as e:
272			logger.debug('Rejecting verification token %s because %s', token, e)
273			response = "".join(("You can't reset password with this token because ", str(e)))
274			return HttpResponse(response, content_type='text/plain')
275
276			def get(self, request):
277			token = request.GET.get('token', False)
278			logger.debug('Rendering restore password page with token %s', token)
279			try:
280			user = self.get_user_by_code(token)[0]
281			response = {
282			'message': settings.VALIDATION_IS_OK,
283			'restore_user': user.username,
284			'token': token
285			}
286			except ValidationError as e:
287			logger.debug('Rejecting verification token %s because %s', token, e)
288			response = {'message': "Unable to confirm email with token {} because {}".format(token, e)}
289			return render_to_response('reset_password.html', response, context_instance=RequestContext(request))
290
291
292			@require_http_methods('GET')
293			def confirm_email(request):
294			"""
295			Accept the verification token sent to email
296			"""
297			token = request.GET.get('token', False)
298			logger.debug('Processing email confirm with token %s', token)
299			try:
300			try:
301			v = Verification.objects.get(token=token)
302			except Verification.DoesNotExist:
303			raise ValidationError('Unknown verification token')
304			if v.type_enum != Verification.TypeChoices.register:
305			raise ValidationError('This is not confirm email token')
306			if v.verified:
307			raise ValidationError('This verification token already accepted')
308			user = UserProfile.objects.get(id=v.user_id)
309			if user.email_verification_id != v.id:
310			raise ValidationError('Verification token expired because you generated another one')
311			v.verified = True
312			v.save(update_fields=['verified'])
313			message = settings.VALIDATION_IS_OK
314			logger.info('Email verification token %s has been accepted for user %s(id=%d)', token, user.username, user.id)
315			except Exception as e:
316			logger.debug('Rejecting verification token %s because %s', token, e)
317			message = ("Unable to confirm email with token {} because {}".format(token, e))
318			response = {'message': message}
319			return render_to_response('confirm_mail.html', response, context_instance=RequestContext(request))
320
321
322			@require_http_methods('GET')
323			def show_profile(request, profile_id):
324			try:
325			user_profile = UserProfile.objects.get(pk=profile_id)
326			form = UserProfileReadOnlyForm(instance=user_profile)
327			form.username = user_profile.username
328			return render_to_response(
329			'show_profile.html',
330			{'form': form},
331			context_instance=RequestContext(request)
332			)
333			except ObjectDoesNotExist:
334			raise Http404
335
336
337			@require_http_methods('GET')
338			def statistics(request):
339			pie_data = IpAddress.objects.values('country').filter(country__isnull=False).annotate(count=Count("country"))
340			return HttpResponse(json.dumps(list(pie_data)), content_type='application/json')
341
342
343			@login_required_no_redirect()
344			@transaction.atomic
345			def report_issue(request):
346			logger.info('Saving issue: %s', hide_fields(request.POST, ('log',), huge=True))
347			issue_text = request.POST['issue']
348			issue = Issue.objects.get_or_create(content=issue_text)[0]
349			issue_details = IssueDetails(
350			sender_id=request.user.id,
351			browser=request.POST.get('browser'),
352			issue=issue,
353			log=request.POST.get('log')
354			)
355			try:
356			mail_admins("{} reported issue".format(request.user.username), issue_text, fail_silently=True)
357			except Exception as e:
358			logging.error("Failed to send issue email because {}".format(e))
359			issue_details.save()
360			return HttpResponse(settings.VALIDATION_IS_OK, content_type='text/plain')
361
362
363			class ProfileView(View):
364
365			@login_required_no_redirect()
366			def get(self, request):
367			user_profile = UserProfile.objects.get(pk=request.user.id)
368			form = UserProfileForm(instance=user_profile)
369			c = csrf(request)
370			c['form'] = form
371			c['date_format'] = settings.DATE_INPUT_FORMATS_JS
372			return render_to_response('change_profile.html', c, context_instance=RequestContext(request))
373
374			@login_required_no_redirect()
375			def post(self, request):
376			logger.info('Saving profile: %s', hide_fields(request.POST, ("base64_image", ), huge=True))
377			user_profile = UserProfile.objects.get(pk=request.user.id)
378			image_base64 = request.POST.get('base64_image')
379
380			if image_base64 is not None:
381			image = extract_photo(image_base64)
382			request.FILES['photo'] = image
383
384			form = UserProfileForm(request.POST, request.FILES, instance=user_profile)
385			if form.is_valid():
386			profile = form.save()
387			response = profile. photo.url if 'photo' in request.FILES else settings.VALIDATION_IS_OK
388			else:
389			response = form.errors
390			return HttpResponse(response, content_type='text/plain')
391
392
393			class RegisterView(View):
394
395			def get(self, request):
396			logger.debug(
397			'Rendering register page with captcha site key %s and oauth key %s',
398			RECAPTCHA_SITE_KEY, GOOGLE_OAUTH_2_CLIENT_ID
399			)
400			c = csrf(request)
401			c['captcha_key'] = RECAPTCHA_SITE_KEY
402			c['captcha_url'] = RECAPTHCA_SITE_URL
403			c['oauth_url'] = GOOGLE_OAUTH_2_JS_URL
404			c['oauth_token'] = GOOGLE_OAUTH_2_CLIENT_ID
405			c['fb_app_id'] = FACEBOOK_APP_ID
406			c['fb_js_url'] = FACEBOOK_JS_URL
407			return render_to_response("register.html", c, context_instance=RequestContext(request))
408
409			@transaction.atomic
410			def post(self, request):
411			try:
412			rp = request.POST
413			logger.info('Got register request %s', hide_fields(rp, ('password', 'repeatpassword')))
414			(username, password, email) = (rp.get('username'), rp.get('password'), rp.get('email'))
415			check_user(username)
416			check_password(password)
417			check_email(email)
418			user_profile = UserProfile(username=username, email=email, sex_str=rp.get('sex'))
419			user_profile.set_password(password)
420			create_user_model(user_profile)
421			# You must call authenticate before you can call login
422			auth_user = authenticate(username=username, password=password)
423			message = settings.VALIDATION_IS_OK # redirect
424			if email:
425			send_sign_up_email(user_profile, request.get_host(), request)
426			djangologin(request, auth_user)
427			except ValidationError as e:
428			message = e.message
429			logger.debug('Rejecting request because "%s"', message)
430			return HttpResponse(message, content_type='text/plain')
431

Deathangel908 / pychat

Push — master ( ded4cb...5b64a2 )

get_firebase_playback() B

Complexity

Size

Duplication

Importance

Duplication Side-by-Side

Filter issues like