Версия 1.0.1

.env.example

@@ -1,8 +1,5 @@
 APP_DEBUG=false
 
-HTTP_HOST=0.0.0.0
-HTTP_PORT=8031
-
 CACHE_ENABLED=false
 CACHE_HOST=localhost
 CACHE_PORT=6379

app/app.go

@@ -13,7 +13,7 @@ import (
 	"github.com/redis/go-redis/v9"
 )
 
-const VERSION = "0.2.0"
+const VERSION = "1.0.1"
 
 // Arguments описывает аргументы командной строки
 type Arguments struct {

app/checker/checker.go

@@ -146,6 +146,7 @@ func CheckPlaylists(lists []playlist.Playlist) (int, int) {
 		if err != nil {
 			log.Printf("Cannot read playlist [%s]: %s\n", pls.Url, err)
 			offlineCount++
+			cachePlaylist(pls)
 			continue
 		}
 
@@ -156,28 +157,30 @@ func CheckPlaylists(lists []playlist.Playlist) (int, int) {
 
 		log.Printf("Parsed, checking channels (%d)...\n", len(pls.Channels))
 		pls = CheckChannels(pls)
-
 		lists[idx] = pls
-
+		cachePlaylist(pls)
-		if app.Config.Cache.IsActive {
-			jsonBytes, err := json.Marshal(pls)
-			if err != nil {
-				log.Printf("Error while saving playlist to cache: %s", err)
-			}
-
-			ttl := time.Duration(app.Config.Cache.Ttl) * time.Second
-			written := app.Cache.Set(ctx, pls.Code, string(jsonBytes), ttl)
-			if written.Err() != nil {
-				log.Printf("Error while saving playlist to cache: %s", err)
-			}
-
-			log.Println("Cached sucessfully")
-		}
 	}
 
 	return onlineCount, offlineCount
 }
 
+func cachePlaylist(pls playlist.Playlist) {
+	if app.Config.Cache.IsActive {
+		jsonBytes, err := json.Marshal(pls)
+		if err != nil {
+			log.Printf("Error while saving playlist to cache: %s", err)
+		}
+
+		ttl := time.Duration(app.Config.Cache.Ttl) * time.Second
+		written := app.Cache.Set(ctx, pls.Code, string(jsonBytes), ttl)
+		if written.Err() != nil {
+			log.Printf("Error while saving playlist to cache: %s", err)
+		}
+
+		log.Println("Cached sucessfully")
+	}
+}
+
 // CheckChannels проверяет каналы и возвращает их же с результатами проверки
 func CheckChannels(pls playlist.Playlist) playlist.Playlist {
 	type errorData struct {

app/config/config.go

@@ -16,7 +16,6 @@ import (
 type Config struct {
 	DebugMode bool
 	Cache     CacheConfig
-	Http      HttpConfig
 }
 
 // CacheConfig описывает конфигурацию подключения к keydb
@@ -31,12 +30,6 @@ type CacheConfig struct {
 	IsActive  bool
 }
 
-// HttpConfig описывает конфигурацию веб-сервера
-type HttpConfig struct {
-	Host string
-	Port uint
-}
-
 // Init инициализирует объект конфигурации из переменных окружения
 func Init() *Config {
 	_ = godotenv.Load(".env")
@@ -51,10 +44,6 @@ func Init() *Config {
 			Db:        readEnvInteger("CACHE_DB", 0),
 			Ttl:       readEnvInteger("CACHE_TTL", 1800),
 		},
-		Http: HttpConfig{
-			Host: readEnv("HTTP_HOST", "0.0.0.0"),
-			Port: readEnvInteger("HTTP_PORT", 1380),
-		},
 	}
 }
 

app/playlist/playlist.go

@@ -123,6 +123,7 @@ func parseName(line string) string {
 func (pls *Playlist) Download() error {
 	content, err := utils.Fetch(pls.Url)
 	if err != nil {
+		pls.Content = err.Error()
 		return err
 	}
 
@@ -134,6 +135,7 @@ func (pls *Playlist) Download() error {
 func (pls *Playlist) ReadFromFs() error {
 	content, err := os.ReadFile(pls.Url)
 	if err != nil {
+		pls.Content = err.Error()
 		return err
 	}
 
@@ -144,6 +146,7 @@ func (pls *Playlist) ReadFromFs() error {
 // Parse разбирает плейлист
 func (pls *Playlist) Parse() Playlist {
 	isChannel := false
+	pls.Attributes = make(map[string]string)
 	pls.Channels = make(map[string]Channel)
 	pls.Groups = make(map[string]Group)