WIP: Feature/graphql

.travis.yml

@@ -27,11 +27,13 @@ env:
   - DB=postgresql EXTENSION=pages
   - DB=postgresql EXTENSION=images
   - DB=postgresql EXTENSION=resources
+  - DB=postgresql EXTENSION=api
   - DB=mysql EXTENSION=core
   - DB=mysql EXTENSION=dragonfly
   - DB=mysql EXTENSION=pages
   - DB=mysql EXTENSION=images
   - DB=mysql EXTENSION=resources
+  - DB=mysql EXTENSION=api
 notifications:
   email: true
   webhooks:

Gemfile

@@ -7,6 +7,7 @@ path "./" do
   gem "refinerycms-images"
   gem "refinerycms-pages"
   gem "refinerycms-resources"
+  gem "refinerycms-api"
 end
 
 gem 'bootsnap', require: false

api/app/controllers/refinery/api/graphql_controller.rb

@@ -0,0 +1,55 @@
+module Refinery
+  module Api
+    class GraphqlController < ::ApplicationController
+      include Refinery::Admin::BaseController
+
+      def execute
+        variables = ensure_hash(params[:variables])
+        query = params[:query]
+        operation_name = params[:operationName]
+
+        result = Refinery::Api::GraphqlSchema.execute(
+          query, variables: variables, context: context, operation_name: operation_name
+        )
+
+        render json: result
+      rescue => e
+        raise e unless Rails.env.development?
+        handle_error_in_development e
+      end
+
+      private
+
+      def context
+        {
+          current_user: current_refinery_user
+        }
+      end
+
+      # Handle form data, JSON body, or a blank value
+      def ensure_hash(ambiguous_param)
+        case ambiguous_param
+        when String
+          if ambiguous_param.present?
+            ensure_hash(JSON.parse(ambiguous_param))
+          else
+            {}
+          end
+        when Hash, ActionController::Parameters
+          ambiguous_param
+        when nil
+          {}
+        else
+          raise ArgumentError, "Unexpected parameter: #{ambiguous_param}"
+        end
+      end
+
+      def handle_error_in_development(e)
+        logger.error e.message
+        logger.error e.backtrace.join("\n")
+
+        render json: { error: { message: e.message, backtrace: e.backtrace }, data: {} }, status: 500
+      end
+    end
+  end
+end

api/app/graph/refinery/api/graphql_schema.rb

@@ -0,0 +1,11 @@
+# frozen_string_literal: true
+
+module Refinery
+  module Api
+    class GraphqlSchema < GraphQL::Schema
+      mutation Types::MutationType
+      query Types::QueryType
+      use GraphQL::Guard.new
+    end
+  end
+end

api/app/graph/refinery/api/mutations/base_mutation.rb

@@ -0,0 +1,8 @@
+module Refinery
+  module Api
+    module Mutations
+      class Mutations::BaseMutation < GraphQL::Schema::RelayClassicMutation
+      end
+    end
+  end
+end

api/app/graph/refinery/api/mutations/pages/create.rb

@@ -0,0 +1,37 @@
+# frozen_string_literal: true
+
+module Refinery
+  module Api
+    module Mutations
+      module Pages
+        class Create < Mutations::BaseMutation
+          graphql_name 'CreatePage'
+          description 'Create a Page'
+
+          guard ->(_obj, _args, ctx) { ctx[:current_user].has_role?(:refinery) }
+
+          argument :page, Types::Pages::PageAttributes, required: true
+
+          field :page, Types::Pages::PageType, null: true
+          field :errors, [String], null: false
+
+          def resolve(page:)
+            page = Refinery::Page.create!(page.to_h)
+
+            if page.errors.empty?
+              {
+                page: page,
+                errors: []
+              }
+            else
+              {
+                page: nil,
+                errors: page.errors.full_messages
+              }
+            end
+          end
+        end
+      end
+    end
+  end
+end

api/app/graph/refinery/api/mutations/pages/delete.rb

@@ -0,0 +1,37 @@
+# frozen_string_literal: true
+
+module Refinery
+  module Api
+    module Mutations
+      module Pages
+        class Delete < Mutations::BaseMutation
+          graphql_name 'DeletePage'
+          description 'Delete a Page'
+
+          guard ->(_obj, _args, ctx) { ctx[:current_user].has_role?(:refinery) }
+
+          argument :id, ID, required: true
+
+          field :page, Types::Pages::PageType, null: true
+          field :errors, [String], null: false
+
+          def resolve(id:)
+            page = Refinery::Page.destroy(id)
+
+            if page.errors.empty?
+              {
+                page: page,
+                errors: []
+              }
+            else
+              {
+                page: nil,
+                errors: page.errors.full_messages
+              }
+            end
+          end
+        end
+      end
+    end
+  end
+end

