1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
|
/**
* @class RecorderProcessor
* @extends AudioWorkletProcessor
*
* A simple recorder AudioWorkletProcessor. Returns the recorded buffer to the
* node when recording is finished.
*/
class RecorderProcessor extends AudioWorkletProcessor {
/**
* @param {*} options
* @param {number} options.duration A duration to record in seconds.
* @param {number} options.channelCount A channel count to record.
*/
constructor(options) {
super();
this._createdAt = currentTime;
this._elapsed = 0;
this._recordDuration = options.duration || 1;
this._recordChannelCount = options.channelCount || 1;
this._recordBufferLength = sampleRate * this._recordDuration;
this._recordBuffer = [];
for (let i = 0; i < this._recordChannelCount; ++i) {
this._recordBuffer[i] = new Float32Array(this._recordBufferLength);
}
}
process(inputs, outputs) {
if (this._recordBufferLength <= currentFrame) {
this.port.postMessage({
type: 'recordfinished',
recordBuffer: this._recordBuffer
});
this.port.close();
return false;
}
// Records the incoming data from |inputs| and also bypasses the data to
// |outputs|.
const input = inputs[0];
const output = outputs[0];
for (let channel = 0; channel < input.length; ++channel) {
const inputChannel = input[channel];
const outputChannel = output[channel];
outputChannel.set(inputChannel);
const buffer = this._recordBuffer[channel];
const capacity = buffer.length - currentFrame;
buffer.set(inputChannel.slice(0, capacity), currentFrame);
}
return true;
}
}
registerProcessor('recorder-processor', RecorderProcessor);
|
