Implement batched messages for Digiline Chests

docs/chest.md

@@ -101,13 +101,24 @@ The message is sent when user takes `<stack>` from `<output slot>` in the chest.
 ```
 The message is sent when user puts `<stack>` to the chest to `<input slot>`
 
+----------------------------
+
+```
+{
+    action = "batch",
+    messages = <messages>
+}
+```
+The message contains an array of other messages (`<messages>`) which were emitted within a very short interval, and for this reason merged into a batch and sent as a single message. This is needed to prevent burning of connected Lua controllers in case of a large amount of messages within a very short time. This can happen in case of using the feature which allows to move all items of the same type between inventories at once by taking one of them, and clicking on another one while holding Shift. Another theoretical scenario - sending a lot of requests to the server associated with inventory operations on a Digiline chest using a hacked client or custom software. The decision whether to include a message into a batch is made based on the interval from the previous message. For this reason, a batch message is always preceded by a single message which wasn't included into the batch because there was enough time from the previous message, and we cannot know in advance when the next message will be sent to include the current one into the batch too.
+
 ### Fields used within the messages
 
 | Field | Description |
 | ----- | ----------- |
 | `<stack>` | A table which contains data about the stack, and corresponds to the format returned by the :to_table() method of ItemStack (check the Minetest API documentation). |
 | `<input slot>`, `<output slot>`, `<slot1>`, `<slot2>` | The index of the corresponding slot starting from 1. |
 | `<side>` | A vector represented as a table of format `{ x = <x>, y = <y>, z = <z> }` which represent the direction from which the tube is connected to the chest. |
+| `<messages>` | An array of messages which are emitted by Digiline chest in the same format. |
 
 ## Additional information
 

inventory.lua

@@ -2,6 +2,43 @@ local S = digilines.S
 
 local pipeworks_enabled = minetest.get_modpath("pipeworks") ~= nil
 
+-- Messages which will be sent in a single batch
+local batched_messages = {}
+-- Maximum interval from the previous message to include the current one into batch (in seconds)
+local interval_to_batch = 0.1
+-- Maximum number of messages in batch
+local max_messages_in_batch = 100
+-- Time of the last message for each chest
+local last_message_time_for_chest = {}
+
+-- Sends the current batch message of a Digiline chest
+-- pos: the position of the Digilines chest node
+-- channel: the channel to which the message will be sent
+local function send_and_clear_batch(pos, channel)
+	local pos_hash = minetest.hash_node_position(pos)
+	if #batched_messages[pos_hash] == 1 then
+		-- If there is only one message is the batch, don't send it in a batch
+		digilines.receptor_send(pos, digilines.rules.default, channel,
+			batched_messages[pos_hash][1])
+	else
+		digilines.receptor_send(pos, digilines.rules.default, channel, {
+			action = "batch",
+			messages = batched_messages[pos_hash]
+		})
+	end
+	batched_messages[pos_hash] = nil
+	last_message_time_for_chest[pos_hash] = nil
+end
+
+-- Send all the batched messages for the chest if present
+local function send_batch_for_chest(pos)
+	if not batched_messages[minetest.hash_node_position(pos)] then
+		return
+	end
+	local channel = minetest.get_meta(pos):get_string("channel")
+	send_and_clear_batch(pos, channel)
+end
+
 -- Sends a message onto the Digilines network.
 -- pos: the position of the Digilines chest node.
 -- action: the action string indicating what happened.
@@ -11,6 +48,7 @@ local pipeworks_enabled = minetest.get_modpath("pipeworks") ~= nil
 -- side: which side of the chest the action occurred (optional).
 local function send_message(pos, action, stack, from_slot, to_slot, side)
 	local channel = minetest.get_meta(pos):get_string("channel")
+
 	local msg = {
 		action = action,
 		stack = stack and stack:to_table(),
@@ -19,6 +57,26 @@ local function send_message(pos, action, stack, from_slot, to_slot, side)
 		-- Duplicate the vector in case the caller expects it not to change.
 		side = side and vector.new(side)
 	}
+
+	-- Check if we need to include the current message into batch
+	local pos_hash = minetest.hash_node_position(pos)
+	local prev_time = last_message_time_for_chest[pos_hash] or 0
+	local cur_time = minetest.get_us_time()
+	last_message_time_for_chest[pos_hash] = cur_time
+	if cur_time - prev_time < 1000000 * interval_to_batch then
+		batched_messages[pos_hash] = batched_messages[pos_hash] or {}
+		table.insert(batched_messages[pos_hash], msg)
+		local node_timer = minetest.get_node_timer(pos)
+		if #batched_messages[pos_hash] >= max_messages_in_batch then
+			-- Send the batch immediately if it's full
+			node_timer:stop()
+			send_and_clear_batch(pos, channel)
+		else
+			node_timer:start(interval_to_batch)
+		end
+		return
+	end
+
 	digilines.receptor_send(pos, digilines.rules.default, channel, msg)
 end
 
@@ -186,6 +244,9 @@ minetest.register_node("digilines:chest", {
 		local inv = meta:get_inventory()
 		inv:set_size("main", 8*4)
 	end,
+	on_destruct = function(pos)
+		send_batch_for_chest(pos)
+	end,
 	after_place_node = tubescan,
 	after_dig_node = tubescan,
 	can_dig = function(pos)
@@ -321,6 +382,11 @@ minetest.register_node("digilines:chest", {
 		send_message(pos, "utake", stack, index)
 		check_empty(pos)
 		minetest.log("action", player:get_player_name().." takes stuff from chest at "..minetest.pos_to_string(pos))
+	end,
+	on_timer = function(pos, _)
+		-- Send all the batched messages when enough time since the last message passed
+		send_batch_for_chest(pos)
+		return false
 	end
 })