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

Merge branch 'master' of http://172.20.20.19:3000/ft/skyscraper8

Browse Source
This commit is contained in:
feyris-tan 2026-04-15 18:48:48 +02:00
commit 82253eefce
25 changed files with 1950 additions and 2508 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

1
.gitignore vendored
View File

@ -134,3 +134,4 @@ imgui.ini
/Documentation/TSDuck-Samples/experiment2/*.ts
/.vs/skyscraper8/CopilotIndices/17.14.1431.25910
/.vs
/skyscraper8/bin/Debug/satip

5
skyscraper8/GS/GSE-BFBS/BfbsGseReader.cs
View File

@ -120,6 +120,11 @@ namespace skyscraper8.GS.GSE_BFBS
if (!startIndicator && endIndicator)
gseLength -= 4;
if (span.GetAvailableBytes() < gseLength)
{
//broken gse packet, invalid length
return;
}
gsePacket.GseDataBytes = span.ReadBytes(gseLength);
if (!startIndicator && endIndicator)

293
skyscraper8/Passing.cs
View File

@ -1,293 +0,0 @@
using System;
using System.Collections.Generic;
using System.Collections.ObjectModel;
using System.Diagnostics;
using System.IO;
using System.Linq;
using System.Net.NetworkInformation;
using System.Reflection;
using System.Security.Cryptography.X509Certificates;
using System.Text;
using System.Threading;
using System.Threading.Tasks;
using log4net;
using skyscraper5.Dvb.Psi.Model;
using skyscraper5.Mpeg2;
using skyscraper5.Skyscraper;
using skyscraper5.Skyscraper.Headless;
using skyscraper5.Skyscraper.IO;
using skyscraper5.Skyscraper.IO.CrazycatStreamReader;
using skyscraper5.Skyscraper.IO.TunerInterface;
using skyscraper5.Skyscraper.Plugins;
using skyscraper5.Skyscraper.Scraper;
using skyscraper5.Skyscraper.Scraper.Storage;
using skyscraper8.Skyscraper.Scraper.Storage;
namespace skyscraper5
{
public class Passing
{
public DataStorage DataStorage { get; set; }
public ObjectStorage ObjectStorage { get; set; }
private IStreamReader streamReader;
private List<TunerMetadata> tuners;
private List<SatellitePositionEntity> satellitePositions;
private static readonly ILog logger = LogManager.GetLogger(System.Reflection.MethodBase.GetCurrentMethod().DeclaringType.Name);
public Passing()
{
}
public bool Boot()
{
Ini ini = PluginManager.GetInstance().Ini;
StorageConnectionManager connectionManager = StorageConnectionManager.GetInstance();
IEnumerable<Tuple<int, bool, string>> allKnownFactoryNames = connectionManager.GetAllKnownFactoryNames();
foreach (Tuple<int, bool, string> knownFactoryName in allKnownFactoryNames)
{
logger.InfoFormat("Found {0} Storage Factory #{1}, {2}",knownFactoryName.Item2 ? "Data" : "Object",knownFactoryName.Item1,knownFactoryName.Item3);
}
logger.Debug("Acquiring Default Data Storage...");
DataStorageFactory dataStorageFactory = connectionManager.GetDefaultDataStorageFactory();
logger.Debug("Acquiring Default Object Storage...");
ObjectStorageFactory objectStorageFactory = connectionManager.GetDefaultObjectStorageFactory();
logger.Debug("Acquiring Data Storage...");
DataStorage = dataStorageFactory.CreateDataStorage();
if (DataStorage == null)
{
logger.FatalFormat("The data storage factory didn't create a data storage.");
return false;
}
bool isEquivalent = objectStorageFactory.IsEquivalent(dataStorageFactory);
if (isEquivalent)
{
logger.Debug("Using the Data Storage as Object Storage.");
ObjectStorage = (ObjectStorage)DataStorage;
}
else
{
logger.Debug("Acquiring Object Storage...");
ObjectStorage = objectStorageFactory.CreateObjectStorage();
if (ObjectStorage == null)
{
logger.FatalFormat("The object storage factory didn't create an object storage.");
return false;
}
}
TunerFactoryConnectionManager tunerFactoryConnectionManager = TunerFactoryConnectionManager.GetInstance();
ReadOnlyCollection<KeyValuePair<TunerFactoryIdAttribute, ITunerFactory>> tunerFactories = tunerFactoryConnectionManager.GetKnownFactories();
int tunerFactory = ini.ReadValue("startup", "tunerFactory", 0);
KeyValuePair<TunerFactoryIdAttribute, ITunerFactory> bootingTuner = tunerFactories.First(x => x.Key.Id == tunerFactory);
if (bootingTuner.Value == null)
{
Console.WriteLine("The tuner factory #{0} didn't load.", tunerFactory);
return false;
}
TunerFactoryConnectionManager.ConfigureFactoryFromIni(bootingTuner, ini);
streamReader = bootingTuner.Value.CreateStreamReader();
if (streamReader == null)
{
Console.WriteLine("The tuner factory #{0} didn't create a stream reader.");
return false;
}
try
{
streamReader.CheckForDVB();
}
catch (BadImageFormatException e)
{
Console.WriteLine("The configured tuner factory is not suitable for the current processor architecture. Tuning won't work, therefore functionality will be severely limited. Please configure a Tuner Factory Class suitable for this processor architecture in order to get the best experience. If you need to run crazycat69's StreamReader.dll on 64-bit machines, try RemoteStreamReader.");
streamReader = new NullTunerFactory().CreateStreamReader();
}
List<TunerMetadata> foundTuners = new List<TunerMetadata>();
bool checkForDvbExEx = streamReader.CheckForDVBExEx((index, name, type) =>
{
TunerMetadata tuner = new TunerMetadata(index, name, type);
foundTuners.Add(tuner);
});
foreach (TunerMetadata foundTuner in foundTuners)
{
streamReader.StopDVB();
bool startDvbEx = streamReader.StartDvbEx(foundTuner.Index);
if (!startDvbEx)
{
Console.WriteLine("Failed to start {0}", foundTuner.Name);
Thread.Sleep(1000);
continue;
}
foundTuner.Caps = streamReader.GetCaps();
byte[] macBuffer = new byte[6];
bool mac = streamReader.GetMAC(macBuffer);
if (!mac)
{
Console.WriteLine("Failed to read MAC Address of {0}", foundTuner.Name);
Thread.Sleep(1000);
}
else
{
foundTuner.MacAddress = new PhysicalAddress(macBuffer);
}
bool stopDvb = streamReader.StopDVB();
if (!stopDvb)
{
Console.WriteLine("Failed to stop {0}", foundTuner.Name);
Thread.Sleep(1000);
continue;
}
;
if (DataStorage.UiTunerTestFor(foundTuner))
{
DataStorage.UiTunerGetConfiguration(foundTuner);
}
if (tuners == null)
tuners = new List<TunerMetadata>();
tuners.Add(foundTuner);
}
satellitePositions = DataStorage.UiSatellitesListAll();
return true;
}
private HeadlessJob GetNextJob()
{
HeadlessJob headlessJob = DataStorage.GetQueuedJob();
if (headlessJob != null)
{
return headlessJob;
}
return new HeadlessJob(HeadlessJobType.BlindscanEverything);
}
public void Run()
{
while (true)
{
HeadlessJob headlessJob = GetNextJob();
Run(headlessJob);
if (!headlessJob.isSynthetic)
{
DataStorage.SetQueuedJobComplete(headlessJob);
}
}
}
private void Run(HeadlessJob job)
{
switch (job.jobType)
{
case HeadlessJobType.Sleep:
Thread.Sleep(job.iArg1);
break;
case HeadlessJobType.MassImport:
DirectoryInfo di = new DirectoryInfo(job.sArg1);
MassImportDirectory(di);
break;
case HeadlessJobType.BlindscanEverything:
PerformBlindscanEverything();
break;
case HeadlessJobType.ReimportByTag1:
ReimportTag(job.iArg1);
break;
default:
throw new NotImplementedException(job.jobType.ToString());
}
}
private void PerformBlindscanEverything()
{
if (tuners == null)
tuners = new List<TunerMetadata>();
if (tuners.Count == 0)
throw new ApplicationException("I'd need to blindscan everything, but I don't have any tuners I could use!");
throw new NotImplementedException(nameof(PerformBlindscanEverything));
}
private void ReimportTag(int tag1)
{
IReadOnlyList<string> queue = DataStorage.ListImportFileByTag1(tag1);
foreach(string filename in queue)
{
FileInfo fi = new FileInfo(filename);
if (!fi.Exists)
continue;
ScrapeStream(fi);
}
}
public void MassImportDirectory(DirectoryInfo sourceDir)
{
foreach (FileSystemInfo fileSystemInfo in sourceDir.GetFileSystemInfos())
{
DirectoryInfo di = fileSystemInfo as DirectoryInfo;
FileInfo fi = fileSystemInfo as FileInfo;
if (di != null)
{
MassImportDirectory(di);
}
else if (fi != null)
{
if (fi.Length == 0)
continue;
if (!fi.Extension.ToLowerInvariant().Equals(".ts"))
continue;
if (DataStorage.ImportFileKnown(fi))
continue;
FileStream fileStream = fi.OpenRead();
Stopwatch stopwatch = Stopwatch.StartNew();
int tstype;
ScrapeStream(fileStream,true, out tstype);
stopwatch.Stop();
Console.WriteLine("Importing {0} took {1}",fi.Name, stopwatch.Elapsed);
DataStorage.WaitForCompletion();
DataStorage.ImportMarkFileAsKnown(fi, stopwatch.Elapsed, tstype);
fileStream.Close();
}
else
{
throw new NotImplementedException(fileSystemInfo.GetType().ToString());
}
}
}
private void ScrapeStream(FileInfo fi)
{
FileStream fileStream = fi.OpenRead();
ScrapeStream(fileStream, true, out _);
fileStream.Close();
fileStream.Dispose();
}
private void ScrapeStream(Stream inStream, bool disk, out int tstype)
{
SkyscraperContext skyscraperContext = new SkyscraperContext(new TsContext(), DataStorage,ObjectStorage);
skyscraperContext.SourceIsDisk = disk;
skyscraperContext.InitalizeFilterChain();
skyscraperContext.IngestFromStream(inStream);
skyscraperContext.Dispose();
tstype = skyscraperContext.SpecialTsType;
}
}
}

1914
skyscraper8/Program.cs
View File

File diff suppressed because it is too large Load Diff

1
skyscraper8/Properties/launchSettings.json
View File

@ -2,6 +2,7 @@
"profiles": {
"skyscraper8": {
"commandName": "Project",
"commandLineArgs": "rotation-catalogue F:\\\\ F:\\\\rotate-us.csv",
"remoteDebugEnabled": false
},
"Container (Dockerfile)": {

607
skyscraper8/QuickAndDirtySatIpClient.cs
View File

@ -1,278 +1,329 @@
using log4net;
using skyscraper5.Skyscraper.IO.CrazycatStreamReader;
using skyscraper8.SatIp;
using skyscraper8.SatIp.RtspResponses;
using skyscraper8.SimpleServiceDiscoveryProtocol;
using System;
using System.Collections.Generic;
using System.Linq;
using System.Net;
using System.Text;
using System.Threading.Tasks;
using skyscraper5.Mpeg2;
using skyscraper5.Skyscraper.Scraper;
using skyscraper5.Skyscraper.Scraper.Storage.Filesystem;
using skyscraper5.Skyscraper.Scraper.Storage.InMemory;
using skyscraper8.Skyscraper.Scraper.Storage;
namespace skyscraper8
{
internal class QuickAndDirtySatIpClient
{
private static readonly ILog logger = LogManager.GetLogger(System.Reflection.MethodBase.GetCurrentMethod().DeclaringType.Name);
private const bool ENABLE_TS_WRITER = true;
public QuickAndDirtySatIpClient(string[] args)
{
if (args.Length == 1)
{
logger.Fatal("Hey, what's your SAT>IP Server's IP Address? You can also say \"autodetect\" here.");
return;
}
if (args[1].ToLowerInvariant().Contains("auto"))
{
ipAddress = AutodetectIPAddress();
}
else
{
ipAddress = IPAddress.Parse(args[1]);
}
if (args.Length == 2)
{
logger.Fatal("You didn't specify a DiSEqc setting. (Number between 1-4)");
return;
}
diseqcNumber = Int32.Parse(args[2]);
if (args.Length == 3)
{
logger.Fatal("You didn't specify a polarity. Use H or V.");
return;
}
polarity = args[3].ToUpperInvariant()[0];
if (args.Length == 4)
{
logger.Fatal("Please specify a frequency.");
return;
}
frequency = Int32.Parse(args[4]);
if (args.Length == 5)
{
logger.Fatal("What DVB Standard do we have here? S or S2?");
return;
}
isS2 = ParseDvbStandard(args[5]);
if (args.Length == 6)
{
logger.Fatal("What's the symbol rate?");
return;
}
symbolRate = Int32.Parse(args[6]);
}
private IPAddress AutodetectIPAddress()
{
SsdpDevice firstSatIpServer = SsdpClient.GetFirstSatIpServer(1000, null);
if (firstSatIpServer == null)
{
logger.WarnFormat("Didn't find any SAT>IP servers.");
return null;
}
IPAddress ipAddress = firstSatIpServer.GetIpAddress();
logger.InfoFormat("Found SAT>IP Server at {0}", ipAddress);
return ipAddress;
}
private int symbolRate;
private bool isS2;
private int frequency;
private char polarity;
private int diseqcNumber;
private IPAddress ipAddress;
private RtspClient rtspClient;
public void Run()
{
rtspClient = new RtspClient(ipAddress, 554);
rtspClient.AutoReconnect = false;
Keepalive();
DiSEqC_Opcode opcode = BuildDiseqcOpcode();
string url = RtspClient.MakeUrl(opcode, frequency, isS2, symbolRate, null, false);
RtspDescribeResponse describe = rtspClient.GetDescribe(url);
SessionDescriptionProtocol sessionDescriptionProtocol = describe.GetSessionDescriptionProtocol();
packetQueue = new Queue<byte[]>();
RtspSetupResponse setup = rtspClient.GetSetup(url);
if (setup.RtspStatusCode == 404)
{
logger.Fatal("Your SAT>IP server doesn't have a tuner available that can talk to the requested frequency.");
return;
}
setup.OnRtcpPacket += Setup_OnRtcpPacket;
setup.OnRtpPacket += Setup_OnRtpPacket;
if (dataStorage == null)
dataStorage = new InMemoryScraperStorage();
if (objectStorage == null)
objectStorage = new FilesystemStorage(new DirectoryInfo("."));
context = new SkyscraperContext(new TsContext(), dataStorage, objectStorage);
context.EnableTimeout = true;
context.TimeoutSeconds = 60;
context.InitalizeFilterChain();
RtspPlayResponse play = rtspClient.GetPlay(setup);
DateTime lastTimestamp = DateTime.Now;
while (true)
{
if (packetQueue.Count >= 1)
{
byte[] buffer;
lock (packetQueue)
{
buffer = packetQueue.Dequeue();
}
context.IngestSinglePacket(buffer);
}
else
{
Thread.Sleep(1);
}
if (context.IsAbortConditionMet())
break;
if (DateTime.Now.Second != lastTimestamp.Second)
{
Keepalive(url);
lastTimestamp = DateTime.Now;
}
}
rtspClient.GetTeardown(setup);
rtspClient.Dispose();
}
private FileStream fs;
private uint stuffingBytes;
private Queue<byte[]> packetQueue;
private ObjectStorage objectStorage;
private DataStorage dataStorage;
private SkyscraperContext context;
private void Setup_OnRtpPacket(byte[] data, int length)
{
for (int i = 12; i < length; i += 1)
{
if (data[i] == 'G')
{
byte[] buffer = new byte[188];
Array.Copy(data, i, buffer, 0, 188);
lock (packetQueue)
{
packetQueue.Enqueue(buffer);
}
DumpPacket(buffer);
i += 187;
}
else if (data[i] == 0xff)
{
stuffingBytes++;
}
}
}
private void DumpPacket(byte[] buffer)
{
if (!ENABLE_TS_WRITER)
return;
if (fs == null)
{
string fname = String.Format("{0}.ts", DateTime.Now.Ticks);
fs = File.OpenWrite(fname);
}
fs.Write(buffer, 0, buffer.Length);
}
private int rtcps;
private void Setup_OnRtcpPacket(byte[] data, int length)
{
//rtcps++;
}
private DiSEqC_Opcode BuildDiseqcOpcode()
{
DiSEqC_Opcode opcode = DiSEqC_Opcode.DISEQC_HIGH_NIBBLE;
switch (diseqcNumber)
{
case 1:
opcode |= DiSEqC_Opcode.DISEQC_OPTION_A;
opcode |= DiSEqC_Opcode.DISEQC_POSITION_A;
break;
case 2:
opcode |= DiSEqC_Opcode.DISEQC_OPTION_A;
opcode |= DiSEqC_Opcode.DISEQC_POSITION_B;
break;
case 3:
opcode |= DiSEqC_Opcode.DISEQC_OPTION_B;
opcode |= DiSEqC_Opcode.DISEQC_POSITION_A;
break;
case 4:
opcode |= DiSEqC_Opcode.DISEQC_OPTION_B;
opcode |= DiSEqC_Opcode.DISEQC_POSITION_B;
break;
default:
throw new ArgumentOutOfRangeException("Your DiSEqC position should be a number between 1 and 4.");
}
switch (polarity)
{
case 'H':
opcode |= DiSEqC_Opcode.DISEQC_HORIZONTAL;
break;
case 'V':
opcode |= DiSEqC_Opcode.DISEQC_VERTICAL;
break;
default:
throw new ArgumentException("The polarity should be H or V.");
}
return opcode;
}
private bool ParseDvbStandard(string standard)
{
standard = standard.ToUpperInvariant();
if (standard.StartsWith("DVB"))
standard = standard.Substring(3);
if (standard.StartsWith("-"))
standard = standard.Substring(1);
switch (standard)
{
case "S":
return false;
case "S2":
return true;
case "S2X":
return true;
default:
throw new ArgumentException(String.Format("I have no idea what kind of Standard {0} is supposed to be.", standard));
}
}
private void Keepalive(string url = "/")
{
RtspOptionsResponse options = rtspClient.GetOptions("/");
if (options.RtspStatusCode != 200)
{
throw new RtspException(String.Format("Unexpected RTSP Status code. Wanted {0}, got {1}", 200, options.RtspStatusCode));
}
}
}
}
using log4net;
using skyscraper5.Skyscraper.IO.CrazycatStreamReader;
using skyscraper8.SatIp;
using skyscraper8.SatIp.RtspResponses;
using skyscraper8.SimpleServiceDiscoveryProtocol;
using System;
using System.Collections.Generic;
using System.Linq;
using System.Net;
using System.Text;
using System.Threading.Tasks;
using skyscraper5.Mpeg2;
using skyscraper5.Skyscraper.Scraper;
using skyscraper5.Skyscraper.Scraper.Storage.Filesystem;
using skyscraper5.Skyscraper.Scraper.Storage.InMemory;
using skyscraper8.Skyscraper.Scraper.Storage;
namespace skyscraper8
{
internal class QuickAndDirtySatIpClient
{
private static readonly ILog logger = LogManager.GetLogger(System.Reflection.MethodBase.GetCurrentMethod().DeclaringType.Name);
private const bool ENABLE_TS_WRITER = true;
public QuickAndDirtySatIpClient(string[] args)
{
if (args.Length == 1)
{
logger.Fatal("Hey, what's your SAT>IP Server's IP Address? You can also say \"autodetect\" here.");
return;
}
if (args[1].ToLowerInvariant().Contains("auto"))
{
ipAddress = AutodetectIPAddress();
}
else
{
ipAddress = IPAddress.Parse(args[1]);
}
if (args.Length == 2)
{
logger.Fatal("You didn't specify a DiSEqc setting. (Number between 1-4)");
return;
}
diseqcNumber = Int32.Parse(args[2]);
if (args.Length == 3)
{
logger.Fatal("You didn't specify a polarity. Use H or V.");
return;
}
polarity = args[3].ToUpperInvariant()[0];
if (args.Length == 4)
{
logger.Fatal("Please specify a frequency.");
return;
}
frequency = Int32.Parse(args[4]);
if (args.Length == 5)
{
logger.Fatal("What DVB Standard do we have here? S or S2?");
return;
}
isS2 = ParseDvbStandard(args[5]);
if (args.Length == 6)
{
logger.Fatal("What's the symbol rate?");
return;
}
symbolRate = Int32.Parse(args[6]);
}
public void SetPlayoutMode(string[] args)
{
if (args.Length == 7)
{
logger.Fatal("What's the target port?");
return;
}
destinationPort = int.Parse(args[7]);
playoutMode = true;
if (args.Length == 10)
{
if (args[8].ToLowerInvariant().Equals("multicast"))
{
destinationIp = IPAddress.Parse(args[9]);
multicastMode = true;
}
else
{
logger.FatalFormat("Don't know what {0} means.", args[8]);
return;
}
}
}
private IPAddress AutodetectIPAddress()
{
SsdpDevice firstSatIpServer = SsdpClient.GetFirstSatIpServer(1000, null);
if (firstSatIpServer == null)
{
logger.WarnFormat("Didn't find any SAT>IP servers.");
return null;
}
IPAddress ipAddress = firstSatIpServer.GetIpAddress();
logger.InfoFormat("Found SAT>IP Server at {0}", ipAddress);
return ipAddress;
}
private int symbolRate;
private bool isS2;
private int frequency;
private char polarity;
private int diseqcNumber;
private IPAddress ipAddress;
private RtspClient rtspClient;
public void Run()
{
rtspClient = new RtspClient(ipAddress, 554);
rtspClient.AutoReconnect = false;
Keepalive();
DiSEqC_Opcode opcode = BuildDiseqcOpcode();
string url = RtspClient.MakeUrl(opcode, frequency, isS2, symbolRate, null, false);
RtspDescribeResponse describe = rtspClient.GetDescribe(url);
SessionDescriptionProtocol sessionDescriptionProtocol = describe.GetSessionDescriptionProtocol();
packetQueue = new Queue<byte[]>();
RtspSetupResponse setup = rtspClient.GetSetup(url, destinationPort, multicastMode, destinationIp);
if (setup.RtspStatusCode == 404)
{
logger.Fatal("Your SAT>IP server doesn't have a tuner available that can talk to the requested frequency.");
return;
}
setup.OnRtcpPacket += Setup_OnRtcpPacket;
setup.OnRtpPacket += Setup_OnRtpPacket;
if (dataStorage == null)
dataStorage = new InMemoryScraperStorage();
if (objectStorage == null)
objectStorage = new FilesystemStorage(new DirectoryInfo("."));
if (!playoutMode)
{
context = new SkyscraperContext(new TsContext(), dataStorage, objectStorage);
context.EnableTimeout = true;
context.TimeoutSeconds = 60;
context.InitalizeFilterChain();
}
RtspPlayResponse play = rtspClient.GetPlay(setup);
DateTime lastTimestamp = DateTime.Now;
bool initMessagePrinted = false;
while (true)
{
if (playoutMode)
{
Thread.Sleep(1000);
Keepalive(url);
if (!initMessagePrinted)
{
logger.InfoFormat("Began SAT>IP playout to port {0}", destinationPort);
initMessagePrinted = true;
}
}
else
{
if (packetQueue.Count >= 1)
{
byte[] buffer;
lock (packetQueue)
{
buffer = packetQueue.Dequeue();
}
context.IngestSinglePacket(buffer);
if (!initMessagePrinted)
{
logger.InfoFormat("Began SAT>IP stream.");
initMessagePrinted = true;
}
}
else
{
Thread.Sleep(1);
}
if (context.IsAbortConditionMet())
break;
if (DateTime.Now.Second != lastTimestamp.Second)
{
Keepalive(url);
lastTimestamp = DateTime.Now;
}
}
}
rtspClient.GetTeardown(setup);
rtspClient.Dispose();
}
private FileStream fs;
private uint stuffingBytes;
private Queue<byte[]> packetQueue;
private ObjectStorage objectStorage;
private DataStorage dataStorage;
private SkyscraperContext context;
private void Setup_OnRtpPacket(byte[] data, int length)
{
for (int i = 12; i < length; i += 1)
{
if (data[i] == 'G')
{
byte[] buffer = new byte[188];
Array.Copy(data, i, buffer, 0, 188);
lock (packetQueue)
{
packetQueue.Enqueue(buffer);
}
DumpPacket(buffer);
i += 187;
}
else if (data[i] == 0xff)
{
stuffingBytes++;
}
}
}
private void DumpPacket(byte[] buffer)
{
if (!ENABLE_TS_WRITER)
return;
if (fs == null)
{
string fname = String.Format("{0}.ts", DateTime.Now.Ticks);
fs = File.OpenWrite(fname);
}
fs.Write(buffer, 0, buffer.Length);
}
private int rtcps;
private IPAddress destinationIp;
private int destinationPort;
private bool playoutMode;
private bool multicastMode;
private void Setup_OnRtcpPacket(byte[] data, int length)
{
//rtcps++;
}
private DiSEqC_Opcode BuildDiseqcOpcode()
{
DiSEqC_Opcode opcode = DiSEqC_Opcode.DISEQC_HIGH_NIBBLE;
switch (diseqcNumber)
{
case 1:
opcode |= DiSEqC_Opcode.DISEQC_OPTION_A;
opcode |= DiSEqC_Opcode.DISEQC_POSITION_A;
break;
case 2:
opcode |= DiSEqC_Opcode.DISEQC_OPTION_A;
opcode |= DiSEqC_Opcode.DISEQC_POSITION_B;
break;
case 3:
opcode |= DiSEqC_Opcode.DISEQC_OPTION_B;
opcode |= DiSEqC_Opcode.DISEQC_POSITION_A;
break;
case 4:
opcode |= DiSEqC_Opcode.DISEQC_OPTION_B;
opcode |= DiSEqC_Opcode.DISEQC_POSITION_B;
break;
default:
throw new ArgumentOutOfRangeException("Your DiSEqC position should be a number between 1 and 4.");
}
switch (polarity)
{
case 'H':
opcode |= DiSEqC_Opcode.DISEQC_HORIZONTAL;
break;
case 'V':
opcode |= DiSEqC_Opcode.DISEQC_VERTICAL;
break;
default:
throw new ArgumentException("The polarity should be H or V.");
}
return opcode;
}
private bool ParseDvbStandard(string standard)
{
standard = standard.ToUpperInvariant();
if (standard.StartsWith("DVB"))
standard = standard.Substring(3);
if (standard.StartsWith("-"))
standard = standard.Substring(1);
switch (standard)
{
case "S":
return false;
case "S2":
return true;
case "S2X":
return true;
default:
throw new ArgumentException(String.Format("I have no idea what kind of Standard {0} is supposed to be.", standard));
}
}
private void Keepalive(string url = "/")
{
RtspOptionsResponse options = rtspClient.GetOptions("/");
if (options.RtspStatusCode != 200)
{
throw new RtspException(String.Format("Unexpected RTSP Status code. Wanted {0}, got {1}", 200, options.RtspStatusCode));
}
}
}
}

710
skyscraper8/SatIp/RtspClient.cs
View File

@ -1,347 +1,363 @@
using System;
using System.Collections.Generic;
using System.Linq;
using System.Net;
using System.Net.Sockets;
using System.Text;
using System.Threading.Tasks;
using skyscraper5.Skyscraper;
using skyscraper5.Skyscraper.IO.CrazycatStreamReader;
using skyscraper8.SatIp.RtspRequests;
using skyscraper8.SatIp.RtspResponses;
namespace skyscraper8.SatIp
{
internal class RtspClient : Validatable, IDisposable
{
private uint cseqCounter;
private const string USER_AGENT = "sophiaNetRtspClient/1.0";
public RtspClient(string ip, int port)
{
IPEndPoint ipEndPoint = new IPEndPoint(IPAddress.Parse(ip), port);
ConstructStep2(ipEndPoint);
}
public RtspClient(IPAddress ip, int port)
{
IPEndPoint ipEndPoint = new IPEndPoint(ip, port);
ConstructStep2(ipEndPoint);
}
private void ConstructStep2(IPEndPoint ipEndPoint)
{
this.TcpClient = new TcpClient();
this.TcpClient.Connect(ipEndPoint);
this.RootPath = string.Format("rtsp://{0}:{1}", ipEndPoint.Address.ToString(), ipEndPoint.Port.ToString());
this.NetworkStream = TcpClient.GetStream();
this.BufferedStream = new BufferedStream(this.NetworkStream);
this.StreamReader = new StreamReader(this.BufferedStream);
this.StreamWriter = new StreamWriter(this.BufferedStream);
this.cseqCounter = 2;
this.ListenIp = GetListenIp(this.TcpClient.Client.LocalEndPoint);
RtspOptionsResponse rtspOptionsResponse = GetOptions("/");
this.Valid = rtspOptionsResponse.Valid;
}
public bool AutoReconnect { get; set; }
public IPAddress ListenIp { get; set; }
private IPAddress GetListenIp(EndPoint clientLocalEndPoint)
{
IPEndPoint ipEndPoint = clientLocalEndPoint as IPEndPoint;
if (ipEndPoint == null)
{
throw new NotImplementedException(clientLocalEndPoint.GetType().Name);
}
if (ipEndPoint.Address.AddressFamily == AddressFamily.InterNetwork)
{
return ipEndPoint.Address;
}
if (ipEndPoint.Address.IsIPv4MappedToIPv6)
{
return ipEndPoint.Address.MapToIPv4();
}
throw new NotImplementedException(String.Format("Don't know whether I can listen on IP {0}", ipEndPoint.ToString()));
}
public string RootPath { get; set; }
private TcpClient TcpClient { get; set; }
private NetworkStream NetworkStream { get; set; }
private BufferedStream BufferedStream { get; set; }
private StreamReader StreamReader { get; set; }
private StreamWriter StreamWriter { get; set; }
public RtspOptionsResponse GetOptions(string url)
{
RtspOptionsRequest request = new RtspOptionsRequest();
request.RequestPath = url;
request.CSeq = cseqCounter++;
request.UserAgent = USER_AGENT;
RtspResponseHeader header = GetResponse(request.ListHeaders(RootPath));
RtspOptionsResponse result = new RtspOptionsResponse(header);
return result;
}
public RtspDescribeResponse GetDescribe(string url)
{
RtspDescribeRequest request = new RtspDescribeRequest();
request.RequestPath = url;
request.CSeq = cseqCounter++;
request.UserAgent = USER_AGENT;
request.Accept = "application/sdp";
RtspResponseHeader header = GetResponse(request.ListHeaders(RootPath));
RtspDescribeResponse result = new RtspDescribeResponse(header);
return result;
}
public RtspSetupResponse GetSetup(string url)
{
RtspSetupRequest request = new RtspSetupRequest();
request.RequestPath = url;
request.CSeq = cseqCounter++;
request.UserAgent = USER_AGENT;
Socket rtpSocket = new Socket(AddressFamily.InterNetwork, SocketType.Dgram, ProtocolType.Udp);
rtpSocket.Bind(new IPEndPoint(ListenIp, 0));
int rtpPort = GetPortFromEndPoint(rtpSocket.LocalEndPoint);
Socket rtcpSocket = new Socket(AddressFamily.InterNetwork, SocketType.Dgram, ProtocolType.Udp);
rtcpSocket.Bind(new IPEndPoint(ListenIp, 0));
int rtcpPort = GetPortFromEndPoint(rtcpSocket.LocalEndPoint);
request.SetRtpAvpUnicast(rtpPort, rtcpPort);
RtspResponseHeader response = GetResponse(request.ListHeaders(RootPath));
RtspSetupResponse setupResponse = new RtspSetupResponse(response);
switch (response.statusCode)
{
case 200:
setupResponse.RtpSocket = rtpSocket;
setupResponse.RtcpSocket = rtcpSocket;
setupResponse.SetupListeners();
setupResponse.Valid = true;
break;
case 404:
setupResponse.Valid = true;
break;
default:
throw new NotImplementedException(setupResponse.RtspStatusCode.ToString());
}
return setupResponse;
}
public RtspPlayResponse GetPlay(RtspSetupResponse setupData)
{
RtspPlayRequest request = new RtspPlayRequest();
request.RequestPath = string.Format("/stream={0}", setupData.StreamId);
request.Session = setupData.Session;
request.UserAgent = USER_AGENT;
RtspPlayResponse response = new RtspPlayResponse(GetResponse(request.ListHeaders(RootPath)));
return response;
}
public RtspTeardownResponse GetTeardown(RtspSetupResponse setupData)
{
RtspTeardownRequest request = new RtspTeardownRequest();
request.RequestPath = string.Format("/stream={0}", setupData.StreamId);
request.Session = setupData.Session;
request.UserAgent = USER_AGENT;
RtspTeardownResponse response = new RtspTeardownResponse(GetResponse(request.ListHeaders(RootPath)));
if (response.RtspStatusCode == 200)
{
setupData.InvokeCancellationTokens();
if (AutoReconnect)
{
Reconnect();
}
}
return response;
}
private int GetPortFromEndPoint(EndPoint endpoint)
{
IPEndPoint ipEndPoint = endpoint as IPEndPoint;
if (ipEndPoint == null)
throw new NotImplementedException(endpoint.GetType().Name);
return ipEndPoint.Port;
}
private RtspResponseHeader GetResponse(string request)
{
StreamWriter.Write(request);
StreamWriter.Flush();
RtspResponseHeader result = new RtspResponseHeader();
string response = StreamReader.ReadLine();
if (!response.StartsWith("RTSP/"))
throw new RtspException("Invalid RTSP response.");
response = response.Substring(5);
string versionString = response.Substring(0, 3);
result.rtspVersion = Version.Parse(versionString);
response = response.Substring(4);
string statusCodeString = response.Substring(0,3);
result.statusCode = ushort.Parse(statusCodeString);
response = response.Substring(4);
result.statusLine = response;
long contentLength = 0;
result.kv = new Dictionary<string, string>();
while (true)
{
string lineIn = StreamReader.ReadLine();
if (string.IsNullOrEmpty(lineIn))
break;
int indexOf = lineIn.IndexOf(": ");
string key = lineIn.Substring(0, indexOf);
string value = lineIn.Substring(indexOf + 2);
result.kv.Add(key, value);
if (key.Equals("Content-Length"))
{
contentLength = long.Parse(value);
}
}
if (contentLength > 0)
{
StreamReader.DiscardBufferedData();
byte[] buffer = new byte[contentLength];
int sucessfullyRead = BufferedStream.Read(buffer, 0, (int)contentLength);
if (sucessfullyRead != contentLength)
{
throw new IOException("incomplete read");
}
result.payload = buffer;
}
return result;
}
public void Reconnect()
{
EndPoint clientRemoteEndPoint = this.TcpClient.Client.RemoteEndPoint;
IPEndPoint ipEndPoint = clientRemoteEndPoint as IPEndPoint;
if (ipEndPoint == null)
{
throw new NotImplementedException(clientRemoteEndPoint.GetType().ToString());
}
this.TcpClient.Close();
this.TcpClient = new TcpClient();
this.TcpClient.Connect(ipEndPoint);
this.RootPath = string.Format("rtsp://{0}:{1}", ipEndPoint.Address, ipEndPoint.Port);
this.NetworkStream = TcpClient.GetStream();
this.BufferedStream = new BufferedStream(this.NetworkStream);
this.StreamReader = new StreamReader(this.BufferedStream);
this.StreamWriter = new StreamWriter(this.BufferedStream);
this.cseqCounter = 2;
this.ListenIp = GetListenIp(this.TcpClient.Client.LocalEndPoint);
}
/// <summary>
/// Generates a SAT>IP Tuning string.
/// </summary>
/// <param name="diseqcChannel">The DiSEqC Command to send.</param>
/// <param name="freq">The frequency to tune to in MHz.</param>
/// <param name="isS2">Set this to true if tuning to DVB-S2/S2X, or false for DVB-S</param>
/// <param name="symbolrate">The transponder's symbol rate in Ksyms.</param>
/// <param name="forceBbframeMode">Set this to true to force a STiD135 to BBFrame mode. Set this to false if you do not want this, or if the tuner isn't a STiD135. false is always safe here.</param>
/// <returns>A SAT>IP Tuning String</returns>
/// <exception cref="ArgumentOutOfRangeException">Thrown when an invalid DiSEqC Command is supplied.</exception>
public static string MakeUrl(DiSEqC_Opcode diseqcChannel, int freq, bool isS2, int symbolrate, byte? mis = null, bool forceBbframeMode = false)
{
bool diseqcOk = false;
byte diseqc = 1;
if (diseqcChannel.HasFlag(DiSEqC_Opcode.DISEQC_OPTION_A) && diseqcChannel.HasFlag(DiSEqC_Opcode.DISEQC_POSITION_A))
{
diseqc = 1;
diseqcOk = true;
}
if (diseqcChannel.HasFlag(DiSEqC_Opcode.DISEQC_OPTION_A) && diseqcChannel.HasFlag(DiSEqC_Opcode.DISEQC_POSITION_B))
{
diseqc = 2;
diseqcOk = true;
}
if (diseqcChannel.HasFlag(DiSEqC_Opcode.DISEQC_OPTION_B) && diseqcChannel.HasFlag(DiSEqC_Opcode.DISEQC_POSITION_A))
{
diseqc = 3;
diseqcOk = true;
}
if (diseqcChannel.HasFlag(DiSEqC_Opcode.DISEQC_OPTION_B) && diseqcChannel.HasFlag(DiSEqC_Opcode.DISEQC_POSITION_B))
{
diseqc = 4;
diseqcOk = true;
}
if (!diseqcOk)
{
throw new ArgumentOutOfRangeException(nameof(diseqcChannel));
}
char pol;
if (diseqcChannel.HasFlag(DiSEqC_Opcode.DISEQC_HORIZONTAL))
{
pol = 'h';
}
else
{
pol = 'v';
}
StringBuilder sb = new StringBuilder();
sb.AppendFormat("/?src={0}", diseqc);
sb.AppendFormat("&freq={0}", freq);
sb.AppendFormat("&pol={0}", pol);
sb.AppendFormat("&msys={0}", isS2 ? "dvbs2" : "dvbs");
sb.AppendFormat("&sr={0}", symbolrate);
sb.AppendFormat("&pids=all");
//Thanks to the Digital Devices Customer Support for giving me this advice.
if (forceBbframeMode)
{
sb.Append("&x_isi=0x80000000");
}
else if (mis.HasValue)
{
sb.AppendFormat("&x_isi={0}", mis.Value);
}
return sb.ToString();
}
private bool disposed;
public void Dispose()
{
if (disposed)
throw new ObjectDisposedException(nameof(RtspClient));
ListenIp = null;
RootPath = null;
if (TcpClient.Connected)
{
TcpClient.Close();
}
TcpClient.Dispose();
NetworkStream = null;
BufferedStream = null;
StreamReader = null;
StreamWriter = null;
disposed = true;
}
}
}
using System;
using System.Collections.Generic;
using System.Linq;
using System.Net;
using System.Net.Sockets;
using System.Text;
using System.Threading.Tasks;
using skyscraper5.Skyscraper;
using skyscraper5.Skyscraper.IO.CrazycatStreamReader;
using skyscraper8.SatIp.RtspRequests;
using skyscraper8.SatIp.RtspResponses;
namespace skyscraper8.SatIp
{
internal class RtspClient : Validatable, IDisposable
{
private uint cseqCounter;
private const string USER_AGENT = "sophiaNetRtspClient/1.0";
public RtspClient(string ip, int port)
{
IPEndPoint ipEndPoint = new IPEndPoint(IPAddress.Parse(ip), port);
ConstructStep2(ipEndPoint);
}
public RtspClient(IPAddress ip, int port)
{
IPEndPoint ipEndPoint = new IPEndPoint(ip, port);
ConstructStep2(ipEndPoint);
}
private void ConstructStep2(IPEndPoint ipEndPoint)
{
this.TcpClient = new TcpClient();
this.TcpClient.Connect(ipEndPoint);
this.RootPath = string.Format("rtsp://{0}:{1}", ipEndPoint.Address.ToString(), ipEndPoint.Port.ToString());
this.NetworkStream = TcpClient.GetStream();
this.BufferedStream = new BufferedStream(this.NetworkStream);
this.StreamReader = new StreamReader(this.BufferedStream);
this.StreamWriter = new StreamWriter(this.BufferedStream);
this.cseqCounter = 2;
this.ListenIp = GetListenIp(this.TcpClient.Client.LocalEndPoint);
RtspOptionsResponse rtspOptionsResponse = GetOptions("/");
this.Valid = rtspOptionsResponse.Valid;
}
public bool AutoReconnect { get; set; }
public IPAddress ListenIp { get; set; }
private IPAddress GetListenIp(EndPoint clientLocalEndPoint)
{
IPEndPoint ipEndPoint = clientLocalEndPoint as IPEndPoint;
if (ipEndPoint == null)
{
throw new NotImplementedException(clientLocalEndPoint.GetType().Name);
}
if (ipEndPoint.Address.AddressFamily == AddressFamily.InterNetwork)
{
return ipEndPoint.Address;
}
if (ipEndPoint.Address.IsIPv4MappedToIPv6)
{
return ipEndPoint.Address.MapToIPv4();
}
throw new NotImplementedException(String.Format("Don't know whether I can listen on IP {0}", ipEndPoint.ToString()));
}
public string RootPath { get; set; }
private TcpClient TcpClient { get; set; }
private NetworkStream NetworkStream { get; set; }
private BufferedStream BufferedStream { get; set; }
private StreamReader StreamReader { get; set; }
private StreamWriter StreamWriter { get; set; }
public RtspOptionsResponse GetOptions(string url)
{
RtspOptionsRequest request = new RtspOptionsRequest();
request.RequestPath = url;
request.CSeq = cseqCounter++;
request.UserAgent = USER_AGENT;
RtspResponseHeader header = GetResponse(request.ListHeaders(RootPath));
RtspOptionsResponse result = new RtspOptionsResponse(header);
return result;
}
public RtspDescribeResponse GetDescribe(string url)
{
RtspDescribeRequest request = new RtspDescribeRequest();
request.RequestPath = url;
request.CSeq = cseqCounter++;
request.UserAgent = USER_AGENT;
request.Accept = "application/sdp";
RtspResponseHeader header = GetResponse(request.ListHeaders(RootPath));
RtspDescribeResponse result = new RtspDescribeResponse(header);
return result;
}
public RtspSetupResponse GetSetup(string url, int destinationPort = 0, bool multicastMode = false, IPAddress multicastIp = null)
{
RtspSetupRequest request = new RtspSetupRequest();
request.RequestPath = url;
request.CSeq = cseqCounter++;
request.UserAgent = USER_AGENT;
int rtpPort = 0;
Socket rtpSocket = null;
if (destinationPort == 0)
{
rtpSocket = new Socket(AddressFamily.InterNetwork, SocketType.Dgram, ProtocolType.Udp);
rtpSocket.Bind(new IPEndPoint(ListenIp, 0));
rtpPort = GetPortFromEndPoint(rtpSocket.LocalEndPoint);
}
else
{
rtpPort = destinationPort;
}
Socket rtcpSocket = new Socket(AddressFamily.InterNetwork, SocketType.Dgram, ProtocolType.Udp);
rtcpSocket.Bind(new IPEndPoint(ListenIp, 0));
int rtcpPort = GetPortFromEndPoint(rtcpSocket.LocalEndPoint);
if (multicastMode && multicastIp != null)
{
request.SetRtpAvpMulticast(multicastIp, rtpPort, rtcpPort);
}
else
{
request.SetRtpAvpUnicast(rtpPort, rtcpPort);
}
RtspResponseHeader response = GetResponse(request.ListHeaders(RootPath));
RtspSetupResponse setupResponse = new RtspSetupResponse(response);
switch (response.statusCode)
{
case 200:
setupResponse.RtpSocket = rtpSocket;
setupResponse.RtcpSocket = rtcpSocket;
setupResponse.SetupListeners();
setupResponse.Valid = true;
break;
case 404:
setupResponse.Valid = true;
break;
default:
throw new NotImplementedException(setupResponse.RtspStatusCode.ToString());
}
return setupResponse;
}
public RtspPlayResponse GetPlay(RtspSetupResponse setupData)
{
RtspPlayRequest request = new RtspPlayRequest();
request.RequestPath = string.Format("/stream={0}", setupData.StreamId);
request.Session = setupData.Session;
request.UserAgent = USER_AGENT;
RtspPlayResponse response = new RtspPlayResponse(GetResponse(request.ListHeaders(RootPath)));
return response;
}
public RtspTeardownResponse GetTeardown(RtspSetupResponse setupData)
{
RtspTeardownRequest request = new RtspTeardownRequest();
request.RequestPath = string.Format("/stream={0}", setupData.StreamId);
request.Session = setupData.Session;
request.UserAgent = USER_AGENT;
RtspTeardownResponse response = new RtspTeardownResponse(GetResponse(request.ListHeaders(RootPath)));
if (response.RtspStatusCode == 200)
{
setupData.InvokeCancellationTokens();
if (AutoReconnect)
{
Reconnect();
}
}
return response;
}
private int GetPortFromEndPoint(EndPoint endpoint)
{
IPEndPoint ipEndPoint = endpoint as IPEndPoint;
if (ipEndPoint == null)
throw new NotImplementedException(endpoint.GetType().Name);
return ipEndPoint.Port;
}
private RtspResponseHeader GetResponse(string request)
{
StreamWriter.Write(request);
StreamWriter.Flush();
RtspResponseHeader result = new RtspResponseHeader();
string response = StreamReader.ReadLine();
if (!response.StartsWith("RTSP/"))
throw new RtspException("Invalid RTSP response.");
response = response.Substring(5);
string versionString = response.Substring(0, 3);
result.rtspVersion = Version.Parse(versionString);
response = response.Substring(4);
string statusCodeString = response.Substring(0,3);
result.statusCode = ushort.Parse(statusCodeString);
response = response.Substring(4);
result.statusLine = response;
long contentLength = 0;
result.kv = new Dictionary<string, string>();
while (true)
{
string lineIn = StreamReader.ReadLine();
if (string.IsNullOrEmpty(lineIn))
break;
int indexOf = lineIn.IndexOf(": ");
string key = lineIn.Substring(0, indexOf);
string value = lineIn.Substring(indexOf + 2);
result.kv.Add(key, value);
if (key.Equals("Content-Length"))
{
contentLength = long.Parse(value);
}
}
if (contentLength > 0)
{
StreamReader.DiscardBufferedData();
byte[] buffer = new byte[contentLength];
int sucessfullyRead = BufferedStream.Read(buffer, 0, (int)contentLength);
if (sucessfullyRead != contentLength)
{
throw new IOException("incomplete read");
}
result.payload = buffer;
}
return result;
}
public void Reconnect()
{
EndPoint clientRemoteEndPoint = this.TcpClient.Client.RemoteEndPoint;
IPEndPoint ipEndPoint = clientRemoteEndPoint as IPEndPoint;
if (ipEndPoint == null)
{
throw new NotImplementedException(clientRemoteEndPoint.GetType().ToString());
}
this.TcpClient.Close();
this.TcpClient = new TcpClient();
this.TcpClient.Connect(ipEndPoint);
this.RootPath = string.Format("rtsp://{0}:{1}", ipEndPoint.Address, ipEndPoint.Port);
this.NetworkStream = TcpClient.GetStream();
this.BufferedStream = new BufferedStream(this.NetworkStream);
this.StreamReader = new StreamReader(this.BufferedStream);
this.StreamWriter = new StreamWriter(this.BufferedStream);
this.cseqCounter = 2;
this.ListenIp = GetListenIp(this.TcpClient.Client.LocalEndPoint);
}
/// <summary>
/// Generates a SAT>IP Tuning string.
/// </summary>
/// <param name="diseqcChannel">The DiSEqC Command to send.</param>
/// <param name="freq">The frequency to tune to in MHz.</param>
/// <param name="isS2">Set this to true if tuning to DVB-S2/S2X, or false for DVB-S</param>
/// <param name="symbolrate">The transponder's symbol rate in Ksyms.</param>
/// <param name="forceBbframeMode">Set this to true to force a STiD135 to BBFrame mode. Set this to false if you do not want this, or if the tuner isn't a STiD135. false is always safe here.</param>
/// <returns>A SAT>IP Tuning String</returns>
/// <exception cref="ArgumentOutOfRangeException">Thrown when an invalid DiSEqC Command is supplied.</exception>
public static string MakeUrl(DiSEqC_Opcode diseqcChannel, int freq, bool isS2, int symbolrate, byte? mis = null, bool forceBbframeMode = false)
{
bool diseqcOk = false;
byte diseqc = 1;
if (diseqcChannel.HasFlag(DiSEqC_Opcode.DISEQC_OPTION_A) && diseqcChannel.HasFlag(DiSEqC_Opcode.DISEQC_POSITION_A))
{
diseqc = 1;
diseqcOk = true;
}
if (diseqcChannel.HasFlag(DiSEqC_Opcode.DISEQC_OPTION_A) && diseqcChannel.HasFlag(DiSEqC_Opcode.DISEQC_POSITION_B))
{
diseqc = 2;
diseqcOk = true;
}
if (diseqcChannel.HasFlag(DiSEqC_Opcode.DISEQC_OPTION_B) && diseqcChannel.HasFlag(DiSEqC_Opcode.DISEQC_POSITION_A))
{
diseqc = 3;
diseqcOk = true;
}
if (diseqcChannel.HasFlag(DiSEqC_Opcode.DISEQC_OPTION_B) && diseqcChannel.HasFlag(DiSEqC_Opcode.DISEQC_POSITION_B))
{
diseqc = 4;
diseqcOk = true;
}
if (!diseqcOk)
{
throw new ArgumentOutOfRangeException(nameof(diseqcChannel));
}
char pol;
if (diseqcChannel.HasFlag(DiSEqC_Opcode.DISEQC_HORIZONTAL))
{
pol = 'h';
}
else
{
pol = 'v';
}
StringBuilder sb = new StringBuilder();
sb.AppendFormat("/?src={0}", diseqc);
sb.AppendFormat("&freq={0}", freq);
sb.AppendFormat("&pol={0}", pol);
sb.AppendFormat("&msys={0}", isS2 ? "dvbs2" : "dvbs");
sb.AppendFormat("&sr={0}", symbolrate);
sb.AppendFormat("&pids=all");
//Thanks to the Digital Devices Customer Support for giving me this advice.
if (forceBbframeMode)
{
sb.Append("&x_isi=0x80000000");
}
else if (mis.HasValue)
{
sb.AppendFormat("&x_isi={0}", mis.Value);
}
return sb.ToString();
}
private bool disposed;
public void Dispose()
{
if (disposed)
throw new ObjectDisposedException(nameof(RtspClient));
ListenIp = null;
RootPath = null;
if (TcpClient.Connected)
{
TcpClient.Close();
}
TcpClient.Dispose();
NetworkStream = null;
BufferedStream = null;
StreamReader = null;
StreamWriter = null;
disposed = true;
}
}
}

120
skyscraper8/SatIp/RtspRequests/RtspSetupRequest.cs
View File

@ -1,57 +1,63 @@
using System;
using System.Collections.Generic;
using System.Linq;
using System.Text;
using System.Threading.Tasks;
namespace skyscraper8.SatIp.RtspRequests
{
internal class RtspSetupRequest : RtspRequest
{
public RtspSetupRequest() : base("SETUP")
{
}
public uint CSeq
{
set
{
base.args["CSeq"] = Convert.ToString(value);
}
get
{
return uint.Parse(base.args["CSeq"]);
}
}
public string UserAgent
{
set
{
base.args["User-Agent"] = value;
}
get
{
return base.args["User-Agent"];
}
}
public string Transport
{
set
{
base.args["Transport"] = value;
}
get
{
return base.args["Transport"];
}
}
public void SetRtpAvpUnicast(int rtpPort, int rtcpPort)
{
Transport = String.Format("RTP/AVP;unicast;client_port={0}-{1}", rtpPort, rtcpPort);
}
}
}
using System;
using System.Collections.Generic;
using System.Linq;
using System.Net;
using System.Text;
using System.Threading.Tasks;
namespace skyscraper8.SatIp.RtspRequests
{
internal class RtspSetupRequest : RtspRequest
{
public RtspSetupRequest() : base("SETUP")
{
}
public uint CSeq
{
set
{
base.args["CSeq"] = Convert.ToString(value);
}
get
{
return uint.Parse(base.args["CSeq"]);
}
}
public string UserAgent
{
set
{
base.args["User-Agent"] = value;
}
get
{
return base.args["User-Agent"];
}
}
public string Transport
{
set
{
base.args["Transport"] = value;
}
get
{
return base.args["Transport"];
}
}
public void SetRtpAvpUnicast(int rtpPort, int rtcpPort)
{
Transport = String.Format("RTP/AVP;unicast;client_port={0}-{1}", rtpPort, rtcpPort);
}
public void SetRtpAvpMulticast(IPAddress targetIp, int rtpPort, int rtcpPort)
{
Transport = String.Format("RTP/AVP;multicast;destination={2};port={0}-{1}", rtpPort, rtcpPort, targetIp.ToString());
}
}
}

40
skyscraper8/SatIp/RtspResponses/RtspSetupResponse.cs
View File

@ -53,23 +53,29 @@ namespace skyscraper8.SatIp.RtspResponses
if (listenersStarted)
throw new RtspException("Listener already started.");
rtpCancellation = new CancellationTokenSource();
if (RtpSocket != null)
{
rtpCancellation = new CancellationTokenSource();
}
rtcpCancellation = new CancellationTokenSource();
Task.Run(async () =>
{
byte[] buffer = new byte[2048];
while (!rtpCancellation.IsCancellationRequested)
{
Array.Clear(buffer);
int result = await RtpSocket.ReceiveAsync(buffer, rtpCancellation.Token);
OnRtpPacket?.Invoke(buffer, result);
}
exitedThread++;
}
);
if (RtpSocket != null)
{
Task.Run(async () =>
{
byte[] buffer = new byte[2048];
while (!rtpCancellation.IsCancellationRequested)
{
Array.Clear(buffer);
int result = await RtpSocket.ReceiveAsync(buffer, rtpCancellation.Token);
OnRtpPacket?.Invoke(buffer, result);
}
exitedThread++;
}
);
}
Task.Run(async () =>
{
@ -92,8 +98,8 @@ namespace skyscraper8.SatIp.RtspResponses
internal void InvokeCancellationTokens()
{
rtpCancellation.Cancel();
rtcpCancellation.Cancel();
rtpCancellation?.Cancel();
rtcpCancellation?.Cancel();
}
public event OnRtpPacket OnRtpPacket;

20
skyscraper8/Skyscraper/Equipment/BaseEquipment.cs
View File

@ -1,20 +0,0 @@
using System;
using System.Xml.Serialization;
namespace skyscraper5.Skyscraper.Equipment
{
public class BaseEquipment
{
[XmlIgnore]
public int Id { get; set; }
[XmlAttribute]
public string Manufacturer { get; set; }
[XmlAttribute]
public string Name { get; set; }
[XmlIgnore]
public DateTime DateAdded { get; set; }
}
}

57
skyscraper8/Skyscraper/Equipment/Dish.cs
View File

@ -1,57 +0,0 @@
using System;
using System.Xml.Serialization;
namespace skyscraper5.Skyscraper.Equipment
{
public class DishEntity : BaseEquipment
{
public DishEntity(string manufac, string name, int diameter, DishShape shape)
{
this.Manufacturer = manufac;
this.Name = name;
this.Diameter = diameter;
this.Shape = shape;
}
public DishEntity()
{
}
[XmlAttribute]
public int Diameter { get; set; }
[XmlAttribute]
public DishShape Shape { get; set; }
protected bool Equals(DishEntity other)
{
return Diameter == other.Diameter && Shape == other.Shape;
}
public override bool Equals(object obj)
{
if (ReferenceEquals(null, obj)) return false;
if (ReferenceEquals(this, obj)) return true;
if (obj.GetType() != this.GetType()) return false;
return Equals((DishEntity)obj);
}
public override int GetHashCode()
{
return HashCode.Combine(Diameter, (int)Shape);
}
public override string ToString()
{
return this.Name;
}
}
public enum DishShape : int
{
Offset,
PrimeFocus,
Mesh,
Other
}
}

20
skyscraper8/Skyscraper/Equipment/EquipmentCollection.cs
View File

@ -1,20 +0,0 @@
namespace skyscraper5.Skyscraper.Equipment;
public class EquipmentCollection
{
public EquipmentCollection()
{
Dishes = new List<DishEntity>();
LNBs = new List<LnbEntity>();
SatellitePositions = new List<SatellitePositionEntity>();
}
public List<DishEntity> Dishes { get; set; }
public List<LnbEntity> LNBs { get; set; }
public List<SatellitePositionEntity> SatellitePositions { get; set; }
public override string ToString()
{
return String.Format("{0} dishes, {1} LNBs, {2} satellite positions", Dishes.Count, LNBs.Count, SatellitePositions.Count);
}
}

57
skyscraper8/Skyscraper/Equipment/EquipmentUtilities.cs
View File

@ -1,57 +0,0 @@
using System;
using System.Collections.Generic;
using skyscraper5.Skyscraper.Scraper.Storage;
using skyscraper8.Skyscraper.Scraper.Storage;
namespace skyscraper5.Skyscraper.Equipment
{
public static class EquipmentUtilities
{
public static void InsertDefaultLnbTypes(DataStorage storage)
{
List<LnbEntity> knownLnbTypes = storage.UiLnbTypesListAll();
foreach (LnbEntity defaultLnbType in GetDefaultLnbTypes())
{
if (!knownLnbTypes.Contains(defaultLnbType))
storage.UiLnbTypesAdd(defaultLnbType);
}
}
private static IEnumerable<LnbEntity> GetDefaultLnbTypes()
{
LnbEntity lnbType = new LnbEntity();
lnbType.Lof1 = 9750;
lnbType.Lof2 = 10600;
lnbType.LofSw = 11700;
lnbType.MinimumFrequency = 10700;
lnbType.MaximumFrequency = 12750;
lnbType.Manufacturer = "Generic";
lnbType.Name = "Universal LNB";
yield return lnbType;
}
public static void InsertDefaultDishTypes(DataStorage storage)
{
List<DishEntity> knownDishTypes = storage.UiDishTypesListAll();
foreach (DishEntity defaultDishType in GetDefaultDishTypes())
{
if (!knownDishTypes.Contains(defaultDishType))
storage.UiDishTypesAdd(defaultDishType);
}
}
private static IEnumerable<DishEntity> GetDefaultDishTypes()
{
int[] commonSizes = new int[] { 60, 80, 85, 100 };
foreach (int commonSize in commonSizes)
{
DishEntity dishType = new DishEntity();
dishType.Diameter = commonSize;
dishType.Shape = DishShape.Offset;
dishType.Manufacturer = "Generic";
dishType.Name = String.Format("{0} cm Offset dish antenna", commonSize);
yield return dishType;
}
}
}
}

59
skyscraper8/Skyscraper/Equipment/LNB.cs
View File

@ -1,59 +0,0 @@
using System;
using System.Xml.Serialization;
namespace skyscraper5.Skyscraper.Equipment
{
public class LnbEntity : BaseEquipment
{
public LnbEntity() { }
public LnbEntity(string manufac, string name, int lof1, int lof2, int lofSw, int minFreq, int maxFreq)
{
this.Manufacturer = manufac;
this.Name = name;
this.Lof1 = lof1;
this.Lof2 = lof2;
this.LofSw = lofSw;
this.MinimumFrequency = minFreq;
this.MaximumFrequency = maxFreq;
}
[XmlAttribute]
public int Lof1 { get; set; }
[XmlAttribute]
public int Lof2 { get; set; }
[XmlAttribute]
public int LofSw { get; set; }
[XmlAttribute]
public int MinimumFrequency { get; set; }
[XmlAttribute]
public int MaximumFrequency { get; set; }
protected bool Equals(LnbEntity other)
{
return Lof1 == other.Lof1 && Lof2 == other.Lof2 && LofSw == other.LofSw && MinimumFrequency == other.MinimumFrequency && MaximumFrequency == other.MaximumFrequency;
}
public override bool Equals(object obj)
{
if (ReferenceEquals(null, obj)) return false;
if (ReferenceEquals(this, obj)) return true;
if (obj.GetType() != this.GetType()) return false;
return Equals((LnbEntity)obj);
}
public override int GetHashCode()
{
return HashCode.Combine(Lof1, Lof2, LofSw, MinimumFrequency, MaximumFrequency);
}
public override string ToString()
{
return String.Format("{0} {1}", Manufacturer, Name);
}
}
}

108
skyscraper8/Skyscraper/Equipment/SatellitePositionEntity.cs
View File

@ -1,108 +0,0 @@
using System;
using System.Collections.Generic;
using System.Linq;
using System.Text;
using System.Threading.Tasks;
namespace skyscraper5.Skyscraper
{
public class SatellitePositionEntity
{
public SatellitePositionEntity()
{
}
public SatellitePositionEntity(float angle, string name)
{
this.angle = angle;
this.name = name;
}
public float angle;
public string name;
public int Checksum => GetChecksum(angle);
public static int GetChecksum(float angle)
{
int result = (int)(angle * 10.0f);
return result;
}
public override string ToString()
{
if (angle > 0)
{
return String.Format("{0}°E {1}", angle, name);
}
else
{
float tmpAngle = angle;
tmpAngle *= -1;
return String.Format("{0}°W {1}", tmpAngle, name);
}
}
public static SatellitePositionEntity FromChecksum(int checksum)
{
float newAngle = checksum;
newAngle /= 10.0f;
return new SatellitePositionEntity(newAngle, "???");
}
protected bool Equals(SatellitePositionEntity other)
{
return angle.Equals(other.angle);
}
public override bool Equals(object obj)
{
if (ReferenceEquals(null, obj)) return false;
if (ReferenceEquals(this, obj)) return true;
if (obj.GetType() != this.GetType()) return false;
return Equals((SatellitePositionEntity)obj);
}
public override int GetHashCode()
{
return HashCode.Combine(angle);
}
/// <summary>
/// Returns an integer value for the cardinal direction.
/// </summary>
/// <returns>Returns 0 for east, 1 for west, 2 if satellite is at 0.0</returns>
public int GetCardinalDirectionAsInt()
{
if (angle > 0)
return 0;
else if (angle < 0)
return 1;
else
return 2;
}
/// <summary>
/// Get the letter matching the cardinal direction of the satellite.
/// </summary>
/// <returns>Returns either 'E' or 'W' depending on the angle.</returns>
public char GetCardinalDirectionAsChar()
{
int cardinalDirectionAsInt = GetCardinalDirectionAsInt();
return cardinalDirectionAsInt == 0 ? 'E' : 'W';
}
/// <summary>
/// Get a filename-safe number of the angle. Meaning the angle stripped of its sign and decimal separator.
/// </summary>
/// <returns>For example: For 19.2°E, this will return 192, For 34.5°W, this will return 345</returns>
public int GetCleanAngle()
{
int cleanAngle = (int)(angle * 10.0f);
if (cleanAngle < 0)
cleanAngle /= -1;
return cleanAngle;
}
}
}

68
skyscraper8/Skyscraper/FrequencyListGenerator/BaseBlindscanJob.cs
View File

@ -13,7 +13,6 @@ using skyscraper5.src.Mpeg2.PacketFilter;
using skyscraper5.Skyscraper.IO;
using skyscraper5.Skyscraper.Scraper;
using System.Runtime.InteropServices;
using skyscraper5.Skyscraper.Equipment;
namespace skyscraper8.Skyscraper.FrequencyListGenerator
{
@ -94,12 +93,12 @@ namespace skyscraper8.Skyscraper.FrequencyListGenerator
SearchResult sr1 = default;
int tpNum = default;
int lof1 = config.LnbType.Lof1 * 1000;
int lof2 = config.LnbType.Lof2 * 1000;
int lofSw = config.LnbType.LofSw * 1000;
int lof1 = config.Lof1 * 1000;
int lof2 = config.Lof2 * 1000;
int lofSw = config.LofSw * 1000;
int diseqc = config.TunerMetadata.DiseqcType;
int startFreq = config.LnbType.MinimumFrequency * 1000;
int endFreq = config.LnbType.MaximumFrequency * 1000;
int startFreq = config.MinimumFrequency * 1000;
int endFreq = config.MaximumFrequency * 1000;
bool anythingSuceeded = false;
nint allocHGlobal = Marshal.AllocHGlobal(ushort.MaxValue);
@ -395,15 +394,15 @@ namespace skyscraper8.Skyscraper.FrequencyListGenerator
foundFrequencies.Add(blindscanSearchResult);
}
config.DataStorage.InsertSearchResult(jobInDb, true, searchResult, polarityIndex, new SearchResult2());
config.Ui.OnBlindscanSearchResult1Callback(blindscanSearchResult, polarityIndex, config.LnbType.MinimumFrequency, config.LnbType.MaximumFrequency);
config.Ui.OnBlindscanSearchResult1Callback(blindscanSearchResult, polarityIndex, config.MinimumFrequency, config.MaximumFrequency);
}
public void RunScrape()
{
int lof1 = config.LnbType.Lof1 * 1000;
int lof2 = config.LnbType.Lof2 * 1000;
int lofSw = config.LnbType.LofSw * 1000;
int lof1 = config.Lof1 * 1000;
int lof2 = config.Lof2 * 1000;
int lofSw = config.LofSw * 1000;
foreach (BlindscanSearchResult blindscanResult in foundFrequencies)
@ -412,7 +411,7 @@ namespace skyscraper8.Skyscraper.FrequencyListGenerator
blindscanResult.State = BlindscanResultState.Tuning;
config.DataStorage.UpdateTransponderState(jobInDb, blindscanResult.IsSatellite(), blindscanResult.SearchResult, blindscanResult.State, blindscanResult.SearchResult2);
config.Ui.OnBlindscanBeforeSetChannel(blindscanResult, config.LnbType);
config.Ui.OnBlindscanBeforeSetChannel(blindscanResult);
bool channel = config.StreamReader.SetChannel(blindscanResult.SearchResult.Freq, blindscanResult.SearchResult.SR, blindscanResult.SearchResult.Pol, blindscanResult.SearchResult.FEC, lof1, lof2, lofSw);
if (!channel)
{
@ -445,11 +444,11 @@ namespace skyscraper8.Skyscraper.FrequencyListGenerator
config.Ui.OnBlindscanBeginRfSpectrum();
int lof1 = config.LnbType.Lof1 * 1000;
int lof2 = config.LnbType.Lof2 * 1000;
int lofSw = config.LnbType.LofSw * 1000;
int startFreq = config.LnbType.MinimumFrequency * 1000;
int endFreq = config.LnbType.MaximumFrequency * 1000;
int lof1 = config.Lof1 * 1000;
int lof2 = config.Lof2 * 1000;
int lofSw = config.LofSw * 1000;
int startFreq = config.MinimumFrequency * 1000;
int endFreq = config.MaximumFrequency * 1000;
RfSpectrumData spectrumData = RfSpectrumData.Create();
@ -574,14 +573,14 @@ namespace skyscraper8.Skyscraper.FrequencyListGenerator
{
int polarity = result.SearchResult.Pol;
int freq = result.SearchResult.Freq;
bool isHighBand = freq > config.LnbType.LofSw * 1000;
bool isHighBand = freq > config.LofSw * 1000;
bool isHorizontal = polarity == 0;
SendDiseqcCommand(isHighBand, isHorizontal);
logger.Log(PluginLogLevel.Info, string.Format("Trying to BLScanEx..."), 8);
if (!config.StreamReader.BLScanEx(result.SearchResult.Freq, 5000, result.SearchResult.Pol,
config.LnbType.Lof1 * 1000, config.LnbType.Lof2 * 1000,
config.LnbType.LofSw * 1000, 1000000, (STD_TYPE)result.SearchResult.StdType,
config.Lof1 * 1000, config.Lof2 * 1000,
config.LofSw * 1000, 1000000, (STD_TYPE)result.SearchResult.StdType,
ref satelliteSr))
{
//No blindscan? No problem! Try anyway!
@ -600,7 +599,7 @@ namespace skyscraper8.Skyscraper.FrequencyListGenerator
Thread.Sleep(1000);
result.State = BlindscanResultState.Retrying;
logger.Log(PluginLogLevel.Info, string.Format("Retrying BLScanEx... ({0}/{1})", i + 1, attempts + 1), 8);
bool retryResult = config.StreamReader.BLScanEx(result.SearchResult.Freq, 5000, result.SearchResult.Pol, config.LnbType.Lof1 * 1000, config.LnbType.Lof2 * 1000, config.LnbType.LofSw * 1000, 1000000, (STD_TYPE)result.SearchResult.StdType,ref satelliteSr);
bool retryResult = config.StreamReader.BLScanEx(result.SearchResult.Freq, 5000, result.SearchResult.Pol, config.Lof1 * 1000, config.Lof2 * 1000, config.LofSw * 1000, 1000000, (STD_TYPE)result.SearchResult.StdType,ref satelliteSr);
if (!retryResult)
{
result.State = BlindscanResultState.BlScanFailure;
@ -676,7 +675,7 @@ namespace skyscraper8.Skyscraper.FrequencyListGenerator
if (plot != null)
{
result.State = BlindscanResultState.IqSaving;
config.ObjectStorage.StoreIqGraph(jobInDb.JobGuid, result.GetFrequency(), result.GetPolarity(config.LnbType.LofSw), plot);
config.ObjectStorage.StoreIqGraph(jobInDb.JobGuid, result.GetFrequency(), result.GetPolarity(config.LofSw), plot);
}
}
@ -707,22 +706,19 @@ namespace skyscraper8.Skyscraper.FrequencyListGenerator
if (tsRecorder.PrepareRecording())
{
DateTime now = DateTime.Now;
int cardinalDirection = 0;
int angle = config.SatellitePosition.Checksum;
if (angle < 0)
{
angle *= -1;
cardinalDirection = 1;
}
string recordingFilename = string.Format(
"skyscraper_{0:D4}{1:D2}{2:D2}_{3:D2}{4:D2}_{8:D4}{9}_{5}_{6}_{7}.ts",
now.Year, now.Month, now.Day, now.Hour, now.Minute, result.GetFrequency() / 1000,
result.GetPolarity(config.LnbType.LofSw), result.GetSymbolRate() / 1000,
config.SatellitePosition.GetCleanAngle(),
config.SatellitePosition.GetCardinalDirectionAsChar());
tsRecorder.SetNextFilename(recordingFilename);
"skyscraper_{0:D4}{1:D2}{2:D2}_{3:D2}{4:D2}_{8}_{5}_{6}_{7}.ts",
now.Year, //0
now.Month, //1
now.Day, //2
now.Hour, //3
now.Minute, //4
result.GetFrequency() / 1000, //5
result.GetPolarity(config.LofSw), //6
result.GetSymbolRate() / 1000, //7
config.GetFiveLetterSattelitePosition()); //8
tsRecorder.SetNextFilename(recordingFilename);
tsRecorder.CreateBufferedStream();
}
}

27
skyscraper8/Skyscraper/FrequencyListGenerator/BlindscanJobConfiguration.cs
View File

@ -4,7 +4,6 @@ using System.Linq;
using System.Text;
using System.Threading.Tasks;
using skyscraper5.Skyscraper;
using skyscraper5.Skyscraper.Equipment;
using skyscraper5.Skyscraper.Gps;
using skyscraper5.Skyscraper.IO;
using skyscraper5.Skyscraper.Scraper;
@ -18,7 +17,7 @@ namespace skyscraper8.Skyscraper.FrequencyListGenerator
public TunerMetadata TunerMetadata { get; set; }
public int DiseqcIndex { get; set; }
public IGpsReceiver Gps { get; set; }
public SatellitePositionEntity SatellitePosition { get; set; }
public double SatellitePosition { get; set; }
public bool DoHorizontalHigh { get; set; }
public bool DoHorizontalLow { get; set; }
@ -29,9 +28,27 @@ namespace skyscraper8.Skyscraper.FrequencyListGenerator
public ObjectStorage ObjectStorage { get; set; }
public ISkyscraperUiJunction Ui { get; set; }
public bool DoCollectRfSpectrum { get; set; }
public LnbEntity LnbType { get; set; }
public bool DoCollectIqGraphs { get; set; }
public bool DoRecordTs { get; set; }
public Ini Ini { get; set; }
}
public Ini Ini { get; set; }
public int Lof1 { get; internal set; }
public int Lof2 { get; internal set; }
public int LofSw { get; internal set; }
public int MinimumFrequency { get; internal set; }
public int MaximumFrequency { get; internal set; }
internal string GetFiveLetterSattelitePosition()
{
if (SatellitePosition >= 0)
{
return String.Format("{0:D4}E", (int)(SatellitePosition * 10));
}
else
{
int westerner = (int)(SatellitePosition * 10);
westerner /= -1;
return String.Format("{0:D4}W", westerner);
}
}
}
}

28
skyscraper8/Skyscraper/FrequencyListGenerator/DbBlindscanJob.cs
View File

@ -15,7 +15,7 @@ namespace skyscraper5.src.Skyscraper.FrequencyListGenerator
public class DbBlindscanJob
{
public DbBlindscanJob(Guid jobGuid, PhysicalAddress tunerMac, STD_TYPE tunerStandard, int diseqCIndex,
IGpsReceiver jobContextGps, SatellitePositionEntity satellitePosition)
IGpsReceiver jobContextGps, double satellitePosition)
{
this.JobGuid = jobGuid;
this.TunerMAC = tunerMac;
@ -37,7 +37,7 @@ namespace skyscraper5.src.Skyscraper.FrequencyListGenerator
}
public SatellitePositionEntity SatPosition { get; private set; }
public double SatPosition { get; private set; }
public GpsCoordinate? GpsCoordinate { get; private set; }
@ -68,8 +68,15 @@ namespace skyscraper5.src.Skyscraper.FrequencyListGenerator
switch(mode)
{
case 1:
if (SatPosition != null)
return String.Format("{0:0.0}° {1}", SatPosition.angle, SatPosition.GetCardinalDirectionAsChar());
if (SatPosition >= 0.0)
{
return String.Format("{0}°E", SatPosition);
}
else
{
double westerner = SatPosition /= -1;
return String.Format("{0}°W", westerner);
}
return TunerStandard.ToString();
case 2:
return String.Format("({0}/{1}/{2}/{3})", (int)HorizontalLowState, (int)HorizontalHighState, (int)VerticalLowState, (int)VerticalHighState);
@ -78,6 +85,19 @@ namespace skyscraper5.src.Skyscraper.FrequencyListGenerator
}
}
public string GetFiveLetterOrbitalPosition()
{
if (SatPosition >= 0)
{
return String.Format("{0:4}E", (int)(SatPosition * 10));
}
else
{
double westerner = SatPosition /= -1;
return String.Format("{0:4}W", (int)(westerner * 10));
}
}
}
public enum DbBlindscanJobPolarizationStatus : int

5
skyscraper8/Skyscraper/IO/RemoteStreamReader/RemoteStreamReaderClient.cs
View File

@ -513,7 +513,10 @@ namespace skyscraper5.Skyscraper.IO.RemoteStreamReader
{
case RemoteStreamReaderConstants.COMMAND_SUCCESSFUL:
pRFLevel = NetworkStreamExtensions.ReadDouble(TcpStream);
return true;
return true;
case RemoteStreamReaderConstants.COMMAND_FAILED:
pRFLevel = NetworkStreamExtensions.ReadDouble(TcpStream);
return false;
default:
throw new NotImplementedException(result.ToString());
}

2
skyscraper8/Skyscraper/IO/TunerInterface/RemoteStreamReaderTunerFactory.cs
View File

@ -6,7 +6,7 @@ namespace skyscraper5.Skyscraper.IO.TunerInterface
{
[SkyscraperPlugin]
[TunerFactoryId(2,"skyscraper5 Remote Stream Reader")]
internal class RemoteStreamReaderTunerFactory : ITunerFactory
public class RemoteStreamReaderTunerFactory : ITunerFactory
{
public string Hostname { get; set; }

3
skyscraper8/Skyscraper/Scraper/ISkyscraperUiJunction.cs
View File

@ -14,7 +14,6 @@ using skyscraper5.Mhp.Si.Model;
using skyscraper5.Mpeg2.Descriptors;
using skyscraper5.Mpeg2.Psi.Model;
using skyscraper5.Scte35;
using skyscraper5.Skyscraper.Equipment;
using skyscraper5.Skyscraper.IO.CrazycatStreamReader;
using skyscraper5.Skyscraper.Net;
using skyscraper5.src.InteractionChannel.Model;
@ -98,7 +97,7 @@ namespace skyscraper5.Skyscraper.Scraper
/// Called before a SetChannel operation is performed.
/// </summary>
/// <param name="blindscanResult"></param>
void OnBlindscanBeforeSetChannel(BlindscanSearchResult blindscanResult, LnbEntity lnbType);
void OnBlindscanBeforeSetChannel(BlindscanSearchResult blindscanResult);
/// <summary>
/// Called after a band (meaning e.g. Horizontal High) has been scraped.

12
skyscraper8/Skyscraper/Scraper/Storage/DataStorage.cs
View File

@ -12,13 +12,11 @@ using skyscraper5.Mpeg2.Psi.Model;
using skyscraper5.Rds.Messages;
using skyscraper5.Scte35;
using skyscraper5.Skyscraper;
using skyscraper5.Skyscraper.Equipment;
using skyscraper5.Skyscraper.Gps;
using skyscraper5.Skyscraper.Headless;
using skyscraper5.Skyscraper.IO.CrazycatStreamReader;
using skyscraper5.Skyscraper.Scraper.Storage.Utilities;
using skyscraper5.src.InteractionChannel.Model;
using skyscraper5.src.InteractionChannel.Model.Descriptors;
using skyscraper5.src.Skyscraper.FrequencyListGenerator;
using skyscraper5.src.Skyscraper.Scraper.Dns;
using skyscraper5.Teletext;
@ -30,8 +28,6 @@ using System.Net.NetworkInformation;
using skyscraper5.src.InteractionChannel.Model2;
using skyscraper8.InteractionChannel.Model;
using skyscraper8.InteractionChannel.Model2;
using skyscraper8.InteractionChannel.Model2.Descriptors;
using Platform = skyscraper5.Dvb.SystemSoftwareUpdate.Model.Platform;
namespace skyscraper8.Skyscraper.Scraper.Storage
{
@ -85,9 +81,6 @@ namespace skyscraper8.Skyscraper.Scraper.Storage
void T2MiSetTimestamp(int currentNetworkId, int currentTransportStreamId, int pid, DateTime resolveTime);
bool TestForRelatedContent(EitEvent lEvent, RctLinkInfo rctLinkInfo);
void SetRelatedContent(EitEvent lEvent, RctLinkInfo rctLinkInfo);
List<SatellitePositionEntity> UiSatellitesListAll();
void UiSatellitesAdd(SatellitePositionEntity newPosition);
void UiSatellitesDelete(SatellitePositionEntity satellitePosition);
bool UiTunerTestFor(TunerMetadata tuner);
void UiTunerUpdate(TunerMetadata tuner);
void UiTunerInsert(TunerMetadata tuner);
@ -107,11 +100,6 @@ namespace skyscraper8.Skyscraper.Scraper.Storage
bool T2MiTestForTransmitter(int? currentNetworkId, int? currentTransportStreamId, int relatedPid, ushort txIdentifier);
void T2MiRememberTransmitter(int? currentNetworkId, int? currentTransportStreamId, int relatedPid, ushort txIdentifier);
void T2MiSetTransmitterTimeOffset(int? currentNetworkId, int? currentTransportStreamId, int relatedPid, ushort txIdentifier, ushort timeOffset);
List<LnbEntity> UiLnbTypesListAll();
void UiLnbTypesAdd(LnbEntity defaultLnbType);
List<DishEntity> UiDishTypesListAll();
void UiDishTypesAdd(DishEntity defaultDishType);
IEnumerable<Tuple<int, int, ProgramMapping>> SelectAllPmt();
SdtService SelectSdtById(int networkId, int tsId, ushort programMappingProgramNumber);
IEnumerable<Tuple<int, int, SdtService>> SelectAllSdt();

133
skyscraper8/Skyscraper/Scraper/Storage/Filesystem/FilesystemStorage.cs
View File

@ -13,7 +13,6 @@ using skyscraper5.Mpeg2.Descriptors;
using skyscraper5.Mpeg2.Psi.Model;
using skyscraper5.Rds.Messages;
using skyscraper5.Scte35;
using skyscraper5.Skyscraper.Equipment;
using skyscraper5.Skyscraper.Gps;
using skyscraper5.Skyscraper.Headless;
using skyscraper5.Skyscraper.IO;
@ -789,48 +788,6 @@ namespace skyscraper5.Skyscraper.Scraper.Storage.Filesystem
}
}
public List<SatellitePositionEntity> UiSatellitesListAll()
{
string path = Path.Combine(rootDirectory.FullName, "satellites.json");
FileInfo fi = new FileInfo(path);
if (!fi.Exists)
return new List<SatellitePositionEntity>();
else
{
return JsonConvert.DeserializeObject<List<SatellitePositionEntity>>(File.ReadAllText(fi.FullName));
}
}
public void UiSatellitesAdd(SatellitePositionEntity newPosition)
{
string path = Path.Combine(rootDirectory.FullName, "satellites.json");
FileInfo fi = new FileInfo(path);
List<SatellitePositionEntity> satellites;
if (!fi.Exists)
{
satellites = new List<SatellitePositionEntity>();
}
else
{
satellites = JsonConvert.DeserializeObject<List<SatellitePositionEntity>>(File.ReadAllText(fi.FullName));
}
satellites.Add(newPosition);
EnsureDirectoryExists(fi.Directory);
File.WriteAllText(fi.FullName, JsonConvert.SerializeObject(satellites, Formatting.Indented));
}
public void UiSatellitesDelete(SatellitePositionEntity satellitePosition)
{
string path = Path.Combine(rootDirectory.FullName, "satellites.json");
FileInfo fi = new FileInfo(path);
List<SatellitePositionEntity> satellites = JsonConvert.DeserializeObject<List<SatellitePositionEntity>>(File.ReadAllText(fi.FullName));
satellites.RemoveAll(x => x.Checksum == satellitePosition.Checksum);
File.WriteAllText(fi.FullName, JsonConvert.SerializeObject(satellites, Formatting.Indented));
}
public bool UiTunerTestFor(TunerMetadata tuner)
{
string fname = BitConverter.ToString(tuner.MacAddress.GetAddressBytes());
@ -935,35 +892,6 @@ namespace skyscraper5.Skyscraper.Scraper.Storage.Filesystem
File.WriteAllText(path, timeOffset.ToString());
}
public List<LnbEntity> UiLnbTypesListAll()
{
string path = Path.Combine(rootDirectory.FullName, "0-UI", "LnbTypes");
DirectoryInfo di = new DirectoryInfo(path);
if (!di.Exists)
{
return new List<LnbEntity>();
}
List<LnbEntity> result = new List<LnbEntity>();
FileInfo[] fileInfos = di.GetFiles("*.json");
foreach (FileInfo fileInfo in fileInfos)
{
string fid = Path.GetFileNameWithoutExtension(fileInfo.Name);
if (!fid.IsNaturalNumeric())
continue;
int iid = int.Parse(fid);
string json = File.ReadAllText(fileInfo.FullName);
LnbEntity deserializeObject = JsonConvert.DeserializeObject<LnbEntity>(json);
if (deserializeObject.Id != iid)
continue;
if (result.Contains(deserializeObject))
continue;
result.Add(deserializeObject);
}
return result;
}
private int GetNextJsonFileNumber(DirectoryInfo di)
{
@ -988,61 +916,6 @@ namespace skyscraper5.Skyscraper.Scraper.Storage.Filesystem
return result;
}
public void UiLnbTypesAdd(LnbEntity defaultLnbType)
{
string path = Path.Combine(rootDirectory.FullName, "0-UI", "LnbTypes");
DirectoryInfo di = new DirectoryInfo(path);
int fileId = GetNextJsonFileNumber(di);
defaultLnbType.Id = fileId;
defaultLnbType.DateAdded = DateTime.Now;
path = Path.Combine(rootDirectory.FullName, "0-UI", "LnbTypes", fileId.ToString() + ".json");
string json = JsonConvert.SerializeObject(defaultLnbType, jsonSerializerSettings);
File.WriteAllText(path, json);
}
public List<DishEntity> UiDishTypesListAll()
{
string path = Path.Combine(rootDirectory.FullName, "0-UI", "DishTypes");
DirectoryInfo di = new DirectoryInfo(path);
if (!di.Exists)
{
return new List<DishEntity>();
}
List<DishEntity> result = new List<DishEntity>();
FileInfo[] fileInfos = di.GetFiles("*.json");
foreach (FileInfo fileInfo in fileInfos)
{
string fid = Path.GetFileNameWithoutExtension(fileInfo.Name);
if (!fid.IsNaturalNumeric())
continue;
int iid = int.Parse(fid);
string json = File.ReadAllText(fileInfo.FullName);
DishEntity deserializeObject = JsonConvert.DeserializeObject<DishEntity>(json);
if (deserializeObject.Id != iid)
continue;
if (result.Contains(deserializeObject))
continue;
result.Add(deserializeObject);
}
return result;
}
public void UiDishTypesAdd(DishEntity defaultDishType)
{
string path = Path.Combine(rootDirectory.FullName, "0-UI", "DishTypes");
DirectoryInfo di = new DirectoryInfo(path);
int fileId = GetNextJsonFileNumber(di);
defaultDishType.Id = fileId;
defaultDishType.DateAdded = DateTime.Now;
path = Path.Combine(rootDirectory.FullName, "0-UI", "DishTypes", fileId.ToString() + ".json");
string json = JsonConvert.SerializeObject(defaultDishType, jsonSerializerSettings);
File.WriteAllText(path, json);
}
public object[] GetPluginConnector()
{
@ -1243,7 +1116,7 @@ namespace skyscraper5.Skyscraper.Scraper.Storage.Filesystem
{
if (jobInDb.DateAdded == DateTime.MinValue)
jobInDb.DateAdded = DateTime.Now;
string path = Path.Combine(rootDirectory.FullName, "0-Blindscan",jobInDb.SatPosition.Checksum.ToString(), jobInDb.JobGuid.ToString(), "index.json");
string path = Path.Combine(rootDirectory.FullName, "0-Blindscan",jobInDb.GetFiveLetterOrbitalPosition(), jobInDb.JobGuid.ToString(), "index.json");
FileInfo fi = new FileInfo(path);
EnsureDirectoryExists(fi.Directory);
@ -1260,7 +1133,7 @@ namespace skyscraper5.Skyscraper.Scraper.Storage.Filesystem
SearchResult2 searchResult2)
{
string freq = satellite ? String.Format("{0}_{1}", searchResult.Freq, searchResult.Pol) : String.Format("{0}", searchResult2);
string path = Path.Combine(rootDirectory.FullName, "0-Blindscan", jobInDb.SatPosition.Checksum.ToString(), jobInDb.JobGuid.ToString(), freq + ".json");
string path = Path.Combine(rootDirectory.FullName, "0-Blindscan", jobInDb.GetFiveLetterOrbitalPosition(), jobInDb.JobGuid.ToString(), freq + ".json");
string json = JsonConvert.SerializeObject(satellite ? searchResult : searchResult2, jsonSerializerSettings);
File.WriteAllText(path, json);
}
@ -1276,7 +1149,7 @@ namespace skyscraper5.Skyscraper.Scraper.Storage.Filesystem
{
string freq = resultSatellite ? String.Format("{0}_{1}", resultSr1.Freq, resultSr1.Pol) : String.Format("{0}", resultSr2);
string jsonName = String.Format("{0}.json", humanReadableService.ServiceId);
string path = Path.Combine(rootDirectory.FullName, "0-Blindscan", jobInDb.SatPosition.Checksum.ToString(), jobInDb.JobGuid.ToString(), freq, jsonName);
string path = Path.Combine(rootDirectory.FullName, "0-Blindscan", jobInDb.GetFiveLetterOrbitalPosition(), jobInDb.JobGuid.ToString(), freq, jsonName);
FileInfo fi = new FileInfo(path);
EnsureDirectoryExists(fi.Directory);
string json = JsonConvert.SerializeObject(humanReadableService, jsonSerializerSettings);

56
skyscraper8/Skyscraper/Scraper/Storage/InMemory/InMemoryScraperStorage.cs
View File

@ -12,7 +12,6 @@ using skyscraper5.Mpeg2.Descriptors;
using skyscraper5.Mpeg2.Psi.Model;
using skyscraper5.Rds.Messages;
using skyscraper5.Scte35;
using skyscraper5.Skyscraper.Equipment;
using skyscraper5.Skyscraper.Gps;
using skyscraper5.Skyscraper.Headless;
using skyscraper5.Skyscraper.IO;
@ -771,27 +770,6 @@ namespace skyscraper5.Skyscraper.Scraper.Storage.InMemory
throw new NotImplementedException();
}
private List<SatellitePositionEntity> satellitePositions;
public List<SatellitePositionEntity> UiSatellitesListAll()
{
if (satellitePositions == null)
satellitePositions = new List<SatellitePositionEntity>();
return satellitePositions.ToList();
}
public void UiSatellitesAdd(SatellitePositionEntity newPosition)
{
if (satellitePositions == null)
satellitePositions = new List<SatellitePositionEntity>();
satellitePositions.Add(newPosition);
}
public void UiSatellitesDelete(SatellitePositionEntity satellitePosition)
{
satellitePositions.RemoveAll(x => x.Checksum == satellitePosition.Checksum);
}
private List<TunerMetadata> uiTuners;
public bool UiTunerTestFor(TunerMetadata tuner)
@ -905,40 +883,6 @@ namespace skyscraper5.Skyscraper.Scraper.Storage.InMemory
t2miTransmitters[t2miTransmitterId].TimeOffset = timeOffset;
}
private List<LnbEntity> _lnbTypes;
public List<LnbEntity> UiLnbTypesListAll()
{
if (_lnbTypes == null)
_lnbTypes = new List<LnbEntity>();
return _lnbTypes;
}
public void UiLnbTypesAdd(LnbEntity defaultLnbType)
{
if (_lnbTypes == null)
_lnbTypes = new List<LnbEntity>();
if (!_lnbTypes.Contains(defaultLnbType))
_lnbTypes.Add(defaultLnbType);
}
private List<DishEntity> _dishTypes;
public List<DishEntity> UiDishTypesListAll()
{
if (_dishTypes == null)
_dishTypes = new List<DishEntity>();
return _dishTypes;
}
public void UiDishTypesAdd(DishEntity defaultDishType)
{
if (_dishTypes == null)
_dishTypes = new List<DishEntity>();
if (!_dishTypes.Contains(defaultDishType))
_dishTypes.Add(defaultDishType);
}
public object[] GetPluginConnector()
{

112
skyscraper8/Skyscraper/TsRotationToCsv.cs Normal file
View File

@ -0,0 +1,112 @@
using log4net;
using log4net.Repository.Hierarchy;
using skyscraper5.Docsis.MacManagement;
using skyscraper5.Skyscraper;
using System;
using System.Collections.Generic;
using System.Linq;
using System.Text;
using System.Threading.Tasks;
namespace skyscraper8.Skyscraper
{
internal class TsRotationToCsv
{
public DirectoryInfo SourceDir { get; set; }
public FileInfo DestinationCsv { get; set; }
private List<FileInfo> files;
private ILog logger;
public void Run()
{
logger = LogManager.GetLogger(typeof(TsRotationToCsv));
files = new List<FileInfo>();
ScrapeDirectory(SourceDir);
files.Sort(new FileInfoComparerByDate(logger));
DumpCsv();
}
private void DumpCsv()
{
StreamWriter sw = new StreamWriter(DestinationCsv.FullName);
foreach (FileInfo file in files)
{
sw.WriteLine(String.Format("\"{0}\";{1};{2}", file.FullName, file.Length, file.LastWriteTime));
}
sw.Flush();
sw.Close();
}
private void ScrapeDirectory(DirectoryInfo di)
{
try
{
foreach (FileSystemInfo fsi in di.GetFileSystemInfos())
{
switch (fsi)
{
case FileInfo fi:
if (fi.Extension.ToLowerInvariant().Equals(".ts"))
{
files.Add(fi);
if (files.Count % 100 == 0)
logger.InfoFormat("Listed {0} files.", files.Count);
}
break;
case DirectoryInfo subdirectory:
ScrapeDirectory(subdirectory);
break;
default:
throw new NotImplementedException(di.GetType().Name);
}
}
}
catch (Exception e)
{
logger.WarnFormat(e.Message);
}
}
private class FileInfoComparerByDate : Comparer<FileInfo>
{
private ILog logger;
private int ups, downs, stands;
public FileInfoComparerByDate(ILog logger)
{
this.logger = logger;
}
public override int Compare(FileInfo? x, FileInfo? y)
{
long xTime = x.LastWriteTime.ToUnixTime();
long yTime = y.LastWriteTime.ToUnixTime();
int ops;
int v = xTime.CompareTo(yTime);
switch(v)
{
case -1:
ups++;
ops = ups;
break;
case 0:
stands++;
ops = stands;
break;
case 1:
downs++;
ops = downs;
break;
default:
throw new NotImplementedException(v.ToString());
}
if (ops % 1000 == 0)
{
logger.InfoFormat("Sort progress: {0} up, {1} down, {2} stand.", ups, downs, stands);
}
return v;
}
}
}
}