1 files changed, 65 insertions, 0 deletions
diff --git a/kernel/kapi/devices/bus.cpp b/kernel/kapi/devices/bus.cpp
new file mode 100644
index 0000000..68874c4
--- /dev/null
+++ b/kernel/kapi/devices/bus.cpp
@@ -0,0 +1,65 @@
+#include "kapi/devices/bus.hpp"
+
+#include "kapi/devices.hpp"
+#include "kapi/system.hpp"
+
+#include <kstd/memory>
+#include <kstd/print>
+#include <kstd/string>
+#include <kstd/vector>
+
+#include <algorithm>
+#include <cstddef>
+#include <utility>
+
+namespace kapi::devices
+{
+  bus::bus(std::size_t major, std::size_t minor, kstd::string const & name)
+      : device(major, minor, name)
+  {}
+
+  auto bus::init() -> bool
+  {
+    if (m_initialized.test_and_set())
+    {
+      return true;
+    }
+
+    if (!probe())
+    {
+      return false;
+    }
+
+    return std::ranges::fold_left(m_devices, true, [&](bool acc, auto & child) -> bool {
+      kstd::println("[OS:DEV] Initializing child device {}@{}", child->name(), name());
+      return child->init() && acc;
+    });
+  }
+
+  auto bus::add_child(kstd::unique_ptr<device> child) -> void
+  {
+    auto observer = m_observers.emplace_back(child.get());
+    m_devices.push_back(std::move(child));
+    kapi::devices::register_device(*observer);
+
+    if (m_initialized.test())
+    {
+      kstd::println("[OS:DEV] Initializing child device {}@{}", observer->name(), name());
+      if (!observer->init())
+      {
+        kapi::system::panic("[OS:DEV] Failed to initialize child device");
+      }
+    }
+  }
+
+  [[nodiscard]] auto bus::children() const -> kstd::vector<kstd::observer_ptr<device>> const &
+  {
+    return m_observers;
+  }
+
+  auto bus::probe() -> bool
+  {
+    return true;
+  }
+
+}  // namespace kapi::devices
+\ No newline at end of file