Phase 3: move service layer, serializers and DTOs into WarpEngine + dummy-app test suite

- all catalog services (update/software/highlighted/builds/file/file-manager/
  download/image + SoftwareResponseBuilder), the SoftwareUpdater platform
  services and their concerns, Blueprinter serializers (incl. TimestampFields)
  and the 4 DTOs now live in the engine under WarpEngine::
- constantize dispatch strings use absolute names
  (WarpEngine::SoftwareUpdater::<Platform>Service)
- container paths read from WarpEngine.config everywhere (FileService,
  DownloadService, FileManagerService, ArchiveExtraction, ReleaseSerializer
  path rewriting); FileManagerService base path is now lazy
- engine requires blueprinter itself; gemspec declares blueprinter + rubyzip
- engine test suite: spec/dummy app (mysql warp_engine_test, catalog-only
  schema), rails_helper with engine-local factories; catalog model/service
  specs and factories moved from the host
- host suite keeps TTG specs and loads catalog factories from the engine

Verified: engine suite 40 green, host suite 14 green, /api/software and
/api/builds byte-identical to baselines, admin OK.

Co-Authored-By: Claude Fable 5 <noreply@anthropic.com>

app/services/concerns/warp_engine/software_updater/archive_extraction.rb

@@ -0,0 +1,47 @@
+require "zip"
+require "fileutils"
+
+module WarpEngine
+  module SoftwareUpdater
+    module ArchiveExtraction
+      private
+
+      def base_path
+        @base_path ||= WarpEngine.config.file_container_path
+      end
+
+      def full_path(filename)
+        File.join(base_path, filename)
+      end
+
+      def dir_exists?(dirname)
+        File.directory?(full_path(dirname))
+      end
+
+      def delete_dir(dirname)
+        FileUtils.rm_rf(full_path(dirname))
+      end
+
+      def create_dir(dirname)
+        FileUtils.mkdir_p(full_path(dirname))
+      end
+
+      def unzip_file(zip_filename, dest_dirname)
+        dest = full_path(dest_dirname)
+        Zip::File.open(full_path(zip_filename)) do |zip|
+          zip.each do |entry|
+            entry_dest = File.join(dest, entry.name)
+            FileUtils.mkdir_p(File.dirname(entry_dest))
+            entry.extract(entry_dest) { true }
+          end
+        end
+      end
+
+      def extract_zip_to_dir(zip_file, dir_name)
+        delete_dir(dir_name) if dir_exists?(dir_name)
+        create_dir(dir_name)
+        unzip_file(zip_file, dir_name)
+      end
+    end
+  end
+end

app/services/concerns/warp_engine/software_updater/builds/build_cartridge.rb

@@ -0,0 +1,24 @@
+module WarpEngine
+  module SoftwareUpdater
+    module Builds
+      module BuildCartridge
+        extend ActiveSupport::Concern
+
+        included do
+          register_expected_kind "cartridge"
+        end
+
+        def cartridge_ext
+          raise NotImplementedError, "#{self.class} must implement #cartridge_ext"
+        end
+
+        private
+
+        def cartridge_asset_path(versioned)
+          path = full_path("#{versioned}#{cartridge_ext}")
+          { "cartridge" => path } if File.file?(path)
+        end
+      end
+    end
+  end
+end

app/services/concerns/warp_engine/software_updater/builds/build_docs.rb

@@ -0,0 +1,26 @@
+module WarpEngine
+  module SoftwareUpdater
+    module Builds
+      module BuildDocs
+        extend ActiveSupport::Concern
+
+        included do
+          register_expected_kind "docs"
+          register_prepare_step :prepare_docs
+        end
+
+        private
+
+        def prepare_docs(versioned)
+          docs_zip = "#{versioned}-docs.zip"
+          extract_zip_to_dir(docs_zip, "#{versioned}-docs") if File.file?(full_path(docs_zip))
+        end
+
+        def docs_asset_path(versioned)
+          docs_dir = "#{versioned}-docs"
+          { "docs" => full_path(docs_dir) } if dir_exists?(docs_dir)
+        end
+      end
+    end
+  end
+end

app/services/concerns/warp_engine/software_updater/builds/build_linux_x64.rb

@@ -0,0 +1,20 @@
+module WarpEngine
+  module SoftwareUpdater
+    module Builds
+      module BuildLinuxX64
+        extend ActiveSupport::Concern
+
+        included do
+          register_expected_kind "linux_x64"
+        end
+
+        private
+
+        def linux_x64_asset_path(versioned)
+          path = full_path("#{versioned}-linux-x64.zip")
+          { "linux_x64" => path } if File.file?(path)
+        end
+      end
+    end
+  end
+end

