Refactor Jikan API types: remove unused structures and add HTTP client configuration

1 files changed, 43 insertions, 0 deletions

diff --git a/repositories/mapping.go b/repositories/mapping.go
new file mode 100644
index 0000000..e797bc3
--- /dev/null
+++ b/repositories/mapping.go
@@ -0,0 +1,43 @@
+package repositories
+
+import (
+	"errors"
+	"fmt"
+	"metachan/database"
+	"metachan/entities"
+	"metachan/enums"
+	"metachan/utils/logger"
+
+	"gorm.io/gorm/clause"
+)
+
+func GetAnimeMapping[T idType](maptype enums.MappingType, id T) (entities.Mapping, error) {
+	var mapping entities.Mapping
+
+	result := database.DB.Where(fmt.Sprintf("%s = ?", maptype), id).First(&mapping)
+
+	if result.Error != nil {
+		logger.Errorf("Mapping", "Failed to get mapping for %s with ID %v: %v", maptype, id, result.Error)
+		return entities.Mapping{}, errors.New("mapping not found")
+	}
+
+	return mapping, nil
+}
+
+func CreateOrUpdateMapping(mapping *entities.Mapping) error {
+	result := database.DB.Clauses(clause.OnConflict{
+		Columns: []clause.Column{{Name: "mal"}},
+		DoUpdates: clause.AssignmentColumns([]string{
+			"ani_db", "anilist", "anime_countdown", "anime_planet",
+			"ani_search", "imdb", "kitsu", "live_chart", "notify_moe",
+			"simkl", "tmdb", "tvdb", "type", "mal_anilist_composite",
+		}),
+	}).Create(mapping)
+
+	if result.Error != nil {
+		logger.Errorf("Mapping", "Failed to create or update mapping: %v", result.Error)
+		return errors.New("failed to create or update mapping")
+	}
+
+	return nil
+}