chore: forward-port release-1.3

Signed-off-by: Francesco Noacco <francesco.noacco@secomind.com>

Author: noaccOS

.github/workflows/publish-release-to-dockerhub-workflow.yaml

@@ -11,45 +11,6 @@ on:
         type: string
 
 jobs:
-  astarte_appengine_api:
-    uses: ./.github/workflows/astarte-apps-build-workflow.yaml
-    with:
-      app: "astarte_appengine_api"
-    secrets: inherit
-
-  astarte_data_updater_plant:
-    uses: ./.github/workflows/astarte-apps-build-workflow.yaml
-    with:
-      app: "astarte_data_updater_plant"
-    secrets: inherit
-
-  astarte_housekeeping:
-    uses: ./.github/workflows/astarte-apps-build-workflow.yaml
-    with:
-      app: "astarte_housekeeping"
-    secrets: inherit
-
-  astarte_pairing:
-    uses: ./.github/workflows/astarte-apps-build-workflow.yaml
-    with:
-      app: "astarte_pairing"
-    secrets: inherit
-
-  astarte_realm_management:
-    uses: ./.github/workflows/astarte-apps-build-workflow.yaml
-    with:
-      app: "astarte_realm_management"
-    secrets: inherit
-
-  astarte_trigger_engine:
-    uses: ./.github/workflows/astarte-apps-build-workflow.yaml
-    with:
-      app: "astarte_trigger_engine"
-    secrets: inherit
-
-  e2e_tests:
-    uses: ./.github/workflows/astarte-end-to-end-test-workflow.yaml
-
   build_release:
     name: Push Docker images to Docker Hub
     runs-on: ${{ matrix.platform.os }}
@@ -75,14 +36,6 @@ jobs:
           - astarte_pairing
           - astarte_realm_management
           - astarte_trigger_engine
-    needs:
-      - astarte_appengine_api
-      - astarte_data_updater_plant
-      - astarte_housekeeping
-      - astarte_pairing
-      - astarte_realm_management
-      - astarte_trigger_engine
-      - e2e_tests
     steps:
       - name: Check out the repo
         uses: actions/checkout@34e114876b0b11c390a56381ad16ebd13914f8d5 # v4

CHANGELOG.md

