chore: add path_on_device to file download request

Add trigger to track the path on device for file download requests.

Signed-off-by: Omar <omar.brbutovic@secomind.com>

Author: OmarBrbutovic

REUSE.toml

@@ -60,7 +60,7 @@ SPDX-License-Identifier = "Apache-2.0"
 [[annotations]]
 path = "backend/priv/astarte_resources/trigger_templates/**.json.eex"
 precedence = "aggregate"
-SPDX-FileCopyrightText = "2023-2025 Seco Mind Srl"
+SPDX-FileCopyrightText = "2023-2026 Seco Mind Srl"
 SPDX-License-Identifier = "Apache-2.0"
 
 [[annotations]]

backend/lib/edgehog/files/file_download_request/file_download_request.ex

@@ -144,6 +144,18 @@ defmodule Edgehog.Files.FileDownloadRequest do
 
       run ManualActions.SendFileDownloadRequest
     end
+
+    update :set_path_on_device do
+      argument :path_on_device, :string, allow_nil?: false
+
+      change set_attribute(:path_on_device, arg(:path_on_device))
+    end
+
+    update :set_size_bytes do
+      argument :decompressed_file_size_bytes, :integer, allow_nil?: false
+
+      change set_attribute(:uncompressed_file_size_bytes, arg(:decompressed_file_size_bytes))
+    end
   end
 
   attributes do
@@ -217,6 +229,11 @@ defmodule Edgehog.Files.FileDownloadRequest do
       public? true
     end
 
+    attribute :path_on_device, :string do
+      description "Path on the device for the transferred file"
+      public? true
+    end
+
     attribute :progress, :boolean do
       description "Flag to enable the progress reporting of the download."
       public? true

backend/lib/edgehog/files/files.ex

@@ -84,7 +84,10 @@ defmodule Edgehog.Files do
     resource Repository
 
     resource FileDownloadRequest do
+      define :fetch_file_download_request, action: :read, get_by: [:id]
       define :send_file_download_request, args: [:file_download_request]
+      define :set_path_on_device, args: [:path_on_device]
+      define :set_size_bytes, args: [:decompressed_file_size_bytes]
     end
   end
 end

backend/lib/edgehog/triggers/handler/manual_actions/handle_trigger.ex

@@ -1,7 +1,7 @@
 #
 # This file is part of Edgehog.
 #
-# Copyright 2024 - 2025 SECO Mind Srl
+# Copyright 2024-2026 SECO Mind Srl
 #
 # Licensed under the Apache License, Version 2.0 (the "License");
 # you may not use this file except in compliance with the License.
@@ -28,6 +28,7 @@ defmodule Edgehog.Triggers.Handler.ManualActions.HandleTrigger do
   alias Edgehog.Containers.Deployment
   alias Edgehog.Devices
   alias Edgehog.Devices.Device
+  alias Edgehog.Files
   alias Edgehog.OSManagement
   alias Edgehog.Triggers.DeviceConnected
   alias Edgehog.Triggers.DeviceDeletionFinished
@@ -49,6 +50,7 @@ defmodule Edgehog.Triggers.Handler.ManualActions.HandleTrigger do
   @ota_event "io.edgehog.devicemanager.OTAEvent"
   @ota_response "io.edgehog.devicemanager.OTAResponse"
   @system_info "io.edgehog.devicemanager.SystemInfo"
+  @file_storage "io.edgehog.devicemanager.storage.File"
 
   @impl Ash.Resource.Actions.Implementation
   def run(input, _opts, _context) do
@@ -363,6 +365,23 @@ defmodule Edgehog.Triggers.Handler.ManualActions.HandleTrigger do
     end
   end
 
+  defp handle_event(%IncomingData{interface: @file_storage} = event, tenant, _realm_id, _device_id, _timestamp) do
+    case String.split(event.path, "/") do
+      ["", request_id, "pathOnDevice"] ->
+        file_download_request = Files.fetch_file_download_request!(request_id, tenant: tenant)
+
+        Files.set_path_on_device(file_download_request, event.value, tenant: tenant)
+
+      ["", request_id, "sizeBytes"] ->
+        file_download_request = Files.fetch_file_download_request!(request_id, tenant: tenant)
+
+        Files.set_size_bytes(file_download_request, event.value, tenant: tenant)
+
+      _ ->
+        {:error, :invalid_event_path}
+    end
+  end
+
   defp handle_event(_unhandled_event, tenant, realm_id, device_id, _timestamp) do
     Device
     |> Ash.Changeset.for_create(:from_unhandled_event, %{realm_id: realm_id, device_id: device_id})

backend/priv/astarte_resources/trigger_templates/edgehog-file-transfer-completion.json.eex

@@ -0,0 +1,22 @@
+{
+    "name": "edgehog-file-transfer-completion",
+    "action": {
+        "http_url": "<%= @trigger_url %>",
+        "http_method": "post",
+        "http_static_headers": {},
+        "ignore_ssl_errors": false
+    },
+    "simple_triggers": [
+        {
+            "type": "data_trigger",
+            "interface_name": "io.edgehog.devicemanager.storage.File",
+            "interface_major": 0,
+            "on": "incoming_data",
+            "match_path": "/*",
+            "value_match_operator": "*"
+        }
+    ]
+    <%= if @can_use_trigger_delivery_policy do %>,
+    "policy": "edgehog-retry-on-server-error"
+    <% end %>
+}

backend/priv/repo/migrations/20260316113835_add_path_on_device.exs

@@ -0,0 +1,41 @@
+#
+# This file is part of Edgehog.
+#
+# Copyright 2026 SECO Mind Srl
+#
+# Licensed under the Apache License, Version 2.0 (the "License");
+# you may not use this file except in compliance with the License.
+# You may obtain a copy of the License at
+#
+#    http://www.apache.org/licenses/LICENSE-2.0
+#
+# Unless required by applicable law or agreed to in writing, software
+# distributed under the License is distributed on an "AS IS" BASIS,
+# WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+# See the License for the specific language governing permissions and
+# limitations under the License.
+#
+# SPDX-License-Identifier: Apache-2.0
+#
+
+defmodule Edgehog.Repo.Migrations.AddPathOnDevice do
+  @moduledoc """
+  Updates resources based on their most recent snapshots.
+
+  This file was autogenerated with `mix ash_postgres.generate_migrations`
+  """
+
+  use Ecto.Migration
+
+  def up do
+    alter table(:file_download_requests) do
+      add :path_on_device, :text
+    end
+  end
+
+  def down do
+    alter table(:file_download_requests) do
+      remove :path_on_device
+    end
+  end
+end