More work on Ractor communication. Need to have a proper think about how to keep it DRY and KISS :)

Gemfile

@@ -1,3 +1,21 @@
 source "https://gem.coop"
 
+# "standard lib" gems
+gem "base64"
+gem "rexml"
+gem "logger"
+gem "json"
+
+# "game" library gem
 gem "cyberarm_engine"
+gem "sdl2-bindings"
+
+# networking libs
+gem "async"
+gem "async-http"
+gem "async-websocket"
+
+# misc. libs
+gem "digest-crc"
+gem "ircparser"
+gem "rubyzip"

Gemfile.lock

@@ -1,20 +1,125 @@
 GEM
   remote: https://gem.coop/
   specs:
+    async (2.39.0)
+      console (~> 1.29)
+      fiber-annotation
+      io-event (~> 1.11)
+      metrics (~> 0.12)
+      traces (~> 0.18)
+    async-http (0.95.0)
+      async (>= 2.10.2)
+      async-pool (~> 0.11)
+      io-endpoint (~> 0.14)
+      io-stream (~> 0.6)
+      metrics (~> 0.12)
+      protocol-http (~> 0.62)
+      protocol-http1 (~> 0.39)
+      protocol-http2 (~> 0.26)
+      protocol-url (~> 0.2)
+      traces (~> 0.10)
+    async-pool (0.11.2)
+      async (>= 2.0)
+    async-websocket (0.30.0)
+      async-http (~> 0.76)
+      protocol-http (~> 0.34)
+      protocol-rack (~> 0.7)
+      protocol-websocket (~> 0.17)
+    base64 (0.3.0)
+    console (1.34.3)
+      fiber-annotation
+      fiber-local (~> 1.1)
+      json
     cyberarm_engine (0.25.1)
       gosu (~> 1.1)
+    digest-crc (0.7.0)
+      rake (>= 12.0.0, < 14.0.0)
+    ffi (1.17.4-x86_64-linux-gnu)
+    fiber-annotation (0.2.0)
+    fiber-local (1.1.0)
+      fiber-storage
+    fiber-storage (1.0.1)
     gosu (1.4.6)
+    io-endpoint (0.17.2)
+    io-event (1.15.1)
+    io-stream (0.11.1)
+    ircparser (1.0.0)
+    json (2.19.4)
+    logger (1.7.0)
+    metrics (0.15.0)
+    protocol-hpack (1.5.1)
+    protocol-http (0.62.2)
+    protocol-http1 (0.39.0)
+      protocol-http (~> 0.62)
+    protocol-http2 (0.26.0)
+      protocol-hpack (~> 1.4)
+      protocol-http (~> 0.62)
+    protocol-rack (0.22.1)
+      io-stream (>= 0.10)
+      protocol-http (~> 0.58)
+      rack (>= 1.0)
+    protocol-url (0.4.0)
+    protocol-websocket (0.21.0)
+      protocol-http (~> 0.2)
+    rack (3.2.6)
+    rake (13.4.2)
+    rexml (3.4.4)
+    rubyzip (3.2.2)
+    sdl2-bindings (0.2.3)
+      ffi (~> 1.15)
+    traces (0.18.2)
 
 PLATFORMS
-  ruby
   x86_64-linux
 
 DEPENDENCIES
+  async
+  async-http
+  async-websocket
+  base64
   cyberarm_engine
+  digest-crc
+  ircparser
+  json
+  logger
+  rexml
+  rubyzip
+  sdl2-bindings
 
 CHECKSUMS
