mirror of
https://github.com/91270/MeiamSubtitles.git
synced 2026-02-02 18:19:50 +08:00
f48fc0910b
1. 引入 IHttpClientFactory：重构 Jellyfin 插件的 HTTP 调用模式，使用依赖注入管理 HttpClient 生命周期。 2. 优化服务注册：在 PluginServiceRegistrator 中统一配置命名 HTTP 客户端的超时与默认 Header。 3. 增强资源加载：优化 Emby 插件缩略图获取逻辑，增加安全性检查。 4. 代码逻辑优化：提取私有方法 NormalizeLanguage 统一处理跨平台语言代码映射。 5. 精简配置：简化 PluginConfiguration，移除冗余引用，同时确保与 Jellyfin 10.x 基类兼容。 6. 日志分级：细化 API 响应内容的记录级别，减少生产环境日志输出。
433 lines
14 KiB
C#
433 lines
14 KiB
C#
using Jellyfin.MeiamSub.Thunder.Model;
|
||
using MediaBrowser.Controller.Providers;
|
||
using MediaBrowser.Controller.Subtitles;
|
||
using MediaBrowser.Model.Providers;
|
||
using Microsoft.Extensions.Logging;
|
||
using System;
|
||
using System.Collections.Generic;
|
||
using System.IO;
|
||
using System.Linq;
|
||
using System.Net;
|
||
using System.Net.Http;
|
||
using System.Net.Http.Headers;
|
||
using System.Security.Cryptography;
|
||
using System.Text;
|
||
using System.Text.Json;
|
||
using System.Threading;
|
||
using System.Threading.Tasks;
|
||
|
||
namespace Jellyfin.MeiamSub.Thunder
|
||
{
|
||
/// <summary>
|
||
/// 迅雷看看字幕提供程序
|
||
/// 负责与迅雷 API 进行交互，通过 CID (Content ID) 匹配并下载字幕。
|
||
/// <para>修改人: Meiam</para>
|
||
/// <para>修改时间: 2025-12-22</para>
|
||
/// </summary>
|
||
public class ThunderProvider : ISubtitleProvider, IHasOrder
|
||
{
|
||
#region 变量声明
|
||
public const string ASS = "ass";
|
||
public const string SSA = "ssa";
|
||
public const string SRT = "srt";
|
||
|
||
private readonly ILogger<ThunderProvider> _logger;
|
||
private readonly IHttpClientFactory _httpClientFactory;
|
||
private static readonly JsonSerializerOptions _deserializeOptions = new JsonSerializerOptions
|
||
{
|
||
PropertyNamingPolicy = JsonNamingPolicy.SnakeCaseLower
|
||
};
|
||
|
||
public int Order => 1;
|
||
public string Name => "MeiamSub.Thunder";
|
||
|
||
/// <summary>
|
||
/// 支持电影、剧集
|
||
/// </summary>
|
||
public IEnumerable<VideoContentType> SupportedMediaTypes => new[] { VideoContentType.Movie, VideoContentType.Episode };
|
||
#endregion
|
||
|
||
#region 构造函数
|
||
public ThunderProvider(ILogger<ThunderProvider> logger, IHttpClientFactory httpClientFactory)
|
||
{
|
||
_logger = logger;
|
||
_httpClientFactory = httpClientFactory;
|
||
_logger.LogInformation($"{Name} Init");
|
||
}
|
||
#endregion
|
||
|
||
#region 查询字幕
|
||
|
||
/// <summary>
|
||
/// 搜索字幕 (ISubtitleProvider 接口实现)
|
||
/// 根据媒体信息请求字幕列表。
|
||
/// </summary>
|
||
/// <param name="request">包含媒体路径、语言等信息的搜索请求对象</param>
|
||
/// <param name="cancellationToken">取消令牌</param>
|
||
/// <returns>远程字幕信息列表</returns>
|
||
public async Task<IEnumerable<RemoteSubtitleInfo>> Search(SubtitleSearchRequest request, CancellationToken cancellationToken)
|
||
{
|
||
_logger.LogInformation($"{Name} Search | SubtitleSearchRequest -> { JsonSerializer.Serialize(request) }");
|
||
|
||
var subtitles = await SearchSubtitlesAsync(request);
|
||
|
||
return subtitles;
|
||
}
|
||
|
||
/// <summary>
|
||
|
||
/// 查询字幕
|
||
|
||
/// </summary>
|
||
|
||
/// <param name="request"></param>
|
||
|
||
/// <returns></returns>
|
||
|
||
private async Task<IEnumerable<RemoteSubtitleInfo>> SearchSubtitlesAsync(SubtitleSearchRequest request)
|
||
|
||
{
|
||
|
||
// 修改人: Meiam
|
||
|
||
// 修改时间: 2025-12-22
|
||
|
||
// 备注: 增加异常处理
|
||
|
||
|
||
|
||
try
|
||
|
||
{
|
||
|
||
var language = NormalizeLanguage(request.Language);
|
||
|
||
|
||
|
||
if (language != "chi")
|
||
|
||
{
|
||
|
||
return Array.Empty<RemoteSubtitleInfo>();
|
||
|
||
}
|
||
|
||
|
||
|
||
var cid = await GetCidByFileAsync(request.MediaPath);
|
||
|
||
|
||
|
||
_logger.LogInformation($"{Name} Search | FileHash -> {cid}");
|
||
|
||
|
||
|
||
using var options = new HttpRequestMessage
|
||
|
||
{
|
||
|
||
Method = HttpMethod.Get,
|
||
|
||
RequestUri = new Uri($"https://api-shoulei-ssl.xunlei.com/oracle/subtitle?name={Path.GetFileName(request.MediaPath)}")
|
||
|
||
};
|
||
|
||
|
||
|
||
using var httpClient = _httpClientFactory.CreateClient(Name);
|
||
|
||
|
||
|
||
var response = await httpClient.SendAsync(options);
|
||
|
||
|
||
|
||
_logger.LogDebug($"{Name} Search | Response -> {JsonSerializer.Serialize(response)}");
|
||
|
||
|
||
|
||
if (response.StatusCode == HttpStatusCode.OK)
|
||
|
||
{
|
||
|
||
var subtitleResponse = JsonSerializer.Deserialize<SubtitleResponseRoot>(await response.Content.ReadAsStringAsync(), _deserializeOptions);
|
||
|
||
|
||
|
||
if (subtitleResponse != null)
|
||
|
||
{
|
||
|
||
_logger.LogDebug($"{Name} Search | Response -> {JsonSerializer.Serialize(subtitleResponse)}");
|
||
|
||
|
||
|
||
var subtitles = subtitleResponse.Data.Where(m => !string.IsNullOrEmpty(m.Name));
|
||
|
||
|
||
|
||
var remoteSubtitles = new List<RemoteSubtitleInfo>();
|
||
|
||
|
||
|
||
if (subtitles.Count() > 0)
|
||
|
||
{
|
||
|
||
foreach (var item in subtitles)
|
||
|
||
{
|
||
|
||
remoteSubtitles.Add(new RemoteSubtitleInfo()
|
||
|
||
{
|
||
|
||
Id = Base64Encode(JsonSerializer.Serialize(new DownloadSubInfo
|
||
|
||
{
|
||
|
||
Url = item.Url,
|
||
|
||
Format = item.Ext,
|
||
|
||
Language = language,
|
||
|
||
TwoLetterISOLanguageName = request.TwoLetterISOLanguageName,
|
||
|
||
})),
|
||
|
||
Name = $"[MEIAMSUB] {item.Name} | {(item.Langs == string.Empty ? "未知" : item.Langs)} | 迅雷",
|
||
|
||
Author = "Meiam ",
|
||
|
||
ProviderName = $"{Name}",
|
||
|
||
Format = item.Ext,
|
||
|
||
Comment = $"Format : {item.Ext}",
|
||
|
||
IsHashMatch = cid == item.Cid,
|
||
|
||
});
|
||
|
||
}
|
||
|
||
}
|
||
|
||
|
||
|
||
_logger.LogInformation($"{Name} Search | Summary -> Get {subtitles.Count()} Subtitles");
|
||
|
||
|
||
|
||
return remoteSubtitles;
|
||
|
||
}
|
||
|
||
}
|
||
|
||
}
|
||
|
||
catch (Exception ex)
|
||
|
||
{
|
||
|
||
_logger.LogError(ex, "{0} Search | Error -> {1}", Name, ex.Message);
|
||
|
||
}
|
||
|
||
|
||
|
||
_logger.LogInformation($"{Name} Search | Summary -> Get 0 Subtitles");
|
||
|
||
|
||
|
||
return Array.Empty<RemoteSubtitleInfo>();
|
||
|
||
}
|
||
#endregion
|
||
|
||
#region 下载字幕
|
||
/// <summary>
|
||
/// 获取字幕内容 (ISubtitleProvider 接口实现)
|
||
/// 根据字幕 ID 下载具体的字幕文件流。
|
||
/// </summary>
|
||
/// <param name="id">字幕唯一标识符 (Base64 编码的 JSON 数据)</param>
|
||
/// <param name="cancellationToken">取消令牌</param>
|
||
/// <returns>包含字幕流的响应对象</returns>
|
||
public async Task<SubtitleResponse> GetSubtitles(string id, CancellationToken cancellationToken)
|
||
{
|
||
_logger.LogInformation($"{Name} DownloadSub | Request -> {id}");
|
||
|
||
return await DownloadSubAsync(id);
|
||
}
|
||
|
||
/// <summary>
|
||
/// 下载字幕
|
||
/// </summary>
|
||
/// <param name="info"></param>
|
||
/// <returns></returns>
|
||
private async Task<SubtitleResponse> DownloadSubAsync(string info)
|
||
{
|
||
// 修改人: Meiam
|
||
// 修改时间: 2025-12-22
|
||
// 备注: 增加异常处理
|
||
|
||
try
|
||
{
|
||
var downloadSub = JsonSerializer.Deserialize<DownloadSubInfo>(Base64Decode(info));
|
||
|
||
if (downloadSub == null)
|
||
{
|
||
return new SubtitleResponse();
|
||
}
|
||
|
||
_logger.LogInformation($"{Name} DownloadSub | Url -> {downloadSub.Url} | Format -> {downloadSub.Format} | Language -> {downloadSub.Language} ");
|
||
|
||
using var options = new HttpRequestMessage
|
||
{
|
||
Method = HttpMethod.Get,
|
||
RequestUri = new Uri(downloadSub.Url)
|
||
};
|
||
|
||
using var httpClient = _httpClientFactory.CreateClient(Name);
|
||
|
||
var response = await httpClient.SendAsync(options);
|
||
_logger.LogInformation($"{Name} DownloadSub | Response -> {response.StatusCode}");
|
||
|
||
if (response.StatusCode == HttpStatusCode.OK)
|
||
{
|
||
var stream = await response.Content.ReadAsStreamAsync();
|
||
|
||
return new SubtitleResponse()
|
||
{
|
||
Language = downloadSub.Language,
|
||
IsForced = false,
|
||
Format = downloadSub.Format,
|
||
Stream = stream,
|
||
};
|
||
}
|
||
}
|
||
catch (Exception ex)
|
||
{
|
||
_logger.LogError(ex, "{0} DownloadSub | Error -> {1}", Name, ex.Message);
|
||
}
|
||
|
||
return new SubtitleResponse();
|
||
|
||
}
|
||
#endregion
|
||
|
||
#region 内部方法
|
||
|
||
/// <summary>
|
||
/// Base64 加密
|
||
/// </summary>
|
||
/// <param name="plainText">明文</param>
|
||
/// <returns></returns>
|
||
public static string Base64Encode(string plainText)
|
||
{
|
||
var plainTextBytes = Encoding.UTF8.GetBytes(plainText);
|
||
return Convert.ToBase64String(plainTextBytes);
|
||
}
|
||
/// <summary>
|
||
/// Base64 解密
|
||
/// </summary>
|
||
/// <param name="base64EncodedData"></param>
|
||
/// <returns></returns>
|
||
public static string Base64Decode(string base64EncodedData)
|
||
{
|
||
var base64EncodedBytes = Convert.FromBase64String(base64EncodedData);
|
||
return Encoding.UTF8.GetString(base64EncodedBytes);
|
||
}
|
||
|
||
/// <summary>
|
||
/// 提取格式化字幕类型
|
||
/// </summary>
|
||
/// <param name="text"></param>
|
||
/// <returns></returns>
|
||
protected string ExtractFormat(string text)
|
||
{
|
||
if (string.IsNullOrEmpty(text))
|
||
{
|
||
return null;
|
||
}
|
||
|
||
text = text.ToLower();
|
||
if (text.Contains(ASS)) return ASS;
|
||
if (text.Contains(SSA)) return SSA;
|
||
if (text.Contains(SRT)) return SRT;
|
||
|
||
return null;
|
||
}
|
||
|
||
/// <summary>
|
||
/// 规范化语言代码
|
||
/// </summary>
|
||
/// <param name="language"></param>
|
||
/// <returns></returns>
|
||
private static string NormalizeLanguage(string language)
|
||
{
|
||
if (string.IsNullOrEmpty(language)) return language;
|
||
|
||
if (language.Equals("zh-CN", StringComparison.OrdinalIgnoreCase) ||
|
||
language.Equals("zh-TW", StringComparison.OrdinalIgnoreCase) ||
|
||
language.Equals("zh-HK", StringComparison.OrdinalIgnoreCase))
|
||
{
|
||
return "chi";
|
||
}
|
||
if (language.Equals("en", StringComparison.OrdinalIgnoreCase))
|
||
{
|
||
return "eng";
|
||
}
|
||
return language;
|
||
}
|
||
|
||
/// <summary>
|
||
/// 异步计算文件 CID (迅雷专用算法)
|
||
/// <para>修改人: Meiam</para>
|
||
/// <para>修改时间: 2025-12-22</para>
|
||
/// <para>备注: 采用异步 I/O 读取文件特定位置的数据块进行 SHA1 计算。</para>
|
||
/// </summary>
|
||
/// <param name="filePath">文件路径</param>
|
||
/// <returns>计算得到的 CID 字符串</returns>
|
||
private async Task<string> GetCidByFileAsync(string filePath)
|
||
{
|
||
// 修改人: Meiam
|
||
// 修改时间: 2025-12-22
|
||
// 备注: 改造为异步方法，优化 I/O 性能，使用 SHA1.Create() 替代旧 API，并增加 using 语句释放资源
|
||
|
||
using (var stream = new FileStream(filePath, FileMode.Open, FileAccess.Read, FileShare.Read, 4096, FileOptions.Asynchronous))
|
||
{
|
||
var fileSize = new FileInfo(filePath).Length;
|
||
using (var sha1 = SHA1.Create())
|
||
{
|
||
var buffer = new byte[0xf000];
|
||
if (fileSize < 0xf000)
|
||
{
|
||
await stream.ReadExactlyAsync(buffer, 0, (int)fileSize);
|
||
buffer = sha1.ComputeHash(buffer, 0, (int)fileSize);
|
||
}
|
||
else
|
||
{
|
||
await stream.ReadExactlyAsync(buffer, 0, 0x5000);
|
||
stream.Seek(fileSize / 3, SeekOrigin.Begin);
|
||
await stream.ReadExactlyAsync(buffer, 0x5000, 0x5000);
|
||
stream.Seek(fileSize - 0x5000, SeekOrigin.Begin);
|
||
await stream.ReadExactlyAsync(buffer, 0xa000, 0x5000);
|
||
|
||
buffer = sha1.ComputeHash(buffer, 0, 0xf000);
|
||
}
|
||
var result = "";
|
||
foreach (var i in buffer)
|
||
{
|
||
result += string.Format("{0:X2}", i);
|
||
}
|
||
return result;
|
||
}
|
||
}
|
||
}
|
||
#endregion
|
||
}
|
||
}
|