1124c1b4c2
Twilio voice now uses first-class `Call` records as the source of truth for call state, instead of storing it on `conversation.additional_attributes` and `conversation.identifier`. Each call gets its own record, its own `voice_call` bubble matched by `call_sid`, and its own conference name keyed off `Call.id`. Multiple calls on the same conversation (for `lock_to_single_conversation` inboxes) now work correctly, and the conversation card stays in sync with the real latest message. Fixes https://linear.app/chatwoot/issue/PLA-121/lock-to-single-thread --------- Co-authored-by: Muhsin <12408980+muhsin-k@users.noreply.github.com>
58 lines
1.4 KiB
Ruby
58 lines
1.4 KiB
Ruby
class Voice::StatusUpdateService
|
|
pattr_initialize [:account!, :call_sid!, :call_status, { payload: {} }]
|
|
|
|
TWILIO_STATUS_MAP = {
|
|
'queued' => 'ringing',
|
|
'initiated' => 'ringing',
|
|
'ringing' => 'ringing',
|
|
'in-progress' => 'in_progress',
|
|
'inprogress' => 'in_progress',
|
|
'answered' => 'in_progress',
|
|
'completed' => 'completed',
|
|
'busy' => 'no_answer',
|
|
'no-answer' => 'no_answer',
|
|
'failed' => 'failed',
|
|
'canceled' => 'failed'
|
|
}.freeze
|
|
|
|
def perform
|
|
normalized_status = normalize_status(call_status)
|
|
return if normalized_status.blank?
|
|
|
|
call = Call.where(account_id: account.id).find_by(provider: :twilio, provider_call_id: call_sid)
|
|
return unless call
|
|
|
|
Voice::CallStatus::Manager.new(call: call).process_status_update(
|
|
normalized_status,
|
|
duration: payload_duration,
|
|
timestamp: payload_timestamp
|
|
)
|
|
end
|
|
|
|
private
|
|
|
|
def normalize_status(status)
|
|
return if status.to_s.strip.empty?
|
|
|
|
TWILIO_STATUS_MAP[status.to_s.downcase]
|
|
end
|
|
|
|
def payload_duration
|
|
return unless payload.is_a?(Hash)
|
|
|
|
duration = payload['CallDuration'] || payload['call_duration']
|
|
duration&.to_i
|
|
end
|
|
|
|
def payload_timestamp
|
|
return unless payload.is_a?(Hash)
|
|
|
|
ts = payload['Timestamp'] || payload['timestamp']
|
|
return unless ts
|
|
|
|
Time.zone.parse(ts).to_i
|
|
rescue ArgumentError
|
|
nil
|
|
end
|
|
end
|