-  cyberarm_engine (0.25.1)
+  async (2.39.0) sha256=df18730073f2bbb45788077dfa20cb365ecc1b9453969f44de6796b5191a00aa
-  gosu (1.4.6)
+  async-http (0.95.0) sha256=08128cab255a48e41d1e856bfa9cbda001f1c57c88bafa3fa3a545ad795754aa
+  async-pool (0.11.2) sha256=0a43a17b02b04d9c451b7d12fafa9a50e55dc6dd00d4369aca00433f16a7e3ed
+  async-websocket (0.30.0) sha256=55739954528ad8f87f7792d0452e1268d1ef2aa5b3719f79400a05a1a6202cdf
+  base64 (0.3.0) sha256=27337aeabad6ffae05c265c450490628ef3ebd4b67be58257393227588f5a97b
+  console (1.34.3) sha256=869fbd74697efc4c606f102d2812b0b008e4e7fd738a91c591e8577140ec0dcc
+  cyberarm_engine (0.25.1) sha256=6f851a2ed0a32bdd25fc619172b546a8e26eefeb13a62c509f226337170d0efe
+  digest-crc (0.7.0) sha256=64adc23a26a241044cbe6732477ca1b3c281d79e2240bcff275a37a5a0d78c07
+  ffi (1.17.4-x86_64-linux-gnu) sha256=9d3db14c2eae074b382fa9c083fe95aec6e0a1451da249eab096c34002bc752d
+  fiber-annotation (0.2.0) sha256=7abfadf1d119f508867d4103bf231c0354d019cc39a5738945dec2edadaf6c03
+  fiber-local (1.1.0) sha256=c885f94f210fb9b05737de65d511136ea602e00c5105953748aa0f8793489f06
+  fiber-storage (1.0.1) sha256=f48e5b6d8b0be96dac486332b55cee82240057065dc761c1ea692b2e719240e1
+  gosu (1.4.6) sha256=80c7fa48cf61f4960ef067fdd1c000d98b4adc8e11faeaa486543d00908a5c15
+  io-endpoint (0.17.2) sha256=3feaf766c116b35839c11fac68b6aaadc47887bb488902a57bf8e1d288fb3338
+  io-event (1.15.1) sha256=c644cdcf48254015d63f558bf4492f35471f5bb204a42180ea49752be59b30cc
+  io-stream (0.11.1) sha256=fa5f551fcff99581c1757b9d1cee2c37b124f07d2ca4f40b756a05ab9bd21b87
+  ircparser (1.0.0) sha256=0d4598f691172e2ad078207c50ba62c0d3428ae841836b0a682e6cd01d62878d
+  json (2.19.4) sha256=670a7d333fb3b18ca5b29cb255eb7bef099e40d88c02c80bd42a3f30fe5239ac
+  logger (1.7.0) sha256=196edec7cc44b66cfb40f9755ce11b392f21f7967696af15d274dde7edff0203
+  metrics (0.15.0) sha256=61ded5bac95118e995b1bc9ed4a5f19bc9814928a312a85b200abbdac9039072
+  protocol-hpack (1.5.1) sha256=6feca238b8078da1cd295677d6f306c6001af92d75fe0643d33e6956cbc3ad91
+  protocol-http (0.62.2) sha256=e1c1f2f56029c1af8c4e2b8a67d0d096c76620f3afd8d99d1dcd2f6b8ffa773b
+  protocol-http1 (0.39.0) sha256=e49b3f4cda6f5d94c76a323d2b7f6977cba3ebd082d2da437039594da77ad8eb
+  protocol-http2 (0.26.0) sha256=bac89cd78082b241ccd0cf7246f5160e4bb0c9c975fb4bf7deef5f88cc317486
+  protocol-rack (0.22.1) sha256=1185d245927ef9849a603700d6991ca353bc89724fbf98efa4a4333ed62a9fc3
+  protocol-url (0.4.0) sha256=64d4c03b6b51ad815ac6fdaf77a1d91e5baf9220d26becb846c5459dacdea9e1
+  protocol-websocket (0.21.0) sha256=6e2ccc2adf7de1895b0f6548fdfacf5f9735c0d4deb56cd2bac1ae38a1952e93
+  rack (3.2.6) sha256=5ed78e1f73b2e25679bec7d45ee2d4483cc4146eb1be0264fc4d94cb5ef212c2
+  rake (13.4.2) sha256=cb825b2bd5f1f8e91ca37bddb4b9aaf345551b4731da62949be002fa89283701
+  rexml (3.4.4) sha256=19e0a2c3425dfbf2d4fc1189747bdb2f849b6c5e74180401b15734bc97b5d142
+  rubyzip (3.2.2) sha256=c0ed99385f0625415c8f05bcae33fe649ed2952894a95ff8b08f26ca57ea5b3c
+  sdl2-bindings (0.2.3) sha256=878c0755a4bea1aed0fa85c01596effd1c2b7d1878141ceec5bef808038bd309
+  traces (0.18.2) sha256=80f1649cb4daace1d7174b81f3b3b7427af0b93047759ba349960cb8f315e214
 
 BUNDLED WITH
   4.0.8

