perfect: 提高 Emby 匹配资源的兼容性

Author: AkimioJR

internal/handler/emby.go

@@ -219,45 +219,9 @@ func (handler *EmbyHandler) VideosHandler(ctx *gin.Context) {
 	// EmbyServer >= 4.9 ====> mediaSourceID = mediasource_31
 	mediaSourceID := ctx.Query("mediasourceid")
 
-	// // 从 URL 中提取 item ID（例如：/emby/videos/43609/stream 中的 43609）
-	// var itemID string
-	// if matches := constants.EmbyRegexp.Router.VideosHandler.FindStringSubmatch(orginalPath); len(matches) > 0 {
-	// 	parts := strings.Split(orginalPath, "/")
-	// 	for i, part := range parts {
-	// 		if part == "videos" && i+1 < len(parts) {
-	// 			itemID = parts[i+1]
-	// 			break
-	// 		}
-	// 	}
-	// }
-
-	// // 并发控制：确保同一个 item ID 只有一个任务在运行
-	// // 将整个处理流程放在锁内，避免重复查询和重复获取重定向 URL
-	// var muWrapper *mutexWithRefCount
-	// if itemID != "" {
-	// 	// 加载或创建 mutex wrapper
-	// 	value, _ := embyServerHandler.playbackInfoMutex.LoadOrStore(itemID, &mutexWithRefCount{})
-	// 	muWrapper = value.(*mutexWithRefCount)
-
-	// 	// 增加引用计数
-	// 	atomic.AddInt32(&muWrapper.refCount, 1)
-
-	// 	// 锁定并处理
-	// 	muWrapper.mu.Lock()
-	// 	defer func() {
-	// 		muWrapper.mu.Unlock()
-	// 		// 减少引用计数
-	// 		refCount := atomic.AddInt32(&muWrapper.refCount, -1)
-	// 		// 如果没有其他 goroutine 在使用，删除这个 mutex 以避免内存泄漏
-	// 		if refCount == 0 {
-	// 			embyServerHandler.playbackInfoMutex.Delete(itemID)
-	// 		}
-	// 	}()
-	// 	logging.Debugf("开始处理 item %s 的 VideosHandler 请求", itemID)
-	// }
-
 	logging.Debugf("请求 ItemsServiceQueryItem：%s", mediaSourceID)
-	itemResponse, err := handler.client.ItemsServiceQueryItem(strings.Replace(mediaSourceID, "mediasource_", "", 1), 1, "Path,MediaSources") // 查询 item 需要去除前缀仅保留数字部分
+	mediaSourceID_without_prefix := strings.Replace(mediaSourceID, "mediasource_", "", 1)
+	itemResponse, err := handler.client.ItemsServiceQueryItem(mediaSourceID_without_prefix, 1, "Path,MediaSources") // 查询 item 需要去除前缀仅保留数字部分
 	if err != nil {
 		logging.Warning("请求 ItemsServiceQueryItem 失败：", err)
 		handler.ReverseProxy(ctx.Writer, ctx.Request)
@@ -273,12 +237,14 @@ func (handler *EmbyHandler) VideosHandler(ctx *gin.Context) {
 	}
 
 	strmFileType, opt := recgonizeStrmFileType(*item.Path)
+
 	for _, mediasource := range item.MediaSources {
-		if *mediasource.ID == mediaSourceID { // EmbyServer >= 4.9 返回的ID带有前缀mediasource_
+		logging.Debugf("mediasource.ID: %s ; mediaSourceID: %s ; mediaSourceID_without_prefix: %s", *mediasource.ID, mediaSourceID, mediaSourceID_without_prefix)
+		// EmbyServer >= 4.9 返回的ID带有前缀mediasource_
+		if strings.Replace(*mediasource.ID, "mediasource_", "", 1) == mediaSourceID_without_prefix {
 			switch strmFileType {
 			case constants.HTTPStrm:
 				if *mediasource.Protocol == emby.HTTP {
-					// httpStrmHandler 内部有缓存机制，锁确保串行化访问
 					ctx.Redirect(http.StatusFound, handler.httpStrmHandler(*mediasource.Path, ctx.Request.UserAgent()))
 					return
 				}

internal/handler/jellyfin.go

@@ -180,44 +180,6 @@ func (handler *JellyfinHandler) VideosHandler(ctx *gin.Context) {
 		return
 	}
 
-	// // 从 URL 中提取 item ID（例如：/Videos/813a630bcf9c3f693a2ec8c498f868d2/stream 中的 813a630bcf9c3f693a2ec8c498f868d2）
-	// var itemID string
-	// path := ctx.Request.URL.Path
-	// if matches := constants.JellyfinRegexp.Router.VideosHandler.FindStringSubmatch(path); len(matches) > 0 {
-	// 	parts := strings.Split(path, "/")
-	// 	for i, part := range parts {
-	// 		if part == "Videos" && i+1 < len(parts) {
-	// 			itemID = parts[i+1]
-	// 			break
-	// 		}
-	// 	}
-	// }
-
-	// // 并发控制：确保同一个 item ID 只有一个任务在运行
-	// // 将整个处理流程放在锁内，避免重复查询和重复获取重定向 URL
-	// var muWrapper *mutexWithRefCount
-	// if itemID != "" {
-	// 	// 加载或创建 mutex wrapper
-	// 	value, _ := handler.playbackInfoMutex.LoadOrStore(itemID, &mutexWithRefCount{})
-	// 	muWrapper = value.(*mutexWithRefCount)
-
-	// 	// 增加引用计数
-	// 	atomic.AddInt32(&muWrapper.refCount, 1)
-
-	// 	// 锁定并处理
-	// 	muWrapper.mu.Lock()
-	// 	defer func() {
-	// 		muWrapper.mu.Unlock()
-	// 		// 减少引用计数
-	// 		refCount := atomic.AddInt32(&muWrapper.refCount, -1)
-	// 		// 如果没有其他 goroutine 在使用，删除这个 mutex 以避免内存泄漏
-	// 		if refCount == 0 {
-	// 			handler.playbackInfoMutex.Delete(itemID)
-	// 		}
-	// 	}()
-	// 	logging.Debugf("开始处理 item %s 的 VideosHandler 请求", itemID)
-	// }
-
 	mediaSourceID := ctx.Query("mediasourceid")
 	logging.Debugf("请求 ItemsServiceQueryItem：%s", mediaSourceID)
 	itemResponse, err := handler.client.ItemsServiceQueryItem(mediaSourceID, 1, "Path,MediaSources") // 查询 item 需要去除前缀仅保留数字部分
@@ -241,7 +203,6 @@ func (handler *JellyfinHandler) VideosHandler(ctx *gin.Context) {
 			switch strmFileType {
 			case constants.HTTPStrm:
 				if *mediasource.Protocol == jellyfin.HTTP {
-					// httpStrmHandler 内部有缓存机制，锁确保串行化访问
 					ctx.Redirect(http.StatusFound, handler.httpStrmHandler(*mediasource.Path, ctx.Request.UserAgent()))
 					return
 				}