refactor(mirror): adjust to recent changes

modules/ecs/public/entity.hpp

@@ -19,7 +19,7 @@ public:
 	template<typename Component_T>
 	auto add(Component_T component) -> Component_T &
 	{
-		m_registry->add(m_identifier, component);
+		return m_registry->add(m_identifier, component);
 	}
 
 	template<typename Component_T>
@@ -42,7 +42,6 @@ public:
 private:
 	memory::Ref<Registry> m_registry;
 
-
 	EntityId m_identifier;
 };
 

modules/mirror/private/entrypoint/mirror.cpp

@@ -64,30 +64,25 @@ public:
 
 			if (input.get_action(m_quit_action_key).state == State::active)
 			{
-				log_dbg("Quit triggered! BYE!");
 				should_quit = true;
 			}
 			if (input.get_action(m_debug_action_keys[0]).state == State::active)
 			{
-				log_dbg("Deubg action 1");
 				surface.push_request(surface::ModifyPositionRequest({ x + 5, y + 5 }));
 			}
 
 			if (input.get_action(m_debug_action_keys[1]).state == State::active)
 			{
-				log_dbg("Deubg action 2");
 				surface.push_request(surface::ModifyPositionRequest({ x - 5, y - 5 }));
 			}
 
 			if (input.get_action(m_debug_action_keys[2]).state == State::active)
 			{
-				log_dbg("Deubg action 3");
 				surface.push_request(surface::ModifyResolutionRequest({ width + 5, height + 5 }));
 			}
 
 			if (input.get_action(m_debug_action_keys[3]).state == State::active)
 			{
-				log_dbg("Deubg action 4");
 				surface.push_request(surface::ModifyResolutionRequest({ width - 5, height - 5 }));
 			}
 		}
@@ -154,7 +149,7 @@ public:
 		m_surface_system = memory::create_ref<lt::surface::System>(m_editor_registry);
 
 		m_window = m_editor_registry->create_entity();
-		m_editor_registry->add<SurfaceComponent>(
+		m_surface_system->create_component(
 		    m_window,
 		    SurfaceComponent::CreateInfo {
 		        .title = "Editor Window",
@@ -217,12 +212,15 @@ public:
 		    .surface_entity = entity,
 		});
 
-		// entity.add<renderer::MessengerComponent>({
+		m_renderer_system->create_messenger_component(
-		//     .severities = renderer::MessageSeverity::all,
+		    m_window,
-		//     .types = renderer::MessageType::all,
+		    renderer::MessengerComponent::CreateInfo {
-		//     .callback = &renderer_callback,
+		        .severities = renderer::MessageSeverity::all,
-		//     .user_data = this,
+		        .types = renderer::MessageType::all,
-		// });
+		        .callback = &renderer_callback,
+		        .user_data = this,
+		    }
+		);
 	}
 
 	void setup_input_system()

modules/renderer/private/backend/vk/context/context.hpp

@@ -3,6 +3,7 @@
 #include <ecs/entity.hpp>
 #include <memory/pointer_types/null_on_move.hpp>
 #include <memory/scope.hpp>
+#include <renderer/backend/vk/context/swapchain.hpp>
 #include <renderer/frontend/context/context.hpp>
 
 namespace lt::renderer::vk {
@@ -43,7 +44,11 @@ public:
 	void recreate_swapchain() override
 	{
 		m_swapchain.reset();
-		// m_swapchain = memory::create_scope<vk::Swapchain>(m_device, m_surface);
+		m_swapchain = memory::create_scope<vk::Swapchain>(
+		    m_surface.get(),
+		    m_gpu.get(),
+		    m_device.get()
+		);
 	}
 
 private:

modules/renderer/private/backend/vk/context/swapchain.cpp

@@ -44,6 +44,7 @@ Swapchain::Swapchain(ISurface *surface, IGpu *gpu, IDevice *device)
 	        .oldSwapchain = nullptr,
 	    }
 	);