lib/constants.rb

@@ -1,3 +1,11 @@
 module W3DHubLauncher
+  DIRECTORY_NAME = "w3d-hub-linux-launcher".freeze
+
   ROOT_PATH = Dir.pwd
+  CONFIG_PATH = "#{Dir.home}/.config/#{DIRECTORY_NAME}".freeze
+  CACHE_PATH = "#{Dir.home}/.cache/#{DIRECTORY_NAME}".freeze
+  DEFAULT_PACKAGE_CACHE_PATH = "#{CACHE_PATH}/packages".freeze
+  DEFAULT_APPLICATIONS_PATH = "#{Dir.home}/.local/share/#{DIRECTORY_NAME}/applications".freeze
+
+  USER_AGENT = "#{NAME} v#{VERSION}".freeze
 end

lib/dialogs/downloads.rb

@@ -0,0 +1,38 @@
+module W3DHubLauncher
+  class Dialog
+    class Downloads < W3DHubLauncher::Dialog
+      def setup
+        super
+
+        stack(width: 1.0, max_width: 600, height: 1.0, max_height: 600, h_align: :center, v_align: :center, background_nine_slice: NINE_SLICE_ROUNDED, background_nine_slice_from_edge: NINE_SLICE_EDGE, background_nine_slice_color: ALPHA_BLACK) do
+          flow(width: 1.0, background_nine_slice: NINE_SLICE_ROUNDED_TOP, background_nine_slice_from_edge: NINE_SLICE_EDGE, background_nine_slice_color: ALPHA_GRAY) do
+            banner "Downloads", width: 1.0, text_align: :center
+          end
+
+          stack(width: 1.0, fill: true, scroll: true, padding_left: PADDING, padding_right: PADDING) do
+            50.times do
+              stack(width: 1.0, margin_top: HALF_PADDING, margin_bottom: HALF_PADDING) do
+                flow(width: 1.0) do
+                  para "PACKAGE_NAME.mix"
+                  flow(fill: true)
+                  para ["Downloading...", "Pending...", "Done.", "Patching...", "Unpacking..."].sample
+                end
+                progress(width: 1.0, fraction: rand)
+              end
+            end
+          end
+
+          flow(width: 1.0, padding: PADDING, background_nine_slice: NINE_SLICE_ROUNDED_BOTTOM, background_nine_slice_from_edge: NINE_SLICE_EDGE, background_nine_slice_color: ALPHA_GRAY) do
+            flow(fill: true)
+
+            button "Close" do
+              pop_state
+            end
+
+            flow(fill: true)
+          end
+        end
+      end
+    end
+  end
+end

lib/pages/boot/initial_setup.rb

@@ -15,23 +15,16 @@ module W3DHubLauncher
               title "Initial Setup"
               caption "Please confirm launcher's default settings and make any desired tweaks.", font: FONT_REGULAR
 
-              flow(width: 1.0, height: 40, margin_top: PADDING) do
-              tagline "Launcher data directory", height: 1.0, text_v_align: :center
-              edit_line format("%s/.local/share/W3D Hub", Dir.home), fill: true
-              button "Browse..."
-              end
-              inscription "Location where the launcher stores it's configuration files and cache interface data."
-
               flow(width: 1.0, height: 40, margin_top: HALF_PADDING) do
               tagline "Launcher package cache directory", height: 1.0, text_v_align: :center
-              edit_line format("%s/.local/share/W3D Hub/package-cache", Dir.home), fill: true
+              edit_line DEFAULT_PACKAGE_CACHE_PATH, fill: true
               button "Browse..."
               end
               inscription "Location where the launcher will download application packages."
 
               flow(width: 1.0, height: 40, margin_top: HALF_PADDING) do
                 tagline "Application installation directory", height: 1.0, text_v_align: :center
