ft/skyscraper8
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases 2 Wiki Activity

Introduced OnAtsc3FileDelivery.
Some checks failed
🚀 Pack skyscraper8 / make-zip (push) Failing after 29s
Details

Browse Source
This commit is contained in:
feyris-tan 2026-06-10 04:54:24 +02:00
parent 4fe40e082a
commit 595ed5cd4f
4 changed files with 33 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

3
skyscraper8/Atsc/A331/Atsc3EventHandler.cs
View File

@ -1,9 +1,11 @@
using System; using System;
using System.Collections.Generic; using System.Collections.Generic;
using System.Linq; using System.Linq;
using System.Net;
using System.Text; using System.Text;
using System.Threading.Tasks; using System.Threading.Tasks;
using skyscraper8.Atsc.A331.Schema; using skyscraper8.Atsc.A331.Schema;
using skyscraper8.Ietf.FLUTE;
namespace skyscraper8.Atsc.A331 namespace skyscraper8.Atsc.A331
{ {
@ -11,5 +13,6 @@ namespace skyscraper8.Atsc.A331
{ {
void OnAtsc3Detected(); void OnAtsc3Detected();
void OnAtsc3ServiceList(sltType slt); void OnAtsc3ServiceList(sltType slt);
void OnAtsc3FileDelivery(IPEndPoint destination, ulong tsi, ulong toi, FluteListener targetListener, GuessedFluteDataType guessedFluteDataType, string outFileName);
} }
} }

18
skyscraper8/Atsc/A331/Atsc3FilenameTable.cs
View File

@ -19,5 +19,23 @@ namespace skyscraper8.Atsc.A331
staticFilenames.Add(new Tuple<IPEndPoint, ulong, string>(endpoint, file.TOI, file.ContentLocation)); staticFilenames.Add(new Tuple<IPEndPoint, ulong, string>(endpoint, file.TOI, file.ContentLocation));
} }
} }
public string GuessFilename(IPEndPoint destination, ulong tsi, ulong toi)
{
if (staticFilenames != null)
{
foreach (Tuple<IPEndPoint, ulong, string> staticFilename in staticFilenames)
{
if (!staticFilename.Item1.Equals(destination))
continue;
if (staticFilename.Item2 != toi)
continue;
return staticFilename.Item3;
}
}
return null;
}
} }
} }

8
skyscraper8/Atsc/A331/Atsc3Receiver.cs
View File

@ -131,6 +131,12 @@ namespace skyscraper8.Atsc.A331
{ {
GuessedFluteDataType guessedFluteDataType = FluteUtilities.GuessDataType(targetListener); GuessedFluteDataType guessedFluteDataType = FluteUtilities.GuessDataType(targetListener);
ProcessMetafile(guessedFluteDataType, targetListener, destination); ProcessMetafile(guessedFluteDataType, targetListener, destination);
string outFileName = filenames.GuessFilename(destination, tsi, toi);
if (!string.IsNullOrEmpty(outFileName))
{
eventHandler.OnAtsc3FileDelivery(destination, tsi, toi, targetListener, guessedFluteDataType, outFileName);
}
} }
} }
@ -147,6 +153,8 @@ namespace skyscraper8.Atsc.A331
return true; return true;
} }
return false;
case GuessedFluteDataType.MultimediaContent:
return false; return false;
default: default:
throw new NotImplementedException(guessedFluteDataType.ToString()); throw new NotImplementedException(guessedFluteDataType.ToString());

5
skyscraper8/Ietf/FLUTE/FluteUtilities.cs
View File

@ -85,6 +85,8 @@ namespace skyscraper8.Ietf.FLUTE
byte[] firstBlock = targetListener.GetFirstBlock(); byte[] firstBlock = targetListener.GetFirstBlock();
if (firstBlock[0] == 0x3c && firstBlock[1] == 0x3f && firstBlock[2] == 0x78 && firstBlock[3] == 0x6d && firstBlock[4] == 0x6c) if (firstBlock[0] == 0x3c && firstBlock[1] == 0x3f && firstBlock[2] == 0x78 && firstBlock[3] == 0x6d && firstBlock[4] == 0x6c)
return GuessedFluteDataType.Xml; return GuessedFluteDataType.Xml;
if (firstBlock[0] == 0x00 && firstBlock[1] == 0x00 && firstBlock[2] == 0x00)
return GuessedFluteDataType.MultimediaContent;
return GuessedFluteDataType.Unknown; return GuessedFluteDataType.Unknown;
} }
} }
@ -92,6 +94,7 @@ namespace skyscraper8.Ietf.FLUTE
public enum GuessedFluteDataType public enum GuessedFluteDataType
{ {
Unknown, Unknown,
Xml Xml,
MultimediaContent
} }
} }