SfxSystem.hpp

Go to the documentation of this file.

 
#pragma once
 
#include "AudioMath.hpp"
#include "AudioRuntime.hpp"
#include "SfxTypes.hpp"
#include "ecs/components/ClientId.hpp"
#include "ecs/registry/Registry.hpp"
#include "particles/ParticleEvents.hpp"
 
#include <SDL3/SDL.h>
 
#include <array>
#include <cstdint>
#include <mutex>
#include <span>
#include <string>
#include <unordered_map>
#include <vector>
 
struct SfxRuntimeStats
{
    std::uint64_t sourcesStarted = 0;
    std::uint64_t droppedByCooldown = 0;
    std::uint64_t droppedByLimit = 0;
    std::uint64_t stolenSources = 0;
    std::uint64_t virtualizedFrames = 0;
};

class SfxSystem
{
public:
    using SourceHandle = std::uint32_t;
    static constexpr SourceHandle kInvalidSource = 0;

    bool init();

    void update(float dt, const Registry& registry);

    void quit();

    void handleEvent(const SDL_Event& event);

    void play(SfxId id, float gain = 1.0f);
    SourceHandle play2D(SfxId id, float gain = 1.0f, float priority = 1.0f);
    SourceHandle play3D(SfxId id,
                        const glm::vec3& position,
                        const glm::vec3& velocity = glm::vec3{0.0f},
                        float gain = 1.0f,
                        float priority = 1.0f);
    SourceHandle startLoop(SfxId id,
                           bool positional = false,
                           const glm::vec3& position = glm::vec3{0.0f},
                           float gain = 1.0f,
                           float priority = 1.0f);
    void updateSource(SourceHandle handle,
                      const glm::vec3& position,
                      const glm::vec3& velocity = glm::vec3{0.0f},
                      float gain = 1.0f);
    void stopSource(SourceHandle handle);
    void setListener(const audio::ListenerState& listener);
    void setAudioObjectTransform(audio::AudioObjectId object,
                                 const glm::vec3& position,
                                 const glm::vec3& velocity = glm::vec3{0.0f});
    void removeAudioObject(audio::AudioObjectId object);
    void setAudioRtpc(audio::AudioObjectId object, audio::RtpcId rtpc, float value);
    void setAudioSwitch(audio::AudioObjectId object, audio::SwitchGroupId group, audio::SwitchValueId value);
    void setAudioState(audio::StateGroupId group, audio::StateValueId value);
    void setAudioBusVolume(audio::AudioBusId bus, float volume);
    bool reloadAudioManifest();
    SourceHandle
    postAudioEvent(std::string_view eventName, audio::AudioObjectId object = audio::kGlobalObject, float gain = 1.0f);
    SourceHandle postLocalAudioEvent(std::string_view eventName,
                                     audio::AudioObjectId object = audio::kGlobalObject,
                                     float gain = 1.0f);
    void submitVoiceFrame(ClientId speaker,
                          std::uint16_t sequence,
                          std::span<const float> monoPcm48k,
                          const glm::vec3& position,
                          const glm::vec3& velocity = glm::vec3{0.0f});

    void stop(SfxId id);
 
    // --- Volume control ---
    void setMasterVolume(float v) { masterVolume_ = v; }
    void setCategoryVolume(SfxCategory cat, float v);
    float masterVolume() const { return masterVolume_; }
    float categoryVolume(SfxCategory cat) const;
 
    // --- entt::dispatcher event handlers ---
    void onWeaponFired(const WeaponFiredEvent& e);
    void onExplosion(const ExplosionEvent& e);

    bool isInitialized() const { return device_ != 0; }
    [[nodiscard]] const audio::AudioRuntime& audioRuntime() const noexcept { return audioRuntime_; }
    [[nodiscard]] const audio::AudioRuntimeStats& audioStats() const noexcept { return audioRuntime_.stats(); }
    [[nodiscard]] const SfxRuntimeStats& sfxStats() const noexcept { return sfxStats_; }
    [[nodiscard]] std::uint32_t activeSourceCount() const noexcept;
    [[nodiscard]] std::uint32_t activeVoiceSourceCount() const noexcept;
 
private:
    SDL_AudioDeviceID device_ = 0;           
    SDL_AudioDeviceID physicalDeviceId_ = 0; 
    SDL_AudioStream* mixStream_ = nullptr;   
    SDL_AudioSpec mixerSpec_{};
 