-                edit_line format("%s/.local/share/W3D Hub/applications", Dir.home), fill: true
+                edit_line DEFAULT_APPLICATIONS_PATH, fill: true
                 button "Browse..."
               end
               inscription "Location where the launcher will install new applications."
@@ -53,8 +46,18 @@ module W3DHubLauncher
 
             flow(width: 1.0, padding_top: PADDING) do
               flow(fill: true)
-              button "Accept" do
+              button "Accept" do |btn|
+                btn.enabled = false
+
+                Worker::Api.update_settings({}) do |result|
+                  if result.okay?
                     page(Page::Boot::StartUp)
+                  else
+                    btn.enabled = true
+                  end
+
+                  puts "NOW!"
+                end
               end
             end
           end

lib/states/interface.rb

@@ -7,9 +7,9 @@ module W3DHubLauncher
         # root container - background image
         stack(width: 1.0, height: 1.0, background_image: safe_get_image("/run/media/cyberarm/Storage/W3DHub/Launcher/package-cache/games/apb/background.png.package"), background_image_mode: :fill) do
           # root container - background image tint
-          flow(width: 1.0, height: 1.0, background: ALPHA_BLACK) do
+          stack(width: 1.0, height: 1.0, background: ALPHA_BLACK) do
             # content container
-            stack(fill: true, height: 1.0, margin: PADDING, margin_right: LARGE_PADDING) do
+            stack(width: 1.0, fill: true, margin: PADDING) do
               # header bar container
               flow(width: 1.0, height: 80, margin_bottom: PADDING) do |c|
                 # logo + menu button
@@ -25,28 +25,33 @@ module W3DHubLauncher
                   end.show
                 end
 
+                # navigation bar container
                 stack(fill: true, height: 1.0) do
-                  stack(fill: true)
+                  # stack(fill: true)
+
+                  # navigation container
                   flow(width: 1.0) do
                     link("GAMES", text_v_align: :center, font: FONT_BLACK, margin_left: PADDING) { page(Page::Games) }
                     link("SERVERS", text_v_align: :center, font: FONT_BLACK, margin_left: PADDING) { page(Page::ServerBrowser) }
                     stack(fill: true)
-                    image safe_get_image("#{ROOT_PATH}/media/icons/import.png"), height: 40, color: 0xff_bbbbbb, tip: "Downloads"
+                    image safe_get_image("#{ROOT_PATH}/media/icons/import.png"), height: 40, color: 0xff_bbbbbb, tip: "Downloads" do |img|
+                      dialog(Dialog::Downloads)
+                    end
                     image safe_get_image("#{ROOT_PATH}/media/icons/information.png"), height: 40, color: 0xff_bbbbbb, tip: "Notifications"
                   end
+                  # application task status bar container
+                  stack(width: 1.0, fill: true, margin_left: PADDING) do
+                    flow(width: 1.0) do
+                      para "Updating Red Alert: A Path Beyond (Release)"
                       stack(fill: true)
+                      para "Fetching manifests..."
+                    end
+                    progress(width: 1.0, fraction: 0.75)
                   end
                 end
 
-              # page content container
-              @page_host = stack(width: 1.0, fill: true) do
-              end
-            end
-
-            # battleview/friends container
-            stack(width: 300, height: 1.0, margin: PADDING, margin_left: 0) do
                 # self account container
-              flow(width: 1.0, height: 80) do
+                flow(width: 300, height: 80, margin_left: LARGE_PADDING) do
                   # self avatar container
                   stack(width: 80, height: 1.0, background_image: rounded_avatar(safe_get_image("#{ROOT_PATH}/media/default.png"))) do
                     # self online state container
@@ -70,9 +75,18 @@ module W3DHubLauncher
                     flow(fill: true)
                   end
                 end
+              end
 
+              # layout container
+              flow(width: 1.0, fill: true) do
+                # page host container
+                @page_host = stack(fill: true, height: 1.0) do
+                end
+
+                # battleview/friends container
+                @battleview_container = stack(width: 300, height: 1.0, margin_left: LARGE_PADDING, visible: true) do
                   # friend management container
