diff --git a/apps/common-app/src/App.tsx b/apps/common-app/src/App.tsx
index 4204e65ad..c9b6eb581 100644
--- a/apps/common-app/src/App.tsx
+++ b/apps/common-app/src/App.tsx
@@ -30,8 +30,7 @@ const HomeScreen: FC = () => {
style={({ pressed }) => [
styles.button,
{ borderStyle: pressed ? 'solid' : 'dashed' },
- ]}
- >
+ ]}>
{item.title}
{item.subtitle}
@@ -64,8 +63,7 @@ const App: FC = () => {
headerTintColor: colors.white,
headerBackTitle: ' ',
headerBackAccessibilityLabel: 'Go back',
- }}
- >
+ }}>
= (props) => {
return (
+ style={[
+ styles.basic,
+ centered && styles.centered,
+ !disablePadding && styles.padding,
+ style,
+ ]}>
{children}
diff --git a/apps/common-app/src/components/VerticalSlider.tsx b/apps/common-app/src/components/VerticalSlider.tsx
new file mode 100644
index 000000000..889ba92b6
--- /dev/null
+++ b/apps/common-app/src/components/VerticalSlider.tsx
@@ -0,0 +1,119 @@
+import React, { useEffect } from 'react';
+import { View, Text, StyleSheet } from 'react-native';
+import { GestureDetector, Gesture } from 'react-native-gesture-handler';
+import Animated, {
+ useSharedValue,
+ useAnimatedStyle,
+} from 'react-native-reanimated';
+import { scheduleOnRN } from 'react-native-worklets';
+
+const SLIDER_HEIGHT = 150;
+const THUMB_SIZE = 30;
+const TRACK_HEIGHT = SLIDER_HEIGHT - THUMB_SIZE;
+
+interface VerticalSliderProps {
+ label: string;
+ value: number;
+ onValueChange: (val: number) => void;
+}
+
+const VerticalSlider: React.FC = ({
+ label,
+ value,
+ onValueChange,
+}) => {
+ const progress = useSharedValue(value);
+ const startValue = useSharedValue(0);
+
+ useEffect(() => {
+ progress.value = value;
+ }, [value, progress]);
+
+ const gesture = Gesture.Pan()
+ .onStart(() => {
+ 'worklet';
+ startValue.value = progress.value;
+ })
+ .onUpdate((e) => {
+ 'worklet';
+ const change = -e.translationY / TRACK_HEIGHT;
+ const newValue = startValue.value + change;
+ progress.value = Math.min(Math.max(newValue, 0), 1);
+ scheduleOnRN(onValueChange, progress.value);
+ });
+
+ const thumbStyle = useAnimatedStyle(() => {
+ const translateY = (1 - progress.value) * TRACK_HEIGHT;
+ return {
+ transform: [{ translateY }],
+ };
+ });
+
+ return (
+
+ {label}
+
+
+
+
+
+
+
+
+ {(value * 100).toFixed(0)}
+
+ );
+};
+
+const styles = StyleSheet.create({
+ sliderContainer: {
+ alignItems: 'center',
+ gap: 5,
+ height: SLIDER_HEIGHT + 40,
+ },
+ sliderLabel: {
+ fontWeight: 'bold',
+ fontSize: 12,
+ color: '#333',
+ },
+ sliderTrackContainer: {
+ width: 40,
+ height: SLIDER_HEIGHT,
+ justifyContent: 'center',
+ alignItems: 'center',
+ },
+ sliderTrack: {
+ position: 'absolute',
+ width: 4,
+ height: '100%',
+ backgroundColor: '#111',
+ borderRadius: 2,
+ },
+ sliderThumbHitArea: {
+ position: 'absolute',
+ top: 0,
+ width: 40,
+ height: THUMB_SIZE,
+ justifyContent: 'center',
+ alignItems: 'center',
+ },
+ sliderThumb: {
+ width: 30,
+ height: 15,
+ backgroundColor: '#222',
+ borderWidth: 1,
+ borderColor: '#fff',
+ borderRadius: 2,
+ shadowColor: '#000',
+ shadowOffset: { width: 0, height: 2 },
+ shadowOpacity: 0.5,
+ shadowRadius: 2,
+ },
+ sliderValue: {
+ fontSize: 10,
+ color: '#555',
+ fontVariant: ['tabular-nums'],
+ },
+});
+
+export default VerticalSlider;
diff --git a/apps/common-app/src/components/index.ts b/apps/common-app/src/components/index.ts
index 95b235bb7..c3e93660e 100644
--- a/apps/common-app/src/components/index.ts
+++ b/apps/common-app/src/components/index.ts
@@ -5,3 +5,4 @@ export { default as Switch } from './Switch';
export { default as Select } from './Select';
export { default as Container } from './Container';
export { default as BGGradient } from './BGGradient';
+export { default as VerticalSlider } from './VerticalSlider';
diff --git a/apps/common-app/src/examples/AudioFile/AudioPlayer.ts b/apps/common-app/src/examples/AudioFile/AudioPlayer.ts
index 91ef3695b..34a127013 100644
--- a/apps/common-app/src/examples/AudioFile/AudioPlayer.ts
+++ b/apps/common-app/src/examples/AudioFile/AudioPlayer.ts
@@ -1,4 +1,7 @@
-import { AudioContext, PlaybackNotificationManager } from 'react-native-audio-api';
+import {
+ AudioContext,
+ PlaybackNotificationManager,
+} from 'react-native-audio-api';
import type {
AudioBufferSourceNode,
AudioBuffer,
diff --git a/apps/common-app/src/examples/Distorted/Distorted.tsx b/apps/common-app/src/examples/Distorted/Distorted.tsx
new file mode 100644
index 000000000..579508c72
--- /dev/null
+++ b/apps/common-app/src/examples/Distorted/Distorted.tsx
@@ -0,0 +1,103 @@
+import React, { useCallback, useEffect, useState, FC } from 'react';
+import { ActivityIndicator } from 'react-native';
+import {
+ AudioContext,
+ AudioNode,
+ AudioBuffer,
+ AudioBufferSourceNode,
+} from 'react-native-audio-api';
+import { Container, Button } from '../../components';
+import { presetEffects } from '../../utils/effects';
+
+const URL = 'https://files.catbox.moe/s2i1wn.flac';
+
+const Distorted: FC = () => {
+ const [isPlaying, setIsPlaying] = useState(false);
+ const [isLoading, setIsLoading] = useState(false);
+ const [buffer, setBuffer] = useState(null);
+
+ const aCtxRef = React.useRef(null);
+ const effectsMap = React.useRef | null>(null);
+ const sourceNodeRef = React.useRef(null);
+
+ const fetchAudioBuffer = useCallback(async () => {
+ setIsLoading(true);
+
+ if (!aCtxRef.current) {
+ aCtxRef.current = new AudioContext();
+ }
+ const audioContext = aCtxRef.current;
+
+ effectsMap.current = presetEffects.distorted(audioContext);
+
+ const audioBuffer = await fetch(URL, {
+ headers: {
+ 'User-Agent':
+ 'Mozilla/5.0 (Android; Mobile; rv:122.0) Gecko/122.0 Firefox/122.0',
+ },
+ })
+ .then((response) => response.arrayBuffer())
+ .then((arrayBuffer) => audioContext.decodeAudioData(arrayBuffer))
+ .catch((error) => {
+ console.error('Error decoding audio data source:', error);
+ return null;
+ });
+
+ setBuffer(audioBuffer);
+
+ setIsLoading(false);
+ }, []);
+
+ const togglePlayPause = useCallback(async () => {
+ if (!aCtxRef.current) {
+ return;
+ }
+
+ if (buffer === null) {
+ fetchAudioBuffer();
+ return;
+ }
+
+ if (isPlaying) {
+ sourceNodeRef.current?.stop();
+ } else {
+ await aCtxRef.current.resume();
+ sourceNodeRef.current = aCtxRef.current.createBufferSource();
+ sourceNodeRef.current.buffer = buffer;
+
+ let previousNode: AudioNode = sourceNodeRef.current;
+ effectsMap.current?.forEach((node) => {
+ previousNode.connect(node);
+ previousNode = node;
+ });
+
+ previousNode.connect(aCtxRef.current.destination);
+
+ sourceNodeRef.current.start();
+ }
+
+ setIsPlaying((prev) => !prev);
+ }, [isPlaying, buffer, fetchAudioBuffer]);
+
+ useEffect(() => {
+ fetchAudioBuffer();
+
+ return () => {
+ aCtxRef.current?.close();
+ aCtxRef.current = null;
+ };
+ }, [fetchAudioBuffer]);
+
+ return (
+
+ {isLoading && }
+
+
+ );
+};
+
+export default Distorted;
diff --git a/apps/common-app/src/examples/Distorted/index.tsx b/apps/common-app/src/examples/Distorted/index.tsx
new file mode 100644
index 000000000..9f70fd280
--- /dev/null
+++ b/apps/common-app/src/examples/Distorted/index.tsx
@@ -0,0 +1 @@
+export { default } from './Distorted';
diff --git a/apps/common-app/src/examples/GuitarPedal/GuitarPedal.tsx b/apps/common-app/src/examples/GuitarPedal/GuitarPedal.tsx
new file mode 100644
index 000000000..9c0f2e979
--- /dev/null
+++ b/apps/common-app/src/examples/GuitarPedal/GuitarPedal.tsx
@@ -0,0 +1,277 @@
+import React, { useEffect, useRef, useState } from 'react';
+import { View, Text, StyleSheet } from 'react-native';
+import { GestureDetector, Gesture } from 'react-native-gesture-handler';
+import {
+ AudioContext,
+ GainNode,
+ WaveShaperNode,
+ BiquadFilterNode,
+ AudioBuffer,
+ AudioBufferSourceNode,
+} from 'react-native-audio-api';
+import { Container, VerticalSlider } from '../../components';
+import { makeDistortionCurve } from './makeDistortionCurve';
+
+const URL = 'https://files.catbox.moe/s2i1wn.flac';
+
+const MIN_DRIVE_GAIN = 0.05;
+const MAX_DRIVE_GAIN = 50;
+const MIN_FREQ = 500;
+const MAX_FREQ = 20000;
+
+export default function GuitarPedal() {
+ const [isActive, setIsActive] = useState(false);
+ const [isLoading, setIsLoading] = useState(false);
+ const [buffer, setBuffer] = useState(null);
+
+ const [drive, setDrive] = useState(0.5);
+ const [tone, setTone] = useState(0.5);
+ const [level, setLevel] = useState(0.5);
+
+ const audioCtxRef = useRef(null);
+ const sourceNodeRef = useRef(null);
+ const driveNodeRef = useRef(null);
+ const shaperNodeRef = useRef(null);
+ const toneNodeRef = useRef(null);
+ const levelNodeRef = useRef(null);
+
+ useEffect(() => {
+ const init = async () => {
+ setIsLoading(true);
+ const ctx = new AudioContext();
+ audioCtxRef.current = ctx;
+
+ try {
+ const audioBuffer = await fetch(URL, {
+ headers: {
+ 'User-Agent':
+ 'Mozilla/5.0 (Android; Mobile; rv:122.0) Gecko/122.0 Firefox/122.0',
+ },
+ })
+ .then((response) => response.arrayBuffer())
+ .then((arrayBuffer) => ctx.decodeAudioData(arrayBuffer));
+
+ setBuffer(audioBuffer);
+ } catch (error) {
+ console.error('Error loading audio:', error);
+ } finally {
+ setIsLoading(false);
+ }
+ };
+ init();
+
+ return () => {
+ stopAudio();
+ audioCtxRef.current?.close();
+ audioCtxRef.current = null;
+ };
+ }, []);
+
+ const startAudio = async () => {
+ if (!audioCtxRef.current || !buffer) return;
+ const ctx = audioCtxRef.current;
+
+ if (ctx.state === 'suspended') {
+ await ctx.resume();
+ }
+
+ const source = ctx.createBufferSource();
+ source.buffer = buffer;
+ source.loop = true;
+
+ const driveNode = ctx.createGain();
+ const shaper = ctx.createWaveShaper();
+ const toneNode = ctx.createBiquadFilter();
+ const levelNode = ctx.createGain();
+
+ shaper.oversample = '4x';
+ shaper.curve = makeDistortionCurve(50, ctx.sampleRate);
+
+ toneNode.type = 'lowpass';
+ toneNode.Q.value = 1;
+
+ source.connect(driveNode);
+ driveNode.connect(shaper);
+ shaper.connect(toneNode);
+ toneNode.connect(levelNode);
+ levelNode.connect(ctx.destination);
+
+ source.start();
+
+ sourceNodeRef.current = source;
+ driveNodeRef.current = driveNode;
+ shaperNodeRef.current = shaper;
+ toneNodeRef.current = toneNode;
+ levelNodeRef.current = levelNode;
+
+ updateAudioParams(drive, tone, level);
+ setIsActive(true);
+ };
+
+ const stopAudio = () => {
+ if (sourceNodeRef.current) {
+ sourceNodeRef.current.stop();
+ }
+
+ sourceNodeRef.current = null;
+ driveNodeRef.current = null;
+ shaperNodeRef.current = null;
+ toneNodeRef.current = null;
+ levelNodeRef.current = null;
+
+ setIsActive(false);
+ };
+
+ const togglePower = () => {
+ if (isLoading || !buffer) return;
+
+ if (isActive) {
+ stopAudio();
+ } else {
+ startAudio();
+ }
+ };
+
+ const updateAudioParams = (d: number, t: number, l: number) => {
+ if (!driveNodeRef.current || !toneNodeRef.current || !levelNodeRef.current)
+ return;
+
+ const driveGain = MIN_DRIVE_GAIN + d * (MAX_DRIVE_GAIN - MIN_DRIVE_GAIN);
+ driveNodeRef.current.gain.value = driveGain;
+
+ // logarithmic mapping for tone
+ const freq = MIN_FREQ * Math.pow(MAX_FREQ / MIN_FREQ, t);
+ toneNodeRef.current.frequency.value = freq;
+
+ levelNodeRef.current.gain.value = l * 3;
+ };
+
+ useEffect(() => {
+ updateAudioParams(drive, tone, level);
+ }, [drive, tone, level]);
+
+ return (
+
+
+
+ RN AUDIO API
+ OVERDRIVE
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+ {isActive ? 'ON' : 'BYPASS'}
+
+
+
+
+ );
+}
+
+const styles = StyleSheet.create({
+ pedalBody: {
+ flex: 1,
+ backgroundColor: '#e6b800',
+ margin: 20,
+ borderRadius: 20,
+ borderWidth: 4,
+ borderColor: '#b38f00',
+ padding: 20,
+ justifyContent: 'space-between',
+ shadowColor: '#000',
+ shadowOffset: { width: 0, height: 10 },
+ shadowOpacity: 0.5,
+ shadowRadius: 10,
+ elevation: 10,
+ },
+ header: {
+ alignItems: 'center',
+ marginTop: 20,
+ },
+ brand: {
+ fontSize: 16,
+ fontWeight: 'bold',
+ color: '#333',
+ letterSpacing: 2,
+ },
+ model: {
+ fontSize: 32,
+ fontWeight: '900',
+ color: '#000',
+ fontStyle: 'italic',
+ },
+ controlsRow: {
+ flexDirection: 'row',
+ justifyContent: 'space-around',
+ alignItems: 'center',
+ },
+ footer: {
+ alignItems: 'center',
+ marginBottom: 40,
+ },
+ switchContainer: {
+ alignItems: 'center',
+ gap: 10,
+ },
+ led: {
+ width: 15,
+ height: 15,
+ borderRadius: 8,
+ borderWidth: 1,
+ borderColor: '#000',
+ marginBottom: 10,
+ shadowColor: '#f00',
+ shadowOffset: { width: 0, height: 0 },
+ shadowOpacity: 0.8,
+ shadowRadius: 5,
+ },
+ stompSwitch: {
+ width: 60,
+ height: 60,
+ borderRadius: 30,
+ backgroundColor: '#c0c0c0',
+ borderWidth: 2,
+ borderColor: '#888',
+ justifyContent: 'center',
+ alignItems: 'center',
+ elevation: 5,
+ },
+ stompInner: {
+ width: 40,
+ height: 40,
+ borderRadius: 20,
+ backgroundColor: '#e0e0e0',
+ borderWidth: 1,
+ borderColor: '#aaa',
+ },
+ switchLabel: {
+ fontWeight: 'bold',
+ color: '#333',
+ },
+});
diff --git a/apps/common-app/src/examples/GuitarPedal/makeDistortionCurve.ts b/apps/common-app/src/examples/GuitarPedal/makeDistortionCurve.ts
new file mode 100644
index 000000000..71ad3cf7c
--- /dev/null
+++ b/apps/common-app/src/examples/GuitarPedal/makeDistortionCurve.ts
@@ -0,0 +1,10 @@
+export function makeDistortionCurve(k: number, sampleRate: number) {
+ const curve = new Float32Array(sampleRate);
+ const deg = Math.PI / 180;
+
+ for (let i = 0; i < sampleRate; ++i) {
+ const x = (i * 2) / sampleRate - 1;
+ curve[i] = ((3 + k) * x * 20 * deg) / (Math.PI + k * Math.abs(x));
+ }
+ return curve;
+}
diff --git a/apps/common-app/src/examples/index.ts b/apps/common-app/src/examples/index.ts
index d0744d4c7..8a3e851b3 100644
--- a/apps/common-app/src/examples/index.ts
+++ b/apps/common-app/src/examples/index.ts
@@ -11,7 +11,9 @@ import Record from './Record/Record';
import PlaybackSpeed from './PlaybackSpeed/PlaybackSpeed';
import Worklets from './Worklets/Worklets';
import Streaming from './Streaming/Streaming';
+import Distorted from './Distorted/Distorted';
import { PlaybackNotificationExample } from './PlaybackNotification/PlaybackNotification';
+import GuitarPedal from './GuitarPedal/GuitarPedal';
type NavigationParamList = {
Oscillator: undefined;
@@ -26,7 +28,9 @@ type NavigationParamList = {
Record: undefined;
Worklets: undefined;
Streamer: undefined;
+ Distorted: undefined;
PlaybackNotification: undefined;
+ GuitarPedal: undefined;
};
export type ExampleKey = keyof NavigationParamList;
@@ -106,10 +110,22 @@ export const Examples: Example[] = [
subtitle: 'Stream audio from a URL',
screen: Streaming,
},
+ {
+ key: 'Distorted',
+ title: 'Distorted Audio',
+ subtitle: 'Apply non-linear distortion effect to audio',
+ screen: Distorted,
+ },
{
key: 'PlaybackNotification',
title: 'Playback Notification',
subtitle: 'Media playback notification with controls',
screen: PlaybackNotificationExample,
- }
+ },
+ {
+ key: 'GuitarPedal',
+ title: 'Guitar Pedal',
+ subtitle: 'Overdrive/Distortion Effect',
+ screen: GuitarPedal,
+ },
] as const;
diff --git a/apps/common-app/src/utils/effects.ts b/apps/common-app/src/utils/effects.ts
new file mode 100644
index 000000000..40365ff79
--- /dev/null
+++ b/apps/common-app/src/utils/effects.ts
@@ -0,0 +1,157 @@
+import {
+ AudioContext,
+ GainNode,
+ BiquadFilterNode,
+ ConvolverNode,
+ WaveShaperNode,
+ AudioNode,
+} from 'react-native-audio-api';
+
+export function createGainEffect(
+ audioContext: AudioContext,
+ gain: number = 1.0
+): GainNode {
+ const gainNode = audioContext.createGain();
+ gainNode.gain.setValueAtTime(gain, audioContext.currentTime);
+ return gainNode;
+}
+
+export function createLowPassFilter(
+ audioContext: AudioContext,
+ frequency: number = 1000
+): BiquadFilterNode {
+ const filter = audioContext.createBiquadFilter();
+ filter.type = 'lowpass';
+ filter.frequency.setValueAtTime(frequency, audioContext.currentTime);
+ filter.Q.setValueAtTime(1, audioContext.currentTime);
+ return filter;
+}
+
+export function createHighPassFilter(
+ audioContext: AudioContext,
+ frequency: number = 300
+): BiquadFilterNode {
+ const filter = audioContext.createBiquadFilter();
+ filter.type = 'highpass';
+ filter.frequency.setValueAtTime(frequency, audioContext.currentTime);
+ filter.Q.setValueAtTime(1, audioContext.currentTime);
+ return filter;
+}
+
+export function createSimpleReverb(
+ audioContext: AudioContext,
+ roomSize: number = 0.5,
+ decayTime: number = 2
+): ConvolverNode {
+ const convolver = audioContext.createConvolver();
+
+ const sampleRate = audioContext.sampleRate;
+ const length = sampleRate * decayTime;
+ const impulse = audioContext.createBuffer(2, length, sampleRate);
+
+ for (let channel = 0; channel < 2; channel++) {
+ const channelData = impulse.getChannelData(channel);
+ for (let i = 0; i < length; i++) {
+ const decay = Math.pow(1 - i / length, 2);
+ channelData[i] = (Math.random() * 2 - 1) * decay * roomSize;
+ }
+ }
+
+ convolver.buffer = impulse;
+ return convolver;
+}
+
+export function createOverdrive(
+ audioContext: AudioContext,
+ amount: number = 0.5
+): WaveShaperNode {
+ const waveShaper = audioContext.createWaveShaper();
+
+ const samples = 44100;
+ const curve = new Float32Array(samples);
+
+ const clampedAmount = Math.max(0, Math.min(1, amount));
+ const drive = 2 + clampedAmount * 30;
+
+ for (let i = 0; i < samples; i++) {
+ const x = (i * 2) / samples - 1;
+ const driven = x * drive;
+
+ let distorted;
+ if (driven > 0) {
+ distorted = Math.tanh(driven * 1.5) * 0.8;
+ } else {
+ distorted = Math.tanh(driven * 1.2) * 0.9;
+ }
+
+ const harmonics = Math.sin(driven * 3) * 0.1 * clampedAmount;
+
+ curve[i] = Math.max(-1, Math.min(1, distorted + harmonics)) * 3;
+ }
+
+ waveShaper.curve = curve;
+ waveShaper.oversample = '4x';
+
+ return waveShaper;
+}
+
+export function createBandPassFilter(
+ audioContext: AudioContext,
+ lowFreq: number = 800,
+ highFreq: number = 3000
+): BiquadFilterNode {
+ const filter = audioContext.createBiquadFilter();
+ filter.type = 'bandpass';
+
+ const centerFreq = Math.sqrt(lowFreq * highFreq);
+ filter.frequency.setValueAtTime(centerFreq, audioContext.currentTime);
+
+ const Q = centerFreq / (highFreq - lowFreq);
+ filter.Q.setValueAtTime(Q, audioContext.currentTime);
+
+ return filter;
+}
+
+export function createEffectsMap(
+ effects: { name: string; node: AudioNode }[]
+): Map {
+ const effectsMap = new Map();
+
+ effects.forEach(({ name, node }) => {
+ effectsMap.set(name, node);
+ });
+
+ return effectsMap;
+}
+
+export const presetEffects = {
+ ambient: (audioContext: AudioContext) =>
+ createEffectsMap([
+ { name: 'reverb', node: createSimpleReverb(audioContext, 0.3, 1.5) },
+ { name: 'lowpass', node: createLowPassFilter(audioContext, 8000) },
+ ]),
+
+ warm: (audioContext: AudioContext) =>
+ createEffectsMap([
+ { name: 'lowpass', node: createLowPassFilter(audioContext, 3000) },
+ { name: 'gain', node: createGainEffect(audioContext, 1.2) },
+ ]),
+
+ distorted: (audioContext: AudioContext) =>
+ createEffectsMap([
+ { name: 'overdrive', node: createOverdrive(audioContext, 0.85) },
+ { name: 'midpass', node: createBandPassFilter(audioContext, 800, 3000) },
+ { name: 'lowpass', node: createLowPassFilter(audioContext, 6000) },
+ { name: 'gain', node: createGainEffect(audioContext, 0.4) },
+ ]),
+
+ test: (audioContext: AudioContext) =>
+ createEffectsMap([
+ { name: 'gain', node: createGainEffect(audioContext, 0.3) },
+ ]),
+
+ overdrive_only: (audioContext: AudioContext) =>
+ createEffectsMap([
+ { name: 'overdrive', node: createOverdrive(audioContext, 0.9) },
+ ]),
+};
diff --git a/packages/audiodocs/docs/core/base-audio-context.mdx b/packages/audiodocs/docs/core/base-audio-context.mdx
index 2e6a098bf..c6f31682f 100644
--- a/packages/audiodocs/docs/core/base-audio-context.mdx
+++ b/packages/audiodocs/docs/core/base-audio-context.mdx
@@ -195,6 +195,12 @@ Creates [`StreamerNode`](/docs/sources/streamer-node).
#### Returns `StreamerNode`.
+### `createWaveShaper`
+
+Creates [`WaveShaperNode`](/docs/effects/wave-shaper-node).
+
+#### Returns `WaveShaperNode`.
+
### `createWorkletNode`
Creates [`WorkletNode`](/docs/worklets/worklet-node).
diff --git a/packages/audiodocs/docs/effects/wave-shaper-node.mdx b/packages/audiodocs/docs/effects/wave-shaper-node.mdx
new file mode 100644
index 000000000..bb277eb31
--- /dev/null
+++ b/packages/audiodocs/docs/effects/wave-shaper-node.mdx
@@ -0,0 +1,57 @@
+---
+sidebar_position: 6
+---
+
+import AudioNodePropsTable from "@site/src/components/AudioNodePropsTable"
+import { ReadOnly } from '@site/src/components/Badges';
+
+# WaveShaperNode
+
+The `WaveShaperNode` interface represents non-linear signal distortion effects.
+Non-linear distortion is commonly used for both subtle non-linear warming, or more obvious distortion effects.
+
+#### [`AudioNode`](/docs/core/audio-node#properties) properties
+
+
+
+## Constructor
+
+[`BaseAudioContext.createWaveShaper()`](/docs/core/base-audio-context#createwaveshaper)
+
+## Properties
+
+It inherits all properties from [`AudioNode`](/docs/core/audio-node#properties).
+
+| Name | Type | Description |
+| :--: | :--: | :---------- |
+| `curve` | `Float32Array \| null` | The shaping curve used for waveshaping effect. |
+| `oversample` | [`OverSampleType`](/docs/effects/wave-shaper-node#oversampletype) | Specifies what type of oversampling should be used when applying shaping curve. |
+
+## Methods
+
+`WaveShaperNode` does not define any additional methods.
+It inherits all methods from [`AudioNode`](/docs/core/audio-node#methods).
+
+## Remarks
+
+#### `curve`
+- Default value is null
+- Contains at least two values.
+- Subsequent modifications of curve have no effects. To change the curve, assign a new Float32Array object to this property.
+
+#### `oversample`
+- Default value `none`
+- Value of `2x` or `4x` can increases quality of the effect, but in some cases it is better not to use oversampling for very accurate shaping curve.
+
+### `OverSampleType`
+
+
+Type definitions
+
+```typescript
+// Do not oversample | Oversample two times | Oversample four times
+export type OverSampleType = 'none' | '2x' | '4x';
+```
+
+
+
diff --git a/packages/audiodocs/docs/other/web-audio-api-coverage.mdx b/packages/audiodocs/docs/other/web-audio-api-coverage.mdx
index 2eac36708..7461c2e16 100644
--- a/packages/audiodocs/docs/other/web-audio-api-coverage.mdx
+++ b/packages/audiodocs/docs/other/web-audio-api-coverage.mdx
@@ -28,6 +28,7 @@ sidebar_position: 2
| OscillatorNode | ✅ |
| PeriodicWave | ✅ |
| StereoPannerNode | ✅ |
+| WaveShaperNode | ✅ |
| AudioContext | 🚧 | Available props and methods: `close`, `suspend`, `resume` |
| BaseAudioContext | 🚧 | Available props and methods: `currentTime`, `destination`, `sampleRate`, `state`, `decodeAudioData`, all create methods for available or partially implemented nodes |
| AudioListener | ❌ |
@@ -43,7 +44,6 @@ sidebar_position: 2
| MediaStreamAudioDestinationNode | ❌ |
| MediaStreamAudioSourceNode | ❌ |
| PannerNode | ❌ |
-| WaveShaperNode | ❌ |
### Description
diff --git a/packages/audiodocs/static/audio/music/guitar-sample.flac b/packages/audiodocs/static/audio/music/guitar-sample.flac
new file mode 100644
index 000000000..f594cf262
Binary files /dev/null and b/packages/audiodocs/static/audio/music/guitar-sample.flac differ
diff --git a/packages/react-native-audio-api/common/cpp/audioapi/HostObjects/BaseAudioContextHostObject.cpp b/packages/react-native-audio-api/common/cpp/audioapi/HostObjects/BaseAudioContextHostObject.cpp
index 8487e859c..a7ec66a0a 100644
--- a/packages/react-native-audio-api/common/cpp/audioapi/HostObjects/BaseAudioContextHostObject.cpp
+++ b/packages/react-native-audio-api/common/cpp/audioapi/HostObjects/BaseAudioContextHostObject.cpp
@@ -11,6 +11,7 @@
#include
#include
#include
+#include
#include
#include
#include
@@ -57,7 +58,8 @@ BaseAudioContextHostObject::BaseAudioContextHostObject(
JSI_EXPORT_FUNCTION(BaseAudioContextHostObject, createBuffer),
JSI_EXPORT_FUNCTION(BaseAudioContextHostObject, createPeriodicWave),
JSI_EXPORT_FUNCTION(BaseAudioContextHostObject, createConvolver),
- JSI_EXPORT_FUNCTION(BaseAudioContextHostObject, createAnalyser));
+ JSI_EXPORT_FUNCTION(BaseAudioContextHostObject, createAnalyser),
+ JSI_EXPORT_FUNCTION(BaseAudioContextHostObject, createWaveShaper));
}
JSI_PROPERTY_GETTER_IMPL(BaseAudioContextHostObject, destination) {
@@ -308,4 +310,10 @@ JSI_HOST_FUNCTION_IMPL(BaseAudioContextHostObject, createConvolver) {
}
return jsiObject;
}
+
+JSI_HOST_FUNCTION_IMPL(BaseAudioContextHostObject, createWaveShaper) {
+ auto waveShaper = context_->createWaveShaper();
+ auto waveShaperHostObject = std::make_shared(waveShaper);
+ return jsi::Object::createFromHostObject(runtime, waveShaperHostObject);
+}
} // namespace audioapi
diff --git a/packages/react-native-audio-api/common/cpp/audioapi/HostObjects/BaseAudioContextHostObject.h b/packages/react-native-audio-api/common/cpp/audioapi/HostObjects/BaseAudioContextHostObject.h
index 37daf4e04..63b9cb152 100644
--- a/packages/react-native-audio-api/common/cpp/audioapi/HostObjects/BaseAudioContextHostObject.h
+++ b/packages/react-native-audio-api/common/cpp/audioapi/HostObjects/BaseAudioContextHostObject.h
@@ -43,6 +43,7 @@ class BaseAudioContextHostObject : public JsiHostObject {
JSI_HOST_FUNCTION_DECL(createPeriodicWave);
JSI_HOST_FUNCTION_DECL(createAnalyser);
JSI_HOST_FUNCTION_DECL(createConvolver);
+ JSI_HOST_FUNCTION_DECL(createWaveShaper);
JSI_HOST_FUNCTION_DECL(createDelay);
std::shared_ptr context_;
diff --git a/packages/react-native-audio-api/common/cpp/audioapi/HostObjects/effects/WaveShaperNodeHostObject.cpp b/packages/react-native-audio-api/common/cpp/audioapi/HostObjects/effects/WaveShaperNodeHostObject.cpp
new file mode 100644
index 000000000..01b225fbf
--- /dev/null
+++ b/packages/react-native-audio-api/common/cpp/audioapi/HostObjects/effects/WaveShaperNodeHostObject.cpp
@@ -0,0 +1,72 @@
+#include
+#include
+#include
+
+#include
+#include
+
+namespace audioapi {
+
+WaveShaperNodeHostObject::WaveShaperNodeHostObject(const std::shared_ptr &node)
+ : AudioNodeHostObject(node) {
+ addGetters(
+ JSI_EXPORT_PROPERTY_GETTER(WaveShaperNodeHostObject, oversample),
+ JSI_EXPORT_PROPERTY_GETTER(WaveShaperNodeHostObject, curve));
+
+ addSetters(JSI_EXPORT_PROPERTY_SETTER(WaveShaperNodeHostObject, oversample));
+ addFunctions(JSI_EXPORT_FUNCTION(WaveShaperNodeHostObject, setCurve));
+}
+
+JSI_PROPERTY_GETTER_IMPL(WaveShaperNodeHostObject, oversample) {
+ auto waveShaperNode = std::static_pointer_cast(node_);
+ return jsi::String::createFromUtf8(runtime, waveShaperNode->getOversample());
+}
+
+JSI_PROPERTY_GETTER_IMPL(WaveShaperNodeHostObject, curve) {
+ auto waveShaperNode = std::static_pointer_cast(node_);
+ auto curve = waveShaperNode->getCurve();
+
+ if (curve == nullptr) {
+ return jsi::Value::null();
+ }
+
+ // copy AudioArray holding curve data to avoid subsequent modifications
+ auto audioArray = std::make_shared(*curve);
+ auto audioArrayBuffer = std::make_shared(audioArray);
+ auto arrayBuffer = jsi::ArrayBuffer(runtime, audioArrayBuffer);
+
+ auto float32ArrayCtor = runtime.global().getPropertyAsFunction(runtime, "Float32Array");
+ auto float32Array = float32ArrayCtor.callAsConstructor(runtime, arrayBuffer).getObject(runtime);
+ float32Array.setExternalMemoryPressure(runtime, audioArrayBuffer->size());
+
+ return float32Array;
+}
+
+JSI_PROPERTY_SETTER_IMPL(WaveShaperNodeHostObject, oversample) {
+ auto waveShaperNode = std::static_pointer_cast(node_);
+ std::string type = value.asString(runtime).utf8(runtime);
+ waveShaperNode->setOversample(type);
+}
+
+JSI_HOST_FUNCTION_IMPL(WaveShaperNodeHostObject, setCurve) {
+ auto waveShaperNode = std::static_pointer_cast(node_);
+
+ if (args[0].isNull()) {
+ waveShaperNode->setCurve(std::shared_ptr(nullptr));
+ return jsi::Value::undefined();
+ }
+
+ auto arrayBuffer =
+ args[0].getObject(runtime).getPropertyAsObject(runtime, "buffer").getArrayBuffer(runtime);
+
+ auto curve = std::make_shared(
+ reinterpret_cast(arrayBuffer.data(runtime)),
+ static_cast(arrayBuffer.size(runtime) / sizeof(float)));
+
+ waveShaperNode->setCurve(curve);
+ thisValue.asObject(runtime).setExternalMemoryPressure(runtime, arrayBuffer.size(runtime));
+
+ return jsi::Value::undefined();
+}
+
+} // namespace audioapi
diff --git a/packages/react-native-audio-api/common/cpp/audioapi/HostObjects/effects/WaveShaperNodeHostObject.h b/packages/react-native-audio-api/common/cpp/audioapi/HostObjects/effects/WaveShaperNodeHostObject.h
new file mode 100644
index 000000000..cdddf01fe
--- /dev/null
+++ b/packages/react-native-audio-api/common/cpp/audioapi/HostObjects/effects/WaveShaperNodeHostObject.h
@@ -0,0 +1,23 @@
+#pragma once
+
+#include
+
+#include
+#include
+
+namespace audioapi {
+using namespace facebook;
+
+class WaveShaperNode;
+
+class WaveShaperNodeHostObject : public AudioNodeHostObject {
+ public:
+ explicit WaveShaperNodeHostObject(const std::shared_ptr &node);
+
+ JSI_PROPERTY_GETTER_DECL(oversample);
+ JSI_PROPERTY_GETTER_DECL(curve);
+
+ JSI_PROPERTY_SETTER_DECL(oversample);
+ JSI_HOST_FUNCTION_DECL(setCurve);
+};
+} // namespace audioapi
diff --git a/packages/react-native-audio-api/common/cpp/audioapi/core/BaseAudioContext.cpp b/packages/react-native-audio-api/common/cpp/audioapi/core/BaseAudioContext.cpp
index afebaf2b5..9e8a69bbe 100644
--- a/packages/react-native-audio-api/common/cpp/audioapi/core/BaseAudioContext.cpp
+++ b/packages/react-native-audio-api/common/cpp/audioapi/core/BaseAudioContext.cpp
@@ -7,6 +7,7 @@
#include
#include
#include
+#include
#include
#include
#include
@@ -206,6 +207,12 @@ std::shared_ptr BaseAudioContext::createConvolver(
return convolver;
}
+std::shared_ptr BaseAudioContext::createWaveShaper() {
+ auto waveShaper = std::make_shared(this);
+ nodeManager_->addProcessingNode(waveShaper);
+ return waveShaper;
+}
+
AudioNodeManager *BaseAudioContext::getNodeManager() {
return nodeManager_.get();
}
diff --git a/packages/react-native-audio-api/common/cpp/audioapi/core/BaseAudioContext.h b/packages/react-native-audio-api/common/cpp/audioapi/core/BaseAudioContext.h
index b17304977..674d1d580 100644
--- a/packages/react-native-audio-api/common/cpp/audioapi/core/BaseAudioContext.h
+++ b/packages/react-native-audio-api/common/cpp/audioapi/core/BaseAudioContext.h
@@ -37,6 +37,7 @@ class WorkletSourceNode;
class WorkletNode;
class WorkletProcessingNode;
class StreamerNode;
+class WaveShaperNode;
class BaseAudioContext {
public:
@@ -88,6 +89,7 @@ class BaseAudioContext {
std::shared_ptr createConvolver(
std::shared_ptr buffer,
bool disableNormalization);
+ std::shared_ptr createWaveShaper();
std::shared_ptr getBasicWaveForm(OscillatorType type);
[[nodiscard]] float getNyquistFrequency() const;
diff --git a/packages/react-native-audio-api/common/cpp/audioapi/core/effects/WaveShaperNode.cpp b/packages/react-native-audio-api/common/cpp/audioapi/core/effects/WaveShaperNode.cpp
new file mode 100644
index 000000000..14dcaddde
--- /dev/null
+++ b/packages/react-native-audio-api/common/cpp/audioapi/core/effects/WaveShaperNode.cpp
@@ -0,0 +1,79 @@
+#include
+#include
+#include
+#include
+#include
+
+#include
+#include
+#include
+
+namespace audioapi {
+
+WaveShaperNode::WaveShaperNode(BaseAudioContext *context)
+ : AudioNode(context), oversample_(OverSampleType::OVERSAMPLE_NONE) {
+
+ waveShapers_.reserve(6);
+ for (int i = 0; i < channelCount_; i++) {
+ waveShapers_.emplace_back(std::make_unique(nullptr));
+ }
+
+ // to change after graph processing improvement - should be max
+ channelCountMode_ = ChannelCountMode::CLAMPED_MAX;
+ isInitialized_ = true;
+}
+
+std::string WaveShaperNode::getOversample() const {
+ return overSampleTypeToString(oversample_.load(std::memory_order_acquire));
+}
+
+void WaveShaperNode::setOversample(const std::string &type) {
+ std::scoped_lock lock(mutex_);
+ oversample_.store(overSampleTypeFromString(type), std::memory_order_release);
+
+ for (int i = 0; i < waveShapers_.size(); i++) {
+ waveShapers_[i]->setOversample(overSampleTypeFromString(type));
+ }
+}
+
+std::shared_ptr WaveShaperNode::getCurve() const {
+ std::scoped_lock lock(mutex_);
+ return curve_;
+}
+
+void WaveShaperNode::setCurve(const std::shared_ptr &curve) {
+ std::scoped_lock lock(mutex_);
+ curve_ = curve;
+
+ for (int i = 0; i < waveShapers_.size(); i++) {
+ waveShapers_[i]->setCurve(curve);
+ }
+}
+
+std::shared_ptr WaveShaperNode::processNode(
+ const std::shared_ptr &processingBus,
+ int framesToProcess) {
+ if (!isInitialized_) {
+ return processingBus;
+ }
+
+ std::unique_lock lock(mutex_, std::try_to_lock);
+
+ if (!lock.owns_lock()) {
+ return processingBus;
+ }
+
+ if (curve_ == nullptr) {
+ return processingBus;
+ }
+
+ for (int channel = 0; channel < processingBus->getNumberOfChannels(); channel++) {
+ auto channelData = processingBus->getSharedChannel(channel);
+
+ waveShapers_[channel]->process(channelData, framesToProcess);
+ }
+
+ return processingBus;
+}
+
+} // namespace audioapi
diff --git a/packages/react-native-audio-api/common/cpp/audioapi/core/effects/WaveShaperNode.h b/packages/react-native-audio-api/common/cpp/audioapi/core/effects/WaveShaperNode.h
new file mode 100644
index 000000000..d5a64eab7
--- /dev/null
+++ b/packages/react-native-audio-api/common/cpp/audioapi/core/effects/WaveShaperNode.h
@@ -0,0 +1,66 @@
+#pragma once
+
+#include
+#include
+#include
+#include
+
+#include
+#include
+#include
+#include
+#include
+#include
+
+namespace audioapi {
+
+class AudioBus;
+class AudioArray;
+
+class WaveShaperNode : public AudioNode {
+ public:
+ explicit WaveShaperNode(BaseAudioContext *context);
+
+ [[nodiscard]] std::string getOversample() const;
+ [[nodiscard]] std::shared_ptr getCurve() const;
+
+ void setOversample(const std::string &type);
+ void setCurve(const std::shared_ptr &curve);
+
+ protected:
+ std::shared_ptr processNode(
+ const std::shared_ptr &processingBus,
+ int framesToProcess) override;
+
+ private:
+ std::atomic oversample_;
+ std::shared_ptr curve_{};
+ mutable std::mutex mutex_;
+
+ std::vector> waveShapers_{};
+
+ static OverSampleType overSampleTypeFromString(const std::string &type) {
+ std::string lowerType = type;
+ std::transform(lowerType.begin(), lowerType.end(), lowerType.begin(), ::tolower);
+
+ if (lowerType == "2x")
+ return OverSampleType::OVERSAMPLE_2X;
+ if (lowerType == "4x")
+ return OverSampleType::OVERSAMPLE_4X;
+
+ return OverSampleType::OVERSAMPLE_NONE;
+ }
+
+ static std::string overSampleTypeToString(OverSampleType type) {
+ switch (type) {
+ case OverSampleType::OVERSAMPLE_2X:
+ return "2x";
+ case OverSampleType::OVERSAMPLE_4X:
+ return "4x";
+ default:
+ return "none";
+ }
+ }
+};
+
+} // namespace audioapi
diff --git a/packages/react-native-audio-api/common/cpp/audioapi/core/types/OverSampleType.h b/packages/react-native-audio-api/common/cpp/audioapi/core/types/OverSampleType.h
new file mode 100644
index 000000000..8ba765169
--- /dev/null
+++ b/packages/react-native-audio-api/common/cpp/audioapi/core/types/OverSampleType.h
@@ -0,0 +1,7 @@
+#pragma once
+
+namespace audioapi {
+
+enum class OverSampleType { OVERSAMPLE_NONE, OVERSAMPLE_2X, OVERSAMPLE_4X };
+
+} // namespace audioapi
diff --git a/packages/react-native-audio-api/common/cpp/audioapi/dsp/Resampler.cpp b/packages/react-native-audio-api/common/cpp/audioapi/dsp/Resampler.cpp
new file mode 100644
index 000000000..29a25ff73
--- /dev/null
+++ b/packages/react-native-audio-api/common/cpp/audioapi/dsp/Resampler.cpp
@@ -0,0 +1,211 @@
+/*
+ * Copyright (C) 2010 Google Inc. All rights reserved.
+ *
+ * Redistribution and use in source and binary forms, with or without
+ * modification, are permitted provided that the following conditions
+ * are met:
+ *
+ * 1. Redistributions of source code must retain the above copyright
+ * notice, this list of conditions and the following disclaimer.
+ * 2. Redistributions in binary form must reproduce the above copyright
+ * notice, this list of conditions and the following disclaimer in the
+ * documentation and/or other materials provided with the distribution.
+ * 3. Neither the name of Apple Computer, Inc. ("Apple") nor the names of
+ * its contributors may be used to endorse or promote products derived
+ * from this software without specific prior written permission.
+ *
+ * THIS SOFTWARE IS PROVIDED BY APPLE AND ITS CONTRIBUTORS "AS IS" AND ANY
+ * EXPRESS OR IMPLIED WARRANTIES, INCLUDING, BUT NOT LIMITED TO, THE IMPLIED
+ * WARRANTIES OF MERCHANTABILITY AND FITNESS FOR A PARTICULAR PURPOSE ARE
+ * DISCLAIMED. IN NO EVENT SHALL APPLE OR ITS CONTRIBUTORS BE LIABLE FOR ANY
+ * DIRECT, INDIRECT, INCIDENTAL, SPECIAL, EXEMPLARY, OR CONSEQUENTIAL DAMAGES
+ * (INCLUDING, BUT NOT LIMITED TO, PROCUREMENT OF SUBSTITUTE GOODS OR SERVICES;
+ * LOSS OF USE, DATA, OR PROFITS; OR BUSINESS INTERRUPTION) HOWEVER CAUSED AND
+ * ON ANY THEORY OF LIABILITY, WHETHER IN CONTRACT, STRICT LIABILITY, OR TORT
+ * (INCLUDING NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY OUT OF THE USE OF
+ * THIS SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF SUCH DAMAGE.
+ */
+
+#include
+#include
+#include
+#include
+#include
+#include
+
+#if defined(__ARM_NEON)
+#include
+#endif
+
+// based on WebKit UpSampler and DownSampler implementation
+
+namespace audioapi {
+
+static constexpr float PI = std::numbers::pi_v;
+
+// https://en.wikipedia.org/wiki/Window_function
+static float blackmanWindow(double x) {
+ double alpha = 0.16;
+ double a0 = 0.5 * (1.0 - alpha);
+ double a1 = 0.5;
+ double a2 = 0.5 * alpha;
+ double n = x / KERNEL_SIZE;
+ return static_cast(a0 - a1 * std::cos(2.0 * PI * n) + a2 * std::cos(4.0 * PI * n));
+}
+
+Resampler::Resampler() {
+ kernel_ = std::make_shared(KERNEL_SIZE);
+ stateBuffer_ = std::make_shared(KERNEL_SIZE + MAX_BLOCK_SIZE);
+ stateBuffer_->zero();
+}
+
+float Resampler::computeConvolution(const float *stateStart, const float *kernelStart) {
+ float sum = 0.0f;
+ int k = 0;
+
+#ifdef __ARM_NEON
+ float32x4_t vSum = vdupq_n_f32(0.0f);
+
+ // process 4 samples at a time
+ for (; k <= KERNEL_SIZE - 4; k += 4) {
+ float32x4_t vState = vld1q_f32(stateStart + k);
+ float32x4_t vKernel = vld1q_f32(kernelStart + k);
+
+ // fused multiply-add: vSum += vState * vKernel
+ vSum = vmlaq_f32(vSum, vState, vKernel);
+ }
+
+ // horizontal reduction: Sum the 4 lanes of vSum into a single float
+ sum += vgetq_lane_f32(vSum, 0);
+ sum += vgetq_lane_f32(vSum, 1);
+ sum += vgetq_lane_f32(vSum, 2);
+ sum += vgetq_lane_f32(vSum, 3);
+#endif
+ for (; k < KERNEL_SIZE; ++k) {
+ sum += stateStart[k] * kernelStart[k];
+ }
+
+ return sum;
+}
+
+void Resampler::reset() {
+ if (stateBuffer_) {
+ stateBuffer_->zero();
+ }
+}
+
+UpSampler::UpSampler() : Resampler() {
+ initializeKernel();
+}
+
+void UpSampler::initializeKernel() {
+ auto kData = kernel_->getData();
+ int halfSize = KERNEL_SIZE / 2;
+ double subSampleOffset = -0.5;
+
+ for (int i = 0; i < KERNEL_SIZE; ++i) {
+ // we want to sample the sinc function halfway between integer points
+ auto x = static_cast(i - halfSize) - subSampleOffset;
+
+ // https://en.wikipedia.org/wiki/Sinc_filter
+ // sets cutoff frequency to nyquist
+ double sinc = (std::abs(x) < 1e-9) ? 1.0 : std::sin(x * PI) / (x * PI);
+
+ // apply window in order smooth out the edges, because sinc extends to infinity in both directions
+ kData[i] = static_cast(sinc * blackmanWindow(i - subSampleOffset));
+ }
+
+ // reverse kernel to match convolution implementation
+ std::reverse(kData, kData + KERNEL_SIZE);
+}
+
+int UpSampler::process(
+ const std::shared_ptr &input,
+ const std::shared_ptr &output,
+ int framesToProcess) {
+
+ if (framesToProcess > MAX_BLOCK_SIZE) {
+ return 0;
+ }
+
+ const float *inputData = input->getData();
+ float *outputData = output->getData();
+ float *state = stateBuffer_->getData();
+ const float *kernel = kernel_->getData();
+
+ // move previous tail to front
+ std::memmove(state, state + framesToProcess, KERNEL_SIZE * sizeof(float));
+ // copy new input
+ std::memcpy(state + KERNEL_SIZE, inputData, framesToProcess * sizeof(float));
+
+ int halfKernel = KERNEL_SIZE / 2;
+
+ for (int i = 0; i < framesToProcess; ++i) {
+ int centerIdx = KERNEL_SIZE + i;
+
+ // direct copy for even samples
+ outputData[2 * i] = state[centerIdx - halfKernel];
+
+ // convolution for odd samples
+ outputData[2 * i + 1] = computeConvolution(&state[centerIdx - halfKernel], kernel);
+ }
+
+ return framesToProcess * 2;
+}
+
+DownSampler::DownSampler() : Resampler() {
+ initializeKernel();
+}
+
+void DownSampler::initializeKernel() {
+ auto kData = kernel_->getData();
+ int halfSize = KERNEL_SIZE / 2;
+
+ for (int i = 0; i < KERNEL_SIZE; ++i) {
+ // we want to sample the sinc function halfway between integer points
+ auto x = static_cast(i - halfSize);
+
+ // https://en.wikipedia.org/wiki/Sinc_filter
+ // sets cutoff frequency to nyquist / 2
+ double sinc = (std::abs(x) < 1e-9) ? 1.0 : std::sin(x * PI * 0.5) / (x * PI * 0.5);
+ sinc *= 0.5;
+
+ // apply window in order smooth out the edges, because sinc extends to infinity in both directions
+ kData[i] = static_cast(sinc * blackmanWindow(i));
+ }
+
+ // reverse kernel to match convolution implementation
+ std::reverse(kData, kData + KERNEL_SIZE);
+}
+
+int DownSampler::process(
+ const std::shared_ptr &input,
+ const std::shared_ptr &output,
+ int framesToProcess) {
+ if (framesToProcess > MAX_BLOCK_SIZE * 2) {
+ return 0;
+ }
+
+ const float *inputData = input->getData();
+ float *outputData = output->getData();
+ float *state = stateBuffer_->getData();
+ const float *kernel = kernel_->getData();
+ int halfKernel = KERNEL_SIZE / 2;
+
+ // move history (shift by amount processed last time, which is inputSize)
+ std::memmove(state, state + framesToProcess, KERNEL_SIZE * sizeof(float));
+ // copy new input
+ std::memcpy(state + KERNEL_SIZE, inputData, framesToProcess * sizeof(float));
+
+ auto outputCount = framesToProcess / 2;
+
+ for (int i = 0; i < outputCount; ++i) {
+ int centerIdx = KERNEL_SIZE + (2 * i);
+
+ // convolution for downsampled samples
+ outputData[i] = computeConvolution(&state[centerIdx - halfKernel], kernel);
+ }
+
+ return outputCount;
+}
+} // namespace audioapi
diff --git a/packages/react-native-audio-api/common/cpp/audioapi/dsp/Resampler.h b/packages/react-native-audio-api/common/cpp/audioapi/dsp/Resampler.h
new file mode 100644
index 000000000..210cf3f9d
--- /dev/null
+++ b/packages/react-native-audio-api/common/cpp/audioapi/dsp/Resampler.h
@@ -0,0 +1,58 @@
+#pragma once
+
+#include
+#include
+#include
+
+namespace audioapi {
+constexpr int KERNEL_SIZE = 128;
+constexpr int MAX_BLOCK_SIZE = 1024;
+
+class Resampler {
+ public:
+ Resampler();
+ virtual ~Resampler() = default;
+
+ virtual int process(
+ const std::shared_ptr &input,
+ const std::shared_ptr &output,
+ int framesToProcess) = 0;
+ void reset();
+
+ protected:
+ static float computeConvolution(const float *stateStart, const float *kernelStart);
+ virtual void initializeKernel() = 0;
+
+ std::shared_ptr kernel_;
+ std::shared_ptr stateBuffer_;
+};
+
+class UpSampler : public Resampler {
+ public:
+ UpSampler();
+
+ // N -> 2N
+ int process(
+ const std::shared_ptr &input,
+ const std::shared_ptr &output,
+ int framesToProcess) override;
+
+ protected:
+ void initializeKernel() final;
+};
+
+class DownSampler : public Resampler {
+ public:
+ DownSampler();
+
+ // N -> N / 2
+ int process(
+ const std::shared_ptr &input,
+ const std::shared_ptr &output,
+ int framesToProcess) override;
+
+ protected:
+ void initializeKernel() final;
+};
+
+} // namespace audioapi
diff --git a/packages/react-native-audio-api/common/cpp/audioapi/dsp/WaveShaper.cpp b/packages/react-native-audio-api/common/cpp/audioapi/dsp/WaveShaper.cpp
new file mode 100644
index 000000000..da942b87e
--- /dev/null
+++ b/packages/react-native-audio-api/common/cpp/audioapi/dsp/WaveShaper.cpp
@@ -0,0 +1,105 @@
+#include
+#include
+#include
+#include
+#include
+
+#include
+#include
+#include
+
+namespace audioapi {
+
+WaveShaper::WaveShaper(const std::shared_ptr &curve) : curve_(curve) {
+ tempBuffer2x_ = std::make_shared(RENDER_QUANTUM_SIZE * 2);
+ tempBuffer2x_->zero();
+ tempBuffer4x_ = std::make_shared(RENDER_QUANTUM_SIZE * 4);
+ tempBuffer4x_->zero();
+
+ upSampler_ = std::make_unique();
+ downSampler_ = std::make_unique();
+ upSampler2_ = std::make_unique();
+ downSampler2_ = std::make_unique();
+}
+
+void WaveShaper::setCurve(const std::shared_ptr &curve) {
+ curve_ = curve;
+}
+
+void WaveShaper::setOversample(OverSampleType type) {
+ oversample_ = type;
+
+ if (upSampler_) {
+ upSampler_->reset();
+ }
+
+ if (downSampler_) {
+ downSampler_->reset();
+ }
+
+ if (upSampler2_) {
+ upSampler2_->reset();
+ }
+
+ if (downSampler2_) {
+ downSampler2_->reset();
+ }
+}
+
+void WaveShaper::process(const std::shared_ptr &channelData, int framesToProcess) {
+ if (curve_ == nullptr) {
+ return;
+ }
+
+ switch (oversample_) {
+ case OverSampleType::OVERSAMPLE_2X:
+ process2x(channelData, framesToProcess);
+ break;
+ case OverSampleType::OVERSAMPLE_4X:
+ process4x(channelData, framesToProcess);
+ break;
+ case OverSampleType::OVERSAMPLE_NONE:
+ default:
+ processNone(channelData, framesToProcess);
+ break;
+ }
+}
+
+// based on https://webaudio.github.io/web-audio-api/#WaveShaperNode
+void WaveShaper::processNone(const std::shared_ptr &channelData, int framesToProcess) {
+ auto curveArray = curve_->getData();
+ auto curveSize = curve_->getSize();
+
+ auto data = channelData->getData();
+
+ for (int i = 0; i < framesToProcess; i++) {
+ float v = (static_cast(curveSize) - 1) * 0.5f * (data[i] + 1.0f);
+
+ if (v <= 0) {
+ data[i] = curveArray[0];
+ } else if (v >= static_cast(curveSize) - 1) {
+ data[i] = curveArray[curveSize - 1];
+ } else {
+ auto k = std::floor(v);
+ auto f = v - k;
+ auto kIndex = static_cast(k);
+ data[i] = (1 - f) * curveArray[kIndex] + f * curveArray[kIndex + 1];
+ }
+ }
+}
+
+void WaveShaper::process2x(const std::shared_ptr &channelData, int framesToProcess) {
+ auto outputFrames = upSampler_->process(channelData, tempBuffer2x_, framesToProcess);
+ processNone(tempBuffer2x_, outputFrames);
+ downSampler_->process(tempBuffer2x_, channelData, outputFrames);
+}
+
+void WaveShaper::process4x(const std::shared_ptr &channelData, int framesToProcess) {
+ auto upSamplerOutputFrames = upSampler_->process(channelData, tempBuffer2x_, framesToProcess);
+ auto upSampler2OutputFrames = upSampler2_->process(tempBuffer2x_, tempBuffer4x_, upSamplerOutputFrames);
+ processNone(tempBuffer4x_, upSampler2OutputFrames);
+ auto downSampler2OutputFrames = downSampler2_->process(tempBuffer4x_, tempBuffer2x_, upSampler2OutputFrames);
+ downSampler_->process(tempBuffer2x_, channelData, downSampler2OutputFrames);
+}
+
+} // namespace audioapi
diff --git a/packages/react-native-audio-api/common/cpp/audioapi/dsp/WaveShaper.h b/packages/react-native-audio-api/common/cpp/audioapi/dsp/WaveShaper.h
new file mode 100644
index 000000000..fd5a04b44
--- /dev/null
+++ b/packages/react-native-audio-api/common/cpp/audioapi/dsp/WaveShaper.h
@@ -0,0 +1,46 @@
+#pragma once
+
+#include
+#include
+
+#include
+#include
+#include
+#include
+#include
+
+namespace audioapi {
+
+class AudioBus;
+class AudioArray;
+
+class WaveShaper {
+ public:
+ explicit WaveShaper(const std::shared_ptr &curve);
+
+ void process(const std::shared_ptr &channelData, int framesToProcess);
+
+ void setCurve(const std::shared_ptr &curve);
+ void setOversample(OverSampleType type);
+
+ private:
+ OverSampleType oversample_ = OverSampleType::OVERSAMPLE_NONE;
+ std::shared_ptr curve_;
+
+ // stage 1 Filters (1x <-> 2x)
+ std::unique_ptr upSampler_;
+ std::unique_ptr downSampler_;
+
+ // stage 2 Filters (2x <-> 4x)
+ std::unique_ptr upSampler2_;
+ std::unique_ptr downSampler2_;
+
+ std::shared_ptr tempBuffer2x_;
+ std::shared_ptr tempBuffer4x_;
+
+ void processNone(const std::shared_ptr &channelData, int framesToProcess);
+ void process2x(const std::shared_ptr &channelData, int framesToProcess);
+ void process4x(const std::shared_ptr &channelData, int framesToProcess);
+};
+
+} // namespace audioapi
diff --git a/packages/react-native-audio-api/common/cpp/audioapi/utils/AudioArray.cpp b/packages/react-native-audio-api/common/cpp/audioapi/utils/AudioArray.cpp
index 967a8ed65..0e321ed80 100644
--- a/packages/react-native-audio-api/common/cpp/audioapi/utils/AudioArray.cpp
+++ b/packages/react-native-audio-api/common/cpp/audioapi/utils/AudioArray.cpp
@@ -14,6 +14,11 @@ AudioArray::AudioArray(const AudioArray &other) : data_(nullptr), size_(0) {
copy(&other);
}
+AudioArray::AudioArray(const float *data, size_t size) : size_(size) {
+ data_ = new float[size_];
+ memcpy(data_, data, size_ * sizeof(float));
+}
+
AudioArray::~AudioArray() {
if (data_) {
delete[] data_;
diff --git a/packages/react-native-audio-api/common/cpp/audioapi/utils/AudioArray.h b/packages/react-native-audio-api/common/cpp/audioapi/utils/AudioArray.h
index 6f17d23ed..9291f22ff 100644
--- a/packages/react-native-audio-api/common/cpp/audioapi/utils/AudioArray.h
+++ b/packages/react-native-audio-api/common/cpp/audioapi/utils/AudioArray.h
@@ -11,6 +11,12 @@ class AudioArray {
public:
explicit AudioArray(size_t size);
AudioArray(const AudioArray &other);
+
+ /// @brief Construct AudioArray from raw float data
+ /// @param data Pointer to the float data
+ /// @param size Number of float samples
+ /// @note The data is copied, so it does not take ownership of the pointer
+ AudioArray(const float *data, size_t size);
~AudioArray();
[[nodiscard]] size_t getSize() const;
diff --git a/packages/react-native-audio-api/common/cpp/test/src/core/effects/WaveShaperNodeTest.cpp b/packages/react-native-audio-api/common/cpp/test/src/core/effects/WaveShaperNodeTest.cpp
new file mode 100644
index 000000000..5abee5ea9
--- /dev/null
+++ b/packages/react-native-audio-api/common/cpp/test/src/core/effects/WaveShaperNodeTest.cpp
@@ -0,0 +1,75 @@
+#include
+#include
+#include
+#include
+#include
+#include
+#include
+#include
+
+using namespace audioapi;
+
+class WaveShaperNodeTest : public ::testing::Test {
+ protected:
+ std::shared_ptr eventRegistry;
+ std::unique_ptr context;
+ static constexpr int sampleRate = 44100;
+
+ void SetUp() override {
+ eventRegistry = std::make_shared();
+ context = std::make_unique(
+ 2, 5 * sampleRate, sampleRate, eventRegistry, RuntimeRegistry{});
+ }
+};
+
+class TestableWaveShaperNode : public WaveShaperNode {
+ public:
+ explicit TestableWaveShaperNode(BaseAudioContext *context) : WaveShaperNode(context) {
+ testCurve_ = std::make_shared(3);
+ auto data = testCurve_->getData();
+ data[0] = -2.0f;
+ data[1] = 0.0f;
+ data[2] = 2.0f;
+ }
+
+ std::shared_ptr processNode(
+ const std::shared_ptr &processingBus,
+ int framesToProcess) override {
+ return WaveShaperNode::processNode(processingBus, framesToProcess);
+ }
+
+ std::shared_ptr testCurve_;
+};
+
+TEST_F(WaveShaperNodeTest, WaveShaperNodeCanBeCreated) {
+ auto waveShaper = context->createWaveShaper();
+ ASSERT_NE(waveShaper, nullptr);
+}
+
+TEST_F(WaveShaperNodeTest, NullCanBeAsignedToCurve) {
+ auto waveShaper = context->createWaveShaper();
+ ASSERT_NO_THROW(waveShaper->setCurve(nullptr));
+ ASSERT_EQ(waveShaper->getCurve(), nullptr);
+}
+
+TEST_F(WaveShaperNodeTest, NoneOverSamplingProcessesCorrectly) {
+ static constexpr int FRAMES_TO_PROCESS = 5;
+ auto waveShaper = std::make_shared(context.get());
+ waveShaper->setOversample("none");
+ waveShaper->setCurve(waveShaper->testCurve_);
+
+ auto bus = std::make_shared(FRAMES_TO_PROCESS, 1, sampleRate);
+ for (size_t i = 0; i < bus->getSize(); ++i) {
+ bus->getChannel(0)->getData()[i] = -1.0f + i * 0.5f;
+ }
+
+ auto resultBus = waveShaper->processNode(bus, FRAMES_TO_PROCESS);
+ auto curveData = waveShaper->testCurve_->getData();
+ auto resultData = resultBus->getChannel(0)->getData();
+
+ EXPECT_FLOAT_EQ(resultData[0], curveData[0]);
+ EXPECT_FLOAT_EQ(resultData[1], -1.0f);
+ EXPECT_FLOAT_EQ(resultData[2], 0.0f);
+ EXPECT_FLOAT_EQ(resultData[3], 1.0f);
+ EXPECT_FLOAT_EQ(resultData[4], curveData[2]);
+}
diff --git a/packages/react-native-audio-api/common/cpp/test/src/dsp/ResamplerTest.cpp b/packages/react-native-audio-api/common/cpp/test/src/dsp/ResamplerTest.cpp
new file mode 100644
index 000000000..6e6d07796
--- /dev/null
+++ b/packages/react-native-audio-api/common/cpp/test/src/dsp/ResamplerTest.cpp
@@ -0,0 +1,195 @@
+#include
+#include
+#include
+#include
+#include
+#include
+
+using namespace audioapi;
+
+class ResamplerTest : public ::testing::Test {
+ protected:
+};
+
+class TestableUpSampler : public UpSampler {
+ public:
+ explicit TestableUpSampler() : UpSampler() {}
+
+ std::shared_ptr getKernel() {
+ return kernel_;
+ }
+};
+
+class TestableDownSampler : public DownSampler {
+ public:
+ explicit TestableDownSampler() : DownSampler() {}
+
+ std::shared_ptr getKernel() {
+ return kernel_;
+ }
+};
+
+TEST_F(ResamplerTest, UpSamplerCanBeCreated) {
+ auto upSampler = std::make_unique();
+ ASSERT_NE(upSampler, nullptr);
+}
+
+TEST_F(ResamplerTest, DownSamplerCanBeCreated) {
+ auto downSampler = std::make_unique();
+ ASSERT_NE(downSampler, nullptr);
+}
+
+TEST_F(ResamplerTest, UpSamplerKernelSymmetry) {
+ auto upSampler = std::make_unique();
+ auto kernel = upSampler->getKernel();
+
+ // check for symmetry around the center point
+ for (size_t i = 0; i < kernel->getSize() / 2; ++i) {
+ EXPECT_NEAR((*kernel)[i], (*kernel)[kernel->getSize() - 1 - i], 1e-6);
+ }
+}
+
+TEST_F(ResamplerTest, DownSamplerKernelSymmetry) {
+ auto downSampler = std::make_unique();
+ auto kernel = downSampler->getKernel();
+
+ // check for symmetry around the center point
+ // as the kernel size is even, we compare pairs around the center -> kernel[size/2 - 1]
+ // last value is skipped
+ for (size_t i = 0; i < kernel->getSize() / 2; ++i) {
+ EXPECT_NEAR((*kernel)[i], (*kernel)[kernel->getSize() - 2 - i], 1e-6);
+ }
+
+ EXPECT_FLOAT_EQ((*kernel)[kernel->getSize() / 2 - 1], 0.5f);
+}
+
+TEST_F(ResamplerTest, UpSamplerKernelSum) {
+ auto upSampler = std::make_unique();
+ auto kernel = upSampler->getKernel();
+
+ float sum = 0.0f;
+ for (size_t i = 0; i < kernel->getSize(); ++i) {
+ sum += (*kernel)[i];
+ }
+
+ EXPECT_NEAR(sum, 1.0f, 1e-6);
+}
+
+TEST_F(ResamplerTest, DownSamplerKernelSum) {
+ auto downSampler = std::make_unique();
+ auto kernel = downSampler->getKernel();
+
+ float sum = 0.0f;
+ for (size_t i = 0; i < kernel->getSize(); ++i) {
+ sum += (*kernel)[i];
+ }
+
+ EXPECT_NEAR(sum, 1.0f, 1e-6);
+}
+
+TEST_F(ResamplerTest, UpSamplerProcess) {
+ auto upSampler = std::make_unique();
+ auto kernel = upSampler->getKernel();
+
+ auto stateBuffer = std::make_shared(KERNEL_SIZE + MAX_BLOCK_SIZE);
+ stateBuffer->zero();
+
+ auto inputArray = std::make_shared(4);
+ (*inputArray)[0] = 1.0f;
+ (*inputArray)[1] = 0.0f;
+ (*inputArray)[2] = -1.0f;
+ (*inputArray)[3] = 1.0f;
+
+ auto outputArray = std::make_shared(8);
+
+ // update history buffer
+ memmove(
+ stateBuffer->getData(),
+ stateBuffer->getData() + inputArray->getSize(),
+ KERNEL_SIZE * sizeof(float));
+ memcpy(
+ stateBuffer->getData() + KERNEL_SIZE,
+ inputArray->getData(),
+ inputArray->getSize() * sizeof(float));
+
+ upSampler->process(inputArray, outputArray, 4);
+
+ for (size_t i = 0; i < outputArray->getSize(); ++i) {
+ auto idx = KERNEL_SIZE - KERNEL_SIZE / 2 + i / 2;
+
+ if (i % 2 == 0) {
+ EXPECT_FLOAT_EQ(outputArray->getData()[i], stateBuffer->getData()[idx]);
+ } else {
+ float sum = 0.0f;
+
+ for (size_t k = 0; k < kernel->getSize(); ++k) {
+ sum += stateBuffer->getData()[idx + k] * kernel->getData()[k];
+ }
+
+ EXPECT_FLOAT_EQ(outputArray->getData()[i], sum);
+ }
+ }
+}
+
+TEST_F(ResamplerTest, DownSamplerProcess) {
+ auto downSampler = std::make_unique();
+ auto kernel = downSampler->getKernel();
+
+ auto stateBuffer = std::make_shared(KERNEL_SIZE + MAX_BLOCK_SIZE);
+ stateBuffer->zero();
+
+ auto inputArray = std::make_shared(8);
+ (*inputArray)[0] = 1.0f;
+ (*inputArray)[1] = 0.0f;
+ (*inputArray)[2] = -1.0f;
+ (*inputArray)[3] = 1.0f;
+ (*inputArray)[4] = 0.5f;
+ (*inputArray)[5] = -0.5f;
+ (*inputArray)[6] = 0.25f;
+ (*inputArray)[7] = -0.25f;
+
+ auto outputArray = std::make_shared(4);
+
+ // update history buffer
+ memmove(
+ stateBuffer->getData(),
+ stateBuffer->getData() + inputArray->getSize(),
+ KERNEL_SIZE * sizeof(float));
+ memcpy(
+ stateBuffer->getData() + KERNEL_SIZE,
+ inputArray->getData(),
+ inputArray->getSize() * sizeof(float));
+
+ downSampler->process(inputArray, outputArray, 8);
+
+ for (size_t i = 0; i < outputArray->getSize() / 8; ++i) {
+ auto idx = KERNEL_SIZE + i * 2;
+ float sum = 0.0f;
+
+ for (size_t k = 0; k < kernel->getSize(); ++k) {
+ sum += stateBuffer->getData()[idx + k] * kernel->getData()[k];
+ }
+
+ EXPECT_FLOAT_EQ(outputArray->getData()[i], sum);
+ }
+}
+
+TEST_F(ResamplerTest, UpDownSamplingProcessThrowsNoErrors) {
+ auto upSampler = std::make_unique();
+ auto downSampler = std::make_unique();
+
+ auto inputArray = std::make_shared(4);
+ (*inputArray)[0] = 1.0f;
+ (*inputArray)[1] = 0.0f;
+ (*inputArray)[2] = -1.0f;
+ (*inputArray)[3] = 1.0f;
+
+ auto outputArray = std::make_shared(8);
+
+ EXPECT_NO_THROW(upSampler->process(inputArray, outputArray, 4));
+ EXPECT_NO_THROW(downSampler->process(outputArray, inputArray, 8));
+
+ for (size_t i = 0; i < inputArray->getSize(); ++i) {
+ ASSERT_NE(inputArray->getData()[i], 0.0f);
+ }
+}
diff --git a/packages/react-native-audio-api/src/api.ts b/packages/react-native-audio-api/src/api.ts
index 4c93907ed..ed0c03a8f 100644
--- a/packages/react-native-audio-api/src/api.ts
+++ b/packages/react-native-audio-api/src/api.ts
@@ -22,6 +22,7 @@ export { default as OscillatorNode } from './core/OscillatorNode';
export { default as RecorderAdapterNode } from './core/RecorderAdapterNode';
export { default as StereoPannerNode } from './core/StereoPannerNode';
export { default as StreamerNode } from './core/StreamerNode';
+export { default as WaveShaperNode } from './core/WaveShaperNode';
export { default as WorkletNode } from './core/WorkletNode';
export { default as WorkletProcessingNode } from './core/WorkletProcessingNode';
export { default as WorkletSourceNode } from './core/WorkletSourceNode';
diff --git a/packages/react-native-audio-api/src/api.web.ts b/packages/react-native-audio-api/src/api.web.ts
index 22571c557..aad59cfc6 100644
--- a/packages/react-native-audio-api/src/api.web.ts
+++ b/packages/react-native-audio-api/src/api.web.ts
@@ -14,6 +14,7 @@ export { default as OscillatorNode } from './web-core/OscillatorNode';
export { default as StereoPannerNode } from './web-core/StereoPannerNode';
export { default as ConstantSourceNode } from './web-core/ConstantSourceNode';
export { default as ConvolverNode } from './web-core/ConvolverNode';
+export { default as WaveShaperNode } from './web-core/WaveShaperNode';
export * from './web-core/custom';
diff --git a/packages/react-native-audio-api/src/core/BaseAudioContext.ts b/packages/react-native-audio-api/src/core/BaseAudioContext.ts
index ed60cf395..1718414e2 100644
--- a/packages/react-native-audio-api/src/core/BaseAudioContext.ts
+++ b/packages/react-native-audio-api/src/core/BaseAudioContext.ts
@@ -31,6 +31,7 @@ import PeriodicWave from './PeriodicWave';
import RecorderAdapterNode from './RecorderAdapterNode';
import StereoPannerNode from './StereoPannerNode';
import StreamerNode from './StreamerNode';
+import WaveShaperNode from './WaveShaperNode';
import WorkletNode from './WorkletNode';
import WorkletProcessingNode from './WorkletProcessingNode';
import WorkletSourceNode from './WorkletSourceNode';
@@ -355,4 +356,8 @@ export default class BaseAudioContext {
this.context.createConvolver(buffer?.buffer, disableNormalization)
);
}
+
+ createWaveShaper(): WaveShaperNode {
+ return new WaveShaperNode(this, this.context.createWaveShaper());
+ }
}
diff --git a/packages/react-native-audio-api/src/core/WaveShaperNode.ts b/packages/react-native-audio-api/src/core/WaveShaperNode.ts
new file mode 100644
index 000000000..069c4d52b
--- /dev/null
+++ b/packages/react-native-audio-api/src/core/WaveShaperNode.ts
@@ -0,0 +1,43 @@
+import AudioNode from './AudioNode';
+import { InvalidStateError } from '../errors';
+import { IWaveShaperNode } from '../interfaces';
+
+export default class WaveShaperNode extends AudioNode {
+ private isCurveSet: boolean = false;
+
+ get curve(): Float32Array | null {
+ if (!this.isCurveSet) {
+ return null;
+ }
+
+ return (this.node as IWaveShaperNode).curve;
+ }
+
+ get oversample(): OverSampleType {
+ return (this.node as IWaveShaperNode).oversample;
+ }
+
+ set curve(curve: Float32Array | null) {
+ if (curve !== null) {
+ if (this.isCurveSet) {
+ throw new InvalidStateError(
+ 'The curve can only be set once and cannot be changed afterwards.'
+ );
+ }
+
+ if (curve.length < 2) {
+ throw new InvalidStateError(
+ 'The curve must have at least two values if not null.'
+ );
+ }
+
+ this.isCurveSet = true;
+ }
+
+ (this.node as IWaveShaperNode).setCurve(curve);
+ }
+
+ set oversample(value: OverSampleType) {
+ (this.node as IWaveShaperNode).oversample = value;
+ }
+}
diff --git a/packages/react-native-audio-api/src/interfaces.ts b/packages/react-native-audio-api/src/interfaces.ts
index d06e5173e..4629efc24 100644
--- a/packages/react-native-audio-api/src/interfaces.ts
+++ b/packages/react-native-audio-api/src/interfaces.ts
@@ -6,6 +6,7 @@ import {
ContextState,
OscillatorType,
WindowType,
+ OverSampleType,
} from './types';
// IMPORTANT: use only IClass, because it is a part of contract between cpp host object and js layer
@@ -87,6 +88,7 @@ export interface IBaseAudioContext {
disableNormalization: boolean
) => IConvolverNode;
createStreamer: () => IStreamerNode | null; // null when FFmpeg is not enabled
+ createWaveShaper: () => IWaveShaperNode;
}
export interface IAudioContext extends IBaseAudioContext {
@@ -285,6 +287,13 @@ export interface IWorkletSourceNode extends IAudioScheduledSourceNode {}
export interface IWorkletProcessingNode extends IAudioNode {}
+export interface IWaveShaperNode extends IAudioNode {
+ readonly curve: Float32Array | null;
+ oversample: OverSampleType;
+
+ setCurve(curve: Float32Array | null): void;
+}
+
export interface IAudioRecorder {
start: () => void;
stop: () => void;
@@ -314,7 +323,7 @@ export interface IAudioDecoder {
export interface IAudioStretcher {
changePlaybackSpeed: (
- arrayBuffer: AudioBuffer,
+ arrayBuffer: IAudioBuffer,
playbackSpeed: number
) => Promise;
}
diff --git a/packages/react-native-audio-api/src/types.ts b/packages/react-native-audio-api/src/types.ts
index 740a7ad14..9e3bc7f93 100644
--- a/packages/react-native-audio-api/src/types.ts
+++ b/packages/react-native-audio-api/src/types.ts
@@ -57,6 +57,7 @@ export interface ConvolverNodeOptions {
disableNormalization?: boolean;
}
+export type OverSampleType = 'none' | '2x' | '4x';
export interface IIRFilterNodeOptions {
feedforward: number[];
feedback: number[];
diff --git a/packages/react-native-audio-api/src/web-core/AudioContext.tsx b/packages/react-native-audio-api/src/web-core/AudioContext.tsx
index f2770ef11..ed800f75b 100644
--- a/packages/react-native-audio-api/src/web-core/AudioContext.tsx
+++ b/packages/react-native-audio-api/src/web-core/AudioContext.tsx
@@ -23,6 +23,7 @@ import { ConvolverNodeOptions } from './ConvolverNodeOptions';
import { globalWasmPromise, globalTag } from './custom/LoadCustomWasm';
import ConstantSourceNode from './ConstantSourceNode';
+import WaveShaperNode from './WaveShaperNode';
export default class AudioContext implements BaseAudioContext {
readonly context: globalThis.AudioContext;
@@ -175,6 +176,10 @@ export default class AudioContext implements BaseAudioContext {
return new AnalyserNode(this, this.context.createAnalyser());
}
+ createWaveShaper(): WaveShaperNode {
+ return new WaveShaperNode(this, this.context.createWaveShaper());
+ }
+
async decodeAudioDataSource(source: string): Promise {
const arrayBuffer = await fetch(source).then((response) =>
response.arrayBuffer()
diff --git a/packages/react-native-audio-api/src/web-core/BaseAudioContext.tsx b/packages/react-native-audio-api/src/web-core/BaseAudioContext.tsx
index c9341289f..d94b2be64 100644
--- a/packages/react-native-audio-api/src/web-core/BaseAudioContext.tsx
+++ b/packages/react-native-audio-api/src/web-core/BaseAudioContext.tsx
@@ -8,6 +8,7 @@ import AudioDestinationNode from './AudioDestinationNode';
import AudioBuffer from './AudioBuffer';
import AudioBufferSourceNode from './AudioBufferSourceNode';
import BiquadFilterNode from './BiquadFilterNode';
+import DelayNode from './DelayNode';
import IIRFilterNode from './IIRFilterNode';
import GainNode from './GainNode';
import OscillatorNode from './OscillatorNode';
@@ -15,7 +16,7 @@ import PeriodicWave from './PeriodicWave';
import StereoPannerNode from './StereoPannerNode';
import ConstantSourceNode from './ConstantSourceNode';
import ConvolverNode from './ConvolverNode';
-import DelayNode from './DelayNode';
+import WaveShaperNode from './WaveShaperNode';
export default interface BaseAudioContext {
readonly context: globalThis.BaseAudioContext;
@@ -45,6 +46,7 @@ export default interface BaseAudioContext {
constraints?: PeriodicWaveConstraints
): PeriodicWave;
createAnalyser(): AnalyserNode;
+ createWaveShaper(): WaveShaperNode;
decodeAudioDataSource(source: string): Promise;
decodeAudioData(arrayBuffer: ArrayBuffer): Promise;
}
diff --git a/packages/react-native-audio-api/src/web-core/OfflineAudioContext.tsx b/packages/react-native-audio-api/src/web-core/OfflineAudioContext.tsx
index 54c7f9288..e0dc900cf 100644
--- a/packages/react-native-audio-api/src/web-core/OfflineAudioContext.tsx
+++ b/packages/react-native-audio-api/src/web-core/OfflineAudioContext.tsx
@@ -18,6 +18,7 @@ import OscillatorNode from './OscillatorNode';
import PeriodicWave from './PeriodicWave';
import StereoPannerNode from './StereoPannerNode';
import ConstantSourceNode from './ConstantSourceNode';
+import WaveShaperNode from './WaveShaperNode';
import { globalWasmPromise, globalTag } from './custom/LoadCustomWasm';
import ConvolverNode from './ConvolverNode';
@@ -181,6 +182,10 @@ export default class OfflineAudioContext implements BaseAudioContext {
return new AnalyserNode(this, this.context.createAnalyser());
}
+ createWaveShaper(): WaveShaperNode {
+ return new WaveShaperNode(this, this.context.createWaveShaper());
+ }
+
async decodeAudioDataSource(source: string): Promise {
const arrayBuffer = await fetch(source).then((response) =>
response.arrayBuffer()
diff --git a/packages/react-native-audio-api/src/web-core/WaveShaperNode.tsx b/packages/react-native-audio-api/src/web-core/WaveShaperNode.tsx
new file mode 100644
index 000000000..96addac2d
--- /dev/null
+++ b/packages/react-native-audio-api/src/web-core/WaveShaperNode.tsx
@@ -0,0 +1,42 @@
+import { InvalidStateError } from '../errors';
+import AudioNode from './AudioNode';
+
+export default class WaveShaperNode extends AudioNode {
+ private isCurveSet: boolean = false;
+
+ get curve(): Float32Array | null {
+ if (!this.isCurveSet) {
+ return null;
+ }
+
+ return (this.node as globalThis.WaveShaperNode).curve;
+ }
+
+ get oversample(): OverSampleType {
+ return (this.node as globalThis.WaveShaperNode).oversample;
+ }
+
+ set curve(curve: Float32Array | null) {
+ if (curve !== null) {
+ if (this.isCurveSet) {
+ throw new InvalidStateError(
+ 'The curve can only be set once and cannot be changed afterwards.'
+ );
+ }
+
+ if (curve.length < 2) {
+ throw new InvalidStateError(
+ 'The curve must have at least two values if not null.'
+ );
+ }
+
+ this.isCurveSet = true;
+ }
+
+ (this.node as globalThis.WaveShaperNode).curve = curve;
+ }
+
+ set oversample(value: OverSampleType) {
+ (this.node as globalThis.WaveShaperNode).oversample = value;
+ }
+}