diff --git a/CMakeLists.txt b/CMakeLists.txt
index 93cec82..838c590 100644
--- a/CMakeLists.txt
+++ b/CMakeLists.txt
@@ -31,22 +31,18 @@ FetchContent_Declare(clopts
 )
 FetchContent_MakeAvailable(clopts)
 
-# Find all the modules
+message(STATUS "Looking for files")
 file(GLOB_RECURSE modules src/*.cppm)
-# Create the executable target
-add_executable(ffmpegraph)
-# Main file
-target_sources(ffmpegraph
-  PUBLIC
-    src/main.cpp
-)
-# The modules
-target_sources(ffmpegraph
-  PUBLIC
-  FILE_SET CXX_MODULES FILES
-    ${modules}
+file(GLOB_RECURSE headers src/*.hpp)
+file(GLOB_RECURSE impls   src/*.cpp)
+
+message(STATUS "Create target")
+add_executable(ffmpegraph ${impls})
+target_sources(ffmpegraph PUBLIC
+    FILE_SET CXX_MODULES FILES ${modules}
+    FILE_SET HEADERS     FILES ${headers}
 )
-#Compile flags
+
 target_compile_options(ffmpegraph PRIVATE
         -Wall -Wextra # Standard screaming
         -Wconversion -Wsign-conversion # Scream about accidentally converting stuff
@@ -55,13 +51,12 @@ target_compile_options(ffmpegraph PRIVATE
         $<$<CONFIG:DEBUG>:-O0 -g3 -glldb>
         $<$<CONFIG:RELEASE>:-O3 -march=native>
 )
-# color shit out
+
 if (CMAKE_CXX_COMPILER_ID STREQUAL "GNU")
     target_compile_options(ffmpegraph PRIVATE -fdiagnostics-color=always)
 elseif (CMAKE_CXX_COMPILER_ID STREQUAL "Clang")
     target_compile_options(ffmpegraph PRIVATE -fcolor-diagnostics)
 endif()
 
-# Link against exernal libraries
 target_link_libraries(ffmpegraph PRIVATE raylib m)
 target_include_directories(ffmpegraph PRIVATE "${CMAKE_CURRENT_BINARY_DIR}/libs/clopts/include")
diff --git a/src/Application.cppm b/src/Application.cppm
index b07a86d..6a7510c 100644
--- a/src/Application.cppm
+++ b/src/Application.cppm
@@ -1,6 +1,9 @@
 module;
+#include "macros.hpp"
+
 #include <algorithm>
 #include <cmath>
+#include <deque>
 #include <memory>
 #include <print>
 #include <ranges>
@@ -9,7 +12,6 @@ module;
 #include <unordered_map>
 #include <unordered_set>
 #include <vector>
-#include <deque>
 export module Application;
 import Node;
 import Base;
@@ -30,7 +32,7 @@ protected:
     void OnLeftClick();
     void OnKeyPressed(i32 key);
     void Render();
-    void ExecuteGraph();
+    Result<> ExecuteGraph();
     std::deque<std::string> message_queue;
     std::string title;
     bool should_close;
@@ -38,6 +40,14 @@ protected:
     Node *selected_node = nullptr;
     OutputPort *selected_port = nullptr;
     Button run_button;
+    enum class State {
+        DEFAULT,
+        CONNECTING,
+        EDITING,
+        ADDING,
+    } current_state = State::DEFAULT;
+
+    std::vector<Button> add_buttons;
     u64 framecounter = 0;
 };
 }    // namespace ffmpegraph
@@ -50,19 +60,16 @@ Application::Application(std::string _title)
     InitWindow(800, 600, this->title.c_str());
     SetTargetFPS(60);
     SetExitKey(KEY_NULL);
+    add_buttons.emplace_back(10, 10, 100, 20, "String Constant");
+    add_buttons.emplace_back(10, 35, 100, 20, "Input File");
+    add_buttons.emplace_back(10, 60, 100, 20, "Output File");
+    add_buttons.emplace_back(10, 85 , 100, 20, "Stream Spec Constant");
 
-    nodes.push_back(std::make_unique<InputNode>());
-    nodes.push_back(std::make_unique<StringConstantNode>());
-    nodes.push_back(std::make_unique<InputNode>());
-    nodes[0]->pos_x = 400;
-    nodes[0]->pos_y = 10;
-    nodes[1]->pos_x = 200;
-    nodes[1]->pos_y = 100;
     run_button.width = 10 + MeasureText("Run", 10);
 }
 
 void Application::Tick() {
-    if (selected_node) {
+    if (current_state == State::EDITING) {
         selected_node->pos_x = GetMouseX();
         selected_node->pos_y = GetMouseY();
     }
@@ -75,6 +82,20 @@ void Application::ProcessEvents() {
 }
 
 void Application::OnLeftClick() {
+    if (current_state == State::ADDING) {
+        if (add_buttons[0].IsHovered()) {
+            nodes.push_back(std::make_unique<StringConstantNode>());
+        } else if (add_buttons[1].IsHovered()) {
+            nodes.push_back(std::make_unique<InputNode>());
+        } else if (add_buttons[2].IsHovered()) {
+            nodes.push_back(std::make_unique<OutputNode>());
+        } else if (add_buttons[3].IsHovered()) {
+            nodes.push_back(std::make_unique<StreamSpecConstantNode>());
+        }
+        current_state = State::DEFAULT;
+        return;
+    }
+
     auto GetPort = [&] -> Port * {
         for (auto &node : nodes) {
             for (auto *port : node->ports) {
@@ -85,15 +106,19 @@ void Application::OnLeftClick() {
         }
         return nullptr;
     };
-    if (selected_node) {
+    if (current_state == State::EDITING) {
         selected_node = nullptr;
-    } else if (selected_port) {
+        current_state = State::DEFAULT;
+    } else if (current_state == State::CONNECTING) {
         auto port = GetPort();
         auto iport = dynamic_cast<InputPort *>(port);
         if (iport) { selected_port->TryConnect(*iport); }
         selected_port = nullptr;
+        current_state = State::DEFAULT;
     } else if (run_button.IsHovered()) {
-        ExecuteGraph();
+        if (auto res = ExecuteGraph(); not res) {
+            message_queue.push_front(res.error());
+        }
     } else {
         i32 x = GetMouseX();
         i32 y = GetMouseY();
@@ -103,6 +128,7 @@ void Application::OnLeftClick() {
             if (oport->GetConnected()) {
                 oport->Disconnect();
             } else {
+                current_state = State::CONNECTING;
                 selected_port = oport;
             }
         } else {
@@ -110,6 +136,7 @@ void Application::OnLeftClick() {
                 if (node->pos_x < x and x < node->pos_x + node->Width() and node->pos_y < y
                     and y < node->pos_y + node->Height()) {
                     selected_node = node.get();
+                    current_state = State::EDITING;
                     break;
                 }
             }
@@ -117,7 +144,7 @@ void Application::OnLeftClick() {
     }
 }
 
-void Application::ExecuteGraph() {
+Result<> Application::ExecuteGraph() {
     std::unordered_map<Node *, isz> index_map;
     std::unordered_map<isz, std::unordered_set<isz>> adj_list;
     for (auto [i, node] : vws::enumerate(nodes)) {
@@ -132,41 +159,87 @@ void Application::ExecuteGraph() {
         if (auto n = dynamic_cast<StringConstantNode *>(raw_node)) {
             if (auto c = n->out.GetConnected()) { adj_list[index_map[c->owner]].insert(index_map[raw_node]); }
         }
-        // TODO add cases for all new types of nodes
+        if (auto _ = dynamic_cast<OutputNode *>(raw_node)) {}
+        // OutputNode doesn’t have output ports.
     }
 
+    // TODO add cases for all new types of nodes
+
     std::vector<Node *> sorted_nodes;
     while (not adj_list.empty()) {
         bool changed = false;
         for (auto &[i, incoming] : adj_list) {
             if (incoming.empty()) {
                 sorted_nodes.push_back(nodes[usz(i)].get());
-                for (auto &[_, thing] : adj_list) { thing.erase(i); }
+                for (auto &thing : adj_list | vws::values) { thing.erase(i); }
                 adj_list.erase(i);
                 changed = true;
                 break;
             }
         }
         if (not changed) {
-            message_queue.push_back("ERROR: Graph has cycle");
-            return;
+            return Error("Graph has cycle");
         }
     }
-    for (auto node : sorted_nodes) {
-        node->Run();
-    }
+    for (auto node : sorted_nodes) { Try(node->Run()); }
+    return{};
 }
 
 void Application::OnKeyPressed(i32 key) {
+    if ((key == KEY_EQUAL or key == KEY_KP_ADD) and current_state == State::DEFAULT) {
+        current_state = State::ADDING;
+    }
+    if (current_state != State::EDITING) return;
+    if (key == KEY_DELETE) {
+        for(auto& node : nodes) {
+            for (auto raw_port: node->ports) {
+                if (auto port = dynamic_cast<OutputPort*>(raw_port)) {
+                    if (auto a = port->GetConnected(); a and a->owner == selected_node) {
+                        port->Disconnect();
+                    }
+                }
+            }
+        }
+        std::erase_if(nodes, [&](auto const &it) { return it.get() == selected_node; });
+        selected_node = nullptr;
+        current_state = State::DEFAULT;
+        return;
+    }
     auto selected = dynamic_cast<StringConstantNode *>(selected_node);
     if (not selected) return;
-    if (key == KEY_ENTER) {
+    if (key == KEY_ENTER or key == KEY_KP_ENTER) {
         selected_node = nullptr;
+        current_state = State::DEFAULT;
     } else if (key == KEY_BACKSPACE) {
         if (not selected->in.data.empty()) selected->in.data.pop_back();
     } else if (0x20 <= key and key <= 0x7E) {
         if (not IsKeyDown(KEY_LEFT_SHIFT) and not IsKeyDown(KEY_RIGHT_SHIFT) and 'A' <= key and key <= 'Z') {
             key += 32;
+        } else if (IsKeyDown(KEY_LEFT_SHIFT) or IsKeyDown(KEY_RIGHT_SHIFT)) {
+            switch (key) {
+                case KEY_GRAVE: key = '~'; break;
+                case KEY_ONE: key = '!'; break;
+                case KEY_TWO: key = '"'; break;
+                case KEY_THREE: key = '#'; break;
+                case KEY_FOUR: key = '$'; break;
+                case KEY_FIVE: key = '%'; break;
+                case KEY_SIX: key = '^'; break;
+                case KEY_SEVEN: key = '&'; break;
+                case KEY_EIGHT: key = '*'; break;
+                case KEY_NINE: key = '('; break;
+                case KEY_ZERO: key = ')'; break;
+                case KEY_MINUS: key = '_'; break;
+                case KEY_EQUAL: key = '+'; break;
+                case KEY_LEFT_BRACKET: key = '{'; break;
+                case KEY_RIGHT_BRACKET: key = '}'; break;
+                case KEY_SEMICOLON: key = ':'; break;
+                case KEY_APOSTROPHE: key = '"'; break;
+                case KEY_BACKSLASH: key = '|'; break;
+                case KEY_COMMA: key = '<'; break;
+                case KEY_PERIOD: key = '>'; break;
+                case KEY_SLASH: key = '?'; break;
+                default:;
+            }
         }
         selected->in.data += char(key);
     }
@@ -174,22 +247,25 @@ void Application::OnKeyPressed(i32 key) {
 
 void Application::Render() {
     framecounter++;
-    if (not (framecounter%300) and not message_queue.empty()) {
-        message_queue.pop_back();
-    }
+    if (not(framecounter % 300) and not message_queue.empty()) { message_queue.pop_back(); }
     BeginDrawing();
     ClearBackground(RAYWHITE);
     message_queue.resize(std::min(message_queue.size(), usz(10)));
     i32 offset = 15;
-    for (auto& message: message_queue) {
+    for (auto &message : message_queue) {
         DrawText(message.c_str(), 5, GetScreenHeight() - offset, 10, RED);
         offset += 20;
     }
-    if (selected_port) { DrawLine(selected_port->pos_x, selected_port->pos_y, GetMouseX(), GetMouseY(), BLACK); }
-    for (auto &node : nodes) { node->Render(); }
-    run_button.Render();
+    if (current_state == State::ADDING) {
+        for (auto b : add_buttons) {
+            b.Render();
+        }
+    } else {
+        if (selected_port) { DrawLine(selected_port->pos_x, selected_port->pos_y, GetMouseX(), GetMouseY(), BLACK); }
+        for (auto &node : nodes) { node->Render(); }
+        run_button.Render();
+    }
     EndDrawing();
-
 }
 
 void Application::Run() {
diff --git a/src/Base.cppm b/src/Base.cppm
index e8631d0..47f55b4 100644
--- a/src/Base.cppm
+++ b/src/Base.cppm
@@ -1,5 +1,6 @@
 module;
 #include <cstdint>
+#include <expected>
 #include <format>
 #include <ranges>
 #include <string>
@@ -8,40 +9,48 @@ module;
 #include <unordered_set>
 #include <vector>
 export module Base;
+export {
+namespace rgs = std::ranges;
+namespace vws = std::views;
 
-export namespace rgs = std::ranges;
-export namespace vws = std::views;
+using u8 = std::uint8_t;
+using u16 = std::uint16_t;
+using u32 = std::uint32_t;
+using u64 = std::uint64_t;
+using usz = std::size_t;
+using uptr = std::uintptr_t;
 
-export using u8 = std::uint8_t;
-export using u16 = std::uint16_t;
-export using u32 = std::uint32_t;
-export using u64 = std::uint64_t;
-export using usz = std::size_t;
-export using uptr = std::uintptr_t;
+using i8 = std::int8_t;
+using i16 = std::int16_t;
+using i32 = std::int32_t;
+using i64 = std::int64_t;
+using isz = std::make_signed_t<std::size_t>;
+using iptr = std::intptr_t;
 
-export using i8 = std::int8_t;
-export using i16 = std::int16_t;
-export using i32 = std::int32_t;
-export using i64 = std::int64_t;
-export using isz = std::make_signed_t<std::size_t>;
-export using iptr = std::intptr_t;
+using f32 = float;
+using f64 = double;
 
-export using f32 = float;
-export using f64 = double;
+using Unit = std::monostate;
 
-export namespace utils {
+template <class... Args>
+[[nodiscard]] auto Error(std::format_string<Args...> fmt, Args&&... args) -> std::unexpected<std::string> {
+    return std::unexpected(std::format(fmt, std::forward<Args>(args)...));
+}
+template <class T = void> using Result = std::expected<T, std::string>;
+namespace utils {
 template <typename... Types> struct Overloaded : Types... {
     using Types::operator()...;
 };
 template <typename... Types> Overloaded(Types...) -> Overloaded<Types...>;
 }
+}
 
 template <class T> struct std::formatter<std::vector<T>> : std::formatter<std::string> {
     template <class FormatContext> auto format(std::vector<T> const& data, FormatContext& ctx) const {
         std::string repr = "[";
         bool first = true;
         for (auto& el : data) {
-            repr += std::format("{}{}",first ? "" : ", ", el);
+            repr += std::format("{}{}", first ? "" : ", ", el);
             first = false;
         }
         repr += "]";
diff --git a/src/Node.cppm b/src/Node.cppm
index 482ea84..a105607 100644
--- a/src/Node.cppm
+++ b/src/Node.cppm
@@ -1,4 +1,5 @@
 module;
+#include <print>
 #include <raylib.h>
 #include <string>
 #include <vector>
@@ -10,12 +11,22 @@ export namespace ffmpegraph {
 
 struct Node {
     virtual ~Node() = default;
-    void Render();
-    i32 Width() const;
-    i32 Height() const;
+    void Render() {
+        i32 port_y = pos_y;
+        DrawRectangle(pos_x, pos_y, Width(), Height(), WHITE);
+        i32 new_width = min_port_width;
+        for (auto* port : ports) {
+            new_width = std::max(port->Render(pos_x, port_y, width), new_width);
+            port_y += 20;
+        }
+        width = new_width;
+    }
+    i32 Width() const { return width; }
+    i32 Height() const { return 20 * i32(ports.size()); }
     i32 pos_x{}, pos_y{};
     std::vector<Port*> ports;
-    virtual void Run() = 0;
+    virtual Result<> Run() = 0;
+    virtual void OnDisconnect() {}
 protected:
     i32 width = min_port_width;
 };
@@ -24,7 +35,15 @@ struct InputNode : Node {
     Label label;
     InputPort filename_port;
     OutputPort output_port;
-    void Run() override;
+    Result<> Run() override;
+};
+
+struct OutputNode : Node {
+    OutputNode();
+    Result<> Run() override;
+    Label label;
+    InputPort in_data;
+    InputPort in_filename;
 };
 
 struct StringConstantNode : Node {
@@ -32,48 +51,19 @@ struct StringConstantNode : Node {
     Label label;
     StringUserInput in;
     OutputPort out;
-    void Run() override;
+    Result<> Run() override;
 };
 
-}
-
-module :private;
-
-namespace ffmpegraph {
-
-i32 Node::Width() const { return width; }
-i32 Node::Height() const { return 20 * i32(ports.size()); }
-
-InputNode::InputNode()
-    : label("Input", this), filename_port("filename", this, PortType::STRING), output_port("output", this, PortType::STRING) {
-    ports.emplace_back(&label);
-    ports.emplace_back(&filename_port);
-    ports.emplace_back(&output_port);
-}
-
-void InputNode::Run() {
-    output_port.SetValue(filename_port.GetValue());
-}
-
-StringConstantNode::StringConstantNode() : label("String Constant", this), in("Text", this), out("Output", this, PortType::STRING) {
-    ports.emplace_back(&label);
-    ports.emplace_back(&in);
-    ports.emplace_back(&out);
-}
+struct StreamSpecConstantNode : Node {
+    StreamSpecConstantNode();
+    Result<> Run() override;
+    Label label;
+    StringUserInput in;
+    OutputPort out;
+};
 
-void StringConstantNode::Run() {
-    out.SetValue(in.data);
-}
+struct SplitterNode : Node {
 
+};
 
-void Node::Render() {
-    i32 port_y = pos_y;
-    DrawRectangle(pos_x, pos_y, Width(), Height(), WHITE);
-    i32 new_width = min_port_width;
-    for (auto* port : ports) {
-        new_width = std::max(port->Render(pos_x, port_y, width), new_width);
-        port_y += 20;
-    }
-    width = new_width;
 }
-}    // namespace ffmpegraph
diff --git a/src/Nodes/InputNode.cpp b/src/Nodes/InputNode.cpp
new file mode 100644
index 0000000..cbceccf
--- /dev/null
+++ b/src/Nodes/InputNode.cpp
@@ -0,0 +1,21 @@
+module;
+#include <format>
+#include <variant>
+module Node;
+using namespace ffmpegraph;
+
+InputNode::InputNode()
+    : label("Input File", this)
+    , filename_port("Filename", this, PortTypeE::STRING)
+    , output_port("Out", this, PortTypeE::STRING) {
+    ports.push_back(&label);
+    ports.push_back(&filename_port);
+    ports.push_back(&output_port);
+}
+
+Result<> InputNode::Run() {
+    auto data = std::get_if<std::string>(&filename_port.GetValue());
+    if (not data or data->empty()) return Error("File Input needs a filename ");
+    output_port.SetValue(std::format("-i {}", *data));
+    return {};
+}
diff --git a/src/Nodes/OutputNode.cpp b/src/Nodes/OutputNode.cpp
new file mode 100644
index 0000000..6ba22a2
--- /dev/null
+++ b/src/Nodes/OutputNode.cpp
@@ -0,0 +1,20 @@
+module;
+#include <variant>
+module Node;
+using namespace ffmpegraph;
+
+OutputNode::OutputNode()
+    : label("File Output", this)
+    , in_data("Data", this, PortTypeE::STRING)
+    , in_filename("File", this, PortTypeE::STRING) {
+    ports.push_back(&label);
+    ports.push_back(&in_data);
+    ports.push_back(&in_filename);
+}
+Result<> OutputNode::Run() {
+    auto data = std::get_if<std::string>(&in_data.GetValue());
+    if (not data) return {};
+    auto fname = std::get_if<std::string>(&in_filename.GetValue());
+    auto path = fname and not fname->empty() ? std::string_view{*fname} : "/tmp/ffmpegraph_out";
+    return Error("ffmpeg {} {}", *data, path);
+}
\ No newline at end of file
diff --git a/src/Nodes/StreamSpecConstantNode.cpp b/src/Nodes/StreamSpecConstantNode.cpp
new file mode 100644
index 0000000..2ee2ce5
--- /dev/null
+++ b/src/Nodes/StreamSpecConstantNode.cpp
@@ -0,0 +1,34 @@
+module Node;
+using namespace ffmpegraph;
+
+StreamSpecConstantNode::StreamSpecConstantNode()
+    : label("Stream Specifier Constant", this), in("Stream Specifier", this), out("Out", this, PortTypeE::STREAM_SPEC) {
+    ports.push_back(&label);
+    ports.push_back(&in);
+    ports.push_back(&out);
+}
+Result<> StreamSpecConstantNode::Run() {
+    // TODO validate that
+    //  <stream_specifier> →
+    //      <index>
+    //      [vVasdt](:<stream_specifier>)?
+    //      g:<group_specifier>(:<stream_specifier>)?
+    //      p:<id>(:<stream_specifier>)?
+    //      #<id>
+    //      i:<id>
+    //      m:<id>(:<id>)?
+    //      disp:<dispositions>(:<stream_specifier>)?
+    //      u
+    //  <index> → [1-9][0-9]*
+    //  <group_specifier> →
+    //      <index>
+    //      #<id>
+    //      i:<id>
+    //  <id> → [a-zA-Z0-9_-]+
+    //  <dispositions> →
+    //      <id>
+    //      <dispositions>+<id>
+
+    out.SetValue(in.data);
+    return {};
+}
diff --git a/src/Nodes/StringConstantNode.cpp b/src/Nodes/StringConstantNode.cpp
new file mode 100644
index 0000000..6029bee
--- /dev/null
+++ b/src/Nodes/StringConstantNode.cpp
@@ -0,0 +1,13 @@
+module Node;
+using namespace ffmpegraph;
+
+StringConstantNode::StringConstantNode()
+    : label("String Constant", this), in("Text", this), out("Out", this, PortTypeE::STRING) {
+    ports.push_back(&label);
+    ports.push_back(&in);
+    ports.push_back(&out);
+}
+Result<> StringConstantNode::Run() {
+    out.SetValue(in.data);
+    return {};
+}
diff --git a/src/Port.cppm b/src/Port.cppm
index 12ea0ba..7e2e0b0 100644
--- a/src/Port.cppm
+++ b/src/Port.cppm
@@ -1,21 +1,45 @@
 module;
 #include <format>
 #include <limits>
-#include <raylib.h>
 #include <string>
 #include <variant>
 export module Node:Port;
 import Base;
 using namespace std::literals;
 export namespace ffmpegraph {
-
 struct Node;
-
-enum struct PortType {
+enum struct PortTypeE {
+    GENERIC,
     INT,
     STRING,
+    STREAM_SPEC
+};
+
+struct PortType {
+    PortType(PortTypeE t): t(t) {}
+    friend bool operator==(PortType a, PortType b) = default;
+    friend struct std::formatter<PortType>;
+protected:
+    PortTypeE t;
 };
+}
 
+template <> struct std::formatter<ffmpegraph::PortType> : std::formatter<std::string_view> {
+    template <class FormatContext> auto format(ffmpegraph::PortType data, FormatContext& ctx) const {
+        auto s = [data] -> string_view {
+            switch (data.t) {
+                case ffmpegraph::PortTypeE::INT: return "integer";
+                case ffmpegraph::PortTypeE::STREAM_SPEC: return "stream spec";
+                case ffmpegraph::PortTypeE::STRING: return "string";
+                case ffmpegraph::PortTypeE::GENERIC: return "any";
+                default: return "unknown_type";
+            }
+        }();
+        return formatter<std::string_view>::format(s, ctx);
+    }
+};
+
+export namespace ffmpegraph {
 constexpr i32 min_port_width = 100;
 using PortData = std::variant<i32, std::string, std::monostate>;
 }
@@ -75,7 +99,7 @@ public:
 
 struct Label : Port {
     i32 Render(i32 x, i32 y, i32 width) override;
-    explicit Label(std::string name, Node* owner) : Port(std::move(name), owner) {
+    Label(std::string name, Node* owner) : Port(std::move(name), owner) {
         pos_x = pos_y = std::numeric_limits<i32>::min();
     }
 };
@@ -87,55 +111,10 @@ struct StringUserInput : Port {
     i32 Render(i32 x, i32 y, i32 width) override;
     std::string data;
 };
+};
 
-PortData const& InputPort::GetValue() const { return value; }
+namespace ffmpegraph{
 
-void OutputPort::SetValue(PortData value) {
-    if (connected) { connected->value = std::move(value); }
-}
-bool OutputPort::TryConnect(InputPort& ip) {
-    if (ip.type == type) {
-        connected = &ip;
-        return true;
-    }
-    return false;
 }
 
-void OutputPort::Disconnect() { connected = nullptr; }
 
-i32 OutputPort::Render(i32 x, i32 y, i32 width) {
-    pos_x = x + width;
-    pos_y = y + 10;
-    DrawRectangleLines(x, y, width, 20, BLACK);
-    DrawText(name.c_str(), x + 5, y + 5, 10, RED);
-    DrawCircle(x + width, y + 10, 2.5f, BLACK);
-    if (connected) { DrawLine(pos_x, pos_y, connected->pos_x, connected->pos_y, BLUE); }
-    return 10 + MeasureText(name.c_str(), 10);
-}
-i32 InputPort::Render(i32 x, i32 y, i32 width) {
-    pos_x = x;
-    pos_y = y + 10;
-    auto formatted = std::format("{}: {}", name, value);
-    auto new_width = 10 + MeasureText(formatted.c_str(), 10);
-    DrawRectangleLines(x, y, width, 20, BLACK);
-    DrawText(formatted.c_str(), x + 5, y + 5, 10, BLUE);
-    DrawCircle(x, y + 10, 2.5f, BLACK);
-    return new_width;
-}
-i32 Label::Render(i32 x, i32 y, i32 width) {
-    DrawRectangleLines(x, y, width, 20, BLACK);
-    DrawText(name.c_str(), x + 5, y + 5, 10, BLACK);
-    return 10 + MeasureText(name.c_str(), 10);
-}
-
-i32 StringUserInput::Render(i32 x, i32 y, i32 width) {
-    DrawRectangleLines(x, y, width, 20, BLACK);
-    if (data.empty()) {
-        DrawText(name.c_str(), x + 5, y + 5, 10, GRAY);
-        return 10 + MeasureText(name.c_str(), 10);
-    } else {
-        DrawText(data.c_str(), x + 5, y + 5, 10, BLACK);
-        return 10 + MeasureText(data.c_str(), 10);
-    }
-}
-}    // namespace ffmpegraph
diff --git a/src/Ports/InputPort.cpp b/src/Ports/InputPort.cpp
new file mode 100644
index 0000000..9aeed16
--- /dev/null
+++ b/src/Ports/InputPort.cpp
@@ -0,0 +1,21 @@
+module;
+#include <raylib.h>
+#include <format>
+module Node;
+using namespace ffmpegraph;
+
+PortData const& InputPort::GetValue() const { return value; }
+i32 InputPort::Render(i32 x, i32 y, i32 width) {
+    pos_x = x;
+    pos_y = y + 10;
+    auto formatted = std::format("{}: {}", name, type);
+    DrawRectangleLines(x, y, width, 20, BLACK);
+    DrawText(formatted.c_str(), x + 5, y + 5, 10, BLUE);
+    DrawCircle(x, y + 10, 2.5f, BLACK);
+    return 10 + MeasureText(formatted.c_str(), 10);
+}
+i32 Label::Render(i32 x, i32 y, i32 width) {
+    DrawRectangleLines(x, y, width, 20, BLACK);
+    DrawText(name.c_str(), x + 5, y + 5, 10, BLACK);
+    return 10 + MeasureText(name.c_str(), 10);
+}
diff --git a/src/Ports/OutputPort.cpp b/src/Ports/OutputPort.cpp
new file mode 100644
index 0000000..e791d94
--- /dev/null
+++ b/src/Ports/OutputPort.cpp
@@ -0,0 +1,32 @@
+module;
+#include <raylib.h>
+#include <format>
+module Node;
+using namespace ffmpegraph;
+
+void OutputPort::SetValue(PortData value) {
+    if (connected) { connected->value = std::move(value); }
+}
+bool OutputPort::TryConnect(InputPort& ip) {
+    if (ip.type == type) {
+        connected = &ip;
+        return true;
+    }
+    return false;
+}
+void OutputPort::Disconnect() {
+    if (connected) {
+        connected->owner->OnDisconnect();
+    }
+    connected = nullptr;
+}
+i32 OutputPort::Render(i32 x, i32 y, i32 width) {
+    pos_x = x + width;
+    pos_y = y + 10;
+    auto formatted = std::format("{}: {}", name, type);
+    DrawRectangleLines(x, y, width, 20, BLACK);
+    DrawText(formatted.c_str(), x + 5, y + 5, 10, RED);
+    if (type != PortTypeE::GENERIC) DrawCircle(x + width, y + 10, 2.5f, BLACK);
+    if (connected) { DrawLine(pos_x, pos_y, connected->pos_x, connected->pos_y, BLUE); }
+    return 10 + MeasureText(formatted.c_str(), 10);
+}
\ No newline at end of file
diff --git a/src/Ports/StringUserInput.cpp b/src/Ports/StringUserInput.cpp
new file mode 100644
index 0000000..03c936a
--- /dev/null
+++ b/src/Ports/StringUserInput.cpp
@@ -0,0 +1,15 @@
+module;
+#include <raylib.h>
+module Node;
+using namespace ffmpegraph;
+
+i32 StringUserInput::Render(i32 x, i32 y, i32 width) {
+    DrawRectangleLines(x, y, width, 20, BLACK);
+    if (data.empty()) {
+        DrawText(name.c_str(), x + 5, y + 5, 10, GRAY);
+        return 10 + MeasureText(name.c_str(), 10);
+    } else {
+        DrawText(data.c_str(), x + 5, y + 5, 10, BLACK);
+        return 10 + MeasureText(data.c_str(), 10);
+    }
+}
\ No newline at end of file
diff --git a/src/macros.hpp b/src/macros.hpp
new file mode 100644
index 0000000..105d24c
--- /dev/null
+++ b/src/macros.hpp
@@ -0,0 +1,20 @@
+#ifndef MACROS_HPP
+#define MACROS_HPP
+
+#include <string>
+#include <expected>
+#include <type_traits>
+#include <utility>
+
+#define Try(x, ...)                                                                                                    \
+    ({                                                                                                                 \
+        auto _res = x;                                                                                                 \
+        if (not _res) {                                                                                                \
+            return std::unexpected(__VA_OPT__([&]([[maybe_unused]] std::string $) { return __VA_ARGS__; }              \
+            ) __VA_OPT__(LIBBASE_LPAREN_) std::move(_res.error()) __VA_OPT__(LIBBASE_RPAREN_));                        \
+        }                                                                                                              \
+        using NonRef = std::remove_reference_t<decltype(*_res)>;                                                       \
+        static_cast<std::add_rvalue_reference_t<NonRef>>(*_res);                                                       \
+    })
+
+#endif    // MACROS_HPP
\ No newline at end of file
diff --git a/src/main.cpp b/src/main.cpp
index 6d8ab39..ed7c49f 100644
--- a/src/main.cpp
+++ b/src/main.cpp
@@ -1,5 +1,4 @@
 #include <clopts.hh>
-#include <print>
 import Base;
 import Application;
 using namespace ffmpegraph;
@@ -15,6 +14,7 @@ namespace detail {
 
 int main(int argc, char *argv[]) {
     auto opts = detail::options::parse(argc, argv);
+    auto ffmpeg_path = opts.get_or<"--ffmpeg-path">("ffmpeg");
     Application app("FFMpeGraph");
     app.Run();
     return 0;