5 files changed, 101 insertions(+), 11 deletions(-)

A forms/customer_cdr.rb
M lib/cdr.rb
A lib/cdr_repo.rb
M sgx_jmp.rb
M web.rb

@@ 0,0 1,13 @@
+result!
+title "Call History"
+
+table(
+	@cdrs,
+	start: "Start",
+	direction: "Direction",
+	tel: "Number",
+	disposition: "Status",
+	duration: "Duration",
+	formatted_rate: "Rate",
+	formatted_charge: "Charge"
+)

@@ 30,7 30,25 @@ class CDR
 		billsec Integer
 		disposition Disposition
 		tel(/\A\+\d+\Z/)
-		direction Either(:inbound, :outbound)
+		direction Either(:inbound, :outbound), coerce: :to_sym.to_proc
+		rate Either(nil, BigDecimal), default: nil
+		charge Either(nil, BigDecimal), default: nil
+	end
+
+	def formatted_rate
+		"$%.4f" % rate
+	end
+
+	def formatted_charge
+		"$%.4f" % charge
+	end
+
+	def duration
+		"%02d:%02d:%02d" % [
+			billsec / (60 * 60),
+			billsec % (60 * 60) / 60,
+			billsec % 60
+		]
 	end
 
 	def self.for(event, **kwargs)


@@ 61,12 79,4 @@ class CDR
 			direction: :outbound
 		)
 	end
-
-	def save
-		columns, values = to_h.to_a.transpose
-		DB.query_defer(<<~SQL, values)
-			INSERT INTO cdr (#{columns.join(',')})
-			VALUES ($1, $2, $3, $4, $5, $6, $7)
-		SQL
-	end
 end

@@ 0,0 1,47 @@
+# frozen_string_literal: true
+
+require_relative "cdr"
+
+class CDRRepo
+	def initialize(db: DB)
+		@db = db
+	end
+
+	def put(cdr)
+		data = cdr.to_h
+		data.delete(:rate)
+		data.delete(:charge)
+		columns, values = data.to_a.transpose
+		DB.query_defer(<<~SQL, values)
+			INSERT INTO cdr (#{columns.join(',')})
+			VALUES ($1, $2, $3, $4, $5, $6, $7)
+		SQL
+	end
+
+	def find_range(customer, range)
+		customer_id = customer.customer_id
+		cdrs = @db.query_defer(CDR_SQL, [customer_id, range.first, range.last])
+
+		cdrs.then do |rows|
+			rows.map { |row|
+				CDR.new(**row.transform_keys(&:to_sym))
+			}
+		end
+	end
+
+	CDR_SQL = <<~SQL
+		SELECT
+			cdr_id,
+			customer_id,
+			start,
+			billsec,
+			disposition,
+			tel,
+			direction,
+			rate,
+			charge
+		FROM cdr_with_charge
+		WHERE customer_id = $1 AND start >= $2 AND DATE_TRUNC('day', start) <= $3
+		ORDER BY start DESC
+	SQL
+end

@@ 527,6 527,21 @@ Command.new(
 }.register(self).then(&CommandList.method(:register))
 
 Command.new(
+	"cdrs",
+	"Show Call Logs"
+) {
+	report_for = ((Date.today << 1)..Date.today)
+
+	Command.customer.then { |customer|
+		CDRRepo.new.find_range(customer, report_for)
+	}.then do |cdrs|
+		Command.finish do |reply|
+			reply.command << FormTemplate.render("customer_cdr", cdrs: cdrs)
+		end
+	end
+}.register(self).then(&CommandList.method(:register))
+
+Command.new(
 	"transactions",
 	"🧾 Show Transactions",
 	list_for: ->(customer:, **) { !!customer&.currency }

@@ 10,6 10,7 @@ require "sentry-ruby"
 
 require_relative "lib/call_attempt_repo"
 require_relative "lib/cdr"
+require_relative "lib/cdr_repo"
 require_relative "lib/oob"
 require_relative "lib/rev_ai"
 require_relative "lib/roda_capture"


@@ 121,6 122,10 @@ class Web < Roda
 		opts[:call_attempt_repo] || CallAttemptRepo.new
 	end
 
+	def cdr_repo
+		opts[:cdr_repo] || CDRRepo.new
+	end
+
 	def rev_ai
 		RevAi.new(logger: log.child(loggable_params))
 	end


@@ 200,7 205,7 @@ class Web < Roda
 						end
 
 						customer_repo.find_by_tel(params["to"]).then do |customer|
-							CDR.for_inbound(customer.customer_id, params).save
+							cdr_repo.put(CDR.for_inbound(customer.customer_id, params))
 						end
 					end
 					"OK"


@@ 359,7 364,7 @@ class Web < Roda
 					log.info "#{params['eventType']} #{params['callId']}", loggable_params
 					if params["eventType"] == "disconnect"
 						call_attempt_repo.ending_call(c, params["callId"])
-						CDR.for_outbound(params).save.catch(&method(:log_error))
+						cdr_repo.put(CDR.for_outbound(params)).catch(&method(:log_error))
 					end
 					"OK"
 				end