feat(actions): add runs, jobs, and logs commands
Implement tea actions commands to view workflow runs and logs using the Gitea 1.25 API endpoints directly. This adds: - `tea actions runs` - list workflow runs for a repository - `tea actions jobs <run-id>` - list jobs for a specific run - `tea actions logs <job-id>` - display logs for a specific job Also adds a new `modules/api` package for making raw authenticated HTTP requests to Gitea API endpoints not yet supported by the go-sdk. Closes #1 🤖 Generated with [Claude Code](https://claude.com/claude-code) Co-Authored-By: Claude Opus 4.5 <noreply@anthropic.com>
This commit is contained in:
97
modules/api/client.go
Normal file
97
modules/api/client.go
Normal file
@@ -0,0 +1,97 @@
|
||||
// Copyright 2024 The Gitea Authors. All rights reserved.
|
||||
// SPDX-License-Identifier: MIT
|
||||
|
||||
package api
|
||||
|
||||
import (
|
||||
"crypto/tls"
|
||||
"encoding/json"
|
||||
"fmt"
|
||||
"io"
|
||||
"net/http"
|
||||
|
||||
"code.gitea.io/tea/modules/config"
|
||||
)
|
||||
|
||||
// Client provides methods for making raw API calls to Gitea
|
||||
type Client struct {
|
||||
login *config.Login
|
||||
httpClient *http.Client
|
||||
}
|
||||
|
||||
// NewClient creates a new API client from a login
|
||||
func NewClient(login *config.Login) *Client {
|
||||
httpClient := &http.Client{}
|
||||
if login.Insecure {
|
||||
httpClient = &http.Client{
|
||||
Transport: &http.Transport{
|
||||
TLSClientConfig: &tls.Config{InsecureSkipVerify: true},
|
||||
},
|
||||
}
|
||||
}
|
||||
return &Client{
|
||||
login: login,
|
||||
httpClient: httpClient,
|
||||
}
|
||||
}
|
||||
|
||||
// Get makes an authenticated GET request to the API
|
||||
func (c *Client) Get(path string, result interface{}) (*http.Response, error) {
|
||||
url := fmt.Sprintf("%s/api/v1%s", c.login.URL, path)
|
||||
|
||||
req, err := http.NewRequest("GET", url, nil)
|
||||
if err != nil {
|
||||
return nil, err
|
||||
}
|
||||
|
||||
req.Header.Set("Authorization", "token "+c.login.Token)
|
||||
req.Header.Set("Accept", "application/json")
|
||||
|
||||
resp, err := c.httpClient.Do(req)
|
||||
if err != nil {
|
||||
return nil, err
|
||||
}
|
||||
defer resp.Body.Close()
|
||||
|
||||
if resp.StatusCode >= 400 {
|
||||
body, _ := io.ReadAll(resp.Body)
|
||||
return resp, fmt.Errorf("API request failed with status %d: %s", resp.StatusCode, string(body))
|
||||
}
|
||||
|
||||
if result != nil {
|
||||
if err := json.NewDecoder(resp.Body).Decode(result); err != nil {
|
||||
return resp, fmt.Errorf("failed to decode response: %w", err)
|
||||
}
|
||||
}
|
||||
|
||||
return resp, nil
|
||||
}
|
||||
|
||||
// GetRaw makes an authenticated GET request and returns the raw response body
|
||||
func (c *Client) GetRaw(path string) ([]byte, error) {
|
||||
url := fmt.Sprintf("%s/api/v1%s", c.login.URL, path)
|
||||
|
||||
req, err := http.NewRequest("GET", url, nil)
|
||||
if err != nil {
|
||||
return nil, err
|
||||
}
|
||||
|
||||
req.Header.Set("Authorization", "token "+c.login.Token)
|
||||
|
||||
resp, err := c.httpClient.Do(req)
|
||||
if err != nil {
|
||||
return nil, err
|
||||
}
|
||||
defer resp.Body.Close()
|
||||
|
||||
body, err := io.ReadAll(resp.Body)
|
||||
if err != nil {
|
||||
return nil, err
|
||||
}
|
||||
|
||||
if resp.StatusCode >= 400 {
|
||||
return nil, fmt.Errorf("API request failed with status %d: %s", resp.StatusCode, string(body))
|
||||
}
|
||||
|
||||
return body, nil
|
||||
}
|
||||
59
modules/api/types.go
Normal file
59
modules/api/types.go
Normal file
@@ -0,0 +1,59 @@
|
||||
// Copyright 2024 The Gitea Authors. All rights reserved.
|
||||
// SPDX-License-Identifier: MIT
|
||||
|
||||
package api
|
||||
|
||||
import "time"
|
||||
|
||||
// ActionRun represents a workflow run
|
||||
type ActionRun struct {
|
||||
ID int64 `json:"id"`
|
||||
Title string `json:"display_title"`
|
||||
Path string `json:"path"`
|
||||
Status string `json:"status"`
|
||||
Conclusion string `json:"conclusion"`
|
||||
Event string `json:"event"`
|
||||
HeadBranch string `json:"head_branch"`
|
||||
HeadSHA string `json:"head_sha"`
|
||||
RunNumber int64 `json:"run_number"`
|
||||
RunAttempt int64 `json:"run_attempt"`
|
||||
HTMLURL string `json:"html_url"`
|
||||
URL string `json:"url"`
|
||||
StartedAt *time.Time `json:"started_at"`
|
||||
CompletedAt *time.Time `json:"completed_at"`
|
||||
}
|
||||
|
||||
// ActionRunList is a list of workflow runs
|
||||
type ActionRunList struct {
|
||||
TotalCount int64 `json:"total_count"`
|
||||
WorkflowRuns []*ActionRun `json:"workflow_runs"`
|
||||
}
|
||||
|
||||
// ActionJob represents a job within a workflow run
|
||||
type ActionJob struct {
|
||||
ID int64 `json:"id"`
|
||||
RunID int64 `json:"run_id"`
|
||||
Name string `json:"name"`
|
||||
Status string `json:"status"`
|
||||
Conclusion string `json:"conclusion"`
|
||||
HTMLURL string `json:"html_url"`
|
||||
StartedAt *time.Time `json:"started_at"`
|
||||
CompletedAt *time.Time `json:"completed_at"`
|
||||
Steps []*ActionJobStep `json:"steps"`
|
||||
}
|
||||
|
||||
// ActionJobStep represents a step within a job
|
||||
type ActionJobStep struct {
|
||||
Name string `json:"name"`
|
||||
Number int64 `json:"number"`
|
||||
Status string `json:"status"`
|
||||
Conclusion string `json:"conclusion"`
|
||||
StartedAt *time.Time `json:"started_at"`
|
||||
CompletedAt *time.Time `json:"completed_at"`
|
||||
}
|
||||
|
||||
// ActionJobList is a list of jobs
|
||||
type ActionJobList struct {
|
||||
TotalCount int64 `json:"total_count"`
|
||||
Jobs []*ActionJob `json:"jobs"`
|
||||
}
|
||||
@@ -7,6 +7,7 @@ import (
|
||||
"fmt"
|
||||
|
||||
"code.gitea.io/sdk/gitea"
|
||||
"code.gitea.io/tea/modules/api"
|
||||
)
|
||||
|
||||
// ActionSecretsList prints a list of action secrets
|
||||
@@ -74,3 +75,94 @@ func ActionVariablesList(variables []*gitea.RepoActionVariable, output string) {
|
||||
t.sort(0, true)
|
||||
t.print(output)
|
||||
}
|
||||
|
||||
// ActionRunsList prints a list of workflow runs
|
||||
func ActionRunsList(runs []*api.ActionRun, output string) {
|
||||
t := table{
|
||||
headers: []string{
|
||||
"ID",
|
||||
"Title",
|
||||
"Status",
|
||||
"Conclusion",
|
||||
"Event",
|
||||
"Branch",
|
||||
"Started",
|
||||
},
|
||||
}
|
||||
|
||||
for _, run := range runs {
|
||||
conclusion := run.Conclusion
|
||||
if conclusion == "" {
|
||||
conclusion = "-"
|
||||
}
|
||||
|
||||
started := ""
|
||||
if run.StartedAt != nil {
|
||||
started = FormatTime(*run.StartedAt, output != "")
|
||||
}
|
||||
|
||||
t.addRow(
|
||||
fmt.Sprintf("%d", run.ID),
|
||||
run.Title,
|
||||
run.Status,
|
||||
conclusion,
|
||||
run.Event,
|
||||
run.HeadBranch,
|
||||
started,
|
||||
)
|
||||
}
|
||||
|
||||
if len(runs) == 0 {
|
||||
fmt.Printf("No workflow runs found\n")
|
||||
return
|
||||
}
|
||||
|
||||
t.print(output)
|
||||
}
|
||||
|
||||
// ActionJobsList prints a list of jobs
|
||||
func ActionJobsList(jobs []*api.ActionJob, output string) {
|
||||
t := table{
|
||||
headers: []string{
|
||||
"ID",
|
||||
"Name",
|
||||
"Status",
|
||||
"Conclusion",
|
||||
"Started",
|
||||
"Completed",
|
||||
},
|
||||
}
|
||||
|
||||
for _, job := range jobs {
|
||||
conclusion := job.Conclusion
|
||||
if conclusion == "" {
|
||||
conclusion = "-"
|
||||
}
|
||||
|
||||
started := ""
|
||||
if job.StartedAt != nil {
|
||||
started = FormatTime(*job.StartedAt, output != "")
|
||||
}
|
||||
|
||||
completed := ""
|
||||
if job.CompletedAt != nil {
|
||||
completed = FormatTime(*job.CompletedAt, output != "")
|
||||
}
|
||||
|
||||
t.addRow(
|
||||
fmt.Sprintf("%d", job.ID),
|
||||
job.Name,
|
||||
job.Status,
|
||||
conclusion,
|
||||
started,
|
||||
completed,
|
||||
)
|
||||
}
|
||||
|
||||
if len(jobs) == 0 {
|
||||
fmt.Printf("No jobs found\n")
|
||||
return
|
||||
}
|
||||
|
||||
t.print(output)
|
||||
}
|
||||
|
||||
Reference in New Issue
Block a user