Compare commits

..

3 Commits

3 changed files with 7 additions and 9 deletions

View File

@@ -7,7 +7,8 @@ type DBQueueLog struct {
ConversationId string `gorm:"primaryKey"` ConversationId string `gorm:"primaryKey"`
Start time.Time `gorm:"index"` Start time.Time `gorm:"index"`
End time.Time `gorm:"index"` End time.Time `gorm:"index"`
Result string `gorm:"type:json"` Duration float64
Result string `gorm:"type:json"`
} }
func (DBQueueLog) TableName() string { func (DBQueueLog) TableName() string {

View File

@@ -1,5 +1,10 @@
package models package models
type AnalyticsConversationWithAttributesQuery struct {
Conversations []AnalyticsConversationWithAttributes `json:"conversations"`
Cursor *string `json:"cursor"`
}
type AnalyticsConversationWithAttributes struct { type AnalyticsConversationWithAttributes struct {
ConversationEnd string `json:"conversationEnd"` ConversationEnd string `json:"conversationEnd"`
ConversationId string `json:"conversationId"` ConversationId string `json:"conversationId"`

View File

@@ -33,8 +33,6 @@ func ExtractWithoutAttributes(base models.AnalyticsConversationWithoutAttributes
} }
divisionIdsBytesStr := string(divisionIdsBytes) divisionIdsBytesStr := string(divisionIdsBytes)
currentTime := time.Now()
conversation := models.DBConversation{ conversation := models.DBConversation{
DivisionIds: &divisionIdsBytesStr, DivisionIds: &divisionIdsBytesStr,
End: endTime, End: endTime,
@@ -43,7 +41,6 @@ func ExtractWithoutAttributes(base models.AnalyticsConversationWithoutAttributes
MinRFactor: &base.MediaStatsMinConversationRFactor, MinRFactor: &base.MediaStatsMinConversationRFactor,
OriginatingDirection: &base.OriginatingDirection, OriginatingDirection: &base.OriginatingDirection,
Start: startTime, Start: startTime,
SemiLiveUpdate: &currentTime,
} }
var participants []models.DBParticipant var participants []models.DBParticipant
var sessions []models.DBSession var sessions []models.DBSession
@@ -129,7 +126,6 @@ func ExtractWithoutAttributes(base models.AnalyticsConversationWithoutAttributes
} }
func ExtractLive(base models.NotificationConversationWithAttributes) (models.DBConversation, []models.DBParticipant, []models.DBCall) { func ExtractLive(base models.NotificationConversationWithAttributes) (models.DBConversation, []models.DBParticipant, []models.DBCall) {
currentTime := time.Now()
conversation := models.DBConversation{ conversation := models.DBConversation{
Id: base.Id, Id: base.Id,
@@ -138,7 +134,6 @@ func ExtractLive(base models.NotificationConversationWithAttributes) (models.DBC
RecordingState: &base.RecordingState, RecordingState: &base.RecordingState,
SecurePause: &base.SecurePause, SecurePause: &base.SecurePause,
UtilizationLabelId: &base.UtilizationLabelId, UtilizationLabelId: &base.UtilizationLabelId,
LiveUpdate: &currentTime,
} }
var participants []models.DBParticipant var participants []models.DBParticipant
@@ -284,8 +279,6 @@ func ExtractWithAttributes(base models.AnalyticsConversationWithAttributes) (mod
} }
divisionIdsBytesStr := string(divisionIdsBytes) divisionIdsBytesStr := string(divisionIdsBytes)
currentTime := time.Now()
conversation := models.DBConversation{ conversation := models.DBConversation{
DivisionIds: &divisionIdsBytesStr, DivisionIds: &divisionIdsBytesStr,
End: endTime, End: endTime,
@@ -294,7 +287,6 @@ func ExtractWithAttributes(base models.AnalyticsConversationWithAttributes) (mod
MinRFactor: &base.MediaStatsMinConversationRFactor, MinRFactor: &base.MediaStatsMinConversationRFactor,
OriginatingDirection: &base.OriginatingDirection, OriginatingDirection: &base.OriginatingDirection,
Start: startTime, Start: startTime,
JobUpdate: &currentTime,
} }
var participants []models.DBParticipant var participants []models.DBParticipant
var sessions []models.DBSession var sessions []models.DBSession