Added packetID handling

This commit is contained in:
Pax1601
2024-10-07 21:36:14 +02:00
parent d774977387
commit 4078759310
3 changed files with 6 additions and 34 deletions

View File

@@ -3,6 +3,8 @@ import { Unit } from "../unit/unit";
import { Filter, Noise } from "./audiolibrary";
import { AudioPacket } from "./audiopacket";
let packetID = 0;
export class AudioUnitPipeline {
#inputNode: GainNode;
#sourceUnit: Unit;
@@ -97,6 +99,7 @@ export class AudioUnitPipeline {
let audioPacket = new AudioPacket();
audioPacket.setAudioData(new Uint8Array(arrayBuffer));
audioPacket.setPacketID(packetID++);
audioPacket.setFrequencies([
{
frequency: 100,

View File

@@ -2,6 +2,8 @@ import { AudioSink } from "./audiosink";
import { AudioPacket } from "./audiopacket";
import { getApp } from "../olympusapp";
let packetID = 0;
export class RadioSink extends AudioSink {
#encoder: AudioEncoder;
#desinationNode: MediaStreamAudioDestinationNode;
@@ -101,6 +103,7 @@ export class RadioSink extends AudioSink {
if (this.#ptt) {
let audioPacket = new AudioPacket();
audioPacket.setAudioData(new Uint8Array(arrayBuffer));
audioPacket.setPacketID(packetID++);
audioPacket.setFrequencies([{
frequency: this.#frequency,
modulation: this.#modulation,

View File

@@ -1,34 +0,0 @@
import { SRSRadioSetting } from "../interfaces";
import { AudioPacket } from "./audiopacket";
import { CapturePipeline } from "./capturepipeline";
export class MicrophoneHandler {
#socket: WebSocket;
#setting: SRSRadioSetting;
constructor(socket, setting) {
this.#socket = socket;
this.#setting = setting;
console.log("Starting microphone handler");
const pipeline = new CapturePipeline();
navigator.mediaDevices.enumerateDevices()
.then(function(devices) {
devices.forEach(function(device) {
console.log(device.kind + ": " + device.label +
" id = " + device.deviceId);
});
})
pipeline.connect().then(() => {
pipeline.onencoded = (data) => {
let buffer = new ArrayBuffer(data.byteLength);
data.copyTo(buffer);
let packet = new AudioPacket(new Uint8Array(buffer), this.#setting);
this.#socket.send(packet.getArray());
}
})
}
}