feat(data_access): Add Required field to Endpoints table

nedimtokic · nedimtokic · commit 04f6d19937c0 · 2026-03-11T12:33:01.000+01:00
Add migration for new `Required` field in the Endpoints
table, and use it.

Signed-off-by: nedimtokic &lt;nedim.tokic@secomind.com&gt;
diff --git a/apps/astarte_appengine_api/test/support/helpers/database.ex b/apps/astarte_appengine_api/test/support/helpers/database.ex
@@ -192,6 +192,7 @@ defmodule Astarte.Helpers.Database do
         explicit_timestamp boolean,
         description varchar,
         doc varchar,
+        required boolean,
 
         PRIMARY KEY ((interface_id), endpoint_id)
     );
diff --git a/apps/astarte_appengine_api/test/support/helpers/database_v2.ex b/apps/astarte_appengine_api/test/support/helpers/database_v2.ex
@@ -141,6 +141,7 @@ defmodule Astarte.Helpers.DatabaseV2 do
     explicit_timestamp boolean,
     description text,
     doc text,
+    required boolean,
 
     PRIMARY KEY ((interface_id), endpoint_id)
   )
diff --git a/apps/astarte_data_updater_plant/test/support/database_test_helper.ex b/apps/astarte_data_updater_plant/test/support/database_test_helper.ex
@@ -124,6 +124,7 @@ defmodule Astarte.DataUpdaterPlant.DatabaseTestHelper do
         explicit_timestamp boolean,
         description varchar,
         doc varchar,
+        required boolean,
 
         PRIMARY KEY ((interface_id), endpoint_id)
     );
diff --git a/apps/astarte_data_updater_plant/test/support/helpers/database.ex b/apps/astarte_data_updater_plant/test/support/helpers/database.ex
@@ -146,6 +146,7 @@ defmodule Astarte.Helpers.Database do
     explicit_timestamp boolean,
     description text,
     doc text,
+    required boolean,
 
     PRIMARY KEY ((interface_id), endpoint_id)
   )
diff --git a/apps/astarte_housekeeping/lib/astarte_housekeeping/realms/queries.ex b/apps/astarte_housekeeping/lib/astarte_housekeeping/realms/queries.ex
@@ -807,6 +807,7 @@ defmodule Astarte.Housekeeping.Realms.Queries do
       explicit_timestamp boolean,
       description varchar,
       doc varchar,
+      required boolean,
 
       PRIMARY KEY ((interface_id), endpoint_id)
     );
diff --git a/apps/astarte_housekeeping/priv/migrations/realm/0011_add_required_to_endpoints.sql b/apps/astarte_housekeeping/priv/migrations/realm/0011_add_required_to_endpoints.sql
@@ -0,0 +1,4 @@
+ALTER TABLE :keyspace.endpoints
+ADD (
+  required boolean
+);
diff --git a/apps/astarte_housekeeping/test/support/helpers/database.ex b/apps/astarte_housekeeping/test/support/helpers/database.ex
@@ -166,6 +166,7 @@ defmodule Astarte.Housekeeping.Helpers.Database do
     explicit_timestamp boolean,
     description text,
     doc text,
+    required boolean,
 
     PRIMARY KEY ((interface_id), endpoint_id)
   )
diff --git a/apps/astarte_pairing/test/support/helpers/database.ex b/apps/astarte_pairing/test/support/helpers/database.ex
@@ -187,6 +187,7 @@ defmodule Astarte.Helpers.Database do
     explicit_timestamp boolean,
     description text,
     doc text,
+    required boolean,
 
     PRIMARY KEY ((interface_id), endpoint_id)
   )
diff --git a/apps/astarte_realm_management/test/support/helpers/database.ex b/apps/astarte_realm_management/test/support/helpers/database.ex
@@ -139,6 +139,7 @@ defmodule Astarte.Helpers.Database do
     explicit_timestamp boolean,
     description text,
     doc text,
+    required boolean,
 
     PRIMARY KEY ((interface_id), endpoint_id)
   )
diff --git a/apps/astarte_trigger_engine/test/support/helpers/database.ex b/apps/astarte_trigger_engine/test/support/helpers/database.ex
@@ -141,6 +141,7 @@ defmodule Astarte.Helpers.Database do
     explicit_timestamp boolean,
     description text,
     doc text,
+    required boolean,
 
     PRIMARY KEY ((interface_id), endpoint_id)
   )
diff --git a/libs/astarte_data_access/lib/astarte_data_access/mappings.ex b/libs/astarte_data_access/lib/astarte_data_access/mappings.ex
@@ -42,7 +42,8 @@ defmodule Astarte.DataAccess.Mappings do
     :allow_unset,
     :explicit_timestamp,
     :endpoint_id,
-    :interface_id
+    :interface_id,
+    :required
   ]
 
   @spec fetch_interface_mappings(String.t(), binary, keyword) ::