    std::array<SoundClip, static_cast<size_t>(SfxId::_Count)> clips_;
 
    struct Source
    {
        bool active = false;
        bool loop = false;
        bool positional = false;
        bool voiceStream = false;
        SfxId playingId = SfxId::_Count; 
        SourceHandle handle = kInvalidSource;
        ClientId speaker{};
        float cursor = 0.0f;
        float gain = 1.0f;
        float priority = 1.0f;
        audio::AudioBusId bus{};
        float busGain = 1.0f;
        std::uint16_t maxInstances = 0;
        std::uint16_t maxBusInstances = 0;
        float fullGainDistance = audio::k_fullGainDistance;
        float silentDistance = audio::k_silentDistance;
        float age = 0.0f;
        float lowPassStateL = 0.0f;
        float lowPassStateR = 0.0f;
        std::uint16_t newestVoiceSeq = 0;
        bool hasVoiceSeq = false;
        bool occluded = false;
        glm::vec3 position{0.0f};
        glm::vec3 velocity{0.0f};
        std::vector<float> voicePcm;
        std::size_t voiceReadFrame = 0;
    };
    static constexpr int kMaxSources = 64;
    static constexpr std::size_t kMaxVoiceQueuedFrames = 48000 / 2; // 500 ms per speaker.
    std::array<Source, kMaxSources> sources_{};
    SourceHandle nextSourceHandle_ = 1;
    std::unordered_map<int, SourceHandle> voiceSources_;
 
    float masterVolume_ = 0.8f;
    std::array<float, static_cast<size_t>(SfxCategory::_Count)> categoryVolumes_{};
    audio::AudioRuntime audioRuntime_;
    SfxRuntimeStats sfxStats_{};
    std::string manifestPath_;
    audio::ListenerState listener_{};
    std::array<float, 48000> reverbDelayL_{};
    std::array<float, 48000> reverbDelayR_{};
    std::size_t reverbWrite_ = 0;
    mutable std::mutex mixerMutex_;

    std::array<float, static_cast<size_t>(SfxId::_Count)> cooldowns_{};
 
    // --- Client-side state tracking for event detection ---
    float prevHealth_ = 100.0f;
    float prevArmor_ = 100.0f;
    int prevDeaths_ = 0;
    int prevKills_ = 0;
    float healingSoundCooldown_ = 0.0f; 
    bool stateInitialized_ = false;     
 
    bool pendingReopen_ = false;        

    bool loadClip(SfxId id, const char* filename, SfxCategory cat, float gain, float cooldownSecs);
 
    Source* acquireSource(float priority,
                          SfxId id = SfxId::_Count,
                          audio::AudioBusId bus = audio::kInvalidBus,
                          std::uint16_t maxInstances = 0,
                          std::uint16_t maxBusInstances = 0);
    Source* findSource(SourceHandle handle);
    Source* findVoiceSource(ClientId speaker);
    SourceHandle startSource(SfxId id,
                             bool positional,
                             bool loop,
                             const glm::vec3& position,
                             const glm::vec3& velocity,
                             float gain,
                             float priority,
                             audio::AudioBusId bus,
                             float busGain,
                             std::uint16_t maxInstances,
                             std::uint16_t maxBusInstances,
                             float cooldownOverrideSeconds = -1.0f,
                             float fullGainDistance = audio::k_fullGainDistance,
                             float silentDistance = audio::k_silentDistance);
    SourceHandle playCommand(const audio::AudioCommand& command);

    float effectiveGain(SfxId id, float extraGain) const;
    void convertClipToMixer(SoundClip& clip, const char* debugName);
    void synthesizeClip(SfxId id, SfxCategory cat, float gain, float cooldownSecs);
    bool isOccluded(const glm::vec3& position) const;
    static void mixCallback(void* userdata, SDL_AudioStream* stream, int additionalAmount, int totalAmount);
    void mixIntoStream(SDL_AudioStream* stream, int additionalAmount);

    bool openDevice();

    void reopenDevice();

    void warmUpDevice();
 
    void convertClipsToMixer();
};