Crafter.Graphics/interfaces/Crafter.Graphics-PipelineRTVulkan.cppm

/*
Crafter®.Graphics
Copyright (C) 2026 Catcrafts®
catcrafts.net

This library is free software; you can redistribute it and/or
modify it under the terms of the GNU Lesser General Public
License version 3.0 as published by the Free Software Foundation;

This library is distributed in the hope that it will be useful,
but WITHOUT ANY WARRANTY; without even the implied warranty of
MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the GNU
Lesser General Public License for more details.

You should have received a copy of the GNU Lesser General Public
License along with this library; if not, write to the Free Software
Foundation, Inc., 51 Franklin Street, Fifth Floor, Boston, MA  02110-1301 USA
*/

module;
#ifdef CRAFTER_GRAPHICS_VULKAN
#include "vulkan/vulkan.h"
#endif
export module Crafter.Graphics:PipelineRTVulkan;
#ifdef CRAFTER_GRAPHICS_VULKAN
import std;
import :VulkanDevice;
import :VulkanBuffer;
import :ShaderBindingTableVulkan;
import :Types;

export namespace Crafter {
    class PipelineRTVulkan {
        public:
        VkPipeline pipeline;
        VkPipelineLayout pipelineLayout;
        std::vector<std::uint8_t> shaderHandles;  
        VulkanBuffer<std::uint8_t, true, true, false> sbtBuffer;
        VkStridedDeviceAddressRegionKHR raygenRegion;
        VkStridedDeviceAddressRegionKHR missRegion;
        VkStridedDeviceAddressRegionKHR hitRegion;
        VkStridedDeviceAddressRegionKHR callableRegion;

