mirror of
https://github.com/seaweedfs/seaweedfs.git
synced 2026-10-20 04:54:24 +02:00
Copilot
e3ef3a5b56
New package weed/s3api/s3lifecycle/ provides a pure-function lifecycle rule evaluation engine. The evaluator accepts flattened Rule structs and ObjectInfo metadata, and returns the appropriate Action. Components: - evaluator.go: Evaluate() for per-object actions with S3 priority ordering (delete marker > noncurrent version > current expiration), ShouldExpireNoncurrentVersion() with NewerNoncurrentVersions support, EvaluateMPUAbort() for multipart upload rules - filter.go: prefix, tag, and size-based filter matching - tags.go: ExtractTags() extracts S3 tags from filer Extended metadata, HasTagRules() for scan-time optimization - version_time.go: GetVersionTimestamp() extracts timestamps from SeaweedFS version IDs (both old and new format) Comprehensive test coverage: 54 tests covering all action types, filter combinations, edge cases, and version ID formats.
65 lines
1.8 KiB
Go
65 lines
1.8 KiB
Go
package s3lifecycle
|
|
|
|
import (
|
|
"fmt"
|
|
"math"
|
|
"testing"
|
|
"time"
|
|
)
|
|
|
|
func TestGetVersionTimestamp(t *testing.T) {
|
|
t.Run("new_format_inverted_timestamp", func(t *testing.T) {
|
|
// Simulate a new-format version ID (inverted timestamp above threshold).
|
|
now := time.Now()
|
|
inverted := math.MaxInt64 - now.UnixNano()
|
|
versionId := fmt.Sprintf("%016x", inverted) + "0000000000000000"
|
|
|
|
got := GetVersionTimestamp(versionId)
|
|
// Should recover the original timestamp within 1 second.
|
|
diff := got.Sub(now)
|
|
if diff < -time.Second || diff > time.Second {
|
|
t.Errorf("timestamp diff too large: %v (got %v, want ~%v)", diff, got, now)
|
|
}
|
|
})
|
|
|
|
t.Run("old_format_raw_timestamp", func(t *testing.T) {
|
|
// Simulate an old-format version ID (raw nanosecond timestamp below threshold).
|
|
// Use a timestamp from 2023 which would be below threshold.
|
|
ts := time.Date(2023, 6, 15, 12, 0, 0, 0, time.UTC)
|
|
versionId := fmt.Sprintf("%016x", ts.UnixNano()) + "abcdef0123456789"
|
|
|
|
got := GetVersionTimestamp(versionId)
|
|
if !got.Equal(ts) {
|
|
t.Errorf("expected %v, got %v", ts, got)
|
|
}
|
|
})
|
|
|
|
t.Run("null_version_id", func(t *testing.T) {
|
|
got := GetVersionTimestamp("null")
|
|
if !got.IsZero() {
|
|
t.Errorf("expected zero time for null version, got %v", got)
|
|
}
|
|
})
|
|
|
|
t.Run("empty_version_id", func(t *testing.T) {
|
|
got := GetVersionTimestamp("")
|
|
if !got.IsZero() {
|
|
t.Errorf("expected zero time for empty version, got %v", got)
|
|
}
|
|
})
|
|
|
|
t.Run("short_version_id", func(t *testing.T) {
|
|
got := GetVersionTimestamp("abc")
|
|
if !got.IsZero() {
|
|
t.Errorf("expected zero time for short version, got %v", got)
|
|
}
|
|
})
|
|
|
|
t.Run("invalid_hex", func(t *testing.T) {
|
|
got := GetVersionTimestamp("zzzzzzzzzzzzzzzz0000000000000000")
|
|
if !got.IsZero() {
|
|
t.Errorf("expected zero time for invalid hex, got %v", got)
|
|
}
|
|
})
|
|
}
|