Compare commits
27 Commits
| Author | SHA1 | Date | |
|---|---|---|---|
| d34916c276 | |||
| d350500486 | |||
| f802ad296c | |||
| 9ac282ba17 | |||
| 2cc1f16bce | |||
| c6fdcc8a11 | |||
| baf6977a33 | |||
| f1e4b0c2ba | |||
| fa63d56e43 | |||
| d8a590eb79 | |||
| 46d23bf565 | |||
| 5d3ce5baf8 | |||
| c7d68c742d | |||
| 674c75f5eb | |||
| 4e7b072f82 | |||
| 02a108a58e | |||
| baf829349c | |||
| 3145acc423 | |||
| ce3fc36835 | |||
| c267bc86a8 | |||
| c790a7236c | |||
| 0ef2184204 | |||
| ca3564a1ec | |||
| e6ca9a078d | |||
| 7d90b5eb4b | |||
| faf5fc1797 | |||
| af8e705919 |
@@ -0,0 +1,44 @@
|
|||||||
|
root = "."
|
||||||
|
testdata_dir = "testdata"
|
||||||
|
tmp_dir = "tmp"
|
||||||
|
|
||||||
|
[build]
|
||||||
|
args_bin = []
|
||||||
|
bin = "./tmp/main"
|
||||||
|
cmd = "go build -o ./tmp/main ./cmd/server"
|
||||||
|
delay = 500
|
||||||
|
exclude_dir = ["assets", "tmp", "vendor", "testdata", ".git", "node_modules"]
|
||||||
|
exclude_file = []
|
||||||
|
exclude_regex = ["_test\\.go$"]
|
||||||
|
exclude_unchanged = false
|
||||||
|
follow_symlink = false
|
||||||
|
full_bin = ""
|
||||||
|
include_dir = []
|
||||||
|
include_ext = ["go", "html", "css", "js"]
|
||||||
|
include_file = []
|
||||||
|
kill_delay = "0s"
|
||||||
|
log = "build-errors.log"
|
||||||
|
poll = false
|
||||||
|
poll_interval = 0
|
||||||
|
rerun = false
|
||||||
|
rerun_delay = 500
|
||||||
|
send_interrupt = false
|
||||||
|
stop_on_error = false
|
||||||
|
|
||||||
|
[color]
|
||||||
|
app = ""
|
||||||
|
build = "yellow"
|
||||||
|
main = "magenta"
|
||||||
|
runner = "green"
|
||||||
|
watcher = "cyan"
|
||||||
|
|
||||||
|
[log]
|
||||||
|
main_only = false
|
||||||
|
time = false
|
||||||
|
|
||||||
|
[misc]
|
||||||
|
clean_on_exit = true
|
||||||
|
|
||||||
|
[screen]
|
||||||
|
clear_on_rebuild = false
|
||||||
|
keep_scroll = true
|
||||||
@@ -4,6 +4,9 @@ on:
|
|||||||
push:
|
push:
|
||||||
branches:
|
branches:
|
||||||
- master
|
- master
|
||||||
|
pull_request:
|
||||||
|
branches:
|
||||||
|
- master
|
||||||
|
|
||||||
jobs:
|
jobs:
|
||||||
test:
|
test:
|
||||||
@@ -15,12 +18,16 @@ jobs:
|
|||||||
with:
|
with:
|
||||||
go-version: '1.22'
|
go-version: '1.22'
|
||||||
|
|
||||||
|
- name: Vet
|
||||||
|
run: go vet ./...
|
||||||
|
|
||||||
- name: Run tests
|
- name: Run tests
|
||||||
run: go test -race ./...
|
run: go test -race ./...
|
||||||
|
|
||||||
build:
|
build:
|
||||||
runs-on: ubuntu-latest
|
runs-on: ubuntu-latest
|
||||||
needs: test
|
needs: test
|
||||||
|
if: gitea.event_name == 'push'
|
||||||
steps:
|
steps:
|
||||||
- uses: actions/checkout@v4
|
- uses: actions/checkout@v4
|
||||||
|
|
||||||
|
|||||||
+1
-1
@@ -1,7 +1,7 @@
|
|||||||
# Stage 1: Build
|
# Stage 1: Build
|
||||||
FROM golang:1.22-alpine AS builder
|
FROM golang:1.22-alpine AS builder
|
||||||
WORKDIR /app
|
WORKDIR /app
|
||||||
COPY go.mod ./
|
COPY go.mod go.sum ./
|
||||||
RUN go mod download
|
RUN go mod download
|
||||||
COPY . .
|
COPY . .
|
||||||
RUN CGO_ENABLED=0 GOOS=linux go build -ldflags="-s -w" -o /gitea-mobile ./cmd/server
|
RUN CGO_ENABLED=0 GOOS=linux go build -ldflags="-s -w" -o /gitea-mobile ./cmd/server
|
||||||
|
|||||||
@@ -0,0 +1,116 @@
|
|||||||
|
# Gitea Mobile
|
||||||
|
|
||||||
|
A mobile-first Progressive Web App (PWA) for managing Gitea issues and pull requests across multiple repositories and organizations from an iPhone. Built with Go, HTMX, and hand-rolled CSS -- no JavaScript frameworks, no build step, no node_modules.
|
||||||
|
|
||||||
|
## Tech Stack
|
||||||
|
|
||||||
|
| Layer | Choice |
|
||||||
|
|-------|--------|
|
||||||
|
| Backend | Go + Gitea SDK (`code.gitea.io/sdk/gitea`) |
|
||||||
|
| Frontend | HTMX + Go `html/template` + hand-rolled CSS |
|
||||||
|
| Container | Multi-stage Dockerfile -> distroless (~15MB) |
|
||||||
|
| Deployment | Kustomize manifests + FluxCD GitOps |
|
||||||
|
|
||||||
|
## Project Structure
|
||||||
|
|
||||||
|
```
|
||||||
|
/
|
||||||
|
├── cmd/server/main.go # entrypoint
|
||||||
|
├── internal/
|
||||||
|
│ ├── config/config.go # env-based configuration
|
||||||
|
│ ├── gitea/client.go # Gitea SDK wrapper / aggregation layer
|
||||||
|
│ ├── handlers/ # HTTP handlers (issues, PRs, triage, settings)
|
||||||
|
│ ├── auth/ # cookie-based token auth
|
||||||
|
│ ├── middleware/ # auth middleware, logging
|
||||||
|
│ └── templates/ # Go html/template files (for HTMX)
|
||||||
|
├── static/ # CSS, JS (htmx.min.js), icons, manifest
|
||||||
|
├── .gitea/workflows/build.yaml # CI pipeline (Gitea Actions)
|
||||||
|
├── Dockerfile
|
||||||
|
├── flake.nix # Nix dev shell with Go + air
|
||||||
|
└── go.mod
|
||||||
|
```
|
||||||
|
|
||||||
|
## Local Development
|
||||||
|
|
||||||
|
### Prerequisites
|
||||||
|
|
||||||
|
- [Nix](https://nixos.org/download/) with flakes enabled, **or** Go 1.22+
|
||||||
|
- A Gitea instance with an API token
|
||||||
|
|
||||||
|
### Quick Start
|
||||||
|
|
||||||
|
```bash
|
||||||
|
# Enter the Nix dev shell (provides Go, gopls, air)
|
||||||
|
nix develop
|
||||||
|
|
||||||
|
# Set required environment variables
|
||||||
|
export GITEA_URL=https://gitea.leeworks.dev
|
||||||
|
export SESSION_SECRET=$(openssl rand -hex 32)
|
||||||
|
|
||||||
|
# Optional: set a default API token
|
||||||
|
export GITEA_TOKEN=your-gitea-api-token
|
||||||
|
|
||||||
|
# Start the server with live reload
|
||||||
|
air
|
||||||
|
```
|
||||||
|
|
||||||
|
If you are not using Nix, install Go 1.22+ and [air](https://github.com/air-verse/air) manually, then run the same commands above starting from the export lines.
|
||||||
|
|
||||||
|
### Environment Variables
|
||||||
|
|
||||||
|
| Variable | Required | Default | Description |
|
||||||
|
|----------|----------|---------|-------------|
|
||||||
|
| `GITEA_URL` | Yes | -- | Base URL of the Gitea instance |
|
||||||
|
| `SESSION_SECRET` | Yes | -- | HMAC key for signing session cookies (min 32 chars) |
|
||||||
|
| `GITEA_TOKEN` | No | -- | Default API token (users can set their own via the settings page) |
|
||||||
|
| `LISTEN_ADDR` | No | `:8080` | Server listen address |
|
||||||
|
|
||||||
|
### Live Reload with Air
|
||||||
|
|
||||||
|
The dev shell includes [air](https://github.com/air-verse/air) for automatic recompilation on file changes. Configuration is in `.air.toml`. Air watches `.go` and `.html` files under `cmd/`, `internal/`, and `static/` and rebuilds/restarts the server automatically.
|
||||||
|
|
||||||
|
## Running Tests
|
||||||
|
|
||||||
|
```bash
|
||||||
|
# Run all tests
|
||||||
|
go test ./...
|
||||||
|
|
||||||
|
# Run tests with race detection
|
||||||
|
go test -race ./...
|
||||||
|
```
|
||||||
|
|
||||||
|
## Building the Container
|
||||||
|
|
||||||
|
```bash
|
||||||
|
# Build the Docker image
|
||||||
|
docker build -t gitea-mobile .
|
||||||
|
|
||||||
|
# Run locally
|
||||||
|
docker run -p 8080:8080 \
|
||||||
|
-e GITEA_URL=https://gitea.leeworks.dev \
|
||||||
|
-e SESSION_SECRET=$(openssl rand -hex 32) \
|
||||||
|
gitea-mobile
|
||||||
|
```
|
||||||
|
|
||||||
|
The Dockerfile uses a multi-stage build: Go binary compiled in an Alpine builder stage, then copied into a distroless image (~15MB final size).
|
||||||
|
|
||||||
|
## Deployment
|
||||||
|
|
||||||
|
Kubernetes manifests for this app live in the Talos cluster repo under `testing1/first-cluster/apps/gitea-mobile/`. FluxCD syncs from that repo and handles automated image updates via `ImagePolicy` annotations.
|
||||||
|
|
||||||
|
Key deployment resources:
|
||||||
|
- `deployment.yaml` -- Pod spec with health checks
|
||||||
|
- `service.yaml` -- ClusterIP service on port 8080
|
||||||
|
- `ingressroute.yaml` -- Traefik IngressRoute for `gitea-mobile.testing.leeworks.dev`
|
||||||
|
- `kustomization.yaml` -- Kustomize overlay
|
||||||
|
|
||||||
|
## Contributing
|
||||||
|
|
||||||
|
1. Fork the repository
|
||||||
|
2. Create a feature branch: `git checkout -b feature/your-feature`
|
||||||
|
3. Make your changes and add tests
|
||||||
|
4. Run `go test -race ./...` to verify
|
||||||
|
5. Commit with a clear message referencing the issue number
|
||||||
|
6. Push to your fork and open a pull request
|
||||||
|
|
||||||
|
All PRs target the fork (`leeworks-agents/gitea-mobile`), not the upstream repo.
|
||||||
+148
@@ -0,0 +1,148 @@
|
|||||||
|
# Post-Deployment Smoke Test Runbook
|
||||||
|
|
||||||
|
Smoke test procedure for verifying gitea-mobile after deployment to the Talos cluster.
|
||||||
|
|
||||||
|
## Pre-conditions
|
||||||
|
|
||||||
|
Before running the smoke test, confirm:
|
||||||
|
|
||||||
|
- [ ] FluxCD has reconciled the latest manifests: `flux get kustomizations -n flux-system`
|
||||||
|
- [ ] The gitea-mobile pod is Running: `kubectl get pods -n gitea-mobile`
|
||||||
|
- [ ] The IngressRoute is active: `kubectl get ingressroute -n gitea-mobile`
|
||||||
|
- [ ] DNS resolves `gitea-mobile.testing.leeworks.dev` to the cluster ingress
|
||||||
|
|
||||||
|
## Step 1: Pod Health
|
||||||
|
|
||||||
|
```bash
|
||||||
|
# Verify the pod is running and ready
|
||||||
|
kubectl get pods -n gitea-mobile
|
||||||
|
# Expected: STATUS=Running, READY=1/1
|
||||||
|
|
||||||
|
# Check pod logs for startup errors
|
||||||
|
kubectl logs -n gitea-mobile deployment/gitea-mobile --tail=20
|
||||||
|
# Expected: JSON log line with "server starting" message
|
||||||
|
```
|
||||||
|
|
||||||
|
## Step 2: Health Endpoint
|
||||||
|
|
||||||
|
```bash
|
||||||
|
# Hit the health check endpoint from inside the cluster
|
||||||
|
kubectl exec -n gitea-mobile deployment/gitea-mobile -- wget -qO- http://localhost:8080/health
|
||||||
|
# Expected: HTTP 200
|
||||||
|
|
||||||
|
# Hit the health check endpoint from outside the cluster
|
||||||
|
curl -s -o /dev/null -w "%{http_code}" https://gitea-mobile.testing.leeworks.dev/health
|
||||||
|
# Expected: 200
|
||||||
|
```
|
||||||
|
|
||||||
|
## Step 3: TLS and Ingress
|
||||||
|
|
||||||
|
```bash
|
||||||
|
# Verify TLS certificate is valid
|
||||||
|
curl -vI https://gitea-mobile.testing.leeworks.dev 2>&1 | grep "SSL certificate"
|
||||||
|
# Expected: valid certificate from Let's Encrypt or cluster CA
|
||||||
|
|
||||||
|
# Verify the app responds with HTML
|
||||||
|
curl -s https://gitea-mobile.testing.leeworks.dev | head -5
|
||||||
|
# Expected: HTML document with <html> tag
|
||||||
|
```
|
||||||
|
|
||||||
|
## Step 4: Authentication Flow
|
||||||
|
|
||||||
|
1. Open `https://gitea-mobile.testing.leeworks.dev` in a browser
|
||||||
|
2. Navigate to the Settings page (`/settings`)
|
||||||
|
3. Enter a valid Gitea API token
|
||||||
|
4. Submit the form
|
||||||
|
5. **Expected**: Token is saved, page confirms success
|
||||||
|
6. Navigate back to the Issues tab
|
||||||
|
7. **Expected**: Issues load from the Gitea API using the saved token
|
||||||
|
|
||||||
|
## Step 5: Core Functionality -- Issues
|
||||||
|
|
||||||
|
1. Navigate to the Issues tab (`/issues`)
|
||||||
|
2. **Expected**: Cross-org issues load and display with titles, labels, and timestamps
|
||||||
|
3. Tap on an issue to expand details
|
||||||
|
4. **Expected**: Issue body renders correctly
|
||||||
|
5. Use the filter dropdown to filter by repo or label
|
||||||
|
6. **Expected**: List updates via HTMX without full page reload
|
||||||
|
|
||||||
|
## Step 6: Core Functionality -- Pull Requests
|
||||||
|
|
||||||
|
1. Navigate to the PRs tab (`/pulls`)
|
||||||
|
2. **Expected**: Pull requests load with review status icons
|
||||||
|
3. Tap on a PR to see details
|
||||||
|
4. **Expected**: PR diff summary or review status displays correctly
|
||||||
|
|
||||||
|
## Step 7: Core Functionality -- Dashboard / Triage Queue
|
||||||
|
|
||||||
|
1. Navigate to the Dashboard/Triage tab (`/`)
|
||||||
|
2. **Expected**: Unassigned issues and PRs awaiting review appear sorted by priority
|
||||||
|
|
||||||
|
## Step 8: Create Issue (Write Operation)
|
||||||
|
|
||||||
|
1. Navigate to the new issue form
|
||||||
|
2. Fill in title: `[smoke-test] Automated verification`
|
||||||
|
3. Fill in body: `This issue was created during smoke testing. Safe to close.`
|
||||||
|
4. Submit the form
|
||||||
|
5. **Expected**: Issue is created successfully in Gitea
|
||||||
|
6. Verify in Gitea web UI that the issue exists
|
||||||
|
7. Close and delete the test issue after verification
|
||||||
|
|
||||||
|
## Step 9: Apply Label (Write Operation)
|
||||||
|
|
||||||
|
1. On any test issue, attempt to apply a label
|
||||||
|
2. **Expected**: Label is applied via the Gitea API and reflected in the UI
|
||||||
|
|
||||||
|
## Step 10: PWA / iPhone Safari
|
||||||
|
|
||||||
|
1. Open `https://gitea-mobile.testing.leeworks.dev` on iPhone Safari
|
||||||
|
2. **Expected**: App loads with mobile-optimized layout, no horizontal scroll
|
||||||
|
3. Tap "Add to Home Screen" from the Safari share menu
|
||||||
|
4. **Expected**: App icon appears on the home screen (apple-touch-icon)
|
||||||
|
5. Launch from the home screen
|
||||||
|
6. **Expected**: App opens in standalone mode (no Safari browser chrome)
|
||||||
|
7. Verify bottom navigation does not overlap with iPhone home indicator
|
||||||
|
8. Toggle device dark mode in Settings
|
||||||
|
9. **Expected**: App switches between dark and light themes via `prefers-color-scheme`
|
||||||
|
10. See issue #93 for the full PWA validation checklist
|
||||||
|
|
||||||
|
## Expected Results Summary
|
||||||
|
|
||||||
|
| Step | Check | Expected |
|
||||||
|
|------|-------|----------|
|
||||||
|
| 1 | Pod status | Running, Ready 1/1 |
|
||||||
|
| 2 | `/health` | HTTP 200 |
|
||||||
|
| 3 | TLS | Valid cert, HTML response |
|
||||||
|
| 4 | Auth | Token saved, API calls work |
|
||||||
|
| 5 | Issues | List loads, filter works |
|
||||||
|
| 6 | PRs | List loads with review status |
|
||||||
|
| 7 | Dashboard/Triage | Queue displays correctly at `/` |
|
||||||
|
| 8 | Create issue | Issue created in Gitea |
|
||||||
|
| 9 | Apply label | Label applied via API |
|
||||||
|
| 10 | PWA | Standalone mode, safe areas, dark mode |
|
||||||
|
|
||||||
|
## Rollback Procedure
|
||||||
|
|
||||||
|
If the deployment is broken or the app is not functioning:
|
||||||
|
|
||||||
|
```bash
|
||||||
|
# Roll back to the previous deployment revision
|
||||||
|
kubectl rollout undo deployment/gitea-mobile -n gitea-mobile
|
||||||
|
|
||||||
|
# Verify the rollback
|
||||||
|
kubectl rollout status deployment/gitea-mobile -n gitea-mobile
|
||||||
|
# Expected: "deployment successfully rolled out"
|
||||||
|
|
||||||
|
# Check that the previous image tag is running
|
||||||
|
kubectl get deployment gitea-mobile -n gitea-mobile -o jsonpath='{.spec.template.spec.containers[0].image}'
|
||||||
|
```
|
||||||
|
|
||||||
|
If FluxCD keeps reconciling back to the broken version, suspend reconciliation temporarily:
|
||||||
|
|
||||||
|
```bash
|
||||||
|
# Suspend Flux reconciliation
|
||||||
|
flux suspend kustomization gitea-mobile -n flux-system
|
||||||
|
|
||||||
|
# After fixing the issue, resume
|
||||||
|
flux resume kustomization gitea-mobile -n flux-system
|
||||||
|
```
|
||||||
+32
-1
@@ -1,10 +1,14 @@
|
|||||||
package main
|
package main
|
||||||
|
|
||||||
import (
|
import (
|
||||||
|
"context"
|
||||||
"log"
|
"log"
|
||||||
"log/slog"
|
"log/slog"
|
||||||
"net/http"
|
"net/http"
|
||||||
"os"
|
"os"
|
||||||
|
"os/signal"
|
||||||
|
"syscall"
|
||||||
|
"time"
|
||||||
|
|
||||||
"gitea.leeworks.dev/0xwheatyz/gitea-mobile/internal/config"
|
"gitea.leeworks.dev/0xwheatyz/gitea-mobile/internal/config"
|
||||||
giteaclient "gitea.leeworks.dev/0xwheatyz/gitea-mobile/internal/gitea"
|
giteaclient "gitea.leeworks.dev/0xwheatyz/gitea-mobile/internal/gitea"
|
||||||
@@ -36,8 +40,35 @@ func main() {
|
|||||||
handler = middleware.Auth(cfg.SessionSecret, cfg.GiteaToken)(handler)
|
handler = middleware.Auth(cfg.SessionSecret, cfg.GiteaToken)(handler)
|
||||||
handler = middleware.Logging()(handler)
|
handler = middleware.Logging()(handler)
|
||||||
|
|
||||||
|
srv := &http.Server{
|
||||||
|
Addr: cfg.ListenAddr,
|
||||||
|
Handler: handler,
|
||||||
|
}
|
||||||
|
|
||||||
|
// Channel to receive shutdown signals.
|
||||||
|
quit := make(chan os.Signal, 1)
|
||||||
|
signal.Notify(quit, syscall.SIGTERM, syscall.SIGINT)
|
||||||
|
|
||||||
|
// Start server in a goroutine.
|
||||||
|
go func() {
|
||||||
slog.Info("server starting", "addr", cfg.ListenAddr, "gitea_url", cfg.GiteaURL)
|
slog.Info("server starting", "addr", cfg.ListenAddr, "gitea_url", cfg.GiteaURL)
|
||||||
if err := http.ListenAndServe(cfg.ListenAddr, handler); err != nil {
|
if err := srv.ListenAndServe(); err != nil && err != http.ErrServerClosed {
|
||||||
log.Fatalf("server error: %v", err)
|
log.Fatalf("server error: %v", err)
|
||||||
}
|
}
|
||||||
|
}()
|
||||||
|
|
||||||
|
// Block until a shutdown signal is received.
|
||||||
|
sig := <-quit
|
||||||
|
slog.Info("shutdown signal received, draining in-flight requests", "signal", sig.String())
|
||||||
|
|
||||||
|
// Give in-flight requests up to 15 seconds to complete.
|
||||||
|
ctx, cancel := context.WithTimeout(context.Background(), 15*time.Second)
|
||||||
|
defer cancel()
|
||||||
|
|
||||||
|
if err := srv.Shutdown(ctx); err != nil {
|
||||||
|
slog.Error("server forced to shutdown", "error", err)
|
||||||
|
os.Exit(1)
|
||||||
|
}
|
||||||
|
|
||||||
|
slog.Info("server stopped gracefully")
|
||||||
}
|
}
|
||||||
|
|||||||
@@ -760,6 +760,33 @@ func (c *Client) GetPull(ctx context.Context, token, owner, repo string, index i
|
|||||||
return &pr, nil
|
return &pr, nil
|
||||||
}
|
}
|
||||||
|
|
||||||
|
// ChangedFile represents a file changed in a pull request.
|
||||||
|
type ChangedFile struct {
|
||||||
|
Filename string `json:"filename"`
|
||||||
|
Status string `json:"status"` // "added", "modified", "removed", "renamed"
|
||||||
|
Additions int `json:"additions"`
|
||||||
|
Deletions int `json:"deletions"`
|
||||||
|
Changes int `json:"changes"`
|
||||||
|
PreviousFilename string `json:"previous_filename,omitempty"`
|
||||||
|
}
|
||||||
|
|
||||||
|
// GetChangedFiles fetches the list of files changed in a pull request.
|
||||||
|
func (c *Client) GetChangedFiles(ctx context.Context, token, owner, repo string, index int64) ([]ChangedFile, error) {
|
||||||
|
path := fmt.Sprintf("/repos/%s/%s/pulls/%d/files?limit=50", owner, repo, index)
|
||||||
|
resp, err := c.doRequest(ctx, token, http.MethodGet, path, nil)
|
||||||
|
if err != nil {
|
||||||
|
return nil, fmt.Errorf("fetching changed files: %w", err)
|
||||||
|
}
|
||||||
|
defer resp.Body.Close()
|
||||||
|
|
||||||
|
var files []ChangedFile
|
||||||
|
if err := json.NewDecoder(resp.Body).Decode(&files); err != nil {
|
||||||
|
return nil, fmt.Errorf("decoding changed files: %w", err)
|
||||||
|
}
|
||||||
|
|
||||||
|
return files, nil
|
||||||
|
}
|
||||||
|
|
||||||
// GetIssueComments fetches comments for an issue or pull request.
|
// GetIssueComments fetches comments for an issue or pull request.
|
||||||
func (c *Client) GetIssueComments(ctx context.Context, token, owner, repo string, index int64) ([]Comment, error) {
|
func (c *Client) GetIssueComments(ctx context.Context, token, owner, repo string, index int64) ([]Comment, error) {
|
||||||
path := fmt.Sprintf("/repos/%s/%s/issues/%d/comments?limit=50", owner, repo, index)
|
path := fmt.Sprintf("/repos/%s/%s/issues/%d/comments?limit=50", owner, repo, index)
|
||||||
@@ -945,6 +972,40 @@ func (c *Client) SetIssueState(ctx context.Context, token, owner, repo string, i
|
|||||||
return nil
|
return nil
|
||||||
}
|
}
|
||||||
|
|
||||||
|
// MergePull merges a pull request using the specified merge style.
|
||||||
|
// Valid styles: "merge", "rebase", "rebase-merge", "squash".
|
||||||
|
// If style is empty, defaults to "merge".
|
||||||
|
func (c *Client) MergePull(ctx context.Context, token, owner, repo string, index int64, style, title, message string) error {
|
||||||
|
if style == "" {
|
||||||
|
style = "merge"
|
||||||
|
}
|
||||||
|
|
||||||
|
payload := map[string]string{
|
||||||
|
"Do": style,
|
||||||
|
}
|
||||||
|
if title != "" {
|
||||||
|
payload["merge_message_field"] = title
|
||||||
|
}
|
||||||
|
if message != "" {
|
||||||
|
payload["merge_message_field"] = message
|
||||||
|
}
|
||||||
|
|
||||||
|
jsonData, err := json.Marshal(payload)
|
||||||
|
if err != nil {
|
||||||
|
return fmt.Errorf("marshaling merge request: %w", err)
|
||||||
|
}
|
||||||
|
|
||||||
|
path := fmt.Sprintf("/repos/%s/%s/pulls/%d/merge", owner, repo, index)
|
||||||
|
resp, err := c.doRequest(ctx, token, http.MethodPost, path, strings.NewReader(string(jsonData)))
|
||||||
|
if err != nil {
|
||||||
|
return fmt.Errorf("merging pull request: %w", err)
|
||||||
|
}
|
||||||
|
resp.Body.Close()
|
||||||
|
|
||||||
|
c.InvalidateAll()
|
||||||
|
return nil
|
||||||
|
}
|
||||||
|
|
||||||
// AddComment creates a comment on an issue and returns the created Comment.
|
// AddComment creates a comment on an issue and returns the created Comment.
|
||||||
func (c *Client) AddComment(ctx context.Context, token, owner, repo string, index int64, body string) (*Comment, error) {
|
func (c *Client) AddComment(ctx context.Context, token, owner, repo string, index int64, body string) (*Comment, error) {
|
||||||
return c.PostComment(ctx, token, owner, repo, index, body)
|
return c.PostComment(ctx, token, owner, repo, index, body)
|
||||||
|
|||||||
@@ -1456,3 +1456,141 @@ func TestRetryDelay_ExponentialBackoff(t *testing.T) {
|
|||||||
}
|
}
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
|
func TestGetChangedFiles(t *testing.T) {
|
||||||
|
server := httptest.NewServer(http.HandlerFunc(func(w http.ResponseWriter, r *http.Request) {
|
||||||
|
if r.Method != http.MethodGet {
|
||||||
|
t.Errorf("expected GET, got %s", r.Method)
|
||||||
|
}
|
||||||
|
if r.URL.Path != "/api/v1/repos/owner1/repo1/pulls/5/files" {
|
||||||
|
t.Errorf("unexpected path: %s", r.URL.Path)
|
||||||
|
}
|
||||||
|
if r.Header.Get("Authorization") != "token test-token" {
|
||||||
|
t.Error("missing or wrong Authorization header")
|
||||||
|
}
|
||||||
|
|
||||||
|
files := []ChangedFile{
|
||||||
|
{Filename: "main.go", Status: "modified", Additions: 10, Deletions: 3, Changes: 13},
|
||||||
|
{Filename: "new_file.go", Status: "added", Additions: 25, Deletions: 0, Changes: 25},
|
||||||
|
{Filename: "old_file.go", Status: "removed", Additions: 0, Deletions: 15, Changes: 15},
|
||||||
|
}
|
||||||
|
json.NewEncoder(w).Encode(files)
|
||||||
|
}))
|
||||||
|
defer server.Close()
|
||||||
|
|
||||||
|
c := NewClient(server.URL)
|
||||||
|
files, err := c.GetChangedFiles(context.Background(), "test-token", "owner1", "repo1", 5)
|
||||||
|
if err != nil {
|
||||||
|
t.Fatalf("unexpected error: %v", err)
|
||||||
|
}
|
||||||
|
if len(files) != 3 {
|
||||||
|
t.Fatalf("got %d files, want 3", len(files))
|
||||||
|
}
|
||||||
|
if files[0].Filename != "main.go" {
|
||||||
|
t.Errorf("files[0].Filename = %q, want %q", files[0].Filename, "main.go")
|
||||||
|
}
|
||||||
|
if files[0].Status != "modified" {
|
||||||
|
t.Errorf("files[0].Status = %q, want %q", files[0].Status, "modified")
|
||||||
|
}
|
||||||
|
if files[1].Status != "added" {
|
||||||
|
t.Errorf("files[1].Status = %q, want %q", files[1].Status, "added")
|
||||||
|
}
|
||||||
|
if files[2].Status != "removed" {
|
||||||
|
t.Errorf("files[2].Status = %q, want %q", files[2].Status, "removed")
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
|
func TestGetChangedFiles_Error(t *testing.T) {
|
||||||
|
server := httptest.NewServer(http.HandlerFunc(func(w http.ResponseWriter, r *http.Request) {
|
||||||
|
w.WriteHeader(http.StatusNotFound)
|
||||||
|
fmt.Fprintln(w, `{"message":"pull request not found"}`)
|
||||||
|
}))
|
||||||
|
defer server.Close()
|
||||||
|
|
||||||
|
c := NewClient(server.URL)
|
||||||
|
_, err := c.GetChangedFiles(context.Background(), "test-token", "owner1", "repo1", 999)
|
||||||
|
if err == nil {
|
||||||
|
t.Fatal("expected error for 404 response, got nil")
|
||||||
|
}
|
||||||
|
if !strings.Contains(err.Error(), "404") {
|
||||||
|
t.Errorf("error should contain status code 404, got: %v", err)
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
|
func TestMergePull(t *testing.T) {
|
||||||
|
server := httptest.NewServer(http.HandlerFunc(func(w http.ResponseWriter, r *http.Request) {
|
||||||
|
if r.Method != http.MethodPost {
|
||||||
|
t.Errorf("expected POST, got %s", r.Method)
|
||||||
|
}
|
||||||
|
if r.URL.Path != "/api/v1/repos/owner1/repo1/pulls/5/merge" {
|
||||||
|
t.Errorf("unexpected path: %s", r.URL.Path)
|
||||||
|
}
|
||||||
|
if r.Header.Get("Authorization") != "token test-token" {
|
||||||
|
t.Error("missing or wrong Authorization header")
|
||||||
|
}
|
||||||
|
|
||||||
|
var body map[string]string
|
||||||
|
if err := json.NewDecoder(r.Body).Decode(&body); err != nil {
|
||||||
|
t.Fatalf("failed to decode body: %v", err)
|
||||||
|
}
|
||||||
|
if body["Do"] != "squash" {
|
||||||
|
t.Errorf("expected Do=squash, got %q", body["Do"])
|
||||||
|
}
|
||||||
|
|
||||||
|
w.WriteHeader(http.StatusOK)
|
||||||
|
}))
|
||||||
|
defer server.Close()
|
||||||
|
|
||||||
|
c := NewClient(server.URL)
|
||||||
|
c.setCache("pulls-org1", "should-be-invalidated")
|
||||||
|
|
||||||
|
err := c.MergePull(context.Background(), "test-token", "owner1", "repo1", 5, "squash", "", "")
|
||||||
|
if err != nil {
|
||||||
|
t.Fatalf("unexpected error: %v", err)
|
||||||
|
}
|
||||||
|
|
||||||
|
// Verify cache was invalidated.
|
||||||
|
_, ok := c.getFromCache("pulls-org1")
|
||||||
|
if ok {
|
||||||
|
t.Error("expected cache to be invalidated after MergePull")
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
|
func TestMergePull_DefaultStyle(t *testing.T) {
|
||||||
|
var receivedStyle string
|
||||||
|
server := httptest.NewServer(http.HandlerFunc(func(w http.ResponseWriter, r *http.Request) {
|
||||||
|
var body map[string]string
|
||||||
|
if err := json.NewDecoder(r.Body).Decode(&body); err != nil {
|
||||||
|
t.Fatalf("failed to decode body: %v", err)
|
||||||
|
}
|
||||||
|
receivedStyle = body["Do"]
|
||||||
|
w.WriteHeader(http.StatusOK)
|
||||||
|
}))
|
||||||
|
defer server.Close()
|
||||||
|
|
||||||
|
c := NewClient(server.URL)
|
||||||
|
err := c.MergePull(context.Background(), "test-token", "owner1", "repo1", 5, "", "", "")
|
||||||
|
if err != nil {
|
||||||
|
t.Fatalf("unexpected error: %v", err)
|
||||||
|
}
|
||||||
|
if receivedStyle != "merge" {
|
||||||
|
t.Errorf("expected default style 'merge', got %q", receivedStyle)
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
|
func TestMergePull_Error(t *testing.T) {
|
||||||
|
server := httptest.NewServer(http.HandlerFunc(func(w http.ResponseWriter, r *http.Request) {
|
||||||
|
w.WriteHeader(http.StatusMethodNotAllowed)
|
||||||
|
fmt.Fprintln(w, `{"message":"not mergeable"}`)
|
||||||
|
}))
|
||||||
|
defer server.Close()
|
||||||
|
|
||||||
|
c := NewClient(server.URL)
|
||||||
|
err := c.MergePull(context.Background(), "test-token", "owner1", "repo1", 5, "merge", "", "")
|
||||||
|
if err == nil {
|
||||||
|
t.Fatal("expected error for 405 response, got nil")
|
||||||
|
}
|
||||||
|
if !strings.Contains(err.Error(), "405") {
|
||||||
|
t.Errorf("error should contain status code 405, got: %v", err)
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|||||||
@@ -78,6 +78,31 @@ func getToken(r *http.Request) string {
|
|||||||
return middleware.TokenFromContext(r.Context())
|
return middleware.TokenFromContext(r.Context())
|
||||||
}
|
}
|
||||||
|
|
||||||
|
// isTokenError returns true if the error indicates an expired or revoked API token.
|
||||||
|
func isTokenError(err error) bool {
|
||||||
|
if err == nil {
|
||||||
|
return false
|
||||||
|
}
|
||||||
|
msg := err.Error()
|
||||||
|
return strings.Contains(msg, "API error 401") || strings.Contains(msg, "API error 403")
|
||||||
|
}
|
||||||
|
|
||||||
|
// redirectOnTokenError checks if the error is a token auth error and redirects
|
||||||
|
// to /settings with an error banner. Returns true if a redirect was performed.
|
||||||
|
func redirectOnTokenError(w http.ResponseWriter, r *http.Request, err error) bool {
|
||||||
|
if !isTokenError(err) {
|
||||||
|
return false
|
||||||
|
}
|
||||||
|
slog.Warn("Gitea API token expired or revoked, redirecting to settings", "error", err)
|
||||||
|
if isHTMX(r) {
|
||||||
|
w.Header().Set("HX-Redirect", "/settings?error=token_expired")
|
||||||
|
w.WriteHeader(http.StatusOK)
|
||||||
|
} else {
|
||||||
|
http.Redirect(w, r, "/settings?error=token_expired", http.StatusSeeOther)
|
||||||
|
}
|
||||||
|
return true
|
||||||
|
}
|
||||||
|
|
||||||
// getUserOrgs returns the list of org names the user belongs to.
|
// getUserOrgs returns the list of org names the user belongs to.
|
||||||
func (h *Handler) getUserOrgs(r *http.Request) []string {
|
func (h *Handler) getUserOrgs(r *http.Request) []string {
|
||||||
token := getToken(r)
|
token := getToken(r)
|
||||||
@@ -263,6 +288,9 @@ func (h *Handler) Dashboard(w http.ResponseWriter, r *http.Request) {
|
|||||||
|
|
||||||
queue, err := h.Client.GetTriageQueue(r.Context(), token, queryOrgs)
|
queue, err := h.Client.GetTriageQueue(r.Context(), token, queryOrgs)
|
||||||
if err != nil {
|
if err != nil {
|
||||||
|
if redirectOnTokenError(w, r, err) {
|
||||||
|
return
|
||||||
|
}
|
||||||
slog.Error("failed to get triage queue", "error", err)
|
slog.Error("failed to get triage queue", "error", err)
|
||||||
data.Error = "Error loading triage queue."
|
data.Error = "Error loading triage queue."
|
||||||
} else {
|
} else {
|
||||||
@@ -346,6 +374,9 @@ func (h *Handler) ListIssues(w http.ResponseWriter, r *http.Request) {
|
|||||||
|
|
||||||
result, err := h.Client.ListAllIssues(r.Context(), token, queryOrgs, selectedState, page, selectedLabel, selectedRepo)
|
result, err := h.Client.ListAllIssues(r.Context(), token, queryOrgs, selectedState, page, selectedLabel, selectedRepo)
|
||||||
if err != nil {
|
if err != nil {
|
||||||
|
if redirectOnTokenError(w, r, err) {
|
||||||
|
return
|
||||||
|
}
|
||||||
slog.Error("failed to list issues", "error", err)
|
slog.Error("failed to list issues", "error", err)
|
||||||
data.Error = "Error loading issues."
|
data.Error = "Error loading issues."
|
||||||
} else {
|
} else {
|
||||||
@@ -451,6 +482,9 @@ func (h *Handler) ListPulls(w http.ResponseWriter, r *http.Request) {
|
|||||||
|
|
||||||
result, err := h.Client.ListAllPullRequests(r.Context(), token, queryOrgs, selectedState, page, selectedLabel, selectedRepo)
|
result, err := h.Client.ListAllPullRequests(r.Context(), token, queryOrgs, selectedState, page, selectedLabel, selectedRepo)
|
||||||
if err != nil {
|
if err != nil {
|
||||||
|
if redirectOnTokenError(w, r, err) {
|
||||||
|
return
|
||||||
|
}
|
||||||
slog.Error("failed to list pull requests", "error", err)
|
slog.Error("failed to list pull requests", "error", err)
|
||||||
data.Error = "Error loading pull requests."
|
data.Error = "Error loading pull requests."
|
||||||
} else {
|
} else {
|
||||||
|
|||||||
@@ -45,6 +45,13 @@ func (h *SettingsHandler) handleGet(w http.ResponseWriter, r *http.Request) {
|
|||||||
}
|
}
|
||||||
|
|
||||||
data := settingsData{HasToken: hasToken}
|
data := settingsData{HasToken: hasToken}
|
||||||
|
|
||||||
|
// Show error banner when redirected due to expired/revoked token.
|
||||||
|
if r.URL.Query().Get("error") == "token_expired" {
|
||||||
|
data.Message = "Your Gitea API token is expired or has been revoked. Please enter a new token."
|
||||||
|
data.MessageType = "error"
|
||||||
|
}
|
||||||
|
|
||||||
h.renderSettings(w, data)
|
h.renderSettings(w, data)
|
||||||
}
|
}
|
||||||
|
|
||||||
|
|||||||
@@ -1,6 +1,8 @@
|
|||||||
package middleware
|
package middleware
|
||||||
|
|
||||||
import (
|
import (
|
||||||
|
"crypto/rand"
|
||||||
|
"encoding/hex"
|
||||||
"log/slog"
|
"log/slog"
|
||||||
"net/http"
|
"net/http"
|
||||||
"time"
|
"time"
|
||||||
@@ -17,21 +19,39 @@ func (rw *responseWriter) WriteHeader(code int) {
|
|||||||
rw.ResponseWriter.WriteHeader(code)
|
rw.ResponseWriter.WriteHeader(code)
|
||||||
}
|
}
|
||||||
|
|
||||||
// Logging returns middleware that logs each HTTP request with structured logging.
|
// generateRequestID creates a short random hex string for request tracing.
|
||||||
|
func generateRequestID() string {
|
||||||
|
b := make([]byte, 8)
|
||||||
|
if _, err := rand.Read(b); err != nil {
|
||||||
|
return "unknown"
|
||||||
|
}
|
||||||
|
return hex.EncodeToString(b)
|
||||||
|
}
|
||||||
|
|
||||||
|
// Logging returns middleware that logs each HTTP request with structured fields:
|
||||||
|
// method, path, status, duration (ms), request-id, and remote address.
|
||||||
func Logging() func(http.Handler) http.Handler {
|
func Logging() func(http.Handler) http.Handler {
|
||||||
return func(next http.Handler) http.Handler {
|
return func(next http.Handler) http.Handler {
|
||||||
return http.HandlerFunc(func(w http.ResponseWriter, r *http.Request) {
|
return http.HandlerFunc(func(w http.ResponseWriter, r *http.Request) {
|
||||||
start := time.Now()
|
start := time.Now()
|
||||||
|
requestID := generateRequestID()
|
||||||
rw := &responseWriter{ResponseWriter: w, statusCode: http.StatusOK}
|
rw := &responseWriter{ResponseWriter: w, statusCode: http.StatusOK}
|
||||||
|
|
||||||
|
// Set request ID header for downstream correlation.
|
||||||
|
w.Header().Set("X-Request-ID", requestID)
|
||||||
|
|
||||||
next.ServeHTTP(rw, r)
|
next.ServeHTTP(rw, r)
|
||||||
|
|
||||||
|
duration := time.Since(start)
|
||||||
slog.Info("http request",
|
slog.Info("http request",
|
||||||
"method", r.Method,
|
"method", r.Method,
|
||||||
"path", r.URL.Path,
|
"path", r.URL.Path,
|
||||||
"status", rw.statusCode,
|
"status", rw.statusCode,
|
||||||
"duration", time.Since(start).String(),
|
"duration_ms", duration.Milliseconds(),
|
||||||
|
"duration", duration.String(),
|
||||||
|
"request_id", requestID,
|
||||||
"remote", r.RemoteAddr,
|
"remote", r.RemoteAddr,
|
||||||
|
"user_agent", r.UserAgent(),
|
||||||
)
|
)
|
||||||
})
|
})
|
||||||
}
|
}
|
||||||
|
|||||||
@@ -14,7 +14,7 @@
|
|||||||
</span>
|
</span>
|
||||||
<span>{{.Issue.RepoOwner}}/{{.Issue.RepoName}} #{{.Issue.Number}}</span>
|
<span>{{.Issue.RepoOwner}}/{{.Issue.RepoName}} #{{.Issue.Number}}</span>
|
||||||
{{range .Issue.Labels}}
|
{{range .Issue.Labels}}
|
||||||
<span class="label" style="color:#{{.Color}};border:1px solid #{{.Color}}">{{.Name}}</span>
|
<span class="label label-pill" style="background-color:#{{.Color}};color:#fff;border:1px solid #{{.Color}}">{{.Name}}</span>
|
||||||
{{end}}
|
{{end}}
|
||||||
</div>
|
</div>
|
||||||
{{if .RenderedBody}}
|
{{if .RenderedBody}}
|
||||||
|
|||||||
@@ -5,7 +5,7 @@
|
|||||||
<div class="card-meta">
|
<div class="card-meta">
|
||||||
<span>{{.RepoOwner}}/{{.RepoName}} #{{.Number}}</span>
|
<span>{{.RepoOwner}}/{{.RepoName}} #{{.Number}}</span>
|
||||||
{{range .Labels}}
|
{{range .Labels}}
|
||||||
<span class="label" style="color:#{{.Color}};border:1px solid #{{.Color}}">{{.Name}}</span>
|
<span class="label label-pill" style="background-color:#{{.Color}};color:#fff;border:1px solid #{{.Color}}">{{.Name}}</span>
|
||||||
{{end}}
|
{{end}}
|
||||||
{{if .Assignee}}
|
{{if .Assignee}}
|
||||||
<img src="{{.Assignee.AvatarURL}}" alt="{{.Assignee.Login}}" class="avatar" title="Assigned to {{.Assignee.Login}}">
|
<img src="{{.Assignee.AvatarURL}}" alt="{{.Assignee.Login}}" class="avatar" title="Assigned to {{.Assignee.Login}}">
|
||||||
|
|||||||
@@ -7,7 +7,7 @@
|
|||||||
{{if eq .Pull.State "closed"}}<span class="state-closed">{{.Pull.State}}</span>{{else}}<span class="state-open">{{.Pull.State}}</span>{{end}}
|
{{if eq .Pull.State "closed"}}<span class="state-closed">{{.Pull.State}}</span>{{else}}<span class="state-open">{{.Pull.State}}</span>{{end}}
|
||||||
<span>{{.Pull.RepoOwner}}/{{.Pull.RepoName}} #{{.Pull.Number}}</span>
|
<span>{{.Pull.RepoOwner}}/{{.Pull.RepoName}} #{{.Pull.Number}}</span>
|
||||||
{{range .Pull.Labels}}
|
{{range .Pull.Labels}}
|
||||||
<span class="label" style="color:#{{.Color}};border:1px solid #{{.Color}}">{{.Name}}</span>
|
<span class="label label-pill" style="background-color:#{{.Color}};color:#fff;border:1px solid #{{.Color}}">{{.Name}}</span>
|
||||||
{{end}}
|
{{end}}
|
||||||
</div>
|
</div>
|
||||||
<div class="card-meta" style="margin-top:0.5rem;">
|
<div class="card-meta" style="margin-top:0.5rem;">
|
||||||
|
|||||||
@@ -8,7 +8,7 @@
|
|||||||
<div class="card-meta">
|
<div class="card-meta">
|
||||||
<span>{{.RepoOwner}}/{{.RepoName}} #{{.Number}}</span>
|
<span>{{.RepoOwner}}/{{.RepoName}} #{{.Number}}</span>
|
||||||
{{range .Labels}}
|
{{range .Labels}}
|
||||||
<span class="label" style="color:#{{.Color}};border:1px solid #{{.Color}}">{{.Name}}</span>
|
<span class="label label-pill" style="background-color:#{{.Color}};color:#fff;border:1px solid #{{.Color}}">{{.Name}}</span>
|
||||||
{{end}}
|
{{end}}
|
||||||
<span class="diff-add">+{{.Additions}}</span>
|
<span class="diff-add">+{{.Additions}}</span>
|
||||||
<span class="diff-del">-{{.Deletions}}</span>
|
<span class="diff-del">-{{.Deletions}}</span>
|
||||||
|
|||||||
@@ -176,6 +176,11 @@ a:active {
|
|||||||
white-space: nowrap;
|
white-space: nowrap;
|
||||||
}
|
}
|
||||||
|
|
||||||
|
.label-pill {
|
||||||
|
text-shadow: 0 1px 2px rgba(0, 0, 0, 0.4);
|
||||||
|
font-weight: 600;
|
||||||
|
}
|
||||||
|
|
||||||
.type-badge {
|
.type-badge {
|
||||||
font-size: 0.65rem;
|
font-size: 0.65rem;
|
||||||
text-transform: uppercase;
|
text-transform: uppercase;
|
||||||
|
|||||||
Reference in New Issue
Block a user