Compare commits
1 Commits
| Author | SHA1 | Date | |
|---|---|---|---|
| 3d1775a37b |
@@ -4,9 +4,6 @@ on:
|
|||||||
push:
|
push:
|
||||||
branches:
|
branches:
|
||||||
- master
|
- master
|
||||||
pull_request:
|
|
||||||
branches:
|
|
||||||
- master
|
|
||||||
|
|
||||||
jobs:
|
jobs:
|
||||||
test:
|
test:
|
||||||
@@ -27,7 +24,6 @@ jobs:
|
|||||||
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 go.sum ./
|
COPY go.mod ./
|
||||||
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
|
||||||
|
|||||||
+1
-32
@@ -1,14 +1,10 @@
|
|||||||
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"
|
||||||
@@ -40,35 +36,8 @@ 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 := srv.ListenAndServe(); err != nil && err != http.ErrServerClosed {
|
if err := http.ListenAndServe(cfg.ListenAddr, handler); err != nil {
|
||||||
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,33 +760,6 @@ 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)
|
||||||
|
|||||||
@@ -1457,66 +1457,6 @@ 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) {
|
func TestMergePull(t *testing.T) {
|
||||||
server := httptest.NewServer(http.HandlerFunc(func(w http.ResponseWriter, r *http.Request) {
|
server := httptest.NewServer(http.HandlerFunc(func(w http.ResponseWriter, r *http.Request) {
|
||||||
if r.Method != http.MethodPost {
|
if r.Method != http.MethodPost {
|
||||||
|
|||||||
@@ -78,31 +78,6 @@ 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)
|
||||||
@@ -288,9 +263,6 @@ 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 {
|
||||||
@@ -374,9 +346,6 @@ 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 {
|
||||||
@@ -482,9 +451,6 @@ 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,13 +45,6 @@ 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,8 +1,6 @@
|
|||||||
package middleware
|
package middleware
|
||||||
|
|
||||||
import (
|
import (
|
||||||
"crypto/rand"
|
|
||||||
"encoding/hex"
|
|
||||||
"log/slog"
|
"log/slog"
|
||||||
"net/http"
|
"net/http"
|
||||||
"time"
|
"time"
|
||||||
@@ -19,39 +17,21 @@ func (rw *responseWriter) WriteHeader(code int) {
|
|||||||
rw.ResponseWriter.WriteHeader(code)
|
rw.ResponseWriter.WriteHeader(code)
|
||||||
}
|
}
|
||||||
|
|
||||||
// generateRequestID creates a short random hex string for request tracing.
|
// Logging returns middleware that logs each HTTP request with structured logging.
|
||||||
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_ms", duration.Milliseconds(),
|
"duration", time.Since(start).String(),
|
||||||
"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 label-pill" style="background-color:#{{.Color}};color:#fff;border:1px solid #{{.Color}}">{{.Name}}</span>
|
<span class="label" style="color:#{{.Color}};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 label-pill" style="background-color:#{{.Color}};color:#fff;border:1px solid #{{.Color}}">{{.Name}}</span>
|
<span class="label" style="color:#{{.Color}};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 label-pill" style="background-color:#{{.Color}};color:#fff;border:1px solid #{{.Color}}">{{.Name}}</span>
|
<span class="label" style="color:#{{.Color}};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 label-pill" style="background-color:#{{.Color}};color:#fff;border:1px solid #{{.Color}}">{{.Name}}</span>
|
<span class="label" style="color:#{{.Color}};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,11 +176,6 @@ 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