        void Init(VkCommandBuffer cmd, std::span<VkDescriptorSetLayout> setLayouts, std::span<VkRayTracingShaderGroupCreateInfoKHR> raygenGroups, std::span<VkRayTracingShaderGroupCreateInfoKHR> missGroups, std::span<VkRayTracingShaderGroupCreateInfoKHR> hitGroups, ShaderBindingTableVulkan& shaderTable) {
            VkPipelineLayoutCreateInfo pipelineLayoutInfo {
                .sType = VK_STRUCTURE_TYPE_PIPELINE_LAYOUT_CREATE_INFO,
                .setLayoutCount = static_cast<std::uint32_t>(setLayouts.size()),
                .pSetLayouts = setLayouts.data()
            };

			VulkanDevice::CheckVkResult(vkCreatePipelineLayout(VulkanDevice::device, &pipelineLayoutInfo, nullptr, &pipelineLayout));

            std::vector<VkRayTracingShaderGroupCreateInfoKHR> groups;
            groups.reserve(raygenGroups.size() + missGroups.size() + hitGroups.size());

            groups.insert(groups.end(), raygenGroups.begin(), raygenGroups.end());
            groups.insert(groups.end(), missGroups.begin(), missGroups.end());
            groups.insert(groups.end(), hitGroups.begin(), hitGroups.end());

            VkRayTracingPipelineCreateInfoKHR rtPipelineInfo{
                .sType = VK_STRUCTURE_TYPE_RAY_TRACING_PIPELINE_CREATE_INFO_KHR,
                .stageCount = static_cast<std::uint32_t>(shaderTable.shaderStages.size()),
                .pStages = shaderTable.shaderStages.data(),
                .groupCount = static_cast<std::uint32_t>(groups.size()),
                .pGroups = groups.data(),
                .maxPipelineRayRecursionDepth = 1,
                .layout = pipelineLayout
            };

            VulkanDevice::CheckVkResult(VulkanDevice::vkCreateRayTracingPipelinesKHR(VulkanDevice::device, {}, {}, 1, &rtPipelineInfo, nullptr, &pipeline));

            std::size_t dataSize = VulkanDevice::rayTracingProperties.shaderGroupHandleSize * rtPipelineInfo.groupCount;
            shaderHandles.resize(dataSize);
            VulkanDevice::CheckVkResult(VulkanDevice::vkGetRayTracingShaderGroupHandlesKHR(VulkanDevice::device, pipeline, 0, rtPipelineInfo.groupCount, dataSize, shaderHandles.data()));

            std::uint32_t sbtStride = AlignUp(VulkanDevice::rayTracingProperties.shaderGroupHandleSize, VulkanDevice::rayTracingProperties.shaderGroupHandleAlignment);

            raygenRegion.stride = sbtStride;
            raygenRegion.deviceAddress = 0;
            raygenRegion.size = raygenGroups.size() * sbtStride;

            missRegion.stride = sbtStride;
            missRegion.deviceAddress = AlignUp(raygenRegion.size, VulkanDevice::rayTracingProperties.shaderGroupBaseAlignment);
            missRegion.size = missGroups.size() * sbtStride;

            hitRegion.stride = sbtStride;
            hitRegion.deviceAddress = AlignUp(missRegion.deviceAddress + missRegion.size, VulkanDevice::rayTracingProperties.shaderGroupBaseAlignment);
            hitRegion.size = hitGroups.size() * sbtStride;

            std::size_t bufferSize =  hitRegion.deviceAddress + hitRegion.size;
            sbtBuffer.Create(VK_BUFFER_USAGE_2_SHADER_BINDING_TABLE_BIT_KHR | VK_BUFFER_USAGE_SHADER_DEVICE_ADDRESS_BIT, VK_MEMORY_PROPERTY_HOST_VISIBLE_BIT, bufferSize);

            std::uint8_t* offset = sbtBuffer.value;
            std::uint8_t* handleOffset = shaderHandles.data();

            std::memcpy(offset, handleOffset, raygenGroups.size() * VulkanDevice::rayTracingProperties.shaderGroupHandleSize);
            offset += AlignUp(raygenRegion.size, VulkanDevice::rayTracingProperties.shaderGroupBaseAlignment); 
            handleOffset += raygenGroups.size() * VulkanDevice::rayTracingProperties.shaderGroupHandleSize;

            std::memcpy(offset, handleOffset, missGroups.size() * VulkanDevice::rayTracingProperties.shaderGroupHandleSize);
            offset += AlignUp(missRegion.size, VulkanDevice::rayTracingProperties.shaderGroupBaseAlignment); 
            handleOffset += missGroups.size() * VulkanDevice::rayTracingProperties.shaderGroupHandleSize;

            std::memcpy(offset, handleOffset, hitGroups.size() * VulkanDevice::rayTracingProperties.shaderGroupHandleSize);

            sbtBuffer.FlushDevice(cmd, VK_ACCESS_MEMORY_READ_BIT, VK_PIPELINE_STAGE_RAY_TRACING_SHADER_BIT_KHR);

            raygenRegion.deviceAddress += sbtBuffer.address;
            missRegion.deviceAddress += sbtBuffer.address;
            hitRegion.deviceAddress += sbtBuffer.address;

            callableRegion.deviceAddress = 0;
            callableRegion.stride        = 0;
            callableRegion.size          = 0;
        }
    };

    template <std::uint32_t GeneralShader, std::uint32_t ClosestHitShader, std::uint32_t AnyHitShader, std::uint32_t IntersectionShader>    
    struct ShaderGroup {
        static constexpr std::uint32_t generalShader = GeneralShader;
        static constexpr std::uint32_t closestHitShader = ClosestHitShader;
        static constexpr std::uint32_t anyHitShader = AnyHitShader;
        static constexpr std::uint32_t intersectionShader = IntersectionShader;
    };

