Skip to content
New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

Sign up for GitHub

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

PlaybackStreamReader sample #102

Open
wants to merge 2 commits into
base: main
Choose a base branch
from
Open

PlaybackStreamReader sample #102

Changes from all commits
Commits
Show all changes
2 commits
Select commit Hold shift + click to select a range
d6bbede
Add cancellation support and improve stream handling
alafleur-genetec Jan 4, 2025
d3f61cd
Refactor code for readability and functionality
alafleur-genetec Jan 5, 2025
File filter

Filter by extension

Filter by extension
Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
140 changes: 82 additions & 58 deletions Samples/Media SDK/PlaybackStreamReaderSample/Program.cs
View file
Open in desktop
Original file line number Diff line number Diff line change
@@ -1,5 +1,6 @@
using System;
using System.Linq;
using System.Threading;
using System.Threading.Tasks;
using Genetec.Dap.CodeSamples;
using Genetec.Sdk;
Expand All @@ -10,103 +11,126 @@

await RunSample();

Console.Write("Press any key to exit...");
Console.ReadKey(true);

async Task RunSample()
{
const string server = "localhost";
const string username = "admin";
const string password = "";
const string cameraGuid = "your-camera-guid-here"; // Replace with your camera's GUID
const string server = "localhost"; // Specify the IP address or hostname of your Security Center server.
const string username = "admin"; // Enter the username for Security Center authentication.
const string password = ""; // Provide the corresponding password for the specified username.
const string cameraGuid = ""; // Enter the GUID of the camera to access its stream.

using var engine = new Engine();
engine.LogonStatusChanged += (_, args) => Console.Write($"\rConnection status: {args.Status}".PadRight(Console.WindowWidth));
engine.LogonFailed += (_, args) => Console.WriteLine($"\rError: {args.FormattedErrorMessage}".PadRight(Console.WindowWidth));
engine.LoggedOn += (_, args) => Console.WriteLine($"\rConnected to {args.ServerName}".PadRight(Console.WindowWidth));

ConnectionStateCode state = await engine.LogOnAsync(server, username, password);

if (state == ConnectionStateCode.Success)
if (state != ConnectionStateCode.Success)
{
if (engine.GetEntity(new Guid(cameraGuid)) is not Camera camera)
{
Console.WriteLine($"Camera {cameraGuid} not found");
return;
}
return;
}

if (engine.GetEntity(new Guid(cameraGuid)) is not Camera camera)
{
Console.WriteLine($"Camera {cameraGuid} not found");
return;
}

using var cancellationTokenSource = new CancellationTokenSource();

Console.CancelKeyPress += (_, e) =>
{
Console.WriteLine("\nCancelling...");
e.Cancel = true;
cancellationTokenSource.Cancel();
};

try
{
await ReadVideoStream(cancellationTokenSource.Token);
await ReadAudioStream(cancellationTokenSource.Token);
await ReadMetadataStream(cancellationTokenSource.Token);
}
catch (OperationCanceledException)
{
Console.WriteLine("Read cancelled");
}

Console.WriteLine("\nReading video stream:");
await using var videoReader = PlaybackStreamReader.CreateVideoReader(engine, camera.Guid);
await ReadStream(videoReader);
async Task ReadVideoStream(CancellationToken cancellationToken)
{
Console.WriteLine($"\nReading video stream from camera: {camera.Name}");
await using var reader = PlaybackStreamReader.CreateVideoReader(engine, camera.Guid);
await ReadStream(reader, cancellationToken);
}

Console.WriteLine("\nReading audio stream:");
await using var audioReader = PlaybackStreamReader.CreateAudioReader(engine, camera.Guid);
await ReadStream(audioReader);
async Task ReadAudioStream(CancellationToken cancellationToken)
{
Console.WriteLine($"\nReading audio stream from camera: {camera.Name}");
await using var reader = PlaybackStreamReader.CreateAudioReader(engine, camera.Guid);
await ReadStream(reader, cancellationToken);
}

// Get the metadata stream. In this example, we are only reading the first metadata stream
async Task ReadMetadataStream(CancellationToken cancellationToken)
{
MetadataStreamInfo metadataStreamInfo = camera.MetadataStreams.FirstOrDefault();
Console.WriteLine($"\nReading metadata stream from camera: {camera.Name}");
if (metadataStreamInfo is not null)
{
Console.WriteLine("\nReading metadata stream:");
await using var metadataReader = PlaybackStreamReader.CreateReader(engine, camera.Guid, metadataStreamInfo.StreamId);
await ReadStream(metadataReader);
await using var reader = PlaybackStreamReader.CreateReader(engine, camera.Guid, metadataStreamInfo.StreamId);
await ReadStream(reader, cancellationToken);
}
else
{
Console.WriteLine("\nNo metadata stream available");
Console.WriteLine("No metadata stream available");
}
}
else
{
Console.WriteLine($"logon failed: {state}");
}

Console.WriteLine("Press any key to exit...");
Console.ReadKey();

// Method to open and read from a stream
async Task ReadStream(PlaybackStreamReader reader)
async Task ReadStream(PlaybackStreamReader reader, CancellationToken cancellationToken)
{
// Connect to the stream
await reader.ConnectAsync();
await reader.ConnectAsync(cancellationToken);
await reader.SeekAsync(DateTime.UtcNow.AddMinutes(-5), cancellationToken);

// Seek to one minute ago
await reader.SeekAsync(DateTime.UtcNow.AddMinutes(-1));
var (frames, bytes, start) = (0, 0L, DateTime.Now);

while (true)
{
// Read data from the stream
RawDataContent content = await reader.ReadAsync();
if (content is null)
RawDataContent rawDataContent = await reader.ReadAsync(cancellationToken);
if (rawDataContent is null)
{
// if the content is null, it means we have reached the end of the stream
Console.WriteLine(" End of stream reached");
Console.Write("\rEnd of stream reached".PadRight(Console.WindowWidth));
break;
}

using (content)
using (rawDataContent)
{
// Get the MediaType name
string mediaTypeName = GetMediaTypeName(content.MediaType);

// Output frame information
Console.WriteLine($"Frame time {content.FrameTime}, Format: {content.Format}, MediaType: {mediaTypeName}, Data size: {content.Data.Count}");
frames++;
bytes += rawDataContent.Data.Count;
Console.Write($"\r{rawDataContent.FrameTime:HH:mm:ss.fff} | {GetMediaTypeName(rawDataContent.MediaType),-12} | {rawDataContent.Format,8} | Size: {rawDataContent.Data.Count,6:N0} B | Avg: {bytes / frames,6:N0} B | FPS: {frames / (DateTime.Now - start).TotalSeconds,5:N1}".PadRight(Console.WindowWidth));
}
}
}

string GetMediaTypeName(Guid mediaTypeGuid)
{
if (mediaTypeGuid == MediaTypes.Video) return "Video";
if (mediaTypeGuid == MediaTypes.AudioIn) return "AudioIn";
if (mediaTypeGuid == MediaTypes.AudioOut) return "AudioOut";
if (mediaTypeGuid == MediaTypes.AudioIn) return "Audio In";
if (mediaTypeGuid == MediaTypes.AudioOut) return "Audio Out";
if (mediaTypeGuid == MediaTypes.Metadata) return "Metadata";
if (mediaTypeGuid == MediaTypes.Ptz) return "Ptz";
if (mediaTypeGuid == MediaTypes.AgentPtz) return "AgentPtz";
if (mediaTypeGuid == MediaTypes.OverlayUpdate) return "OverlayUpdate";
if (mediaTypeGuid == MediaTypes.OverlayStream) return "OverlayStream";
if (mediaTypeGuid == MediaTypes.EncryptionKey) return "EncryptionKey";
if (mediaTypeGuid == MediaTypes.CollectionEvents) return "CollectionEvents";
if (mediaTypeGuid == MediaTypes.ArchiverEvents) return "ArchiverEvents";
if (mediaTypeGuid == MediaTypes.OnvifAnalyticsStream) return "OnvifAnalyticsStream";
if (mediaTypeGuid == MediaTypes.BoschVcaStream) return "BoschVcaStream";
if (mediaTypeGuid == MediaTypes.FusionStream) return "FusionStream";
if (mediaTypeGuid == MediaTypes.FusionStreamEvents) return "FusionStreamEvents";
if (mediaTypeGuid == MediaTypes.OriginalVideo) return "OriginalVideo";
if (mediaTypeGuid == MediaTypes.AgentPtz) return "Agent Ptz";
if (mediaTypeGuid == MediaTypes.OverlayUpdate) return "Overlay Update";
if (mediaTypeGuid == MediaTypes.OverlayStream) return "Overlay Stream";
if (mediaTypeGuid == MediaTypes.EncryptionKey) return "Encryption Key";
if (mediaTypeGuid == MediaTypes.CollectionEvents) return "Collection Events";
if (mediaTypeGuid == MediaTypes.ArchiverEvents) return "Archiver Events";
if (mediaTypeGuid == MediaTypes.OnvifAnalyticsStream) return "Onvif Analytics Stream";
if (mediaTypeGuid == MediaTypes.BoschVcaStream) return "Bosch Vca Stream";
if (mediaTypeGuid == MediaTypes.FusionStream) return "Fusion Stream";
if (mediaTypeGuid == MediaTypes.FusionStreamEvents) return "Fusion Stream Events";
if (mediaTypeGuid == MediaTypes.OriginalVideo) return "Original Video";
if (mediaTypeGuid == MediaTypes.Block) return "Block";
return "Unknown";
}
Expand Down