Removed live, semi_live, and job update timestamps from Extract functions.

models/queue_log.go

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

models/raw.go

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

util/extract.go

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