+	m_resolution = capabilities.currentExtent;
 	m_device->name(m_swapchain, "swapchain {}", idx++);
 	m_device->wait_idle();
 

modules/renderer/private/backend/vk/messenger.cpp

@@ -7,13 +7,13 @@ Messenger::Messenger(IInstance *instance, ecs::Entity entity)
     , m_entity(std::move(entity))
 
 {
-	const auto &component = entity.get<MessengerComponent>();
+	const auto &component = m_entity.get<MessengerComponent>();
 
 	m_debug_messenger = m_instance->create_messenger(
 	    VkDebugUtilsMessengerCreateInfoEXT {
 	        .sType = VK_STRUCTURE_TYPE_DEBUG_UTILS_MESSENGER_CREATE_INFO_EXT,
-	        .messageSeverity = to_native_severity(component.severities),
+	        .messageSeverity = to_native_severity(component.get_severities()),
-	        .messageType = to_native_type(component.types),
+	        .messageType = to_native_type(component.get_types()),
 	        .pfnUserCallback = &native_callback,
 	        .pUserData = this,
 	    }
@@ -43,13 +43,13 @@ Messenger::~Messenger()
 
 		auto *messenger = (Messenger *)vulkan_user_data; // NOLINT
 		auto &component = messenger->m_entity.get<MessengerComponent>();
-		component.callback(
+		component.get_callback()(
 		    from_native_severity(severity),
 		    from_native_type(type),
 		    {
 		        .message = callback_data->pMessage,
 		    },
-		    component.user_data
+		    component.get_user_data()
 		);
 	}
 	catch (const std::exception &exp)

modules/renderer/private/backend/vk/renderer/renderer.cpp

@@ -136,6 +136,7 @@ void Renderer::replace_swapchain(ISwapchain *swapchain)
 	m_device->wait_idle();
 	m_swapchain = static_cast<Swapchain *>(swapchain);
 	m_resolution = m_swapchain->get_resolution();
+	m_pass->replace_swapchain(*swapchain);
 }
 
 void Renderer::record_cmd(VkCommandBuffer cmd, uint32_t image_idx)

modules/renderer/private/frontend/messenger.cpp

@@ -13,7 +13,6 @@ namespace lt::renderer {
 	switch (target_api)
 	{
 	case API::Vulkan: return memory::create_scope<vk::Messenger>(instance, std::move(entity));
-
 	case API::Metal:
 	case API::DirectX: throw std::runtime_error { "Invalid API" };
 	}

modules/renderer/private/system.cpp

@@ -19,10 +19,6 @@ System::System(CreateInfo info)
 	ensure(m_registry, "Failed to initialize renderer system: null registry");
 
 	m_renderer = IRenderer::create(m_api, *m_context, info.config.max_frames_in_flight);
-
-	// WIP(Light): attach debug messenger on messenger component construction
-	// m_registry->connect_on_construct<renderer::MessengerComponent>([](ecs::Registry &registry,
-	//                                                                   ecs::EntityId entity) {});
 }
 
 System::~System()
@@ -62,4 +58,21 @@ void System::tick(app::TickInfo tick)
 	m_frame_idx = (m_frame_idx + 1) % m_max_frames_in_flight;
 }
 
+void System::create_messenger_component(ecs::EntityId entity, MessengerComponent::CreateInfo info)
+try
+{
+	auto &component = m_registry->add<MessengerComponent>(entity, std::move(info));
+	component.m_implementation = IMessenger::create(
+	    m_api,
+	    m_context->instance(),
+	    { m_registry, entity }
+	);
+}
+catch (const std::exception &exp)
+{
+	log_err("Failed to create renderer::MessengerComponent:");
+	log_err("\twhat: {}", exp.what());
+}
+
+
 } // namespace lt::renderer

modules/renderer/public/components/messenger.hpp

