TimeCrafters/timecrafters_configuration_tool_desktop
1
0
Fork 0
mirror of https://github.com/TimeCrafters/timecrafters_configuration_tool_desktop.git synced 2025-12-16 05:42:35 +00:00
Code Issues Projects Releases Wiki Activity

Added logo, added Boot screen, renamed dump_config packet to upload_config, misc changes and UX improvements

Browse Source
This commit is contained in:
Cyberarm
2020-06-08 16:08:41 -05:00
parent ef0174fb06
commit f04dfb01e7
13 changed files with 124 additions and 42 deletions
Download Patch File Download Diff File Expand all files Collapse all files

11
lib/tacnet/client.rb
View File

@@ -3,6 +3,7 @@ module TAC
class Client
TAG = "TACNET|Client"
CHUNK_SIZE = 4096
PACKET_TAIL = "\r\n\n"
attr_reader :uuid, :read_queue, :write_queue, :socket,
:packets_sent, :packets_received,
@@ -105,7 +106,7 @@ module TAC
def write(message)
begin
@socket.puts("#{message}\r\n\n")
@socket.puts("#{message}#{PACKET_TAIL}")
rescue => error
@last_socket_error = error
@socket_error = true
@@ -115,18 +116,14 @@ module TAC
end
def read
message = ""
begin
data = @socket.readpartial(CHUNK_SIZE)
message += data
message = @socket.gets
rescue => error
@last_socket_error = error
@socket_error = true
message = ""
break
end until message.end_with?("\r\n\n")
end
return message.strip

6
lib/tacnet/connection.rb
View File

@@ -9,10 +9,10 @@ module TAC
@client = nil
@last_sync_time = 0
@last_sync_time = Gosu.milliseconds
@sync_interval = SYNC_INTERVAL
@last_heartbeat_sent = 0
@last_heartbeat_sent = Gosu.milliseconds
@heartbeat_interval = HEARTBEAT_INTERVAL
@connection_handler = proc do
@@ -63,6 +63,8 @@ module TAC
@client.puts(PacketHandler.packet_heartbeat)
end
sleep @sync_interval / 1000.0
end
end

23
lib/tacnet/packet.rb
View File

@@ -1,26 +1,27 @@
module TAC
class TACNET
class Packet
PROTOCOL_VERSION = 0
PROTOCOL_VERSION = 1
PROTOCOL_HEADER_SEPERATOR = "|"
PROTOCOL_HEARTBEAT = "heartbeat"
PACKET_TYPES = {
handshake: 0,
heartbeat: 1,
dump_config: 2,
download_config: 2,
upload_config: 3,
add_group: 3,
update_group: 4,
delete_group: 5,
add_group: 20,
update_group: 21,
delete_group: 22,
add_action: 6,
update_action: 7,
delete_action: 8,
add_action: 30,
update_action: 31,
delete_action: 32,
add_variable: 9,
update_variable: 10,
delete_variable: 11,
add_variable: 40,
update_variable: 41,
delete_variable: 42,
}
def self.from_stream(message)

57
lib/tacnet/packet_handler.rb
View File

