dynamicweb/utils/stripe_utils.py

236 lines
9 KiB
Python
Raw Normal View History

import logging
import stripe
from django.conf import settings
from datacenterlight.models import StripePlan
2016-05-01 12:13:12 +00:00
stripe.api_key = settings.STRIPE_API_PRIVATE_KEY
logger = logging.getLogger(__name__)
def handleStripeError(f):
2016-05-04 15:36:54 +00:00
def handleProblems(*args, **kwargs):
response = {
'paid': False,
'response_object': None,
'error': None
}
2017-06-04 22:05:48 +00:00
2017-08-07 06:56:57 +00:00
common_message = "Currently it's not possible to make payments."
2016-05-04 15:36:54 +00:00
try:
response_object = f(*args, **kwargs)
response = {
2016-05-04 15:36:54 +00:00
'response_object': response_object,
'error': None
}
2016-05-04 15:36:54 +00:00
return response
except stripe.error.CardError as e:
# Since it's a decline, stripe.error.CardError will be caught
body = e.json_body
err = body['error']
response.update({'error': err['message']})
return response
except stripe.error.RateLimitError as e:
response.update({'error': "Too many requests made to the API too quickly"})
return response
except stripe.error.InvalidRequestError as e:
response.update({'error': "Invalid parameters"})
return response
except stripe.error.AuthenticationError as e:
# Authentication with Stripe's API failed
# (maybe you changed API keys recently)
response.update({'error': common_message})
return response
except stripe.error.APIConnectionError as e:
response.update({'error': common_message})
return response
except stripe.error.StripeError as e:
# maybe send email
response.update({'error': common_message})
return response
except Exception as e:
# maybe send email
response.update({'error': common_message})
return response
2016-05-04 15:36:54 +00:00
return handleProblems
2016-05-01 12:13:12 +00:00
class StripeUtils(object):
CURRENCY = 'chf'
INTERVAL = 'month'
SUCCEEDED_STATUS = 'succeeded'
STRIPE_PLAN_ALREADY_EXISTS = 'Plan already exists'
STRIPE_NO_SUCH_PLAN = 'No such plan'
PLAN_EXISTS_ERROR_MSG = 'Plan {} exists already.\nCreating a local StripePlan now.'
PLAN_DOES_NOT_EXIST_ERROR_MSG = 'Plan {} does not exist.'
def __init__(self):
self.stripe = stripe
2016-05-01 12:13:12 +00:00
2016-12-19 14:33:15 +00:00
def update_customer_token(self, customer, token):
2017-01-20 16:33:25 +00:00
customer.source = token
customer.save()
2016-12-19 14:33:15 +00:00
2017-01-20 16:33:25 +00:00
@handleStripeError
def update_customer_card(self, customer_id, token):
customer = stripe.Customer.retrieve(customer_id)
current_card_token = customer.default_source
customer.sources.retrieve(current_card_token).delete()
2016-12-19 14:33:15 +00:00
customer.source = token
customer.save()
2017-01-20 16:33:25 +00:00
credit_card_raw_data = customer.sources.data.pop()
new_card_data = {
'last4': credit_card_raw_data.last4,
'brand': credit_card_raw_data.brand
}
return new_card_data
2016-12-19 14:33:15 +00:00
@handleStripeError
def get_card_details(self, customer_id, token):
customer = stripe.Customer.retrieve(customer_id)
credit_card_raw_data = customer.sources.data.pop()
card_details = {
'last4': credit_card_raw_data.last4,
'brand': credit_card_raw_data.brand
}
return card_details
2016-05-04 15:36:54 +00:00
def check_customer(self, id, user, token):
2016-05-01 12:13:12 +00:00
customers = self.stripe.Customer.all()
if not customers.get('data'):
customer = self.create_customer(token, user.email, user.name)
2016-05-01 12:13:12 +00:00
else:
try:
customer = stripe.Customer.retrieve(id)
except stripe.InvalidRequestError:
customer = self.create_customer(token, user.email, user.name)
user.stripecustomer.stripe_id = customer.get('response_object').get('id')
2016-05-01 12:13:12 +00:00
user.stripecustomer.save()
return customer
2017-01-20 16:33:25 +00:00
@handleStripeError
def get_customer(self, id):
customer = stripe.Customer.retrieve(id)
# data = customer.get('response_object')
return customer
@handleStripeError
def create_customer(self, token, email, name=None):
if name is None or name.strip() == "":
name = email
customer = self.stripe.Customer.create(
2016-05-01 12:13:12 +00:00
source=token,
description=name,
2016-05-01 12:13:12 +00:00
email=email
)
return customer
@handleStripeError
def make_charge(self, amount=None, customer=None):
2017-05-25 18:04:29 +00:00
_amount = float(amount)
amount = int(_amount * 100) # stripe amount unit, in cents
charge = self.stripe.Charge.create(
2016-05-04 15:36:54 +00:00
amount=amount, # in cents
currency=self.CURRENCY,
customer=customer
)
return charge
@handleStripeError
def get_or_create_stripe_plan(self, amount, name, stripe_plan_id):
"""
2017-08-17 09:04:22 +00:00
This function checks if a StripePlan with the given stripe_plan_id already exists. If it exists then the
function returns this object otherwise it creates a new StripePlan and returns the new object.
:param amount: The amount in CHF
:param name: The name of the Stripe plan to be created.
2017-08-17 09:04:22 +00:00
:param stripe_plan_id: The id of the Stripe plan to be created. Use get_stripe_plan_id_string function to obtain
the name of the plan to be created
2017-08-17 11:23:49 +00:00
:return: The StripePlan object if it exists else creates a Plan object in Stripe and a local StripePlan and
returns it. Returns None in case of Stripe error
"""
_amount = float(amount)
amount = int(_amount * 100) # stripe amount unit, in cents
2017-08-17 09:04:22 +00:00
stripe_plan_db_obj = None
try:
stripe_plan_db_obj = StripePlan.objects.get(stripe_plan_id=stripe_plan_id)
except StripePlan.DoesNotExist:
try:
self.stripe.Plan.create(
amount=amount,
interval=self.INTERVAL,
name=name,
currency=self.CURRENCY,
id=stripe_plan_id)
stripe_plan_db_obj = StripePlan.objects.create(stripe_plan_id=stripe_plan_id)
except stripe.error.InvalidRequestError as e:
if self.STRIPE_PLAN_ALREADY_EXISTS in str(e):
logger.debug(self.PLAN_EXISTS_ERROR_MSG.format(stripe_plan_id))
stripe_plan_db_obj = StripePlan.objects.create(stripe_plan_id=stripe_plan_id)
return stripe_plan_db_obj
@handleStripeError
def delete_stripe_plan(self, stripe_plan_id):
"""
Deletes the Plan in Stripe and also deletes the local db copy of the plan if it exists
:param stripe_plan_id: The stripe plan id that needs to be deleted
2017-08-17 11:23:49 +00:00
:return: True if the plan was deleted successfully from Stripe, False otherwise.
"""
return_value = False
try:
plan = self.stripe.Plan.retrieve(stripe_plan_id)
plan.delete()
return_value = True
StripePlan.objects.filter(stripe_plan_id=stripe_plan_id).all().delete()
except stripe.error.InvalidRequestError as e:
if self.STRIPE_NO_SUCH_PLAN in str(e):
logger.debug(self.PLAN_DOES_NOT_EXIST_ERROR_MSG.format(stripe_plan_id))
return return_value
@handleStripeError
def subscribe_customer_to_plan(self, customer, plans):
"""
Subscribes the given customer to the list of given plans
:param customer: The stripe customer identifier
:param plans: A list of stripe plans. Ref: https://stripe.com/docs/api/python#create_subscription-items
e.g.
plans = [
{
"plan": "dcl-v1-cpu-2-ram-5gb-ssd-10gb",
},
]
:return: The subscription StripeObject
"""
subscription_result = self.stripe.Subscription.create(
customer=customer,
items=plans,
)
return subscription_result
2016-05-04 15:36:54 +00:00
@handleStripeError
def make_payment(self, customer, amount, token):
2016-05-04 15:36:54 +00:00
charge = self.stripe.Charge.create(
amount=amount, # in cents
currency=self.CURRENCY,
customer=customer
)
return charge
@staticmethod
def get_stripe_plan_id(cpu, ram, ssd, version, app):
"""
Returns the stripe plan id string of the form `dcl-v1-cpu-2-ram-5gb-ssd-10gb` based on the input parameters
:param cpu: The number of cores
:param ram: The size of the RAM in GB
:param ssd: The size of storage in GB
:param version: The version of the Stripe plans
:return: A string of the form `dcl-v1-cpu-2-ram-5gb-ssd-10gb`
"""
2017-08-17 11:23:49 +00:00
dcl_plan_string = 'cpu-{cpu}-ram-{ram}gb-ssd-{ssd}gb'.format(cpu=cpu, ram=ram, ssd=ssd)
stripe_plan_id_string = '{app}-v{version}-{plan}'.format(app=app, version=version, plan=dcl_plan_string)
2017-08-17 11:23:49 +00:00
return stripe_plan_id_string