api/app/graph/refinery/api/mutations/pages/update.rb

@@ -0,0 +1,38 @@
+# frozen_string_literal: true
+
+module Refinery
+  module Api
+    module Mutations
+      module Pages
+        class Update < Mutations::BaseMutation
+          graphql_name 'UpdatePage'
+          description 'Update a Page'
+
+          guard ->(_obj, _args, ctx) { ctx[:current_user].has_role?(:refinery) }
+
+          argument :id, ID, required: true
+          argument :page, Types::Pages::PageAttributes, required: true
+
+          field :page, Types::Pages::PageType, null: false
+          field :errors, [String], null: false
+
+          def resolve(id:, page:)
+            page = Refinery::Page.update(id, page.to_h)
+
+            if page.errors.empty?
+              {
+                page: page,
+                errors: []
+              }
+            else
+              {
+                page: nil,
+                errors: page.errors.full_messages
+              }
+            end
+          end
+        end
+      end
+    end
+  end
+end

api/app/graph/refinery/api/queries/pages/page_query.rb

@@ -0,0 +1,30 @@
+# frozen_string_literal: true
+
+module Refinery
+  module Api
+    module Queries
+      module Pages
+        class PageQuery < GraphQL::Field.define do
+          name 'Page'
+          description 'Find a page by ID'
+
+          type Types::Pages::PageType
+          argument :id, !types.ID
+
+          resolve -> (obj, args, ctx) {
+            Refinery::Page.find_by_id(args[:id])
+          }
+        end
+      end
+    end
+  end
+end
+
+# frozen_string_literal: true
+
+field :page, Types::Pages::PageType,
+              null: true, resolve: Resolvers::Pages::PageResolver::ById do
+          description "Find page by id"
+          guard ->(_obj, _args, ctx) { ctx[:current_user].has_plugin?('refinery_pages') }
+          argument :id, ID, required: true
+        end

api/app/graph/refinery/api/resolvers/pages/page_resolver.rb

@@ -0,0 +1,31 @@
+# frozen_string_literal: true
+
+module Refinery
+  module Api
+    module Resolvers
+      module Pages
+        class PageResolver
+          class All
+            def self.call(_obj, args, ctx)
+              if ctx[:current_user].has_role?(:refinery)
+                Refinery::Page.all
+              else
+                Refinery::Page.live
+              end
+            end
+          end
+
+          class ById
+            def self.call(_obj, args, ctx)
+              if ctx[:current_user].has_role?(:refinery)
+                Refinery::Page.find_by_id(args[:id])
+              else
+                Refinery::Page.live.find_by_id(args[:id])
+              end
+            end
+          end
+        end
+      end
+    end
+  end
+end

api/app/graph/refinery/api/types/base_enum.rb

@@ -0,0 +1,10 @@
+# frozen_string_literal: true
+
+module Refinery
+  module Api
+    module Types
+      class BaseEnum < GraphQL::Schema::Enum
+      end
+    end
+  end
+end

api/app/graph/refinery/api/types/base_input_object.rb

@@ -0,0 +1,10 @@
+# frozen_string_literal: true
+
+module Refinery
+  module Api
+    module Types
+      class BaseInputObject < GraphQL::Schema::InputObject
+      end
+    end
+  end
+end

api/app/graph/refinery/api/types/base_interface.rb

@@ -0,0 +1,11 @@
+# frozen_string_literal: true
+
+module Refinery
+  module Api
+    module Types
+      class BaseInterface
+        include GraphQL::Schema::Interface
+      end
+    end
+  end
+end

api/app/graph/refinery/api/types/base_object.rb

@@ -0,0 +1,10 @@
+# frozen_string_literal: true
+
+module Refinery
+  module Api
+    module Types
+      class BaseObject < GraphQL::Schema::Object
+      end
+    end
+  end
+end

api/app/graph/refinery/api/types/base_union.rb

@@ -0,0 +1,10 @@
+# frozen_string_literal: true
+
+module Refinery
+  module Api
+    module Types
+      class BaseUnion < GraphQL::Schema::Union
+      end
+    end
+  end
+end

api/app/graph/refinery/api/types/mutation_type.rb

@@ -0,0 +1,16 @@
+# frozen_string_literal: true
+
+module Refinery
+  module Api
+    module Types
+      class MutationType < Types::BaseObject
+        graphql_name 'Mutation'
+        description 'The mutation root for this schema'
+
+        field :createPage, mutation: Mutations::Pages::Create
+        field :updatePage, mutation: Mutations::Pages::Update
+        field :deletePage, mutation: Mutations::Pages::Delete
+      end
+    end
+  end
+end