refactor: expand file transfer capabilities

Update Device capabilities based on the latest version of interfaces

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

Author: OmarBrbutovic

backend/config/test.exs

@@ -120,6 +120,10 @@ config :edgehog,
        :astarte_file_upload_request_module,
        Edgehog.Astarte.Device.FileUploadRequestMock
 
+config :edgehog,
+       :astarte_file_transfer_capabilities_module,
+       Edgehog.Astarte.Device.FileTransferCapabilitiesMock
+
 config :edgehog, :astarte_forwarder_session_module, Edgehog.Astarte.Device.ForwarderSessionMock
 config :edgehog, :astarte_geolocation_module, Edgehog.Astarte.Device.GeolocationMock
 config :edgehog, :astarte_hardware_info_module, Edgehog.Astarte.Device.HardwareInfoMock

backend/lib/edgehog/astarte/device/file_download_request/behaviour.ex

@@ -29,8 +29,7 @@ defmodule Edgehog.Astarte.Device.FileDownloadRequest.Behaviour do
   @callback request_download(
               client :: AppEngine.t(),
               device_id :: String.t(),
-              request_data :: RequestData.t(),
-              device_type :: :posix | :windows
+              request_data :: RequestData.t()
             ) ::
               :ok | {:error, term()}
 end

backend/lib/edgehog/astarte/device/file_download_request/request_data.ex

