Function createXEPGDatabase

src/xepg.go:349–942

XEPG Datenbank erstellen / aktualisieren

(completionChan chan<- bool)

// XEPG Datenbank erstellen / aktualisieren
func createXEPGDatabase(completionChan chan<- bool) (err error) {

	// Protect against concurrent access to XEPG data structures
	xepgMutex.Lock()
	defer xepgMutex.Unlock()

	// Send initial progress update - continue from previous progress
	if globalXEPGProgress > 0 {
		showInfo(fmt.Sprintf("XEPG: Continuing from previous progress (%d%%)", globalXEPGProgress))
	}
	globalXEPGProgress = 40
	broadcastProgressUpdate(ProcessingProgress{
		Percentage:   globalXEPGProgress,
		Current:      0,
		Total:        len(Data.Streams.Active),
		Operation:    "Rebuilding XEPG Database - Starting",
		IsProcessing: true,
	})

	var allChannelNumbers = make([]float64, 0, System.UnfilteredChannelLimit)
	Data.Cache.Streams.Active = make([]string, 0, System.UnfilteredChannelLimit)
	Data.XEPG.Channels = make(map[string]interface{}, System.UnfilteredChannelLimit)

	// Clear streaming URL cache
	Data.Cache.StreamingURLS = make(map[string]StreamInfo)
	saveMapToJSONFile(System.File.URLS, Data.Cache.StreamingURLS)

	Data.Cache.Streams.Active = make([]string, 0, System.UnfilteredChannelLimit)
	Settings = SettingsStruct{}
	Data.XEPG.Channels, err = loadJSONFileToMap(System.File.XEPG)
	if err != nil {
		ShowError(err, 1004)
		return err
	}

	settings, err := loadJSONFileToMap(System.File.Settings)
	if err != nil || len(settings) == 0 {
		return
	}
	settings_json, _ := json.Marshal(settings)
	json.Unmarshal(settings_json, &Settings)

	// Get current M3U channels
	m3uChannels := make(map[string]M3UChannelStructXEPG)
	for _, dsa := range Data.Streams.Active {
		var m3uChannel M3UChannelStructXEPG
		err = json.Unmarshal([]byte(mapToJSON(dsa)), &m3uChannel)
		if err == nil {
			// Use tvg-id as the key for matching channels
			key := m3uChannel.TvgID
			if key == "" {
				key = m3uChannel.TvgName
			}
			m3uChannels[key] = m3uChannel
		}
	}

	// Update URLs in XEPG database