Function buildDatabaseDVR

src/data.go:770–1088

Datenbank für das DVR System erstellen

()

// Datenbank für das DVR System erstellen
func buildDatabaseDVR() (err error) {

	// Don't send progress updates here - they're handled by the calling function
	// This prevents conflicts with the main progress tracking

	Data.Streams.All = make([]interface{}, 0, System.UnfilteredChannelLimit)
	Data.Streams.Active = make([]interface{}, 0, System.UnfilteredChannelLimit)
	Data.Streams.Inactive = make([]interface{}, 0, System.UnfilteredChannelLimit)
	Data.Playlist.M3U.Groups.Text = []string{}
	Data.Playlist.M3U.Groups.Value = []string{}
	Data.StreamPreviewUI.Active = []string{}
	Data.StreamPreviewUI.Inactive = []string{}

	var availableFileTypes = []string{"m3u", "hdhr"}

	var tmpGroupsM3U = make(map[string]int64)

	err = createFilterRules()
	if err != nil {
		return
	}

	// Calculate total channels for progress tracking
	totalChannels := 0
	for _, fileType := range availableFileTypes {
		playlistFile := getLocalProviderFiles(fileType)
		for _, i := range playlistFile {
			channels, _ := parsePlaylist(i, fileType)
			totalChannels += len(channels)
		}
	}

	// Reset for actual processing
	Data.Streams.All = make([]interface{}, 0, System.UnfilteredChannelLimit)
	Data.Streams.Active = make([]interface{}, 0, System.UnfilteredChannelLimit)
	Data.Streams.Inactive = make([]interface{}, 0, System.UnfilteredChannelLimit)
	Data.Playlist.M3U.Groups.Text = []string{}
	Data.Playlist.M3U.Groups.Value = []string{}
	Data.StreamPreviewUI.Active = []string{}
	Data.StreamPreviewUI.Inactive = []string{}

	processedChannels := 0

	for _, fileType := range availableFileTypes {

		var playlistFile = getLocalProviderFiles(fileType)

		for n, i := range playlistFile {

			var channels []interface{}
			var groupTitle, tvgID, uuid int = 0, 0, 0
			var keys = []string{"group-title", "tvg-id", "uuid"}
			var compatibility = make(map[string]int)

			var id = strings.TrimSuffix(getFilenameFromPath(i), path.Ext(getFilenameFromPath(i)))
			var playlistName = getProviderParameter(id, fileType, "name")

			// Check file size for progress reporting