# frozen_string_literal: true
require "forwardable"
require_relative "./blather_ext"
require_relative "./customer_usage"
require_relative "./customer_plan"
require_relative "./customer_ogm"
require_relative "./customer_finacials"
require_relative "./backend_sgx"
require_relative "./invites_repo"
require_relative "./payment_methods"
require_relative "./plan"
require_relative "./proxied_jid"
require_relative "./sip_account"
require_relative "./trivial_backend_sgx_repo"
class Customer
extend Forwardable
attr_reader :customer_id, :balance, :jid, :tndetails
alias billing_customer_id customer_id
def_delegators :@plan, :active?, :activate_plan_starting_now, :bill_plan,
:currency, :merchant_account, :plan_name, :minute_limit,
:message_limit, :monthly_overage_limit, :activation_date,
:expires_at, :monthly_price, :save_plan!
def_delegators :@sgx, :deregister!, :register!, :registered?, :set_ogm_url,
:fwd, :transcription_enabled
def_delegators :@usage, :usage_report, :message_usage, :incr_message_usage
def_delegators :@financials, :payment_methods, :btc_addresses,
:add_btc_address, :declines, :mark_decline,
:transactions
def self.extract(customer_id, jid, **kwargs)
klass, *keys = if kwargs[:parent_customer_id]
[ChildCustomer, :parent_customer_id]
else
[Customer]
end
klass.new(
customer_id, jid,
plan: CustomerPlan.extract(customer_id, kwargs),
**kwargs.slice(:balance, :sgx, :tndetails, *keys)
)
end
def initialize(
customer_id,
jid,
plan: CustomerPlan.new(customer_id),
balance: BigDecimal(0),
tndetails: {},
sgx: TrivialBackendSgxRepo.new.get(customer_id)
)
@plan = plan
@usage = CustomerUsage.new(customer_id)
@financials = CustomerFinancials.new(customer_id)
@customer_id = customer_id
@jid = jid
@balance = balance
@tndetails = tndetails
@sgx = sgx
end
def with_balance(balance)
self.class.new(
@customer_id, @jid,
plan: @plan, balance: balance,
tndetails: @tndetails, sgx: @sgx
)
end
def with_plan(plan_name)
self.class.new(
@customer_id, @jid,
plan: @plan.with_plan_name(plan_name),
balance: @balance, tndetails: @tndetails, sgx: @sgx
)
end
def billing_customer(*)
EMPromise.resolve(self)
end
def auto_top_up_amount
if @plan.auto_top_up_amount.positive? &&
balance < -@plan.auto_top_up_amount + 5
-balance + @plan.auto_top_up_amount
else
@plan.auto_top_up_amount
end
end
def unused_invites
InvitesRepo.new(DB).unused_invites(customer_id)
end
def stanza_to(stanza)
stanza = stanza.dup
stanza.to = jid.with(resource: stanza.to&.resource)
stanza.from ||= Blather::JID.new("")
stanza.from = stanza.from.with(domain: CONFIG[:component][:jid])
block_given? ? yield(stanza) : (BLATHER << stanza)
end
def stanza_from(stanza)
BLATHER << @sgx.stanza(stanza)
end
def fetch_pep(node, from_tel=nil)
iq = Blather::Stanza::PubSub::Items.new(:get)
iq.node = node
iq.from = Blather::JID.new(from_tel, CONFIG[:component][:jid])
stanza_to(iq, &IQ_MANAGER.method(:write))
end
def ogm(from_tel=nil)
fetch_vcard = -> { fetch_pep("urn:xmpp:vcard4", from_tel) }
CustomerOGM.for(@sgx.ogm_url, @sgx.registered?.phone, fetch_vcard)
end
def sip_account
SipAccount.find(customer_id)
end
def reset_sip_account
sip_account.with_random_password.put
end
def admin?
CONFIG[:admins].include?(jid.to_s)
end
class ChildCustomer < Customer
def initialize(*args, parent_customer_id:, **kwargs)
super(*args, **kwargs)
@parent_customer_id = parent_customer_id
end
def billing_customer_id
@parent_customer_id
end
def billing_customer(repo=CustomerRepo.new)
repo.find(billing_customer_id)
end
end
end