missing specs

spec/lib/karafka/web/pro/ui/controllers/recurring_tasks_controller_spec.rb

@@ -388,4 +388,64 @@
       expect(message.payload[:task][:id]).to eq('*')
     end
   end
+
+  describe '#enable' do
+    before { post 'recurring_tasks/task1/enable' }
+
+    it do
+      expect(response.status).to eq(302)
+      # Taken from referer and referer is nil in specs
+      expect(response.location).to eq(nil)
+    end
+
+    it 'expect to create new command' do
+      # Dispatch of commands is async, so we have to wait
+      sleep(1)
+      message = Karafka::Admin.read_topic(schedules_topic, 0, 1, -1).first
+      expect(message.key).to eq('command:enable:task1')
+      expect(message.payload[:type]).to eq('command')
+      expect(message.payload[:command][:name]).to eq('enable')
+      expect(message.payload[:task][:id]).to eq('task1')
+    end
+  end
+
+  describe '#disable' do
+    before { post 'recurring_tasks/task1/disable' }
+
+    it do
+      expect(response.status).to eq(302)
+      # Taken from referer and referer is nil in specs
+      expect(response.location).to eq(nil)
+    end
+
+    it 'expect to create new command' do
+      # Dispatch of commands is async, so we have to wait
+      sleep(1)
+      message = Karafka::Admin.read_topic(schedules_topic, 0, 1, -1).first
+      expect(message.key).to eq('command:disable:task1')
+      expect(message.payload[:type]).to eq('command')
+      expect(message.payload[:command][:name]).to eq('disable')
+      expect(message.payload[:task][:id]).to eq('task1')
+    end
+  end
+
+  describe '#trigger' do
+    before { post 'recurring_tasks/task1/trigger' }
+
+    it do
+      expect(response.status).to eq(302)
+      # Taken from referer and referer is nil in specs
+      expect(response.location).to eq(nil)
+    end
+
+    it 'expect to create new command' do
+      # Dispatch of commands is async, so we have to wait
+      sleep(1)
+      message = Karafka::Admin.read_topic(schedules_topic, 0, 1, -1).first
+      expect(message.key).to eq('command:trigger:task1')
+      expect(message.payload[:type]).to eq('command')
+      expect(message.payload[:command][:name]).to eq('trigger')
+      expect(message.payload[:task][:id]).to eq('task1')
+    end
+  end
 end

spec/lib/karafka/web/ui/models/recurring_tasks/log_spec.rb

@@ -0,0 +1,7 @@
+# frozen_string_literal: true
+
+RSpec.describe_current do
+  subject(:log) { described_class }
+
+  it { expect(log).to be < Karafka::Web::Ui::Lib::HashProxy }
+end

spec/lib/karafka/web/ui/models/recurring_tasks/schedule_spec.rb

@@ -0,0 +1,30 @@
+# frozen_string_literal: true
+
+RSpec.describe_current do
+  subject(:schedule) { described_class.new(attrs) }
+
+  let(:attrs) { { tasks: {} } }
+
+  describe '#tasks' do
+    context 'when no tasks' do
+      it { expect(schedule.tasks).to eq([]) }
+    end
+
+    context 'when tasks are present' do
+      let(:attrs) do
+        {
+          tasks: {
+            task1: {
+              id: 'task1',
+              cron: '* * * * *'
+            }
+          }
+        }
+      end
+
+      it { expect(schedule.tasks.first).to be_a(Karafka::Web::Ui::Models::RecurringTasks::Task) }
+      it { expect(schedule.tasks).to be_a(Array) }
+      it { expect(schedule.tasks.first.id).to eq('task1') }
+    end
+  end
+end

spec/lib/karafka/web/ui/models/recurring_tasks/task_spec.rb

@@ -0,0 +1,21 @@
+# frozen_string_literal: true
+
+RSpec.describe_current do
+  subject(:task) { described_class.new(attrs) }
+
+  let(:attrs) { { enabled: true } }
+
+  it { expect(task.class).to be < Karafka::Web::Ui::Lib::HashProxy }
+
+  describe '#enabled?' do
+    context 'when enabled' do
+      it { expect(task.enabled?).to eq(true) }
+    end
+
+    context 'when disabled' do
+      let(:attrs) { { enabled: false } }
+
+      it { expect(task.enabled?).to eq(false) }
+    end
+  end
+end