-
Notifications
You must be signed in to change notification settings - Fork 240
Commit
This commit does not belong to any branch on this repository, and may belong to a fork outside of the repository.
#1014 Adds AMBE voice frame recording support.
- Loading branch information
Dennis Sheirer
committed
Nov 21, 2021
1 parent
6a54fe1
commit 31b9ee5
Showing
4 changed files
with
270 additions
and
35 deletions.
There are no files selected for viewing
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
214 changes: 214 additions & 0 deletions
214
src/main/java/io/github/dsheirer/module/decode/dmr/audio/DMRCallSequenceRecorder.java
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| Original file line number | Diff line number | Diff line change |
|---|---|---|
| @@ -0,0 +1,214 @@ | ||
| /* | ||
| * ***************************************************************************** | ||
| * Copyright (C) 2014-2021 Dennis Sheirer | ||
| * | ||
| * This program is free software: you can redistribute it and/or modify | ||
| * it under the terms of the GNU General Public License as published by | ||
| * the Free Software Foundation, either version 3 of the License, or | ||
| * (at your option) any later version. | ||
| * | ||
| * This program is distributed in the hope that it will be useful, | ||
| * but WITHOUT ANY WARRANTY; without even the implied warranty of | ||
| * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the | ||
| * GNU General Public License for more details. | ||
| * | ||
| * You should have received a copy of the GNU General Public License | ||
| * along with this program. If not, see <http://www.gnu.org/licenses/> | ||
| * **************************************************************************** | ||
| */ | ||
|
|
||
| package io.github.dsheirer.module.decode.dmr.audio; | ||
|
|
||
|
|
||
| import io.github.dsheirer.audio.codec.mbe.MBECallSequence; | ||
| import io.github.dsheirer.audio.codec.mbe.MBECallSequenceRecorder; | ||
| import io.github.dsheirer.bits.BinaryMessage; | ||
| import io.github.dsheirer.message.IMessage; | ||
| import io.github.dsheirer.module.decode.dmr.message.DMRMessage; | ||
| import io.github.dsheirer.module.decode.dmr.message.data.lc.LCMessage; | ||
| import io.github.dsheirer.module.decode.dmr.message.data.lc.full.FullLCMessage; | ||
| import io.github.dsheirer.module.decode.dmr.message.data.lc.full.GroupVoiceChannelUser; | ||
| import io.github.dsheirer.module.decode.dmr.message.data.lc.full.UnitToUnitVoiceChannelUser; | ||
| import io.github.dsheirer.module.decode.dmr.message.data.lc.full.hytera.HyteraGroupVoiceChannelUser; | ||
| import io.github.dsheirer.module.decode.dmr.message.data.lc.full.hytera.HyteraUnitToUnitVoiceChannelUser; | ||
| import io.github.dsheirer.module.decode.dmr.message.data.lc.full.motorola.CapacityPlusGroupVoiceChannelUser; | ||
| import io.github.dsheirer.module.decode.dmr.message.data.lc.full.motorola.CapacityPlusWideAreaVoiceChannelUser; | ||
| import io.github.dsheirer.module.decode.dmr.message.data.terminator.Terminator; | ||
| import io.github.dsheirer.module.decode.dmr.message.voice.VoiceMessage; | ||
| import io.github.dsheirer.preference.UserPreferences; | ||
| import org.slf4j.Logger; | ||
| import org.slf4j.LoggerFactory; | ||
|
|
||
| import java.util.List; | ||
|
|
||
| /** | ||
| * DMR AMBE Frame recorder generates call sequence recordings containing JSON representations of audio | ||
| * frames, optional encryption and call identifiers. | ||
| */ | ||
| public class DMRCallSequenceRecorder extends MBECallSequenceRecorder | ||
| { | ||
| private final static Logger mLog = LoggerFactory.getLogger(DMRCallSequenceRecorder.class); | ||
|
|
||
| private static final String PROTOCOL = "DMR"; | ||
|
|
||
| private MBECallSequence mCallSequence; | ||
|
|
||
| /** | ||
| * Constructs a DMR MBE call sequence recorder. | ||
| * | ||
| * @param userPreferences to obtain the recording directory | ||
| * @param channelFrequency for the channel to record | ||
| * @param system defined by the user | ||
| * @param site defined by the user | ||
| */ | ||
| public DMRCallSequenceRecorder(UserPreferences userPreferences, long channelFrequency, String system, String site) | ||
| { | ||
| super(userPreferences, channelFrequency, system, site); | ||
| } | ||
|
|
||
| /** | ||
| * Stops and flushes any partial frame sequence from the processors | ||
| */ | ||
| @Override | ||
| public void stop() | ||
| { | ||
| flush(); | ||
| } | ||
|
|
||
| /** | ||
| * Primary message interface for receiving frames and metadata messages to record | ||
| */ | ||
| @Override | ||
| public void receive(IMessage message) | ||
| { | ||
| if(message instanceof DMRMessage dmr) | ||
| { | ||
| if(dmr.isValid()) | ||
| { | ||
| process(dmr); | ||
| } | ||
| } | ||
| } | ||
|
|
||
|
|
||
| /** | ||
| * Flushes any partial call sequence | ||
| */ | ||
| public void flush() | ||
| { | ||
| if(mCallSequence != null) | ||
| { | ||
| writeCallSequence(mCallSequence); | ||
| mCallSequence = null; | ||
| } | ||
| } | ||
|
|
||
| /** | ||
| * Processes any DMR audio and terminator messages | ||
| */ | ||
| public void process(DMRMessage message) | ||
| { | ||
| if(message instanceof VoiceMessage voiceMessage) | ||
| { | ||
| process(voiceMessage); | ||
| } | ||
| else if(message instanceof FullLCMessage fullLCMessage) | ||
| { | ||
| process(fullLCMessage); | ||
| } | ||
| else if(message instanceof Terminator) | ||
| { | ||
| flush(); | ||
| } | ||
| } | ||
|
|
||
| /** | ||
| * Processes Voice messages | ||
| */ | ||
| private void process(VoiceMessage voiceMessage) | ||
| { | ||
| if(mCallSequence == null) | ||
| { | ||
| mCallSequence = new MBECallSequence(PROTOCOL); | ||
| } | ||
|
|
||
| List<byte[]> voiceFrames = voiceMessage.getAMBEFrames(); | ||
|
|
||
| long baseTimestamp = voiceMessage.getTimestamp(); | ||
|
|
||
| for(byte[] frame : voiceFrames) | ||
| { | ||
| BinaryMessage frameBits = BinaryMessage.from(frame); | ||
| mCallSequence.addVoiceFrame(baseTimestamp, frameBits.toHexString()); | ||
|
|
||
| //Voice frames are 20 milliseconds each, so we increment the timestamp by 20 for each one | ||
| baseTimestamp += 20; | ||
| } | ||
| } | ||
|
|
||
| /** | ||
| * Process full link control messages to extract call details | ||
| */ | ||
| private void process(FullLCMessage message) | ||
| { | ||
| if(message.isValid() && mCallSequence != null) | ||
| { | ||
| switch(message.getOpcode()) | ||
| { | ||
| case FULL_CAPACITY_PLUS_GROUP_VOICE_CHANNEL_USER: | ||
| if(message instanceof CapacityPlusGroupVoiceChannelUser cpvcu) | ||
| { | ||
| mCallSequence.setFromIdentifier(cpvcu.getRadio()); | ||
| mCallSequence.setToIdentifier(cpvcu.getTalkgroup()); | ||
| mCallSequence.setEncrypted(cpvcu.getServiceOptions().isEncrypted()); | ||
| mCallSequence.setCallType(CALL_TYPE_GROUP); | ||
| } | ||
| break; | ||
| case FULL_CAPACITY_PLUS_WIDE_AREA_VOICE_CHANNEL_USER: | ||
| if(message instanceof CapacityPlusWideAreaVoiceChannelUser cpwavcu) | ||
| { | ||
| mCallSequence.setToIdentifier(cpwavcu.getTalkgroup()); | ||
| mCallSequence.setEncrypted(cpwavcu.getServiceOptions().isEncrypted()); | ||
| mCallSequence.setCallType(CALL_TYPE_GROUP); | ||
| } | ||
| break; | ||
| case FULL_HYTERA_GROUP_VOICE_CHANNEL_USER: | ||
| if(message instanceof HyteraGroupVoiceChannelUser hgvcu) | ||
| { | ||
| mCallSequence.setToIdentifier(hgvcu.getTalkgroup()); | ||
| mCallSequence.setFromIdentifier(hgvcu.getSourceRadio()); | ||
| mCallSequence.setCallType(CALL_TYPE_GROUP); | ||
| mCallSequence.setEncrypted(hgvcu.isEncrypted()); | ||
| } | ||
| break; | ||
| case FULL_HYTERA_UNIT_TO_UNIT_VOICE_CHANNEL_USER: | ||
| if(message instanceof HyteraUnitToUnitVoiceChannelUser huuvcu) | ||
| { | ||
| mCallSequence.setToIdentifier(huuvcu.getTargetRadio()); | ||
| mCallSequence.setFromIdentifier(huuvcu.getSourceRadio()); | ||
| mCallSequence.setCallType(CALL_TYPE_INDIVIDUAL); | ||
| mCallSequence.setEncrypted(huuvcu.isEncrypted()); | ||
| } | ||
| break; | ||
| case FULL_STANDARD_GROUP_VOICE_CHANNEL_USER: | ||
| if(message instanceof GroupVoiceChannelUser gvcu) | ||
| { | ||
| mCallSequence.setFromIdentifier(gvcu.getRadio()); | ||
| mCallSequence.setToIdentifier(gvcu.getTalkgroup()); | ||
| mCallSequence.setCallType(CALL_TYPE_GROUP); | ||
| mCallSequence.setEncrypted(gvcu.getServiceOptions().isEncrypted()); | ||
| } | ||
| break; | ||
| case FULL_STANDARD_UNIT_TO_UNIT_VOICE_CHANNEL_USER: | ||
| if(message instanceof UnitToUnitVoiceChannelUser uuvcu) | ||
| { | ||
| mCallSequence.setFromIdentifier(uuvcu.getSourceRadio()); | ||
| mCallSequence.setToIdentifier(uuvcu.getTargetRadio()); | ||
| mCallSequence.setCallType(CALL_TYPE_INDIVIDUAL); | ||
| mCallSequence.setEncrypted(uuvcu.getServiceOptions().isEncrypted()); | ||
| } | ||
| break; | ||
| } | ||
| } | ||
| } | ||
| } |