[proto] add game event proto messages

gulpfile.js

@@ -48,6 +48,9 @@ const config = new Project.Config({
     assets: [
         'src/common/resources'
     ],
+    flags: [
+        //'proto_debug',
+    ],
     macros: [
         `CompilationOption.set('build','${dateformat(new Date(), 'yyyy-mm-dd HH:MM:ss')}')`,
     ]

package.json

@@ -1,6 +1,6 @@
 {
     "name": "tankz",
-    "version": "0.13.0",
+    "version": "0.14.2",
     "private": true,
     "devDependencies": {
         "dateformat": "^3.0.3",

protohx.json

@@ -3,6 +3,7 @@
   "protoFiles": [
     "src/common/proto/core.proto",
     "src/common/proto/game.proto",
+    "src/common/proto/room.proto",
     "src/common/proto/pack.proto"
   ],
   "cleanOut": true,

src/client/haxe/ru/m/display/DisplayObjectContainerExtender.hx

@@ -0,0 +1,14 @@
+package ru.m.display;
+
+import flash.display.DisplayObject;
+import flash.display.DisplayObjectContainer;
+
+class DisplayObjectContainerExtender {
+
+    public static function removeChildSafety(self:DisplayObjectContainer, child:DisplayObject):DisplayObject {
+        if (self.contains(child)) {
+            return self.removeChild(child);
+        }
+        return null;
+    }
+}

src/client/haxe/ru/m/tankz/Init.hx

@@ -15,7 +15,7 @@ import ru.m.tankz.proto.pack.Request;
 import ru.m.tankz.proto.pack.Response;
 import ru.m.tankz.sound.SoundManager;
 import ru.m.tankz.storage.GameStorage;
-import ru.m.tankz.storage.MultiplayerStorage;
+import ru.m.tankz.storage.NetworkStorage;
 import ru.m.tankz.storage.RecordStorage;
 import ru.m.tankz.storage.SettingsStorage;
 
@@ -25,7 +25,7 @@ class Init {
     @:provide static var levelBundle:ILevelBundle;
     @:provide static var configBundle:IConfigBundle;
     @:provide static var settingsStorage:SettingsStorage;
-    @:provide static var multiplayerStorage:MultiplayerStorage;
+    @:provide static var multiplayerStorage:NetworkStorage;
     @:provide static var gameStorage:GameStorage;
     @:provide static var recordStorage:RecordStorage;
     @:provide static var soundManager:SoundManager;
@@ -51,7 +51,7 @@ class Init {
         levelBundle = new LevelBundle();
         configBundle = new ConfigBundle();
         settingsStorage = new SettingsStorage();
-        multiplayerStorage = new MultiplayerStorage();
+        multiplayerStorage = new NetworkStorage();
         gameStorage = new GameStorage();
         recordStorage = new RecordStorage();
         soundManager = new SoundManager();

src/client/haxe/ru/m/tankz/Style.hx

@@ -22,6 +22,7 @@ class Style {
     public static var darkColor = 0x777564;
     public static var textColor = 0xE7E0BB;
     public static var activeColor = 0xFFFF00;
+    public static var borderColor = ColorUtil.multiply(lightColor, 1.5);
 
     public static var baseFontSize = 18;
     public static var bigFontSize = 22;
@@ -45,6 +46,14 @@ class Style {
         ]);
     }
 
+    public static function textBox(color:Int):SkinSet {
+        return [
+            Skin.color(0x000000, 0.1),
+            Skin.border(lightColor, 1, 2),
+            Skin.text(color, baseFontSize, fontFamily, fontEmbed),
+        ];
+    }
+
     public static function register(font:Font = null):Void {
         resources.color.put("light", lightColor);
         resources.color.put("dark", darkColor);
@@ -111,7 +120,7 @@ class Style {
             Skin.geometry(new Geometry().setPadding([25, 8])),
         ]);
         resources.skin.put("border", [
-            Skin.border(ColorUtil.multiply(lightColor, 1.5), 1, 2),
+            Skin.border(borderColor, 1, 2),
         ]);
         resources.skin.put("scroll", [
             Skin.scrollVertical(lightColor, ColorUtil.diff(lightColor, 128)),
@@ -134,13 +143,16 @@ class Style {
         ]);
         resources.skin.put("window", [
             Skin.color(darkColor),
-            Skin.border(ColorUtil.multiply(lightColor, 1.5), 1, 2),
+            Skin.border(borderColor, 1, 2),
             Skin.geometry(new Geometry().setPadding(2)),
         ]);
         resources.skin.put("window.close", [
             Skin.size(36, 36),
             new ButtonSVGSkin(Assets.getText("resources/image/icon/window-close-solid.svg"), lightColor),
         ]);
+        resources.skin.put("line", [
+            Skin.color(borderColor),
+        ]);
 
         registerButton("settings", "cog-solid.svg");
         registerButton("close", "times-circle-solid.svg");

src/client/haxe/ru/m/tankz/control/ActionConfig.hx

@@ -18,7 +18,7 @@ class ActionConfig {
     }
 
     public function asKeyBinding():KeyBinding {
-        var result = new Map<Int, TankAction>();
+        var result = new KeyBinding();
         for (item in data) {
             result[item.key] = item.action;
         }

src/client/haxe/ru/m/tankz/control/HumanControl.hx

@@ -3,7 +3,6 @@ package ru.m.tankz.control;
 import flash.events.FocusEvent;
 import flash.events.KeyboardEvent;
 import flash.Lib;
-import flash.ui.Keyboard;
 import haxe.Timer;
 import ru.m.tankz.control.ActionConfig;
 import ru.m.tankz.control.Control;
@@ -21,10 +20,20 @@ class HumanControl extends Control {
     public function new(playerId:PlayerId, controlIndex:Int) {
         super(playerId);
         this.keyBinding = storage.getActionConfig(controlIndex).asKeyBinding();
-        moveQueue = new Array<Int>();
+        moveQueue = [];
+    }
+
+    override public function start():Void {
+        super.start();
         Lib.current.stage.addEventListener(KeyboardEvent.KEY_DOWN, onKeyDown);
         Lib.current.stage.addEventListener(KeyboardEvent.KEY_UP, onKeyUp);
-        //Lib.current.stage.addEventListener(FocusEvent.FOCUS_OUT, onFocusOut);
+    }
+
+    override public function stop():Void {
+        super.stop();
+        Lib.current.stage.removeEventListener(KeyboardEvent.KEY_DOWN, onKeyDown);
+        Lib.current.stage.removeEventListener(KeyboardEvent.KEY_UP, onKeyUp);
+        moveQueue = [];
     }
 
     private function onKeyDown(event:KeyboardEvent):Void {

src/client/haxe/ru/m/tankz/game/NetworkGame.hx

@@ -1,41 +0,0 @@
-package ru.m.tankz.game;
-
-import haxe.Unserializer;
-import ru.m.tankz.control.NetworkControlFactory;
-import ru.m.tankz.game.Game;
-import ru.m.tankz.game.GameEvent;
-import ru.m.tankz.game.GameState;
-import ru.m.tankz.network.NetworkManager;
-import ru.m.tankz.proto.pack.GameEventResponse;
-
-class NetworkGame extends Game {
-
-    private var network:NetworkManager;
-
-    public function new(network:NetworkManager) {
-        super(new GameState(network.game.type, 0, network.game.level));
-        this.network = network;
-        this.controlFactory = new NetworkControlFactory();
-        network.gameEventSignal.connect(onGameEventProto);
-    }
-
-    private function onGameEventProto(game:GameEventResponse):Void {
-        var time = game.time;
-        var eventStr = game.event;
-        var event:GameEvent = Unserializer.run(eventStr);
-        gameEventSignal.emit(event);
-    }
-
-    override public function start():Void {
-        var player = Lambda.find(network.game.players, function(player) return player.user.uuid == network.user.uuid);
-        if (player != null) {
-            state.controls.push({playerId: [player.team, player.index], control: "human-0"});
-        }
-        super.start();
-    }
-
-    override public function dispose():Void {
-        super.dispose();
-        network.gameEventSignal.disconnect(onGameEventProto);
-    }
-}

src/client/haxe/ru/m/tankz/local/LocalControlFactory.hx

@@ -1,5 +1,8 @@
-package ru.m.tankz.control;
+package ru.m.tankz.local;
 
+import ru.m.tankz.control.BaseControlFactory;
+import ru.m.tankz.control.Control;
+import ru.m.tankz.control.HumanControl;
 import ru.m.tankz.Type;
 
 class LocalControlFactory extends BaseControlFactory {

src/client/haxe/ru/m/tankz/local/LocalGame.hx

@@ -1,7 +1,9 @@
-package ru.m.tankz.game;
+package ru.m.tankz.local;
 
-import ru.m.tankz.control.LocalControlFactory;
+import ru.m.tankz.local.LocalControlFactory;
 import ru.m.tankz.game.GameEvent;
+import ru.m.tankz.game.GameRunner;
+import ru.m.tankz.game.GameState;
 import ru.m.tankz.game.record.GameRecorder;
 import ru.m.tankz.storage.RecordStorage;
 

src/client/haxe/ru/m/tankz/network/NetworkControl.hx

@@ -1,5 +1,6 @@
-package ru.m.tankz.control;
+package ru.m.tankz.network;
 
+import ru.m.tankz.control.HumanControl;
 import ru.m.tankz.network.NetworkManager;
 import ru.m.tankz.control.Control;
 

src/client/haxe/ru/m/tankz/network/NetworkControlFactory.hx

@@ -1,5 +1,7 @@
-package ru.m.tankz.control;
+package ru.m.tankz.network;
 
+import ru.m.tankz.control.BaseControlFactory;
+import ru.m.tankz.control.Control;
 import ru.m.tankz.Type;
 
 class NetworkControlFactory extends BaseControlFactory {
@@ -7,4 +9,8 @@ class NetworkControlFactory extends BaseControlFactory {
     override private function buildHuman(id:PlayerId, index:Int):Control {
         return new NetworkControl(id, index);
     }
+
+    override private function buildBot(id:PlayerId, type:String):Control {
+        return null;
+    }
 }

src/client/haxe/ru/m/tankz/network/NetworkGame.hx

@@ -0,0 +1,54 @@
+package ru.m.tankz.network;
+
+import haxe.Unserializer;
+import ru.m.tankz.game.Game;
+import ru.m.tankz.game.GameEvent;
+import ru.m.tankz.game.GameState;
+import ru.m.tankz.network.NetworkControlFactory;
+import ru.m.tankz.network.NetworkManager;
+import ru.m.tankz.proto.pack.GameEventResponse;
+import ru.m.tankz.proto.room.RoomSlotProto;
+
+class NetworkGame extends Game {
+
+    private var network:NetworkManager;
+
+    public function new(network:NetworkManager) {
+        super(new GameState(network.room.game.type, 0, network.room.game.level));
+        this.network = network;
+        this.controlFactory = new NetworkControlFactory();
+        network.gameEventSignal.connect(onGameEventProto);
+        network.stateSignal.connect(onConnectionState);
+    }
+
+    private function onGameEventProto(game:GameEventResponse):Void {
+        var time = game.event.time;
+        var eventStr = game.event.event;
+        var event:GameEvent = Unserializer.run(eventStr);
+        gameEventSignal.emit(event);
+    }
+
+    private function onConnectionState(state:ConnectionState):Void {
+        switch state {
+            case ONLINE(user):
+                if (network.room != null) {
+                    network.joinGame(network.room.game.id);
+                }
+            case _:
+        }
+    }
+
+    override public function start():Void {
+        var slot:RoomSlotProto = Lambda.find(network.room.slots, function(slot:RoomSlotProto) return slot.hasUser() && slot.user.uuid == network.user.uuid);
+        if (slot != null) {
+            state.controls.push({playerId: [slot.slot.team, slot.slot.index], control: "human-0"});
+        }
+        super.start();
+    }
+
+    override public function dispose():Void {
+        super.dispose();
+        network.gameEventSignal.disconnect(onGameEventProto);
+        network.stateSignal.disconnect(onConnectionState);
+    }
+}

src/client/haxe/ru/m/tankz/network/NetworkManager.hx

@@ -1,25 +1,28 @@
 package ru.m.tankz.network;
 
+import ru.m.tankz.proto.game.GameEventProto;
+import ru.m.tankz.proto.room.SlotProto;
+import ru.m.tankz.proto.room.SlotRequest;
 import haxe.Serializer;
 import haxework.signal.Signal;
 import ru.m.connect.IConnection;
 import ru.m.tankz.control.Control;
 import ru.m.tankz.game.GameEvent;
-import ru.m.tankz.proto.core.GameProto;
 import ru.m.tankz.proto.core.UserProto;
-import ru.m.tankz.proto.game.GameChangeProto;
-import ru.m.tankz.proto.pack.CreateGameRequest;
 import ru.m.tankz.proto.pack.GameEventRequest;
 import ru.m.tankz.proto.pack.GameEventResponse;
-import ru.m.tankz.proto.pack.JoinGameRequest;
-import ru.m.tankz.proto.pack.LeaveGameRequest;
-import ru.m.tankz.proto.pack.ListGameRequest;
 import ru.m.tankz.proto.pack.LoginRequest;
 import ru.m.tankz.proto.pack.LogoutRequest;
 import ru.m.tankz.proto.pack.Request;
 import ru.m.tankz.proto.pack.Response;
-import ru.m.tankz.proto.pack.StartGameRequest;
+import ru.m.tankz.proto.room.CreateRequest;
-import ru.m.tankz.storage.MultiplayerStorage;
+import ru.m.tankz.proto.room.JoinRequest;
+import ru.m.tankz.proto.room.LeaveRequest;
+import ru.m.tankz.proto.room.RoomListRequest;
+import ru.m.tankz.proto.room.RoomProto;
+import ru.m.tankz.proto.room.RoomRequest;
+import ru.m.tankz.proto.room.StartRequest;
+import ru.m.tankz.storage.NetworkStorage;
 
 typedef ClientConnection = IConnection<Request, Response>;
 
@@ -35,31 +38,30 @@ enum ConnectionState {
 class NetworkManager {
 
     public var state(default, null):ConnectionState;
-    public var game(default, null):GameProto;
+    public var room(default, null):RoomProto;
     public var user(default, null):UserProto;
 
     public var stateSignal:Signal<ConnectionState>;
-    public var listGameSignal:Signal<Array<GameProto>>;
+    public var listRoomSignal:Signal<Array<RoomProto>>;
-    public var gameSignal:Signal<GameProto>;
+    public var roomSignal:Signal<RoomProto>;
-    public var gameUpdateSignal:Signal<Array<GameChangeProto>>;
     public var gameEventSignal:Signal<GameEventResponse>;
 
     @:provide private var connection:ClientConnection;
-    @:provide private var storage:MultiplayerStorage;
+    @:provide private var storage:NetworkStorage;
+
+    private var reconnectTimer:Timer;
+    private var reconnectDelay:Int;
 
     public function new() {
+        reconnectDelay = 500;
         stateSignal = new Signal();
-        listGameSignal = new Signal();
+        listRoomSignal = new Signal();
-        gameSignal = new Signal();
+        roomSignal = new Signal();
-        gameUpdateSignal = new Signal();
         gameEventSignal = new Signal();
         updateState(OFFLINE);
         connection.handler.connect(onConnectionEvent);
         connection.receiveHandler.connect(onResponse);
-        var user = storage.user;
+        connect();
-        if (user != null) {
-            login(user.name, user.uuid);
-        }
     }
 
     private function updateState(value:ConnectionState):Void {
@@ -68,61 +70,83 @@ class NetworkManager {
     }
 
     public function login(name:String, uuid:String = null):Void {
-        updateState(CONNECT);
-        connection.connect().then(function(c:ClientConnection) {
         updateState(LOGIN);
-            c.send(new Request().setLogin(
+        connection.send(new Request().setLogin(
             new LoginRequest()
                 .setUuid(uuid)
                 .setName(name)
         ));
-        }).catchError(function(error) {
-            updateState(ERROR(error));
-        });
     }
 
     public function logout():Void {
         connection.send(new Request().setLogout(new LogoutRequest()));
     }
 
-    public function listGame():Void {
+    public function listGame(subscribe:Bool):Void {
-        connection.send(new Request().setListGame(new ListGameRequest()));
+        connection.send(new Request().setRoomList(new RoomListRequest().setSubscribe(subscribe)));
     }
 
     public function createGame(type:String, level:Int):Void {
-        connection.send(new Request().setCreateGame(new CreateGameRequest().setType(type).setLevel(level)));
+        connection.send(new Request().setRoom(new RoomRequest().setCreate(new CreateRequest().setType(type).setLevel(level))));
     }
 
-    public function joinGame(gameId:Int):Void {
+    public function joinGame(gameId:Int, restore:Bool = false):Void {
-        connection.send(new Request().setJoinGame(new JoinGameRequest().setGameId(gameId)));
+        connection.send(new Request().setRoom(new RoomRequest().setJoin(new JoinRequest().setGameId(gameId).setRestore(restore))));
+    }
+
+    public function selectSlot(slot:SlotProto):Void {
+        connection.send(new Request().setRoom(new RoomRequest().setSlot(new SlotRequest().setSlot(slot))));
     }
 
     public function leaveGame():Void {
-        connection.send(new Request().setLeaveGame(new LeaveGameRequest()));
+        connection.send(new Request().setRoom(new RoomRequest().setLeave(new LeaveRequest())));
     }
 
     public function startGame():Void {
-        connection.send(new Request().setStartGame(new StartGameRequest()));
+        connection.send(new Request().setRoom(new RoomRequest().setStart(new StartRequest())));
     }
 
     public function action(tankId:Int, action:TankAction):Void {
-        connection.send(new Request().setGameEvent(new GameEventRequest().setTime(0).setEvent(
+        connection.send(new Request().setGameEvent(new GameEventRequest().setEvent(
+            new GameEventProto().setTime(0).setEvent(
                 Serializer.run(GameEvent.ACTION(tankId, action))
-        )));
+            )))
+        );
+    }
+
+    private function connect():Void {
+        if (reconnectTimer != null) {
+            reconnectTimer.stop();
+            reconnectTimer = null;
+        }
+        reconnectTimer = null;
+        updateState(CONNECT);
+        connection.connect().catchError(function(error) {});
+    }
+
+    private function reconnect():Void {
+        reconnectDelay = Std.int(Math.min(reconnectDelay * 2, 10000));
+        if (reconnectTimer == null) {
+            reconnectTimer = Timer.delay(connect, reconnectDelay);
+        }
     }
 
     private function onConnectionEvent(event:ConnectionEvent):Void {
         updateState(switch event {
-            case CONNECTED:
+            case CONNECTED: CONNECTED;
-                L.d('Network', '$event');
+            case DISCONNECTED: OFFLINE;
-                CONNECTED;
+            case ERROR(error): ERROR(error);
-            case DISCONNECTED:
-                L.d('Network', '$event');
-                OFFLINE;
-            case ERROR(error):
-                L.e('Network', '$error', error);
-                ERROR(error);
         });
+        switch event {
+            case CONNECTED:
+                reconnectDelay = 500;
+                var user = storage.user;
+                if (user != null) {
+                    login(user.name, user.uuid);
+                }
+            case DISCONNECTED | ERROR(_):
+                reconnect();
+        }
     }
 
     private function onResponse(packet:Response):Void {
@@ -137,25 +161,11 @@ class NetworkManager {
         } else if (packet.hasLogout()) {
             storage.user = null;
             updateState(CONNECTED);
-        } else if (packet.hasListGame()) {
+        } else if (packet.hasRoomList()) {
-            listGameSignal.emit(packet.listGame.games);
+            listRoomSignal.emit(packet.roomList.rooms);
-        } else if (packet.hasCreateGame()) {
+        } else if (packet.hasRoom()) {
-            game = packet.createGame.game;
+            room = packet.room.room;
-            gameSignal.emit(game);
+            roomSignal.emit(room);
-        } else if (packet.hasJoinGame()) {
-            game = packet.joinGame.game;
-            gameSignal.emit(game);
-        } else if (packet.hasLeaveGame()) {
-            if (packet.leaveGame.user.uuid == user.uuid) {
-                game = null;
-                gameSignal.emit(null);
-            } else {
-                game = packet.leaveGame.game;
-                gameSignal.emit(game);
-            }
-        } else if (packet.hasStartGame()) {
-            game = packet.startGame.game;
-            gameSignal.emit(game);
         } else if (packet.hasGameEvent()) {
             gameEventSignal.emit(packet.gameEvent);
         }

src/client/haxe/ru/m/tankz/render/Render.hx

@@ -21,6 +21,7 @@ import ru.m.tankz.render.item.EagleRenderItem;
 import ru.m.tankz.render.item.IRenderItem;
 import ru.m.tankz.render.item.TankRenderItem;
 import ru.m.tankz.Type;
+using ru.m.display.DisplayObjectContainerExtender;
 
 class Render extends SpriteView implements IRender {
 
@@ -51,18 +52,18 @@ class Render extends SpriteView implements IRender {
     }
 
     private function set_config(value:Config):Config {
-        return config = value;
+        config = value;
+        setContentSize(config.mapWidth, config.mapHeight);
+        drawBackground();
+        return config;
     }
 
     private function drawBackground():Void {
-        var width = config.map.cellWidth * config.map.gridWidth;
-        var height = config.map.cellHeight * config.map.gridHeight;
         var g:Graphics = backgroundLayer.graphics;
         g.clear();
         g.beginFill(0x000000);
-        g.drawRect(0, 0, width, height);
+        g.drawRect(0, 0, config.mapWidth, config.mapHeight);
         g.endFill();
-        setContentSize(width, height);
     }
 
     public function draw():Void {
@@ -121,6 +122,7 @@ class Render extends SpriteView implements IRender {
                 item.skin = tankConfig.skin;
                 item.hits = info.hits;
                 item.bonus = info.bonus;
+                item.name = info.name == null ? "" : info.name;
                 items.set(id, item);
                 entryLayer.addChild(item.view);
                 item.update();
@@ -236,7 +238,7 @@ class Render extends SpriteView implements IRender {
         return animate.play().then(function(animate:Animate):Void {
             // ToDo: clean animates on reset
             if (upperLayer.contains(animate)) {
-                upperLayer.removeChild(animate);
+                upperLayer.removeChildSafety(animate);
             }
             animate.dispose();
         });
@@ -251,6 +253,6 @@ class Render extends SpriteView implements IRender {
         view.x = point.x - view.width / 2;
         view.y = point.y - view.height / 2;
         upperLayer.addChild(view.content);
-        Timer.delay(function() upperLayer.removeChild(view.content), 1000);
+        Timer.delay(function() upperLayer.removeChildSafety(view.content), 1000);
     }
 }

src/client/haxe/ru/m/tankz/render/item/RenderItem.hx

@@ -7,6 +7,7 @@ import ru.m.geom.Rectangle;
 class RenderItem implements IRenderItem {
 
     public var view(get, null):DisplayObject;
+    public var content(get, null):DisplayObject;
 
     public var rect(default, null):Rectangle;
 
@@ -18,16 +19,26 @@ class RenderItem implements IRenderItem {
         throw "Not Implemented";
     }
 
+    private function get_content():DisplayObject {
+        return null;
+    }
+
     public function move(position:Position):Void {
         view.x = rect.x = position.x;
         view.y = rect.y = position.y;
         if (position.direction != null) {
             rect.direction = position.direction;
+            if (content != null) {
+                content.rotation = rect.direction.angle;
+                content.x = - rect.width * (rect.direction.x + 1) / 2 + rect.width * (rect.direction.y + 1) / 2 + 0.5 * rect.width;
+                content.y = - rect.height * (rect.direction.x + 1) / 2 - rect.height * (rect.direction.y + 1) / 2 + 1.5 * rect.height;
+            } else {
                 view.rotation = rect.direction.angle;
                 view.x = rect.x - rect.width * (rect.direction.x + 1) / 2 + rect.width * (rect.direction.y + 1) / 2 + 0.5 * rect.width;
                 view.y = rect.y - rect.height * (rect.direction.x + 1) / 2 - rect.height * (rect.direction.y + 1) / 2 + 1.5 * rect.height;
             }
         }
+    }
 
     public function update():Void {}
 

src/client/haxe/ru/m/tankz/render/item/TankRenderItem.hx

@@ -1,9 +1,13 @@
 package ru.m.tankz.render.item;
 
+import flash.display.BitmapData;
 import flash.display.DisplayObject;
 import flash.display.Sprite;
-import flash.display.BitmapData;
+import flash.text.TextField;
+import flash.text.TextFieldAutoSize;
+import flash.text.TextFormat;
 import haxework.color.Color;
+import haxework.text.BitmapTextField;
 import haxework.view.utils.BitmapUtil;
 import openfl.Assets;
 import ru.m.animate.Animate;
@@ -16,11 +20,13 @@ class TankRenderItem extends BitmapRenderItem {
     public var bonus(default, set):Bool;
     public var moves(default, set):Bool;
     public var protect(default, set):Bool;
+    public var name(default, set):String;
 
     private var container:Sprite;
     private var images:Array<BitmapData>;
     private var frame:Int;
     private var protectView:Animate;
+    private var nameView:TextField;
 
     public function new(rect:Rectangle) {
         super(rect);
@@ -29,13 +35,29 @@ class TankRenderItem extends BitmapRenderItem {
         protectView = AnimateBundle.tankProtect();
         protectView.visible = false;
         container.addChild(protectView);
+        nameView = buildNameView();
+        container.addChild(nameView);
         move(rect.position);
     }
 
+    private function buildNameView():TextField {
+        var result = new BitmapTextField();
+        result.defaultTextFormat = new TextFormat(Style.fontFamily, 10, 0xffffff);
+        result.embedFonts = Style.fontEmbed;
+        result.autoSize = TextFieldAutoSize.LEFT;
+        result.shadowColor = 0x000000;
+        result.stroke = true;
+        return result;
+    }
+
     override private function get_view():DisplayObject {
         return container;
     }
 
+    override private function get_content():DisplayObject {
+        return bitmap;
+    }
+
     private function redraw():Void {
         var image1 = Assets.getBitmapData('resources/image/tank/${skin}-0.png');
         var image2 = Assets.getBitmapData('resources/image/tank/${skin}-1.png');
@@ -105,6 +127,16 @@ class TankRenderItem extends BitmapRenderItem {
         return moves;
     }
 
+    private function set_name(value:String):String {
+        if (name != value) {
+            name = value;
+            nameView.text = name;
+            nameView.x = (rect.width - nameView.width) / 2;
+            nameView.y = -nameView.height / 2; //(rect.height - nameView.height) / 2;
+        }
+        return name;
+    }
+
     override public function update():Void {
         super.update();
         if (moves) {

src/client/haxe/ru/m/tankz/storage/NetworkStorage.hx

@@ -2,12 +2,12 @@ package ru.m.tankz.storage;
 
 import haxework.storage.SharedObjectStorage;
 
-class MultiplayerStorage extends SharedObjectStorage {
+class NetworkStorage extends SharedObjectStorage {
 
     public var user(get, set):User;
 
     public function new() {
-        super("multiplayer");
+        super("network");
     }
 
     private inline function get_user():User {

src/client/haxe/ru/m/tankz/view/ClientView.hx

@@ -1,20 +1,34 @@
 package ru.m.tankz.view;
 
+import ru.m.tankz.game.IGame;
 import flash.events.KeyboardEvent;
 import flash.ui.Keyboard;
 import haxework.resources.IResources;
+import haxework.view.ButtonView;
 import haxework.view.frame.FrameSwitcher;
+import haxework.view.LabelView;
+import haxework.view.VGroupView;
+import ru.m.tankz.network.NetworkManager;
 import ru.m.tankz.sound.SoundManager;
+import ru.m.tankz.view.popup.LoginPopup;
 
-@:template class ClientView extends FrameSwitcher {
+@:template class ClientView extends VGroupView {
+    @:view("switcher") var switcherView:FrameSwitcher;
+    @:view var username:LabelView;
+    @:view("login") var loginButton:ButtonView;
+    @:view("logout") var logoutButton:ButtonView;
 
+    @:provide var network:NetworkManager;
     @:provide var resources:IResources;
     @:provide var switcher:FrameSwitcher;
     @:provide var soundManager:SoundManager;
+    @:provide var game:IGame;
 
     public function init():Void {
         resources.text.put('version', '${Const.VERSION}');
-        switcher = this;
+        switcher = switcherView;
+        network.stateSignal.connect(onConnectionState);
+        onConnectionState(network.state);
     }
 
     public function launch():Void {
@@ -22,11 +36,50 @@ import ru.m.tankz.sound.SoundManager;
         content.stage.addEventListener(KeyboardEvent.KEY_UP, function(event:KeyboardEvent):Void {
             switch event.keyCode {
                 case Keyboard.ESCAPE:
-                    change(StartFrame.ID);
+                    switcher.change(StartFrame.ID);
                 case Keyboard.M:
                     soundManager.mute = !soundManager.mute;
+                case Keyboard.P:
+                    if (game != null) {
+                        game.pause = !game.pause;
+                    }
             }
         });
-        change(StartFrame.ID);
+        switcher.change(StartFrame.ID);
+    }
+
+    private function onConnectionState(state:ConnectionState):Void {
+        L.d("ClientView", 'onConnectionState: ${state}');
+        switch state {
+            case ONLINE(user):
+                username.text = user.name;
+                logoutButton.visible = true;
+                loginButton.visible = false;
+            case CONNECTED:
+                username.text = "";
+                logoutButton.visible = false;
+                loginButton.visible = true;
+            case ERROR(error):
+                //L.e("ClientView", 'onConnectionState: ERROR', error);
+                L.w("ClientView", 'onConnectionState: ERROR');
+            case _:
+                username.text = "";
+                logoutButton.visible = false;
+                loginButton.visible = false;
+        }
+    }
+
+    private function login():Void {
+        LoginPopup.instance.show().then(function(user:User):Void {
+            L.d("Login", 'user: $user');
+        });
+    }
+
+    private function logout():Void {
+        network.logout();
+    }
+
+    private function close():Void {
+        switcher.change(StartFrame.ID);
     }
 }

src/client/haxe/ru/m/tankz/view/ClientView.yaml

@@ -1,8 +1,10 @@
 ---
-$type: haxework.view.frame.FrameSwitcher
-geometry.size.stretch: true
-skinId: dark
 views:
+  - $type: haxework.view.frame.FrameSwitcher
+    id: switcher
+    geometry.size.stretch: true
+    skinId: dark
+    views:
       - id: start
         $type: ru.m.tankz.view.StartFrame
       - id: level
@@ -15,7 +17,35 @@ views:
         $type: ru.m.tankz.view.SettingsFrame
       - id: record
         $type: ru.m.tankz.view.RecordFrame
-  - id: game_list
+      - id: room_list
-    $type: ru.m.tankz.view.network.GameListFrame
+        $type: ru.m.tankz.view.network.RoomListFrame
-  - id: game_room
+      - id: room
-    $type: ru.m.tankz.view.network.GameRoomFrame
+        $type: ru.m.tankz.view.network.RoomFrame
+  - $type: haxework.view.HGroupView
+    skinId: panel
+    layout.margin: 10
+    views:
+      - id: settings
+        $type: haxework.view.ButtonView
+        skinId: button.settings
+        +onPress: $code:switcher.change('settings')
+      - $type: haxework.view.SpriteView
+        geometry.size.width: 50%
+      - id: username
+        $type: haxework.view.LabelView
+        skinId: text
+      - id: login
+        $type: haxework.view.ButtonView
+        skinId: button.login
+        +onPress: $code:login()
+      - id: logout
+        $type: haxework.view.ButtonView
+        skinId: button.logout
+        +onPress: $code:logout()
+        visible: false
+      - $type: haxework.view.SpriteView
+        geometry.size.width: 50%
+      - id: close
+        $type: haxework.view.ButtonView
+        skinId: button.close
+        +onPress: $code:close()

src/client/haxe/ru/m/tankz/view/GameFrame.yaml

@@ -5,10 +5,3 @@ views:
     views:
       - id: game
         $type: ru.m.tankz.view.game.GameView
-#  - $type: haxework.view.HGroupView
-#    skinId: panel
-#    views:
-#      - id: close
-#        $type: haxework.view.ButtonView
-#        skinId: button.close
-#        +onPress: $code:close()

src/client/haxe/ru/m/tankz/view/LevelFrame.hx

@@ -9,7 +9,7 @@ import ru.m.tankz.bundle.ILevelBundle;
 import ru.m.tankz.config.Config;
 import ru.m.tankz.game.GameState;
 import ru.m.tankz.game.IGame;
-import ru.m.tankz.game.LocalGame;
+import ru.m.tankz.local.LocalGame;
 import ru.m.tankz.storage.GameStorage;
 import ru.m.tankz.Type;
 import ru.m.tankz.view.popup.LevelPopup;

src/client/haxe/ru/m/tankz/view/LevelFrame.yaml

@@ -16,9 +16,3 @@ views:
         factory: $this:levelViewFactory
         +onItemSelect: $this:onLevelSelect
         geometry.padding: 10
-  - $type: haxework.view.HGroupView
-    skinId: panel
-    views:
-      - $type: haxework.view.ButtonView
-        skinId: button.close
-        +onPress: $code:switcher.change('start')

src/client/haxe/ru/m/tankz/view/RecordFrame.hx

@@ -25,8 +25,4 @@ import ru.m.tankz.storage.RecordStorage;
     private function onRecordSelect(item:IListItemView<GameRecordInfo>):Void {
 
     }
-
-    private function close() {
-        switcher.change(StartFrame.ID);
-    }
 }

src/client/haxe/ru/m/tankz/view/RecordFrame.yaml

@@ -16,9 +16,3 @@ views:
         scroll:
             $type: haxework.view.list.VScrollBarView
             skinId: scroll
-  - $type: haxework.view.HGroupView
-    skinId: panel
-    views:
-      - $type: haxework.view.ButtonView
-        skinId: button.close
-        +onPress: $code:close()

src/client/haxe/ru/m/tankz/view/ResultFrame.hx

@@ -14,7 +14,6 @@ import ru.m.tankz.view.common.LifeView;
     public static var ID(default, never):String = "result";
 
     @:view("result") var resultView:DataView<PlayerState, LifeView>;
-    @:view("next") var nextButton:ButtonView;
     @:view("level") var levelLabel:LabelView;
 
     @:provide var frames:FrameSwitcher;
@@ -37,7 +36,6 @@ import ru.m.tankz.view.common.LifeView;
     public function onShow() {
         resultView.data =  Lambda.array(state.players);
         levelLabel.text = 'Level ${state.levelId}';
-        nextButton.visible = nextState != null;
     }
 
     private function next() {

src/client/haxe/ru/m/tankz/view/ResultFrame.yaml

@@ -14,16 +14,3 @@ views:
           $type: haxework.view.layout.VerticalLayout
           hAlign: right
           margin: 10
-  - $type: haxework.view.HGroupView
-    skinId: panel
-    views:
-      - id: close
-        $type: haxework.view.ButtonView
-        skinId: button.close
-        +onPress: $code:close()
-      - $type: haxework.view.SpriteView
-        geometry.size.width: 100%
-      - id: next
-        $type: haxework.view.ButtonView
-        skinId: button.next
-        +onPress: $code:next()

src/client/haxe/ru/m/tankz/view/SettingsFrame.hx

@@ -1,11 +1,7 @@
 package ru.m.tankz.view;
 
-import haxework.view.frame.FrameSwitcher;
 import haxework.view.VGroupView;
 
 @:template class SettingsFrame extends VGroupView {
-
     public static var ID(default, never):String = "settings";
-
-    @:provide var switcher:FrameSwitcher;
 }

src/client/haxe/ru/m/tankz/view/SettingsFrame.yaml

@@ -13,9 +13,3 @@ views:
             controlIndex: 0
           - $type: ru.m.tankz.view.settings.SettingsEditor
             controlIndex: 1
-  - $type: haxework.view.HGroupView
-    skinId: panel
-    views:
-      - $type: haxework.view.ButtonView
-        skinId: button.close
-        +onPress: $code:switcher.change('start')

src/client/haxe/ru/m/tankz/view/StartFrame.hx

@@ -1,12 +1,12 @@
 package ru.m.tankz.view;
 
-import haxework.view.ButtonView;
-import haxework.view.LabelView;
 import haxework.view.frame.FrameSwitcher;
 import haxework.view.VGroupView;
 import ru.m.tankz.game.GameState;
 import ru.m.tankz.network.NetworkManager;
 import ru.m.tankz.Type.GameType;
+import ru.m.tankz.view.network.RoomListFrame;
+import ru.m.tankz.view.network.RoomFrame;
 import ru.m.tankz.view.popup.FontPopup;
 import ru.m.tankz.view.popup.LoginPopup;
 
@@ -14,54 +14,34 @@ import ru.m.tankz.view.popup.LoginPopup;
 
     public static var ID(default, never):String = "start";
 
-    @:view var username:LabelView;
-    @:view("login") var loginButton:ButtonView;
-    @:view("logout") var logoutButton:ButtonView;
-    @:view("network") var networkButton:ButtonView;
-
     @:provide var state:GameState;
     @:provide var switcher:FrameSwitcher;
     @:provide var network:NetworkManager;
 
     private var fontPopup:FontPopup;
 
-    public function onShow():Void {
-        onConnectionState(network.state);
-        network.stateSignal.connect(onConnectionState);
-    }
-
-    public function onHide():Void {
-        network.stateSignal.disconnect(onConnectionState);
-    }
-
-    private function onConnectionState(state:ConnectionState):Void {
-        trace("state", state);
-        setUser(switch state {
-            case ONLINE(user): user;
-            case _: null;
-        });
-    }
-
-    private function setUser(value:User):Void {
-        username.text = value == null ? "" : value.name;
-        loginButton.visible = value == null;
-        logoutButton.visible = value != null;
-        networkButton.disabled = value == null;
-    }
-
     private function startGame(type:GameType):Void {
         state = new GameState(type);
         switcher.change(LevelFrame.ID);
     }
 
-    private function login():Void {
+    private function startNetwork():Void {
-        LoginPopup.instance.show().then(function(user:User):Void {
+        switch network.state {
-            L.d("Login", 'user: $user');
+            case ONLINE(user):
-        });
+                if (network.room != null) {
+                    switcher.change(RoomFrame.ID);
+                    network.joinGame(network.room.game.id, true);
+                } else {
+                    switcher.change(RoomListFrame.ID);
+                }
+            case CONNECTED:
+                LoginPopup.instance.show().then(function(user):Void {
+                    if (user != null) {
+                        switcher.change(RoomListFrame.ID);
+                    }
+                });
+            case _:
         }
-
-    private function logout():Void {
-        network.logout();
     }
 
     private function choiceFont():Void {

src/client/haxe/ru/m/tankz/view/StartFrame.yaml

@@ -28,31 +28,9 @@ views:
           - id: network
             $type: haxework.view.ButtonView
             skinId: button
-            +onPress: $code:switcher.change('game_list')
+            +onPress: $code:startNetwork()
             text: Network
-            disabled: true
+            #disabled: true
-    - $type: haxework.view.HGroupView
-      skinId: panel
-      views:
-          - id: settings
-            $type: haxework.view.ButtonView
-            skinId: button.settings
-            +onPress: $code:switcher.change('settings')
-          - $type: haxework.view.SpriteView
-            geometry.size.width: 100%
-          - id: username
-            $type: haxework.view.LabelView
-            skinId: text
-            geometry.margin.right: 10
-          - id: login
-            $type: haxework.view.ButtonView
-            skinId: button.login
-            +onPress: $code:login()
-          - id: logout
-            $type: haxework.view.ButtonView
-            skinId: button.logout
-            +onPress: $code:logout()
-            visible: false
     - $type: haxework.view.LabelView
       geometry.hAlign: right
       geometry.vAlign: top

src/client/haxe/ru/m/tankz/view/game/ClassicGamePanel.yaml

@@ -2,7 +2,7 @@
 geometry.padding: 5
 geometry.size.height: 100%
 layout.margin: 5
-layout.hAlign: right
+layout.hAlign: left
 views:
   - id: level
     $type: haxework.view.LabelView

src/client/haxe/ru/m/tankz/view/network/GameItemView.hx

@@ -1,24 +0,0 @@
-package ru.m.tankz.view.network;
-
-import haxework.view.LabelView;
-import haxework.view.HGroupView;
-import haxework.view.list.ListView;
-import ru.m.tankz.proto.core.GameProto;
-
-@:template class GameItemView extends HGroupView implements IListItemView<GameProto> {
-
-    public var item_index(default, default):Int;
-    public var data(default, set):GameProto;
-
-    @:view var label:LabelView;
-
-    private function set_data(value:GameProto):GameProto {
-        data = value;
-        label.text = '[${value.creator.name}] ${value.type} ${value.level} (${value.players.length})';
-        return data;
-    }
-
-    public static function factory():GameItemView {
-        return new GameItemView();
-    }
-}

src/client/haxe/ru/m/tankz/view/network/GameItemView.yaml

@@ -1,8 +0,0 @@
----
-geometry.size.width: 100%
-geometry.size.height: 48
-views:
-    - id: label
-      $type: haxework.view.LabelView
-      geometry.size.stretch: true
-      skinId: text.box

src/client/haxe/ru/m/tankz/view/network/GameListFrame.hx

@@ -1,54 +0,0 @@
-package ru.m.tankz.view.network;
-
-import haxework.view.frame.FrameSwitcher;
-import haxework.view.list.VListView;
-import haxework.view.VGroupView;
-import ru.m.tankz.network.NetworkManager;
-import ru.m.tankz.proto.core.GameProto;
-
-@:template class GameListFrame extends VGroupView {
-    public static inline var ID = "game_list";
-
-    @:view var games:VListView<GameProto>;
-
-    @:provide var switcher:FrameSwitcher;
-    @:provide var network:NetworkManager;
-
-    public function onShow():Void {
-        network.listGameSignal.connect(onGameList);
-        network.gameSignal.connect(onGame);
-        network.stateSignal.connect(onState);
-        network.listGame();
-    }
-
-    public function onHide():Void {
-        network.listGameSignal.disconnect(onGameList);
-        network.gameSignal.disconnect(onGame);
-        network.stateSignal.disconnect(onState);
-    }
-
-    private function create():Void {
-        network.createGame("classic", 0);
-    }
-
-    private function onState(state:ConnectionState):Void {
-        switch state {
-            case ONLINE(_):
-            case _: switcher.change(StartFrame.ID);
-        }
-    }
-
-    private function onGameList(data:Array<GameProto>):Void {
-        games.data = data;
-    }
-
-    private function onGame(game:GameProto):Void {
-        if (game != null) {
-            switcher.change(GameRoomFrame.ID);
-        }
-    }
-
-    private function selectGame(game:GameProto):Void {
-        network.joinGame(game.id);
-    }
-}

src/client/haxe/ru/m/tankz/view/network/GameRoomFrame.hx

@@ -1,65 +0,0 @@
-package ru.m.tankz.view.network;
-
-import haxework.view.ButtonView;
-import haxework.view.frame.FrameSwitcher;
-import haxework.view.list.VListView;
-import haxework.view.TextView;
-import haxework.view.VGroupView;
-import ru.m.tankz.game.IGame;
-import ru.m.tankz.game.NetworkGame;
-import ru.m.tankz.network.NetworkManager;
-import ru.m.tankz.proto.core.GameProto;
-import ru.m.tankz.proto.core.GameStateProto;
-import ru.m.tankz.proto.core.PlayerProto;
-
-@:template class GameRoomFrame extends VGroupView {
-
-    public static inline var ID = "game_room";
-
-    @:view var start:ButtonView;
-    @:view var info:TextView;
-    @:view var players:VListView<PlayerProto>;
-
-    @:provide var switcher:FrameSwitcher;
-    @:provide var network:NetworkManager;
-    @:provide var game:IGame;
-
-    private function refresh(game:GameProto):Void {
-        if (game != null) {
-            start.visible = game.creator.uuid == network.user.uuid;
-            info.text = '[${game.creator.name}] ${game.type} ${game.level} (${game.players.length})';
-            players.data = game.players;
-            if (game.state == GameStateProto.STARTED) {
-                this.game = new NetworkGame(network);
-                switcher.change(GameFrame.ID);
-            }
-        } else {
-            Timer.delay(function() switcher.change(GameListFrame.ID), 1);
-        }
-    }
-
-    public function onShow():Void {
-        refresh(network.game);
-        network.gameSignal.connect(onGame);
-        network.stateSignal.connect(onState);
-    }
-
-    public function onHide():Void {
-        network.gameSignal.disconnect(onGame);
-        network.stateSignal.disconnect(onState);
-        // ToDo:
-        //network.leaveGame();
-    }
-
-    private function onGame(game:GameProto):Void {
-        refresh(game);
-    }
-
-    private function onState(state:ConnectionState):Void {
-        switch state {
-            case ONLINE(_):
-            case _: switcher.change(StartFrame.ID);
-        }
-    }
-
-}

src/client/haxe/ru/m/tankz/view/network/GameRoomFrame.yaml

@@ -1,31 +0,0 @@
----
-views:
-    - $type: haxework.view.VGroupView
-      skinId: container
-      geometry.padding: 20
-      views:
-          - id: header
-            $type: haxework.view.LabelView
-            geometry.margin.bottom: 20
-            skinId: text.header
-            text: Game Room
-          - id: start
-            $type: haxework.view.ButtonView
-            skinId: button.simple
-            text: Start
-            +onPress: $code:network.startGame()
-            visible: false
-          - id: info
-            $type: haxework.view.LabelView
-            geometry.size.width: 100%
-            skinId: text.box
-          - id: players
-            $type: haxework.view.list.VListView
-            geometry.size.stretch: true
-            factory: $code:ru.m.tankz.view.network.PlayerItemView.factory
-    - $type: haxework.view.HGroupView
-      skinId: panel
-      views:
-          - $type: haxework.view.ButtonView
-            skinId: button.close
-            +onPress: $code:network.leaveGame()

src/client/haxe/ru/m/tankz/view/network/PlayerItemView.hx

@@ -1,24 +0,0 @@
-package ru.m.tankz.view.network;
-
-import haxework.view.HGroupView;
-import haxework.view.LabelView;
-import haxework.view.list.ListView;
-import ru.m.tankz.proto.core.PlayerProto;
-
-@:template class PlayerItemView extends HGroupView implements IListItemView<PlayerProto> {
-
-    public var item_index(default, default):Int;
-    public var data(default, set):PlayerProto;
-
-    @:view var label:LabelView;
-
-    private function set_data(value:PlayerProto):PlayerProto {
-        data = value;
-        label.text = '${value.user.name}';
-        return data;
-    }
-
-    public static function factory():PlayerItemView {
-        return new PlayerItemView();
-    }
-}

src/client/haxe/ru/m/tankz/view/network/PlayerItemView.yaml

@@ -1,8 +0,0 @@
----
-geometry.size.width: 100%
-geometry.size.height: 48
-views:
-    - id: label
-      $type: haxework.view.LabelView
-      geometry.size.stretch: true
-      skinId: text.box

src/client/haxe/ru/m/tankz/view/network/RoomFrame.hx

@@ -0,0 +1,50 @@
+package ru.m.tankz.view.network;
+
+import haxework.view.ButtonView;
+import haxework.view.frame.FrameSwitcher;
+import haxework.view.list.VListView;
+import haxework.view.TextView;
+import haxework.view.VGroupView;
+import ru.m.tankz.game.IGame;
+import ru.m.tankz.network.NetworkGame;
+import ru.m.tankz.network.NetworkManager;
+import ru.m.tankz.proto.room.RoomProto;
+import ru.m.tankz.proto.room.RoomSlotProto;
+
+@:template class RoomFrame extends VGroupView {
+
+    public static inline var ID = "room";
+
+    @:view var start:ButtonView;
+    @:view var info:TextView;
+    @:view var slots:VListView<RoomSlotProto>;
+
+    @:provide var switcher:FrameSwitcher;
+    @:provide var network:NetworkManager;
+    @:provide var game:IGame;
+
+    private function refresh(room:RoomProto):Void {
+        if (room != null) {
+            start.visible = room.creator.uuid == network.user.uuid;
+            info.text = '${room.game.type} #${room.game.level}';
+            slots.data = room.slots;
+            if (room.game.started) {
+                if (this.game == null) {
+                    this.game = new NetworkGame(network);
+                }
+                switcher.change(GameFrame.ID);
+            }
+        } else {
+            Timer.delay(function() switcher.change(RoomListFrame.ID), 1);
+        }
+    }
+
+    public function onShow():Void {
+        refresh(network.room);
+        network.roomSignal.connect(refresh);
+    }
+
+    public function onHide():Void {
+        network.roomSignal.disconnect(refresh);
+    }
+}

src/client/haxe/ru/m/tankz/view/network/RoomFrame.yaml

@@ -0,0 +1,38 @@
+---
+views:
+  - $type: haxework.view.VGroupView
+    skinId: container
+    geometry.padding: 20
+    layout.margin: 10
+    views:
+      - id: header
+        $type: haxework.view.LabelView
+        geometry.margin.bottom: 20
+        skinId: text.header
+        text: Game Room
+      - $type: haxework.view.HGroupView
+        layout.margin: 10
+        views:
+          - id: info
+            $type: haxework.view.LabelView
+            geometry.padding: [30, 10]
+            skinId: text.box
+          - id: start
+            $type: haxework.view.ButtonView
+            skinId: button.simple
+            text: Start
+            +onPress: $code:network.startGame()
+            visible: false
+          - id: leave
+            $type: haxework.view.ButtonView
+            skinId: button.simple
+            text: Leave
+            +onPress: $code:network.leaveGame()
+      - $type: haxework.view.SpriteView
+        geometry.size.width: 100%
+        geometry.size.height: 3
+        skinId: line
+      - id: slots
+        $type: haxework.view.list.VListView
+        geometry.size.stretch: true
+        factory: $code:ru.m.tankz.view.network.SlotItemView.factory

src/client/haxe/ru/m/tankz/view/network/RoomItemView.hx

@@ -0,0 +1,40 @@
+package ru.m.tankz.view.network;
+
+import ru.m.tankz.network.NetworkManager;
+import ru.m.tankz.proto.room.RoomSlotProto;
+import haxework.view.ButtonView;
+import haxework.view.HGroupView;
+import haxework.view.LabelView;
+import haxework.view.list.ListView;
+import ru.m.tankz.proto.room.RoomProto;
+
+@:template class RoomItemView extends HGroupView implements IListItemView<RoomProto> {
+
+    public var item_index(default, default):Int;
+    public var data(default, set):RoomProto;
+
+    @:view("creator") var creatorView:LabelView;
+    @:view("type") var typeView:LabelView;
+    @:view("users") var usersView:LabelView;
+    @:view("join") var joinButton:ButtonView;
+
+    @:provide static var network:NetworkManager;
+
+    private function set_data(value:RoomProto):RoomProto {
+        data = value;
+        creatorView.skinId = value.creator.uuid == network.user.uuid ? "text.box.active" : "text.box";
+        creatorView.text = value.creator.name;
+        typeView.text = '${value.game.type} #${value.game.level}';
+        var used = value.slots.filter(function(slot:RoomSlotProto) return slot.hasUser()).length;
+        usersView.text = value.game.started ? 'started' : '${used}/${value.slots.length}';
+        return data;
+    }
+
+    private function join():Void {
+        network.joinGame(data.game.id, true);
+    }
+
+    public static function factory():RoomItemView {
+        return new RoomItemView();
+    }
+}

src/client/haxe/ru/m/tankz/view/network/RoomItemView.yaml

@@ -0,0 +1,27 @@
+---
+# geometry.size.width: 100%
+geometry.size.height: 48
+layout.margin: 10
+layout.hAlign: center
+views:
+  - id: creator
+    $type: haxework.view.LabelView
+    geometry.size.height: 100%
+    geometry.size.width: 200
+    skinId: text.box
+  - id: type
+    $type: haxework.view.LabelView
+    geometry.size.height: 100%
+    geometry.size.width: 200
+    skinId: text.box
+  - id: users
+    $type: haxework.view.LabelView
+    geometry.size.height: 100%
+    geometry.size.width: 150
+    skinId: text.box
+  - id: join
+    $type: haxework.view.ButtonView
+    geometry.size.height: 100%
+    skinId: button.simple
+    text: Join
+    +onPress: $code:join()

src/client/haxe/ru/m/tankz/view/network/RoomListFrame.hx

@@ -0,0 +1,47 @@
+package ru.m.tankz.view.network;
+
+import haxework.view.frame.FrameSwitcher;
+import haxework.view.list.VListView;
+import haxework.view.VGroupView;
+import ru.m.tankz.network.NetworkManager;
+import ru.m.tankz.proto.room.RoomProto;
+import ru.m.tankz.view.popup.CreateGamePopup;
+
+@:template class RoomListFrame extends VGroupView {
+    public static inline var ID = "room_list";
+
+    @:view var games:VListView<RoomProto>;
+
+    @:provide var switcher:FrameSwitcher;
+    @:provide var network:NetworkManager;
+
+    public function onShow():Void {
+        network.listRoomSignal.connect(onRoomList);
+        network.roomSignal.connect(onRoom);
+        network.listGame(true);
+    }
+
+    public function onHide():Void {
+        network.listRoomSignal.disconnect(onRoomList);
+        network.roomSignal.disconnect(onRoom);
+        network.listGame(false);
+    }
+
+    private function create():Void {
+        CreateGamePopup.instance.show().then(function(result) {
+            if (result != null) {
+                network.createGame(result.type, result.level);
+            }
+        });
+    }
+
+    private function onRoomList(data:Array<RoomProto>):Void {
+        games.data = data;
+    }
+
+    private function onRoom(room:RoomProto):Void {
+        if (room != null) {
+            switcher.change(RoomFrame.ID);
+        }
+    }
+}

src/client/haxe/ru/m/tankz/view/network/RoomListFrame.yaml

@@ -16,12 +16,5 @@ views:
           - id: games
             $type: haxework.view.list.VListView
             geometry.size.stretch: true
-            factory: $code:ru.m.tankz.view.network.GameItemView.factory
+            factory: $code:ru.m.tankz.view.network.RoomItemView.factory
             geometry.margin: 10
-            +onItemSelect: $code:function(item) selectGame(item.data)
-    - $type: haxework.view.HGroupView
-      skinId: panel
-      views:
-          - $type: haxework.view.ButtonView
-            skinId: button.close
-            +onPress: $code:switcher.change('start')

src/client/haxe/ru/m/tankz/view/network/SlotItemView.hx

@@ -0,0 +1,45 @@
+package ru.m.tankz.view.network;
+
+import haxework.view.ButtonView;
+import haxework.view.HGroupView;
+import haxework.view.LabelView;
+import haxework.view.list.ListView;
+import ru.m.tankz.bundle.IConfigBundle;
+import ru.m.tankz.network.NetworkManager;
+import ru.m.tankz.proto.room.RoomSlotProto;
+
+@:template class SlotItemView extends HGroupView implements IListItemView<RoomSlotProto> {
+
+    public var item_index(default, default):Int;
+    public var data(default, set):RoomSlotProto;
+
+    @:view("type") var typeView:LabelView;
+    @:view("user") var userView:LabelView;
+    @:view("select") var selectButton:ButtonView;
+
+    @:provide static var network:NetworkManager;
+    @:provide static var configBundle:IConfigBundle;
+
+    private function set_data(value:RoomSlotProto):RoomSlotProto {
+        data = value;
+        typeView.text = '${value.slot.team} #${value.slot.index}';
+        userView.text = value.hasUser() ? value.user.name : "(NONE)";
+        userView.visible = value.hasUser();
+        selectButton.visible = !value.hasUser();
+        userView.skinId = (value.hasUser() && value.user.uuid == network.user.uuid) ? "text.box.active" : "text.box";
+        var config = configBundle.get(network.room.game.type);
+        var color = config.getColor([value.slot.team, value.slot.index]);
+        if (color != null) {
+            typeView.skin = Style.textBox(color);
+        }
+        return data;
+    }
+
+    private function select():Void {
+        network.selectSlot(data.slot);
+    }
+
+    public static function factory():SlotItemView {
+        return new SlotItemView();
+    }
+}

src/client/haxe/ru/m/tankz/view/network/SlotItemView.yaml

@@ -0,0 +1,25 @@
+---
+geometry.size.height: 48
+geometry.padding: 2
+layout.margin: 10
+views:
+  - id: type
+    $type: haxework.view.LabelView
+    skinId: text.box
+    geometry.size.height: 100%
+    geometry.size.width: 150
+  - $type: haxework.view.HGroupView
+    layout.hAlign: center
+    layout.vAlign: middle
+    geometry.size.height: 100%
+    geometry.size.width: 300
+    views:
+    - id: user
+      $type: haxework.view.LabelView
+      geometry.size.stretch: true
+      skinId: text.box
+    - id: select
+      $type: haxework.view.ButtonView
+      skinId: button.simple
+      text: Select
+      +onPress: $this:select()

src/client/haxe/ru/m/tankz/view/popup/CreateGamePopup.hx

@@ -0,0 +1,72 @@
+package ru.m.tankz.view.popup;
+
+import haxework.view.DataView;
+import haxework.view.popup.PopupView;
+import haxework.view.ToggleButtonView;
+import ru.m.tankz.bundle.IConfigBundle;
+import ru.m.tankz.Type;
+
+private typedef Result = {
+    var type:GameType;
+    var level:LevelId;
+}
+
+@:template class CreateGamePopup extends PopupView<Result> {
+
+    @:view("type") var typeView:DataView<GameType, ToggleButtonView>;
+    @:view("level") var levelView:DataView<LevelId, ToggleButtonView>;
+
+    @:provide var configBundle:IConfigBundle;
+
+    private var type:GameType;
+    private var level:LevelId;
+
+    override private function onShow():Void {
+        super.onShow();
+        onGameTypeSelect(0, "classic", typeView.dataViews[0]);
+    }
+
+    private function submit():Void {
+        close({type:type, level:level});
+    }
+
+    private function gameTypeViewFactory(index:Int, type:GameType):ToggleButtonView {
+        var result = new ToggleButtonView();
+        result.skinId = "button.simple";
+        result.text = type;
+        result.on = type == this.type;
+        return result;
+    }
+
+    private function onGameTypeSelect(index:Int, value:GameType, view:ToggleButtonView):Void {
+        this.type = value;
+        for (v in typeView.dataViews) {
+            v.on = v == view;
+        }
+        levelView.data = [for (i in 0...configBundle.get(type).game.levels) i];
+        onLevelSelect(0, 0, levelView.dataViews[0]);
+    }
+
+    private function levelViewFactory(index:Int, value:LevelId):ToggleButtonView {
+        var result = new ToggleButtonView();
+        result.skinId = "button.level";
+        result.text = Std.string(value);
+        return result;
+    }
+
+    private function onLevelSelect(index:Int, level:LevelId, view:ToggleButtonView):Void {
+        this.level = level;
+        for (v in levelView.dataViews) {
+            v.on = v == view;
+        }
+    }
+
+    public static var instance(get, null):CreateGamePopup;
+
+    private static function get_instance():CreateGamePopup {
+        if (instance == null) {
+            instance = new CreateGamePopup();
+        }
+        return instance;
+    }
+}

src/client/haxe/ru/m/tankz/view/popup/CreateGamePopup.yaml

@@ -0,0 +1,68 @@
+---
+layout.hAlign: center
+layout.vAlign: middle
+view:
+  $type: haxework.view.VGroupView
+  layout.hAlign: center
+  geometry.size.width: 600
+  skinId: window
+  views:
+    - $type: haxework.view.HGroupView
+      geometry.size.width: 100%
+      geometry.padding: 10
+      layout.vAlign: middle
+      views:
+        - id: name
+          $type: haxework.view.LabelView
+          geometry.size.width: 100%
+          geometry.margin.left: 10
+          layout.hAlign: left
+          skinId: text
+          text: New game
+        - $type: haxework.view.ButtonView
+          skinId: window.close
+          +onPress: $code:reject('close')
+    - $type: haxework.view.VGroupView
+      geometry.size.width: 100%
+      geometry.padding: 20
+      layout.margin: 5
+      layout.hAlign: center
+      views:
+          - $type: haxework.view.LabelView
+            geometry.size.width: 100%
+            skinId: text
+            text: Type
+          - id: type
+            $type: haxework.view.DataView
+            layout:
+              $type: haxework.view.layout.HorizontalLayout
+              margin: 10
+            factory: $this:gameTypeViewFactory
+            +onItemSelect: $this:onGameTypeSelect
+            data:
+              - "classic"
+              - "dota"
+              - "death"
+          - $type: haxework.view.LabelView
+            geometry.size.width: 100%
+            skinId: text
+            text: Level
+          - id: level
+            $type: haxework.view.DataView
+            geometry.size.width: 100%
+            layout:
+              $type: haxework.view.layout.TailLayout
+              rowSize: 10
+              margin: 5
+            factory: $this:levelViewFactory
+            +onItemSelect: $this:onLevelSelect
+            geometry.padding: 10
+    - $type: haxework.view.HGroupView
+      layout.hAlign: center
+      layout.margin: 5
+      skinId: panel
+      views:
+        - $type: haxework.view.ButtonView
+          skinId: button.simple
+          text: Create
+          +onPress: $code:submit()

src/client/haxe/ru/m/tankz/view/popup/LevelPopup.hx

@@ -8,7 +8,7 @@ import haxework.view.popup.PopupView;
 import ru.m.tankz.config.Config;
 import ru.m.tankz.game.GameProgress;
 
-typedef Result = {
+private typedef Result = {
     var control:ControlPreset;
     var preset:GamePreset;
 }

src/client/haxe/ru/m/tankz/view/popup/LoginPopup.yaml

@@ -42,12 +42,14 @@ view:
                 geometry.size.width: 100%
                 skinId: text
                 text: Password
+                visible: false
               - id: password
                 $type: haxework.view.InputView
                 textField.displayAsPassword: true
                 geometry.size.width: 100%
                 geometry.size.height: 28
                 skinId: text.box
+                visible: false
               - id: error
                 $type: haxework.view.TextView
                 geometry.size.width: 100%

src/common/haxe/ru/m/connect/desktop/DesktopConnection.hx

@@ -38,8 +38,10 @@ class DesktopConnection<O:Message, I:Message> extends BaseConnection<O, I> {
                 connected = true;
                 reader = Thread.create(_read);
                 connectDeferred.resolve(this);
+                handler.emit(ConnectionEvent.CONNECTED);
             }
         } catch (error:Dynamic) {
+            handler.emit(ConnectionEvent.ERROR(error));
             Timer.delay(function() connectDeferred.throwError(error), 1);
         }
         return connectDeferred.promise();

src/common/haxe/ru/m/connect/js/JsConnection.hx

@@ -49,7 +49,7 @@ class JsConnection<O:Message, I:Message> extends BaseConnection<O, I> {
     }
 
     private function onError(event:Dynamic):Void {
-        socket.close();
+        socket.close(1000);
         connected = false;
         handler.emit(ConnectionEvent.ERROR(event));
     }
@@ -67,18 +67,25 @@ class JsConnection<O:Message, I:Message> extends BaseConnection<O, I> {
     }
 
     private function onSocketData(event:Dynamic):Void {
+        var packet:I = null;
         try {
             var bytes = Bytes.ofData(event.data);
-            var packet:I = PacketUtil.fromBytes(bytes, queue.packetClass);
+            packet = PacketUtil.fromBytes(bytes, queue.packetClass);
-            receive(packet);
         } catch (error:Dynamic) {
-            handler.emit(ConnectionEvent.ERROR(event));
+            handler.emit(ConnectionEvent.ERROR(error));
+        }
+        if (packet != null) {
+            receive(packet);
         }
     }
 
     override public function send(packet:O):Void {
+        if (connected) {
             super.send(packet);
             var bytes = PacketUtil.toBytes(packet);
             socket.send(bytes.getData());
+        } else {
+            L.w("Connection", "closed");
+        }
     }
 }

src/common/haxe/ru/m/connect/neko/NekoConnection.hx

@@ -7,16 +7,22 @@ class NekoConnection<O:Message, I:Message> extends BaseConnection<O, I> {
 
     public var socket(default, null):Socket;
 
+    private var sendQueue:Array<O>;
+    private var timer:Timer;
+
     public function new(socket:Socket, i:Class<I>) {
         super(i);
         this.socket = socket;
         socket.setFastSend(true);
         socket.output.bigEndian = false;
         socket.input.bigEndian = false;
-        sendHandler.connect(_send);
+        sendHandler.connect(pushPacket);
+        sendQueue = [];
+        timer = new Timer(1);
+        timer.run = sendRun;
     }
 
-    private function _send(packet:O):Void {
+    private function sendPacket(packet:O):Void {
         try {
             var bytes = PacketUtil.toBytes(packet);
             socket.output.writeUInt16(bytes.length);
@@ -26,4 +32,25 @@ class NekoConnection<O:Message, I:Message> extends BaseConnection<O, I> {
             L.e('Proto', 'Error send packet: ${packet}', error);
         }
     }
+
+    private function sendRun():Void {
+        if (sendQueue.length > 0) {
+            for (packet in sendQueue) {
+                sendPacket(packet);
+            }
+            sendQueue = [];
+        }
+    }
+
+    private function pushPacket(packet:O):Void {
+        sendQueue.push(packet);
+    }
+
+    override public function disconnect():Void {
+        if (timer != null) {
+            timer.stop();
+            timer = null;
+        }
+        super.disconnect();
+    }
 }

src/common/haxe/ru/m/connect/neko/NekoWSConnection.hx

@@ -16,7 +16,7 @@ class NekoWSConnection<O:Message, I:Message> extends NekoConnection<O, I> {
         opened = false;
     }
 
-    override private function _send(packet:O):Void {
+    override private function sendPacket(packet:O):Void {
         var data = PacketUtil.toBytes(packet);
         writeData(data, socket);
     }

src/common/haxe/ru/m/tankz/config/Config.hx

@@ -75,7 +75,7 @@ typedef PlayerConfig = {
     @:optional var bonus:Float;
     @:optional var protect:Float;
     @:optional var life:Int;
-    @:optional var color:Color;
+    @:optional var color:Null<Int>;
     @:optional var control:String;
 }
 
@@ -89,7 +89,7 @@ typedef TeamConfig = {
     @:optional var eagle:EagleConfig;
     @:optional var life:Int;
     @:optional var spawnInterval:Int;
-    @:optional var color:Color;
+    @:optional var color:Null<Int>;
 }
 
 typedef GamePreset = {
@@ -108,7 +108,8 @@ typedef LevelConfig = {
 typedef PlayerControl = {
     var playerId:PlayerId;
     var control:String;
-    @:optional var color:Color;
+    @:optional var color:Null<Int>;
+    @:optional var name:String;
 }
 
 typedef ControlPreset = {
@@ -138,6 +139,8 @@ class Config {
     public var controls(default, null):Array<ControlPreset>;
     public var points(default, null):Array<SpawnPoint>;
     public var bonuses(default, null):Array<BonusConfig>;
+    public var mapWidth(get, null):Float;
+    public var mapHeight(get, null):Float;
 
     private var brickMap:Map<BrickType, BrickConfig>;
     private var brickMapByIndex:Map<Int, BrickConfig>;
@@ -205,6 +208,14 @@ class Config {
         }
     }
 
+    private function get_mapWidth():Float {
+        return map.cellWidth * map.gridWidth;
+    }
+
+    private function get_mapHeight():Float {
+        return map.cellHeight * map.gridHeight;
+    }
+
     public function getBrick(type:BrickType):BrickConfig {
         return brickMap.get(type);
     }
@@ -233,16 +244,16 @@ class Config {
         return playersMap.get(playerId);
     }
 
-    public function getColor(playerId:PlayerId):Color {
+    public function getColor(playerId:PlayerId):Null<Color> {
         var player = getPlayer(playerId);
-        if (player != null && !player.color.zero) {
+        if (player != null && player.color != null) {
             return player.color;
         }
         var team = getTeam(playerId.team);
         if (team != null) {
             return team.color;
         }
-        return -1;
+        return null;
     }
 
     public function getPoint(teamId:TeamId, type:String, index:Int = -1):SpawnPoint {

src/common/haxe/ru/m/tankz/core/Eagle.hx

@@ -11,7 +11,7 @@ class Eagle extends Entity {
     public var config(default, null):EagleConfig;
     public var color(default, default):Color;
     public var death(default, default):Bool;
-    public var protect(default, null):Modificator;
+    public var protect(default, default):Bool;
 
     public var score(get, null):Int;
 
@@ -20,15 +20,10 @@ class Eagle extends Entity {
         this.team = team;
         this.config = config;
         this.death = false;
-        this.protect = new Modificator(id);
+        this.protect = false;
     }
 
     private inline function get_score():Int {
         return config != null ? config.score : 0;
     }
-
-    override public function dispose() {
-        super.dispose();
-        protect.dispose();
-    }
 }

src/common/haxe/ru/m/tankz/core/Entity.hx

@@ -18,6 +18,4 @@ class Entity {
     public function toString():String {
         return '$type($id)';
     }
-
-    public function dispose() {}
 }

src/common/haxe/ru/m/tankz/core/Modificator.hx

@@ -1,38 +0,0 @@
-package ru.m.tankz.core;
-
-import haxework.signal.Signal;
-import ru.m.Timer;
-
-class Modificator extends Signal2<Int, Bool> {
-
-    public var id(default, default):Int;
-    public var active(default, default):Bool;
-    private var timer:Timer;
-
-    public function new(id) {
-        super();
-        this.id = id;
-        active = false;
-    }
-
-    override public function connect(receiver:Int->Bool->Void):Void {
-        super.connect(receiver);
-        receiver(id, active);
-    }
-
-    public function on(seconds:Float):Void {
-        off();
-        active = true;
-        timer = Timer.delay(off, Std.int(seconds * 1000));
-        emit(id, true);
-    }
-
-    public function off():Void {
-        if (timer != null) {
-            timer.stop();
-            timer = null;
-            emit(id, false);
-        }
-        active = false;
-    }
-}

src/common/haxe/ru/m/tankz/core/Tank.hx

@@ -10,15 +10,16 @@ class Tank extends MobileEntity {
     public var playerId(default, null):PlayerId;
     public var config(default, set):TankConfig;
     public var color(default, default):Color;
+    public var name(default, default):String;
     public var hits(default, default):Int;
     public var bonus(default, default):Bool;
-    public var protect(default, null):Modificator;
+    public var protect(default, default):Bool;
-    public var freezing(default, null):Modificator;
+    public var freezing(default, default):Bool;
 
     public function new(id:Int, rect:Rectangle, playerId:PlayerId, config:TankConfig) {
         super(id, rect, config.speed, Direction.RIGHT);
-        this.protect = new Modificator(id);
+        this.protect = false;
-        this.freezing = new Modificator(id);
+        this.freezing = false;
         this.playerId = playerId;
         this.config = config;
         this.layer = 1;
@@ -35,14 +36,8 @@ class Tank extends MobileEntity {
     }
 
     override public function move(direction:Direction):Void {
-        if (!freezing.active) {
+        if (!freezing) {
             super.move(direction);
         }
     }
-
-    override public function dispose() {
-        super.dispose();
-        protect.dispose();
-        freezing.dispose();
-    }
 }

src/common/haxe/ru/m/tankz/engine/Engine.hx

@@ -16,11 +16,10 @@ import ru.m.tankz.map.LevelMap;
 
     public var config(default, default):Config;
     public var map(default, null):LevelMap;
-
+    public var ticker(default, null):ITicker;
-    public var allEntities(default, null):Map<Int, Entity>;
     public var entities(default, null):Map<Int, Entity>;
 
-    private var ticker:Ticker;
+    public var allEntities(default, null):Map<Int, Entity>;
 
     public function new(config:Config) {
         this.config = config;
@@ -67,8 +66,7 @@ import ru.m.tankz.map.LevelMap;
     }
 
     public function update():Void {
-        if (!ticker.running) ticker.start();
+        var d:Float = ticker.tick();
-        var d:Float = ticker.passed;
 
         for (ent in entities) if (Std.is(ent, MobileEntity)) {
             var entityType:EntityType = EntityTypeResolver.of(ent);
@@ -138,9 +136,6 @@ import ru.m.tankz.map.LevelMap;
     }
 
     public function dispose():Void {
-        for (entity in allEntities) {
-            entity.dispose();
-        }
         allEntities = new Map();
         entities = new Map();
         //map = null;

src/common/haxe/ru/m/tankz/engine/IEngine.hx

@@ -12,6 +12,7 @@ interface IEngine {
     public var entities(default, null):Map<Int, Entity>;
     public var config(default, default):Config;
     public var map(default, null):LevelMap;
+    public var ticker(default, null):ITicker;
 
     public var spawnSignal(default, null):Signal1<EntityType>;
     public var collisionSignal(default, null):Signal2<EntityType, EntityType>;

src/common/haxe/ru/m/tankz/engine/ITicker.hx

@@ -0,0 +1,11 @@
+package ru.m.tankz.engine;
+
+interface ITicker {
+    public var time(get, null):Int;
+    public var running(default, null):Bool;
+
+    public function start():Void;
+    public function stop():Void;
+    public function tick():Int;
+    public function emit(f:Void->Void, delay:Int):Void;
+}

src/common/haxe/ru/m/tankz/engine/Ticker.hx

@@ -1,12 +1,17 @@
 package ru.m.tankz.engine;
 
-class Ticker {
+typedef Action = {
+    var time:Int;
+    var action:Void->Void;
+}
+
+class Ticker implements ITicker {
     public var time(get, null):Int;
-    public var passed(get, null):Int;
     public var running(default, null):Bool;
 
-    private var begin:Int;
+    private var passed:Int;
-    private var last:Int;
+    private var last_tick:Int;
+    private var actions:Array<Action>;
 
     private static var TIME = Timer.stamp();
 
@@ -15,13 +20,18 @@ class Ticker {
     }
 
     public function new() {
-        begin = 0;
+        passed = 0;
-        last = 0;
+        last_tick = 0;
         running = false;
+        actions = [];
+    }
+
+    private function get_time():Int {
+        return passed;
     }
 
     public function start():Void {
-        last = begin = now();
+        last_tick = now();
         running = true;
     }
 
@@ -29,14 +39,36 @@ class Ticker {
         running = false;
     }
 
-    private function get_time():Int {
+    public function tick():Int {
-        return now() - begin;
+        if (!running) {
+            return 0;
         }
-
-    private function get_passed():Int {
         var now = now();
-        var result = now - last;
+        var result = now - last_tick;
-        last = now;
+        last_tick = now;
+        passed += result;
+        if (actions.length > 0) {
+            runActions();
+        }
         return result;
     }
+
+    private function runActions():Void {
+        var it = actions.iterator();
+        var action = it.next();
+        var i = 0;
+        while (action != null && time >= action.time) {
+            action.action();
+            i++;
+            action = it.next();
+        }
+        if (i > 0) {
+            actions = actions.slice(i);
+        }
+    }
+
+    public function emit(action:Void->Void, delay:Int):Void {
+        actions.push({action:action, time:time+delay});
+        actions.sort(function(a, b) return a.time - b.time);
+    }
 }

src/common/haxe/ru/m/tankz/game/EntityBuilder.hx

@@ -44,17 +44,15 @@ class EntityBuilder {
         return eagle;
     }
 
-    public function buildTank(point:EntityPoint, playerId:PlayerId, type:TankType, color:Color, bonusOff:Bool = false):Tank {
+    public function buildTank(point:EntityPoint, playerId:PlayerId, type:TankType, color:Null<Color>, name:String, bonusOff:Bool = false):Tank {
         var playerConfig = config.getPlayer(playerId);
         var tankConfig = config.getTank(type);
         var tank = new Tank(++entityId, buildRect(point, tankConfig.width, tankConfig.height), playerId, tankConfig);
-        tank.color = color.zero ? config.getColor(playerId) : color;
+        tank.color = color == null || color.zero ? config.getColor(playerId) : color;
+        tank.name = name;
         if (!bonusOff) {
             tank.bonus = Math.random() < playerConfig.bonus;
         }
-        if (playerConfig.protect > 0) {
-            tank.protect.on(playerConfig.protect);
-        }
         return tank;
     }
 

src/common/haxe/ru/m/tankz/game/EventUtil.hx

@@ -1,11 +1,13 @@
 package ru.m.tankz.game;
 
-import ru.m.tankz.core.EntityType.EntityTypeResolver;
+import ru.m.tankz.core.Bonus;
-import ru.m.tankz.core.Entity;
+import ru.m.tankz.core.Bullet;
 import ru.m.tankz.core.Eagle;
+import ru.m.tankz.core.Entity;
+import ru.m.tankz.core.EntityType;
 import ru.m.tankz.core.Tank;
-import ru.m.tankz.map.Brick;
 import ru.m.tankz.game.GameEvent;
+import ru.m.tankz.map.Brick;
 import ru.m.tankz.map.LevelMap;
 
 class EventUtil {
@@ -20,30 +22,51 @@ class EventUtil {
                 type: item.config.type,
             }
         });
-        return GameEvent.SPAWN(BRICK(bricks));
+        return SPAWN(BRICK(bricks));
+    }
+
+    public static function buildCellsDestroyed(map:LevelMap):Array<GameEvent> {
+        var result = [];
+        for (brick in map.bricks) {
+            for (cell in brick.cells) {
+                if (cell.destroyed) {
+                    result.push(DESTROY(CELL(brick.id, cell.cellX - brick.cellX * 2, cell.cellY - brick.cellY * 2, {tankId: -1})));
+                }
+            }
+        }
+        return result;
     }
 
     public static function buildEagleSpawn(eagle:Eagle):GameEvent {
-        return GameEvent.SPAWN(EAGLE(eagle.id, eagle.rect, eagle.team));
+        return SPAWN(EAGLE(eagle.id, eagle.rect, eagle.team));
     }
 
     public static function buildTankSpawn(tank:Tank):GameEvent {
-        return GameEvent.SPAWN(TANK(tank.id, tank.rect.clone(), tank.playerId, {
+        return SPAWN(TANK(tank.id, tank.rect.clone(), tank.playerId, {
             type:tank.config.type,
             hits:tank.hits,
             bonus:tank.bonus,
             color:tank.color,
+            name:tank.name,
         }));
     }
 
+    public static function buildBonusSpawn(bonus:Bonus):GameEvent {
+        return SPAWN(BONUS(bonus.id, bonus.rect.clone(), bonus.config.type));
+    }
+
+    public static function buildBulletSpawn(bullet:Bullet):GameEvent {
+        return SPAWN(BULLET(bullet.id, bullet.rect.clone(), bullet.playerId, bullet.config.piercing));
+    }
+
     public static function buildMove(entity:Entity):GameEvent {
         return switch EntityTypeResolver.of(entity) {
             case EAGLE(eagle):
-                GameEvent.MOVE(EAGLE(entity.id, entity.rect.position));
+                MOVE(EAGLE(entity.id, entity.rect.position));
             case TANK(tank):
-                GameEvent.MOVE(TANK(entity.id, entity.rect.position));
+                MOVE(TANK(entity.id, entity.rect.position));
             case BULLET(bullet):
-                GameEvent.MOVE(BULLET(entity.id, entity.rect.position));
+                MOVE(BULLET(entity.id, entity.rect.position));
             case _:
                 null;
         }

src/common/haxe/ru/m/tankz/game/Game.hx

@@ -4,6 +4,7 @@ import ru.m.geom.Point;
 import ru.m.geom.Position;
 import ru.m.tankz.bundle.IConfigBundle;
 import ru.m.tankz.config.Config;
+import ru.m.tankz.control.Control;
 import ru.m.tankz.control.Controller;
 import ru.m.tankz.control.IControlFactory;
 import ru.m.tankz.control.NoneControlFactory;
@@ -26,6 +27,9 @@ import ru.m.tankz.Type;
     public var state(default, null):GameState;
     public var engine(default, null):IEngine;
     public var controlFactory(default, null):IControlFactory;
+    public var pause(default, set):Bool;
+
+    private var controls:Map<String, Control>;
 
     @:provide var configBundle:IConfigBundle;
 
@@ -35,9 +39,21 @@ import ru.m.tankz.Type;
         this.teams = new Map();
         this.config = configBundle.get(type);
         this.controlFactory = new NoneControlFactory();
+        this.pause = false;
+        this.controls = new Map();
         connect(this);
     }
 
+    private function set_pause(value:Bool):Bool {
+        if (pause != value) {
+            pause = value;
+            changePause(pause);
+        }
+        return pause;
+    }
+
+    private function changePause(value:Bool):Void {}
+
     private function applyPosition(entity:Entity, position:Position):Void {
         entity.rect.center = new Point(position.x, position.y);
         if (position.direction != null) {
@@ -64,9 +80,19 @@ import ru.m.tankz.Type;
                 var team = getTeam(teamId);
                 team.eagleId = id;
             case SPAWN(TANK(id, rect, playerId, info)):
-                var player = getPlayer(playerId);
+                if (controls.exists(playerId)) {
-                player.tankId = id;
+                    var control = controls[playerId];
-                player.state.tank = info.type;
+                    control.tankId = id;
+                    control.start();
+                }
+            case DESTROY(TANK(id, shot)):
+                for (control in controls) {
+                    if (control.tankId == id) {
+                        control.stop();
+                        control.tankId = -1;
+                        break;
+                    }
+                }
             case _:
         }
     }
@@ -86,14 +112,19 @@ import ru.m.tankz.Type;
         for (team in teams.iterator()) {
             for (player in team.players.iterator()) {
                 var playerControl = controlsById.get(player.id);
-                if (playerControl != null && !playerControl.color.zero) {
+                if (playerControl != null) {
+                    if (playerControl.color != null) {
                         player.state.color = playerControl.color;
                     }
+                    if (playerControl.name != null) {
+                        player.state.name = playerControl.name;
+                    }
+                }
                 var controlType:Controller = AController.fromString(playerControl != null ? playerControl.control : player.config.control);
                 var control = controlFactory.build(player.id, controlType);
                 if (control != null) {
-                    player.control = control;
+                    controls[player.id] = control;
-                    player.control.bind(this, engine);
+                    control.bind(this, engine);
                 } else {
                     // ToDo: remove player
                     player.state.life = 0;
@@ -103,6 +134,10 @@ import ru.m.tankz.Type;
     }
 
     public function dispose():Void {
+        for (control in controls) {
+            control.dispose();
+        }
+        controls = new Map();
         gameEventSignal.dispose();
     }
 }

src/common/haxe/ru/m/tankz/game/GameEvent.hx

@@ -11,6 +11,7 @@ typedef TankInfo = {
     var hits:Int;
     var bonus:Bool;
     var color:Color;
+    @:optional var name:String;
 }
 
 typedef BrickInfo = {

src/common/haxe/ru/m/tankz/game/GameRunner.hx

@@ -1,6 +1,5 @@
 package ru.m.tankz.game;
 
-import haxework.color.Color;
 import ru.m.geom.Line;
 import ru.m.geom.Point;
 import ru.m.tankz.control.Control;
@@ -27,6 +26,16 @@ class GameRunner extends Game implements EngineListener {
         this.engine.connect(this);
     }
 
+    override function changePause(value:Bool):Void {
+        if (engine != null) {
+            if (value) {
+                engine.ticker.stop();
+            } else {
+                engine.ticker.start();
+            }
+        }
+    }
+
     private function update():Void {
         engine.update();
     }
@@ -47,7 +56,7 @@ class GameRunner extends Game implements EngineListener {
             team.spawner.runner = spawn;
             for (player in team.players.iterator()) {
                 if (team.tryRespawn(player.id)) {
-                    team.spawner.push(player.id);
+                    team.spawner.push(engine.ticker, player.id);
                 }
             }
             if (team.config.eagle != null) {
@@ -55,7 +64,6 @@ class GameRunner extends Game implements EngineListener {
                 var eagle = builder.buildEagle(point, team.id);
                 engine.spawn(eagle);
                 gameEventSignal.emit(EventUtil.buildEagleSpawn(eagle));
-                eagle.protect.connect(onEagleProtectChange);
             }
         }
         gameEventSignal.emit(EventUtil.buildBricksSpawn(engine.map));
@@ -65,23 +73,39 @@ class GameRunner extends Game implements EngineListener {
 
     private function spawn(task:SpawnTask):Void {
         var player = getPlayer(task.playerId);
-        var tank = builder.buildTank(task.point, task.playerId, task.tankType, player.state.color);
+        var tank = builder.buildTank(task.point, task.playerId, task.tankType, player.state.color, player.state.name);
         engine.spawn(tank);
         gameEventSignal.emit(EventUtil.buildTankSpawn(tank));
-        tank.protect.connect(onTankProtectChange);
+        if (player.config.protect > 0) {
-        tank.freezing.connect(onTankFreezingChange);
+            protectTank(tank, player.config.protect);
+        }
     }
 
-    private function onEagleProtectChange(id:Int, state:Bool):Void {
+    private function protectEagle(eagle:Eagle, duration:Float):Void {
-        gameEventSignal.emit(CHANGE(EAGLE_PROTECT(id, state)));
+        eagle.protect = true;
+        gameEventSignal.emit(CHANGE(EAGLE_PROTECT(eagle.id, eagle.protect)));
+        engine.ticker.emit(function() {
+            eagle.protect = false;
+            gameEventSignal.emit(CHANGE(EAGLE_PROTECT(eagle.id, eagle.protect)));
+        }, Std.int(duration * 1000));
     }
 
-    private function onTankProtectChange(id:Int, state:Bool):Void {
+    private function protectTank(tank:Tank, duration:Float):Void {
-        gameEventSignal.emit(CHANGE(TANK_PROTECT(id, state)));
+        tank.protect = true;
+        gameEventSignal.emit(CHANGE(TANK_PROTECT(tank.id, tank.protect)));
+        engine.ticker.emit(function() {
+            tank.protect = false;
+            gameEventSignal.emit(CHANGE(TANK_PROTECT(tank.id, tank.protect)));
+        }, Std.int(duration * 1000));
     }
 
-    private function onTankFreezingChange(id:Int, state:Bool):Void {
+    private function freezeTank(tank:Tank, duration:Float):Void {
-        gameEventSignal.emit(CHANGE(TANK_FREEZE(id, state)));
+        tank.freezing = true;
+        gameEventSignal.emit(CHANGE(TANK_FREEZE(tank.id, tank.freezing)));
+        engine.ticker.emit(function() {
+            tank.freezing = false;
+            gameEventSignal.emit(CHANGE(TANK_FREEZE(tank.id, tank.freezing)));
+        }, Std.int(duration * 1000));
     }
 
     private function checkComplete():Void {
@@ -106,14 +130,6 @@ class GameRunner extends Game implements EngineListener {
     }
 
     private function complete(winner:TeamId):Void {
-        for (team in teams.iterator()) {
-            for (player in team.players) {
-                if (player.control != null) {
-                    player.control.action(STOP);
-                    player.control.dispose();
-                }
-            }
-        }
         Timer.delay(function() {
             gameEventSignal.emit(COMPLETE(state, winner));
         }, 3000);
@@ -141,8 +157,9 @@ class GameRunner extends Game implements EngineListener {
     public function onCollision(entity:EntityType, with:EntityType):Void {
         switch entity {
             case EntityType.TANK(tank):
-                var control = getPlayer(tank.playerId).control;
+                if (controls.exists(tank.playerId)) {
-                if (control != null) control.onCollision(with);
+                    controls[tank.playerId].onCollision(with);
+                }
             case _:
         }
         switch [entity, with] {
@@ -168,7 +185,7 @@ class GameRunner extends Game implements EngineListener {
                 if (bullet.tankId == tank.id || (!config.game.friendlyFire && tank.playerId.team == bullet.playerId.team)) {
                     // Nothing
                 } else {
-                    if (!tank.protect.active) {
+                    if (!tank.protect) {
                         if (tank.hits > 0) {
                             tank.hits--;
                             if (tank.bonus) {
@@ -192,7 +209,7 @@ class GameRunner extends Game implements EngineListener {
                     gameEventSignal.emit(DESTROY(BULLET(bullet.id)));
                 }
             case [BULLET(bullet), EAGLE(eagle)]:
-                if (!eagle.protect.active) {
+                if (!eagle.protect) {
                     gameEventSignal.emit(DESTROY(EAGLE(eagle.id, buildShot(bullet, eagle.score))));
                 }
                 gameEventSignal.emit(DESTROY(BULLET(bullet.id)));
@@ -222,7 +239,7 @@ class GameRunner extends Game implements EngineListener {
         }
         var bonus = builder.buildBonus(point, type);
         engine.spawn(bonus);
-        gameEventSignal.emit(SPAWN(BONUS(bonus.id, bonus.rect.clone(), bonus.config.type)));
+        gameEventSignal.emit(EventUtil.buildBonusSpawn(bonus));
     }
 
     private inline function alienTank(team:TeamId):Tank->Bool {
@@ -240,10 +257,10 @@ class GameRunner extends Game implements EngineListener {
                     gameEventSignal.emit(DESTROY(TANK(t.id, {tankId: tank.id})));
                 }
             case "helmet":
-                tank.protect.on(bonus.config.duration);
+                protectTank(tank, bonus.config.duration);
             case "clock":
                 for (t in engine.iterTanks(alienTank(tank.playerId.team))) {
-                    t.freezing.on(bonus.config.duration);
+                    freezeTank(t, bonus.config.duration);
                     t.stop();
                     gameEventSignal.emit(STOP(TANK(t.id)));
                 }
@@ -252,7 +269,7 @@ class GameRunner extends Game implements EngineListener {
                 var team:Team = teams[tank.playerId.team];
                 if (team.eagleId > 0) {
                     var eagle:Eagle = cast(engine.entities[team.eagleId], Eagle);
-                    eagle.protect.on(bonus.config.duration);
+                    protectEagle(eagle, bonus.config.duration);
                 }
             case "gun":
                 upgradeTank(tank, 5);
@@ -293,12 +310,20 @@ class GameRunner extends Game implements EngineListener {
     }
 
     override public function onGameEvent(event:GameEvent):Void {
+        if (pause) {
+            switch event {
+                case ACTION(_): return;
+                case _:
+            }
+        }
         super.onGameEvent(event);
         switch event {
             case START(_):
+                engine.ticker.start();
                 timer = new Timer(30);
                 timer.run = update;
             case COMPLETE(_, _):
+                engine.ticker.stop();
                 if (timer != null) {
                     timer.stop();
                     timer = null;
@@ -306,25 +331,20 @@ class GameRunner extends Game implements EngineListener {
             case ACTION(tankId, SHOT):
                 var tank:Tank = cast engine.entities.get(tankId);
                 var player = getPlayer(tank.playerId);
-                if (!tank.freezing.active && player.bullets < tank.config.bullets) {
+                if (!tank.freezing && player.bullets < tank.config.bullets) {
                     var rect = tank.rect;
                     var point = rect.center.add(new Point(rect.width / 4 * rect.direction.x, rect.height / 4 * rect.direction.y));
                     var bullet = builder.buildBullet(point, rect.direction, player.id, tank.config.type);
                     bullet.tank = tank;
                     bullet.move(bullet.rect.direction);
                     engine.spawn(bullet);
-                    gameEventSignal.emit(SPAWN(BULLET(bullet.id, bullet.rect.clone(), bullet.playerId, bullet.config.piercing)));
+                    gameEventSignal.emit(EventUtil.buildBulletSpawn(bullet));
                 }
             case ACTION(tankId, MOVE(direction)):
                 engine.move(tankId, direction);
             case ACTION(tankId, STOP):
                 gameEventSignal.emit(STOP(TANK(tankId)));
                 engine.stop(tankId);
-            case SPAWN(TANK(_, _, playerId, _)):
-                var control = getPlayer(playerId).control;
-                if (control != null) {
-                    control.start();
-                }
             case SPAWN(BULLET(_, _, playerId, _)):
                 getPlayer(playerId).bullets++;
             case DESTROY(EAGLE(id, shot)):
@@ -339,9 +359,6 @@ class GameRunner extends Game implements EngineListener {
                 var tank:Tank = engine.getEntity(id);
                 var team = getTeam(tank.playerId.team);
                 var player = getPlayer(tank.playerId);
-                if (player.control != null) {
-                    player.control.stop();
-                }
                 player.tankId = -1;
                 team.onDestroy(player.id);
                 if (player.state.life > 0) {
@@ -351,7 +368,7 @@ class GameRunner extends Game implements EngineListener {
                 }
                 var respawn:Bool = team.tryRespawn(player.id);
                 if (respawn) {
-                    team.spawner.push(player.id);
+                    team.spawner.push(engine.ticker, player.id);
                 }
                 if (!team.isAlive) {
                     checkComplete();

src/common/haxe/ru/m/tankz/game/GameState.hx

@@ -38,6 +38,7 @@ class PlayerState extends State {
     public var id:PlayerId;
     public var tank:TankType;
     public var color:Color;
+    public var name:String;
     public var life:Int;
     public var total:State;
 

src/common/haxe/ru/m/tankz/game/IGame.hx

@@ -12,6 +12,7 @@ interface IGame extends GameListener {
     public var winner(default, null):Null<TeamId>;
     public var state(default, null):GameState;
     public var controlFactory(default, null):IControlFactory;
+    public var pause(default, set):Bool;
 
     public var gameEventSignal(default, null):Signal<GameEvent>;
 

src/common/haxe/ru/m/tankz/game/Player.hx

@@ -1,15 +1,13 @@
 package ru.m.tankz.game;
 
-import ru.m.tankz.game.GameState;
 import ru.m.tankz.config.Config;
-import ru.m.tankz.control.Control;
+import ru.m.tankz.game.GameState;
 import ru.m.tankz.Type;
 
 class Player {
     public var config(default, null):PlayerConfig;
     public var id(default, null):PlayerId;
     public var tankId(default, set):Int;
-    public var control(default, set):Control;
     public var isAlive(get, null):Bool;
     public var state(default, default):PlayerState;
     public var bullets(default, default):Int;
@@ -17,7 +15,6 @@ class Player {
     public function new(teamId:TeamId, config:PlayerConfig, state:PlayerState = null) {
         this.config = config;
         this.id = new PlayerId(teamId, config.index);
-        this.control = null;
         this.state = state == null ? new PlayerState(id) : state;
         this.state.reset();
         this.state.life = Math.isNaN(config.life) ? 0 : config.life;
@@ -27,21 +24,9 @@ class Player {
 
     private function set_tankId(value:Int):Int {
         tankId = value;
-        if (control != null) {
-            control.tankId = tankId;
-        }
         return tankId;
     }
 
-    private function set_control(value:Control):Control {
-        if (control != null) control.dispose();
-        control = value;
-        if (control != null) {
-            control.tankId = tankId;
-        }
-        return control;
-    }
-
     private function get_isAlive():Bool {
         return tankId > -1 || state.life > 0;
     }

src/common/haxe/ru/m/tankz/game/Spawner.hx

@@ -1,8 +1,8 @@
 package ru.m.tankz.game;
 
+import ru.m.tankz.engine.ITicker;
 import ru.m.tankz.config.Config;
 import ru.m.tankz.Type;
-import ru.m.Timer;
 
 typedef SpawnTask = {
     var point:SpawnPoint;
@@ -18,7 +18,6 @@ class Spawner {
     private var config:TeamConfig;
     private var points:Array<SpawnPoint>;
     private var queue:Array<SpawnTask>;
-    private var timer:Timer;
 
     private var indexedPoints:Map<Int, SpawnPoint>;
     private var anyPoints:Array<SpawnPoint>;
@@ -61,7 +60,7 @@ class Spawner {
         return null;
     }
 
-    public function push(playerId:PlayerId):Void {
+    public function push(ticker:ITicker, playerId:PlayerId):Void {
         var point:SpawnPoint = null;
         if (indexedPoints.exists(playerId.index)) {
             point = indexedPoints.get(playerId.index);
@@ -71,24 +70,16 @@ class Spawner {
         }
         if (point != null) {
             queue.push({playerId:playerId, point:point, tankType:getPlayerTank(playerId)});
-            run();
+            if (config.spawnInterval == null) {
+                ticker.emit(spawn, 500);
+            } else {
+                ticker.emit(spawn, 500 + config.spawnInterval * queue.length);
             }
         }
-
-    private function run():Void {
-        if (timer == null) {
-            timer = new Timer(config.spawnInterval == null ? 500 : config.spawnInterval);
-            timer.run = spawn;
-        }
     }
 
     private function spawn():Void {
-        if (queue.length == 0) {
+        if (queue.length > 0) {
-            if (timer != null) {
-                timer.stop();
-                timer = null;
-            }
-        } else {
             runner(queue.shift());
         }
     }

src/common/haxe/ru/m/tankz/game/record/GameRecorder.hx

@@ -1,5 +1,6 @@
 package ru.m.tankz.game.record;
 
+import ru.m.tankz.engine.ITicker;
 import ru.m.tankz.engine.Ticker;
 import ru.m.tankz.game.IGame;
 
@@ -7,7 +8,7 @@ class GameRecorder implements GameListener {
 
     public var record(default, null):GameRecord;
 
-    private var ticker:Ticker;
+    private var ticker:ITicker;
 
     public function new() {
         ticker = new Ticker();
@@ -15,10 +16,9 @@ class GameRecorder implements GameListener {
     }
 
     public function onGameEvent(event:GameEvent):Void {
-        if (!ticker.running) ticker.start();
-        record.events.push({time: ticker.time, event: event});
         switch event {
             case GameEvent.START(state):
+                ticker.start();
                 record.info.type = state.type;
                 record.info.presetId = state.presetId;
                 record.info.levelId = state.levelId;
@@ -27,5 +27,7 @@ class GameRecorder implements GameListener {
                 ticker.stop();
             case _:
         }
+        ticker.tick();
+        record.events.push({time: ticker.time, event: event});
     }
 }

src/common/proto/core.proto

@@ -7,23 +7,9 @@ message UserProto {
     string name = 2;
 }
 
-enum GameStateProto {
-    READY = 0;
-    STARTED = 1;
-    ENDED = 2;
-}
-
-message PlayerProto {
-    UserProto user = 1;
-    string team = 2;
-    int32 index = 3;
-}
-
 message GameProto {
     int32 id = 1;
     string type = 2;
     int32 level = 3;
-    UserProto creator = 4;
+    bool started = 4;
-    repeated PlayerProto players = 5;
-    GameStateProto state = 6;
 }

src/common/proto/game.proto

@@ -2,27 +2,116 @@ syntax = "proto3";
 
 package ru.m.tankz.proto.game;
 
-
+message PositionProto {
-enum GameActionTypeProto {
+    float x = 1;
-    MOVE = 0;
+    float y = 2;
-    SHOT = 1;
-    STOP = 2;
 }
 
-enum GameChangeTypeProto {
+message RectangleProto {
-    MOVED = 0;
+    float x = 1;
-    DESTROED = 1;
+    float y = 2;
-    MODIFIED = 2;
+    float width = 3;
-    APPEND = 3;
+    float height = 4;
-    DIRECTION = 4;
 }
 
-message GameChangeProto {
+message ShotProto {
-    GameChangeTypeProto type = 1;
+    int32 tankId = 1;
-    string entityType = 2;
+    int32 bulletId = 2;
-    int32 entityId = 3;
+    int32 score = 3;
-    float x = 4;
+}
-    float y = 5;
+
-    int32 directionX = 6;
+message BrickProto {
-    int32 directionY = 7;
+    int32 gridX = 1;
+    int32 gridY = 2;
+    string type = 3;
+}
+
+message EagleProto {
+    string team = 1;
+}
+
+message TankProto {
+    string team = 1;
+    int32 index = 2;
+    string type = 3;
+    int32 hits = 4;
+    bool bonus = 5;
+    int32 color = 6;
+    string name = 7;
+}
+
+message BulletProto {
+    string team = 1;
+    int32 index = 2;
+    int32 piercing = 3;
+}
+
+message BonusProto {
+    string type = 1;
+}
+
+message GameStateProto {
+    string state = 1;
+}
+
+message GameEventStartProto {
+    GameStateProto state = 1;
+}
+
+message GameEventCompleteProto {
+    GameStateProto state = 1;
+}
+
+message GameEventSpawnProto {
+    int32 entityId = 1;
+    RectangleProto rectangle = 2;
+    oneof entity {
+        EagleProto eagle = 3;
+        TankProto tank = 4;
+        BulletProto bullet = 5;
+        BonusProto bonus = 6;
+        BrickProto bricks = 7;
+    }
+}
+
+message GameEventMoveProto {
+    int32 entityId = 1;
+    PositionProto position = 2;
+}
+
+message GameEventStopProto {
+    int32 entityId = 1;
+}
+
+message GameEventHitProto {
+    int32 entityId = 1;
+    ShotProto shot = 2;
+}
+
+message GameEventDestroyProto {
+    int32 entityId = 1;
+    ShotProto shot = 2;
+}
+
+message GameEventActionProto {
+    int32 entityId = 1;
+    oneof action {
+        PositionProto move = 2;
+        bool stop = 3;
+        bool shot = 4;
+    }
+}
+
+message GameEventProto {
+    int32 time = 1;
+    oneof event {
+        GameEventStartProto start = 2;
+        GameEventCompleteProto complete = 3;
+        GameEventSpawnProto spawn = 4;
+        GameEventMoveProto move = 5;
+        GameEventStopProto stop = 6;
+        GameEventHitProto hit = 7;
+        GameEventDestroyProto destroy = 8;
+        GameEventActionProto action = 9;
+    }
 }

src/common/proto/pack.proto

@@ -2,16 +2,15 @@ syntax = "proto3";
 
 import "core.proto";
 import "game.proto";
+import "room.proto";
 
 package ru.m.tankz.proto.pack;
 
-
 message ErrorResponse {
     int32 code = 1;
     string message = 2;
 }
 
-// Login
 message LoginRequest {
     string uuid = 1;
     string name = 2;
@@ -21,89 +20,35 @@ message LoginResponse {
     ru.m.tankz.proto.core.UserProto user = 1;
 }
 
-// Logout
 message LogoutRequest {}
 
 message LogoutResponse {}
 
-// List Game
-message ListGameRequest {}
-
-message ListGameResponse {
-    repeated ru.m.tankz.proto.core.GameProto games = 1;
-}
-
-// Create Game
-message CreateGameRequest {
-    string type = 1;
-    int32 level = 2;
-}
-
-message CreateGameResponse {
-    ru.m.tankz.proto.core.GameProto game = 1;
-}
-
-// Join Game
-message JoinGameRequest {
-    int32 game_id = 1;
-}
-
-message JoinGameResponse {
-    ru.m.tankz.proto.core.GameProto game = 1;
-    ru.m.tankz.proto.core.UserProto user = 2;
-}
-
-// Leave Game
-message LeaveGameRequest {}
-
-message LeaveGameResponse {
-    ru.m.tankz.proto.core.GameProto game = 1;
-    ru.m.tankz.proto.core.UserProto user = 2;
-}
-
-// Start Game
-message StartGameRequest {}
-
-message StartGameResponse {
-    ru.m.tankz.proto.core.GameProto game = 1;
-}
-
-// Game
 message GameEventRequest {
-    int32 time = 1;
+    ru.m.tankz.proto.game.GameEventProto event = 1;
-    string event = 2;
 }
 
 message GameEventResponse {
-    int32 time = 1;
+    ru.m.tankz.proto.game.GameEventProto event = 1;
-    string event = 2;
 }
 
-// Request
 message Request {
     oneof content {
         LoginRequest login = 1;
         LogoutRequest logout = 2;
-        ListGameRequest listGame = 3;
+        ru.m.tankz.proto.room.RoomRequest room = 3;
-        CreateGameRequest createGame = 4;
+        ru.m.tankz.proto.room.RoomListRequest roomList = 4;
-        JoinGameRequest joinGame = 5;
+        GameEventRequest gameEvent = 6;
-        LeaveGameRequest leaveGame = 6;
-        StartGameRequest startGame = 7;
-        GameEventRequest gameEvent = 8;
     }
 }
 
-// Response
 message Response {
     oneof content {
         LoginResponse login = 1;
         LogoutResponse logout = 2;
-        ListGameResponse listGame = 3;
+        ru.m.tankz.proto.room.RoomResponse room = 3;
-        CreateGameResponse createGame = 4;
+        ru.m.tankz.proto.room.RoomListResponse roomList = 4;
-        JoinGameResponse joinGame = 5;
+        GameEventResponse gameEvent = 6;
-        LeaveGameResponse leaveGame = 6;
-        StartGameResponse startGame = 7;
-        GameEventResponse gameEvent = 8;
 
         ErrorResponse error = 999;
     }

src/common/proto/room.proto

@@ -0,0 +1,64 @@
+syntax = "proto3";
+
+import "core.proto";
+
+package ru.m.tankz.proto.room;
+
+message SlotProto {
+    string team = 3;
+    int32 index = 4;
+}
+
+message RoomSlotProto {
+    SlotProto slot = 1;
+    ru.m.tankz.proto.core.UserProto user = 2;
+}
+
+message RoomProto {
+    ru.m.tankz.proto.core.GameProto game = 1;
+    ru.m.tankz.proto.core.UserProto creator = 2;
+    repeated ru.m.tankz.proto.core.UserProto users = 3;
+    repeated RoomSlotProto slots = 4;
+}
+
+message CreateRequest {
+    string type = 2;
+    int32 level = 3;
+}
+
+message JoinRequest {
+    int32 gameId = 1;
+    bool restore = 2;
+}
+
+message LeaveRequest {
+}
+
+message SlotRequest {
+    SlotProto slot = 3;
+}
+
+message StartRequest {
+}
+
+message RoomRequest {
+    oneof content {
+        CreateRequest create = 1;
+        JoinRequest join = 2;
+        LeaveRequest leave = 3;
+        SlotRequest slot = 4;
+        StartRequest start = 5;
+    }
+}
+
+message RoomResponse {
+    RoomProto room = 1;
+}
+
+message RoomListRequest {
+    bool subscribe = 1;
+}
+
+message RoomListResponse {
+    repeated RoomProto rooms = 1;
+}

src/common/resources/classic/config.yaml

@@ -203,10 +203,13 @@ controls:
       values:
           - playerId: [human, 0]
             control: human-0
+            name: Player 1
     - id: 1
       name: 2 Player
       values:
           - playerId: [human, 0]
             control: human-0
+            name: Player 1
           - playerId: [human, 1]
             control: human-1
+            name: Player 2

src/common/resources/death/config.yaml

@@ -96,10 +96,13 @@ controls:
       values:
           - playerId: [alpha, 0]
             control: human-0
+            name: Player 1
     - id: 1
       name: 2 Player
       values:
           - playerId: [alpha, 0]
             control: human-0
+            name: Player 1
           - playerId: [beta, 0]
             control: human-1
+            name: Player 2

src/common/resources/dota/config.yaml

@@ -122,21 +122,26 @@ controls:
           - playerId: [radiant, 0]
             control: human-0
             color: 0xff8866
+            name: Player 1
     - id: 1
       name: 2 Player Coop
       values:
           - playerId: [radiant, 0]
             control: human-0
             color: 0xff8866
+            name: Player 1
           - playerId: [radiant, 1]
             control: human-1
             color: 0xff8866
+            name: Player 2
     - id: 2
       name: 2 Player VS
       values:
           - playerId: [radiant, 0]
             control: human-0
             color: 0xff8866
+            name: Player 1
           - playerId: [dire, 0]
             control: human-1
             color: 0x4294ff
+            name: Player 2

src/editor/haxe/ru/m/tankz/editor/level/MapEditView.hx

@@ -46,17 +46,15 @@ enum Brush {
 
     override private function drawBackground():Void {
         super.drawBackground();
-        var mapWidth = map.gridWidth * map.cellWidth;
-        var mapHeight = map.gridHeight * map.cellHeight;
         var g:Graphics = backgroundLayer.graphics;
         g.lineStyle(1, 0x007700);
-        for (x in 0...map.gridWidth) {
+        for (x in 0...config.map.gridWidth) {
-            g.moveTo(x * map.cellWidth, 0);
+            g.moveTo(x * config.map.cellWidth, 0);
-            g.lineTo(x * map.cellWidth, mapHeight);
+            g.lineTo(x * config.map.cellWidth, config.mapHeight);
         }
-        for (y in 0...map.gridHeight) {
+        for (y in 0...config.map.gridHeight) {
-            g.moveTo(0, y * map.cellHeight);
+            g.moveTo(0, y * config.map.cellHeight);
-            g.lineTo(mapWidth, y * map.cellHeight);
+            g.lineTo(config.mapWidth, y * config.map.cellHeight);
         }
     }
 
@@ -117,7 +115,7 @@ enum Brush {
                     var playerId = new PlayerId(point.team, point.index < 0 ? 0 : point.index);
                     var player = config.getPlayer(playerId);
                     var tankSpawn = player.tanks[0];
-                    var tank = builder.buildTank(point, playerId, tankSpawn.type, 0, true);
+                    var tank = builder.buildTank(point, playerId, tankSpawn.type, 0, playerId.toString(), true);
                     pointEntities[pointKey(point)] = tank;
                     gameEventSignal.emit(EventUtil.buildTankSpawn(tank));
             }

src/server/haxe/ru/m/tankz/server/game/GameManager.hx

@@ -4,8 +4,10 @@ import ru.m.tankz.game.GameEvent;
 import ru.m.tankz.game.IGame.GameListener;
 import ru.m.tankz.game.IGame;
 import ru.m.tankz.proto.core.GameProto;
-import ru.m.tankz.proto.core.GameStateProto;
 import ru.m.tankz.proto.core.UserProto;
+import ru.m.tankz.proto.room.RoomProto;
+import ru.m.tankz.proto.room.RoomSlotProto;
+import ru.m.tankz.proto.room.SlotProto;
 import ru.m.tankz.server.game.IGameManager;
 
 class _GameListener implements GameListener {
@@ -21,7 +23,7 @@ class _GameListener implements GameListener {
         dispatcher.dispatchEvent(game, event);
         switch event {
             case COMPLETE(_, _):
-                dispatcher.delete(game.proto.id);
+                dispatcher.delete(game.id);
                 dispose();
             case _:
         }
@@ -52,26 +54,36 @@ class _GameListener implements GameListener {
 
     public function create(user:UserProto, type:String, level:Int):ServerGame {
         if (gamesByCreator.exists(user.uuid)) {
-            delete(gamesByCreator[user.uuid].proto.id);
+            delete(gamesByCreator[user.uuid].id);
         }
-        var proto = new GameProto()
+        var room = new RoomProto()
+        .setGame(
+            new GameProto()
             .setId(++counter)
-        .setCreator(user)
             .setType(type)
-        .setLevel(level);
+            .setLevel(level)
-        var game = new ServerGame(proto);
+        )
-        game.joinUser(user);
+        .setCreator(user);
+        var game = new ServerGame(room);
+        var slots:Array<RoomSlotProto> = [];
+        for (team in game.state.teams) {
+            for (player in team.players) {
+                slots.push(new RoomSlotProto().setSlot(new SlotProto().setTeam(player.id.team).setIndex(player.id.index)));
+            }
+        }
+        game.room.setSlots(slots);
         games.push(game);
-        gamesById[game.proto.id] = game;
+        gamesById[game.id] = game;
-        gamesByCreator[game.proto.creator.uuid] = game;
+        gamesByCreator[game.room.creator.uuid] = game;
         createSignal.emit(game);
+        join(game.id, user);
         return game;
     }
 
     public function join(gameId:Int, user:UserProto):Void {
         if (gamesById.exists(gameId)) {
             var game = gamesById[gameId];
-            game.joinUser(user);
+            game.join(user);
             gamesByUser[user.uuid] = game;
             changeSignal.emit(game, JOIN(user));
         }
@@ -81,26 +93,35 @@ class _GameListener implements GameListener {
         if (gamesById.exists(gameId)) {
             var game = gamesById[gameId];
             games.remove(game);
-            gamesById.remove(game.proto.id);
+            gamesById.remove(game.id);
-            gamesByCreator.remove(game.proto.creator.uuid);
+            gamesByCreator.remove(game.room.creator.uuid);
             deleteSignal.emit(game);
         }
     }
 
     public function leave(user:UserProto):Void {
-        if (gamesByCreator.exists(user.uuid)) {
+        /*if (gamesByCreator.exists(user.uuid)) {
             delete(gamesByCreator[user.uuid].proto.id);
-        } else if (gamesByUser.exists(user.uuid)) {
+        } else*/ if (gamesByUser.exists(user.uuid)) {
             var game = gamesByUser[user.uuid];
-            game.leaveUser(user);
+            gamesByUser.remove(user.uuid);
+            game.leave(user);
             changeSignal.emit(game, LEAVE(user));
         }
     }
 
+    public function slot(user:UserProto, slot:SlotProto):Void {
+        if (gamesByUser.exists(user.uuid)) {
+            var game = gamesByUser[user.uuid];
+            game.slot(user, slot);
+            changeSignal.emit(game, SLOT(user, slot));
+        }
+    }
+
     public function start(gameId:Int):Void {
         if (gamesById.exists(gameId)) {
             var game:ServerGame = gamesById[gameId];
-            game.proto.setState(GameStateProto.STARTED);
+            game.room.game.setStarted(true);
             changeSignal.emit(game, START);
             game.connect(new _GameListener(game, this));
             game.start();

src/server/haxe/ru/m/tankz/server/game/IGameManager.hx

@@ -1,12 +1,14 @@
 package ru.m.tankz.server.game;
 
-import ru.m.tankz.game.GameEvent;
 import haxework.signal.Signal;
+import ru.m.tankz.game.GameEvent;
 import ru.m.tankz.proto.core.UserProto;
+import ru.m.tankz.proto.room.SlotProto;
 
 enum GameChange {
     JOIN(user:UserProto);
     LEAVE(user:UserProto);
+    SLOT(user:UserProto, slot:SlotProto);
     START();
 }
 
@@ -21,6 +23,7 @@ interface IGameManager {
     public var games(default, null):Array<ServerGame>;
     public var gamesById(default, null):Map<Int, ServerGame>;
     public var gamesByCreator(default, null):Map<String, ServerGame>;
+    public var gamesByUser(default, null):Map<String, ServerGame>;
 
     private var createSignal(default, null):Signal<ServerGame>;
     private var changeSignal(default, null):Signal2<ServerGame, GameChange>;
@@ -35,6 +38,7 @@ interface IGameManager {
     public function create(user:UserProto, type:String, level:Int):ServerGame;
     public function delete(gameId:Int):Void;
     public function join(gameId:Int, user:UserProto):Void;
+    public function slot(user:UserProto, slot:SlotProto):Void;
     public function leave(user:UserProto):Void;
     public function start(gameId:Int):Void;
 }

src/server/haxe/ru/m/tankz/server/game/ServerGame.hx

@@ -1,39 +1,99 @@
 package ru.m.tankz.server.game;
 
+import ru.m.tankz.proto.room.RoomSlotProto;
 import ru.m.tankz.config.Config;
+import ru.m.tankz.core.EntityType;
+import ru.m.tankz.game.EventUtil;
+import ru.m.tankz.game.GameEvent;
 import ru.m.tankz.game.GameRunner;
 import ru.m.tankz.game.GameState;
-import ru.m.tankz.proto.core.GameProto;
-import ru.m.tankz.proto.core.PlayerProto;
 import ru.m.tankz.proto.core.UserProto;
+import ru.m.tankz.proto.room.RoomProto;
+import ru.m.tankz.proto.room.SlotProto;
 import ru.m.tankz.server.control.ServerControlFactory;
 
 class ServerGame extends GameRunner {
 
     public var runner(default, null):GameRunner;
-    public var proto(default, null):GameProto;
+    public var room(default, null):RoomProto;
+    public var id(get, null):Int;
 
-    public function new(proto:GameProto) {
+    public function new(room:RoomProto) {
-        super(new GameState(proto.type, 0, proto.level));
+        super(new GameState(room.game.type, 0, room.game.level));
         this.controlFactory = new ServerControlFactory();
-        this.proto = proto;
+        this.room = room;
     }
 
-    public function joinUser(user:UserProto):Void {
+    private inline function get_id():Int {
-        var index = proto.players.length;
+        return room.game.id;
-        var teamId = "human"; // ToDo:
-        proto.players.push(new PlayerProto().setUser(user).setTeam(teamId).setIndex(index));
     }
 
-    public function leaveUser(user:UserProto):Void {
+    public function contains(user:UserProto):Bool {
-        proto.setPlayers(proto.players.filter(function(player) return player.user.uuid != user.uuid));
+        for (slot in room.slots) {
+            if (slot.hasUser() && slot.user.uuid == user.uuid) {
+                return true;
+            }
+        }
+        return false;
+    }
+
+    public function join(user:UserProto):Void {
+        if (!contains(user)) {
+            room.users.push(user);
+        }
+    }
+
+    public function slot(user:UserProto, slot:SlotProto):Void {
+        join(user);
+        for (s in room.slots) {
+            if (s.hasUser() && s.user.uuid == user.uuid) {
+                s.clearUser();
+                break;
+            }
+        }
+        for (s in room.slots) {
+            if (s.slot.team == slot.team && s.slot.index == slot.index) {
+                s.setUser(user);
+                break;
+            }
+        }
+    }
+
+    public function leave(user:UserProto):Void {
+        for (slot in room.slots) {
+            if (slot.user != null && slot.user.uuid == user.uuid) {
+                slot.clearUser();
+                break;
+            }
+        }
+        room.setUsers(room.users.filter(function(u:UserProto) return u.uuid != user.uuid));
     }
 
     override public function start():Void {
-        state.controls = proto.players.map(function(player):PlayerControl return {
+        state.controls = room.slots
-            playerId: [player.team, player.index],
+        .filter(function(slot:RoomSlotProto) return slot.hasUser())
-            control: 'human-0'
+        .map(function(slot:RoomSlotProto):PlayerControl return {
+            playerId: [slot.slot.team, slot.slot.index],
+            control: "human-0",
+            name: slot.user.name,
         });
         super.start();
     }
+
+    public function restore():Array<GameEvent> {
+        var result = [];
+        result.push(EventUtil.buildBricksSpawn(engine.map));
+        result = result.concat(EventUtil.buildCellsDestroyed(engine.map));
+        result.push(START(state));
+        for (entity in engine.entities) {
+            switch EntityTypeResolver.of(entity) {
+                case EAGLE(eagle): result.push(EventUtil.buildEagleSpawn(eagle));
+                case TANK(tank): result.push(EventUtil.buildTankSpawn(tank));
+                case BONUS(bonus): result.push(EventUtil.buildBonusSpawn(bonus));
+                case BULLET(bullet): result.push(EventUtil.buildBulletSpawn(bullet));
+                case CELL(_):
+            }
+        }
+        return result;
+    }
 }

src/server/haxe/ru/m/tankz/server/session/GameSession.hx

@@ -1,23 +1,21 @@
 package ru.m.tankz.server.session;
 
-import haxe.Unserializer;
+import ru.m.tankz.proto.game.GameEventProto;
-import haxe.Serializer;
-import ru.m.tankz.proto.pack.GameEventResponse;
-import ru.m.tankz.game.GameEvent;
 import com.hurlant.crypto.extra.UUID;
 import com.hurlant.crypto.prng.Random;
+import haxe.Serializer;
+import haxe.Unserializer;
 import haxework.log.BaseLogger.LoggerUtil;
+import ru.m.tankz.game.GameEvent;
 import ru.m.tankz.proto.core.UserProto;
-import ru.m.tankz.proto.pack.CreateGameResponse;
 import ru.m.tankz.proto.pack.ErrorResponse;
-import ru.m.tankz.proto.pack.JoinGameResponse;
+import ru.m.tankz.proto.pack.GameEventResponse;
-import ru.m.tankz.proto.pack.LeaveGameResponse;
-import ru.m.tankz.proto.pack.ListGameResponse;
 import ru.m.tankz.proto.pack.LoginResponse;
 import ru.m.tankz.proto.pack.LogoutResponse;
 import ru.m.tankz.proto.pack.Request;
 import ru.m.tankz.proto.pack.Response;
-import ru.m.tankz.proto.pack.StartGameResponse;
+import ru.m.tankz.proto.room.RoomListResponse;
+import ru.m.tankz.proto.room.RoomResponse;
 import ru.m.tankz.server.game.IGameManager;
 import ru.m.tankz.server.game.ServerGame;
 import sys.net.Socket;
@@ -30,6 +28,7 @@ class GameSession extends ProtoSession<Response, Request> implements GameManager
     public var user(default, null):UserProto;
     public var gameId(default, null):Int;
 
+    private var subscribed:Bool;
     private var tag(get, never):String;
 
     private function get_tag():String {
@@ -45,9 +44,9 @@ class GameSession extends ProtoSession<Response, Request> implements GameManager
         send(new Response().setError(new ErrorResponse().setCode(code).setMessage(message)));
     }
 
-    private function listGame():ListGameResponse {
+    private function listGame():RoomListResponse {
         var games = gameManager.games;
-        return new ListGameResponse().setGames([for (game in games) game.proto]);
+        return new RoomListResponse().setRooms([for (game in games) game.room]);
     }
 
     override public function send(packet:Response):Void {
@@ -59,15 +58,26 @@ class GameSession extends ProtoSession<Response, Request> implements GameManager
         }
     }
 
-    private function logout():Void {
+    private function logout(leave:Bool = true):Void {
         gameId = -1;
         gameManager.disconnect(this);
-        if (user != null) {
+        if (user != null && leave) {
             gameManager.leave(user);
             user = null;
         }
     }
 
+    private function join(gameId:Int, restore:Bool):Void {
+        this.gameId = gameId;
+        gameManager.join(gameId, user);
+        var game = gameManager.gamesById[gameId];
+        if (restore && game.room.game.started) {
+            for (event in game.restore()) {
+                send(new Response().setGameEvent(new GameEventResponse().setEvent(new GameEventProto().setTime(0).setEvent(Serializer.run(event)))));
+            }
+        }
+    }
+
     override private function onRequest(request:Request):Void {
         #if proto_debug L.d(TAG, '$tag onRequest: ${request}'); #end
         try {
@@ -81,31 +91,37 @@ class GameSession extends ProtoSession<Response, Request> implements GameManager
                 .setName(request.login.name);
                 gameManager.connect(this);
                 send(new Response().setLogin(new LoginResponse().setUser(user)));
+                if (gameManager.gamesByUser.exists(user.uuid)) {
+                    join(gameManager.gamesByUser[user.uuid].id, false);
+                }
             // logout
             } else if (request.hasLogout()) {
                 logout();
                 send(new Response().setLogout(new LogoutResponse()));
-            // create
+            // room
-            } else if (request.hasCreateGame()) {
+            } else if (request.hasRoom()) {
-                var game = gameManager.create(user, request.createGame.type, request.createGame.level);
+                if (request.room.hasCreate()) {
-                gameId = game.proto.id;
+                    var game = gameManager.create(user, request.room.create.type, request.room.create.level);
-                send(new Response().setCreateGame(new CreateGameResponse().setGame(game.proto)));
+                    gameId = game.id;
-            // list
+                    send(new Response().setRoom(new RoomResponse().setRoom(game.room)));
-            } else if (request.hasListGame()) {
+                } else if (request.room.hasJoin()) {
-                send(new Response().setListGame(listGame()));
+                    join(request.room.join.gameId, request.room.join.restore);
-            // join
+                } else if (request.room.hasLeave()) {
-            } else if (request.hasJoinGame()) {
-                gameId = request.joinGame.gameId;
-                gameManager.join(request.joinGame.gameId, user);
-            // leave
-            } else if (request.hasLeaveGame()) {
                     gameManager.leave(user);
-            // start
+                } else if (request.room.hasSlot()) {
-            } else if (request.hasStartGame()) {
+                    gameManager.slot(user, request.room.slot.slot);
+                } else if (request.room.hasStart()) {
                     gameManager.start(gameId);
+                }
+            // room list
+            } else if (request.hasRoomList()) {
+                subscribed = request.roomList.subscribe;
+                if (subscribed) {
+                    send(new Response().setRoomList(listGame()));
+                }
             } else if (request.hasGameEvent()) {
                 if (gameManager.gamesById.exists(gameId)) {
-                    var event:GameEvent = Unserializer.run(request.gameEvent.event);
+                    var event:GameEvent = Unserializer.run(request.gameEvent.event.event);
                     gameManager.gamesById[gameId].gameEventSignal.emit(event);
                 }
             }
@@ -117,50 +133,47 @@ class GameSession extends ProtoSession<Response, Request> implements GameManager
 
     override public function disconnect():Void {
         L.d(TAG, '$tag disconnect');
-        logout();
+        logout(false);
         super.disconnect();
     }
 
     public function onCreate(game:ServerGame):Void {
-        if (gameId == -1) {
+        if (subscribed) {
-            send(new Response().setListGame(listGame()));
+            send(new Response().setRoomList(listGame()));
         }
     }
 
     public function onChange(game:ServerGame, change:GameChange):Void {
-        if (gameId == game.proto.id) {
+        if (gameId == game.id) {
             switch change {
-                case JOIN(user):
-                    if (user.uuid == this.user.uuid) {
-                        gameId = game.proto.id;
-                    }
-                    send(new Response().setJoinGame(new JoinGameResponse().setGame(game.proto).setUser(user)));
                 case LEAVE(user):
                     if (user.uuid == this.user.uuid) {
                         gameId = -1;
+                        send(new Response().setRoom(new RoomResponse()));
+                        return;
                     }
-                    send(new Response().setLeaveGame(new LeaveGameResponse().setGame(game.proto).setUser(user)));
+                case _:
-                case START:
-                    send(new Response().setStartGame(new StartGameResponse().setGame(game.proto)));
             }
-        } else {
+            send(new Response().setRoom(new RoomResponse().setRoom(game.room)));
-            // ToDo: change game event
+        }
-            send(new Response().setListGame(listGame()));
+        if (subscribed) {
+            send(new Response().setRoomList(listGame()));
         }
     }
 
     public function onDelete(game:ServerGame):Void {
-        if (gameId == -1) {
+        if (gameId == game.id) {
-            send(new Response().setListGame(listGame()));
-        } else if (gameId == game.proto.id) {
             gameId = -1;
-            send(new Response().setLeaveGame(new LeaveGameResponse().setGame(game.proto).setUser(user)));
+            send(new Response().setRoom(new RoomResponse()));
+        }
+        if (subscribed) {
+            send(new Response().setRoomList(listGame()));
         }
     }
 
     public function onEvent(game:ServerGame, event:GameEvent):Void {
-        if (gameId == game.proto.id) {
+        if (gameId == game.id) {
-            send(new Response().setGameEvent(new GameEventResponse().setTime(0).setEvent(Serializer.run(event))));
+            send(new Response().setGameEvent(new GameEventResponse().setEvent(new GameEventProto().setTime(0).setEvent(Serializer.run(event)))));
         }
     }
 }