defmodule Ueberauth.Strategy.Intercom do
@moduledoc """
Intercom Strategy for Überauth.
"""
use Ueberauth.Strategy, oauth2_module: Ueberauth.Strategy.Intercom.OAuth
alias Ueberauth.Auth.Info
alias Ueberauth.Auth.Credentials
alias Ueberauth.Auth.Extra
def handle_request!(conn) do
opts =
if conn.params["state"], do: [state: conn.params["state"]], else: []
module = option(conn, :oauth2_module)
redirect!(conn, apply(module, :authorize_url!, [opts]))
end
def handle_callback!(%Plug.Conn{params: %{"code" => code}} = conn) do
module = option(conn, :oauth2_module)
token = apply(module, :get_token!, [[code: code]])
if token.access_token == nil do
set_errors!(conn, [
error(token.other_params["error"], token.other_params["error_description"])
])
else
conn
|> store_token(token)
|> fetch_user(token)
end
end
def handle_callback!(conn) do
set_errors!(conn, [error("missing_code", "No code received")])
end
defp store_token(conn, token) do
put_private(conn, :intercom_token, token)
end
def handle_cleanup!(conn) do
conn
|> put_private(:intercom_user, nil)
|> put_private(:intercom_token, nil)
end
defp fetch_user(conn, token) do
resp = Ueberauth.Strategy.Intercom.OAuth.get(token, "/me")
case resp do
{:ok, %OAuth2.Response{status_code: 401, body: _body}} ->
set_errors!(conn, [error("token", "unauthorized")])
{:ok, %OAuth2.Response{status_code: status_code, body: user}}
when status_code in 200..399 ->
put_private(conn, :intercom_user, user)
{:error, %OAuth2.Error{reason: reason}} ->
set_errors!(conn, [error("OAuth2", reason)])
end
end
def credentials(conn) do
token = conn.private.intercom_token
user = conn.private.intercom_user
%Credentials{
token: token.access_token,
refresh_token: token.refresh_token,
expires_at: token.expires_at,
token_type: token.token_type,
expires: !!token.expires_at,
other: %{
user_id: user["id"],
type: user["type"]
}
}
end
def info(conn) do
user = conn.private.intercom_user
%Info{
email: user["email"],
image: user["avatar"]["image_url"],
name: user["name"]
}
end
def extra(conn) do
%Extra{
raw_info: %{
token: conn.private.intercom_token,
user: conn.private.intercom_user
}
}
end
defp option(conn, key) do
Keyword.get(options(conn), key, Keyword.get(default_options(), key))
end
end