    template <typename Shaders, typename ShaderGroups>
    class PipelineRTVulkanConst {
        public:
        inline static VkPipeline pipeline;
        inline static VkPipelineLayout pipelineLayout;
        inline static std::vector<std::uint8_t> shaderHandles;  
        inline static VulkanBuffer<std::uint8_t, true, true, false> sbtBuffer;
        inline static VkStridedDeviceAddressRegionKHR raygenRegion;
        inline static VkStridedDeviceAddressRegionKHR missRegion;
        inline static VkStridedDeviceAddressRegionKHR hitRegion;
        inline static VkStridedDeviceAddressRegionKHR callableRegion;

        static void Init(VkCommandBuffer cmd, const std::span<const VkDescriptorSetLayout> setLayouts) {
            VkPipelineLayoutCreateInfo pipelineLayoutInfo {
                .sType = VK_STRUCTURE_TYPE_PIPELINE_LAYOUT_CREATE_INFO,
                .setLayoutCount = static_cast<std::uint32_t>(setLayouts.size()),
                .pSetLayouts = setLayouts.data()
            };

			VulkanDevice::CheckVkResult(vkCreatePipelineLayout(VulkanDevice::device, &pipelineLayoutInfo, nullptr, &pipelineLayout));

            constexpr auto groupIndexSeq = std::make_index_sequence<std::tuple_size_v<ShaderGroups>>{};

            constexpr std::array<VkRayTracingShaderGroupCreateInfoKHR, std::tuple_size_v<ShaderGroups>> groups = GetShaderGroups(groupIndexSeq);

            VkRayTracingPipelineCreateInfoKHR rtPipelineInfo{
                .sType = VK_STRUCTURE_TYPE_RAY_TRACING_PIPELINE_CREATE_INFO_KHR,
                .stageCount = static_cast<std::uint32_t>(ShaderBindingTableVulkanConst<Shaders>::shaderStages.size()),
                .pStages = ShaderBindingTableVulkanConst<Shaders>::shaderStages.data(),
                .groupCount = static_cast<std::uint32_t>(groups.size()),
                .pGroups = groups.data(),
                .maxPipelineRayRecursionDepth = 1,
                .layout = pipelineLayout
            };

            VulkanDevice::CheckVkResult(VulkanDevice::vkCreateRayTracingPipelinesKHR(VulkanDevice::device, {}, {}, 1, &rtPipelineInfo, nullptr, &pipeline));

            std::size_t dataSize = VulkanDevice::rayTracingProperties.shaderGroupHandleSize * rtPipelineInfo.groupCount;
            shaderHandles.resize(dataSize);
            VulkanDevice::CheckVkResult(VulkanDevice::vkGetRayTracingShaderGroupHandlesKHR(VulkanDevice::device, pipeline, 0, rtPipelineInfo.groupCount, dataSize, shaderHandles.data()));

            std::uint32_t sbtStride = AlignUp(VulkanDevice::rayTracingProperties.shaderGroupHandleSize, VulkanDevice::rayTracingProperties.shaderGroupHandleAlignment);

            raygenRegion.stride = sbtStride;
            raygenRegion.deviceAddress = 0;
            raygenRegion.size = GetGroupCount<VK_SHADER_STAGE_RAYGEN_BIT_KHR>(groupIndexSeq) * sbtStride;

            missRegion.stride = sbtStride;
            missRegion.deviceAddress = AlignUp(raygenRegion.size, VulkanDevice::rayTracingProperties.shaderGroupBaseAlignment);
            missRegion.size = GetGroupCount<VK_SHADER_STAGE_MISS_BIT_KHR>(groupIndexSeq) * sbtStride;

            hitRegion.stride = sbtStride;
            hitRegion.deviceAddress = AlignUp(missRegion.deviceAddress + missRegion.size, VulkanDevice::rayTracingProperties.shaderGroupBaseAlignment);
            hitRegion.size = (GetGroupCount<VK_SHADER_STAGE_CLOSEST_HIT_BIT_KHR>(groupIndexSeq) * sbtStride) + (GetGroupCount<VK_SHADER_STAGE_ANY_HIT_BIT_KHR>(groupIndexSeq) * sbtStride);

            std::size_t bufferSize =  hitRegion.deviceAddress + hitRegion.size;
            sbtBuffer.Create(VK_BUFFER_USAGE_2_SHADER_BINDING_TABLE_BIT_KHR | VK_BUFFER_USAGE_SHADER_DEVICE_ADDRESS_BIT, VK_MEMORY_PROPERTY_HOST_VISIBLE_BIT, bufferSize);

            AddShaderGroupsToBuffer(sbtStride, groupIndexSeq);
            sbtBuffer.FlushDevice(cmd, VK_ACCESS_MEMORY_READ_BIT, VK_PIPELINE_STAGE_RAY_TRACING_SHADER_BIT_KHR);

            raygenRegion.deviceAddress += sbtBuffer.address;
            missRegion.deviceAddress += sbtBuffer.address;
            hitRegion.deviceAddress += sbtBuffer.address;

            callableRegion.deviceAddress = 0;
            callableRegion.stride        = 0;
            callableRegion.size          = 0;
        }
        private:
        template<std::size_t index>
        consteval static void AddShaderGroup(std::array<VkRayTracingShaderGroupCreateInfoKHR, std::tuple_size_v<ShaderGroups>>& groups) {
            using groupTemplate = std::tuple_element_t<index, ShaderGroups>;
            VkRayTracingShaderGroupTypeKHR groupType;
            if constexpr(groupTemplate::generalShader != VK_SHADER_UNUSED_KHR) {
                groupType = VK_RAY_TRACING_SHADER_GROUP_TYPE_GENERAL_KHR; 
            } else if constexpr(groupTemplate::closestHitShader != VK_SHADER_UNUSED_KHR || groupTemplate::anyHitShader != VK_SHADER_UNUSED_KHR) {
                groupType = VK_RAY_TRACING_SHADER_GROUP_TYPE_TRIANGLES_HIT_GROUP_KHR; 
            } else {
                static_assert(
                    groupTemplate::generalShader != VK_SHADER_UNUSED_KHR ||
                    groupTemplate::closestHitShader != VK_SHADER_UNUSED_KHR,
                    "Shader group must define either a general or closest-hit shader"
                );
            }
            groups[index] =  {
                .sType = VK_STRUCTURE_TYPE_RAY_TRACING_SHADER_GROUP_CREATE_INFO_KHR,
                .type = groupType,
                .generalShader = groupTemplate::generalShader,
                .closestHitShader = groupTemplate::closestHitShader,
                .anyHitShader = groupTemplate::anyHitShader,
                .intersectionShader = groupTemplate::intersectionShader
            };
        }
        template<std::size_t... Is>
        consteval static std::array<VkRayTracingShaderGroupCreateInfoKHR, std::tuple_size_v<ShaderGroups>> GetShaderGroups(std::index_sequence<Is...>) {
            std::array<VkRayTracingShaderGroupCreateInfoKHR, std::tuple_size_v<ShaderGroups>> groups{};
            (AddShaderGroup<Is>(groups), ...);
            return groups;
        }

