diff options
| author | Bobby <[email protected]> | 2026-02-25 10:42:51 +0530 |
|---|---|---|
| committer | Bobby <[email protected]> | 2026-02-25 10:42:51 +0530 |
| commit | c18acfafee26d7d2508848135aa94a524f8dde06 (patch) | |
| tree | e0b4d5e07f872d9252af6d73fb8b108e15a49f91 /database | |
| parent | 2df69fab61b580b6b329db214ee0025a9d84958d (diff) | |
| download | metachan-c18acfafee26d7d2508848135aa94a524f8dde06.tar.xz metachan-c18acfafee26d7d2508848135aa94a524f8dde06.zip | |
Refactor anime update logic and task management
- Simplified title retrieval in AnimeUpdate and updateAnime functions.
- Updated next airing checks to use new fields directly.
- Removed unnecessary nil checks for titles in various functions.
- Enhanced task management by eliminating redundant LastRun updates.
- Improved dependency handling in triggerDependentTasks for better clarity and performance.
- Streamlined Jikan API response structure by merging related fields.
- Added StopRateLimiters function to rate limiter utilities for better control.
- Refined episode title handling in TMDB and TVDB enrichment functions.
- Introduced Stop method in MultiLimiter for graceful shutdown of rate limiters.
Diffstat (limited to 'database')
| -rw-r--r-- | database/database.go | 9 | ||||
| -rw-r--r-- | database/migrate.go | 9 |
2 files changed, 10 insertions, 8 deletions
diff --git a/database/database.go b/database/database.go index a9215b7..fef6705 100644 --- a/database/database.go +++ b/database/database.go @@ -4,6 +4,7 @@ import ( "metachan/config" "metachan/enums" "metachan/utils/logger" + "time" "gorm.io/driver/mysql" "gorm.io/driver/postgres" @@ -40,6 +41,14 @@ func init() { logger.Fatalf("Database", "Error connecting to database: %v", err) } + sqlDB, err := DB.DB() + if err != nil { + logger.Fatalf("Database", "Failed to get underlying sql.DB: %v", err) + } + sqlDB.SetMaxOpenConns(25) + sqlDB.SetMaxIdleConns(5) + sqlDB.SetConnMaxLifetime(time.Hour) + logger.Successf("Database", "Database connection established successfully") migrate() diff --git a/database/migrate.go b/database/migrate.go index 3fe542e..6bd04ca 100644 --- a/database/migrate.go +++ b/database/migrate.go @@ -10,13 +10,6 @@ func migrate() { &entities.TaskLog{}, &entities.TaskStatus{}, &entities.Mapping{}, - &entities.Title{}, - &entities.Scores{}, - &entities.Date{}, - &entities.AiringStatus{}, - &entities.Broadcast{}, - &entities.Images{}, - &entities.Logos{}, &entities.ExternalURL{}, &entities.SimpleTitle{}, &entities.SimpleImage{}, @@ -25,9 +18,9 @@ func migrate() { &entities.Anime{}, &entities.Episode{}, &entities.EpisodeSkipTime{}, + &entities.StreamInfo{}, &entities.StreamingSource{}, &entities.EpisodeSchedule{}, - &entities.NextEpisode{}, &entities.Season{}, &entities.Character{}, &entities.Person{}, |