WTEL-4153

webitel · Jan 18, 2024 · ee77da4 · ee77da4
1 parent 43926f6
commit ee77da4
Show file tree

Hide file tree

Showing 5 changed files with 37 additions and 1 deletion.
diff --git a/call_manager/call.go b/call_manager/call.go
@@ -33,6 +33,7 @@ type Call interface {
 	AddAction(action CallAction)
 
 	BridgeId() *string
+	Answered() bool
 
 	AcceptAt() int64
 	BridgeAt() int64
@@ -510,6 +511,13 @@ func (call *CallImpl) AcceptAt() int64 {
 	return call.acceptAt
 }
 
+func (call *CallImpl) Answered() bool {
+	call.RLock()
+	a := call.acceptAt
+	call.RUnlock()
+	return a > 0
+}
+
 func (call *CallImpl) BridgeAt() int64 {
 	return call.bridgeAt
 }

diff --git a/chat/session.go b/chat/session.go
@@ -67,6 +67,13 @@ func (c *ChatSession) SessionId() string {
 
 	return c.InviteId
 }
+func (c *ChatSession) Answered() bool {
+	c.RLock()
+	a := c.AnsweredAt
+	c.RUnlock()
+
+	return a > 0
+}
 
 func (c *ChatSession) SetActivity() {
 	c.Lock()

diff --git a/queue/events.go b/queue/events.go
@@ -10,6 +10,7 @@ import (
 type Channel interface {
 	Id() string
 	Stats() map[string]string
+	Answered() bool
 }
 
 type ChannelEvent struct {
@@ -19,7 +20,7 @@ type ChannelEvent struct {
 	Timestamp int64  `json:"timestamp"`
 }
 
-//TODO refactoring call event to CC
+// TODO refactoring call event to CC
 type Distribute struct {
 	AppId           string                    `json:"app_id"`
 	Channel         string                    `json:"channel"`

diff --git a/queue/queue_agent_task.go b/queue/queue_agent_task.go
@@ -68,6 +68,13 @@ func (t *TaskChannel) setState(state TaskState) {
 	t.stateC <- t.state
 }
 
+func (t *TaskChannel) Answered() bool {
+	t.RLock()
+	a := t.bridgedAt
+	t.RUnlock()
+	return a > 0
+}
+
 func (t *TaskChannel) SetAnswered() *model.AppError {
 	t.Lock()
 	defer t.Unlock()

diff --git a/queue/schema.go b/queue/schema.go
@@ -176,6 +176,19 @@ func (qm *QueueManager) AfterDistributeSchema(att *Attempt) (*model.SchemaResult
 
 	st := time.Now()
 
+	// TODO WTEL-4153
+	if att.Result() == "" && att.memberChannel != nil {
+		if att.agentChannel != nil && att.agentChannel.Answered() && att.memberChannel.Answered() {
+			vars["cc_result"] = "success"
+		} else {
+			vars["cc_result"] = "abandoned"
+		}
+
+		if !att.memberChannel.Answered() {
+			vars["cc_result"] = "failed"
+		}
+	}
+
 	res, err := qm.app.FlowManager().Queue().ResultAttempt(&flow.ResultAttemptRequest{
 		DomainId: att.queue.DomainId(),
 		SchemaId: *att.queue.AfterSchemaId(),