Function buildXEPG

src/xepg.go:48–175

Track overall progress across multiple XEPG runs XEPG Daten erstellen

()

// XEPG Daten erstellen
func buildXEPG() chan bool {
	// Completely disable background XEPG when webserver.go is handling it
	if webserverXEPGInProgress {
		showInfo("XEPG: BACKGROUND XEPG DISABLED - webserver.go is handling XEPG processing")
		completionChan := make(chan bool, 1)
		completionChan <- true
		return completionChan
	}

	// Prevent duplicate XEPG processing when webserver.go is handling it
	if xepgProcessingInProgress {
		showInfo("XEPG: Skipping background processing - already in progress via webserver.go")
		completionChan := make(chan bool, 1)
		completionChan <- true
		return completionChan
	}

	// Set flag to indicate background XEPG is running
	xepgProcessingInProgress = true
	defer func() {
		xepgProcessingInProgress = false
		showInfo("XEPG: Background processing flag cleared")
	}()

	completionChan := make(chan bool, 1)

	xepgMutex.Lock()
	defer func() {
		xepgMutex.Unlock()
	}()

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

	var err error

	Data.Cache.Images, err = imgcache.New(System.Folder.ImagesCache, fmt.Sprintf("%s://%s/images/", System.ServerProtocol.WEB, System.Domain), Settings.CacheImages)
	if err != nil {
		ShowError(err, 0)
	}

	if Settings.EpgSource == "XEPG" {

		// Always use background processing for better user experience
		// This prevents the interface from being locked during heavy operations
		go func() {

			showDebug("XEPG: Starting background processing...", 1)

			createXEPGMapping()

			// Send progress update for mapping - continue from previous progress
			globalXEPGProgress = 40
			broadcastProgressUpdate(ProcessingProgress{
				Percentage:   globalXEPGProgress,
				Current:      0,
				Total:        1,