mirror of
https://github.com/LaCasemate/fab-manager.git
synced 2024-11-29 10:24:20 +01:00
54 lines
1.5 KiB
Ruby
54 lines
1.5 KiB
Ruby
# frozen_string_literal: true
|
|
|
|
# This worker perform various requests to the Stripe API (payment service)
|
|
class StripeWorker
|
|
include Sidekiq::Worker
|
|
sidekiq_options queue: :stripe
|
|
|
|
def perform(action, *params)
|
|
send(action, *params)
|
|
end
|
|
|
|
def create_stripe_customer(user_id)
|
|
user = User.find(user_id)
|
|
customer = Stripe::Customer.create(
|
|
{
|
|
description: user.profile.full_name,
|
|
email: user.email
|
|
},
|
|
{ api_key: Setting.get('stripe_secret_key') }
|
|
)
|
|
user.update_columns(stp_customer_id: customer.id)
|
|
end
|
|
|
|
def delete_stripe_coupon(coupon_code)
|
|
cpn = Stripe::Coupon.retrieve(coupon_code, api_key: Setting.get('stripe_secret_key'))
|
|
cpn.delete
|
|
rescue Stripe::InvalidRequestError => e
|
|
STDERR.puts "WARNING: Unable to delete the coupon on Stripe: #{e}"
|
|
end
|
|
|
|
def create_or_update_stp_product(class_name, id)
|
|
object = class_name.constantize.find(id)
|
|
if !object.stp_product_id.nil?
|
|
Stripe::Product.update(
|
|
object.stp_product_id,
|
|
{ name: object.name },
|
|
{ api_key: Setting.get('stripe_secret_key') }
|
|
)
|
|
else
|
|
product = Stripe::Product.create(
|
|
{
|
|
name: object.name,
|
|
metadata: {
|
|
id: object.id,
|
|
type: class_name
|
|
}
|
|
}, { api_key: Setting.get('stripe_secret_key') }
|
|
)
|
|
object.update_attributes(stp_product_id: product.id)
|
|
puts "Stripe product was created for the #{class_name} \##{id}"
|
|
end
|
|
end
|
|
end
|