-
Notifications
You must be signed in to change notification settings - Fork 207
/
repo_releases_query.rb
72 lines (60 loc) · 2.13 KB
/
repo_releases_query.rb
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
59
60
61
62
63
64
65
66
67
68
69
70
71
72
# frozen_string_literal: true
module MaintenanceStats
module Queries
module Github
class RepoReleasesQuery < BaseQuery
RELEASES_QUERY = GithubGraphql.parse_query <<-GRAPHQL
query($owner: String!, $repo_name: String!, $cursor: String){
repository(owner: $owner, name: $repo_name){
releases(first: 100, after: $cursor, orderBy: {field: CREATED_AT, direction: DESC}){
nodes {
name
publishedAt
}
totalCount
pageInfo {
hasPreviousPage
hasNextPage
endCursor
startCursor
}
}
}
}
GRAPHQL
VALID_PARAMS = %i[owner repo_name end_date].freeze
REQUIRED_PARAMS = %i[owner repo_name].freeze
def self.client_type
:v4
end
def query(params: {})
validate_params(params)
end_date = params.delete(:end_date)
full_name = "#{params[:owner]}/#{params[:repo_name]}"
releases = nil
has_next_page = true
cursor = nil
while has_next_page
params[:cursor] = cursor if cursor.present?
result = @client.query(RELEASES_QUERY, variables: params)
QueryUtils.check_for_graphql_errors(result, full_name)
has_next_page = result.data.repository.releases.page_info.has_next_page
cursor = result.data.repository.releases.page_info.end_cursor
# initialize releases if we have not started gathering data
releases ||= []
result.data.repository&.releases&.nodes&.each do |release|
# if release is within our search window or we don't have a specific date window then add it to the list
publish_date = DateTime.parse(release.published_at)
if end_date.nil? || publish_date > end_date
releases << release
else
break
end
end
end
releases
end
end
end
end
end