Add check for existing logs before updating cl.Logs

Author: jhoxhaa

pkg/schema/v1/container.go

@@ -129,7 +129,19 @@ func (cl *ContainerLog) syncContainerLogs(ctx context.Context, clientset *kubern
 	currentTimeMillis := time.Now().UnixMilli()
 	periodStartMillis := currentTimeMillis - (currentTimeMillis % (3600 * 1000))
 	cl.Period = types.UnixMilli(time.UnixMilli(periodStartMillis))
-	cl.Logs += string(logs)
+
+	// Check if logs for the current period already exist
+	existingLog := &ContainerLog{}
+	err = db.Get(existingLog, "SELECT * FROM container_log WHERE container_id = ? AND pod_id = ? AND period = ?", cl.ContainerId, cl.PodId, cl.Period)
+	if errors.Is(err, sql.ErrNoRows) {
+		// No existing logs for this period, insert new log
+		cl.Logs = string(logs)
+	} else if err != nil {
+		return err
+	} else {
+		// Existing logs found for this period, concatenate logs
+		cl.Logs += string(logs)
+	}
 	entities := make(chan interface{}, 1)
 	entities <- cl
 	close(entities)