~singpolyma/sgx-jmp

ref: 3260c8a99a392510d2c52f54ac76eeb854a441f8 sgx-jmp/lib/cdr.rb -rw-r--r-- 1.0 KiB
3260c8a9Stephen Paul Weber Outbound calls from v2 SIP endpoint work and save a CDR 1 year, 2 months ago
                                                                                
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
# frozen_string_literal: true

require "value_semantics/monkey_patched"

class CDR
	value_semantics do
		cdr_id String
		customer_id String
		start Time
		billsec Integer
		disposition Either("NO ANSWER", "ANSWERED", "BUSY", "FAILED")
		tel(/\A\+\d+\Z/)
		direction Either(:inbound, :outbound)
	end

	def self.for_disconnect(event)
		start = Time.parse(event["startTime"])

		new(
			cdr_id: "sgx-jmp/#{event['callId']}",
			customer_id: event["from"].sub(/^\+/, ""),
			start: start,
			billsec: (Time.parse(event["endTime"]) - start).ceil,
			disposition: Disposition.for(event["cause"]),
			tel: event["to"],
			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

	module Disposition
		def self.for(cause)
			case cause
			when "timeout", "rejected", "cancel"
				"NO ANSWER"
			when "hangup"
				"ANSWERED"
			when "busy"
				"BUSY"
			else
				"FAILED"
			end
		end
	end
end