        template<std::size_t index, VkShaderStageFlagBits stage>
        consteval static void GetGroupCountImpl(std::uint32_t& count) {
            using groupTemplate = std::tuple_element_t<index, ShaderGroups>;
            if constexpr(groupTemplate::generalShader != VK_SHADER_UNUSED_KHR) {
                using shaderTemplate = std::tuple_element_t<groupTemplate::generalShader, Shaders>;
                if constexpr(shaderTemplate::_stage == stage) {
                    count++;
                }
            } else if constexpr(groupTemplate::closestHitShader != VK_SHADER_UNUSED_KHR) {
                using shaderTemplate = std::tuple_element_t<groupTemplate::closestHitShader, Shaders>;
                if constexpr(shaderTemplate::_stage == stage) {
                    count++;
                }
            } else if constexpr(groupTemplate::anyHitShader != VK_SHADER_UNUSED_KHR) {
                using shaderTemplate = std::tuple_element_t<groupTemplate::anyHitShader, Shaders>;
                if constexpr(shaderTemplate::_stage == stage) {
                    count++;
                }
            } else {
                static_assert(
                    groupTemplate::generalShader != VK_SHADER_UNUSED_KHR ||
                    groupTemplate::closestHitShader != VK_SHADER_UNUSED_KHR,
                    "Shader group must define either a general or closest-hit shader"
                );
            }
        }
        template<VkShaderStageFlagBits stage, std::size_t... Is>
        consteval static std::uint32_t GetGroupCount(std::index_sequence<Is...>) {
            std::uint32_t count = 0;
            (GetGroupCountImpl<Is, stage>(count), ...);
            return count;
        }   

