chore: Add file upload request support

Generated migrate and snapshots using command:
˛˛˛ bash
mix ash.codegen create_files_upload_resource
˛˛˛

- Introduce `FileUploadRequest` module to handle file upload requests
on Astarte devices.
- Add changes for setting upload URLs and sending file upload requests.
- Update `HandleTrigger` to process file upload events and update
request statuses.
- Add tests for file upload request handling and deployment updates.

Signed-off-by: Osman Hadzic <osman.hadzic@secomind.com>

Author: osmanhadzic

backend/config/test.exs

@@ -116,6 +116,10 @@ config :edgehog,
        :astarte_file_download_request_module,
        Edgehog.Astarte.Device.FileDownloadRequestMock
 
+config :edgehog,
+       :astarte_file_upload_request_module,
+       Edgehog.Astarte.Device.FileUploadRequestMock
+
 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_upload_request/behaviour.ex

@@ -0,0 +1,35 @@
+#
+# 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.FileUploadRequest.Behaviour do
+  @moduledoc """
+  Behaviour for requesting file uploads on Astarte devices.
+  """
+
+  alias Astarte.Client.AppEngine
+  alias Edgehog.Astarte.Device.FileUploadRequest.RequestData
+
+  @callback request_upload(
+              client :: AppEngine.t(),
+              device_id :: String.t(),
+              request_data :: RequestData.t()
+            ) ::
+              :ok | {:error, term()}
+end

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

@@ -0,0 +1,47 @@
+#
+# 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.FileUploadRequest.RequestData do
+  @moduledoc """
+  Struct representing the data needed to request a file upload on an Astarte device.
+  """
+
+  defstruct [
+    :id,
+    :url,
+    :httpHeaderKey,
+    :httpHeaderValue,
+    :compression,
+    :progress,
+    :source,
+    :sourceType
+  ]
+
+  @type t() :: %__MODULE__{
+          id: String.t(),
+          url: String.t(),
+          httpHeaderKey: String.t(),
+          httpHeaderValue: String.t(),
+          compression: String.t(),
+          progress: boolean(),
+          source: String.t(),
+          sourceType: String.t()
+        }
+end

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

@@ -0,0 +1,46 @@
+#
+# 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.FileUploadRequest do
+  @moduledoc """
+  Module responsible for handling file upload requests on Astarte devices.
+  """
+
+  @behaviour Edgehog.Astarte.Device.FileUploadRequest.Behaviour
+
+  alias Astarte.Client.AppEngine
+  alias Edgehog.Error
+
+  @interface "io.edgehog.devicemanager.fileTransfer.DeviceToServer"
+
+  @impl Edgehog.Astarte.Device.FileUploadRequest.Behaviour
+  def request_upload(%AppEngine{} = client, device_id, request_data) do
+    request_data = Map.from_struct(request_data)
+
+    client
+    |> AppEngine.Devices.send_datastream(
+      device_id,
+      @interface,
+      "/request",
+      request_data
+    )
+    |> Error.maybe_match_error(device_id, @interface)
+  end
+end

backend/lib/edgehog/files/file_upload_request.ex

@@ -0,0 +1,44 @@
+#
+# 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.Files.FileUploadRequest.Changes.SendFileUploadRequest do
+  @moduledoc """
+  Ash change responsible for sending a file upload request to the Astarte device
+  after the file upload request resource has been created.
+  """
+
+  use Ash.Resource.Change
+
+  alias Edgehog.Files
+
+  @impl Ash.Resource.Change
+  def change(changeset, _opts, _context) do
+    Ash.Changeset.after_transaction(changeset, &send_file_upload_request/2)
+  end
+
+  defp send_file_upload_request(_changeset, {:ok, file_upload_request} = result) do
+    case Files.send_file_upload_request(file_upload_request) do
+      :ok -> result
+      {:error, reason} -> {:error, reason}
+    end
+  end
+
+  defp send_file_upload_request(_changeset, result), do: result
+end

backend/lib/edgehog/files/file_upload_request/changes/send_file_upload_request.ex

@@ -0,0 +1,53 @@
+#
+# 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.Files.FileUploadRequest.Changes.SetUploadUrl do
+  @moduledoc """
+  Ash change responsible for generating and setting a presigned upload URL
+  for a file upload request before persisting it.
+  """
+
+  use Ash.Resource.Change
+
+  alias Ash.Resource.Change
+
+  @files_storage_module Application.compile_env(
+                          :edgehog,
+                          :files_storage_module,
+                          Edgehog.Storage
+                        )
+
+  @impl Change
+  def change(%Ash.Changeset{valid?: false} = changeset, _opts, _context), do: changeset
+
+  @impl Change
+  def change(changeset, _opts, context) do
+    tenant_id = context.tenant.tenant_id
+    file_upload_request_id = Ash.Changeset.get_attribute(changeset, :id)
+
+    file_path =
+      "uploads/tenants/#{tenant_id}/file_upload_requests/#{file_upload_request_id}"
+
+    case @files_storage_module.create_presigned_urls(file_path) do
+      {:ok, %{put_url: put_url}} -> Ash.Changeset.change_attribute(changeset, :url, put_url)
+      {:error, reason} -> Ash.Changeset.add_error(changeset, reason)
+    end
+  end
+end

backend/lib/edgehog/files/file_upload_request/changes/set_upload_url.ex

@@ -0,0 +1,32 @@
+#
+# 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.Files.FileUploadRequest.FileSource do
+  @moduledoc false
+
+  use Ash.Type.Enum,
+    values: [
+      storage: "File source from storage",
+      streaming: "File source from streaming",
+      filesystem: "File source from filesystem"
+    ]
+
+  def graphql_type(_), do: :file_source
+end