1# frozen_string_literal: true
 2
 3require "forwardable"
 4
 5require_relative "./blather_ext"
 6require_relative "./customer_plan"
 7require_relative "./customer_usage"
 8require_relative "./backend_sgx"
 9require_relative "./ibr"
10require_relative "./payment_methods"
11require_relative "./plan"
12require_relative "./sip_account"
13
14class Customer
15	extend Forwardable
16
17	attr_reader :customer_id, :balance, :jid
18	def_delegators :@plan, :active?, :activate_plan_starting_now, :bill_plan,
19	               :currency, :merchant_account, :plan_name, :auto_top_up_amount
20	def_delegators :@sgx, :register!, :registered?, :fwd_timeout=
21	def_delegators :@usage, :usage_report, :message_usage, :incr_message_usage
22
23	def initialize(
24		customer_id,
25		jid,
26		plan: CustomerPlan.new(customer_id),
27		balance: BigDecimal.new(0),
28		sgx: BackendSgx.new(customer_id)
29	)
30		@plan = plan
31		@usage = CustomerUsage.new(customer_id)
32		@customer_id = customer_id
33		@jid = jid
34		@balance = balance
35		@sgx = sgx
36	end
37
38	def with_plan(plan_name)
39		self.class.new(
40			@customer_id,
41			@jid,
42			plan: @plan.with_plan_name(plan_name),
43			balance: @balance,
44			sgx: @sgx
45		)
46	end
47
48	def payment_methods
49		BRAINTREE
50			.customer
51			.find(@customer_id)
52			.catch { OpenStruct.new(payment_methods: []) }
53			.then(PaymentMethods.method(:for_braintree_customer))
54	end
55
56	def unused_invites
57		promise = DB.query_defer(<<~SQL, [customer_id])
58			SELECT code FROM unused_invites WHERE creator_id=$1
59		SQL
60		promise.then { |result| result.map { |row| row["code"] } }
61	end
62
63	def stanza_to(stanza)
64		stanza = stanza.dup
65		stanza.to = jid.with(resource: stanza.to&.resource)
66		stanza.from = stanza.from.with(domain: CONFIG[:component][:jid])
67		BLATHER << stanza
68	end
69
70	def stanza_from(stanza)
71		BLATHER << @sgx.stanza(stanza)
72	end
73
74	def sip_account
75		SipAccount.find(customer_id)
76	end
77
78	def reset_sip_account
79		SipAccount::New.new(username: customer_id).put.catch do
80			sip_account.then { |acct| acct.with_random_password.put }
81		end
82	end
83
84	def btc_addresses
85		REDIS.smembers("jmp_customer_btc_addresses-#{customer_id}")
86	end
87
88	def add_btc_address
89		REDIS.spopsadd([
90			"jmp_available_btc_addresses",
91			"jmp_customer_btc_addresses-#{customer_id}"
92		]).then do |addr|
93			ELECTRUM.notify(addr, CONFIG[:electrum_notify_url].call(addr, customer_id))
94			addr
95		end
96	end
97
98	protected def_delegator :@plan, :expires_at
99end