diff --git a/config/config.exs b/config/config.exs index ee4bda3e..fe8b2372 100644 --- a/config/config.exs +++ b/config/config.exs @@ -4,4 +4,4 @@ config :avrora, schemas_path: Path.expand("./priv/schemas"), registry_url: nil -config :logger, :console, format: "$time $metadata[$level] $levelpad(Avrora) $message\n" +config :logger, :console, format: "$time $metadata[$level] $levelpad$message\n" diff --git a/lib/avrora/config.ex b/lib/avrora/config.ex index bac28518..ba73d592 100644 --- a/lib/avrora/config.ex +++ b/lib/avrora/config.ex @@ -16,7 +16,7 @@ defmodule Avrora.Config do """ @doc false - def schemas_path, do: get_env(:schemas_path, Path.expand("../../priv/schemas")) + def schemas_path, do: get_env(:schemas_path, Path.expand("./priv/schemas")) @doc false def registry_url, do: get_env(:registry_url, nil) diff --git a/lib/avrora/storage/file.ex b/lib/avrora/storage/file.ex index d0d2f869..94144b65 100644 --- a/lib/avrora/storage/file.ex +++ b/lib/avrora/storage/file.ex @@ -46,12 +46,15 @@ defmodule Avrora.Storage.File do ) end + Logger.debug("reading schema `#{schema_name.name}` from the file #{filepath}") + Schema.parse(body) end end @doc false def get(key) when is_integer(key), do: {:error, :unsupported} + @doc false def put(_key, _value), do: {:error, :unsupported} diff --git a/lib/avrora/storage/registry.ex b/lib/avrora/storage/registry.ex index dce1c2b6..ee82225e 100644 --- a/lib/avrora/storage/registry.ex +++ b/lib/avrora/storage/registry.ex @@ -28,6 +28,8 @@ defmodule Avrora.Storage.Registry do {:ok, version} <- Map.fetch(response, "version"), {:ok, schema} <- Map.fetch(response, "schema"), {:ok, schema} <- Schema.parse(schema) do + Logger.debug("obtaining schema #{schema_name.name} with version `#{version}`") + {:ok, %{schema | version: version}} end end @@ -48,6 +50,8 @@ defmodule Avrora.Storage.Registry do with {:ok, response} <- http_client_get("schemas/ids/#{key}"), {:ok, schema} <- Map.fetch(response, "schema"), {:ok, schema} <- Schema.parse(schema) do + Logger.debug("obtaining schema with global id `#{key}`") + {:ok, %{schema | id: key}} end end @@ -74,6 +78,8 @@ defmodule Avrora.Storage.Registry do ) end + Logger.debug("new schema `#{schema_name.name}` stored with global id `#{id}`") + {:ok, %{schema | id: id}} end end diff --git a/mix.exs b/mix.exs index 1bfbade3..ee5b2dee 100644 --- a/mix.exs +++ b/mix.exs @@ -4,7 +4,7 @@ defmodule Avrora.MixProject do def project do [ app: :avrora, - version: "0.2.0", + version: "0.2.1", elixir: "~> 1.6", description: description(), package: package(),