Class: GraphQL::Relay::BaseConnection

Inherits:
Object
  • Object
show all
Defined in:
lib/graphql/relay/base_connection.rb

Overview

Subclasses must implement:

  • #cursor_from_node, which returns an opaque cursor for the given item
  • #sliced_nodes, which slices by before & after
  • #paged_nodes, which applies first & last limits

In a subclass, you have access to

Direct Known Subclasses

ArrayConnection, RelationConnection

Constant Summary collapse

CURSOR_SEPARATOR =

Just to encode data in the cursor, use something that won't conflict

"---"
CONNECTION_IMPLEMENTATIONS =

Map of collection class names -> connection_classes eg {"Array" => ArrayConnection}

{}

Instance Attribute Summary collapse

Class Method Summary collapse

Instance Method Summary collapse

Constructor Details

#initialize(nodes, arguments, field: nil, max_page_size: nil, parent: nil, context: nil) ⇒ BaseConnection

Make a connection, wrapping nodes

Parameters:

  • nodes (Object) —

    The collection of nodes

  • arguments (GraphQL::Query::Arguments) —

    Query arguments

  • field (GraphQL::Field) (defaults to: nil) —

    The underlying field

  • max_page_size (Int) (defaults to: nil) —

    The maximum number of results to return

  • parent (Object) (defaults to: nil) —

    The object which this collection belongs to

  • context (GraphQL::Query::Context) (defaults to: nil) —

    The context from the field being resolved



61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
 
# File 'lib/graphql/relay/base_connection.rb', line 61

def initialize(nodes, arguments, field: nil, max_page_size: nil, parent: nil, context: nil)
  GraphQL::Deprecation.warn "GraphQL::Relay::BaseConnection (used for #{self.class}) will be removed from GraphQL-Ruby 2.0, use GraphQL::Pagination::Connections instead: https://graphql-ruby.org/pagination/overview.html"

  deprecated_caller = caller(0, 10).find { |c| !c.include?("lib/graphql") }
  if deprecated_caller
    GraphQL::Deprecation.warn "  -> called from #{deprecated_caller}"
  end

  @context = context
  @nodes = nodes
  @arguments = arguments
  @field = field
  @parent = parent
  @encoder = context ? @context.schema.cursor_encoder : GraphQL::Schema::Base64Encoder
  @max_page_size = max_page_size.nil? && context ? @context.schema.default_max_page_size : max_page_size
end

Instance Attribute Details

#arguments ⇒ Object (readonly)

Returns the value of attribute arguments.



52
53
54
 
# File 'lib/graphql/relay/base_connection.rb', line 52

def arguments
  @arguments
end

#context ⇒ Object (readonly)

Returns the value of attribute context.



52
53
54
 
# File 'lib/graphql/relay/base_connection.rb', line 52

def context
  @context
end

#field ⇒ Object (readonly)

Returns the value of attribute field.



52
53
54
 
# File 'lib/graphql/relay/base_connection.rb', line 52

def field
  @field
end

#max_page_size ⇒ Object (readonly)

Returns the value of attribute max_page_size.



52
53
54
 
# File 'lib/graphql/relay/base_connection.rb', line 52

def max_page_size
  @max_page_size
end

#nodes ⇒ Object (readonly)

Returns the value of attribute nodes.



52
53
54
 
# File 'lib/graphql/relay/base_connection.rb', line 52

def nodes
  @nodes
end

#parent ⇒ Object (readonly)

Returns the value of attribute parent.



52
53
54
 
# File 'lib/graphql/relay/base_connection.rb', line 52

def parent
  @parent
end

Class Method Details

.connection_for_nodes(nodes) ⇒ subclass of BaseConnection

Find a connection implementation suitable for exposing nodes

Parameters:

  • nodes (Object) —

    A collection of nodes (eg, Array, AR::Relation)

Returns:

  • (subclass of BaseConnection) —

    a connection Class for wrapping nodes



27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
 
# File 'lib/graphql/relay/base_connection.rb', line 27

def connection_for_nodes(nodes)
  # If it's a new-style connection object, it's already ready to go
  if nodes.is_a?(GraphQL::Pagination::Connection)
    return nodes
  end
  # Check for class _names_ because classes can be redefined in Rails development
  nodes.class.ancestors.each do |ancestor|
    conn_impl = CONNECTION_IMPLEMENTATIONS[ancestor.name]
    if conn_impl
      return conn_impl
    end
  end
  # Should have found a connection during the loop:
  raise("No connection implementation to wrap #{nodes.class} (#{nodes})")
