Forward-port release-1.3

.formatter.exs

@@ -1,3 +1,4 @@
 [
-  inputs: ["{mix,.formatter}.exs", "{config,lib,test}/**/*.{ex,exs}"]
+  inputs: ["{mix,.formatter}.exs", "{config,lib,test}/**/*.{ex,exs}"],
+  import_deps: [:stream_data]
 ]

.github/workflows/build-workflow.yaml

@@ -4,8 +4,8 @@ on:
   # Run when pushing to stable branches
   push:
     branches:
-    - 'master'
-    - 'release-*'
+      - "master"
+      - "release-*"
   # Run on branch/tag creation
   create:
   # Run on pull requests
@@ -24,36 +24,36 @@ jobs:
     env:
       MIX_ENV: ci
     steps:
-    - uses: actions/checkout@v2
-    - uses: actions/cache@v1
-      with:
-        path: deps
-        key: ${{ runner.os }}-${{ env.elixir_version }}-${{ env.otp_version }}-mix-${{ hashFiles(format('{0}{1}', github.workspace, '/mix.lock')) }}
-    - uses: actions/cache@v1
-      with:
-        path: _build
-        key: ${{ runner.os }}-${{ env.elixir_version }}-${{ env.otp_version }}-_build-${{ hashFiles(format('{0}{1}', github.workspace, '/mix.lock')) }}-${{ github.sha }}
-        restore-keys: |
-          ${{ runner.os }}-${{ env.elixir_version }}-${{ env.otp_version }}-_build-${{ hashFiles(format('{0}{1}', github.workspace, '/mix.lock')) }}
-    - id: plt_cache
-      uses: actions/cache@v1
-      with:
-        path: dialyzer_cache
-        key: ${{ runner.os }}-${{ env.elixir_version }}-${{ env.otp_version }}-dialyzer_cache-${{ github.sha }}
-        restore-keys: |
-          ${{ runner.os }}-${{ env.elixir_version }}-${{ env.otp_version }}-dialyzer_cache-
-    - uses: erlef/setup-beam@v1.15
-      with:
-        otp-version: ${{ env.otp_version }}
-        elixir-version: ${{ env.elixir_version }}
-    - name: Install Dependencies
-      run: mix deps.get
-    - name: Create PLTs dir
-      if: ${{steps.plt_cache.outputs.cache-hit != 'true'}}
-      run: mkdir -p dialyzer_cache && mix dialyzer --plt
-    - name: Run dialyzer
-      # FIXME: This should be set to fail when dialyzer issues are fixed
-      run: mix dialyzer || exit 0
+      - uses: actions/checkout@v2
+      - uses: actions/cache@v4
+        with:
+          path: deps
+          key: ${{ runner.os }}-${{ env.elixir_version }}-${{ env.otp_version }}-mix-${{ hashFiles(format('{0}{1}', github.workspace, '/mix.lock')) }}
+      - uses: actions/cache@v4
+        with:
+          path: _build
+          key: ${{ runner.os }}-${{ env.elixir_version }}-${{ env.otp_version }}-_build-${{ hashFiles(format('{0}{1}', github.workspace, '/mix.lock')) }}-${{ github.sha }}
+          restore-keys: |
+            ${{ runner.os }}-${{ env.elixir_version }}-${{ env.otp_version }}-_build-${{ hashFiles(format('{0}{1}', github.workspace, '/mix.lock')) }}
+      - id: plt_cache
+        uses: actions/cache@v4
+        with:
+          path: dialyzer_cache
+          key: ${{ runner.os }}-${{ env.elixir_version }}-${{ env.otp_version }}-dialyzer_cache-${{ github.sha }}
+          restore-keys: |
+            ${{ runner.os }}-${{ env.elixir_version }}-${{ env.otp_version }}-dialyzer_cache-
+      - uses: erlef/setup-beam@v1.15
+        with:
+          otp-version: ${{ env.otp_version }}
+          elixir-version: ${{ env.elixir_version }}
+      - name: Install Dependencies
+        run: mix deps.get
+      - name: Create PLTs dir
+        if: ${{steps.plt_cache.outputs.cache-hit != 'true'}}
+        run: mkdir -p dialyzer_cache && mix dialyzer --plt
+      - name: Run dialyzer
+        # FIXME: This should be set to fail when dialyzer issues are fixed
+        run: mix dialyzer || exit 0
 
   test-coverage:
     name: Build and Test
