First commit

Author: rylanc

Diff for: .eslintrc.js

@@ -0,0 +1,6 @@
+module.exports = {
+  extends: 'eslint-config-gusto',
+  rules: {
+    'no-console': 'off',
+  },
+};

Diff for: .gitignore

@@ -0,0 +1,6 @@
+# yarn
+yarn-debug.log*
+yarn-error.log*
+
+# Dependency directories
+node_modules/

Diff for: .prettierrc.js

@@ -0,0 +1 @@
+module.exports = require('eslint-config-gusto/.prettierrc');

Diff for: Gemfile

@@ -0,0 +1,3 @@
+source "https://rubygems.org"
+
+gemspec

Diff for: Gemfile.lock

@@ -0,0 +1,46 @@
+PATH
+  remote: .
+  specs:
+    apollo-federation (0.1.0)
+      graphql
+
+GEM
+  remote: https://rubygems.org/
+  specs:
+    byebug (11.0.1)
+    coderay (1.1.2)
+    diff-lcs (1.3)
+    graphql (1.9.6)
+    method_source (0.9.2)
+    pry (0.12.2)
+      coderay (~> 1.1.0)
+      method_source (~> 0.9.0)
+    pry-byebug (3.7.0)
+      byebug (~> 11.0)
+      pry (~> 0.10)
+    rack (2.0.7)
+    rspec (3.8.0)
+      rspec-core (~> 3.8.0)
+      rspec-expectations (~> 3.8.0)
+      rspec-mocks (~> 3.8.0)
+    rspec-core (3.8.0)
+      rspec-support (~> 3.8.0)
+    rspec-expectations (3.8.3)
+      diff-lcs (>= 1.2.0, < 2.0)
+      rspec-support (~> 3.8.0)
+    rspec-mocks (3.8.0)
+      diff-lcs (>= 1.2.0, < 2.0)
+      rspec-support (~> 3.8.0)
+    rspec-support (3.8.0)
+
+PLATFORMS
+  ruby
+
+DEPENDENCIES
+  apollo-federation!
+  pry-byebug
+  rack
+  rspec
+
+BUNDLED WITH
+   2.0.1

Diff for: README.md

@@ -0,0 +1,23 @@
+# apollo-federation
+
+This gem extends the graphql gem to add support for creating a federated schema
+
+## Installation
+
+Add this line to your application's Gemfile:
+
+```ruby
+gem 'apollo-federation'
+```
+
+And then execute:
+
+    $ bundle
+
+Or install it yourself as:
+
+    $ gem install apollo-federation
+
+## Usage
+
+TODO: Write usage instructions here

Diff for: apollo-federation.gemspec

@@ -0,0 +1,28 @@
+
+lib = File.expand_path("../lib", __FILE__)
+$LOAD_PATH.unshift(lib) unless $LOAD_PATH.include?(lib)
+require "apollo-federation/version"
+
+Gem::Specification.new do |spec|
+  spec.name          = "apollo-federation"
+  spec.version       = ApolloFederation::VERSION
+  spec.authors       = ["Gusto"]
+
+  spec.summary       = 'This gem extends the graphql gem to add support for creating a federated schema'
+  spec.description   = spec.summary
+  spec.homepage      = 'https://www.gusto.com'
+
+  # Prevent pushing this gem to RubyGems.org. To allow pushes either set the 'allowed_push_host'
+  # to allow pushing to a single host or delete this section to allow pushing to any host.
+  if spec.respond_to?(:metadata)
+    spec.metadata['allowed_push_host'] = 'https://gemstash.zp-int.com/private'
+  else
+    raise 'RubyGems 2.0 or newer is required to protect against public gem pushes.'
+  end
+
+  spec.add_dependency 'graphql'
+
+  spec.add_development_dependency 'pry-byebug'
+  spec.add_development_dependency 'rack'
+  spec.add_development_dependency 'rspec'
+end

Diff for: babel.config.js

@@ -0,0 +1,12 @@
+module.exports = {
+  presets: [
+    [
+      '@babel/preset-env',
+      {
+        targets: {
+          node: 'current',
+        },
+      },
+    ],
+  ],
+};

Diff for: example/accounts.rb

@@ -0,0 +1,54 @@
+require_relative './graphql_server'
+
+# extend type Query {
+#   me: User
+# }
+
+# type User @key(fields: "id") {
+#   id: ID!
+#   name: String
+#   username: String
+# }
+
+USERS = [
+  {
+    id: "1",
+    name: "Ada Lovelace",
+    birthDate: "1815-12-10",
+    username: "@ada"
+  },
+  {
+    id: "2",
+    name: "Alan Turing",
+    birthDate: "1912-06-23",
+    username: "@complete"
+  }
+];
+
+class User < BaseObject
+  key fields: 'id'
+
+  field :id, ID, null: false
+  field :name, String, null: true
+  field :username, String, null: true
+
+  def self.resolve_reference(object, _context)
+    USERS.find { |user| user[:id] == object[:id] }
+  end
+end
+
+class Query < BaseObject
+  field :me, User, null: true
+
+  def me
+    USERS[0]
+  end
+end
+
+class AccountSchema < GraphQL::Schema
+  extend ApolloFederation::Schema
+
+  query(Query)
+end
+
+GraphQLServer.run(AccountSchema, Port: 5001)

Diff for: example/gateway.js

