Manage task schedules

.env.development.sample

@@ -3,3 +3,4 @@ DATABASE_URL="postgresql://username:password@localhost/omniscrapper_hq_developme
 SERVE_STATIC_ASSETS="true"
 WEB_SESSIONS_SECRET="00bdb001d8f18ee8e8e4b7d063877243348fa8cb2c3879a52052c33871f09228"
 API_SESSIONS_SECRET="985f2d9f9d1f729e3204d011354792a148e548f599b3554b2bedc591949240d0"
+SCHEDULER_API=http://localhost:2301/api/graphql

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 :schedules, only: [:index]

apps/web/controllers/schedules/index.rb

@@ -0,0 +1,18 @@
+module Web
+  module Controllers
+    module Schedules
+      class Index
+        include Web::Action
+        include Import[
+          operation: 'operations.schedule.index'
+        ]
+
+        expose :schedules
+
+        def call(_)
+          @schedules = operation.call
+        end
+      end
+    end
+  end
+end

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

@@ -0,0 +1,17 @@
+%table.table.table-bordered.table-hover.table-sm
+  %thead
+    %tr
+      %th Name
+      %th Task
+      %th Frequency
+      %th
+  %tbody
+    - schedules.each do |event|
+      %tr
+        %td= schedule.name
+        %td= schedule.task_id
+        %td= schedule.frequency
+        %td
+          = edit_button("#")
+          = remove_button("#")
+

apps/web/templates/shared/_navbar.html.haml

@@ -15,6 +15,8 @@
         = link_to 'Outputs', routes.outputs_path, class: 'nav-link'
       %li.nav-item
         = link_to 'Tasks', routes.tasks_path, class: 'nav-link'
+      %li.nav-item
+        = link_to 'Schedules', routes.schedules_path, class: 'nav-link'
       %li.nav-item
         = link_to 'Results', routes.test_results_path, class: 'nav-link'
       %li.nav-item

apps/web/views/schedules/index.rb

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

lib/omniscrapper_hq/entities/event.rb

@@ -0,0 +1,15 @@
+class Event
+  attr_reader :id, :name, :task_id, :frequency_period, :frequency_quantity
+
+  def initialize(id:, name:, task_id:, frequency_period:, frequency_quantity:)
+    @id = id
+    @name = name
+    @task_id = task_id
+    @frequency_period = frequency_period
+    @frequency_quantity = frequency_quantity
+  end
+
+  def frequency
+    "#{frequency_quantity} #{frequency_period}"
+  end
+end

lib/omniscrapper_hq/operations/schedule/index.rb

@@ -0,0 +1,32 @@
+module Operations
+  module Schedule
+    class Index < Base
+      GRAPHQL_CLIENT ||= System::Container['omniscrapper.graphql_client']
+
+      Query ||= GRAPHQL_CLIENT.parse <<-'GRAPHQL'
+        query {
+          events {
+            id,
+            name,
+            taskId,
+            frequencyPeriod,
+            frequencyQuantity
+          }
+        }
+      GRAPHQL
+
+      def call
+        results = GRAPHQL_CLIENT.query(Query)
+        results.data.events.map do |event|
+          ::Event.new(
+            id: event.id,
+            name: event.name,
+            task_id: event.task_id,
+            frequency_quantity: event.frequency_quantity,
+            frequency_period: event.frequency_period
+          )
+        end
+      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