app/services/concerns/warp_engine/software_updater/builds/build_mac_arm64.rb

@@ -0,0 +1,20 @@
+module WarpEngine
+  module SoftwareUpdater
+    module Builds
+      module BuildMacArm64
+        extend ActiveSupport::Concern
+
+        included do
+          register_expected_kind "mac_arm64"
+        end
+
+        private
+
+        def mac_arm64_asset_path(versioned)
+          path = full_path("#{versioned}-mac-arm64.zip")
+          { "mac_arm64" => path } if File.file?(path)
+        end
+      end
+    end
+  end
+end

app/services/concerns/warp_engine/software_updater/builds/build_mac_universal.rb

@@ -0,0 +1,20 @@
+module WarpEngine
+  module SoftwareUpdater
+    module Builds
+      module BuildMacUniversal
+        extend ActiveSupport::Concern
+
+        included do
+          register_expected_kind "mac_universal"
+        end
+
+        private
+
+        def mac_universal_asset_path(versioned)
+          path = full_path("#{versioned}-mac-universal.zip")
+          { "mac_universal" => path } if File.file?(path)
+        end
+      end
+    end
+  end
+end

app/services/concerns/warp_engine/software_updater/builds/build_mac_x64.rb

@@ -0,0 +1,20 @@
+module WarpEngine
+  module SoftwareUpdater
+    module Builds
+      module BuildMacX64
+        extend ActiveSupport::Concern
+
+        included do
+          register_expected_kind "mac_x64"
+        end
+
+        private
+
+        def mac_x64_asset_path(versioned)
+          path = full_path("#{versioned}-mac-x64.zip")
+          { "mac_x64" => path } if File.file?(path)
+        end
+      end
+    end
+  end
+end

app/services/concerns/warp_engine/software_updater/builds/build_source.rb

@@ -0,0 +1,24 @@
+module WarpEngine
+  module SoftwareUpdater
+    module Builds
+      module BuildSource
+        extend ActiveSupport::Concern
+
+        included do
+          register_expected_kind "source"
+        end
+
+        def source_ext
+          raise NotImplementedError, "#{self.class} must implement #source_ext"
+        end
+
+        private
+
+        def source_asset_path(versioned)
+          path = full_path("#{versioned}#{source_ext}")
+          { "source" => path } if File.file?(path)
+        end
+      end
+    end
+  end
+end

app/services/concerns/warp_engine/software_updater/builds/build_web.rb

@@ -0,0 +1,25 @@
+module WarpEngine
+  module SoftwareUpdater
+    module Builds
+      module BuildWeb
+        extend ActiveSupport::Concern
+
+        included do
+          register_expected_kind "html"
+          register_prepare_step :prepare_web
+        end
+
+        private
+
+        def prepare_web(versioned)
+          extract_zip_to_dir("#{versioned}.html.zip", versioned)
+        end
+
+        def html_asset_path(versioned)
+          path = full_path(versioned)
+          { "html" => path } if dir_exists?(versioned)
+        end
+      end
+    end
+  end
+end

app/services/concerns/warp_engine/software_updater/builds/build_win_x64.rb

@@ -0,0 +1,20 @@
+module WarpEngine
+  module SoftwareUpdater
+    module Builds
+      module BuildWinX64
+        extend ActiveSupport::Concern
+
+        included do
+          register_expected_kind "win_x64"
+        end
+
+        private
+
+        def win_x64_asset_path(versioned)
+          path = full_path("#{versioned}-win-x64.zip")
+          { "win_x64" => path } if File.file?(path)
+        end
+      end
+    end
+  end
+end

app/services/concerns/warp_engine/software_updater/builds/build_win_x86.rb

@@ -0,0 +1,20 @@
+module WarpEngine
+  module SoftwareUpdater
+    module Builds
+      module BuildWinX86
+        extend ActiveSupport::Concern
+
+        included do
+          register_expected_kind "win_x86"
+        end
+
+        private
+
+        def win_x86_asset_path(versioned)
+          path = full_path("#{versioned}-win-x86.zip")
+          { "win_x86" => path } if File.file?(path)
+        end
+      end
+    end
+  end
+end

app/services/concerns/warp_engine/software_updater/metadata_parsing.rb

