# frozen_string_literal: true # This worker perform various requests to the Stripe API (payment service) class StripeWorker require 'stripe/helper' include Sidekiq::Worker sidekiq_options queue: :stripe def perform(action, *params) return false unless Stripe::Helper.enabled? 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') } ) pgo = PaymentGatewayObject.find_or_initialize_by(item: user) pgo.gateway_object = customer pgo.save! 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 warn "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.payment_gateway_object.nil? product = Stripe::Product.create( { name: object.name, metadata: { id: object.id, type: class_name } }, { api_key: Setting.get('stripe_secret_key') } ) pgo = PaymentGatewayObject.new(item: object) pgo.gateway_object = product pgo.save! Rails.logger.info "Stripe product was created for the #{class_name} \##{id}" else Stripe::Product.update( object.payment_gateway_object.gateway_object_id, { name: object.name }, { api_key: Setting.get('stripe_secret_key') } ) end rescue Stripe::InvalidRequestError obj_id = object.payment_gateway_object.gateway_object_id Rails.logger.warn "WARNING: saved payment_gateway_object#id (#{obj_id}) does not match on Stripe, recreating..." product = Stripe::Product.create( { name: object.name, metadata: { id: object.id, type: class_name } }, { api_key: Setting.get('stripe_secret_key') } ) pgo = PaymentGatewayObject.new(item: object) pgo.gateway_object = product pgo.save! Rails.logger.info "Stripe product was created for the #{class_name} \##{id}" end end