@@ -28,13 +28,12 @@ defmodule Edgehog.Astarte.Device.FileDownloadRequest.RequestData do
   defstruct [
     :id,
     :url,
-    :httpHeaderKey,
-    :httpHeaderValue,
-    :compression,
+    :httpHeaderKeys,
+    :httpHeaderValues,
+    :encoding,
     :fileSizeBytes,
     :progress,
     :digest,
-    :fileName,
     :ttlSeconds,
     :fileMode,
     :userId,
@@ -46,13 +45,12 @@ defmodule Edgehog.Astarte.Device.FileDownloadRequest.RequestData do
   @type t() :: %__MODULE__{
           id: String.t(),
           url: String.t(),
-          httpHeaderKey: String.t(),
-          httpHeaderValue: String.t(),
-          compression: String.t(),
+          httpHeaderKeys: [String.t()],
+          httpHeaderValues: [String.t()],
+          encoding: String.t(),
           fileSizeBytes: non_neg_integer() | nil,
           progress: boolean(),
           digest: String.t() | nil,
-          fileName: String.t() | nil,
           ttlSeconds: non_neg_integer(),
           fileMode: non_neg_integer(),
           userId: integer(),

backend/lib/edgehog/astarte/device/file_download_request/request_download.ex

@@ -28,26 +28,17 @@ defmodule Edgehog.Astarte.Device.FileDownloadRequest do
   alias Astarte.Client.AppEngine
   alias Edgehog.Error
 
-  @posix_interface "io.edgehog.devicemanager.fileTransfer.posix.ServerToDevice"
-  @windows_interface "io.edgehog.devicemanager.fileTransfer.windows.ServerToDevice"
+  @interface "io.edgehog.devicemanager.fileTransfer.ServerToDevice"
 
   @impl Edgehog.Astarte.Device.FileDownloadRequest.Behaviour
-  def request_download(%AppEngine{} = client, device_id, request_data, :posix) do
-    do_request_download(client, device_id, request_data, @posix_interface)
-  end
-
-  def request_download(%AppEngine{} = client, device_id, request_data, :windows) do
-    do_request_download(client, device_id, request_data, @windows_interface)
-  end
-
-  defp do_request_download(client, device_id, request_data, interface) do
+  def request_download(%AppEngine{} = client, device_id, request_data) do
     client
     |> AppEngine.Devices.send_datastream(
       device_id,
-      interface,
+      @interface,
       "/request",
       Map.from_struct(request_data)
     )
-    |> Error.maybe_match_error(device_id, interface)
+    |> Error.maybe_match_error(device_id, @interface)
   end
 end

backend/lib/edgehog/astarte/device/file_transfer_capabilities.ex

@@ -0,0 +1,72 @@
+#
+# 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.Astarte.Device.FileTransferCapabilities do
+  @moduledoc false
+  @behaviour Edgehog.Astarte.Device.FileTransferCapabilities.Behaviour
+
+  alias Astarte.Client.AppEngine
+  alias Edgehog.Astarte.Device.FileTransferCapabilities
+
+  @type target :: :storage | :streaming | :filesystem
+
+  @type t :: %__MODULE__{
+          encodings: [String.t()],
+          unix_permissions: boolean() | nil,
+          targets: [target()]
+        }
+
+  @enforce_keys [:encodings, :unix_permissions, :targets]
+  defstruct @enforce_keys
+
+  @interface "io.edgehog.devicemanager.fileTransfer.Capabilities"
+
+  @impl Edgehog.Astarte.Device.FileTransferCapabilities.Behaviour
+  def get(%AppEngine{} = client, device_id) do
+    with {:ok, %{"data" => data}} <-
+           AppEngine.Devices.get_properties_data(client, device_id, @interface) do
+      {:ok, parse_data(data)}
+    end
+  end
+
+  def parse_data(data) do
+    %FileTransferCapabilities{
+      encodings: Map.get(data, "encodings", []),
+      unix_permissions: Map.get(data, "unixPermissions"),
+      targets: parse_targets(Map.get(data, "targets", []))
+    }
+  end
+
+  defp parse_targets(targets) when is_list(targets) do
+    targets
+    |> Enum.map(&parse_target/1)
+    |> Enum.reject(&is_nil/1)
+  end
+
+  defp parse_targets(_), do: []
+
+  defp parse_target("storage"), do: :storage
+  defp parse_target("streaming"), do: :streaming
+  defp parse_target("filesystem"), do: :filesystem
+  defp parse_target(:storage), do: :storage
+  defp parse_target(:streaming), do: :streaming
+  defp parse_target(:filesystem), do: :filesystem
+  defp parse_target(_), do: nil
+end

backend/lib/edgehog/astarte/device/file_transfer_capabilities/behaviour.ex

@@ -0,0 +1,29 @@
+#
+# 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.Astarte.Device.FileTransferCapabilities.Behaviour do
+  @moduledoc false
+
+  alias Astarte.Client.AppEngine
+  alias Edgehog.Astarte.Device.FileTransferCapabilities
+
+  @callback get(client :: AppEngine.t(), device_id :: String.t()) ::
+              {:ok, FileTransferCapabilities.t()} | {:error, term()}
+end

backend/lib/edgehog/astarte/device/file_upload_request/request_data.ex

@@ -26,9 +26,9 @@ defmodule Edgehog.Astarte.Device.FileUploadRequest.RequestData do
   defstruct [
     :id,
     :url,
-    :httpHeaderKey,
-    :httpHeaderValue,
-    :compression,
+    :httpHeaderKeys,
+    :httpHeaderValues,
+    :encoding,
     :progress,
     :source,
     :sourceType
@@ -37,9 +37,9 @@ defmodule Edgehog.Astarte.Device.FileUploadRequest.RequestData do
   @type t() :: %__MODULE__{
           id: String.t(),
           url: String.t(),
-          httpHeaderKey: String.t(),
-          httpHeaderValue: String.t(),
-          compression: String.t(),
+          httpHeaderKeys: [String.t()],
+          httpHeaderValues: [String.t()],
+          encoding: String.t(),
           progress: boolean(),
           source: String.t(),
           sourceType: String.t()

backend/lib/edgehog/capabilities.ex

@@ -133,9 +133,9 @@ defmodule Edgehog.Capabilities do
         minor: 1
       }
     ],
-    posix_file_transfer_stream: [
+    file_transfer_stream: [
       %Astarte.InterfaceID{
-        name: "io.edgehog.devicemanager.fileTransfer.posix.ServerToDevice",
+        name: "io.edgehog.devicemanager.fileTransfer.ServerToDevice",
         major: 0,
         minor: 1
       },
@@ -150,48 +150,9 @@ defmodule Edgehog.Capabilities do
         minor: 1
       }
     ],
-    posix_file_transfer_storage: [
+    file_transfer_storage: [
       %Astarte.InterfaceID{
-        name: "io.edgehog.devicemanager.fileTransfer.posix.ServerToDevice",
-        major: 0,
-        minor: 1
-      },
-      %Astarte.InterfaceID{
-        name: "io.edgehog.devicemanager.fileTransfer.Progress",
-        major: 0,
-        minor: 1
-      },
-      %Astarte.InterfaceID{
-        name: "io.edgehog.devicemanager.fileTransfer.Response",
-        major: 0,
-        minor: 1
-      },
-      %Astarte.InterfaceID{
-        name: "io.edgehog.devicemanager.storage.File",
-        major: 0,
-        minor: 1
-      }
-    ],
-    windows_file_transfer_stream: [
-      %Astarte.InterfaceID{
-        name: "io.edgehog.devicemanager.fileTransfer.windows.ServerToDevice",
-        major: 0,
-        minor: 1
-      },
-      %Astarte.InterfaceID{
-        name: "io.edgehog.devicemanager.fileTransfer.Progress",
-        major: 0,
-        minor: 1
-      },
-      %Astarte.InterfaceID{
-        name: "io.edgehog.devicemanager.fileTransfer.Response",
-        major: 0,
-        minor: 1
-      }
-    ],
-    windows_file_transfer_storage: [
-      %Astarte.InterfaceID{
-        name: "io.edgehog.devicemanager.fileTransfer.windows.ServerToDevice",
+        name: "io.edgehog.devicemanager.fileTransfer.ServerToDevice",
         major: 0,
         minor: 1
       },

backend/lib/edgehog/devices/device/calculations/astarte_interface_value.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.
@@ -97,6 +97,12 @@ defmodule Edgehog.Devices.Device.Calculations.AstarteInterfaceValue do
                    Edgehog.Astarte.Device.HardwareInfo
                  )
 
+  @file_transfer_capabilities Application.compile_env(
+                                :edgehog,
+                                :astarte_file_transfer_capabilities_module,
+                                Edgehog.Astarte.Device.FileTransferCapabilities
+                              )
+
   @os_info Application.compile_env(
              :edgehog,
              :astarte_os_info_module,
@@ -135,6 +141,7 @@ defmodule Edgehog.Devices.Device.Calculations.AstarteInterfaceValue do
   defp value_id_to_fetch_fun(:available_device_mappings), do: &@available_device_mappings.get/2
   defp value_id_to_fetch_fun(:base_image_info), do: &@base_image.get/2
   defp value_id_to_fetch_fun(:hardware_info), do: &@hardware_info.get/2
+  defp value_id_to_fetch_fun(:file_transfer_capabilities), do: &@file_transfer_capabilities.get/2
   defp value_id_to_fetch_fun(:modem_properties), do: &@cellular_connection.get_modem_properties/2
   defp value_id_to_fetch_fun(:modem_status), do: &@cellular_connection.get_modem_status/2
   defp value_id_to_fetch_fun(:os_info), do: &@os_info.get/2

backend/lib/edgehog/devices/device/device.ex

@@ -605,6 +605,11 @@ defmodule Edgehog.Devices.Device do
       calculation {Calculations.AstarteInterfaceValue, value_id: :hardware_info}
     end
 
+    calculate :file_transfer_capabilities, Types.FileTransferCapabilities do
+      public? true
+      calculation {Calculations.AstarteInterfaceValue, value_id: :file_transfer_capabilities}
+    end
+
     calculate :location, Edgehog.Geolocation.Location do
       description """
       Describes the place where the device is located.