@@ -22,8 +22,10 @@ module TAC
handle_handshake(packet)
when :heartbeat
handle_heartbeat(packet)
when :dump_config
handle_dump_config(packet)
when :download_config
handle_download_config(packet)
when :upload_config
handle_upload_config(packet)
else
log.d(TAG, "No hand off available for packet type: #{packet.type}")
end
@@ -39,16 +41,49 @@ module TAC
def handle_heartbeat(packet)
end
def handle_dump_config(packet)
def handle_upload_config(packet)
begin
hash = JSON.parse(packet.body)
data = JSON.parse(packet.body, symbolize_names: true)
if @host_is_a_connection
File.open("#{TAC::ROOT_PATH}/data/config.json", "w") { |f| f.write packet.body }
if data.is_a?(Array)
# OLDEST CONFIG, upgrade?
$window.push_state(TAC::Dialog::AlertDialog, title: "Invalid Config", message: "Remote config to old.")
$window.backend.update_config
elsif data.is_a?(Hash) && data.dig(:config, :spec_version) == TAC::CONFIG_SPEC_VERSION
$window.push_state(TAC::Dialog::ConfirmDialog, title: "Replace Config", message: "Replace local config\nwith remote config?", callback_method: proc {
File.open("#{TAC::ROOT_PATH}/data/config.json", "w") { |f| f.write packet.body }
$window.backend.update_config
})
elsif data.is_a?(Hash) && data.dig(:config, :spec_version) < TAC::CONFIG_SPEC_VERSION
# OLD CONFIG, Upgrade?
$window.push_state(TAC::Dialog::ConfirmDialog, title: "Upgrade Config", message: "Remote config is an older\nspec version.\nTry to upgrade?", callback_method: proc {})
elsif data.is_a?(Hash) && data.dig(:config, :spec_version) > TAC::CONFIG_SPEC_VERSION
# NEWER CONFIG, Error Out
$window.push_state(TAC::Dialog::AlertDialog, title: "Invalid Config", message: "Client outdated, check for\nupdates.\nSupported config spec:\nv#{TAC::CONFIG_SPEC_VERSION} got v#{data.dig(:config, :spec_version)}")
else
# CONFIG is unknown
$window.push_state(TAC::Dialog::AlertDialog, title: "Invalid Config", message: "Remote config is not supported.")
end
end
rescue JSON::ParserError => e
log.e(TAG, "JSON parsing error: #{e}")
end
end
def handle_download_config(packet)
if @host_is_a_connection
json = JSON.dump($window.backend.config)
$window.backend.tacnet.puts(PacketHandler.packet_upload_config(json))
else
if $server.active_client && $server.active_client.connected?
json = File.read(TAC::CONFIG_PATH)
$server.active_client.puts(PacketHandler.packet_upload_config(json))
end
rescue JSON::ParserError
end
end
@@ -60,10 +95,14 @@ module TAC
Packet.create(Packet::PACKET_TYPES[:heartbeat], Packet::PROTOCOL_HEARTBEAT)
end
def self.packet_dump_config(string)
def self.packet_download_config
Packet.create(Packet::PACKET_TYPES[:download_config], "")
end
def self.packet_upload_config(string)
string = string.gsub("\n", " ")
Packet.create(Packet::PACKET_TYPES[:dump_config], string)
Packet.create(Packet::PACKET_TYPES[:upload_config], string)
end
end
end

10
lib/tacnet/server.rb
View File

@@ -6,6 +6,8 @@ module TAC
:packets_sent, :packets_received, :data_sent, :data_received,
:client_last_packets_sent, :client_last_packets_received, :client_last_data_sent, :client_last_data_received
def initialize(port = DEFAULT_PORT)
$server = self
@port = port
@socket = nil
@@ -16,10 +18,10 @@ module TAC
@packets_sent, @packets_received, @client_last_packets_sent, @client_last_packets_received = 0, 0, 0, 0
@data_sent, @data_received, @client_last_data_sent, @client_last_data_received = 0, 0, 0, 0
@last_sync_time = 0
@last_sync_time = Gosu.milliseconds
@sync_interval = SYNC_INTERVAL
@last_heartbeat_sent = 0
@last_heartbeat_sent = Gosu.milliseconds
@heartbeat_interval = HEARTBEAT_INTERVAL
@client_handler_proc = proc do
@@ -72,7 +74,7 @@ module TAC
config = File.read(TAC::CONFIG_PATH)
@active_client.puts(PacketHandler.packet_handshake(@active_client.uuid))
@active_client.puts(PacketHandler.packet_dump_config(config))
@active_client.puts(PacketHandler.packet_upload_config(config))
log.i(TAG, "Client connected!")
@@ -111,6 +113,8 @@ module TAC
@active_client.puts(PacketHandler.packet_heartbeat)
end
sleep @sync_interval / 1000.0
end
end