syntax = "proto3";
// Название пакета
option java_package = "me.ktori.game.proto";
// Название класса в котором будут находиться подклассы сообщений
option java_outer_classname = "GameProto";

//
// Сообщения клиент-сервер
//
// Запрос на изменение имени
message ClSetName {
  string name = 1;
}
// Отправка сообщения в чат
message ClSendChatMessage {
  string text = 1;
}
// Объединение всех сообщений, отсылаемых клиентом
message ClMessage {
  // Только одно из этих полей может быть заполнено, таким образом сервер
  // может быстро определить, что именно хочет сделать клиент
  oneof data {
    ClSetName set_name = 1;
    ClSendChatMessage send_chat_message = 2;
  }
}

//
// Сообщения сервер-клиент
//
// Результат выполнения команды ClSetName
message ClSetNameResult {
  // Удалось ли изменить имя - имя нельзя изменить на уже занятое
  bool success = 1;
}
// Отсылается сервером - объединение всех возможных результатов выполнения команды от клиента
message ClMessageResult {
  oneof result {
    ClSetNameResult set_name = 1;
  }
}
// Отсылается клиенту один раз при соединении
// Получатель этого сообщения сохраняет у себя полученный ID и выданное сервером имя
message SvConnected {
  int32 id = 1;
  string name = 2;
}
// Уведомление о подключении нового клиента
// Получатель должен сохранить имя клиента по ID
message SvClientConnected {
  int32 id = 1;
  string name = 2;
}
// Уведомление об отключении клиента
// Получатель может удалить у себя информацию о клиенте по ID
message SvClientDisconnected {
  int32 id = 1;
}
// Уведомление об изменении имени
// Получатель должен изменить имя клиента по ID на новое
message SvNameChanged {
  int32 id = 1;
  string name = 2;
}
// Сообщение в чате
message SvChatMessage {
  int32 from = 1;
  string text = 2;
}
// Объединение всех сообщений которые сервер посылает клиенту
message SvMessage {
  // Только одно из этих полей будет заполнено в одном SvMessage
  oneof data {
    ClMessageResult result = 1;
    SvConnected connected = 2;
    SvClientConnected client_connected = 3;
    SvClientDisconnected client_disconnected = 4;
    SvNameChanged name_changed = 5;
    SvChatMessage chat_message = 6;
  }
}

extends Node2D
var ws: WebSocketClient
# Вызывается при загрузке сцены
func _ready():
    # Создаем WebSocketClient и подключаем обработчики событий
    ws = WebSocketClient.new()
    ws.connect("connection_established", self, "_on_ws_connection_established")
    ws.connect("data_received", self, "_on_ws_data_received")
    # Подключаемся к локалхосту по порту 8080
    ws.connect_to_url("ws://127.0.0.1:8080")
# Будет вызываться при установке соединения
func _on_ws_connection_established(_protocol):
    pass
# Будет вызываться при получении сообщений из вебсокета
func _on_ws_data_received():
    pass

const GameProto = preload("res://game_proto.gd")

# Изменяем имя на введенное в $Name
func _on_SetName_pressed():
    var msg = GameProto.ClMessage.new()
    var sn = msg.new_set_name()
    sn.set_name(name_input.text)
    send_msg(msg)
# Отправляем сообщение из $Message и очищаем поле
func _on_SendMessage_pressed():
    var msg = GameProto.ClMessage.new()
    var scm = msg.new_send_chat_message()
    scm.set_text(message_input.text)
    message_input.clear()
    send_msg(msg)

# Отправляет ClMessage на сервер
func send_msg(msg: GameProto.ClMessage):
    # Конвертируем ClMessage в PoolByteArray и отправляем его по соединению ws
    ws.get_peer(1).put_packet(msg.to_bytes())

# Вызывается часто по интервалу
func _process(_delta):
    # Производит чтение из вебсокета, читает входящие сообщения
    ws.poll()
# Будет вызываться при установке соединения
func _on_ws_connection_established(_protocol):
    show_message("Connection established!")
# Будет вызываться при получении сообщений из вебсокета
func _on_ws_data_received():
    # Обработка каждого пакета в очереди
    for i in range(ws.get_peer(1).get_available_packet_count()):
        # Сырые данные из пакета
        var bytes = ws.get_peer(1).get_packet()
        var sv_msg = GameProto.SvMessage.new()
        # Превращение массива байтов в структурированное сообщение
        sv_msg.from_bytes(bytes)
        # Обрабатываем уже сконвертированное сообщение
        _on_proto_msg_received(sv_msg)
# Будет вызываться после чтения и конвертации сообщения из вебсокета
func _on_proto_msg_received(msg: GameProto.SvMessage):
    # т.к. все эти поля находятся в блоке oneof - заполнено может быть только
    # одно из них
    if msg.has_connected():
        pass
    elif msg.has_client_connected():
        pass
    elif msg.has_client_disconnected():
        pass
    elif msg.has_chat_message():
        pass
    elif msg.has_name_changed():
        pass
    elif msg.has_result():
        pass
    else:
        push_warning("Received unknown message: %s" % msg.to_string())

# Хранит ID этого клиента
var own_id: int
# Хранит пары ID <> Имя
var names = Dictionary()

# Внутри _on_proto_msg_received
  if msg.has_connected():
    var c = msg.get_connected()
    own_id = c.get_id()
    name_input.text = c.get_name()
    show_message("Welcome! Your ID is %d and your assigned name is '%s'." % [c.get_id(), c.get_name()])