lib/baz/normalized_sinks/logger.ex
defmodule Baz.NormalizedSinks.Logger do
require Logger
@behaviour Baz.CollectionPackSink
@behaviour Baz.CollectionSink
@behaviour Baz.CollectionTraitSink
@behaviour Baz.CollectionAssetSink
@behaviour Baz.CollectionAssetTraitSink
@behaviour Baz.CollectionEventSink
@impl true
def receive_collection_pack_import(changeset) do
log_info_inspect(changeset)
end
@impl true
def receive_collection_pack_stream(changeset) do
log_info_inspect(changeset)
end
@impl true
def receive_collection_import(changeset) do
log_info_inspect(changeset)
end
@impl true
def receive_collection_stream(changeset) do
log_info_inspect(changeset)
end
@impl true
def receive_collection_trait_import(changeset) do
log_info_inspect(changeset)
end
@impl true
def receive_collection_trait_stream(changeset) do
log_info_inspect(changeset)
end
@impl true
def receive_collection_asset_import(multi) do
log_info_inspect(multi)
end
@impl true
def receive_collection_asset_stream(changeset) do
log_info_inspect(changeset)
end
@impl true
def receive_collection_asset_trait_import(changeset) do
log_info_inspect(changeset)
end
@impl true
def receive_collection_asset_trait_stream(changeset) do
log_info_inspect(changeset)
end
@impl true
def receive_collection_event_import(multi) do
log_info_inspect(multi)
end
@impl true
def receive_collection_event_stream(changeset) do
log_info_inspect(changeset)
end
defp log_info_inspect(data) do
data
|> inspect()
|> Logger.info()
end
end