alvaro/lol-analytics
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

update player processor

Browse Source
This commit is contained in:
Álvaro 2024-05-05 02:36:12 +02:00
parent 97a446ddcf
commit 8063944e54
1 changed files with 7 additions and 11 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

18
apps/scrapper/lib/scrapper/processor/player_processor.ex
View File

@ -34,23 +34,21 @@ defmodule Scrapper.Processor.PlayerProcessor do
end end
@impl true @impl true
@spec handle_message(any(), Broadway.Message.t(), any()) :: Broadway.Message.t()
def handle_message(_, message = %Broadway.Message{}, _) do def handle_message(_, message = %Broadway.Message{}, _) do
puuid = message.data puuid = message.data
resp = Scrapper.Data.Api.MatchApi.get_matches_from_player(puuid)
case LolAnalytics.Player.PlayerRepo.get_player(puuid) do case LolAnalytics.Player.PlayerRepo.get_player(puuid) do
nil -> nil ->
LolAnalytics.Player.PlayerRepo.insert_player(puuid) :noop
player -> player ->
player update_player_processed(player)
|> LolAnalytics.Player.PlayerRepo.update_player(%{
:last_processed_at => DateTime.utc_now() |> DateTime.truncate(:second)
})
end end
case resp do match_history = Scrapper.Data.Api.MatchApi.get_matches_from_player(puuid)
case match_history do
{:ok, matches} -> {:ok, matches} ->
{ {
matches matches
@ -66,9 +64,7 @@ defmodule Scrapper.Processor.PlayerProcessor do
message message
end end
defp update_player(nil), do: :player_not_found defp update_player_processed(player) do
defp update_player(player) do
LolAnalytics.Player.PlayerRepo.update_player(player, %{ LolAnalytics.Player.PlayerRepo.update_player(player, %{
:last_processed_at => DateTime.utc_now() |> DateTime.truncate(:second) :last_processed_at => DateTime.utc_now() |> DateTime.truncate(:second)
}) })