check / check (push) Canceled after 0s
Service.Warm, the ImageCache interface, both GenerateSignedURL methods, signature.ParseParams, three functions of internal/magic, the image processor's lists of supported formats, IsEmpty and Count of the allowlist, ssrfSafeDialer, CacheStale, ErrCacheMiss, ErrNegativeCache, ImageResponse.LastModified and VariantStorage.Load had no caller outside tests. They are gone, with the tests that tested only them. The handlers tests sign their image URLs with generateSignedURL, a test helper that builds the URL as the removed generator did. The SSRF dialer tests call dialSSRFSafe with no operator blocklist, which is all ssrfSafeDialer did. ParseImageURL, MIMEToImageFormat, ContentStorage.Store and CleanExpired stay, as pixa calls them. Model: opus-5-5
408 lines
9.8 KiB
Go
408 lines
9.8 KiB
Go
package signature_test
|
|
|
|
import (
|
|
"errors"
|
|
"testing"
|
|
"time"
|
|
|
|
"sneak.berlin/go/pixa/internal/imagerequest"
|
|
"sneak.berlin/go/pixa/internal/signature"
|
|
)
|
|
|
|
// Shared fixture values used across the signature tests.
|
|
const (
|
|
testHost = "cdn.example.com"
|
|
testPath = "/photos/cat.jpg"
|
|
testFormatWebP = "webp"
|
|
testFormatPNG = "png"
|
|
testFitCover = "cover"
|
|
testFitContain = "contain"
|
|
)
|
|
|
|
func TestSigner_Sign(t *testing.T) {
|
|
t.Parallel()
|
|
|
|
signer := signature.New("test-secret-key")
|
|
|
|
req := &imagerequest.Request{
|
|
Source: imagerequest.Source{
|
|
Host: testHost,
|
|
Path: testPath,
|
|
Query: "",
|
|
},
|
|
Transform: imagerequest.Transform{
|
|
Size: imagerequest.Size{Width: 800, Height: 600},
|
|
Format: testFormatWebP,
|
|
},
|
|
Expires: time.Unix(1704067200, 0), // Fixed timestamp for reproducibility
|
|
}
|
|
|
|
sig1 := signer.Sign(req)
|
|
sig2 := signer.Sign(req)
|
|
|
|
// Same input should produce same signature
|
|
if sig1 != sig2 {
|
|
t.Errorf("Sign() produced different signatures for same input: %q vs %q",
|
|
sig1, sig2)
|
|
}
|
|
|
|
// Signature should be non-empty
|
|
if sig1 == "" {
|
|
t.Error("Sign() produced empty signature")
|
|
}
|
|
|
|
// Different input should produce different signature
|
|
req2 := &imagerequest.Request{
|
|
Source: imagerequest.Source{
|
|
Host: testHost,
|
|
Path: "/photos/dog.jpg", // Different path
|
|
Query: "",
|
|
},
|
|
Transform: imagerequest.Transform{
|
|
Size: imagerequest.Size{Width: 800, Height: 600},
|
|
Format: testFormatWebP,
|
|
},
|
|
Expires: time.Unix(1704067200, 0),
|
|
}
|
|
|
|
sig3 := signer.Sign(req2)
|
|
if sig1 == sig3 {
|
|
t.Error("Sign() produced same signature for different input")
|
|
}
|
|
}
|
|
|
|
// validVerifyRequest returns a fully-populated request that verifies
|
|
// successfully once signed.
|
|
func validVerifyRequest() *imagerequest.Request {
|
|
return &imagerequest.Request{
|
|
Source: imagerequest.Source{
|
|
Host: testHost,
|
|
Path: testPath,
|
|
},
|
|
Transform: imagerequest.Transform{
|
|
Size: imagerequest.Size{Width: 800, Height: 600},
|
|
Format: testFormatWebP,
|
|
},
|
|
Expires: time.Now().Add(1 * time.Hour),
|
|
}
|
|
}
|
|
|
|
type verifyCase struct {
|
|
name string
|
|
setup func() *imagerequest.Request
|
|
wantErr error
|
|
}
|
|
|
|
func verifyCases(signer *signature.Signer) []verifyCase {
|
|
return []verifyCase{
|
|
{
|
|
name: "valid signature",
|
|
setup: func() *imagerequest.Request {
|
|
req := validVerifyRequest()
|
|
req.Signature = signer.Sign(req)
|
|
|
|
return req
|
|
},
|
|
wantErr: nil,
|
|
},
|
|
{
|
|
name: "expired signature",
|
|
setup: func() *imagerequest.Request {
|
|
req := validVerifyRequest()
|
|
req.Expires = time.Now().Add(-1 * time.Hour)
|
|
req.Signature = signer.Sign(req)
|
|
|
|
return req
|
|
},
|
|
wantErr: signature.ErrExpired,
|
|
},
|
|
{
|
|
name: "invalid signature",
|
|
setup: func() *imagerequest.Request {
|
|
req := validVerifyRequest()
|
|
req.Signature = "invalid-signature"
|
|
|
|
return req
|
|
},
|
|
wantErr: signature.ErrInvalid,
|
|
},
|
|
{
|
|
name: "missing expiration",
|
|
setup: func() *imagerequest.Request {
|
|
req := validVerifyRequest()
|
|
req.Expires = time.Time{}
|
|
req.Signature = "some-signature"
|
|
|
|
return req
|
|
},
|
|
wantErr: signature.ErrMissingExpiration,
|
|
},
|
|
{
|
|
name: "tampered request",
|
|
setup: func() *imagerequest.Request {
|
|
req := validVerifyRequest()
|
|
req.Signature = signer.Sign(req)
|
|
req.Source.Path = "/photos/secret.jpg"
|
|
|
|
return req
|
|
},
|
|
wantErr: signature.ErrInvalid,
|
|
},
|
|
}
|
|
}
|
|
|
|
func TestSigner_Verify(t *testing.T) {
|
|
t.Parallel()
|
|
|
|
signer := signature.New("test-secret-key")
|
|
|
|
for _, tt := range verifyCases(signer) {
|
|
t.Run(tt.name, func(t *testing.T) {
|
|
t.Parallel()
|
|
|
|
req := tt.setup()
|
|
err := signer.Verify(req)
|
|
|
|
if tt.wantErr == nil {
|
|
if err != nil {
|
|
t.Errorf("Verify() unexpected error = %v", err)
|
|
}
|
|
|
|
return
|
|
}
|
|
|
|
if !errors.Is(err, tt.wantErr) {
|
|
t.Errorf("Verify() error = %v, wantErr %v", err, tt.wantErr)
|
|
}
|
|
})
|
|
}
|
|
}
|
|
|
|
type tamperCase struct {
|
|
name string
|
|
tamper func(r *imagerequest.Request)
|
|
}
|
|
|
|
// exactMatchTamperCases mutates one signed component per case; every
|
|
// mutation must cause verification to fail with ErrInvalid.
|
|
func exactMatchTamperCases() []tamperCase {
|
|
return []tamperCase{
|
|
{
|
|
name: "parent domain does not match subdomain",
|
|
tamper: func(r *imagerequest.Request) { r.Source.Host = "example.com" },
|
|
},
|
|
{
|
|
name: "subdomain does not match parent domain",
|
|
tamper: func(r *imagerequest.Request) { r.Source.Host = "images.cdn.example.com" },
|
|
},
|
|
{
|
|
name: "sibling subdomain does not match",
|
|
tamper: func(r *imagerequest.Request) { r.Source.Host = "images.example.com" },
|
|
},
|
|
{
|
|
name: "host with suffix appended does not match",
|
|
tamper: func(r *imagerequest.Request) { r.Source.Host = testHost + ".evil.com" },
|
|
},
|
|
{
|
|
name: "host with prefix does not match",
|
|
tamper: func(r *imagerequest.Request) { r.Source.Host = "evilcdn.example.com" },
|
|
},
|
|
{
|
|
name: "different path does not match",
|
|
tamper: func(r *imagerequest.Request) { r.Source.Path = "/photos/dog.jpg" },
|
|
},
|
|
{
|
|
name: "path suffix does not match",
|
|
tamper: func(r *imagerequest.Request) { r.Source.Path = testPath + "/extra" },
|
|
},
|
|
{
|
|
name: "path prefix does not match",
|
|
tamper: func(r *imagerequest.Request) { r.Source.Path = "/other" + testPath },
|
|
},
|
|
{
|
|
name: "different query does not match",
|
|
tamper: func(r *imagerequest.Request) { r.Source.Query = "token=xyz" },
|
|
},
|
|
{
|
|
name: "added query does not match empty query",
|
|
tamper: func(r *imagerequest.Request) { r.Source.Query = "extra=1" },
|
|
},
|
|
{
|
|
name: "removed query does not match",
|
|
tamper: func(r *imagerequest.Request) { r.Source.Query = "" },
|
|
},
|
|
{
|
|
name: "different width does not match",
|
|
tamper: func(r *imagerequest.Request) { r.Transform.Size.Width = 801 },
|
|
},
|
|
{
|
|
name: "different height does not match",
|
|
tamper: func(r *imagerequest.Request) { r.Transform.Size.Height = 601 },
|
|
},
|
|
{
|
|
name: "different format does not match",
|
|
tamper: func(r *imagerequest.Request) { r.Transform.Format = testFormatPNG },
|
|
},
|
|
}
|
|
}
|
|
|
|
// TestSigner_Verify_ExactMatchOnly verifies that signatures enforce exact
|
|
// matching on every URL component. No suffix matching, wildcard matching,
|
|
// or partial matching is supported.
|
|
func TestSigner_Verify_ExactMatchOnly(t *testing.T) {
|
|
t.Parallel()
|
|
|
|
signer := signature.New("test-secret-key")
|
|
|
|
// Base request that we'll sign, then tamper with individual fields.
|
|
baseReq := func() *imagerequest.Request {
|
|
req := &imagerequest.Request{
|
|
Source: imagerequest.Source{
|
|
Host: testHost,
|
|
Path: testPath,
|
|
Query: "token=abc",
|
|
},
|
|
Transform: imagerequest.Transform{
|
|
Size: imagerequest.Size{Width: 800, Height: 600},
|
|
Format: testFormatWebP,
|
|
},
|
|
Expires: time.Now().Add(1 * time.Hour),
|
|
}
|
|
req.Signature = signer.Sign(req)
|
|
|
|
return req
|
|
}
|
|
|
|
for _, tt := range exactMatchTamperCases() {
|
|
t.Run(tt.name, func(t *testing.T) {
|
|
t.Parallel()
|
|
|
|
req := baseReq()
|
|
tt.tamper(req)
|
|
|
|
err := signer.Verify(req)
|
|
if !errors.Is(err, signature.ErrInvalid) {
|
|
t.Errorf("Verify() = %v, want %v", err, signature.ErrInvalid)
|
|
}
|
|
})
|
|
}
|
|
|
|
// Verify the unmodified base request still passes
|
|
t.Run("unmodified request passes", func(t *testing.T) {
|
|
t.Parallel()
|
|
|
|
req := baseReq()
|
|
|
|
err := signer.Verify(req)
|
|
if err != nil {
|
|
t.Errorf("Verify() unmodified request failed: %v", err)
|
|
}
|
|
})
|
|
}
|
|
|
|
// TestSigner_Sign_ExactHostInData verifies that Sign uses the exact host
|
|
// string in the signature data, producing different signatures for
|
|
// suffix-related hosts.
|
|
func TestSigner_Sign_ExactHostInData(t *testing.T) {
|
|
t.Parallel()
|
|
|
|
signer := signature.New("test-secret-key")
|
|
|
|
hosts := []string{
|
|
testHost,
|
|
"example.com",
|
|
"images.example.com",
|
|
"images.cdn.example.com",
|
|
"cdn.example.com.evil.com",
|
|
}
|
|
|
|
sigs := make(map[string]string)
|
|
|
|
for _, host := range hosts {
|
|
req := &imagerequest.Request{
|
|
Source: imagerequest.Source{
|
|
Host: host,
|
|
Path: testPath,
|
|
Query: "",
|
|
},
|
|
Transform: imagerequest.Transform{
|
|
Size: imagerequest.Size{Width: 800, Height: 600},
|
|
Format: testFormatWebP,
|
|
},
|
|
Expires: time.Unix(1704067200, 0),
|
|
}
|
|
|
|
sig := signer.Sign(req)
|
|
if existing, ok := sigs[sig]; ok {
|
|
t.Errorf("hosts %q and %q produced the same signature", existing, host)
|
|
}
|
|
|
|
sigs[sig] = host
|
|
}
|
|
}
|
|
|
|
func TestSigner_DifferentKeys(t *testing.T) {
|
|
t.Parallel()
|
|
|
|
signer1 := signature.New("secret-key-1")
|
|
signer2 := signature.New("secret-key-2")
|
|
|
|
req := &imagerequest.Request{
|
|
Source: imagerequest.Source{
|
|
Host: testHost,
|
|
Path: testPath,
|
|
},
|
|
Transform: imagerequest.Transform{
|
|
Size: imagerequest.Size{Width: 800, Height: 600},
|
|
Format: testFormatWebP,
|
|
},
|
|
Expires: time.Now().Add(1 * time.Hour),
|
|
}
|
|
|
|
// Sign with key 1
|
|
req.Signature = signer1.Sign(req)
|
|
|
|
// Verify with key 1 should succeed
|
|
err := signer1.Verify(req)
|
|
if err != nil {
|
|
t.Errorf("Verify() with same key failed: %v", err)
|
|
}
|
|
|
|
// Verify with key 2 should fail
|
|
err = signer2.Verify(req)
|
|
if !errors.Is(err, signature.ErrInvalid) {
|
|
t.Errorf("Verify() with different key should fail, got: %v", err)
|
|
}
|
|
}
|
|
|
|
// TestSign_ReadmeQueryExample checks the signature, with the README's key, of
|
|
// the README's example of a source URL with a query, the image at
|
|
// https://cdn.example.com/img?url=https://origin.example.com/my%20cat.jpg.
|
|
func TestSign_ReadmeQueryExample(t *testing.T) {
|
|
t.Parallel()
|
|
|
|
signer := signature.New("example-signing-key-for-documentation")
|
|
|
|
req := imagerequest.Request{
|
|
Source: imagerequest.Source{
|
|
Host: testHost,
|
|
Path: "/img",
|
|
Query: "url=https://origin.example.com/my%20cat.jpg",
|
|
},
|
|
Transform: imagerequest.Transform{
|
|
Size: imagerequest.Size{Width: 800, Height: 600},
|
|
Format: testFormatWebP,
|
|
Quality: 85,
|
|
FitMode: testFitCover,
|
|
},
|
|
Expires: time.Unix(1704067200, 0),
|
|
}
|
|
|
|
const wantSig = "37aFa9GSVCZM1kRY9SzMOk2fOg_M7Wt5gKNR4xM-FYA="
|
|
|
|
gotSig := signer.Sign(&req)
|
|
if gotSig != wantSig {
|
|
t.Errorf("Sign() = %q, want %q", gotSig, wantSig)
|
|
}
|
|
}
|