# 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