take events from scheduler

Author: artemrakov

Gemfile

@@ -28,6 +28,7 @@ gem 'dry-validation'
 
 gem 'graphql'
 gem 'sidekiq'
+gem 'graphql-client'
 
 gem 'json-schema'
 gem 'pagy', '~> 3.6.0'

Gemfile.lock

@@ -130,6 +130,9 @@ GEM
       websocket-driver (>= 0.6, < 0.8)
     ffi (1.11.1)
     graphql (1.9.15)
+    graphql-client (0.16.0)
+      activesupport (>= 3.0)
+      graphql (~> 1.8)
     haml (5.0.4)
       temple (>= 0.8.0)
       tilt
@@ -374,6 +377,7 @@ DEPENDENCIES
   dry-system-hanami!
   dry-validation
   graphql
+  graphql-client
   haml
   hanami (~> 1.3)
   hanami-fabrication

apps/web/config/routes.rb

@@ -12,3 +12,4 @@
   end
 end
 resources :outputs, only: [:index, :new, :create]
+resources :events, only: [:index]

apps/web/controllers/events/index.rb

@@ -0,0 +1,18 @@
+module Web
+  module Controllers
+    module Events
+      class Index
+        include Web::Action
+        include Import[
+          operation: 'operations.event.index'
+        ]
+
+        def call(_)
+          @events = operation.call
+          p @events
+        end
+
+      end
+    end
+  end
+end

apps/web/templates/events/index.html.haml

@@ -0,0 +1,2 @@
+.container
+  = @events

apps/web/views/events/index.rb

@@ -0,0 +1,9 @@
+module Web
+  module Views
+    module Events
+      class Index
+        include Web::View
+      end
+    end
+  end
+end

lib/omniscrapper_hq/operations/event/index.rb

@@ -0,0 +1,23 @@
+module Operations
+  module Event
+    class Index < Base
+      GRAPHQL_CLIENT = System::Container['omniscrapper.graphql_client']
+
+      Query = GRAPHQL_CLIENT.parse <<-'GRAPHQL'
+        query {
+          events {
+            id,
+            name,
+            frequencyPeriod,
+            frequencyQuantity
+          }
+        }
+      GRAPHQL
+
+
+      def call
+        GRAPHQL_CLIENT.query(Query)
+      end
+    end
+  end
+end

spec/web/controllers/events/index_spec.rb

@@ -0,0 +1,9 @@
+RSpec.describe Web::Controllers::Events::Index, type: :action do
+  let(:action) { described_class.new }
+  let(:params) { Hash[] }
+
+  it 'is successful' do
+    response = action.call(params)
+    expect(response[0]).to eq 200
+  end
+end

spec/web/views/events/index_spec.rb

@@ -0,0 +1,10 @@
+RSpec.describe Web::Views::Events::Index, type: :view do
+  let(:exposures) { Hash[format: :html] }
+  let(:template)  { Hanami::View::Template.new('apps/web/templates/events/index.html.erb') }
+  let(:view)      { described_class.new(template, exposures) }
+  let(:rendered)  { view.render }
+
+  it 'exposes #format' do
+    expect(view.format).to eq exposures.fetch(:format)
+  end
+end

system/container.rb

@@ -1,5 +1,7 @@
 require 'dry/system/container'
 require 'dry/system/hanami'
+require 'graphql/client'
+require 'graphql/client/http'
 
 module System
   class Container < Dry::System::Container
@@ -16,5 +18,11 @@ class Container < Dry::System::Container
     register 'omniscrapper.root' do
       OmniScrapper
     end
+
+    register 'omniscrapper.graphql_client' do
+      http = GraphQL::Client::HTTP.new(ENV['SCHEDULER_API'])
+      schema = GraphQL::Client.load_schema(http)
+      GraphQL::Client.new(schema: schema, execute: http)
+    end
   end
 end