@@ -0,0 +1,16 @@
+require "json"
+
+module WarpEngine
+  module SoftwareUpdater
+    module MetadataParsing
+      METADATA_KEYS = %i[name title author desc site repo license].freeze
+
+      private
+
+      def parse_json_metadata(path)
+        raw = JSON.parse(File.read(path), symbolize_names: true)
+        raw.slice(*METADATA_KEYS)
+      end
+    end
+  end
+end

app/services/concerns/warp_engine/software_updater/software_persistence.rb

@@ -0,0 +1,38 @@
+module WarpEngine
+  module SoftwareUpdater
+    module SoftwarePersistence
+      private
+
+      def update_or_create_software(attrs)
+        software = WarpEngine::Software.unscoped.find_or_initialize_by(name: attrs[:name])
+        software.assign_attributes(attrs.except(:name))
+        software.deleted_at = nil
+        software.save!
+        software
+      end
+
+      def upsert_external_link(software_id, label, url)
+        link = WarpEngine::ExternalLink.unscoped.find_or_initialize_by(software_id: software_id, label: label)
+        link.url = url
+        link.deleted_at = nil
+        link.save!
+      end
+
+      def create_release_if_not_exists(attrs)
+        existing = WarpEngine::Release.unscoped.find_by(software_id: attrs[:software_id], version: attrs[:version])
+        return existing if existing
+
+        WarpEngine::Release.create!(attrs)
+      end
+
+      def sync_release_assets(release, kind_paths)
+        kind_paths.each do |kind, path|
+          asset = WarpEngine::ReleaseAsset.unscoped.find_or_initialize_by(release_id: release.id, kind: kind)
+          asset.path = path
+          asset.deleted_at = nil
+          asset.save!
+        end
+      end
+    end
+  end
+end

app/services/concerns/warp_engine/software_updater/updatable.rb

@@ -0,0 +1,74 @@
+module WarpEngine
+  module SoftwareUpdater
+    module Updatable
+      extend ActiveSupport::Concern
+      include ArchiveExtraction
+      include MetadataParsing
+      include SoftwarePersistence
+
+      class_methods do
+        def platform(value = nil)
+          @platform = value if value
+          @platform ||= name.demodulize.delete_suffix("Service").downcase
+        end
+
+        def label(value = nil)
+          @label = value if value
+          @label ||= platform.titleize
+        end
+
+        def expected_kinds
+          @expected_kinds ||= []
+        end
+
+        def register_expected_kind(kind)
+          expected_kinds << kind unless expected_kinds.include?(kind)
+        end
+
+        def prepare_steps
+          @prepare_steps ||= []
+        end
+
+        def register_prepare_step(method_name)
+          prepare_steps << method_name unless prepare_steps.include?(method_name)
+        end
+      end
+
+      def update(name, version)
+        versioned = "#{name}-#{version}"
+        prepare_files(versioned)
+
+        metadata = parse_metadata(versioned)
+        site_url = metadata.delete(:site)
+        repo_url = metadata.delete(:repo)
+
+        ActiveRecord::Base.transaction do
+          software = update_or_create_software(metadata.merge(platform: self.class.platform))
+          upsert_external_link(software.id, "Source Code", site_url) if site_url.present?
+          upsert_external_link(software.id, "Repository", repo_url) if repo_url.present?
+
+          release = create_release_if_not_exists(software_id: software.id, version: version)
+          sync_release_assets(release, collect_asset_paths(versioned))
+          release
+        end
+      end
+
+      private
+
+      def prepare_files(versioned)
+        self.class.prepare_steps.each { |step| send(step, versioned) }
+      end
+
+      def parse_metadata(versioned)
+        parse_json_metadata(full_path("#{versioned}.metadata.json"))
+      end
+
+      def collect_asset_paths(versioned)
+        self.class.expected_kinds.each_with_object({}) do |kind, hash|
+          result = send(:"#{kind}_asset_path", versioned)
+          hash.merge!(result) if result
+        end
+      end
+    end
+  end
+end

app/services/warp_engine/builds_service.rb