        template<std::size_t index, VkShaderStageFlagBits stage>
        static void AddShaderGroupToBuffer(std::uint32_t sbtStride, std::uint32_t& offset) {
            using groupTemplate = std::tuple_element_t<index, ShaderGroups>;
            if constexpr(groupTemplate::generalShader != VK_SHADER_UNUSED_KHR) {
                using shaderTemplate = std::tuple_element_t<groupTemplate::generalShader, Shaders>;
                if constexpr(shaderTemplate::_stage == stage) {
                    std::memcpy(sbtBuffer.value + offset, shaderHandles.data() + index * VulkanDevice::rayTracingProperties.shaderGroupHandleSize, VulkanDevice::rayTracingProperties.shaderGroupHandleSize);
                    offset += sbtStride;
                }
            } else if constexpr(groupTemplate::closestHitShader != VK_SHADER_UNUSED_KHR) {
                using shaderTemplate = std::tuple_element_t<groupTemplate::closestHitShader, Shaders>;
                if constexpr(shaderTemplate::_stage == stage) {
                    std::memcpy(sbtBuffer.value + offset, shaderHandles.data() + index * VulkanDevice::rayTracingProperties.shaderGroupHandleSize, VulkanDevice::rayTracingProperties.shaderGroupHandleSize);
                    offset += sbtStride;
                }
            } else if constexpr(groupTemplate::anyHitShader != VK_SHADER_UNUSED_KHR) {
                using shaderTemplate = std::tuple_element_t<groupTemplate::anyHitShader, Shaders>;
                if constexpr(shaderTemplate::_stage == stage) {
                    std::memcpy(sbtBuffer.value + offset, shaderHandles.data() + index * VulkanDevice::rayTracingProperties.shaderGroupHandleSize, VulkanDevice::rayTracingProperties.shaderGroupHandleSize);
                    offset += sbtStride;
                }
            } else {
                static_assert(
                    groupTemplate::generalShader != VK_SHADER_UNUSED_KHR ||
                    groupTemplate::closestHitShader != VK_SHADER_UNUSED_KHR,
                    "Shader group must define either a general or closest-hit shader"
                );
            }
        }
        template<std::size_t... Is>
        static void AddShaderGroupsToBuffer(std::uint32_t sbtStride, std::index_sequence<Is...>) {
            std::uint32_t offset = 0;
            (AddShaderGroupToBuffer<Is, VK_SHADER_STAGE_RAYGEN_BIT_KHR>(sbtStride, offset), ...);
            offset = AlignUp(offset, VulkanDevice::rayTracingProperties.shaderGroupBaseAlignment);
            (AddShaderGroupToBuffer<Is, VK_SHADER_STAGE_MISS_BIT_KHR>(sbtStride, offset), ...);
            offset = AlignUp(offset, VulkanDevice::rayTracingProperties.shaderGroupBaseAlignment);
            (AddShaderGroupToBuffer<Is, VK_SHADER_STAGE_CLOSEST_HIT_BIT_KHR>(sbtStride, offset), ...);
            (AddShaderGroupToBuffer<Is, VK_SHADER_STAGE_ANY_HIT_BIT_KHR>(sbtStride, offset), ...);
        }   
    };
}

#endif