import { IAudioParam, IMinimalOfflineAudioContext, IOfflineAudioContext } from '../interfaces';
import { TNativeAudioParam, TNativeOfflineAudioContext, TRenderInputsOfAudioParamFactory } from '../types';

export const createRenderInputsOfAudioParam: TRenderInputsOfAudioParamFactory = (
    getAudioNodeRenderer,
    getAudioParamConnections,
    isPartOfACycle
) => {
    return async <T extends IMinimalOfflineAudioContext | IOfflineAudioContext>(
        audioParam: IAudioParam,
        nativeOfflineAudioContext: TNativeOfflineAudioContext,
        nativeAudioParam: TNativeAudioParam
    ): Promise<void> => {
        const audioParamConnections = getAudioParamConnections<T>(audioParam);

        await Promise.all(
            Array.from(audioParamConnections.activeInputs).map(async ([source, output]) => {
                const audioNodeRenderer = getAudioNodeRenderer(source);
                const renderedNativeAudioNode = await audioNodeRenderer.render(source, nativeOfflineAudioContext);

                if (!isPartOfACycle(source)) {
                    renderedNativeAudioNode.connect(nativeAudioParam, output);
                }
            })
        );
    };
};