Skip to content
New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

Sign up for GitHub

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

IT WORKS #2

Merged
merged 2 commits into from
Nov 30, 2024
Merged

IT WORKS #2

Changes from all commits
Commits
Show all changes
2 commits
Select commit Hold shift + click to select a range
9532760
dwadadad
SticksDeveloper Nov 30, 2024
7b71da0
IT WORKS
SticksDeveloper Nov 30, 2024
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
62 changes: 36 additions & 26 deletions EXILED/Exiled.API/Features/Toys/Speaker.cs
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -5,11 +5,8 @@
// </copyright>
// -----------------------------------------------------------------------

using Mirror;

namespace Exiled.API.Features.Toys
{
using System;
using System.Collections.Generic;
using System.IO;
using System.Linq;
Expand Down Expand Up @@ -189,6 +186,11 @@ public void Stop()
isPlaying = false;
}

// Stick please go to bed -Stick
// Credits:
// - ChatGPT
// - Zer0Tw0
// - Stick
private IEnumerator<float> PlaybackRoutine(string filePath, bool destroyAfter)
{
stopPlayback = false;
Expand All @@ -198,55 +200,63 @@ private IEnumerator<float> PlaybackRoutine(string filePath, bool destroyAfter)

const int sampleRate = 48000; // Enforce 48kHz
const int channels = 1; // Enforce mono audio
const int frameSize = 480;
const int frameSize = 480; // Frame size for 10ms of audio at 48kHz

PlaybackBuffer playbackBuffer = new();
Queue<float> streamBuffer = new();
float[] readBuffer = new float[(48000 / 5) + 1920];
float[] sendBuffer = new float[(48000 / 5) + 1920];
float[] readBuffer = new float[frameSize * 4];
float[] sendBuffer = new float[frameSize];
byte[] encodedBuffer = new byte[512];
OpusEncoder encoder = new(VoiceChat.Codec.Enums.OpusApplicationType.Voip);

// Decoding and playback loop
float playbackInterval = frameSize / (float)sampleRate;
float nextPlaybackTime = Timing.LocalTime;

if (fileExtension == ".ogg")
{
using VorbisReader vorbisReader = new(filePath);

// Validate format
if (vorbisReader.SampleRate != sampleRate || vorbisReader.Channels != channels)
{
Log.Error($"Invalid OGG file. Expected 48kHz mono, got {vorbisReader.SampleRate}Hz {vorbisReader.Channels} channel(s).");
Log.Error($"Invalid OGG file. Expected {sampleRate / 1000}kHz mono, got {vorbisReader.SampleRate / 1000}kHz {vorbisReader.Channels} channel(s).");
yield break;
}

Log.Info($"Playing OGG file with Sample Rate: {sampleRate}, Channels: {channels}");

while (!stopPlayback)
while (streamBuffer.Count < frameSize * 2 && !stopPlayback)
{
int samplesRead = vorbisReader.ReadSamples(readBuffer, 0, readBuffer.Length);
if (samplesRead <= 0)
break; // End of file
break;

foreach (float sample in readBuffer.Take(samplesRead))
streamBuffer.Enqueue(sample);
}

while (streamBuffer.Count >= frameSize)
while (!stopPlayback && streamBuffer.Count > 0)
{
if (Timing.LocalTime < nextPlaybackTime)
{
for (int i = 0; i < frameSize; i++)
playbackBuffer.Write(streamBuffer.Dequeue());
yield return Timing.WaitForOneFrame;
continue;
}

if (playbackBuffer.Length >= frameSize)
{
playbackBuffer.ReadTo(sendBuffer, frameSize, 0);
int dataLen = encoder.Encode(sendBuffer, encodedBuffer, frameSize);
for (int i = 0; i < frameSize && streamBuffer.Count > 0; i++)
sendBuffer[i] = streamBuffer.Dequeue();

AudioMessage audioMessage = new(ControllerID, encodedBuffer, dataLen);
audioMessage.SendToAuthenticated();
int dataLen = encoder.Encode(sendBuffer, encodedBuffer);
AudioMessage audioMessage = new(ControllerID, encodedBuffer, dataLen);
audioMessage.SendToAuthenticated();

Log.Info($"Sent {dataLen} bytes of encoded audio.");
}
Log.Debug($"Sent {dataLen} bytes of encoded audio.");

yield return Timing.WaitForOneFrame;
nextPlaybackTime += playbackInterval;

if (streamBuffer.Count < frameSize && !vorbisReader.IsEndOfStream)
{
int samplesRead = vorbisReader.ReadSamples(readBuffer, 0, readBuffer.Length);
foreach (float sample in readBuffer.Take(samplesRead))
streamBuffer.Enqueue(sample);
}
}
}
Expand All @@ -258,7 +268,7 @@ private IEnumerator<float> PlaybackRoutine(string filePath, bool destroyAfter)

Log.Info("Playback completed.");
isPlaying = false;
if(destroyAfter)
if (destroyAfter)
Destroy();
}

Expand All @@ -278,4 +288,4 @@ private IEnumerator<float> PlaybackRoutine(string filePath, bool destroyAfter)
// return sampleCount;
// }
}
}
}