Merge pull request #149 from sonroyaalmerol/fix-m3u-caching

Clear db before executing save to db on sync to remove stale streams

.github/workflows/linting.yml

@@ -29,7 +29,7 @@ jobs:
       - uses: actions/checkout@v4
       - uses: actions/setup-go@v5
         with:
-          go-version: '1.22'
+          go-version: '1.23'
           cache: false
       - name: golangci-lint
         uses: golangci/golangci-lint-action@v4

database/db.go

@@ -71,6 +71,8 @@ func (db *Instance) SaveToDb(streams []*StreamInfo) error {
 
 	pipeline := db.Redis.Pipeline()
 
+	pipeline.FlushDB(db.Ctx)
+
 	for _, s := range streams {
 		streamKey := fmt.Sprintf("stream:%s", s.Slug)
 

m3u/generate.go

@@ -111,6 +111,24 @@ func GenerateAndCacheM3UContent(db *database.Instance, r *http.Request) string {
 	return content.String()
 }
 
+func ClearCache() {
+	debug := isDebugMode()
+
+	M3uCache.Lock()
+
+	if debug {
+		log.Println("[DEBUG] Clearing memory and disk M3U cache.")
+	}
+	M3uCache.data = ""
+	if err := DeleteCacheFile(); err != nil {
+		if debug {
+			log.Printf("[DEBUG] Cache file deletion failed: %v\n", err)
+		}
+	}
+
+	M3uCache.Unlock()
+}
+
 func Handler(w http.ResponseWriter, r *http.Request) {
 	db, err := database.InitializeDb()
 	if err != nil {
@@ -177,3 +195,7 @@ func ReadCacheFromFile() (string, error) {
 func WriteCacheToFile(content string) error {
 	return os.WriteFile(cacheFilePath, []byte(content), 0644)
 }
+
+func DeleteCacheFile() error {
+	return os.Remove(cacheFilePath)
+}

updater/updater.go

@@ -156,8 +156,15 @@ func (instance *Updater) UpdateSources(ctx context.Context) {
 		err := db.SaveToDb(instance.M3UParser.GetStreams())
 		if err != nil {
 			log.Printf("Background process: Error updating M3U database: %v\n", err)
+			log.Println("Background process: Clearing database after error in attempt to fix issue after container restart.")
+
+			if err := db.ClearDb(); err != nil {
+				log.Printf("Background process: Error clearing database: %v\n", err)
+			}
 		}
 
+		m3u.ClearCache()
+
 		log.Println("Background process: Updated M3U database.")
 	}
 }