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
47
48
49
50
51
52
53
54
55
56
57
58
|
# frozen_string_literal: true
# Helpers for shared & state across all CLI flows
module InternalEventsCli
class GlobalState
def events
@events ||= load_definitions(
Event,
InternalEventsCli::NEW_EVENT_FIELDS,
all_event_paths
)
end
def metrics
@metrics ||= load_definitions(
Metric,
InternalEventsCli::NEW_METRIC_FIELDS,
all_metric_paths
)
end
def reload_definitions
@events = nil
@metrics = nil
end
private
def all_event_paths
[
Dir["config/events/*.yml"],
Dir["ee/config/events/*.yml"]
].flatten
end
def all_metric_paths
[
Dir["config/metrics/counts_all/*.yml"],
Dir["config/metrics/counts_7d/*.yml"],
Dir["config/metrics/counts_28d/*.yml"],
Dir["ee/config/metrics/counts_all/*.yml"],
Dir["ee/config/metrics/counts_7d/*.yml"],
Dir["ee/config/metrics/counts_28d/*.yml"]
].flatten
end
def load_definitions(klass, fields, paths)
paths.filter_map do |path|
details = YAML.safe_load(File.read(path))
relevant_fields = fields.map(&:to_s)
klass.parse(**details.slice(*relevant_fields), file_path: path)
rescue StandardError => e
puts "\n\n\e[31mEncountered an error while loading #{path}: #{e.message}\e[0m\n\n\n"
end
end
end
end
|
