using System;
using System.Collections.Generic;
using BililiveRecorder.Flv.Amf;
using BililiveRecorder.Flv.Pipeline.Actions;
namespace BililiveRecorder.Flv.Pipeline.Rules
{
///
/// 处理收到 Script Tag 的情况
///
///
/// 本规则为一般规则
///
public class HandleNewScriptRule : ISimpleProcessingRule
{
private static readonly ProcessingComment comment_onmetadata = new ProcessingComment(CommentType.Logging, "收到了 onMetaData");
public void Run(FlvProcessingContext context, Action next)
{
context.PerActionRun(this.RunPerAction);
next();
}
private IEnumerable RunPerAction(FlvProcessingContext context, PipelineAction action)
{
if (action is PipelineScriptAction scriptAction)
{
var data = scriptAction.Tag.ScriptData;
if (!(data is null)
&& data.Values.Count == 2
&& data.Values[0] is ScriptDataString name
&& name == "onMetaData")
{
ScriptDataEcmaArray value = data.Values[1] switch
{
ScriptDataObject obj => obj,
ScriptDataEcmaArray arr => arr,
_ => new ScriptDataEcmaArray()
};
context.AddComment(comment_onmetadata);
yield return PipelineNewFileAction.Instance;
yield return (new PipelineScriptAction(new Tag
{
Type = TagType.Script,
ScriptData = new ScriptTagBody(new List
{
name,
value
})
}));
}
else
{
context.AddComment(new ProcessingComment(CommentType.Logging, "收到了非 onMetaData 的 Script Tag: " + (data?.ToJson() ?? "(null)")));
}
}
else
yield return action;
}
}
}