@@ -0,0 +1,39 @@
+module WarpEngine
+  class BuildsService
+    def index
+      platforms = WarpEngine::PlatformLink::SUPPORTED_PLATFORMS.each_with_object({}) do |platform, hash|
+        service_class = "WarpEngine::SoftwareUpdater::#{platform.camelize}Service".constantize
+        hash[platform] = {
+          label: service_class.label,
+          kinds: service_class.expected_kinds
+        }
+      end
+
+      all_kinds = WarpEngine::ReleaseAsset::KINDS
+
+      { platforms: platforms, allKinds: all_kinds }
+    end
+
+    def show(name)
+      software = WarpEngine::Software.find_by!(name: name)
+      service_class = "WarpEngine::SoftwareUpdater::#{software.platform.camelize}Service".constantize
+      expected = service_class.expected_kinds
+
+      releases = software.releases.includes(:release_assets).order(updated_at: :desc)
+
+      release_data = releases.each_with_object({}) do |release, hash|
+        actual = release.release_assets.map(&:kind)
+        hash[release.version] = {
+          actual: actual,
+          missing: expected - actual
+        }
+      end
+
+      {
+        platform: software.platform,
+        expected: expected,
+        releases: release_data
+      }
+    end
+  end
+end

app/services/warp_engine/download_service.rb

@@ -0,0 +1,34 @@
+module WarpEngine
+  class DownloadService
+    def self.container_base
+      WarpEngine.config.file_container_path
+    end
+
+    # Lazy: a container path csak az első használatkor kötelező, boot/teszt közben nem.
+    def self.base_path
+      Pathname.new(container_base).realpath
+    end
+
+    def create(path:, ip:, user_agent:, referer:)
+      sanitized = path.to_s
+      base_path = self.class.base_path
+      full_path = base_path.join(sanitized).realpath
+      return nil unless full_path.to_s.start_with?(base_path.to_s)
+      return nil unless File.file?(full_path)
+
+      escaped = sanitized.gsub("%", "\\%").gsub("_", "\\_")
+      asset = WarpEngine::ReleaseAsset.find_by(path: File.join(self.class.container_base, sanitized)) ||
+              WarpEngine::ReleaseAsset.where("path LIKE ?", "%#{escaped}%").first
+
+      WarpEngine::Download.create!(
+        file_path: sanitized,
+        release: asset&.release,
+        ip_address: ip,
+        user_agent: user_agent&.truncate(500),
+        referer: referer&.truncate(500)
+      )
+
+      full_path
+    end
+  end
+end

app/services/warp_engine/file_manager_service.rb

@@ -0,0 +1,93 @@
+module WarpEngine
+  class FileManagerService
+    # Lazy: a container path csak az első használatkor kötelező, boot/teszt közben nem.
+    def base_path
+      @base_path ||= Pathname.new(WarpEngine.config.file_container_path)
+    end
+
+    def list(relative_path = "")
+      full = safe_path!(relative_path)
+      raise ArgumentError, "Not a directory" unless full.directory?
+
+      entries = full.children.sort_by { |c| [ c.directory? ? 0 : 1, c.basename.to_s.downcase ] }
+      entries.map do |child|
+        stat = child.stat
+        {
+          name:  child.basename.to_s,
+          path:  child.relative_path_from(base_path).to_s,
+          type:  child.directory? ? :directory : :file,
+          size:  child.directory? ? nil : stat.size,
+          mtime: stat.mtime
+        }
+      end
+    end
+
+    MAX_UPLOAD_SIZE = 100 * 1024 * 1024 # 100MB
+
+    def upload(relative_dir, uploaded_file)
+      raise ArgumentError, "File too large (max 100MB)" if uploaded_file.size > MAX_UPLOAD_SIZE
+      dir = safe_path!(relative_dir)
+      raise ArgumentError, "Not a directory" unless dir.directory?
+
+      safe_name = sanitize_name(uploaded_file.original_filename)
+      target = dir.join(safe_name)
+      raise ArgumentError, "Path escape" unless target.to_s.start_with?(base_path.to_s)
+
+      IO.copy_stream(uploaded_file.to_io, target.to_s)
+      target.relative_path_from(base_path).to_s
+    end
+
+    def delete(relative_path)
+      full = safe_path!(relative_path)
+      raise ArgumentError, "Cannot delete root" if full == base_path
+
+      if full.directory?
+        full.rmdir
+      else
+        full.delete
+      end
+    end
+
+    def rename(relative_path, new_name)
+      full = safe_path!(relative_path)
+      raise ArgumentError, "Cannot rename root" if full == base_path
+
+      safe_name = sanitize_name(new_name)
+      new_full = full.parent.join(safe_name)
+      raise ArgumentError, "Path escape" unless new_full.to_s.start_with?(base_path.to_s)
+
+      full.rename(new_full)
+      new_full.relative_path_from(base_path).to_s
+    end
+
+    def mkdir(relative_path, folder_name)
+      parent = safe_path!(relative_path)
+      raise ArgumentError, "Not a directory" unless parent.directory?
+
+      safe_name = sanitize_name(folder_name)
+      new_dir = parent.join(safe_name)
+      raise ArgumentError, "Path escape" unless new_dir.to_s.start_with?(base_path.to_s)
+
+      new_dir.mkdir
+      new_dir.relative_path_from(base_path).to_s
+    end
+
+    private
+
+    def safe_path!(relative_path)
+      cleaned = relative_path.to_s.gsub("..", "").squeeze("/").gsub(%r{^/|/$}, "")
+      full = base_path.join(cleaned)
+      resolved = full.exist? ? full.realpath : full.cleanpath
+      unless resolved.to_s.start_with?(base_path.to_s)
+        raise ArgumentError, "Path traversal detected"
+      end
+      resolved
+    end
+
+    def sanitize_name(name)
+      name.to_s.gsub("..", "").gsub("/", "").gsub("\\", "").strip.tap do |n|
+        raise ArgumentError, "Invalid name" if n.blank?
+      end
+    end
+  end
+end

