Digital_Voice_Modem_Project
/
dvmconsole
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

Add multi channel PTT; add channel marker; other small fixes

Browse Source
pull/1/head
firealarmss 11 months ago
parent 209aadd0db
commit d5c4ee07fc
3 changed files with 185 additions and 76 deletions
Show Stats Download Patch File Download Diff File

2
WhackerLinkConsoleV2/ChannelBox.xaml.cs
Unescape View File

@ -54,6 +54,8 @@ namespace WhackerLinkConsoleV2.Controls
public string SystemName { get; set; } public string SystemName { get; set; }
public string DstId { get; set; } public string DstId { get; set; }
public bool IsReceiving { get; set; } = false;
public string LastSrcId public string LastSrcId
{ {
get => _lastSrcId; get => _lastSrcId;

2
WhackerLinkConsoleV2/MainWindow.xaml
Unescape View File

@ -79,7 +79,7 @@
</Button.Background> </Button.Background>
</Button> </Button>
<Image HorizontalAlignment="Left" Margin="353,3,0,3" Grid.Row="1" Width="37" Source="/alerttone.png" IsHitTestVisible="False"/> <Image HorizontalAlignment="Left" Margin="353,3,0,3" Grid.Row="1" Width="37" Source="/alerttone.png" IsHitTestVisible="False"/>
<Button VerticalContentAlignment="Bottom" HorizontalAlignment="Left" Margin="170,0,0,0" VerticalAlignment="Center" Height="46" Width="82" Click="Button_Click" BorderBrush="#FFC1C1C1" BorderThickness="1,1,1,1" Grid.Row="1" FontSize="10" FontFamily="Arial"> <Button VerticalContentAlignment="Bottom" HorizontalAlignment="Left" Margin="170,0,0,0" x:Name="btnGlobalPtt" VerticalAlignment="Center" Height="46" Width="82" Click="btnGlobalPtt_Click" BorderBrush="#FFC1C1C1" BorderThickness="1,1,1,1" Grid.Row="1" FontSize="10" FontFamily="Arial">
<Button.Resources> <Button.Resources>
<Style TargetType="{x:Type Border}"> <Style TargetType="{x:Type Border}">
<Setter Property="CornerRadius" Value="2"/> <Setter Property="CornerRadius" Value="2"/>

257
WhackerLinkConsoleV2/MainWindow.xaml.cs
Unescape View File

@ -21,6 +21,7 @@
using Microsoft.Win32; using Microsoft.Win32;
using System; using System;
using System.Timers;
using System.IO; using System.IO;
using System.Windows; using System.Windows;
using System.Windows.Controls; using System.Windows.Controls;
@ -41,6 +42,8 @@ using Nancy;
using Microsoft.AspNetCore.Mvc.ModelBinding.Binders; using Microsoft.AspNetCore.Mvc.ModelBinding.Binders;
using static System.Windows.Forms.VisualStyles.VisualStyleElement.ProgressBar; using static System.Windows.Forms.VisualStyles.VisualStyleElement.ProgressBar;
using System.Media; using System.Media;
using System.Threading.Tasks;
using static WhackerLinkLib.Models.Radio.Codeplug;
namespace WhackerLinkConsoleV2 namespace WhackerLinkConsoleV2
{ {
@ -49,6 +52,8 @@ namespace WhackerLinkConsoleV2
public Codeplug Codeplug { get; set; } public Codeplug Codeplug { get; set; }
private bool isEditMode = false; private bool isEditMode = false;
private bool globalPttState = false;
private UIElement _draggedElement; private UIElement _draggedElement;
private Point _startPoint; private Point _startPoint;
private double _offsetX; private double _offsetX;
@ -64,6 +69,8 @@ namespace WhackerLinkConsoleV2
private readonly WaveInEvent _waveIn; private readonly WaveInEvent _waveIn;
private readonly AudioManager _audioManager; private readonly AudioManager _audioManager;
private static System.Timers.Timer _channelHoldTimer;
public MainWindow() public MainWindow()
{ {
#if DEBUG #if DEBUG
@ -75,6 +82,11 @@ namespace WhackerLinkConsoleV2
_flashingManager = new FlashingBackgroundManager(null, ChannelsCanvas, null, this); _flashingManager = new FlashingBackgroundManager(null, ChannelsCanvas, null, this);
_emergencyAlertPlayback = new WaveFilePlaybackManager(System.IO.Path.Combine(AppDomain.CurrentDomain.BaseDirectory, "emergency.wav")); _emergencyAlertPlayback = new WaveFilePlaybackManager(System.IO.Path.Combine(AppDomain.CurrentDomain.BaseDirectory, "emergency.wav"));
_channelHoldTimer = new System.Timers.Timer(10000);
_channelHoldTimer.Elapsed += OnHoldTimerElapsed;
_channelHoldTimer.AutoReset = true;
_channelHoldTimer.Enabled = true;
_waveIn = new WaveInEvent _waveIn = new WaveInEvent
{ {
WaveFormat = new WaveFormat(8000, 16, 1) WaveFormat = new WaveFormat(8000, 16, 1)
@ -488,13 +500,11 @@ namespace WhackerLinkConsoleV2
private void SendAlertTone(AlertTone e) private void SendAlertTone(AlertTone e)
{ {
Task.Run(() => SendAlertTone(e.AlertFilePath)); Task.Factory.StartNew(() => SendAlertTone(e.AlertFilePath));
} }
private async void SendAlertTone(string filePath) private void SendAlertTone(string filePath, bool forHold = false)
{ {
Console.WriteLine(filePath);
Console.WriteLine(File.Exists(filePath));
if (!string.IsNullOrEmpty(filePath) && File.Exists(filePath)) if (!string.IsNullOrEmpty(filePath) && File.Exists(filePath))
{ {
try try
@ -505,92 +515,98 @@ namespace WhackerLinkConsoleV2
Codeplug.Channel cpgChannel = Codeplug.GetChannelByName(channel.ChannelName); Codeplug.Channel cpgChannel = Codeplug.GetChannelByName(channel.ChannelName);
IPeer handler = _webSocketManager.GetWebSocketHandler(system.Name); IPeer handler = _webSocketManager.GetWebSocketHandler(system.Name);
if (channel.PageState) if (channel.PageState || (forHold && channel.HoldState))
{ {
byte[] pcmData; byte[] pcmData;
using (var waveReader = new WaveFileReader(filePath)) Task.Factory.StartNew(async () => {
{ using (var waveReader = new WaveFileReader(filePath))
if (waveReader.WaveFormat.Encoding != WaveFormatEncoding.Pcm ||
waveReader.WaveFormat.SampleRate != 8000 ||
waveReader.WaveFormat.BitsPerSample != 16 ||
waveReader.WaveFormat.Channels != 1)
{ {
MessageBox.Show("The alert tone must be PCM 16-bit, Mono, 8000Hz format.", "Error", MessageBoxButton.OK, MessageBoxImage.Error); if (waveReader.WaveFormat.Encoding != WaveFormatEncoding.Pcm ||
return; waveReader.WaveFormat.SampleRate != 8000 ||
waveReader.WaveFormat.BitsPerSample != 16 ||
waveReader.WaveFormat.Channels != 1)
{
MessageBox.Show("The alert tone must be PCM 16-bit, Mono, 8000Hz format.", "Error", MessageBoxButton.OK, MessageBoxImage.Error);
return;
}
using (MemoryStream ms = new MemoryStream())
{
waveReader.CopyTo(ms);
pcmData = ms.ToArray();
}
} }
using (MemoryStream ms = new MemoryStream()) int chunkSize = 1600;
int totalChunks = (pcmData.Length + chunkSize - 1) / chunkSize;
if (pcmData.Length % chunkSize != 0)
{ {
waveReader.CopyTo(ms); byte[] paddedData = new byte[totalChunks * chunkSize];
pcmData = ms.ToArray(); Buffer.BlockCopy(pcmData, 0, paddedData, 0, pcmData.Length);
pcmData = paddedData;
} }
}
int chunkSize = 1600; Task.Factory.StartNew(() =>
int totalChunks = (pcmData.Length + chunkSize - 1) / chunkSize; {
_audioManager.AddTalkgroupStream(cpgChannel.Tgid, pcmData);
});
if (pcmData.Length % chunkSize != 0) DateTime startTime = DateTime.UtcNow;
{
byte[] paddedData = new byte[totalChunks * chunkSize];
Buffer.BlockCopy(pcmData, 0, paddedData, 0, pcmData.Length);
pcmData = paddedData;
}
Task.Factory.StartNew(() => for (int i = 0; i < totalChunks; i++)
{ {
_audioManager.AddTalkgroupStream(cpgChannel.Tgid, pcmData); int offset = i * chunkSize;
}); byte[] chunk = new byte[chunkSize];
Buffer.BlockCopy(pcmData, offset, chunk, 0, chunkSize);
DateTime startTime = DateTime.UtcNow; AudioPacket voicePacket = new AudioPacket
{
Data = chunk,
VoiceChannel = new VoiceChannel
{
Frequency = channel.VoiceChannel,
DstId = cpgChannel.Tgid,
SrcId = system.Rid,
Site = system.Site
},
Site = system.Site,
LopServerVocode = true
};
handler.SendMessage(voicePacket.GetData());
DateTime nextPacketTime = startTime.AddMilliseconds((i + 1) * 100);
TimeSpan waitTime = nextPacketTime - DateTime.UtcNow;
if (waitTime.TotalMilliseconds > 0)
{
await Task.Delay(waitTime);
}
}
for (int i = 0; i < totalChunks; i++) double totalDurationMs = ((double)pcmData.Length / 16000);
{ await Task.Delay((int)totalDurationMs);
int offset = i * chunkSize;
byte[] chunk = new byte[chunkSize];
Buffer.BlockCopy(pcmData, offset, chunk, 0, chunkSize);
AudioPacket voicePacket = new AudioPacket GRP_VCH_RLS release = new GRP_VCH_RLS
{ {
Data = chunk, SrcId = system.Rid,
VoiceChannel = new VoiceChannel DstId = cpgChannel.Tgid,
{ Channel = channel.VoiceChannel,
Frequency = channel.VoiceChannel, Site = system.Site
DstId = cpgChannel.Tgid,
SrcId = system.Rid,
Site = system.Site
},
Site = system.Site,
LopServerVocode = true
}; };
handler.SendMessage(voicePacket.GetData()); Dispatcher.Invoke(() =>
DateTime nextPacketTime = startTime.AddMilliseconds((i + 1) * 100);
TimeSpan waitTime = nextPacketTime - DateTime.UtcNow;
if (waitTime.TotalMilliseconds > 0)
{ {
await Task.Delay(waitTime); handler.SendMessage(release.GetData());
}
}
double totalDurationMs = ((double)pcmData.Length / 16000) * 1000 - 6000;
await Task.Delay((int)totalDurationMs);
GRP_VCH_RLS release = new GRP_VCH_RLS
{
SrcId = system.Rid,
DstId = cpgChannel.Tgid,
Channel = channel.VoiceChannel,
Site = system.Site
};
handler.SendMessage(release.GetData()); if (forHold)
channel.PttButton.Background = channel.grayGradient;
else
channel.PageState = false;
});
Dispatcher.Invoke(() =>
{
channel.PageSelectButton.Background = channel.grayGradient;
}); });
} }
} }
@ -711,9 +727,15 @@ namespace WhackerLinkConsoleV2
Dispatcher.Invoke(() => Dispatcher.Invoke(() =>
{ {
if (channel.IsSelected) if (channel.IsSelected)
channel.Background = (Brush)new BrushConverter().ConvertFrom("#FF0B004B"); {
channel.Background = (Brush)new BrushConverter().ConvertFrom("#FF0B004B");
channel.IsReceiving = false;
}
else else
{
channel.Background = new SolidColorBrush(Colors.DarkGray); channel.Background = new SolidColorBrush(Colors.DarkGray);
channel.IsReceiving = false;
}
}); });
channel.VoiceChannel = null; channel.VoiceChannel = null;
@ -738,9 +760,10 @@ namespace WhackerLinkConsoleV2
channel.LastSrcId = "Last SRC: " + response.SrcId; channel.LastSrcId = "Last SRC: " + response.SrcId;
Dispatcher.Invoke(() => Dispatcher.Invoke(() =>
{ {
channel.Background = (Brush)new BrushConverter().ConvertFrom("#FF00BC48"); channel.Background = (Brush)new BrushConverter().ConvertFrom("#FF00BC48");
channel.IsReceiving = true;
}); });
} else if (channel.PageState && response.Status == (int)ResponseType.GRANT && response.Channel != null && response.SrcId == system.Rid && response.DstId == cpgChannel.Tgid) } else if ((channel.HoldState || channel.PageState) && response.Status == (int)ResponseType.GRANT && response.Channel != null && response.SrcId == system.Rid && response.DstId == cpgChannel.Tgid)
{ {
channel.VoiceChannel = response.Channel; channel.VoiceChannel = response.Channel;
} }
@ -847,7 +870,7 @@ namespace WhackerLinkConsoleV2
element.CaptureMouse(); element.CaptureMouse();
} }
private const int GridSize = 5; // Set grid size (adjust as needed) private const int GridSize = 5;
private void ChannelBox_MouseMove(object sender, MouseEventArgs e) private void ChannelBox_MouseMove(object sender, MouseEventArgs e)
{ {
@ -876,7 +899,6 @@ namespace WhackerLinkConsoleV2
AdjustCanvasHeight(); AdjustCanvasHeight();
} }
private void ChannelBox_MouseRightButtonDown(object sender, MouseButtonEventArgs e) private void ChannelBox_MouseRightButtonDown(object sender, MouseButtonEventArgs e)
{ {
if (!isEditMode || !_isDragging || _draggedElement == null) return; if (!isEditMode || !_isDragging || _draggedElement == null) return;
@ -1009,6 +1031,39 @@ namespace WhackerLinkConsoleV2
} }
} }
private async void OnHoldTimerElapsed(object sender, ElapsedEventArgs e)
{
foreach (ChannelBox channel in _selectedChannelsManager.GetSelectedChannels())
{
Codeplug.System system = Codeplug.GetSystemForChannel(channel.ChannelName);
Codeplug.Channel cpgChannel = Codeplug.GetChannelByName(channel.ChannelName);
IPeer handler = _webSocketManager.GetWebSocketHandler(system.Name);
if (channel.HoldState && !channel.IsReceiving && !channel.PttState && !channel.PageState)
{
//Task.Factory.StartNew(async () =>
//{
Console.WriteLine("Sending channel hold beep");
Dispatcher.Invoke(() => { channel.PttButton.Background = channel.redGradient; });
GRP_VCH_REQ req = new GRP_VCH_REQ
{
SrcId = system.Rid,
DstId = cpgChannel.Tgid,
Site = system.Site
};
handler.SendMessage(req.GetData());
await Task.Delay(1000);
SendAlertTone("hold.wav", true);
// });
}
}
}
protected override void OnClosing(System.ComponentModel.CancelEventArgs e) protected override void OnClosing(System.ComponentModel.CancelEventArgs e)
{ {
_settingsManager.SaveSettings(); _settingsManager.SaveSettings();
@ -1049,6 +1104,58 @@ namespace WhackerLinkConsoleV2
}); });
} }
private void btnGlobalPtt_Click(object sender, RoutedEventArgs e)
{
globalPttState = !globalPttState;
foreach (ChannelBox channel in _selectedChannelsManager.GetSelectedChannels())
{
Codeplug.System system = Codeplug.GetSystemForChannel(channel.ChannelName);
Codeplug.Channel cpgChannel = Codeplug.GetChannelByName(channel.ChannelName);
IPeer handler = _webSocketManager.GetWebSocketHandler(system.Name);
if (!channel.IsSelected)
return;
if (globalPttState)
{
Dispatcher.Invoke(() =>
{
btnGlobalPtt.Background = channel.redGradient;
});
GRP_VCH_REQ request = new GRP_VCH_REQ
{
SrcId = system.Rid,
DstId = cpgChannel.Tgid,
Site = system.Site
};
channel.PttState = true;
handler.SendMessage(request.GetData());
} else
{
Dispatcher.Invoke(() =>
{
btnGlobalPtt.Background = channel.grayGradient;
});
GRP_VCH_RLS release = new GRP_VCH_RLS
{
SrcId = system.Rid,
DstId = cpgChannel.Tgid,
Site = system.Site
};
channel.PttState = false;
handler.SendMessage(release.GetData());
}
}
}
private void Button_Click(object sender, RoutedEventArgs e) { /* sub */ } private void Button_Click(object sender, RoutedEventArgs e) { /* sub */ }
} }
} }

Write Preview
Loading…
Cancel
Save

Powered by TurnKey Linux.