Skip to content
Draft
Changes from all commits
Commits
File filter

Filter by extension

Filter by extension

Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
39 changes: 31 additions & 8 deletions src/intuitive_daw/audio/processor.py
Original file line number Diff line number Diff line change
Expand Up @@ -231,6 +231,7 @@ def __init__(
self.mix = mix
self.sample_rate = sample_rate
self.buffer = None
self.write_pos = 0

def _process_impl(self, audio: np.ndarray) -> np.ndarray:
"""Apply delay"""
Expand All @@ -239,18 +240,40 @@ def _process_impl(self, audio: np.ndarray) -> np.ndarray:
# Initialize buffer
if self.buffer is None or len(self.buffer) != delay_samples:
self.buffer = np.zeros((delay_samples, audio.shape[1]))
self.write_pos = 0

result = audio.copy()
result = np.empty_like(audio)
num_samples = len(audio)
current_pos = 0

# Process each sample
for i in range(len(result)):
# Add delayed signal
delayed = self.buffer[0]
result[i] = audio[i] * (1 - self.mix) + delayed * self.mix
while current_pos < num_samples:
# Process in chunks to handle circular buffer wrapping
chunk_size = min(
num_samples - current_pos,
delay_samples - self.write_pos
)

# Extract input chunk
chunk_in = audio[current_pos : current_pos + chunk_size]

# Extract delayed signal from buffer
delayed = self.buffer[self.write_pos : self.write_pos + chunk_size]

# Compute output
result[current_pos : current_pos + chunk_size] = (
chunk_in * (1 - self.mix) + delayed * self.mix
)

# Update buffer
self.buffer = np.roll(self.buffer, -1, axis=0)
self.buffer[-1] = audio[i] + delayed * self.feedback
self.buffer[self.write_pos : self.write_pos + chunk_size] = (
chunk_in + delayed * self.feedback
)

# Advance pointers
current_pos += chunk_size
self.write_pos += chunk_size
if self.write_pos >= delay_samples:
self.write_pos = 0

return result

Expand Down