@@ -23,6 +23,10 @@ and this project adheres to [Semantic Versioning](http://semver.org/spec/v2.0.0.
   - `ASTARTE_BASE_URL_DOMAIN` - domain part of the base URL of astarte, used by devices to connect in TO2 phase (required if FDO enabled)
   - `ASTARTE_BASE_URL_PORT` - port of the base URL of astarte (required if FDO enabled)
   - `ASTARTE_BASE_URL_PROTOCOL` - protocol of the base URL of astarte (required if FDO enabled)
+  - `PAIRING_FDO_RENDEZVOUS_SSL_ENABLED` - whether SSL is enabled for the connection to the rendezvous server (default: false)
+  - `PAIRING_FDO_RENDEZVOUS_SSL_CA_FILE` - path to the CA certificate file for the rendezvous server TLS connection; when not specified, the bundled cURL certificate bundle will be used
+  - `PAIRING_FDO_RENDEZVOUS_SSL_DISABLE_SNI` - disable Server Name Indication for the rendezvous server TLS connection (default: false)
+  - `PAIRING_FDO_RENDEZVOUS_SSL_CUSTOM_SNI` - custom SNI hostname for the rendezvous server TLS connection; when not specified, the Rendezvous hostname will be used
 
 - [astarte_housekeeping] AMQP management configuration moved to `astarte_events` library. Environment variables changed:
   - `HOUSEKEEPING_AMQP_SSL_ENABLED` is now `ASTARTE_EVENTS_AMQP_MANAGEMENT_SSL_ENABLED`
@@ -108,15 +112,18 @@ and this project adheres to [Semantic Versioning](http://semver.org/spec/v2.0.0.
 - [astarte_data_updater_plant] Correctly encode values when sending properties to device on connection
 - [astarte_realm_management] Allow to delete long-disconnected devices. For this to work, Realm Management needs `CLUSTERING_STRATEGY`, `CLUSTERING_KUBERNETES_NAMESPACE` and `DATA_UPDATER_PLANT_CLUSTERING_KUBERNETES_SELECTOR` to be set, just like AppEngine and DUP. Refer to 1.2.1-rc.0 for additional information on the variables.
 
-## [1.2.1] - Unreleased
+## [1.2.1] - 2026-03-12
 
 ### Fixed
 
 - [astarte_realm_management] Insufficient validation for conflicting options in interface aggregate mappings
   [#1072](https://github.com/astarte-platform/astarte/issues/1072)
+- [astarte_data_updater_plant] Ensure device deletion rpc always checks updated status
 
 ## [1.2.1-rc.1] - 2026-02-13
 
+### Fixed
+
 - [astarte_realm_management] Bug where devices got stuck in the "in deletion" status: [#1493](https://github.com/astarte-platform/astarte/issues/1493).
 - [astarte_data_updater_plant] Correctly reconnect to AMQP after a connection loss
 - [astarte_data_updater_plant] Fix possible crash when sending data on interface-specific volatile triggers

README.md

@@ -1,7 +1,7 @@
 # Astarte
 
-![](https://github.com/astarte-platform/astarte/workflows/Build%20and%20Test%20Astarte%20Apps/badge.svg?branch=v1.2.0)
-[![codecov](https://codecov.io/gh/astarte-platform/astarte/tag/v1.2.0/graph/badge.svg)](https://codecov.io/gh/astarte-platform/astarte)
+![](https://github.com/astarte-platform/astarte/workflows/Build%20and%20Test%20Astarte%20Apps/badge.svg?branch=v1.2.1)
+[![codecov](https://codecov.io/gh/astarte-platform/astarte/tag/v1.2.1/graph/badge.svg)](https://codecov.io/gh/astarte-platform/astarte)
 
 <img src="doc/images/mascotte.svg" align="left" width="160px" />Astarte is an Open Source IoT
 platform focused on Data management and processing written in [Elixir](https://github.com/elixir-lang/elixir).
@@ -34,7 +34,7 @@ Can't be easier. Pick your favorite machine with at least 4GB of free RAM, make
 [Docker](https://www.docker.com/), and simply:
 
 ```sh
-$ git clone https://github.com/astarte-platform/astarte.git -b v1.2.0 && cd astarte
+$ git clone https://github.com/astarte-platform/astarte.git -b v1.2.1 && cd astarte
 $ docker run -v $(pwd)/compose:/compose astarte/docker-compose-initializer:1.1
 $ docker compose pull
 $ docker compose up -d

apps/astarte_appengine_api/mix.exs

@@ -1,7 +1,7 @@
 #
 # This file is part of Astarte.
 #
-# Copyright 2017-2025 SECO Mind Srl
+# Copyright 2017 - 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.
@@ -60,7 +60,6 @@ defmodule Astarte.AppEngine.API.Mixfile do
   defp astarte_required_modules(_) do
     [
       {:astarte_core, github: "astarte-platform/astarte_core", override: true},
-      {:astarte_generators, github: "astarte-platform/astarte_generators", only: [:dev, :test]},
       {:astarte_realm_management,
        path: "../astarte_realm_management", only: :test, runtime: false}
     ]
@@ -103,6 +102,7 @@ defmodule Astarte.AppEngine.API.Mixfile do
       {:libcluster, "~> 3.3"},
       {:astarte_data_access, path: astarte_lib("astarte_data_access")},
       {:astarte_rpc, path: astarte_lib("astarte_rpc")},
+      {:astarte_generators, path: astarte_lib("astarte_generators"), only: [:dev, :test]},
       {:horde, "~> 0.9"},
       {:credo, "~> 1.7", only: [:dev, :test], runtime: false},
       # Test section

apps/astarte_appengine_api/mix.lock

@@ -2,7 +2,6 @@
   "amqp": {:hex, :amqp, "3.3.2", "6cad7469957b29c517a26a27474828f1db28278a13bcc2e7970db9854a3d3080", [:mix], [{:amqp_client, "~> 3.9", [hex: :amqp_client, repo: "hexpm", optional: false]}], "hexpm", "f977c41d81b65a21234a9158e6491b2296f8bd5bda48d5b611a64b6e0d2c3f31"},
   "amqp_client": {:hex, :amqp_client, "3.12.14", "2b677bc3f2e2234ba7517042b25d72071a79735042e91f9116bd3c176854b622", [:make, :rebar3], [{:credentials_obfuscation, "3.4.0", [hex: :credentials_obfuscation, repo: "hexpm", optional: false]}, {:rabbit_common, "3.12.14", [hex: :rabbit_common, repo: "hexpm", optional: false]}], "hexpm", "5f70b6c3b1a739790080da4fddc94a867e99f033c4b1edc20d6ff8b8fb4bd160"},
   "astarte_core": {:git, "https://github.com/astarte-platform/astarte_core.git", "a6efa2e87b7f121cc7656640cdff88c408e180f5", []},
-  "astarte_generators": {:git, "https://github.com/astarte-platform/astarte_generators.git", "673834e5a90c753c3cc22ad53be20b705c827d4a", []},
   "astarte_rpc": {:hex, :astarte_rpc, "1.2.0", "dcef7434bf3f19ff30ff0bc245ef2d3b0f9abeb369405713cfd28916a5635926", [:mix], [{:amqp, "~> 3.3", [hex: :amqp, repo: "hexpm", optional: false]}, {:castore, "~> 1.0.0", [hex: :castore, repo: "hexpm", optional: false]}, {:protobuf, "~> 0.12", [hex: :protobuf, repo: "hexpm", optional: false]}, {:skogsra, "~> 2.2", [hex: :skogsra, repo: "hexpm", optional: false]}], "hexpm", "8470ed2f116fa8c9d70845f295f3738529aff123d9d3f98cbfa37107314763cb"},
   "bunt": {:hex, :bunt, "1.0.0", "081c2c665f086849e6d57900292b3a161727ab40431219529f13c4ddcf3e7a44", [:mix], [], "hexpm", "dc5f86aa08a5f6fa6b8096f0735c4e76d54ae5c9fa2c143e5a1fc7c1cd9bb6b5"},
   "castore": {:hex, :castore, "1.0.17", "4f9770d2d45fbd91dcf6bd404cf64e7e58fed04fadda0923dc32acca0badffa2", [:mix], [], "hexpm", "12d24b9d80b910dd3953e165636d68f147a31db945d2dcb9365e441f8b5351e5"},
@@ -13,7 +12,7 @@
   "cowboy_telemetry": {:hex, :cowboy_telemetry, "0.4.0", "f239f68b588efa7707abce16a84d0d2acf3a0f50571f8bb7f56a15865aae820c", [:rebar3], [{:cowboy, "~> 2.7", [hex: :cowboy, repo: "hexpm", optional: false]}, {:telemetry, "~> 1.0", [hex: :telemetry, repo: "hexpm", optional: false]}], "hexpm", "7d98bac1ee4565d31b62d59f8823dfd8356a169e7fcbb83831b8a5397404c9de"},
   "cowlib": {:hex, :cowlib, "2.16.0", "54592074ebbbb92ee4746c8a8846e5605052f29309d3a873468d76cdf932076f", [:make, :rebar3], [], "hexpm", "7f478d80d66b747344f0ea7708c187645cfcc08b11aa424632f78e25bf05db51"},
   "credentials_obfuscation": {:hex, :credentials_obfuscation, "3.4.0", "34e18b126b3aefd6e8143776fbe1ceceea6792307c99ac5ee8687911f048cfd7", [:rebar3], [], "hexpm", "738ace0ed5545d2710d3f7383906fc6f6b582d019036e5269c4dbd85dbced566"},
-  "credo": {:hex, :credo, "1.7.16", "a9f1389d13d19c631cb123c77a813dbf16449a2aebf602f590defa08953309d4", [:mix], [{:bunt, "~> 0.2.1 or ~> 1.0", [hex: :bunt, repo: "hexpm", optional: false]}, {:file_system, "~> 0.2 or ~> 1.0", [hex: :file_system, repo: "hexpm", optional: false]}, {:jason, "~> 1.0", [hex: :jason, repo: "hexpm", optional: false]}], "hexpm", "d0562af33756b21f248f066a9119e3890722031b6d199f22e3cf95550e4f1579"},
+  "credo": {:hex, :credo, "1.7.17", "f92b6aa5b26301eaa5a35e4d48ebf5aa1e7094ac00ae38f87086c562caf8a22f", [:mix], [{:bunt, "~> 0.2.1 or ~> 1.0", [hex: :bunt, repo: "hexpm", optional: false]}, {:file_system, "~> 0.2 or ~> 1.0", [hex: :file_system, repo: "hexpm", optional: false]}, {:jason, "~> 1.0", [hex: :jason, repo: "hexpm", optional: false]}], "hexpm", "1eb5645c835f0b6c9b5410f94b5a185057bcf6d62a9c2b476da971cde8749645"},
   "current_rabbit_pool": {:hex, :current_rabbit_pool, "1.1.1", "3a9594f62fdeef845ebd75833659dd821174b51bd013a53c269bf43e67ba8df6", [:mix], [{:amqp, "~> 3.1", [hex: :amqp, repo: "hexpm", optional: false]}, {:poolboy, "~> 1.5", [hex: :poolboy, repo: "hexpm", optional: false]}], "hexpm", "69791022a2e818e55a6535ddea623b1240d44c9640ac5ddc99e07262ee711b2b"},
   "cyanide": {:hex, :cyanide, "2.0.0", "f97b700b87f9b0679ae812f0c4b7fe35ea6541a4121a096cf10287941b7a6d55", [:mix], [], "hexpm", "7f9748251804c2a2115b539202568e1117ab2f0ae09875853fb89cc94ae19dd1"},
   "db_connection": {:hex, :db_connection, "2.9.0", "a6a97c5c958a2d7091a58a9be40caf41ab496b0701d21e1d1abff3fa27a7f371", [:mix], [{:telemetry, "~> 0.4 or ~> 1.0", [hex: :telemetry, repo: "hexpm", optional: false]}], "hexpm", "17d502eacaf61829db98facf6f20808ed33da6ccf495354a41e64fe42f9c509c"},

apps/astarte_appengine_api/test/astarte_appengine_api/device/device_reading_v2_test.exs

@@ -1,7 +1,7 @@
 #
 # This file is part of Astarte.
 #
-# Copyright 2025 SECO Mind Srl
+# Copyright 2025 - 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.
@@ -16,18 +16,18 @@
 # limitations under the License.
 
 defmodule Astarte.AppEngine.API.Device.DeviceReadingV2Test do
+  use ExUnitProperties
   use Astarte.Cases.Data, async: true
-
   use Astarte.Cases.Device
-  use ExUnitProperties
 
-  alias Astarte.AppEngine.API.Device
-  alias Astarte.AppEngine.API.Device.InterfaceValues
+  import Astarte.Helpers.Device
+
   alias Astarte.DataAccess.Realms.Realm
   alias Astarte.DataAccess.Repo
 
-  import Astarte.Helpers.Device
-  import Astarte.InterfaceUpdateGenerators
+  alias Astarte.AppEngine.API.Device
+  alias Astarte.AppEngine.API.Device.InterfaceValues
+  alias Astarte.Generators.InterfaceUpdate, as: InterfaceUpdateGenerator
 
   describe "get_interface_value" do
     setup context do
@@ -48,10 +48,9 @@ defmodule Astarte.AppEngine.API.Device.DeviceReadingV2Test do
 
       valid_interfaces_for_update = interfaces |> Enum.filter(&(&1.ownership == :server))
 
-      check all(
-              interface_to_update <- member_of(valid_interfaces_for_update),
-              mapping_update <- valid_mapping_update_for(interface_to_update)
-            ) do
+      check all interface_to_update <- member_of(valid_interfaces_for_update),
+                mapping_update <-
+                  InterfaceUpdateGenerator.valid_mapping_update_for(interface_to_update) do
         %{
           interface_to_update: interface_to_update,
           read_path: read_path,
@@ -81,7 +80,8 @@ defmodule Astarte.AppEngine.API.Device.DeviceReadingV2Test do
       valid_interfaces_for_update = interfaces |> Enum.filter(&(&1.ownership == :server))
 
       check all interface_to_update <- member_of(valid_interfaces_for_update),
-                mapping_update <- valid_mapping_update_for(interface_to_update) do
+                mapping_update <-
+                  InterfaceUpdateGenerator.valid_mapping_update_for(interface_to_update) do
         %{
           interface_to_update: interface_to_update,
           expected_read_value: expected_read_value,
@@ -143,11 +143,10 @@ defmodule Astarte.AppEngine.API.Device.DeviceReadingV2Test do
 
       valid_interfaces_for_update = interfaces |> Enum.filter(&(&1.ownership == :server))
 
-      check all(
-              interface_to_update <- member_of(valid_interfaces_for_update),
-              mapping_update <- valid_mapping_update_for(interface_to_update),
-              limit_n <- integer(1..400)
-            ) do
+      check all interface_to_update <- member_of(valid_interfaces_for_update),
+                mapping_update <-
+                  InterfaceUpdateGenerator.valid_mapping_update_for(interface_to_update),
+                limit_n <- integer(1..400) do
         %{
           interface_to_update: interface_to_update,
           expected_read_value: expected_read_value,

apps/astarte_appengine_api/test/astarte_appengine_api/device/device_v2_reading_test.exs

@@ -1,7 +1,7 @@
 #
 # This file is part of Astarte.
 #
-# Copyright 2025 SECO Mind Srl
+# Copyright 2025 - 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.
@@ -16,15 +16,16 @@
 # limitations under the License.
 
 defmodule Astarte.AppEngine.API.Device.DeviceV2ReadingTest do
+  use ExUnitProperties
+
   use Astarte.Cases.Data, async: true
   use Astarte.Cases.Device
-  use ExUnitProperties
+
+  import Astarte.Helpers.Device
 
   alias Astarte.AppEngine.API.Device
   alias Astarte.AppEngine.API.Device.InterfaceValues
-
-  import Astarte.Helpers.Device
-  import Astarte.InterfaceValuesRetrievealGenerators
+  alias Astarte.Generators.InterfaceValuesRetrieveal, as: InterfaceValuesRetrievealGenerator
 
   setup_all :populate_interfaces
 
@@ -55,7 +56,10 @@ defmodule Astarte.AppEngine.API.Device.DeviceV2ReadingTest do
       check all interface <- member_of(downsampable_interfaces),
                 "/" <> path <- member_of(downsampable_paths[interface]),
                 downsample_to <- integer(3..100),
-                opts <- interface_values_options(downsample_to: downsample_to) do
+                opts <-
+                  InterfaceValuesRetrievealGenerator.interface_values_options(
+                    downsample_to: downsample_to
+                  ) do
         {:ok, %InterfaceValues{data: result}} =
           Device.get_interface_values!(
             realm_name,
@@ -88,7 +92,7 @@ defmodule Astarte.AppEngine.API.Device.DeviceV2ReadingTest do
                 downsample_key <- member_of(object_keys),
                 downsample_to <- integer(3..100),
                 opts <-
-                  interface_values_options(
+                  InterfaceValuesRetrievealGenerator.interface_values_options(
                     downsample_to: downsample_to,
                     downsample_key: downsample_key
                   ) do
@@ -125,7 +129,8 @@ defmodule Astarte.AppEngine.API.Device.DeviceV2ReadingTest do
               lower_limit <- optional(timestamp_at_least(timings.initial_time)),
               to <- optional(timestamp_at_most(timings.last_time)),
               params = [{since_or_after, lower_limit}, to: to],
-              opts <- interface_values_options(params, interface) do
+              opts <-
+                InterfaceValuesRetrievealGenerator.interface_values_options(params, interface) do
       result =
         Device.get_interface_values!(
           realm_name,

apps/astarte_appengine_api/test/astarte_appengine_api/device/device_v2_test.exs

@@ -1,7 +1,7 @@
 #
 # This file is part of Astarte.
 #
-# Copyright 2025 SECO Mind Srl
+# Copyright 2025 - 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.
@@ -20,12 +20,12 @@ defmodule Astarte.AppEngine.API.Device.DeviceV2Test do
   use Astarte.Cases.Device
   use ExUnitProperties
 
+  import Astarte.Generators.InterfaceUpdate
+  import Astarte.Helpers.Device
+
   alias Astarte.AppEngine.API.Device
   alias Astarte.AppEngine.API.Device.InterfaceValues
 
-  import Astarte.Helpers.Device
-  import Astarte.InterfaceUpdateGenerators
-
   describe "update_interface_value" do
     property "returns the given value for valid parameters", context do
       %{realm_name: realm_name, interfaces: interfaces, device: device} = context

apps/astarte_appengine_api/test/astarte_appengine_api_web/controllers/groups_controller_test.exs

@@ -1,7 +1,7 @@
 #
 # This file is part of Astarte.
 #
-# Copyright 2019 Ispirata Srl
+# Copyright 2019 - 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.
@@ -20,11 +20,13 @@ defmodule Astarte.AppEngine.APIWeb.GroupsControllerTest do
   use ExUnitProperties
   use Astarte.Cases.Conn
 
+  alias Astarte.Core.Generators.Device, as: DeviceGenerator
+  alias Astarte.Core.Generators.Group, as: GroupGenerator
+
   alias Astarte.AppEngine.API.Device
   alias Astarte.AppEngine.API.Device.DevicesList
   alias Astarte.AppEngine.API.Device.DeviceStatus
   alias Astarte.AppEngine.API.Groups
-  alias Astarte.AppEngine.API.GroupTestGenerator
   alias Astarte.Helpers.Database, as: DatabaseTestHelper
   alias Astarte.Helpers.JWT, as: JWTTestHelper
 
@@ -175,7 +177,7 @@ defmodule Astarte.AppEngine.APIWeb.GroupsControllerTest do
 
     @tag issue: 904
     property "creates the group with / in group name", %{conn: conn} do
-      check all group_name <- GroupTestGenerator.group_name() do
+      check all group_name <- GroupGenerator.name() do
         params = %{
           "group_name" => group_name,
           "devices" => @group_devices
@@ -205,24 +207,22 @@ defmodule Astarte.AppEngine.APIWeb.GroupsControllerTest do
   describe "add device" do
     setup [:create_group]
 
-    test "returns 404 for non-existing group", %{conn: conn} do
-      params = %{
-        "device_id" => "aWag-VlVKC--1S-vfzZ9uQ"
-      }
-
-      conn = post(conn, groups_path(conn, :add_device, @realm, "nonexisting"), data: params)
+    property "returns 404 for non-existing group", %{conn: conn} do
+      check all device_id <- DeviceGenerator.encoded_id(), max_runs: 10 do
+        params = %{"device_id" => device_id}
+        conn = post(conn, groups_path(conn, :add_device, @realm, "nonexisting"), data: params)
 
-      assert json_response(conn, 404)["errors"]["detail"] == "Group not found"
+        assert json_response(conn, 404)["errors"]["detail"] == "Group not found"
+      end
     end
 
-    test "fails with non-existing device", %{conn: conn} do
-      params = %{
-        "device_id" => "X-Qv0zPMRfiWEXUMHZFNVw"
-      }
-
-      conn = post(conn, groups_path(conn, :add_device, @realm, @group_name), data: params)
+    property "fails with non-existing device", %{conn: conn} do
+      check all device_id <- DeviceGenerator.encoded_id(), max_runs: 10 do
+        params = %{"device_id" => device_id}
+        conn = post(conn, groups_path(conn, :add_device, @realm, @group_name), data: params)
 
-      assert json_response(conn, 422)["errors"]["device_id"] != nil
+        assert json_response(conn, 422)["errors"]["device_id"] != nil
+      end
     end
 
     test "returns 409 for duplicate device", %{conn: conn} do