app/services/warp_engine/file_service.rb

@@ -0,0 +1,35 @@
+module WarpEngine
+  class FileService
+    # Lazy: a container path csak az első használatkor kötelező, boot/teszt közben nem.
+    def self.base_path
+      Pathname.new(WarpEngine.config.file_container_path).realpath
+    end
+
+    def show(input)
+      full_path = base_path.join(input.path.to_s)
+      return FileResultDto.not_found unless safe_path?(full_path)
+
+      if File.directory?(full_path)
+        index_path = full_path.join("index.html")
+        return FileResultDto.not_found unless File.file?(index_path)
+        return FileResultDto.redirect("/file/#{input.path.to_s.chomp("/")}/index.html")
+      end
+
+      if File.file?(full_path)
+        FileResultDto.file(full_path)
+      else
+        FileResultDto.not_found
+      end
+    end
+
+    private
+
+    def base_path
+      @base_path ||= self.class.base_path
+    end
+
+    def safe_path?(path)
+      File.exist?(path) && Pathname.new(path).realpath.to_s.start_with?(base_path.to_s)
+    end
+  end
+end

app/services/warp_engine/image_service.rb

@@ -0,0 +1,7 @@
+module WarpEngine
+  class ImageService
+    def show(input)
+      WarpEngine::Image.find(input.id)
+    end
+  end
+end

app/services/warp_engine/software_highlighted_service.rb

@@ -0,0 +1,16 @@
+module WarpEngine
+  class SoftwareHighlightedService
+    include SoftwareResponseBuilder
+
+    def index
+      software = WarpEngine::Software.includes(:external_links, :software_images)
+                         .where(highlighted: true)
+                         .order(id: :desc)
+                         .first
+      return nil unless software
+
+      releases = WarpEngine::Release.includes(:release_assets).where(software_id: software.id).to_a
+      build_response(software, releases, download_counts_for(releases.map(&:id)))
+    end
+  end
+end

app/services/warp_engine/software_response_builder.rb

@@ -0,0 +1,27 @@
+module WarpEngine
+  module SoftwareResponseBuilder
+    private
+
+    def build_response(software, releases, download_counts)
+      sorted = releases.sort_by { |r| r.created_at || Time.at(0) }.reverse
+      latest = sorted.reject { |r| r.version.to_s.start_with?("dev-") }.first
+      # web-playable, ha az utolsó (stabil) release-nek van webes assetje
+      web_playable = latest if latest&.release_assets&.any? { |a| a.kind == "html" }
+      total_downloads = releases.sum { |r| download_counts.fetch(r.id, 0) }
+
+      SoftwareDetailSerializer.render_as_hash(software,
+        releases:        sorted,
+        latest:          latest,
+        web_playable:    web_playable,
+        total_downloads: total_downloads,
+        download_counts: download_counts
+      )
+    end
+
+    # Egyetlen csoportosított lekérdezés release-enkénti letöltésszámokhoz (N+1 helyett).
+    def download_counts_for(release_ids)
+      return {} if release_ids.empty?
+      WarpEngine::Download.where(release_id: release_ids).group(:release_id).count
+    end
+  end
+end

app/services/warp_engine/software_service.rb

