This commit is contained in:
@@ -47,7 +47,7 @@ type ExportData struct {
|
||||
BookAuthor []models.BookAuthorDTO `json:"book_author"`
|
||||
MediaArticle []models.MediaArticleDTO `json:"media_article"`
|
||||
MediaVideo []models.MediaVideoDTO `json:"media_video"`
|
||||
MediaLoFi []models.MediaLoFiDTO `json:"media_lofi"`
|
||||
MediaLoFi models.MediaLoFiDTOList `json:"media_lofi"`
|
||||
MediaFile []models.MediaFileDTO `json:"media_file"`
|
||||
MediaActor []models.MediaActorDTO `json:"media_actor"`
|
||||
MediaActorFile []models.MediaActorFileDTO `json:"media_actor_file"`
|
||||
@@ -74,7 +74,7 @@ func (e *ExportData) GetMap() map[string]any {
|
||||
|
||||
var (
|
||||
Sports models.SportDTOList
|
||||
Players []models.PlayerDTO
|
||||
Players models.PlayerDTOList
|
||||
Teams []models.TeamDTO
|
||||
Positions []models.PositionDTO
|
||||
Roosters []models.RoosterDTO
|
||||
@@ -102,7 +102,7 @@ var (
|
||||
Mediaactors []models.MediaActorDTO
|
||||
Mediaactorfiles []models.MediaActorFileDTO
|
||||
Mediafiles []models.MediaFileDTO
|
||||
Medialofis []models.MediaLoFiDTO
|
||||
Medialofis models.MediaLoFiDTOList
|
||||
Profiles []models.ProfileDTO
|
||||
Permissions []models.PermissionDTO
|
||||
Assignments []models.AssignmentDTO
|
||||
|
||||
@@ -28,20 +28,26 @@ var syncCmd = &cobra.Command{
|
||||
if config.Verbose > 2 {
|
||||
slog.Info("Size of targetData", "size", reflect.TypeOf(targetData).Size())
|
||||
}
|
||||
// find missing items in target and collect items not available in source
|
||||
for table, item_list := range sourceData.GetMap() {
|
||||
slog.Info("iterate sourceData", "table", table, "count", reflect.TypeOf(item_list).Size())
|
||||
switch table {
|
||||
case "sports":
|
||||
sourceData.Sport.CompareIds(&targetData.Sport)
|
||||
case "players":
|
||||
sourceData.Player.CompareIds(&targetData.Player)
|
||||
slog.Info("iterate sourceData", "table", "Sport", "count", len(sourceData.Sport))
|
||||
sourceData.Sport.CompareIds(&targetData.Sport)
|
||||
slog.Info("iterate sourceData", "table", "Player", "count", len(sourceData.Player))
|
||||
sourceData.Player.CompareIds(&targetData.Player)
|
||||
slog.Info("iterate sourceData", "table", "MediaLofi", "count source", len(sourceData.MediaLoFi), "count target", len(targetData.MediaLoFi))
|
||||
missing, obsolete := sourceData.MediaLoFi.CompareIds(&targetData.MediaLoFi)
|
||||
for _, lofi_id := range missing {
|
||||
if !config.DryRun {
|
||||
slog.Info("add MediaLofi", "id", lofi_id)
|
||||
}
|
||||
}
|
||||
for _, lofi_id := range obsolete {
|
||||
if !config.DryRun {
|
||||
slog.Info("delete MediaLofi", "id", lofi_id)
|
||||
}
|
||||
|
||||
}
|
||||
},
|
||||
}
|
||||
|
||||
func init() {
|
||||
rootCmd.AddCommand(syncCmd)
|
||||
syncCmd.PersistentFlags().BoolVarP(&config.DryRun, "dry-run", "m", false, "do not execute data changes")
|
||||
}
|
||||
|
||||
@@ -14,6 +14,7 @@ var (
|
||||
Overwrite bool
|
||||
ServerName string
|
||||
Config CliConfig
|
||||
DryRun bool
|
||||
)
|
||||
|
||||
type Server struct {
|
||||
|
||||
@@ -1,7 +1,9 @@
|
||||
package models
|
||||
|
||||
import (
|
||||
"fmt"
|
||||
"kontor-api-gin/internal/helpers"
|
||||
"log/slog"
|
||||
"time"
|
||||
)
|
||||
|
||||
@@ -39,6 +41,37 @@ type MediaLoFiDTO struct {
|
||||
WebLink string `json:"url"`
|
||||
}
|
||||
|
||||
type MediaLoFiDTOList []MediaLoFiDTO
|
||||
|
||||
func (source *MediaLoFiDTOList) CompareIds(target *MediaLoFiDTOList) (missing, obsolete []string) {
|
||||
sources := make(map[string]MediaLoFiDTO, len(*source))
|
||||
targets := make(map[string]MediaLoFiDTO, len(*target))
|
||||
for _, source := range *source {
|
||||
sources[source.ID] = source
|
||||
}
|
||||
for _, target := range *target {
|
||||
targets[target.ID] = target
|
||||
}
|
||||
// iterate source IDs
|
||||
for id := range sources {
|
||||
if _, ok := targets[id]; ok {
|
||||
slog.Debug(fmt.Sprintf("ID %s found in both lists", id))
|
||||
} else {
|
||||
missing = append(missing, id)
|
||||
}
|
||||
}
|
||||
for id := range targets {
|
||||
if _, ok := sources[id]; ok {
|
||||
slog.Debug(fmt.Sprintf("ID %s found in both lists", id))
|
||||
} else {
|
||||
obsolete = append(obsolete, id)
|
||||
}
|
||||
}
|
||||
slog.Info("CompareIds", "missing", len(missing), "obsolete", len(obsolete))
|
||||
slog.Debug("CompareIds", "missing", missing, "obsolete", obsolete)
|
||||
return missing, obsolete
|
||||
}
|
||||
|
||||
func ConvertMediaLoFisToDtos(media_lofis []MediaLoFi) []MediaLoFiDTO {
|
||||
dtos := make([]MediaLoFiDTO, len(media_lofis))
|
||||
for i, media_lofi := range media_lofis {
|
||||
|
||||
@@ -46,14 +46,14 @@ func (playerList *PlayerDTOList) CompareIds(target *PlayerDTOList) (missing, obs
|
||||
// iterate source IDs
|
||||
for id := range sources {
|
||||
if _, ok := targets[id]; ok {
|
||||
slog.Info(fmt.Sprintf("ID %s found in both lists", id))
|
||||
slog.Debug(fmt.Sprintf("ID %s found in both lists", id))
|
||||
} else {
|
||||
missing = append(missing, id)
|
||||
}
|
||||
}
|
||||
for id := range targets {
|
||||
if _, ok := sources[id]; ok {
|
||||
slog.Info(fmt.Sprintf("ID %s found in both lists", id))
|
||||
slog.Debug(fmt.Sprintf("ID %s found in both lists", id))
|
||||
} else {
|
||||
obsolete = append(obsolete, id)
|
||||
}
|
||||
|
||||
@@ -43,14 +43,14 @@ func (sportList *SportDTOList) CompareIds(target *SportDTOList) (missing, obsole
|
||||
// iterate source IDs
|
||||
for id := range sources {
|
||||
if _, ok := targets[id]; ok {
|
||||
slog.Info(fmt.Sprintf("ID %s found in both lists", id))
|
||||
slog.Debug(fmt.Sprintf("ID %s found in both lists", id))
|
||||
} else {
|
||||
missing = append(missing, id)
|
||||
}
|
||||
}
|
||||
for id := range targets {
|
||||
if _, ok := sources[id]; ok {
|
||||
slog.Info(fmt.Sprintf("ID %s found in both lists", id))
|
||||
slog.Debug(fmt.Sprintf("ID %s found in both lists", id))
|
||||
} else {
|
||||
obsolete = append(obsolete, id)
|
||||
}
|
||||
|
||||
Reference in New Issue
Block a user