ci: add quality checks and smoke tests

This commit is contained in:
2026-04-10 17:26:49 +02:00
parent 78909cd308
commit 9b46396f32
3 changed files with 227 additions and 0 deletions

36
.github/workflows/ci.yml vendored Normal file
View File

@@ -0,0 +1,36 @@
name: ci
on:
push:
branches:
- main
pull_request:
jobs:
quality:
runs-on: ubuntu-latest
steps:
- name: checkout
uses: actions/checkout@v4
- name: setup go
uses: actions/setup-go@v5
with:
go-version-file: go.mod
cache: true
- name: verify dependencies
run: go mod download
- name: vet
run: go vet ./...
- name: test
run: go test ./...
- name: build
run: go build ./...
- name: staticcheck
run: go run honnef.co/go/tools/cmd/staticcheck@latest ./...

View File

@@ -0,0 +1,125 @@
package watchlist
import (
"context"
"database/sql"
"testing"
"time"
"mal/internal/database"
)
type fakeQuerier struct {
database.Querier
upsertAnimeCalled bool
upsertEntryCalled bool
addRows []database.GetUserWatchListRow
}
func (f *fakeQuerier) UpsertAnime(ctx context.Context, arg database.UpsertAnimeParams) (database.Anime, error) {
f.upsertAnimeCalled = true
return database.Anime{}, nil
}
func (f *fakeQuerier) UpsertWatchListEntry(ctx context.Context, arg database.UpsertWatchListEntryParams) (database.WatchListEntry, error) {
f.upsertEntryCalled = true
return database.WatchListEntry{}, nil
}
func (f *fakeQuerier) GetUserWatchList(ctx context.Context, userID string) ([]database.GetUserWatchListRow, error) {
return f.addRows, nil
}
func TestAddEntry_RejectsInvalidAnimeID(t *testing.T) {
t.Parallel()
q := &fakeQuerier{}
svc := NewService(q)
err := svc.AddEntry(context.Background(), "user-1", AddRequest{
AnimeID: 0,
Status: "watching",
})
if err != ErrInvalidAnimeID {
t.Fatalf("expected ErrInvalidAnimeID, got %v", err)
}
if q.upsertAnimeCalled || q.upsertEntryCalled {
t.Fatal("expected no database writes for invalid anime id")
}
}
func TestAddEntry_RejectsInvalidStatus(t *testing.T) {
t.Parallel()
q := &fakeQuerier{}
svc := NewService(q)
err := svc.AddEntry(context.Background(), "user-1", AddRequest{
AnimeID: 1,
Status: "invalid",
})
if err != ErrInvalidStatus {
t.Fatalf("expected ErrInvalidStatus, got %v", err)
}
if q.upsertAnimeCalled || q.upsertEntryCalled {
t.Fatal("expected no database writes for invalid status")
}
}
func TestExport_UsesDisplayTitleFallbackOrder(t *testing.T) {
t.Parallel()
q := &fakeQuerier{
addRows: []database.GetUserWatchListRow{
{
AnimeID: 101,
TitleOriginal: "Original",
TitleEnglish: sql.NullString{String: "English", Valid: true},
Status: "watching",
ImageUrl: "https://img",
UpdatedAt: time.Date(2026, 1, 2, 3, 4, 5, 0, time.UTC),
},
{
AnimeID: 102,
TitleOriginal: "Original 2",
TitleJapanese: sql.NullString{String: "JP Title", Valid: true},
Status: "completed",
ImageUrl: "https://img2",
UpdatedAt: time.Date(2026, 1, 3, 3, 4, 5, 0, time.UTC),
},
{
AnimeID: 103,
TitleOriginal: "Original 3",
Status: "on_hold",
ImageUrl: "https://img3",
UpdatedAt: time.Date(2026, 1, 4, 3, 4, 5, 0, time.UTC),
},
},
}
svc := NewService(q)
export, err := svc.Export(context.Background(), "user-1")
if err != nil {
t.Fatalf("expected no error, got %v", err)
}
if len(export.Entries) != 3 {
t.Fatalf("expected 3 entries, got %d", len(export.Entries))
}
if export.Entries[0].Title != "English" {
t.Fatalf("expected english title first, got %q", export.Entries[0].Title)
}
if export.Entries[1].Title != "JP Title" {
t.Fatalf("expected japanese title fallback, got %q", export.Entries[1].Title)
}
if export.Entries[2].Title != "Original 3" {
t.Fatalf("expected original title fallback, got %q", export.Entries[2].Title)
}
}

View File

@@ -0,0 +1,66 @@
package middleware
import (
"context"
"net/http"
"net/http/httptest"
"testing"
"mal/internal/database"
)
func TestRequireAuth_UnauthenticatedAPIRequest(t *testing.T) {
t.Parallel()
h := RequireAuth(http.HandlerFunc(func(w http.ResponseWriter, r *http.Request) {
w.WriteHeader(http.StatusOK)
}))
req := httptest.NewRequest(http.MethodGet, "/api/watchlist", nil)
rec := httptest.NewRecorder()
h.ServeHTTP(rec, req)
if rec.Code != http.StatusUnauthorized {
t.Fatalf("expected status %d, got %d", http.StatusUnauthorized, rec.Code)
}
if got := rec.Header().Get("HX-Redirect"); got != "/login" {
t.Fatalf("expected HX-Redirect /login, got %q", got)
}
}
func TestRequireAuth_AuthenticatedRequestPassesThrough(t *testing.T) {
t.Parallel()
h := RequireAuth(http.HandlerFunc(func(w http.ResponseWriter, r *http.Request) {
w.WriteHeader(http.StatusNoContent)
}))
req := httptest.NewRequest(http.MethodGet, "/watchlist", nil)
ctx := context.WithValue(req.Context(), UserContextKey, &database.User{ID: "user-1"})
rec := httptest.NewRecorder()
h.ServeHTTP(rec, req.WithContext(ctx))
if rec.Code != http.StatusNoContent {
t.Fatalf("expected status %d, got %d", http.StatusNoContent, rec.Code)
}
}
func TestRequireGlobalAuth_AllowsPublicRoute(t *testing.T) {
t.Parallel()
h := RequireGlobalAuth(http.HandlerFunc(func(w http.ResponseWriter, r *http.Request) {
w.WriteHeader(http.StatusOK)
}))
req := httptest.NewRequest(http.MethodGet, "/", nil)
rec := httptest.NewRecorder()
h.ServeHTTP(rec, req)
if rec.Code != http.StatusOK {
t.Fatalf("expected status %d, got %d", http.StatusOK, rec.Code)
}
}