Edit plug for authorization

Edit plug to match new astarte feature for a shared db through multiple astarte instances

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

lib/astarte_flow/auth/astarte_public_key_provider.ex

@@ -22,6 +22,8 @@ defmodule Astarte.Flow.Auth.AstartePublicKeyProvider do
   require Logger
 
   alias Astarte.Core.Realm
+  alias Astarte.Core.CQLUtils
+  alias Astarte.Flow.Config
 
   @impl true
   @spec fetch_public_key(realm :: String.t()) ::
@@ -31,6 +33,8 @@ defmodule Astarte.Flow.Auth.AstartePublicKeyProvider do
   end
 
   defp fetch_realm_public_key(conn, realm_name) do
+    realm_name = CQLUtils.realm_name_to_keyspace_name(realm_name, Config.astarte_instance_id!())
+
     statement = """
     SELECT blobAsVarchar(value)
     FROM :realm_name.kv_store

lib/astarte_flow/config.ex

@@ -130,6 +130,12 @@ defmodule Astarte.Flow.Config do
     os_env: "CASSANDRA_NODES",
     type: XandraNodes
 
+  @envdoc "The astarte instance id to generate keyspaces with"
+  app_env :astarte_instance_id, :astarte_flow, :astarte_instance_id,
+    os_env: "ASTARTE_INSTANCE_ID",
+    default: "",
+    type: :binary
+
   @doc "Returns the default amqp connection parameters"
   @type ssl_option ::
           {:cacertfile, String.t()}

lib/astarte_flow/flows/flow.ex

@@ -206,9 +206,7 @@ defmodule Astarte.Flow.Flows.Flow do
       error ->
         _ =
           Logger.error(
-            "Could not start block #{inspect(block_module)} with opts #{inspect(block_opts)}: #{
-              inspect(error)
-            }"
+            "Could not start block #{inspect(block_module)} with opts #{inspect(block_opts)}: #{inspect(error)}"
           )
 
         {:error, :block_start_failed}