blob: 161ce106b9b7ce3c4f5b1e811dd9f9c4782a8874 (
plain)
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
|
# frozen_string_literal: true
module WebHooks
module HasWebHooks
extend ActiveSupport::Concern
WEB_HOOK_CACHE_EXPIRY = 1.hour
def any_hook_failed?
hooks.disabled.exists?
end
def web_hook_failure_redis_key
"any_web_hook_failed:#{id}"
end
def last_failure_redis_key
"web_hooks:last_failure:project-#{id}"
end
def get_web_hook_failure
Gitlab::Redis::SharedState.with do |redis|
current = redis.get(web_hook_failure_redis_key)
Gitlab::Utils.to_boolean(current) if current
end
end
def fetch_web_hook_failure
Gitlab::Redis::SharedState.with do |_redis|
current = get_web_hook_failure
next current unless current.nil?
cache_web_hook_failure
end
end
def cache_web_hook_failure(state = any_hook_failed?)
Gitlab::Redis::SharedState.with do |redis|
redis.set(web_hook_failure_redis_key, state.to_s, ex: WEB_HOOK_CACHE_EXPIRY)
state
end
end
end
end
|
