racerxdl / WaveReader.cs

using System; using System.IO; using System.Text; using RTLSharp.Audio.Structs; using System.Text.RegularExpressions; using System.Globalization; namespace RTLSharp.Audio { public class WaveReader { //private readonly static Regex SDRSharpRegex = new Regex(@"SDRSharp_([0-9]+)_([0-9]+).__([0-9]+)Hz_(.+)\.wav", RegexOptions.IgnoreCase); // SDRSharp_20160922_003831Z_137900000Hz_IQ private readonly static Regex SDRSharpRegex = new Regex(@"SDRSharp_([0-9]+)_([0-9]+)._([0-9]+)Hz_(.+)\.wav", RegexOptions.IgnoreCase); private readonly static Regex MetDemodIFRecorderRegex = new Regex(@"([0-9]+)-([0-9]+)-([0-9]+)_([0-9]+)kHz\.wav", RegexOptions.IgnoreCase); private static bool isSDRSharpFile(string fileName) { return SDRSharpRegex.IsMatch(fileName); } private static bool isMetDemodIFFile(string fileName) { return MetDemodIFRecorderRegex.IsMatch(fileName); } public static Wave readFromFile(string fileName) { if (File.Exists(fileName)) { ChunkHeader header = new ChunkHeader(); FormatChunkHeader subHeader = new FormatChunkHeader(); DataChunkHeader dataHeader = new DataChunkHeader(); Wave wave = new Wave(); string basename = Path.GetFileName(fileName); if (isSDRSharpFile(basename)) { MatchCollection matches = SDRSharpRegex.Matches(basename); GroupCollection groups = matches[0].Groups; uint.TryParse(groups[3].Value, out wave.Frequency); wave.DateTime = DateTime.ParseExact(groups[1].Value + groups[2].Value, "yyyyMMddHHmmss", CultureInfo.InvariantCulture); } else if (isMetDemodIFFile(basename)) { MatchCollection matches = MetDemodIFRecorderRegex.Matches(basename); GroupCollection groups = matches[0].Groups; uint.TryParse(groups[4].Value, out wave.Frequency); wave.Frequency *= 1000; wave.DateTime = DateTime.ParseExact(groups[1].Value + groups[2].Value + groups[3].Value, "HHmmss", CultureInfo.InvariantCulture); } using (BinaryReader reader = new BinaryReader(File.Open(fileName, FileMode.Open))) { subHeader.Format = WavType.UNKNOWN; header.Id = Encoding.UTF8.GetString(reader.ReadBytes(4)); header.Size = reader.ReadUInt32(); header.Format = Encoding.UTF8.GetString(reader.ReadBytes(4)); if (!header.Id.Equals("RIFF")) { Console.WriteLine("Non Wave file!"); } Console.WriteLine("ID: {0}\nSize: {1}\nFormat: {2}", header.Id, header.Size, header.Format); bool cont = true; while (reader.BaseStream.Position != reader.BaseStream.Length && cont) { string chunkId = Encoding.UTF8.GetString(reader.ReadBytes(4)).Trim(); switch (chunkId) { case "fmt": subHeader.Id = chunkId; subHeader.Size = reader.ReadUInt32(); subHeader.Format = (WavType)reader.ReadUInt16(); subHeader.Channels = reader.ReadUInt16(); subHeader.SampleRate = reader.ReadUInt32(); subHeader.ByteRate = reader.ReadUInt32(); subHeader.BlockAlign = reader.ReadUInt16(); subHeader.BitsPerSample = reader.ReadUInt16(); wave.SampleRate = subHeader.SampleRate; Console.WriteLine("Format Chunk 0:\n\tId: {0}\n\tSize: {1}\n\tFormat: {2}\n\tChannels: {3}\n\tSample Rate: {4}\n\tByte Rate: {5}\n\tBlock Align: {6}\n\tBitsPerSample: {7}", subHeader.Id, subHeader.Size, subHeader.Format, subHeader.Channels, subHeader.SampleRate, subHeader.ByteRate, subHeader.BlockAlign, subHeader.BitsPerSample); break; case "data": dataHeader.Id = chunkId; dataHeader.Size = reader.ReadUInt32(); wave.Data = new WaveStream(fileName, reader.BaseStream.Position, dataHeader.Size, subHeader); Console.WriteLine("Data Chunk 0:\n\tId: {0}\n\tSize: {1}", dataHeader.Id, dataHeader.Size); cont = false; break; default: Console.WriteLine("Not recognized: {0}", chunkId); cont = false; break; } } } return wave; } else { Console.WriteLine("File does not exists!"); return null; } } } }

using RTLSharp.Audio.Structs; using RTLSharp.Types; using System; using System.IO; namespace RTLSharp.Audio { public class WaveStream { private BinaryReader _reader; private string _fileName; private long _readPosition; private long _readSize; private FormatChunkHeader _format; internal WaveStream(string fileName, long readPosition, long readSize, FormatChunkHeader format) { _readPosition = readPosition; _readSize = readSize; _fileName = fileName; _format = format; } public void Open() { if (File.Exists(FileName)) { _reader = new BinaryReader(File.Open(FileName, FileMode.Open)); _reader.BaseStream.Position = _readPosition; } } public void Close() { if (_reader != null) { _reader.Close(); } } public float readFloat() { return (_reader.BaseStream.Position < _readPosition + _readSize) ? _reader.ReadSingle() : 0.0f; } public Int16 readInt16() { return (_reader.BaseStream.Position < _readPosition + _readSize) ? _reader.ReadInt16() : (Int16) 0; } public byte readByte() { return (_reader.BaseStream.Position < _readPosition + _readSize) ? _reader.ReadByte() : (byte)0; } public Complex readComplex() { float real = 0.0f, imag = 0.0f; switch (_format.Format) { case WavType.FLOAT: real = readFloat(); imag = (_format.Channels == 2) ? readFloat() : 0.0f; break; case WavType.PCM: if (_format.Size == 8) { real = (readByte() - 128) / 127.0f; imag = (_format.Channels == 2) ? (readByte() - 128) / 127.0f : 0.0f; } else if (_format.Size == 16) { real = readInt16() / 16384.0f; imag = (_format.Channels == 2) ? readInt16() / 16384.0f : 0.0f; } break; } return new Complex(real, imag); } public void readComplexes(ref Complex[] cs, uint size) { for (int i=0; i<size; i++) { cs[i] = readComplex(); } } public unsafe void readComplexes(Complex *cs, uint size) { for (int i = 0; i < size; i++) { cs[i] = readComplex(); } } public string FileName { get { return _fileName; } } } }