-              flow(width: 1.0, height: 60, margin_top: PADDING) do
+                  flow(width: 1.0, height: 60) do
                     flow(width: 1.0, v_align: :center) do
                       button safe_get_image("#{ROOT_PATH}/media/icons/singleplayer.png"), image_height: 1.0
                       button safe_get_image("#{ROOT_PATH}/media/icons/gear.png"), image_height: 1.0, margin_left: HALF_PADDING
@@ -109,9 +123,17 @@ module W3DHubLauncher
                 end
               end
             end
+          end
+        end
 
         page(Page::Games)
       end
+
+      def button_up(id)
+        super
+
+        @battleview_container.toggle if id == Gosu::KB_F8
+      end
     end
   end
 end

lib/window.rb

@@ -4,8 +4,8 @@ module W3DHubLauncher
       self.show_cursor = true
       self.caption = format("%s | v%s (%s)", NAME, VERSION, VERSION_NAME) # "Cyberarm's W3D Hub Linux Launcher | v2.0.0 alpha"
 
-      # push_state(States::Boot)
+      push_state(States::Boot)
-      push_state(States::Interface)
+      # push_state(States::Interface)
     end
 
     def needs_redraw?

lib/worker.rb

@@ -1,7 +1,15 @@
 module W3DHubLauncher
   class Worker
+    Response = Data.define(:status, :request_id, :data)
+
     def initialize
       @threads = []
+      @requests = []
+
+      @settings = # Settings.new
+
+      # next available request_id to assign incoming requests
+      @request_id = 0
 
       # listen for requests from frontend
       listener = Thread.new { listen }
@@ -10,15 +18,35 @@ module W3DHubLauncher
       # connect to and monitor Backend web service
       @threads << Thread.new { backend_websocket }
 
-      Ractor.main.send({ message: "3 o'clock 'nd all's well!" })
+      @w3dhub_api = W3DHubLauncher::W3DHubApi.new
 
       listener.join
     end
 
     def listen
       loop do
-        request = Ractor.receive
+        query = Ractor.receive
-        pp request
+        pp query
+
+        case query.type
+        when Request::FETCH_URL
+        when Request::DOWNLOAD_URL
+        when Request::W3DHUB_API_CALL
+          Async do
+            result = @w3dhub_api.send(query.data[:call], *(query.data[:arguments] || []))
+            response = Response.new(result.okay? ? Request::STATUS_COMPLETE : Request::STATUS_ERROR, query.request_id, result)
+            Ractor.main.send(response)
+          end
+        when Request::LAUNCHER_UPDATE_SETTINGS
+          result = CyberarmEngine::Result.new
+          FileUtils.mkdir_p(W3DHubLauncher::CONFIG_PATH) # FAILABLE!
+          File.write("#{W3DHubLauncher::CONFIG_PATH}/settings.json", query.data) # FAILABLE!
+          result.data = query.data
+          response = Response.new(result.okay? ? Request::STATUS_COMPLETE : Request::STATUS_ERROR, query.request_id, result)
+          Ractor.main.send(response)
+        else
+          raise "UNKNOWN REQUEST"
+        end
       end
     end
 

lib/worker/api.rb

@@ -3,76 +3,71 @@
 module W3DHubLauncher
   class Worker
     class Api
-      Request = Data.define(:coming_soon)
-
-      def initialize
-        @requests = []
-      end
-
       # downloads requested resource, returns raw string
-      def fetch_url
+      def self.fetch_url
       end
 
       # downloads requested resource, periodically reporting progress until completion, returning path for file on disk
-      def download_url
+      def self.download_url
       end
 
       # returns user account data
       #
       # automatically handles signing in / refreshing token (DOES NOT remove account data if failed to refresh token due to network timeout)
-      def account
+      def self.account
       end
 
       # returns launcher settings
-      def settings
+      def self.settings
       end
 
       # write updated launcher settings
