Working on major restructuring

lib/server/connection.rb

@@ -0,0 +1,27 @@
+require "json"
+
+module GameServer
+  module Server
+    class Connection
+      def initialize(ws, world)
+        @ws = ws
+        @world = world
+        @router = MessageRouter.new(world)
+      end
+
+      def run
+        Logging.logger.info "connection opened"
+
+        while msg = @ws.read
+          data = JSON.parse(msg)
+          response = @router.handle(data)
+          @ws.write(JSON.dump(response)) if response
+        end
+      rescue => e
+        Logging.logger.error e.message
+      ensure
+        Logging.logger.info "connection closed"
+      end
+    end
+  end
+end

lib/server/message_router.rb

@@ -0,0 +1,61 @@
+module GameServer
+  module Server
+    class MessageRouter
+      def initialize(world)
+        @world = world
+      end
+
+      def handle(data)
+        case data["type"]
+        when "hello"
+          hello
+        when "query"
+          query(data)
+        when "command"
+          command(data)
+        else
+          error("UNKNOWN_TYPE")
+        end
+      end
+
+      def hello
+        {
+          type: "update",
+          domain: "world",
+          payload: {
+            time: @world.time,
+            game_speed: Settings::GAME_SPEED
+          }
+        }
+      end
+
+      def query(data)
+        if data["domain"] == "player"
+          {
+            type: "update",
+            domain: "player",
+            payload: { money: 1000 }
+          }
+        else
+          error("UNKNOWN_DOMAIN")
+        end
+      end
+
+      def command(data)
+        {
+          type: "update",
+          domain: "command",
+          payload: { status: "accepted" }
+        }
+      end
+
+      def error(code)
+        {
+          type: "error",
+          domain: "system",
+          payload: { code: code }
+        }
+      end
+    end
+  end
+end

lib/server/websocket_server.rb

@@ -0,0 +1,33 @@
+require "async"
+require "async/websocket"
+
+module GameServer
+  module Server
+    class WebSocketServer
+      def initialize(world)
+        @world = world
+      end
+
+      def start
+        Async do |task|
+          task.async { simulation_loop }
+
+          Async::WebSocket::Server.open("0.0.0.0", Settings::PORT) do |ws|
+            task.async { Connection.new(ws, @world).run }
+          end
+        end
+      end
+
+      def simulation_loop
+        last = Time.now
+        loop do
+          now = Time.now
+          delta = (now - last) * Settings::GAME_SPEED
+          @world.advance(delta)
+          last = now
+          sleep Settings::SIMULATION_STEP
+        end
+      end
+    end
+  end
+end