fix(data_updater): ensure GenServer timeouts reset properly

There were cases where DataUpdater GenServer processes might not
shut down automatically due to missing timeout parameters in several
message handlers. This would have caused processes to remain alive
indefinitely, consuming resources.

The following handlers were missing timeout parameters:
- handle_heartbeat: both success and failure cases
- handle_internal: continue case and failure case
- handle_control: success case

Without proper timeout resets, the 3-hour deactivation interval never triggered,
preventing automatic cleanup of disconnected device processes.

Signed-off-by: Davide Briani <davide.briani@secomind.com>

Author: davidebriani

apps/astarte_data_updater_plant/lib/astarte_data_updater_plant/data_updater/server.ex

@@ -81,24 +81,28 @@ defmodule Astarte.DataUpdaterPlant.DataUpdater.Server do
   # TODO remove this when all heartbeats will be moved to internal
   @impl GenServer
   def handle_cast({:handle_heartbeat, message_id, timestamp}, state) do
+    timeout = Config.data_updater_deactivation_interval_ms!()
+
     if MessageTracker.can_process_message(state.message_tracker, message_id) do
       new_state = Core.HeartbeatHandler.handle_heartbeat(state, message_id, timestamp)
-      {:noreply, new_state}
+      {:noreply, new_state, timeout}
     else
-      {:noreply, state}
+      {:noreply, state, timeout}
     end
   end
 
   @impl GenServer
   def handle_cast({:handle_internal, payload, path, message_id, timestamp}, state) do
+    timeout = Config.data_updater_deactivation_interval_ms!()
+
     if MessageTracker.can_process_message(state.message_tracker, message_id) do
       case Impl.handle_internal(state, payload, path, message_id, timestamp) do
-        {:continue, new_state} -> {:noreply, new_state}
+        {:continue, new_state} -> {:noreply, new_state, timeout}
         # No more messages from this device, time out now in order to stop this process
         {:stop, new_state} -> {:noreply, new_state, 0}
       end
     else
-      {:noreply, state}
+      {:noreply, state, timeout}
     end
   end
 
@@ -141,7 +145,7 @@ defmodule Astarte.DataUpdaterPlant.DataUpdater.Server do
 
     if MessageTracker.can_process_message(state.message_tracker, message_id) do
       new_state = Impl.handle_control(state, payload, path, message_id, timestamp)
-      {:noreply, new_state}
+      {:noreply, new_state, timeout}
     else
       {:noreply, state, timeout}
     end