end

.register_connection_implementation(nodes_class, connection_class) ⇒ Object

Add connection_class as the connection wrapper for nodes_class eg, RelationConnection is the implementation for AR::Relation

Parameters:

  • nodes_class (Class) —

    A class representing a collection (eg, Array, AR::Relation)

  • connection_class (Class) —

    A class implementing Connection methods



47
48
49
 
# File 'lib/graphql/relay/base_connection.rb', line 47

def register_connection_implementation(nodes_class, connection_class)
  CONNECTION_IMPLEMENTATIONS[nodes_class.name] = connection_class
end

Instance Method Details

#after ⇒ String?

The value passed as after:, if there was one

Returns:

  • (String, nil) 


100
101
102
 
# File 'lib/graphql/relay/base_connection.rb', line 100

def after
  arguments[:after]
end

#before ⇒ String?

The value passed as before:, if there was one

Returns:

  • (String, nil) 


112
113
114
 
# File 'lib/graphql/relay/base_connection.rb', line 112

def before
  arguments[:before]
end

#cursor_from_node(object) ⇒ Object

An opaque operation which returns a connection-specific cursor.

Raises:



156
157
158
 
# File 'lib/graphql/relay/base_connection.rb', line 156

def cursor_from_node(object)
  raise GraphQL::RequiredImplementationMissingError, "must return a cursor for this object/connection pair"
end

#decode(data) ⇒ Object 



82
83
84
 
# File 'lib/graphql/relay/base_connection.rb', line 82

def decode(data)
  @encoder.decode(data, nonce: true)
end

#edge_nodes ⇒ Object

These are the nodes to render for this connection, probably wrapped by Edge



118
119
120
 
# File 'lib/graphql/relay/base_connection.rb', line 118

def edge_nodes
  @edge_nodes ||= paged_nodes
end

#encode(data) ⇒ Object 



78
79
80
 
# File 'lib/graphql/relay/base_connection.rb', line 78

def encode(data)
  @encoder.encode(data, nonce: true)
end

#end_cursor ⇒ Object

Used by pageInfo



147
148
149
150
151
152
153
 
# File 'lib/graphql/relay/base_connection.rb', line 147

def end_cursor
  if end_node = (respond_to?(:paged_nodes_array, true) ? paged_nodes_array : paged_nodes).last
    return cursor_from_node(end_node)
  else
    return nil
  end
end

#first ⇒ Integer?

The value passed as first:, if there was one. Negative numbers become 0.

Returns:

  • (Integer, nil) 


88
89
90
91
92
93
94
95
96
 
# File 'lib/graphql/relay/base_connection.rb', line 88

def first
  @first ||= begin
    capped = limit_pagination_argument(arguments[:first], max_page_size)
    if capped.nil? && last.nil?
      capped = max_page_size
    end
    capped
  end
end

#has_next_page ⇒ Object

Used by pageInfo



128
129
130
 
# File 'lib/graphql/relay/base_connection.rb', line 128

def has_next_page
  !!(first && sliced_nodes.count > first)
end

#has_previous_page ⇒ Object

Used by pageInfo



133
134
135
 
# File 'lib/graphql/relay/base_connection.rb', line 133

def has_previous_page
  !!(last && sliced_nodes.count > last)
end

#inspect ⇒ Object 



160
161
162
 
# File 'lib/graphql/relay/base_connection.rb', line 160

def inspect
  "#<GraphQL::Relay::Connection @parent=#{@parent.inspect} @arguments=#{@arguments.to_h.inspect}>"
end

#last ⇒ Integer?

The value passed as last:, if there was one. Negative numbers become 0.

Returns:

  • (Integer, nil) 


106
107
108
 
# File 'lib/graphql/relay/base_connection.rb', line 106

def last
  @last ||= limit_pagination_argument(arguments[:last], max_page_size)
end

#page_info ⇒ Object

Support the pageInfo field



123
124
125
 
# File 'lib/graphql/relay/base_connection.rb', line 123

def page_info
  self
end

#start_cursor ⇒ Object

Used by pageInfo



138
139
140
141
142
143
144
 
# File 'lib/graphql/relay/base_connection.rb', line 138

def start_cursor
  if start_node = (respond_to?(:paged_nodes_array, true) ? paged_nodes_array : paged_nodes).first
    return cursor_from_node(start_node)
  else
    return nil
  end
end