-      def update_settings
+      def self.update_settings(settings, &block)
+        Worker::Request.new(Request::LAUNCHER_UPDATE_SETTINGS, settings.to_json, &block)
       end
 
       # returns list of available applications
       #
       # if updated list is requested, return cached version immediately and then the updated list later.
-      def applications
+      def self.applications
       end
 
       # returns current list of servers as reported from GSH / cache
-      def servers
+      def self.servers
       end
 
       # returns news for application
-      def news
+      def self.news
       end
 
       # request installation of application
       #
       # periodically reports progress until completion
-      def install_application
+      def self.install_application
       end
 
       # request update of application
       #
       # periodically reports progress until completion
-      def update_application
+      def self.update_application
       end
 
       # request repair of application
       #
       # periodically reports progress until completion
-      def repair_application
+      def self.repair_application
       end
 
       # request relocation of application
       #
       # periodically reports progress until completion
-      def move_application
+      def self.move_application
       end
 
       # request removal of application
       #
       # periodically reports progress until completion
-      def uninstall_application
+      def self.uninstall_application
       end
     end
   end

lib/worker/request.rb

@@ -0,0 +1,65 @@
+module W3DHubLauncher
+  class Worker
+    class Request
+      Query = Data.define(:type, :request_id, :data)
+
+      FETCH_URL = 0
+      DOWNLOAD_URL = 1
+      W3DHUB_API_CALL = 10
+      LAUNCHER_SETTINGS = 1000
+      LAUNCHER_UPDATE_SETTINGS = 1001
+
+      STATUS_ERROR = -1 # request has failed
+      STATUS_PENDING = 0 # request has not yet started
+      STATUS_OK = 1 # request completed successfully
+      STATUS_COMPLETE = STATUS_OK
+      STATUS_IN_PROGRESS = 2 # request is in progress
+      STATUS_BUSY = STATUS_IN_PROGRESS
+
+      # NOT "Thread"/Ractor safe
+      @request_id = 0
+      @requests = []
+
+      # NOT "Thread"/Ractor safe. Only call from main ractor
+      # returns next available request id, and auto increments by 1
+      def self.request_id
+        @request_id += 1
+      end
+
+      # NOT "Thread"/Ractor safe.
+      # returns an array of pending requests
+      def self.requests
+        @requests
+      end
+
+      attr_reader :type, :data, :request_id
+
+      def initialize(type, data, request_id: Request.request_id, &block)
+        @type = type.freeze
+        @data = data.freeze
+        @status = STATUS_PENDING
+
+        @request_id = request_id
+        @callback = block # only called on error or success
+
+        enqueue(@type, @request_id, @data)
+      end
+
+      def enqueue(type, id, data)
+        Request.requests << self
+        W3DHubLauncher::WORKER.send(Query.new(type, id, data))
+      end
+
+      # event from Worker received
+      def handle_event(event, data)
+        pp [event, data]
+
+        case event
+        when STATUS_ERROR, STATUS_COMPLETE
+          @callback&.call(data)
+          Request.requests.delete(self)
+        end
+      end
+    end
+  end
+end

lib/worker/w3dhub_api.rb

