chore: add ownership_vouchers table and device ref on all db helpers

Signed-off-by: Eddy Babetto <eddy.babetto@secomind.com>

Author: eddbbt

apps/astarte_appengine_api/test/support/helpers/database.ex

@@ -107,6 +107,16 @@ defmodule Astarte.Helpers.Database do
   );
   """
 
+  @create_ownership_vouchers_table """
+  CREATE TABLE #{Realm.keyspace_name(@test_realm)}.ownership_vouchers (
+     id uuid,
+     private_key blob,
+     voucher_data blob,
+     expiry timestamp,
+     PRIMARY KEY (id)
+   );
+  """
+
   @create_devices_table """
       CREATE TABLE #{Realm.keyspace_name(@test_realm)}.devices (
         device_id uuid,
@@ -134,6 +144,7 @@ defmodule Astarte.Helpers.Database do
         attributes map<varchar, varchar>,
         groups map<text, timeuuid>,
         capabilities capabilities,
+        ownership_voucher uuid,
 
         PRIMARY KEY (device_id)
       );
@@ -433,6 +444,8 @@ defmodule Astarte.Helpers.Database do
       {:ok, _} ->
         Repo.query!(@create_capabilities_type)
 
+        Repo.query!(@create_ownership_vouchers_table)
+
         Repo.query!(@create_devices_table)
 
         Repo.query!(@create_deletion_in_progress_table)

apps/astarte_appengine_api/test/support/helpers/database_v2.ex

@@ -66,6 +66,15 @@ defmodule Astarte.Helpers.DatabaseV2 do
     purge_properties_compression_format int
   );
   """
+  @create_ownership_vouchers_table """
+  CREATE TABLE :keyspace.ownership_vouchers (
+     id uuid,
+     private_key blob,
+     voucher_data blob,
+     expiry timestamp,
+     PRIMARY KEY (id)
+   );
+  """
 
   @create_devices_table """
   CREATE TABLE :keyspace.devices (
@@ -95,6 +104,7 @@ defmodule Astarte.Helpers.DatabaseV2 do
     capabilities capabilities,
 
     groups map<text, timeuuid>,
+          ownership_voucher uuid,
 
     PRIMARY KEY (device_id)
   )
@@ -247,6 +257,7 @@ defmodule Astarte.Helpers.DatabaseV2 do
     realm_keyspace = Realm.keyspace_name(realm_name)
     execute!(realm_keyspace, @create_keyspace)
     execute!(realm_keyspace, @create_capabilities_type)
+    execute!(realm_keyspace, @create_ownership_vouchers_table)
     execute!(realm_keyspace, @create_devices_table)
     execute!(realm_keyspace, @create_groups_table)
     execute!(realm_keyspace, @create_names_table)

apps/astarte_data_updater_plant/test/support/database_test_helper.ex

@@ -50,6 +50,16 @@ defmodule Astarte.DataUpdaterPlant.DatabaseTestHelper do
     );
   """
 
+  @create_ownership_vouchers_table """
+  CREATE TABLE :keyspace.ownership_vouchers (
+     id uuid,
+     private_key blob,
+     voucher_data blob,
+     expiry timestamp,
+     PRIMARY KEY (id)
+   );
+  """
+
   @create_devices_table """
       CREATE TABLE :keyspace.devices (
         device_id uuid,
@@ -77,6 +87,7 @@ defmodule Astarte.DataUpdaterPlant.DatabaseTestHelper do
         attributes map<varchar, varchar>,
         groups map<text, timeuuid>,
         capabilities capabilities,
+  ownership_voucher uuid,
 
         PRIMARY KEY (device_id)
     );
@@ -366,6 +377,7 @@ defmodule Astarte.DataUpdaterPlant.DatabaseTestHelper do
     case execute(keyspace_name, @create_autotestrealm) do
       {:ok, _} ->
         execute!(keyspace_name, @create_capabilities_type)
+        execute!(keyspace_name, @create_ownership_vouchers_table)
         execute!(keyspace_name, @create_devices_table)
         execute!(keyspace_name, @create_endpoints_table)
 

apps/astarte_data_updater_plant/test/support/helpers/database.ex

