1 files changed, 71 insertions, 0 deletions
diff --git a/spec/models/hooks/project_hook_spec.rb b/spec/models/hooks/project_hook_spec.rb
index 4253686b843..923a6f92424 100644
--- a/spec/models/hooks/project_hook_spec.rb
+++ b/spec/models/hooks/project_hook_spec.rb
@@ -15,6 +15,19 @@ RSpec.describe ProjectHook do
     subject { build(:project_hook, project: create(:project)) }
   end
 
+  describe '.for_projects' do
+    it 'finds related project hooks' do
+      hook_a = create(:project_hook)
+      hook_b = create(:project_hook)
+      hook_c = create(:project_hook)
+
+      expect(described_class.for_projects([hook_a.project, hook_b.project]))
+        .to contain_exactly(hook_a, hook_b)
+      expect(described_class.for_projects(hook_c.project))
+        .to contain_exactly(hook_c)
+    end
+  end
+
   describe '.push_hooks' do
     it 'returns hooks for push events only' do
       hook = create(:project_hook, push_events: true)
@@ -50,4 +63,62 @@ RSpec.describe ProjectHook do
       )
     end
   end
+
+  describe '#update_last_failure', :clean_gitlab_redis_shared_state do
+    let_it_be(:hook) { create(:project_hook) }
+
+    it 'is a method of this class' do
+      expect { hook.update_last_failure }.not_to raise_error
+    end
+
+    context 'when the hook is executable' do
+      it 'does not update the state' do
+        expect(Gitlab::Redis::SharedState).not_to receive(:with)
+
+        hook.update_last_failure
+      end
+    end
+
+    context 'when the hook is failed' do
+      before do
+        allow(hook).to receive(:executable?).and_return(false)
+      end
+
+      def last_failure
+        Gitlab::Redis::SharedState.with do |redis|
+          redis.get("web_hooks:last_failure:project-#{hook.project.id}")
+        end
+      end
+
+      context 'there is no prior value', :freeze_time do
+        it 'updates the state' do
+          expect { hook.update_last_failure }.to change { last_failure }.to(Time.current)
+        end
+      end
+
+      context 'there is a prior value, from before now' do
+        it 'updates the state' do
+          the_future = 1.minute.from_now
+
+          hook.update_last_failure
+
+          travel_to(the_future) do
+            expect { hook.update_last_failure }.to change { last_failure }.to(the_future.iso8601)
+          end
+        end
+      end
+
+      context 'there is a prior value, from after now' do
+        it 'does not update the state' do
+          the_past = 1.minute.ago
+
+          hook.update_last_failure
+
+          travel_to(the_past) do
+            expect { hook.update_last_failure }.not_to change { last_failure }
+          end
+        end
+      end
+    end
+  end
 end