@@ -0,0 +1,11 @@
+module WarpEngine
+  class SoftwareService
+    include SoftwareResponseBuilder
+
+    def index
+      softwares = WarpEngine::Software.includes(releases: [ :release_assets ]).includes(:external_links, :software_images).all
+      counts = download_counts_for(softwares.flat_map { |sw| sw.releases.map(&:id) })
+      { softwares: softwares.map { |sw| build_response(sw, sw.releases.to_a, counts) } }
+    end
+  end
+end

app/services/warp_engine/software_updater/bevy_service.rb

@@ -0,0 +1,12 @@
+module WarpEngine
+  module SoftwareUpdater
+    class BevyService
+      include Updatable
+      include Builds::BuildWeb
+      include Builds::BuildWinX64
+      include Builds::BuildLinuxX64
+
+      label "Bevy"
+    end
+  end
+end

app/services/warp_engine/software_updater/c64_service.rb

@@ -0,0 +1,12 @@
+module WarpEngine
+  module SoftwareUpdater
+    class C64Service
+      include Updatable
+      include Builds::BuildCartridge
+
+      label "C64"
+
+      def cartridge_ext = ".prg"
+    end
+  end
+end

app/services/warp_engine/software_updater/ebitengine_service.rb

@@ -0,0 +1,15 @@
+module WarpEngine
+  module SoftwareUpdater
+    class EbitengineService
+      include Updatable
+      include Builds::BuildWeb
+      include Builds::BuildWinX86
+      include Builds::BuildWinX64
+      include Builds::BuildLinuxX64
+      include Builds::BuildMacX64
+      include Builds::BuildMacArm64
+
+      label "Ebitengine"
+    end
+  end
+end

app/services/warp_engine/software_updater/godot_service.rb

@@ -0,0 +1,14 @@
+module WarpEngine
+  module SoftwareUpdater
+    class GodotService
+      include Updatable
+      include Builds::BuildWeb
+      include Builds::BuildWinX86
+      include Builds::BuildWinX64
+      include Builds::BuildLinuxX64
+      include Builds::BuildMacUniversal
+
+      label "Godot"
+    end
+  end
+end

app/services/warp_engine/software_updater/love_service.rb

@@ -0,0 +1,13 @@
+module WarpEngine
+  module SoftwareUpdater
+    class LoveService
+      include Updatable
+      include Builds::BuildWeb
+      include Builds::BuildWinX64
+      include Builds::BuildLinuxX64
+      include Builds::BuildMacUniversal
+
+      label "LÖVE"
+    end
+  end
+end

app/services/warp_engine/software_updater/phaser_service.rb

@@ -0,0 +1,10 @@
+module WarpEngine
+  module SoftwareUpdater
+    class PhaserService
+      include Updatable
+      include Builds::BuildWeb
+
+      label "Phaser"
+    end
+  end
+end

app/services/warp_engine/software_updater/tic80_service.rb

@@ -0,0 +1,38 @@
+module WarpEngine
+  module SoftwareUpdater
+    class Tic80Service
+      include Updatable
+      include Builds::BuildCartridge
+      include Builds::BuildSource
+      include Builds::BuildWeb
+      include Builds::BuildDocs
+      include Builds::BuildWinX64
+      include Builds::BuildLinuxX64
+      include Builds::BuildMacX64
+
+      label "TIC-80"
+
+      def cartridge_ext = ".tic"
+      def source_ext = ".lua"
+
+      private
+
+      def parse_metadata(versioned)
+        parse_lua_metadata(full_path("#{versioned}.lua"))
+      end
+
+      def parse_lua_metadata(source_path)
+        metadata = {}
+        File.foreach(source_path) do |line|
+          break unless line.start_with?("--")
+          parts = line[2..].split(":", 2)
+          next if parts.length != 2
+          key   = parts[0].strip.downcase.to_sym
+          value = parts[1].strip
+          metadata[key] = value
+        end
+        metadata.slice(*MetadataParsing::METADATA_KEYS)
+      end
+    end
+  end
+end

app/services/warp_engine/update_service.rb

@@ -0,0 +1,11 @@
+module WarpEngine
+  class UpdateService
+    def update(input)
+      unless WarpEngine::PlatformLink::SUPPORTED_PLATFORMS.include?(input.platform)
+        raise ArgumentError, "Unsupported platform: #{input.platform}"
+      end
+
+      "WarpEngine::SoftwareUpdater::#{input.platform.camelize}Service".constantize.new.update(input.name, input.version)
+    end
+  end
+end