@@ -0,0 +1,22 @@
+const { ApolloServer } = require('apollo-server');
+const { ApolloGateway } = require('@apollo/gateway');
+
+const gateway = new ApolloGateway({
+  serviceList: [
+    { name: 'accounts', url: 'http://localhost:5001/graphql' },
+    { name: 'reviews', url: 'http://localhost:5002/graphql' },
+    { name: 'products', url: 'http://localhost:5003/graphql' },
+    { name: 'inventory', url: 'http://localhost:5004/graphql' },
+  ],
+  debug: true,
+});
+
+(async () => {
+  const { schema, executor } = await gateway.load();
+
+  const server = new ApolloServer({ schema, executor });
+
+  server.listen({ port: 5000 }).then(({ url }) => {
+    console.log(`🚀 Server ready at ${url}`);
+  });
+})();

Diff for: example/graphql_server.rb

@@ -0,0 +1,63 @@
+require 'rack'
+require 'json'
+require 'graphql'
+require 'pry-byebug'
+require 'apollo-federation'
+
+class BaseField < GraphQL::Schema::Field
+  include ApolloFederation::Field
+end
+
+class BaseObject < GraphQL::Schema::Object
+  extend ApolloFederation::Object
+
+  field_class BaseField
+end
+
+class GraphQLServer
+  def self.run(schema, options = {})
+    # TODO: Should this code be shared with the integration tests? If so, we should probably add
+    # a command line arg to run in test mode
+    Rack::Handler::WEBrick.run(
+      GraphQLServer.new(schema),
+      options.merge!(
+        Logger: ::WEBrick::Log.new($stderr, ::WEBrick::Log::ERROR),
+        AccessLog: [],
+      ),
+    ) do
+      $stdout.puts '_READY_'
+      $stdout.flush
+    end
+  end
+
+  def initialize(schema)
+    self.schema = schema
+  end
+
+  def call(env)
+    req = Rack::Request.new(env)
+    req_vars = JSON.parse(req.body.read)
+    query = req_vars['query']
+    operationName = req_vars["operationName"]
+    vars = req_vars["variables"] || {}
+
+    graphql_debugging = {
+      query: query,
+      operationName: operationName,
+      vars: vars,
+      schema: schema,
+    }
+    puts graphql_debugging.inspect
+
+    result = schema.execute(
+      query,
+      operation_name: operationName,
+      variables: vars
+    )
+    ['200', {'Content-Type' => 'application/json'}, [JSON.dump(result.to_h)]]
+  end
+
+  private
+
+  attr_accessor :schema
+end

Diff for: example/inventory.rb

@@ -0,0 +1,48 @@
+require_relative './graphql_server'
+
+# extend type Product @key(fields: "upc") {
+#   upc: String! @external
+#   weight: Int @external
+#   price: Int @external
+#   inStock: Boolean
+#   shippingEstimate: Int @requires(fields: "price weight")
+# }
+
+INVENTORY = [
+  { upc: "1", in_stock: true },
+  { upc: "2", in_stock: false },
+  { upc: "3", in_stock: true }
+]
+
+class Product < BaseObject
+  extend_type
+  key fields: 'upc'
+
+  field :upc, String, null: false, external: true
+  field :weight, Int, null: true, external: true
+  field :price, Int, null: true, external: true
+  field :in_stock, Boolean, null: true
+  field :shipping_estimate, Int, null: true, requires: { fields: "price weight"}
+
+  def self.resolve_reference(reference, context)
+    reference.merge(INVENTORY.find { |product| product[:upc] == reference[:upc] })
+  end
+
+  def shipping_estimate
+    # free for expensive items
+    if object[:price] > 1000
+      0
+    else
+    # estimate is based on weight
+      object[:weight] * 0.5
+    end
+  end
+end
+
+class InventorySchema < GraphQL::Schema
+  extend ApolloFederation::Schema
+
+  orphan_types Product
+end
+
+GraphQLServer.run(InventorySchema, Port: 5004)

Diff for: example/products.rb

@@ -0,0 +1,64 @@
+require_relative './graphql_server'
+
+# extend type Query {
+#   topProducts(first: Int = 5): [Product]
+# }
+
+# type Product @key(fields: "upc") {
+#   upc: String!
+#   name: String
+#   price: Int
+#   weight: Int
+# }
+
+PRODUCTS = [
+  {
+    upc: "1",
+    name: "Table",
+    price: 899,
+    weight: 100
+  },
+  {
+    upc: "2",
+    name: "Couch",
+    price: 1299,
+    weight: 1000
+  },
+  {
+    upc: "3",
+    name: "Chair",
+    price: 54,
+    weight: 50
+  }
+]
+
+class Product < BaseObject
+  key fields: 'upc'
+
+  field :upc, String, null: false
+  field :name, String, null: true
+  field :price, Int, null: true
+  field :weight, Int, null: true
+
+  def self.resolve_reference(reference, context)
+    PRODUCTS.find { |product| product[:upc] === reference[:upc] }
+  end
+end
+
+class Query < BaseObject
+  field :top_products, [Product], null: false do
+    argument :first, Int, required: false, default_value: 5
+  end
+
+  def top_products(first:)
+    PRODUCTS.slice(0, first)
+  end
+end
+
+class ProductSchema < GraphQL::Schema
+  extend ApolloFederation::Schema
+
+  query(Query)
+end
+
+GraphQLServer.run(ProductSchema, Port: 5003)