nas/jellyfin-plugin-danmu
1
0
Fork 0
mirror of https://github.com/cxfksword/jellyfin-plugin-danmu.git synced 2026-05-03 08:53:17 +08:00
Code Issues Packages Projects Releases Wiki Activity

tweak: optimize download bilibili danmu

Browse Source
This commit is contained in:
cxfksword
2024-02-03 10:38:41 +08:00
parent bcc27f54d3
commit 6b61a0463e
2 changed files with 23 additions and 3 deletions
Download Patch File Download Diff File Expand all files Collapse all files

4
Jellyfin.Plugin.Danmu/LibraryManagerEventsHelper.cs
View File

@@ -812,9 +812,9 @@ public class LibraryManagerEventsHelper : IDisposable
if (danmaku != null)
{
var bytes = danmaku.ToXml();
if (bytes.Length < 10 * 1024)
if (bytes.Length < 1024)
{
_logger.LogInformation("[{0}]弹幕内容少于10KB，忽略处理：{1}.{2}", scraper.Name, item.IndexNumber, item.Name);
_logger.LogInformation("[{0}]弹幕内容少于1KB，忽略处理：{1}.{2}", scraper.Name, item.IndexNumber, item.Name);
return;
}
await this.SaveDanmu(item, bytes);

22
Jellyfin.Plugin.Danmu/Scrapers/Bilibili/BilibiliApi.cs
View File

@@ -315,14 +315,33 @@ public class BilibiliApi : AbstractApi
danmaku.ChatServer = "api.bilibili.com";
danmaku.Items = new List<ScraperDanmakuText>();
await this.EnsureSessionCookie(cancellationToken).ConfigureAwait(false);
try
{
var segmentIndex = 1; // 分包，每6分钟一包
while (true)
{
var url = $"https://api.bilibili.com/x/v2/dm/web/seg.so?type=1&oid={cid}&pid={aid}&segment_index={segmentIndex}";
var response = await this.httpClient.GetAsync(url, cancellationToken).ConfigureAwait(false);
if (response.StatusCode == System.Net.HttpStatusCode.NotModified)
{
// 已经到最后了
break;
}
if (response.Headers.TryGetValues("bili-status-code", out var headers))
{
var biliStatusCode = headers.FirstOrDefault();
if (biliStatusCode == "-352")
{
this._logger.LogWarning($"下载部分弹幕失败. bili-status-code: {biliStatusCode} url: {url}");
danmaku.Items = new List<ScraperDanmakuText>();
return danmaku;
}
}
var bytes = await this.httpClient.GetByteArrayAsync(url, cancellationToken).ConfigureAwait(false);
response.EnsureSuccessStatusCode();
var bytes = await response.Content.ReadAsByteArrayAsync(cancellationToken).ConfigureAwait(false);
var danmuReply = Biliproto.Community.Service.Dm.V1.DmSegMobileReply.Parser.ParseFrom(bytes);
if (danmuReply == null || danmuReply.Elems == null || danmuReply.Elems.Count <= 0)
{
@@ -359,6 +378,7 @@ public class BilibiliApi : AbstractApi
}
catch (Exception ex)
{
this._logger.LogError(ex, "下载弹幕出错");
}
return danmaku;