@@ -70,6 +70,15 @@ defmodule Astarte.Helpers.Database do
     purge_properties_compression_format int
   );
   """
+  @create_ownership_vouchers_table """
+  CREATE TABLE :keyspace.ownership_vouchers (
+     id uuid,
+     private_key blob,
+     voucher_data blob,
+     expiry timestamp,
+     PRIMARY KEY (id)
+   );
+  """
 
   @create_devices_table """
   CREATE TABLE :keyspace.devices (
@@ -96,7 +105,8 @@ defmodule Astarte.Helpers.Database do
     last_credentials_request_ip inet,
     last_seen_ip inet,
     attributes map<varchar, varchar>,
-    capabilities capabilities,
+    capabilities capabilities, 
+    ownership_voucher uuid,
 
     groups map<text, timeuuid>,
 
@@ -305,6 +315,7 @@ defmodule Astarte.Helpers.Database do
     realm_keyspace = Realm.keyspace_name(realm_name)
     execute!(realm_keyspace, @create_keyspace)
     execute!(realm_keyspace, @create_capabilities_type)
+    execute!(realm_keyspace, @create_ownership_vouchers_table)
     execute!(realm_keyspace, @create_devices_table)
     execute!(realm_keyspace, @create_groups_table)
     execute!(realm_keyspace, @create_names_table)

apps/astarte_housekeeping/test/support/helpers/database.ex

@@ -67,6 +67,15 @@ defmodule Astarte.Housekeeping.Helpers.Database do
     purge_properties_compression_format int
   );
   """
+  @create_ownership_vouchers_table """
+  CREATE TABLE :keyspace.ownership_vouchers (
+     id uuid,
+     private_key blob,
+     voucher_data blob,
+     expiry timestamp,
+     PRIMARY KEY (id)
+   );
+  """
 
   @create_devices_table """
   CREATE TABLE :keyspace.devices (
@@ -95,6 +104,7 @@ defmodule Astarte.Housekeeping.Helpers.Database do
     attributes map<varchar, varchar>,
     groups map<text, timeuuid>,
     capabilities capabilities,
+  ownership_voucher uuid,
 
     PRIMARY KEY (device_id)
   )
@@ -325,6 +335,7 @@ defmodule Astarte.Housekeeping.Helpers.Database do
     realm_keyspace = Realm.keyspace_name(realm_name)
     execute(realm_keyspace, @create_keyspace)
     execute(realm_keyspace, @create_capabilities_type)
+    execute(realm_keyspace, @create_ownership_vouchers_table)
     execute(realm_keyspace, @create_devices_table)
     execute(realm_keyspace, @create_groups_table)
     execute(realm_keyspace, @create_names_table)

apps/astarte_pairing/test/support/helpers/database.ex

@@ -74,6 +74,16 @@ defmodule Astarte.Helpers.Database do
   );
   """
 
+  @create_ownership_vouchers_table """
+  CREATE TABLE :keyspace.ownership_vouchers (
+     id uuid,
+     private_key blob,
+     voucher_data blob,
+     expiry timestamp,
+     PRIMARY KEY (id)
+   );
+  """
+
   @create_devices_table """
   CREATE TABLE :keyspace.devices (
     device_id uuid,
@@ -102,6 +112,7 @@ defmodule Astarte.Helpers.Database do
     capabilities capabilities,
 
     groups map<text, timeuuid>,
+     ownership_voucher uuid,
 
     PRIMARY KEY (device_id)
   )
@@ -284,6 +295,7 @@ defmodule Astarte.Helpers.Database do
     realm_keyspace = Realm.keyspace_name(realm_name)
     execute!(realm_keyspace, @create_keyspace)
     execute!(realm_keyspace, @create_capabilities_type)
+    execute!(realm_keyspace, @create_ownership_vouchers_table)
     execute!(realm_keyspace, @create_devices_table)
     execute!(realm_keyspace, @create_groups_table)
     execute!(realm_keyspace, @create_names_table)

apps/astarte_realm_management/test/support/helpers/database.ex

@@ -67,6 +67,16 @@ defmodule Astarte.Helpers.Database do
   );
   """
 
+  @create_ownership_vouchers_table """
+  CREATE TABLE IF NOT EXISTS :keyspace.ownership_vouchers (
+     id uuid,
+     private_key blob,
+     voucher_data blob,
+     expiry timestamp,
+     PRIMARY KEY (id)
+   );
+  """
+
   @create_devices_table """
   CREATE TABLE IF NOT EXISTS :keyspace.devices (
     device_id uuid,
@@ -93,8 +103,8 @@ defmodule Astarte.Helpers.Database do
     last_seen_ip inet,
     attributes map<varchar, varchar>,
     capabilities capabilities,
-
     groups map<text, timeuuid>,
+    ownership_voucher uuid,
 
     PRIMARY KEY (device_id)
   )
