defmodule Mobilizon.Addresses do @moduledoc """ The Addresses context. """ import Ecto.Query alias Mobilizon.Addresses.Address alias Mobilizon.Storage.Repo require Logger @doc """ Gets a single address. """ @spec get_address(integer | String.t()) :: Address.t() | nil def get_address(id), do: Repo.get(Address, id) @doc """ Gets a single address. Raises `Ecto.NoResultsError` if the address does not exist. """ @spec get_address!(integer | String.t()) :: Address.t() def get_address!(id), do: Repo.get!(Address, id) @doc """ Gets a single address by its url. """ @spec get_address_by_url(String.t()) :: Address.t() | nil def get_address_by_url(url), do: Repo.get_by(Address, url: url) @doc """ Creates an address. """ @spec create_address(map) :: {:ok, Address.t()} | {:error, Ecto.Changeset.t()} def create_address(attrs \\ %{}) do %Address{} |> Address.changeset(attrs) |> Repo.insert( on_conflict: :replace_all_except_primary_key, conflict_target: [:origin_id] ) end @doc """ Updates an address. """ @spec update_address(Address.t(), map) :: {:ok, Address.t()} | {:error, Ecto.Changeset.t()} def update_address(%Address{} = address, attrs) do address |> Address.changeset(attrs) |> Repo.update() end @doc """ Deletes an address. """ @spec delete_address(Address.t()) :: {:ok, Address.t()} | {:error, Ecto.Changeset.t()} def delete_address(%Address{} = address), do: Repo.delete(address) @doc """ Returns the list of addresses. """ @spec list_addresses :: [Address.t()] def list_addresses, do: Repo.all(Address) @doc """ Searches addresses. We only look at the description for now, and eventually order by object distance. """ @spec search_addresses(String.t(), keyword) :: [Address.t()] def search_addresses(search, options \\ []) do query = search |> search_addresses_query(Keyword.get(options, :limit, 5)) |> order_by_coords(Keyword.get(options, :coords)) |> filter_by_contry(Keyword.get(options, :country)) case Keyword.get(options, :single, false) do true -> Repo.one(query) false -> Repo.all(query) end end @doc """ Reverse geocode from coordinates. We only take addresses 50km around and sort them by distance. """ @spec reverse_geocode(number, number, keyword) :: [Address.t()] def reverse_geocode(lon, lat, options) do limit = Keyword.get(options, :limit, 5) radius = Keyword.get(options, :radius, 50_000) country = Keyword.get(options, :country) srid = Keyword.get(options, :srid, 4326) with {:ok, point} <- Geo.WKT.decode("SRID=#{srid};POINT(#{lon} #{lat})") do point |> addresses_around_query(radius, limit) |> filter_by_contry(country) |> Repo.all() end end @spec search_addresses_query(String.t(), integer) :: Ecto.Query.t() defp search_addresses_query(search, limit) do from( a in Address, where: ilike(a.description, ^"%#{search}%"), limit: ^limit ) end @spec order_by_coords(Ecto.Query.t(), map | nil) :: Ecto.Query.t() defp order_by_coords(query, nil), do: query defp order_by_coords(query, coords) do from( a in query, order_by: [fragment("? <-> ?", a.geom, ^"POINT(#{coords.lon} #{coords.lat})'")] ) end @spec filter_by_contry(Ecto.Query.t(), String.t() | nil) :: Ecto.Query.t() defp filter_by_contry(query, nil), do: query defp filter_by_contry(query, country) do from( a in query, where: ilike(a.country, ^"%#{country}%") ) end @spec addresses_around_query(Geo.geometry(), integer, integer) :: Ecto.Query.t() defp addresses_around_query(point, radius, limit) do import Geo.PostGIS from(a in Address, where: st_dwithin_in_meters(^point, a.geom, ^radius), order_by: [fragment("? <-> ?", a.geom, ^point)], limit: ^limit ) end end