Module: Legion::Extensions::Github::Runners::Issues

Includes:
Helpers::Cache, Helpers::Client, Helpers::Lex
Included in:
Client
Defined in:
lib/legion/extensions/github/runners/issues.rb

Constant Summary

Constants included from Helpers::Cache

Helpers::Cache::DEFAULT_TTL, Helpers::Cache::DEFAULT_TTLS

Constants included from Helpers::Client

Helpers::Client::CREDENTIAL_RESOLVERS

Constants included from Helpers::TokenCache

Helpers::TokenCache::TOKEN_BUFFER_SECONDS

Instance Method Summary collapse

Methods included from Helpers::Cache

#cache_connected?, #cache_invalidate, #cache_write, #cached_get, #github_ttl_for, #local_cache_connected?, #local_cache_delete, #local_cache_get, #local_cache_set

Methods included from Helpers::Client

#connection, #gh_cli_token_output, #max_fallback_retries, #on_rate_limit, #on_scope_authorized, #on_scope_denied, #resolve_broker_app, #resolve_credential, #resolve_env, #resolve_gh_cli, #resolve_next_credential, #resolve_settings_app, #resolve_settings_delegated, #resolve_settings_pat, #resolve_vault_app, #resolve_vault_delegated, #resolve_vault_pat

Methods included from Helpers::ScopeRegistry

#credential_fingerprint, #invalidate_scope, #mark_rate_limited, #rate_limited?, #register_scope, #scope_status

Methods included from Helpers::TokenCache

#fetch_token, #mark_rate_limited, #rate_limited?, #store_token

Instance Method Details

#create_issue(owner:, repo:, title:, body: nil, labels: [], assignees: []) ⇒ Object



27
28
29
30
31
32
# File 'lib/legion/extensions/github/runners/issues.rb', line 27

def create_issue(owner:, repo:, title:, body: nil, labels: [], assignees: [], **)
  payload = { title: title, body: body, labels: labels, assignees: assignees }
  response = connection(owner: owner, repo: repo, **).post("/repos/#{owner}/#{repo}/issues", payload)
  cache_write("github:repo:#{owner}/#{repo}:issues:#{response.body['number']}", response.body) if response.body['id']
  { result: response.body }
end

#create_issue_comment(owner:, repo:, issue_number:, body:) ⇒ Object



48
49
50
51
# File 'lib/legion/extensions/github/runners/issues.rb', line 48

def create_issue_comment(owner:, repo:, issue_number:, body:, **)
  response = connection(owner: owner, repo: repo, **).post("/repos/#{owner}/#{repo}/issues/#{issue_number}/comments", { body: body })
  { result: response.body }
end

#get_issue(owner:, repo:, issue_number:) ⇒ Object



21
22
23
24
25
# File 'lib/legion/extensions/github/runners/issues.rb', line 21

def get_issue(owner:, repo:, issue_number:, **)
  { result: cached_get("github:repo:#{owner}/#{repo}:issues:#{issue_number}") do
    connection(owner: owner, repo: repo, **).get("/repos/#{owner}/#{repo}/issues/#{issue_number}").body
  end }
end

#list_issue_comments(owner:, repo:, issue_number:, per_page: 30, page: 1) ⇒ Object



41
42
43
44
45
46
# File 'lib/legion/extensions/github/runners/issues.rb', line 41

def list_issue_comments(owner:, repo:, issue_number:, per_page: 30, page: 1, **)
  params = { per_page: per_page, page: page }
  { result: cached_get("github:repo:#{owner}/#{repo}:issues:#{issue_number}:comments:#{page}:#{per_page}") do
    connection(owner: owner, repo: repo, **).get("/repos/#{owner}/#{repo}/issues/#{issue_number}/comments", params).body
  end }
end

#list_issues(owner:, repo:, state: 'open', per_page: 30, page: 1) ⇒ Object



14
15
16
17
18
19
# File 'lib/legion/extensions/github/runners/issues.rb', line 14

def list_issues(owner:, repo:, state: 'open', per_page: 30, page: 1, **)
  params = { state: state, per_page: per_page, page: page }
  { result: cached_get("github:repo:#{owner}/#{repo}:issues:#{state}:#{page}:#{per_page}") do
    connection(owner: owner, repo: repo, **).get("/repos/#{owner}/#{repo}/issues", params).body
  end }
end

#update_issue(owner:, repo:, issue_number:, **opts) ⇒ Object



34
35
36
37
38
39
# File 'lib/legion/extensions/github/runners/issues.rb', line 34

def update_issue(owner:, repo:, issue_number:, **opts)
  payload = opts.slice(:title, :body, :state, :labels, :assignees)
  response = connection(owner: owner, repo: repo, **opts).patch("/repos/#{owner}/#{repo}/issues/#{issue_number}", payload)
  cache_write("github:repo:#{owner}/#{repo}:issues:#{issue_number}", response.body) if response.body['id']
  { result: response.body }
end