WTEL-4748

queue/attempt.go

@@ -82,6 +82,7 @@ type Attempt struct {
 	processingFields      sync.Map
 	processingFormStarted bool
 	bridgedAt             int64
+	transferredAt         int64 // todo work in chat
 	manualDistribution    bool
 }
 
@@ -152,6 +153,21 @@ func (a *Attempt) MarkProcessingFormStarted() {
 	a.Unlock()
 }
 
+func (a *Attempt) MarkTransferred() {
+	a.Lock()
+	if a.transferredAt == 0 {
+		a.transferredAt = model.GetMillis()
+	}
+	a.Unlock()
+}
+
+func (a *Attempt) TransferredAt() int64 {
+	a.RLock()
+	t := a.transferredAt
+	a.RUnlock()
+	return t
+}
+
 func (a *Attempt) ProcessingFormStarted() bool {
 	a.RLock()
 	defer a.RUnlock()

queue/chat_inbound.go

@@ -280,11 +280,15 @@ func (queue *InboundChatQueue) process(attempt *Attempt, inviterId, invUserId st
 			// TODO: what reason is this?
 			aSess.Close("")
 		}
-		transferredProcessing := conv.Cause() == "transfer" &&
+		transferred := conv.Cause() == "transfer"
+		if transferred {
+			attempt.MarkTransferred()
+		}
+		transferredProcessing := transferred &&
 			queue.GetVariable(transferResult) == model.MEMBER_CAUSE_ABANDONED
 
 		if conv.BridgedAt() > 0 && !transferredProcessing {
-			team.Reporting(queue, attempt, agent, conv.ReportingAt() > 0, false)
+			team.Reporting(queue, attempt, agent, conv.ReportingAt() > 0, conv.Cause() == "transfer")
 		} else {
 			team.Missed(attempt, agent)
 			queue.queueManager.LeavingMember(attempt)

queue/queue_manager.go

@@ -961,7 +961,7 @@ func (queueManager *QueueManager) closeBeforeReporting(attemptId int64, res *mod
 		break
 	case model.QueueChannelChat:
 		var conv *chat.Conversation
-		if a != nil {
+		if a != nil && a.TransferredAt() == 0 {
 			if conv, err = queueManager.GetChat(a.memberChannel.Id()); err == nil {
 				err = conv.Reporting(false)
 			}