diff --git a/libs/astarte_data_access/lib/astarte_data_access/realms/endpoint.ex b/libs/astarte_data_access/lib/astarte_data_access/realms/endpoint.ex
@@ -44,7 +44,8 @@ defmodule Astarte.DataAccess.Realms.Endpoint do
                       :interface_type,
                       :reliability,
                       :retention,
-                      :value_type
+                      :value_type,
+                      :required
                     ] ++ @required_fields
 
   @primary_key false
@@ -66,6 +67,7 @@ defmodule Astarte.DataAccess.Realms.Endpoint do
     field :reliability, Reliability
     field :retention, Retention
     field :value_type, ValueType
+    field :required, :boolean
   end
 
   def changeset(endpoint, params \\ %{}) do
diff --git a/libs/astarte_data_access/test/support/database_test_helper.exs b/libs/astarte_data_access/test/support/database_test_helper.exs
@@ -151,6 +151,7 @@ defmodule Astarte.DataAccess.DatabaseTestHelper do
         explicit_timestamp boolean,
         description varchar,
         doc varchar,
+        required boolean,
 
         PRIMARY KEY ((interface_id), endpoint_id)
       );
diff --git a/libs/astarte_events/test/support/helpers/database_test_helper.ex b/libs/astarte_events/test/support/helpers/database_test_helper.ex
@@ -155,6 +155,7 @@ defmodule Astarte.Helpers.Database do
     explicit_timestamp boolean,
     description text,
     doc text,
+    required boolean,
 
     PRIMARY KEY ((interface_id), endpoint_id)
   )
diff --git a/libs/astarte_rpc/test/support/helpers/database.ex b/libs/astarte_rpc/test/support/helpers/database.ex
@@ -143,6 +143,7 @@ defmodule Astarte.RPC.Helpers.Database do
     explicit_timestamp boolean,
     description text,
     doc text,
+    required boolean,
 
     PRIMARY KEY ((interface_id), endpoint_id)
   )
diff --git a/tools/astarte_export/test/database_test.exs b/tools/astarte_export/test/database_test.exs
@@ -109,6 +109,7 @@ defmodule Astarte.DatabaseTestdata do
     reliability int,
     retention int,
     value_type int,
+    required boolean,
     PRIMARY KEY (interface_id, endpoint_id)
   )
   """
diff --git a/tools/astarte_import/test/astarte/database_test.exs b/tools/astarte_import/test/astarte/database_test.exs
@@ -124,6 +124,7 @@ defmodule Astarte.DatabaseTestdata do
     reliability int,
     retention int,
     value_type int,
+    required boolean,
     PRIMARY KEY (interface_id, endpoint_id)
   )
   """

Original file line number	Diff line number	Diff line change
`@@ -141,6 +141,7 @@ defmodule Astarte.Helpers.DatabaseV2 do`
`141`	`141`	`explicit_timestamp boolean,`
`142`	`142`	`description text,`
`143`	`143`	`doc text,`
	`144`	`+ required boolean,`
`144`	`145`
`145`	`146`	`PRIMARY KEY ((interface_id), endpoint_id)`
`146`	`147`	`)`
Original file line number	Diff line number	Diff line change
`@@ -146,6 +146,7 @@ defmodule Astarte.Helpers.Database do`
`146`	`146`	`explicit_timestamp boolean,`
`147`	`147`	`description text,`
`148`	`148`	`doc text,`
	`149`	`+ required boolean,`
`149`	`150`
`150`	`151`	`PRIMARY KEY ((interface_id), endpoint_id)`
`151`	`152`	`)`
-Original file line number
+Diff line change
@@ @@ -0,0 +1,4 @@ @@
 +ALTER TABLE :keyspace.endpoints
 +ADD (
 +  required boolean
 +);
Original file line number	Diff line number	Diff line change
`@@ -166,6 +166,7 @@ defmodule Astarte.Housekeeping.Helpers.Database do`
`166`	`166`	`explicit_timestamp boolean,`
`167`	`167`	`description text,`
`168`	`168`	`doc text,`
	`169`	`+ required boolean,`
`169`	`170`
`170`	`171`	`PRIMARY KEY ((interface_id), endpoint_id)`
`171`	`172`	`)`
Original file line number	Diff line number	Diff line change
`@@ -187,6 +187,7 @@ defmodule Astarte.Helpers.Database do`
`187`	`187`	`explicit_timestamp boolean,`
`188`	`188`	`description text,`
`189`	`189`	`doc text,`
	`190`	`+ required boolean,`
`190`	`191`
`191`	`192`	`PRIMARY KEY ((interface_id), endpoint_id)`
`192`	`193`	`)`
Original file line number	Diff line number	Diff line change
`@@ -139,6 +139,7 @@ defmodule Astarte.Helpers.Database do`
`139`	`139`	`explicit_timestamp boolean,`
`140`	`140`	`description text,`
`141`	`141`	`doc text,`
	`142`	`+ required boolean,`
`142`	`143`
`143`	`144`	`PRIMARY KEY ((interface_id), endpoint_id)`
`144`	`145`	`)`