Merge pull request #140 from noaccOS/push-mmptuxorplps

chore: forward-port release-1.3

Author: lusergit

CHANGELOG.md

@@ -1,103 +1,163 @@
 # Changelog
+
 All notable changes to this project will be documented in this file.
 
 The format is based on [Keep a Changelog](http://keepachangelog.com/en/1.0.0/)
 and this project adheres to [Semantic Versioning](http://semver.org/spec/v2.0.0.html).
 
 ## [Unreleased]
 
+## [1.3.0-rc.1] - 2026-01-23
+
+### Fixed
+
+- BREAKING: Trigger target decoding now returns the headers as a map instead of a list, in
+  accordance with the typespec
+
+## [1.3.0-rc.0] - 2025-10-20
+
+### Added
+
+- Device capabilities
+- Device capability `purge_property_compression_format`
+- Add events for device deletion started and finished.
+- Add event for device registration.
+
+## [1.2.1] - 2026-03-06
+
+### Fixed
+- [astarte_realm_management] Insufficient validation for conflicting options in interface aggregate mappings
+  [#1072](https://github.com/astarte-platform/astarte/issues/1072)
+
+## [1.2.1-rc.0] - 2025-08-22
+### Added
+- Allow `to_int` in custom enum types to be called with valid integers
+- Allow `from_int` in custom enum types to be called with valid atoms
+- Expose a custom `@type` for all structs
+- Implement json encoder for `IncomingIntrospectionEvent`
+
 ## [1.2.0] - 2024-07-01
 
 ## [1.2.0-rc.0] - 2024-05-28
+
 ### Added
-- Function for translating realm to keyspace, to support multiple Astarte 
+
+- Function for translating realm to keyspace, to support multiple Astarte
   instances sharing the same database
 - Added device capabilities
 - Added device capability `purge_property_compression_format`
 
 ### Changed
+
 - Bump Elixir to 1.15.7.
 - Bump Erlang/OTP to 26.1.
 - IncomingIntrospectionEvent holds now a interface-name -> {major, minor} map
   instead of the plain introspection string.
 
 ## [1.1.1] - 2023-10-03
+
 ### Fixed
+
 - Handle Cyanide 2.0 binaries correctly. Fix #95.
 - Correctly encode binaryblobarrays in JSON payload of Astarte events.
 
 ## [1.1.0] - 2023-06-20
+
 ### Fixed
+
 - Forward ported changes from 1.0.5 (Do not allow mappings where `database_retention_policy`...)
 
 ## [1.1.0-rc.0] - 2023-06-08
+
 ### Changed
+
 - Bump Elixir and Erlang to 1.14.5 and 25.3.2, respectively.
 
 ## [1.1.0-alpha.0] - 2022-11-14
+
 ### Changed
+
 - Extend interface mappings charset to support name prefixed with underscore
 - Introspection triggers are part of device triggers. Expose an API closer to other triggers.
 
 ## [1.0.6] - 2024-04-18
 
 ## [1.0.5] - 2023-09-25
+
 ### Fixed
+
 - Do not allow mappings where `database_retention_policy` is
   `use_ttl` but no ttl is set. Fix #84.
 
 ## [1.0.4] - 2022-09-26
+
 ### Added
+
 - Add delivery policies to triggers.
 
 ## [1.0.3] - 2022-07-04
 
 ## [1.0.2] - 2022-03-29
 
 ## [1.0.1] - 2021-12-16
+
 ### Added
+
 - Handle array values when decoding simple events
 
 ### Fixed
+
 - Don't treat structs as object aggregations when decoding simple events
 
 ## [1.0.0] - 2021-06-28
 
 ## [1.0.0-rc.0] - 2021-05-05
 
 ## [1.0.0-beta.2] - 2021-03-23
+
 ### Changed
+
 - Update dependencies and Elixir version to 1.11
 - If `database_retention_policy` is set to `:no_ttl`, `database_retention_ttl` must not be set. (See #51)
 
 ### Fixed
+
 - Correctly handle SimpleEvents JSON encoding even when they contain an object aggregation with a
   binaryblob value.
 
 ## [1.0.0-beta.1] - 2021-02-11
+
 ### Fixed
+
 - Return an error instead of crashing when the endpoint is not present within a mapping.
 
 ## [1.0.0-alpha.1] - 2020-06-18
+
 ### Added
+
 - Add `exchange` to `AMQPTriggerTarget` proto. This will allow to send events to any user defined
   AMQP exchange (see [#351](https://github.com/astarte-platform/astarte/issues/351)).
 - Add additional options to `AMQPTriggerTarget` such as `priority`, `expiration` and `persistent`.
 - Add support for device-specific and group-specific triggers.
 - Add `DeviceErrorEvent` to `SimpleEvents`, allowing to react to a device error.
 
 ### Changed
+
 - It is now possible to omit the `device_id` in a `device_trigger`. This is equivalent to passing
   `*` as `device_id`. The old behaviour is still supported.
 
 ## [0.11.4] - 2021-01-25
+
 ### Fixed
+
 - Correctly handle binaryblob value deserialization in events.
 
 ## [0.11.3] - 2020-09-24
 
 ## [0.11.2] - 2020-08-14
+
 ### Changed
+
 - Test against Elixir 1.8.2.
 
 ## [0.11.1] - 2020-05-18
@@ -107,57 +167,78 @@ and this project adheres to [Semantic Versioning](http://semver.org/spec/v2.0.0.
 ## [0.11.0-rc.1] - 2020-03-25
 
 ## [0.11.0-rc.0] - 2020-02-26
+
 ### Changed
+
 - Add support for aggregated server owned interfaces.
 
 ### Fixed
+
 - Correctly handle parametric endpoints regardless of the ordering, so that overlapping endpoints are always refused. (See #2)
 
 ## [0.11.0-beta.2] - 2020-01-24
+
 ### Changed
+
 - Restrict the use of `*` as `interface_name` only to `incoming_data` data triggers.
 - Allow hyphens in `interface_name`. Both the top level domain and the last domain component
   must not contain hyphens. ([#7](https://github.com/astarte-platform/astarte_core/issues/7))
 
 ### Fixed
+
 - Handle empty `bson_value` in `Triggers.SimpleEvents.Encoder`, avoiding crashes when an empty bson
   value is sent as event (e.g. unset).
 
 ## [0.11.0-beta.1] - 2019-12-24
+
 ### Changed
+
 - `astarte`, `system` and all names starting with `system_` are now reserved realm names.
 - Add `database_retention_policy` and `database_retention_ttl` mapping attributes.
 
 ## [0.10.2] - 2019-12-09
+
 ### Added
+
 - Add timestamp field to SimpleEvent protobuf.
 
 ## [0.10.1] - 2019-10-02
+
 ### Fixed
+
 - Fix interface validation: object aggregated properties interfaces are not valid.
 - Fix interface validation: server owned object aggregated interfaces are not yet supported, hence not valid.
 
 ## [0.10.0] - 2019-04-16
 
 ## [0.10.0-rc.0] - 2019-04-03
+
 ### Fixed
+
 - Fix endpoint placeholder regex used in Mapping.normalize_endpoint.
 - Fix overlapping endpoints detection, it was allowing some corner case overlappings.
 
 ## [0.10.0-beta.3] - 2018-12-19
+
 ### Changed
+
 - Interface name `device` is reserved now.
 
 ### Fixed
+
 - Correctly support Bson.Bin struct.
 - False positive overlapping endpoints were detected, EndpointsAutomaton now handles them as valid.
-- Correctly serialize triggers on the special "*" interface and device.
+- Correctly serialize triggers on the special "\*" interface and device.
 
 ## [0.10.0-beta.2] - 2018-10-19
+
 ### Added
+
 - Add limit to 64K for string and blobs, 1024 items for arrays.
 - Add value validation code for any Astarte type.
 
 ## [0.10.0-beta.1] - 2018-08-10
+
 ### Added
+
 - First Astarte release.

config/config.exs

@@ -1,6 +1,6 @@
 # This file is responsible for configuring your application
 # and its dependencies with the aid of the Mix.Config module.
-use Mix.Config
+import Config
 
 # This configuration is loaded before any dependency and is restricted
 # to this project. If another project depends on this project, this

lib/astarte_core/device/capabilities.ex

@@ -19,7 +19,7 @@
 #
 
 defmodule Astarte.Core.Device.Capabilities do
-  use Ecto.Schema
+  use TypedEctoSchema
   import Ecto.Changeset
 
   alias Astarte.Core.Device.Capabilities
@@ -29,7 +29,7 @@ defmodule Astarte.Core.Device.Capabilities do
   @permitted_fields [:purge_properties_compression_format] ++ @required_fields
 
   @primary_key false
-  embedded_schema do
+  typed_embedded_schema do
     field :purge_properties_compression_format, Ecto.Enum,
       values: [zlib: 0, plaintext: 1],
       default: :zlib

lib/astarte_core/interface.ex

@@ -218,15 +218,17 @@ defmodule Astarte.Core.Interface do
 
   defp validate_all_mappings_have_same_attributes(changeset) do
     mappings = get_field(changeset, :mappings, [])
-    aggregation = get_field(changeset, :aggregation, [])
+    aggregation = get_field(changeset, :aggregation, :individual)
 
     if aggregation == :object and mappings != [] do
       %Mapping{
         retention: retention,
         reliability: reliability,
         expiry: expiry,
         allow_unset: allow_unset,
-        explicit_timestamp: explicit_timestamp
+        explicit_timestamp: explicit_timestamp,
+        database_retention_policy: database_retention_policy,
+        database_retention_ttl: database_retention_ttl
       } = List.first(mappings)
 
       all_same_attributes =
@@ -236,12 +238,16 @@ defmodule Astarte.Core.Interface do
             reliability: mapping_reliability,
             expiry: mapping_expiry,
             allow_unset: mapping_allow_unset,
-            explicit_timestamp: mapping_explicit_timestamp
+            explicit_timestamp: mapping_explicit_timestamp,
+            database_retention_policy: mapping_database_retention_policy,
+            database_retention_ttl: mapping_database_retention_ttl
           } = mapping
 
           retention == mapping_retention and reliability == mapping_reliability and
             expiry == mapping_expiry and allow_unset == mapping_allow_unset and
-            explicit_timestamp == mapping_explicit_timestamp
+            explicit_timestamp == mapping_explicit_timestamp and
+            database_retention_policy == mapping_database_retention_policy and
+            database_retention_ttl == mapping_database_retention_ttl
         end)
 
       unless all_same_attributes do

lib/astarte_core/proto/astarte_reference.pb.ex

@@ -1,9 +1,7 @@
 defmodule Astarte.Core.AstarteReference do
   @moduledoc false
 
-  use Protobuf, protoc_gen_elixir_version: "0.11.0", syntax: :proto3
-
-  def fully_qualified_name, do: "AstarteReference"
+  use Protobuf, protoc_gen_elixir_version: "0.15.0", syntax: :proto3
 
   field :object_type, 1, type: :int32, json_name: "objectType"
   field :object_uuid, 2, proto3_optional: true, type: :bytes, json_name: "objectUuid"

lib/astarte_core/triggers/policy/handler.ex

@@ -115,10 +115,10 @@ defmodule Astarte.Core.Triggers.Policy.Handler do
       strategy: strategy
     } = handler
 
-    HandlerProto.new(
+    %HandlerProto{
       strategy: Map.get(@strategy_string_to_atom, strategy),
       on: error_type_to_tagged_error_tuple(error_type)
-    )
+    }
   end
 
   def from_handler_proto(%HandlerProto{} = handler_proto) do
@@ -134,12 +134,13 @@ defmodule Astarte.Core.Triggers.Policy.Handler do
   end
 
   defp error_type_to_tagged_error_tuple(%Policy.ErrorKeyword{keyword: keyword}) do
-    {:error_keyword,
-     ErrorKeywordProto.new(keyword: Map.get(@error_keyword_string_to_atom, keyword))}
+    error_keyword = %ErrorKeywordProto{keyword: Map.get(@error_keyword_string_to_atom, keyword)}
+    {:error_keyword, error_keyword}
   end
 
   defp error_type_to_tagged_error_tuple(%Policy.ErrorRange{error_codes: codes}) do
-    {:error_range, ErrorRangeProto.new(error_codes: codes)}
+    error_range = %ErrorRangeProto{error_codes: codes}
+    {:error_range, error_range}
   end
 
   defp tagged_error_tuple_to_error_type({_, %ErrorKeywordProto{keyword: keyword}}) do

lib/astarte_core/triggers/policy/policy.ex

@@ -28,7 +28,6 @@ defmodule Astarte.Core.Triggers.Policy do
 
   @required_fields [
     :name,
-    :error_handlers,
     :maximum_capacity
   ]
 

lib/astarte_core/triggers/policy_protobuf/error_keyword.pb.ex

@@ -1,9 +1,7 @@
 defmodule Astarte.Core.Triggers.PolicyProtobuf.ErrorKeyword.KeywordType do
   @moduledoc false
 
-  use Protobuf, enum: true, protoc_gen_elixir_version: "0.11.0", syntax: :proto3
-
-  def fully_qualified_name, do: "ErrorKeyword.KeywordType"
+  use Protobuf, enum: true, protoc_gen_elixir_version: "0.15.0", syntax: :proto3
 
   field :INVALID, 0
   field :ANY_ERROR, 1
@@ -14,9 +12,7 @@ end
 defmodule Astarte.Core.Triggers.PolicyProtobuf.ErrorKeyword do
   @moduledoc false
 
-  use Protobuf, protoc_gen_elixir_version: "0.11.0", syntax: :proto3
-
-  def fully_qualified_name, do: "ErrorKeyword"
+  use Protobuf, protoc_gen_elixir_version: "0.15.0", syntax: :proto3
 
   field :keyword, 1,
     type: Astarte.Core.Triggers.PolicyProtobuf.ErrorKeyword.KeywordType,

lib/astarte_core/triggers/policy_protobuf/error_range.pb.ex

@@ -1,9 +1,7 @@
 defmodule Astarte.Core.Triggers.PolicyProtobuf.ErrorRange do
   @moduledoc false
 
-  use Protobuf, protoc_gen_elixir_version: "0.11.0", syntax: :proto3
-
-  def fully_qualified_name, do: "ErrorRange"
+  use Protobuf, protoc_gen_elixir_version: "0.15.0", syntax: :proto3
 
   field :error_codes, 1, repeated: true, type: :int32, json_name: "errorCodes"
 end