@@ -65,56 +65,58 @@ jobs:
       fail-fast: false
       matrix:
         rabbitmq:
-        - "rabbitmq:3.12.0-management"
+          - "rabbitmq:3.12.0-management"
         database:
-        - "cassandra:3.11.15"
-        - "scylladb/scylla:5.2.2"
+          - "cassandra:3.11.15"
+          - "scylladb/scylla:5.2.2"
     services:
       rabbitmq:
         image: ${{ matrix.rabbitmq }}
         ports:
-        - 5672:5672
-        - 15672:15672
+          - 5672:5672
+          - 15672:15672
       database:
         image: ${{ matrix.database }}
         ports:
-        - 9042:9042
+          - 9042:9042
     env:
       MIX_ENV: test
       RABBITMQ_HOST: localhost
       CASSANDRA_NODES: localhost
     steps:
-    - uses: actions/checkout@v2
-    - uses: actions/cache@v1
-      with:
-        path: deps
-        key: ${{ runner.os }}-${{ env.elixir_version }}-${{ env.otp_version }}-mix-${{ hashFiles(format('{0}{1}', github.workspace, '/mix.lock')) }}
-        restore-keys: |
-          ${{ runner.os }}-${{ env.elixir_version }}-${{ env.otp_version }}-mix-
-    - uses: actions/cache@v1
-      with:
-        path: _build
-        key: ${{ runner.os }}-${{ env.elixir_version }}-${{ env.otp_version }}-_build-${{ github.sha }}
-        restore-keys: |
-          ${{ runner.os }}-${{ env.elixir_version }}-${{ env.otp_version }}-_build-
-    - uses: erlef/setup-beam@v1.15
-      with:
-        otp-version: ${{ env.otp_version }}
-        elixir-version: ${{ env.elixir_version }}
-    - name: Install Dependencies
-      run: mix deps.get
-    - name: Check formatting
-      run: mix format --check-formatted
-    - name: Compile
-      run: mix do compile
-    - name: Wait for Cassandra
-      run: |
-        npm install -g wait-for-cassandra
-        wait-for-cassandra -T 120000 -h $CASSANDRA_NODES
-    - name: Test and Coverage
-      run: mix coveralls.json  --exclude wip -o coverage_results
-    - name: Upload Coverage Results to CodeCov
-      env:
-        CODECOV_TOKEN: ${{ secrets.CODECOV_TOKEN }}
-      run: |
-        bash <(curl -s https://codecov.io/bash) -t $CODECOV_TOKEN
+      - uses: actions/checkout@v2
+      - uses: actions/cache@v4
+        with:
+          path: deps
+          key: ${{ runner.os }}-${{ env.elixir_version }}-${{ env.otp_version }}-mix-${{ hashFiles(format('{0}{1}', github.workspace, '/mix.lock')) }}
+          restore-keys: |
+            ${{ runner.os }}-${{ env.elixir_version }}-${{ env.otp_version }}-mix-
+      - uses: actions/cache@v4
+        with:
+          path: _build
+          key: ${{ runner.os }}-${{ env.elixir_version }}-${{ env.otp_version }}-_build-${{ github.sha }}
+          restore-keys: |
+            ${{ runner.os }}-${{ env.elixir_version }}-${{ env.otp_version }}-_build-
+      - uses: erlef/setup-beam@v1.15
+        with:
+          otp-version: ${{ env.otp_version }}
+          elixir-version: ${{ env.elixir_version }}
+      - name: Install Dependencies
+        run: mix deps.get
+      - name: Check formatting
+        run: mix format --check-formatted
+      - name: Compile
+        run: mix do compile
+      - name: Wait for Cassandra
+        run: |
+          npm install -g wait-for-cassandra
+          wait-for-cassandra -T 120000 -h $CASSANDRA_NODES
+      - name: Test and Coverage
+        run: mix coveralls.json  --exclude wip -o coverage_results
+      - name: Upload Coverage Results to CodeCov
+        uses: codecov/codecov-action@v5
+        with:
+          fail_ci_if_error: true
+          token: ${{ secrets.CODECOV_TOKEN }}
+          verbose: true
+          directory: coverage_results  

CHANGELOG.md

@@ -1,25 +1,53 @@
 # 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
+
+## [1.3.0-rc.0] - 2025-11-21
+
 ### Added
+
+- Add the option to enable keepalive for scylladb connections, using the environment variable
+  `DOCKER_VERNEMQ_ASTARTE_VMQ_PLUGIN__CASSANDRA__ENABLE_KEEPALIVE`. Defaults to `true`
+- Devices can now declare support for optional Astarte MQTT v1 features to Astarte via capabilities
+
+## [1.2.1-rc.0] - 2025-08-22
+
+### Changed
+
+- RPC now uses erlang clustering instead of `astarte_rpc`
+
+## [1.2.1-alpha.0] - 2025-04-10
+
+### Added
+
+- Allow to set the Erlang cookie via the `RELEASE_COOKIE`
+  env var. Default to `vmq` for backwards compatibility.
+
+## [1.2.0] - 2024-07-01
+
+## [1.2.0-rc.0] - 2024-05-29
+
+### Added
+
 - The plugin now accesses the Astarte database. The following
   env variables have been added:
   - `DOCKER_VERNEMQ_ASTARTE_VMQ_PLUGIN__CASSANDRA__NODES`
-  (defaults to `localhost:9042`)
+    (defaults to `localhost:9042`)
   - `DOCKER_VERNEMQ_ASTARTE_VMQ_PLUGIN__CASSANDRA__USERNAME`
-  (defaults to `cassandra`)
+    (defaults to `cassandra`)
   - `DOCKER_VERNEMQ_ASTARTE_VMQ_PLUGIN__CASSANDRA__PASSWORD`
-  (defaults to `cassandra`)
+    (defaults to `cassandra`)
   - `DOCKER_VERNEMQ_ASTARTE_VMQ_PLUGIN__CASSANDRA__POOL_SIZE`
-  (defaults to 10)
+    (defaults to 10)
   - `DOCKER_VERNEMQ_ASTARTE_VMQ_PLUGIN__CASSANDRA__SSL_ENABLED`
-  (defaults to `false`)
+    (defaults to `false`)
   - `DOCKER_VERNEMQ_ASTARTE_VMQ_PLUGIN__CASSANDRA__SSL_DISABLE_SNI`
-  (defaults to `true`)
+    (defaults to `true`)
   - `DOCKER_VERNEMQ_ASTARTE_VMQ_PLUGIN__CASSANDRA__SSL_CUSTOM_SNI`
   - `DOCKER_VERNEMQ_ASTARTE_VMQ_PLUGIN__CASSANDRA__SSL_CA_FILE`
 - Added support for device deletion. During deletion, a device is
@@ -33,6 +61,7 @@ and this project adheres to [Semantic Versioning](http://semver.org/spec/v2.0.0.
 - Added support for `capabilities` message topic at `/<realm name>/<device name>/capabilities`
 
 ### Changed
+
 - Update Elixir to 1.15.7.
 - Update Erlang/OTP to 26.1.
 - Update VerneMQ to master (1cc57fa) to support OTP 26.
@@ -42,12 +71,16 @@ and this project adheres to [Semantic Versioning](http://semver.org/spec/v2.0.0.
 ## [1.1.0] - 2023-06-20
 
 ## [1.1.0-rc.0] - 2023-06-09
+
 ### Changed
+
 - Use the `internal` event type for device heartbeat.
 - Update Elixir to 1.14.5 and Erlang/OTP to 25.3.2.
 
 ## [1.1.0-alpha.0] - 2022-11-24
+
 ### Fixed
+
 - Correctly serialize disconnection/reconnection events if VerneMQ hooks are called in
   the wrong order. Fix https://github.com/astarte-platform/astarte/issues/668.
 
@@ -56,38 +89,52 @@ and this project adheres to [Semantic Versioning](http://semver.org/spec/v2.0.0.
 ## [1.0.5] - 2023-09-25
 
 ## [1.0.4] - 2022-09-26
+
 ### Fixed
+
 - Do not let VerneMQ container start unless the CA cert is retrieved from CFSSL.
 - Prevent the connection from timing out when the client takes more than 5 seconds to perform the
   SSL handshake
+
 ### Security
+
 - Rebuild official docker image (updates OTP to 23.3.4.17), in order to fix CVE-2022-37026.
 
 ## [1.0.3] - 2022-04-07
 
 ## [1.0.2] - 2022-03-30
 
 ## [1.0.1] - 2021-12-16
+
 ### Fixed
+
 - Do not override VerneMQ config `max_message_rate` value.
 
 ## [1.0.0] - 2021-06-30
+
 ### Changed
+
 - Log plugin version when the application is starting.
 
 ## [1.0.0-rc.0] - 2021-05-05
 
 ## [1.0.0-beta.2] - 2021-03-24
+
 ### Changed
+
 - Update Elixir to 1.11.4 and Erlang/OTP to 23.2
 - Do not authorize non-devices blindly in `auth_on_publish` and `auth_on_subscribe`.
 
 ## [1.0.0-beta.1] - 2021-02-16
+
 ### Changed
+
 - Default data_queue_count to 128.
 
 ## [1.0.0-alpha.1] - 2020-06-19
+
 ### Added
+
 - Send a periodic heartbeat for every connected device.
 - Support SSL for RabbitMQ connections.
 - Default max certificate chain length to 10.
@@ -96,19 +143,27 @@ and this project adheres to [Semantic Versioning](http://semver.org/spec/v2.0.0.
   variables
 
 ## [0.11.4] - 2021-01-26
+
 ### Fixed
+
 - Fix a bug where the plugin would remain unfunctional after suddenly disconnecting from RabbitMQ.
 
 ## [0.11.3] - 2020-09-24
+
 ### Fixed
+
 - Fix bug that prevented property unset
 
 ## [0.11.2] - 2020-08-14
+
 ### Added
+
 - Update Elixir to 1.8.2
 
 ## [0.11.1] - 2020-05-18
+
 ### Added
+
 - Enhance docker build process
 
 ## [0.11.0] - 2020-04-13
@@ -120,7 +175,9 @@ and this project adheres to [Semantic Versioning](http://semver.org/spec/v2.0.0.
 ## [0.11.0-beta.2] - 2020-01-24
 
 ## [0.11.0-beta.1] - 2019-12-26
+
 ### Added
+
 - Add support to multiple queues with consistent hashing
 
 ## [0.10.2] - 2019-12-09
@@ -130,7 +187,9 @@ and this project adheres to [Semantic Versioning](http://semver.org/spec/v2.0.0.
 ## [0.10.0] - 2019-04-16
 
 ## [0.10.0-rc.1] - 2019-04-10
+
 ### Fixed
+
 - Re-enable SSL listener, which broke Docker Compose.
 
 ## [0.10.0-rc.0] - 2019-04-03
@@ -140,5 +199,7 @@ and this project adheres to [Semantic Versioning](http://semver.org/spec/v2.0.0.
 ## [0.10.0-beta.2] - 2018-10-19
 
 ## [0.10.0-beta.1] - 2018-08-27
+
 ### Added
+
 - First Astarte release.