@@ -1,7 +1,9 @@
 #pragma once
 
-#include <bitwise/operations.hpp>
 #include <any>
+#include <bitwise/operations.hpp>
+#include <memory/scope.hpp>
+#include <renderer/frontend/messenger.hpp>
 
 namespace lt::renderer {
 
@@ -36,10 +38,15 @@ using Callback_T = std::function<void(
     MessageSeverity message_severity,
     MessageType message_type,
     MessengerCallbackData data,
-    std::any user_data
+    std::any &user_data
 )>;
 
-struct MessengerComponent
+class MessengerComponent
+{
+public:
+	friend class System;
+
+	struct CreateInfo
 	{
 		MessageSeverity severities;
 
@@ -50,4 +57,44 @@ struct MessengerComponent
 		std::any user_data;
 	};
 
+	[[nodiscard]] auto get_severities() const -> MessageSeverity
+	{
+		return m_severities;
+	}
+
+	[[nodiscard]] auto get_types() const -> MessageType
+	{
+		return m_types;
+	}
+
+	[[nodiscard]] auto get_callback() const -> const Callback_T &
+	{
+		return m_callback;
+	}
+
+	[[nodiscard]] auto get_user_data() -> std::any &
+	{
+		return m_user_data;
+	}
+
+private:
+	MessengerComponent(CreateInfo info)
+	    : m_severities(info.severities)
+	    , m_types(info.types)
+	    , m_callback(std::move(info.callback))
+	    , m_user_data(std::move(info.user_data))
+	{
+	}
+
+	MessageSeverity m_severities;
+
+	MessageType m_types;
+
+	Callback_T m_callback;
+
+	std::any m_user_data;
+
+	memory::Scope<IMessenger> m_implementation;
+};
+
 } // namespace lt::renderer

modules/renderer/public/system.hpp

@@ -6,6 +6,7 @@
 #include <memory/reference.hpp>
 #include <memory/scope.hpp>
 #include <renderer/api.hpp>
