515 lines
22 KiB
Python
515 lines
22 KiB
Python
import json
|
|
import logging
|
|
|
|
from django import forms
|
|
from django.conf import settings
|
|
from django.contrib import messages
|
|
from django.contrib.auth import login, authenticate
|
|
from django.core.exceptions import ValidationError
|
|
from django.core.urlresolvers import reverse
|
|
from django.http import HttpResponseRedirect, HttpResponse
|
|
from django.shortcuts import render
|
|
from django.utils.translation import get_language, ugettext_lazy as _
|
|
from django.views.decorators.cache import cache_control
|
|
from django.views.generic import FormView, CreateView, DetailView
|
|
|
|
from datacenterlight.tasks import create_vm_task
|
|
from hosting.forms import HostingUserLoginForm
|
|
from hosting.models import HostingOrder
|
|
from membership.models import CustomUser, StripeCustomer
|
|
from opennebula_api.serializers import VMTemplateSerializer
|
|
from utils.forms import BillingAddressForm, BillingAddressFormSignup
|
|
from utils.hosting_utils import get_vm_price
|
|
from utils.stripe_utils import StripeUtils
|
|
from utils.tasks import send_plain_email_task
|
|
from .forms import ContactForm
|
|
from .models import VMTemplate
|
|
from .utils import get_cms_integration
|
|
|
|
logger = logging.getLogger(__name__)
|
|
|
|
|
|
class ContactUsView(FormView):
|
|
template_name = "datacenterlight/contact_form.html"
|
|
form_class = ContactForm
|
|
|
|
def get(self, request, *args, **kwargs):
|
|
return HttpResponseRedirect(reverse('datacenterlight:index'))
|
|
|
|
def form_invalid(self, form):
|
|
if self.request.is_ajax():
|
|
return self.render_to_response(
|
|
self.get_context_data(contact_form=form))
|
|
else:
|
|
return render(
|
|
self.request, 'datacenterlight/index.html',
|
|
self.get_context_data(contact_form=form)
|
|
)
|
|
|
|
def form_valid(self, form):
|
|
form.save()
|
|
from_emails = {
|
|
'glasfaser': 'glasfaser@ungleich.ch'
|
|
}
|
|
from_page = self.request.POST.get('from_page')
|
|
email_data = {
|
|
'subject': "{dcl_text} Message from {sender}".format(
|
|
dcl_text=settings.DCL_TEXT,
|
|
sender=form.cleaned_data.get('email')
|
|
),
|
|
'from_email': settings.DCL_SUPPORT_FROM_ADDRESS,
|
|
'to': [from_emails.get(from_page, 'info@ungleich.ch')],
|
|
'body': "\n".join(
|
|
["%s=%s" % (k, v) for (k, v) in form.cleaned_data.items()]),
|
|
'reply_to': [form.cleaned_data.get('email')],
|
|
}
|
|
send_plain_email_task.delay(email_data)
|
|
if self.request.is_ajax():
|
|
return self.render_to_response(
|
|
self.get_context_data(success=True, contact_form=form))
|
|
else:
|
|
return render(
|
|
self.request, 'datacenterlight/index.html',
|
|
self.get_context_data(success=True, contact_form=form)
|
|
)
|
|
|
|
|
|
class IndexView(CreateView):
|
|
template_name = "datacenterlight/index.html"
|
|
success_url = "/datacenterlight#requestform"
|
|
success_message = "Thank you, we will contact you as soon as possible"
|
|
|
|
def validate_cores(self, value):
|
|
if (value > 48) or (value < 1):
|
|
raise ValidationError(_('Invalid number of cores'))
|
|
|
|
def validate_memory(self, value):
|
|
if (value > 200) or (value < 1):
|
|
raise ValidationError(_('Invalid RAM size'))
|
|
|
|
def validate_storage(self, value):
|
|
if (value > 2000) or (value < 10):
|
|
raise ValidationError(_('Invalid storage size'))
|
|
|
|
@cache_control(no_cache=True, must_revalidate=True, no_store=True)
|
|
def get(self, request, *args, **kwargs):
|
|
for session_var in ['specs', 'user', 'billing_address_data']:
|
|
if session_var in request.session:
|
|
del request.session[session_var]
|
|
return HttpResponseRedirect(reverse('datacenterlight:cms_index'))
|
|
|
|
def post(self, request):
|
|
cores = request.POST.get('cpu')
|
|
cores_field = forms.IntegerField(validators=[self.validate_cores])
|
|
memory = request.POST.get('ram')
|
|
memory_field = forms.IntegerField(validators=[self.validate_memory])
|
|
storage = request.POST.get('storage')
|
|
storage_field = forms.IntegerField(validators=[self.validate_storage])
|
|
template_id = int(request.POST.get('config'))
|
|
vm_pricing_name = request.POST.get('pricing_name')
|
|
template = VMTemplate.objects.filter(
|
|
opennebula_vm_template_id=template_id
|
|
).first()
|
|
template_data = VMTemplateSerializer(template).data
|
|
referer_url = request.META['HTTP_REFERER']
|
|
|
|
try:
|
|
cores = cores_field.clean(cores)
|
|
except ValidationError as err:
|
|
msg = '{} : {}.'.format(cores, str(err))
|
|
messages.add_message(
|
|
self.request, messages.ERROR, msg, extra_tags='cores'
|
|
)
|
|
return HttpResponseRedirect(referer_url + "#order_form")
|
|
|
|
try:
|
|
memory = memory_field.clean(memory)
|
|
except ValidationError as err:
|
|
msg = '{} : {}.'.format(memory, str(err))
|
|
messages.add_message(
|
|
self.request, messages.ERROR, msg, extra_tags='memory'
|
|
)
|
|
return HttpResponseRedirect(referer_url + "#order_form")
|
|
|
|
try:
|
|
storage = storage_field.clean(storage)
|
|
except ValidationError as err:
|
|
msg = '{} : {}.'.format(storage, str(err))
|
|
messages.add_message(
|
|
self.request, messages.ERROR, msg, extra_tags='storage'
|
|
)
|
|
return HttpResponseRedirect(referer_url + "#order_form")
|
|
|
|
amount_to_be_charged = get_vm_price(
|
|
cpu=cores,
|
|
memory=memory,
|
|
disk_size=storage,
|
|
pricing_name=vm_pricing_name
|
|
)
|
|
specs = {
|
|
'cpu': cores,
|
|
'memory': memory,
|
|
'disk_size': storage,
|
|
'price': amount_to_be_charged
|
|
}
|
|
request.session['specs'] = specs
|
|
request.session['template'] = template_data
|
|
return HttpResponseRedirect(reverse('datacenterlight:payment'))
|
|
|
|
def get_success_url(self):
|
|
success_url = reverse('datacenterlight:index')
|
|
success_url += "#requestform"
|
|
return success_url
|
|
|
|
def get_context_data(self, **kwargs):
|
|
context = super(IndexView, self).get_context_data(**kwargs)
|
|
context.update({
|
|
'base_url': "{0}://{1}".format(
|
|
self.request.scheme, self.request.get_host()
|
|
),
|
|
'contact_form': ContactForm
|
|
})
|
|
return context
|
|
|
|
|
|
class WhyDataCenterLightView(IndexView):
|
|
template_name = "datacenterlight/whydatacenterlight.html"
|
|
|
|
|
|
class PaymentOrderView(FormView):
|
|
template_name = 'datacenterlight/landing_payment.html'
|
|
|
|
def get_form_class(self):
|
|
if self.request.user.is_authenticated():
|
|
return BillingAddressForm
|
|
else:
|
|
return BillingAddressFormSignup
|
|
|
|
def get_context_data(self, **kwargs):
|
|
context = super(PaymentOrderView, self).get_context_data(**kwargs)
|
|
if 'billing_address_data' in self.request.session:
|
|
billing_address_data = self.request.session['billing_address_data']
|
|
else:
|
|
billing_address_data = {}
|
|
|
|
if self.request.user.is_authenticated():
|
|
if billing_address_data:
|
|
billing_address_form = BillingAddressForm(
|
|
initial=billing_address_data
|
|
)
|
|
else:
|
|
billing_address_form = BillingAddressForm(
|
|
instance=self.request.user.billing_addresses.first()
|
|
)
|
|
# Get user last order
|
|
last_hosting_order = HostingOrder.objects.filter(
|
|
customer__user=self.request.user
|
|
).last()
|
|
|
|
# If user has already an hosting order, get the credit card
|
|
# data from it
|
|
if last_hosting_order:
|
|
credit_card_data = last_hosting_order.get_cc_data()
|
|
if credit_card_data:
|
|
context['credit_card_data'] = credit_card_data
|
|
else:
|
|
context['credit_card_data'] = None
|
|
else:
|
|
billing_address_form = BillingAddressFormSignup(
|
|
initial=billing_address_data
|
|
)
|
|
|
|
context.update({
|
|
'stripe_key': settings.STRIPE_API_PUBLIC_KEY,
|
|
'site_url': reverse('datacenterlight:index'),
|
|
'login_form': HostingUserLoginForm(prefix='login_form'),
|
|
'billing_address_form': billing_address_form,
|
|
'cms_integration': get_cms_integration('default')
|
|
})
|
|
return context
|
|
|
|
@cache_control(no_cache=True, must_revalidate=True, no_store=True)
|
|
def get(self, request, *args, **kwargs):
|
|
if 'specs' not in request.session:
|
|
return HttpResponseRedirect(reverse('datacenterlight:index'))
|
|
return self.render_to_response(self.get_context_data())
|
|
|
|
def post(self, request, *args, **kwargs):
|
|
if 'login_form' in request.POST:
|
|
login_form = HostingUserLoginForm(
|
|
data=request.POST, prefix='login_form'
|
|
)
|
|
if login_form.is_valid():
|
|
email = login_form.cleaned_data.get('email')
|
|
password = login_form.cleaned_data.get('password')
|
|
auth_user = authenticate(email=email, password=password)
|
|
if auth_user:
|
|
login(self.request, auth_user)
|
|
return HttpResponseRedirect(
|
|
reverse('datacenterlight:payment')
|
|
)
|
|
else:
|
|
context = self.get_context_data()
|
|
context['login_form'] = login_form
|
|
return self.render_to_response(context)
|
|
if request.user.is_authenticated():
|
|
address_form = BillingAddressForm(
|
|
data=request.POST,
|
|
)
|
|
else:
|
|
address_form = BillingAddressFormSignup(
|
|
data=request.POST,
|
|
)
|
|
if address_form.is_valid():
|
|
token = address_form.cleaned_data.get('token')
|
|
if request.user.is_authenticated():
|
|
this_user = {
|
|
'email': request.user.email,
|
|
'name': request.user.name
|
|
}
|
|
customer = StripeCustomer.get_or_create(
|
|
email=this_user.get('email'),
|
|
token=token)
|
|
else:
|
|
user_email = address_form.cleaned_data.get('email')
|
|
user_name = address_form.cleaned_data.get('name')
|
|
this_user = {
|
|
'email': user_email,
|
|
'name': user_name
|
|
}
|
|
try:
|
|
custom_user = CustomUser.objects.get(email=user_email)
|
|
customer = StripeCustomer.objects.filter(
|
|
user_id=custom_user.id).first()
|
|
if customer is None:
|
|
logger.debug(
|
|
("User {email} is already registered with us."
|
|
"But, StripeCustomer does not exist for {email}."
|
|
"Hence, creating a new StripeCustomer.").format(
|
|
email=user_email
|
|
)
|
|
)
|
|
customer = StripeCustomer.create_stripe_api_customer(
|
|
email=user_email,
|
|
token=token,
|
|
customer_name=user_name)
|
|
except CustomUser.DoesNotExist:
|
|
logger.debug(
|
|
("StripeCustomer does not exist for {email}."
|
|
"Hence, creating a new StripeCustomer.").format(
|
|
email=user_email
|
|
)
|
|
)
|
|
customer = StripeCustomer.create_stripe_api_customer(
|
|
email=user_email,
|
|
token=token,
|
|
customer_name=user_name)
|
|
|
|
request.session['billing_address_data'] = address_form.cleaned_data
|
|
request.session['user'] = this_user
|
|
# Get or create stripe customer
|
|
if not customer:
|
|
address_form.add_error(
|
|
"__all__", "Invalid credit card"
|
|
)
|
|
return self.render_to_response(
|
|
self.get_context_data(
|
|
billing_address_form=address_form
|
|
)
|
|
)
|
|
request.session['token'] = token
|
|
if type(customer) is StripeCustomer:
|
|
request.session['customer'] = customer.stripe_id
|
|
else:
|
|
request.session['customer'] = customer
|
|
return HttpResponseRedirect(
|
|
reverse('datacenterlight:order_confirmation'))
|
|
else:
|
|
context = self.get_context_data()
|
|
context['billing_address_form'] = address_form
|
|
return self.render_to_response(context)
|
|
|
|
|
|
class OrderConfirmationView(DetailView):
|
|
template_name = "datacenterlight/order_detail.html"
|
|
payment_template_name = 'datacenterlight/landing_payment.html'
|
|
context_object_name = "order"
|
|
model = HostingOrder
|
|
|
|
@cache_control(no_cache=True, must_revalidate=True, no_store=True)
|
|
def get(self, request, *args, **kwargs):
|
|
if 'specs' not in request.session or 'user' not in request.session:
|
|
return HttpResponseRedirect(reverse('datacenterlight:index'))
|
|
if 'token' not in request.session:
|
|
return HttpResponseRedirect(reverse('datacenterlight:payment'))
|
|
stripe_api_cus_id = request.session.get('customer')
|
|
stripe_utils = StripeUtils()
|
|
card_details = stripe_utils.get_card_details(stripe_api_cus_id,
|
|
request.session.get(
|
|
'token'))
|
|
if not card_details.get('response_object'):
|
|
msg = card_details.get('error')
|
|
messages.add_message(self.request, messages.ERROR, msg,
|
|
extra_tags='failed_payment')
|
|
return HttpResponseRedirect(
|
|
reverse('datacenterlight:payment') + '#payment_error')
|
|
context = {
|
|
'site_url': reverse('datacenterlight:index'),
|
|
'cc_last4': card_details.get('response_object').get('last4'),
|
|
'cc_brand': card_details.get('response_object').get('brand'),
|
|
'vm': request.session.get('specs'),
|
|
'page_header_text': _('Confirm Order'),
|
|
'billing_address_data': (
|
|
request.session.get('billing_address_data')
|
|
),
|
|
'cms_integration': get_cms_integration('default')
|
|
}
|
|
return render(request, self.template_name, context)
|
|
|
|
def post(self, request, *args, **kwargs):
|
|
template = request.session.get('template')
|
|
specs = request.session.get('specs')
|
|
user = request.session.get('user')
|
|
stripe_api_cus_id = request.session.get('customer')
|
|
vm_template_id = template.get('id', 1)
|
|
stripe_utils = StripeUtils()
|
|
card_details = stripe_utils.get_card_details(stripe_api_cus_id,
|
|
request.session.get(
|
|
'token'))
|
|
if not card_details.get('response_object'):
|
|
msg = card_details.get('error')
|
|
messages.add_message(self.request, messages.ERROR, msg,
|
|
extra_tags='failed_payment')
|
|
response = {
|
|
'status': False,
|
|
'redirect': "{url}#{section}".format(
|
|
url=reverse('datacenterlight:payment'),
|
|
section='payment_error'),
|
|
'msg_title': str(_('Error.')),
|
|
'msg_body': str(
|
|
_('There was a payment related error.'
|
|
' On close of this popup, you will be redirected back to'
|
|
' the payment page.'))
|
|
}
|
|
return HttpResponse(json.dumps(response),
|
|
content_type="application/json")
|
|
card_details_dict = card_details.get('response_object')
|
|
cpu = specs.get('cpu')
|
|
memory = specs.get('memory')
|
|
disk_size = specs.get('disk_size')
|
|
amount_to_be_charged = specs.get('price')
|
|
plan_name = StripeUtils.get_stripe_plan_name(cpu=cpu,
|
|
memory=memory,
|
|
disk_size=disk_size)
|
|
stripe_plan_id = StripeUtils.get_stripe_plan_id(cpu=cpu,
|
|
ram=memory,
|
|
ssd=disk_size,
|
|
version=1,
|
|
app='dcl')
|
|
stripe_plan = stripe_utils.get_or_create_stripe_plan(
|
|
amount=amount_to_be_charged,
|
|
name=plan_name,
|
|
stripe_plan_id=stripe_plan_id)
|
|
subscription_result = stripe_utils.subscribe_customer_to_plan(
|
|
stripe_api_cus_id,
|
|
[{"plan": stripe_plan.get(
|
|
'response_object').stripe_plan_id}])
|
|
stripe_subscription_obj = subscription_result.get('response_object')
|
|
# Check if the subscription was approved and is active
|
|
if (stripe_subscription_obj is None
|
|
or stripe_subscription_obj.status != 'active'):
|
|
msg = subscription_result.get('error')
|
|
messages.add_message(self.request, messages.ERROR, msg,
|
|
extra_tags='failed_payment')
|
|
response = {
|
|
'status': False,
|
|
'redirect': "{url}#{section}".format(
|
|
url=reverse('datacenterlight:payment'),
|
|
section='payment_error'),
|
|
'msg_title': str(_('Error.')),
|
|
'msg_body': str(
|
|
_('There was a payment related error.'
|
|
' On close of this popup, you will be redirected back to'
|
|
' the payment page.'))
|
|
}
|
|
return HttpResponse(json.dumps(response),
|
|
content_type="application/json")
|
|
|
|
# Create user if the user is not logged in and if he is not already
|
|
# registered
|
|
if not request.user.is_authenticated():
|
|
try:
|
|
custom_user = CustomUser.objects.get(
|
|
email=user.get('email'))
|
|
stripe_customer = StripeCustomer.objects.filter(
|
|
user_id=custom_user.id).first()
|
|
if stripe_customer is None:
|
|
stripe_customer = StripeCustomer.objects.create(
|
|
user=custom_user, stripe_id=stripe_api_cus_id
|
|
)
|
|
stripe_customer_id = stripe_customer.id
|
|
except CustomUser.DoesNotExist:
|
|
logger.debug(
|
|
"Customer {} does not exist.".format(user.get('email')))
|
|
password = CustomUser.get_random_password()
|
|
base_url = "{0}://{1}".format(self.request.scheme,
|
|
self.request.get_host())
|
|
custom_user = CustomUser.register(
|
|
user.get('name'), password,
|
|
user.get('email'),
|
|
app='dcl', base_url=base_url, send_email=True,
|
|
account_details=password
|
|
)
|
|
logger.debug("Created user {}.".format(user.get('email')))
|
|
stripe_customer = StripeCustomer.objects. \
|
|
create(user=custom_user, stripe_id=stripe_api_cus_id)
|
|
stripe_customer_id = stripe_customer.id
|
|
new_user = authenticate(username=custom_user.email,
|
|
password=password)
|
|
login(request, new_user)
|
|
else:
|
|
# We assume that if the user is here, his/her StripeCustomer
|
|
# object already exists
|
|
stripe_customer_id = request.user.stripecustomer.id
|
|
custom_user = request.user
|
|
|
|
# Save billing address
|
|
billing_address_data = request.session.get('billing_address_data')
|
|
logger.debug('billing_address_data is {}'.format(billing_address_data))
|
|
billing_address_data.update({
|
|
'user': custom_user.id
|
|
})
|
|
user = {
|
|
'name': custom_user.name,
|
|
'email': custom_user.email,
|
|
'pass': custom_user.password,
|
|
'request_scheme': request.scheme,
|
|
'request_host': request.get_host(),
|
|
'language': get_language(),
|
|
}
|
|
|
|
create_vm_task.delay(vm_template_id, user, specs, template,
|
|
stripe_customer_id, billing_address_data,
|
|
stripe_subscription_obj.id, card_details_dict)
|
|
for session_var in ['specs', 'template', 'billing_address',
|
|
'billing_address_data',
|
|
'token', 'customer']:
|
|
if session_var in request.session:
|
|
del request.session[session_var]
|
|
|
|
response = {
|
|
'status': True,
|
|
'redirect': (
|
|
reverse('hosting:virtual_machines')
|
|
if request.user.is_authenticated()
|
|
else reverse('datacenterlight:index')
|
|
),
|
|
'msg_title': str(_('Thank you for the order.')),
|
|
'msg_body': str(
|
|
_('Your VM will be up and running in a few moments.'
|
|
' We will send you a confirmation email as soon as'
|
|
' it is ready.'))
|
|
}
|
|
|
|
return HttpResponse(json.dumps(response),
|
|
content_type="application/json")
|