@@ -0,0 +1,109 @@
+module W3DHubLauncher
+  class W3DHubApi
+    API_TIMEOUT = 30 # seconds
+    API_CONNECT_TIMEOUT = 10 # seconds
+
+    PRIMARY_W3DHUB_API_ENDPOINT = "https://secure.w3dhub.com".freeze
+    ALTERNATIVE_W3DHUB_API_ENDPOINT = "https://backend.w3d.cyberarm.dev".freeze
+
+    def initialize
+      @access_token = nil
+    end
+
+    def headers(form_encoded: false)
+    end
+
+    # return raw response to requester
+    def fetch(url, method: :get, body: nil, headers: headers())
+      result = CyberarmEngine::Result.new
+
+      Sync do |task|
+        task.with_timeout(API_TIMEOUT) do
+          Async::HTTP::Internet.send(method, url, headers, body) do |response|
+            result.data = response.read
+          rescue StandardError => e
+            result.error = e
+          end
+        rescue Async::TimeoutError
+          result.error = e
+        end
+      end
+
+      result
+    end
+
+    # write response to file, periodically reporting progress to requester
+    def download(url, path:, method: :get, body: nil, headers: headers(), &block)
+      result = CyberarmEngine::Result.new
+
+      Sync do |task|
+        task.with_timeout(API_TIMEOUT) do
+          Async::HTTP::Internet.send(method, url, headers, body) do |response|
+            if response.success?
+              content_length = response.headers["content-length"] || 0
+
+              total_downloaded_bytes = 0
+              File.open(path, "wb") do |file|
+                response.each do |chunk|
+                  file.write(chunk)
+                  downloaded_bytes = chunk.length
+                  total_downloaded_bytes += downloaded_bytes
+
+                  block&.call(downloaded_bytes, total_downloaded_bytes, content_length)
+                end
+              end
+
+              result.data = true
+            end
+          rescue StandardError => e
+            result.error = e
+          end
+        rescue Async::TimeoutError
+          result.error = e
+        end
+      end
+
+      result
+    end
+
+    def user_login()
+      result = CyberarmEngine::Result.new
+    end
+
+    def refresh_user_login()
+      result = CyberarmEngine::Result.new
+    end
+
+    def fetch_user_details()
+      result = CyberarmEngine::Result.new
+    end
+
+    def fetch_applications
+      result = CyberarmEngine::Result.new
+    end
+
+    def fetch_news()
+      result = CyberarmEngine::Result.new
+    end
+
+    def fetch_events()
+      result = CyberarmEngine::Result.new
+    end
+
+    def fetch_manifest()
+      result = CyberarmEngine::Result.new
+    end
+
+    def fetch_manifests()
+      result = CyberarmEngine::Result.new
+    end
+
+    def fetch_package_details()
+      result = CyberarmEngine::Result.new
+    end
+
+    def fetch_package()
+      download()
+    end
+  end
+end

w3d_hub_linux_launcher.rb

@@ -4,6 +4,17 @@ rescue LoadError
   require "cyberarm_engine"
 end
 
+require "rexml"
+require "base64"
+require "logger"
+
+require "async"
+require "async/http/internet/instance"
+require "async/websocket"
+require "digest/crc"
+require "ircparser"
+require "zip"
+
 require_relative "lib/version"
 require_relative "lib/constants"
 require_relative "lib/attribution"
@@ -17,12 +28,20 @@ require_relative "lib/pages/boot/terms"
 require_relative "lib/pages/boot/initial_setup"
 require_relative "lib/pages/boot/start_up"
 require_relative "lib/dialogs/about"
+require_relative "lib/dialogs/downloads"
 require_relative "lib/states/boot"
 require_relative "lib/states/interface"
 require_relative "lib/window"
 
 require_relative "lib/worker"
 require_relative "lib/worker/api"
+require_relative "lib/worker/request"
+require_relative "lib/worker/w3dhub_api"
+require_relative "lib/worker/task"
+require_relative "lib/worker/tasks/install_application"
+require_relative "lib/worker/tasks/uninstall_application"
+require_relative "lib/worker/tasks/repair_application"
+require_relative "lib/worker/tasks/update_application"
 
 module W3DHubLauncher
   WORKER = Ractor.new(name: "Parallel Worker") { W3DHubLauncher::Worker.new }
@@ -37,11 +56,20 @@ end
 # NOTE: May need to mangle Window#update to do ruby-land sleep so thread gets time to process :(
 Thread.new do
   loop do
-    message = Ractor.receive
+    response = Ractor.receive
-    pp message
+    pp response
+
+    request = W3DHubLauncher::Worker::Request.requests.find { |r| r.request_id == response.request_id }
+    request&.handle_event(response.status, response.data)
   end
 end
 
+# 10.times do
+#   W3DHubLauncher::Worker::Request.new(W3DHubLauncher::Worker::Request::W3DHUB_API_CALL, { call: :fetch_applications }) do |result|
+#     pp result
+#   end
+# end
+
 window = W3DHubLauncher::Window.new(width: 1280, height: 800, resizable: true)
 # window = W3DHubLauncher::Window.new(width: 1920, height: 1080, resizable: true)
 window.show