+#include <renderer/components/messenger.hpp>
 
 namespace lt::renderer {
 
@@ -46,6 +47,8 @@ public:
 
 	void tick(app::TickInfo tick) override;
 
+	void create_messenger_component(ecs::EntityId entity, MessengerComponent::CreateInfo info);
+
 	[[nodiscard]] auto get_last_tick_result() const -> const app::TickResult & override
 	{
 		return m_last_tick_result;
@@ -62,8 +65,6 @@ private:
 
 	memory::Scope<class IRenderer> m_renderer;
 
-	std::vector<memory::Scope<class IMessenger>> m_messengers;
-
 	app::TickResult m_last_tick_result {};
 
 	uint32_t m_frame_idx {};

modules/surface/private/linux/system.cpp

@@ -54,12 +54,6 @@ System::System(memory::Ref<ecs::Registry> registry): m_registry(std::move(regist
 	    "Failed to initialize surface system: registry has surface component(s)"
 	);
 
-	m_registry->connect_on_construct<SurfaceComponent>(
-	    [this](ecs::Registry &registry, ecs::EntityId entity) {
-		    on_surface_construct(registry, entity);
-	    }
-	);
-
 	m_registry->connect_on_destruct<SurfaceComponent>(
 	    [this](ecs::Registry &registry, ecs::EntityId entity) {
 		    on_surface_destruct(registry, entity);
@@ -106,11 +100,12 @@ void System::on_unregister()
 {
 }
 
-void System::on_surface_construct(ecs::Registry &registry, ecs::EntityId entity)
+auto System::create_component(ecs::EntityId entity, SurfaceComponent::CreateInfo info)
-{
+    -> std::optional<SurfaceComponent *>
 try
 {
-		auto &surface = registry.get<SurfaceComponent>(entity);
+	auto &component = m_registry->add<SurfaceComponent>(entity, info);
+	auto &surface = m_registry->get<SurfaceComponent>(entity);
 	const auto &resolution = surface.get_resolution();
 	const auto &position = surface.get_position();
 	ensure_component_sanity(surface);
@@ -188,15 +183,16 @@ void System::on_surface_construct(ecs::Registry &registry, ecs::EntityId entity)
 	{
 		XUnmapWindow(display, main_window);
 	}
+
+	return &component;
 }
 catch (const std::exception &exp)
 {
 	log_err("Exception thrown when on_constructing surface component");
 	log_err("\tentity: {}", entity);
 	log_err("\twhat: {}", exp.what());
-		registry.remove<SurfaceComponent>(entity);
+	m_registry->remove<SurfaceComponent>(entity);
-		throw;
+	return {};
-	}
 }
 
 void System::on_surface_destruct(ecs::Registry &registry, ecs::EntityId entity)
@@ -285,7 +281,6 @@ void System::handle_events(SurfaceComponent &surface)
 			const auto new_height = event.xconfigure.height;
 			if (prev_width != new_width || prev_height != new_height)
 			{
-				log_dbg("resized: {} - {}", new_width, new_height);
 				surface.m_resolution.x = new_width;
 				surface.m_resolution.y = new_height;
 				queue.emplace_back<ResizedEvent>(ResizedEvent {
@@ -342,7 +337,7 @@ void System::modify_title(SurfaceComponent &surface, const ModifyTitleRequest &r
 
 void System::modify_resolution(SurfaceComponent &surface, const ModifyResolutionRequest &request)
 {
-	surface.m_resolution = request.resolution;
+	// surface.m_resolution = request.resolution;
 
 	auto &[display, window, _] = surface.m_native_data;
 	const auto &[width, height] = request.resolution;

modules/surface/public/components.hpp

@@ -13,7 +13,10 @@ typedef struct _XDisplay Display;
 
 namespace lt::surface {
 
-/** Represents a platform's surface (eg. a Window). */
+/** Represents a platform's surface (eg. a Window).
+ *
+ * @note This is a "system component"
+ */
 class SurfaceComponent
 {
 public:
@@ -66,15 +69,6 @@ public:
 		bool visible;
 	};
 
-	SurfaceComponent(const CreateInfo &info)
-	    : m_title(info.title)
-	    , m_resolution(info.resolution)
-	    , m_vsync(info.vsync)
-	    , m_visible(info.visible)
-	    , m_native_data({})
-	{
-	}
-
 	[[nodiscard]] auto get_title() const -> std::string_view
 	{
 		return m_title;
@@ -127,6 +121,15 @@ public:
 	}
 
 private:
+	SurfaceComponent(const CreateInfo &info)
+	    : m_title(info.title)
+	    , m_resolution(info.resolution)
+	    , m_vsync(info.vsync)
+	    , m_visible(info.visible)
+	    , m_native_data({})
+	{
+	}
+
 	std::string m_title;
 
 	math::uvec2 m_resolution;

modules/surface/public/system.hpp

@@ -4,6 +4,7 @@
 #include <ecs/registry.hpp>
 #include <math/vec2.hpp>
 #include <memory/reference.hpp>
+#include <surface/components.hpp>
 
 namespace lt::surface {
 
@@ -26,6 +27,9 @@ public:
 
 	void on_unregister() override;
 
+	auto create_component(ecs::EntityId entity, SurfaceComponent::CreateInfo info)
+	    -> std::optional<SurfaceComponent *>;
+
 	void tick(app::TickInfo tick) override;
 
 	[[nodiscard]] auto get_last_tick_result() const -> const app::TickResult & override
@@ -34,8 +38,6 @@ public:
 	}
 
 private:
-	void on_surface_construct(ecs::Registry &registry, ecs::EntityId entity);
-
 	void on_surface_destruct(ecs::Registry &registry, ecs::EntityId entity);
 
 	void handle_requests(struct SurfaceComponent &surface);