# frozen_string_literal: true require "forwardable" require_relative "./blather_ext" require_relative "./customer_plan" require_relative "./customer_usage" require_relative "./backend_sgx" require_relative "./ibr" require_relative "./payment_methods" require_relative "./plan" class Customer def self.for_jid(jid) REDIS.get("jmp_customer_id-#{jid}").then do |customer_id| raise "No customer id" unless customer_id for_customer_id(customer_id) end end def self.for_customer_id(customer_id) result = DB.query_defer(<<~SQL, [customer_id]) SELECT COALESCE(balance,0) AS balance, plan_name, expires_at FROM customer_plans LEFT JOIN balances USING (customer_id) WHERE customer_id=$1 LIMIT 1 SQL result.then do |rows| new(customer_id, **rows.first&.transform_keys(&:to_sym) || {}) end end def self.create(jid) BRAINTREE.customer.create.then do |result| raise "Braintree customer create failed" unless result.success? cid = result.customer.id REDIS.msetnx( "jmp_customer_id-#{jid}", cid, "jmp_customer_jid-#{cid}", jid ).then do |redis_result| raise "Saving new customer to redis failed" unless redis_result == 1 new(cid) end end end extend Forwardable attr_reader :customer_id, :balance def_delegators :@plan, :active?, :activate_plan_starting_now, :bill_plan, :currency, :merchant_account, :plan_name def_delegators :@sgx, :register!, :registered? def_delegator :@usage, :report, :usage_report def initialize( customer_id, plan_name: nil, expires_at: Time.now, balance: BigDecimal.new(0), sgx: BackendSgx.new(customer_id) ) @plan = CustomerPlan.new( customer_id, plan: plan_name && Plan.for(plan_name), expires_at: expires_at ) @usage = CustomerUsage.new(customer_id) @customer_id = customer_id @balance = balance @sgx = sgx end def with_plan(plan_name) self.class.new( @customer_id, balance: @balance, expires_at: expires_at, plan_name: plan_name ) end def payment_methods BRAINTREE .customer .find(@customer_id) .then(PaymentMethods.method(:for_braintree_customer)) end def jid @jid ||= REDIS.get("jmp_customer_jid-#{customer_id}").then do |sjid| Blather::JID.new(sjid) end end def stanza_to(stanza) jid.then do |jid| stanza = stanza.dup stanza.to = jid.with(resource: stanza.to&.resource) stanza.from = stanza.from.with(domain: CONFIG[:component][:jid]) BLATHER << stanza end end def stanza_from(stanza) BLATHER << @sgx.stanza(stanza) end protected def_delegator :@plan, :expires_at end