Claudio Ortolina
73 lines
1.9 KiB
Elixir
73 lines
1.9 KiB
Elixir
defmodule MusicLibrary.Artists do
|
|
import Ecto.Query, warn: false
|
|
alias MusicLibrary.Repo
|
|
|
|
alias MusicLibrary.Records.{ArtistInfo, ArtistRecord, Record}
|
|
|
|
def get_artist!(musicbrainz_id) do
|
|
q =
|
|
from ar in ArtistRecord,
|
|
where: ar.musicbrainz_id == ^musicbrainz_id,
|
|
limit: 1,
|
|
select: ar.artist
|
|
|
|
Repo.one!(q)
|
|
end
|
|
|
|
def get_similar_artists(artist) do
|
|
case LastFm.get_similar_artists(artist.musicbrainz_id, artist.name) do
|
|
{:ok, artists} ->
|
|
collected_artist_ids = get_collected_artist_ids()
|
|
|
|
{:ok,
|
|
Enum.filter(artists, fn a ->
|
|
MapSet.member?(collected_artist_ids, a.musicbrainz_id)
|
|
end)}
|
|
|
|
error ->
|
|
error
|
|
end
|
|
end
|
|
|
|
def get_all_artist_ids do
|
|
q = from ar in ArtistRecord, distinct: true, select: ar.musicbrainz_id
|
|
|
|
q |> Repo.all() |> MapSet.new()
|
|
end
|
|
|
|
def get_all_artist_pairs do
|
|
q =
|
|
from ar in ArtistRecord,
|
|
distinct: true,
|
|
select: %{artist_id: ar.musicbrainz_id, record_id: ar.record_id}
|
|
|
|
q |> Repo.all()
|
|
end
|
|
|
|
def fetch_artist_info(artist_id) do
|
|
with {:ok, musicbrainz_artist} <- MusicBrainz.get_artist(artist_id),
|
|
discogs_id = MusicBrainz.Artist.get_discogs_id(musicbrainz_artist),
|
|
{:ok, discogs_artist} <- Discogs.get_artist(discogs_id) do
|
|
%ArtistInfo{}
|
|
|> ArtistInfo.changeset(%{
|
|
id: musicbrainz_artist.id,
|
|
musicbrainz_data: musicbrainz_artist.musicbrainz_data,
|
|
discogs_data: discogs_artist
|
|
})
|
|
|> Repo.insert(on_conflict: {:replace, [:musicbrainz_data, :discogs_data]})
|
|
end
|
|
end
|
|
|
|
defp get_collected_artist_ids do
|
|
q =
|
|
from ar in ArtistRecord,
|
|
join: r in Record,
|
|
on: r.id == ar.record_id,
|
|
where: not is_nil(r.purchased_at),
|
|
distinct: true,
|
|
select: ar.musicbrainz_id
|
|
|
|
q |> Repo.all() |> MapSet.new()
|
|
end
|
|
end
|