Packages
absinthe
1.4.0
1.11.0
1.10.2
1.10.1
1.10.0
1.9.1
1.9.0
1.8.0
1.7.11
1.7.10
1.7.9
1.7.8
1.7.7
1.7.6
1.7.5
1.7.4
1.7.3
1.7.2
1.7.1
1.7.0
1.6.8
1.6.7
retired
1.6.6
1.6.5
1.6.4
1.6.3
1.6.2
1.6.1
1.6.0
1.6.0-rc.1
1.6.0-rc.0
1.5.5
1.5.4
1.5.3
1.5.2
1.5.1
1.5.0
1.5.0-rc.5
1.5.0-rc.4
1.5.0-rc.3
1.5.0-rc.2
1.5.0-rc.1
1.5.0-rc.0
1.5.0-beta.2
1.5.0-beta.1
1.5.0-beta.0
1.5.0-alpha.4
1.5.0-alpha.3
1.5.0-alpha.2
1.5.0-alpha.1
1.5.0-alpha.0
1.4.16
1.4.15
1.4.14
1.4.13
1.4.12
1.4.11
1.4.10
1.4.9
1.4.8
retired
1.4.7
1.4.6
1.4.5
1.4.4
1.4.3
1.4.2
1.4.1
1.4.0
1.4.0-rc.3
1.4.0-rc.2
1.4.0-rc.1
1.4.0-rc.0
1.4.0-beta.5
1.4.0-beta.4
1.4.0-beta.3
1.4.0-beta.2
1.4.0-beta.1
1.3.2
1.3.1
1.3.0
1.3.0-rc.0
1.3.0-beta.2
1.3.0-beta.1
1.3.0-beta.0
1.2.6
1.2.5
1.2.4
1.2.3
1.2.2
1.2.1
1.2.0
1.2.0-rc.0
1.2.0-beta.0
1.2.0-alpha0
1.2.0-alpha.2
1.2.0-alpha.1
1.1.11
1.1.10
1.1.9
1.1.8
1.1.7
1.1.6
1.1.5
1.1.4
1.1.3
1.1.2
1.1.1
1.1.0
1.0.0
0.5.2
0.5.1
0.5.0
0.4.6
0.4.5
0.4.4
0.4.3
0.4.2
0.4.1
0.4.0
0.2.3
0.2.2
0.2.1
0.1.0
GraphQL for Elixir
Security advisory:
This version has known vulnerabilities.
View advisories
Current section
Files
Jump to
Current section
Files
lib/absinthe/phase/document/validation/no_fragment_cycles.ex
defmodule Absinthe.Phase.Document.Validation.NoFragmentCycles do
@moduledoc false
# Ensure that document doesn't have any fragment cycles that could
# result in a loop during execution.
#
# Note that if this phase fails, an error should immediately be given to
# the user.
alias Absinthe.{Blueprint, Phase}
use Absinthe.Phase
@doc """
Run the validation.
"""
@spec run(Blueprint.t, Keyword.t) :: Phase.result_t
def run(input, options \\ []) do
do_run(input, Map.new(options))
end
@spec do_run(Blueprint.t, %{validation_result_phase: Phase.t}) :: Phase.result_t
def do_run(input, %{validation_result_phase: abort_phase}) do
{fragments, error_count} = check(input.fragments)
result = %{input | fragments: fragments}
if error_count > 0 do
{:jump, result, abort_phase}
else
{:ok, result}
end
end
# Check a list of fragments for cycles
@spec check([Blueprint.Document.Fragment.Named.t]) :: {[Blueprint.Document.Fragment.Named.t], integer}
defp check(fragments) do
graph = :digraph.new([:cyclic])
try do
with {fragments, 0} <- check(fragments, graph) do
fragments = Map.new(fragments, &{&1.name, &1})
fragments =
graph
|> :digraph_utils.topsort
|> Enum.reverse
|> Enum.map(&Map.fetch!(fragments, &1))
# fragments |> Enum.map(&(&1.name)) |> IO.inspect
{fragments, 0}
end
after
:digraph.delete(graph)
end
end
@spec check([Blueprint.Document.Fragment.Named.t], :digraph.graph) :: {[Blueprint.Document.Fragment.Named.t], integer}
defp check(fragments, graph) do
Enum.each(fragments, fn(node) -> Blueprint.prewalk(node, &vertex(&1, graph)) end)
{modified, error_count} = Enum.reduce(fragments, {[], 0}, fn
fragment, {processed, error_count} ->
errors_to_add = cycle_errors(fragment, :digraph.get_cycle(graph, fragment.name))
fragment_with_errors = update_in(fragment.errors, &(errors_to_add ++ &1))
{[fragment_with_errors | processed], error_count + length(errors_to_add)}
end)
{modified, error_count}
end
# Add a vertex modeling a fragment
@spec vertex(Blueprint.Document.Fragment.Named.t, :digraph.graph) :: Blueprint.Document.Fragment.Named.t
defp vertex(%Blueprint.Document.Fragment.Named{} = fragment, graph) do
:digraph.add_vertex(graph, fragment.name)
Blueprint.prewalk(fragment, fn
%Blueprint.Document.Fragment.Spread{} = spread ->
edge(fragment, spread, graph)
spread
node ->
node
end)
fragment
end
defp vertex(fragment, _graph) do
fragment
end
# Add an edge, modeling the relationship between two fragments
@spec edge(Blueprint.Document.Fragment.Named.t, Blueprint.Document.Fragment.Spread.t, :digraph.graph) :: true
defp edge(fragment, spread, graph) do
:digraph.add_vertex(graph, spread.name)
:digraph.add_edge(graph, fragment.name, spread.name)
true
end
# Generate an error for a cyclic reference
@spec cycle_errors(Blueprint.Document.Fragment.Named.t, false | [String.t]) :: [Phase.Error.t]
defp cycle_errors(_, false) do
[]
end
defp cycle_errors(fragment, cycles) do
[cycle_error(fragment, error_message(fragment.name, cycles))]
end
@doc """
Generate the error message.
"""
@spec error_message(String.t, [String.t]) :: String.t
def error_message(fragment_name, [fragment_name]) do
~s(Cannot spread fragment "#{fragment_name}" within itself.)
end
def error_message(fragment_name, [_fragment_name | cycles]) do
deps = Enum.map(cycles, &~s("#{&1}")) |> Enum.join(", ")
~s(Cannot spread fragment "#{fragment_name}" within itself via #{deps}.)
end
# Generate the error for a fragment cycle
@spec cycle_error(Blueprint.Document.Fragment.Named.t, String.t) :: Phase.Error.t
defp cycle_error(fragment, message) do
%Phase.Error{
message: message,
phase: __MODULE__,
locations: [
%{line: fragment.source_location.line, column: fragment.source_location.column}
],
}
end
end