@@ -262,6 +272,7 @@ defmodule Astarte.Helpers.Database do
     realm_keyspace = Realm.keyspace_name(realm_name)
     execute!(realm_keyspace, @create_keyspace)
     execute!(realm_keyspace, @create_capabilities_type)
+    execute!(realm_keyspace, @create_ownership_vouchers_table)
     execute!(realm_keyspace, @create_devices_table)
     execute!(realm_keyspace, @create_groups_table)
     execute!(realm_keyspace, @create_names_table)

apps/astarte_trigger_engine/test/support/helpers/database.ex

@@ -66,6 +66,16 @@ defmodule Astarte.Helpers.Database do
   );
   """
 
+  @create_ownership_vouchers_table """
+  CREATE TABLE :keyspace.ownership_vouchers (
+     id uuid,
+     private_key blob,
+     voucher_data blob,
+     expiry timestamp,
+     PRIMARY KEY (id)
+   );
+  """
+
   @create_devices_table """
   CREATE TABLE :keyspace.devices (
     device_id uuid,
@@ -92,8 +102,8 @@ defmodule Astarte.Helpers.Database do
     last_seen_ip inet,
     attributes map<varchar, varchar>,
     capabilities capabilities,
-
     groups map<text, timeuuid>,
+    ownership_voucher uuid,
 
     PRIMARY KEY (device_id)
   )
@@ -223,6 +233,7 @@ defmodule Astarte.Helpers.Database do
     realm_keyspace = Realm.keyspace_name(realm_name)
     execute!(realm_keyspace, @create_keyspace)
     execute!(realm_keyspace, @create_capabilities_type)
+    execute!(realm_keyspace, @create_ownership_vouchers_table)
     execute!(realm_keyspace, @create_devices_table)
     execute!(realm_keyspace, @create_groups_table)
     execute!(realm_keyspace, @create_names_table)

libs/astarte_data_access/test/support/database_test_helper.exs

@@ -57,6 +57,16 @@ defmodule Astarte.DataAccess.DatabaseTestHelper do
     );
   """
 
+  @create_ownership_vouchers_table """
+  CREATE TABLE :keyspace.ownership_vouchers (
+     id uuid,
+     private_key blob,
+     voucher_data blob,
+     expiry timestamp,
+     PRIMARY KEY (id)
+   );
+  """
+
   @create_devices_table """
       CREATE TABLE autotestrealm.devices (
         device_id uuid,
@@ -83,6 +93,7 @@ defmodule Astarte.DataAccess.DatabaseTestHelper do
         last_seen_ip inet,
         attributes map<varchar, varchar>,
         groups map<text, timeuuid>,
+        ownership_voucher uuid,
 
         PRIMARY KEY (device_id)
       );
@@ -403,6 +414,7 @@ defmodule Astarte.DataAccess.DatabaseTestHelper do
   def create_test_keyspace(conn) do
     case Xandra.execute(conn, @create_autotestrealm) do
       {:ok, _} ->
+        Xandra.execute!(conn, @create_ownership_vouchers_table)
         Xandra.execute!(conn, @create_devices_table)
         Xandra.execute!(conn, @create_names_table)
         Xandra.execute!(conn, @create_kv_store)

tools/astarte_export/test/database_test.exs

@@ -34,7 +34,17 @@ defmodule Astarte.DatabaseTestdata do
       PRIMARY KEY ((group_name), insertion_uuid, device_id)
     );
   """
-
+  
+  @create_ownership_vouchers_table """
+  CREATE TABLE :keyspace.ownership_vouchers (
+     id uuid,
+     private_key blob,
+     voucher_data blob,
+     expiry timestamp,
+     PRIMARY KEY (id)
+   );
+  """
+  
   @create_devices_table """
     CREATE TABLE test.devices (
     device_id uuid PRIMARY KEY,
@@ -59,7 +69,8 @@ defmodule Astarte.DatabaseTestdata do
     pending_empty_cache boolean,
     protocol_revision int,
     total_received_bytes bigint,
-    total_received_msgs bigint
+    total_received_msgs bigint,
+    ownership_voucher uuid,
   )
   """
   @create_interfaces_table """
@@ -336,6 +347,7 @@ defmodule Astarte.DatabaseTestdata do
       @create_kv_store,
       @create_names_table,
       @create_groups_table,
+      @create_ownership_vouchers_table,
       @create_devices_table,
       @create_interfaces_table,
       @create_endpoints_table,