Merge pull request #54 from webitel/v24.02

DEV-3973

queue/dialing.go

@@ -122,6 +122,10 @@ func (d *DialingImpl) routeIdleAgents() {
 				} else {
 					d.queueManager.TimeoutLeavingMember(a)
 				}
+			} else {
+				// TODO
+				d.queueManager.store.Member().SetTimeoutError(v.AttemptId)
+				wlog.Error("attempt[%d] error: not found in cache, set timeout error")
 			}
 		}
 	} else {

store/sqlstore/member_store.go

@@ -599,6 +599,22 @@ where a.timeout < now() and a.node_id = :NodeId and not a.schema_processing is t
 	return attempts, nil
 }
 
+func (s *SqlMemberStore) SetTimeoutError(id int64) *model.AppError {
+	_, err := s.GetMaster().Exec(`update call_center.cc_member_attempt
+set schema_processing = false,
+    result = 'timeout error'
+where id = :Id;`, map[string]interface{}{
+		"Id": id,
+	})
+
+	if err != nil {
+		return model.NewAppError("SqlMemberStore.SetTimeoutError", "store.sql_member.set_timeouts.app_error", nil,
+			err.Error(), http.StatusInternalServerError)
+	}
+
+	return nil
+}
+
 func (s *SqlMemberStore) CallbackReporting(attemptId int64, callback *model.AttemptCallback, maxAttempts uint, waitBetween uint64, perNum bool) (*model.AttemptReportingResult, *model.AppError) {
 	var result *model.AttemptReportingResult
 	err := s.GetMaster().SelectOne(&result, `select *

store/store.go

@@ -78,6 +78,7 @@ type MemberStore interface {
 
 	SaveToHistory() ([]*model.HistoryAttempt, *model.AppError)
 	GetTimeouts(nodeId string) ([]*model.AttemptReportingTimeout, *model.AppError)
+	SetTimeoutError(id int64) *model.AppError
 	RenewalProcessing(domainId, attId int64, renewalSec uint32) (*model.RenewalProcessing, *model.AppError)
 
 	// CHAT TODO