github/containerd
2
0
Fork 0
Code Issues Pull Requests Packages Projects Releases 2 Wiki Activity

Refactor: Removing inherently flaky and unused SourceDateEpochOrNow function.

Browse Source 
Signed-off-by: BinBin He <BinSquare@users.noreply.github.com>
This commit is contained in:
BinBin He 2023-09-17 08:31:12 -07:00
parent 31b6cdfd10
commit 79f781d009
2 changed files with 0 additions and 43 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

15
pkg/epoch/epoch.go
View File

@ -22,8 +22,6 @@ import (
"os"
"strconv"
"time"
"github.com/containerd/containerd/log"
)
// SourceDateEpochEnv is the SOURCE_DATE_EPOCH env var.
@ -44,19 +42,6 @@ func SourceDateEpoch() (*time.Time, error) {
return t, nil
}
// SourceDateEpochOrNow returns the SOURCE_DATE_EPOCH time if available,
// otherwise returns the current time.
func SourceDateEpochOrNow() time.Time {
epoch, err := SourceDateEpoch()
if err != nil {
log.L.WithError(err).Warnf("Invalid %s", SourceDateEpochEnv)
}
if epoch != nil {
return *epoch
}
return time.Now().UTC()
}
// ParseSourceDateEpoch parses the given source date epoch, as *time.Time.
// It returns an error if sourceDateEpoch is empty or not well-formatted.
func ParseSourceDateEpoch(sourceDateEpoch string) (*time.Time, error) {

28
pkg/epoch/epoch_test.go
View File

@ -19,25 +19,12 @@ package epoch
import (
"fmt"
"os"
"runtime"
"testing"
"time"
"github.com/stretchr/testify/require"
)
func rightAfter(t1, t2 time.Time) bool {
if t2.Equal(t1) {
return true
}
threshold := 10 * time.Millisecond
if runtime.GOOS == "windows" {
// Low timer resolution on Windows
threshold *= 10
}
return t2.After(t1) && t2.Before(t1.Add(threshold))
}
func TestSourceDateEpoch(t *testing.T) {
if s, ok := os.LookupEnv(SourceDateEpochEnv); ok {
t.Logf("%s is already set to %q, unsetting", SourceDateEpochEnv, s)
@ -50,10 +37,6 @@ func TestSourceDateEpoch(t *testing.T) {
vp, err := SourceDateEpoch()
require.NoError(t, err)
require.Nil(t, vp)
now := time.Now().UTC()
v := SourceDateEpochOrNow()
require.True(t, rightAfter(now, v), "now: %s, v: %s", now, v)
})
t.Run("WithEmptySourceDateEpoch", func(t *testing.T) {
@ -67,10 +50,6 @@ func TestSourceDateEpoch(t *testing.T) {
vp, err = ParseSourceDateEpoch(emptyValue)
require.Error(t, err, "value is empty")
require.Nil(t, vp)
now := time.Now().UTC()
v := SourceDateEpochOrNow()
require.True(t, rightAfter(now, v), "now: %s, v: %s", now, v)
})
t.Run("WithSourceDateEpoch", func(t *testing.T) {
@ -88,9 +67,6 @@ func TestSourceDateEpoch(t *testing.T) {
vp, err = ParseSourceDateEpoch(fmt.Sprintf("%d", sourceDateEpoch.Unix()))
require.NoError(t, err)
require.True(t, vp.Equal(sourceDateEpoch))
v := SourceDateEpochOrNow()
require.True(t, v.Equal(sourceDateEpoch))
})
t.Run("WithInvalidSourceDateEpoch", func(t *testing.T) {
@ -104,9 +80,5 @@ func TestSourceDateEpoch(t *testing.T) {
vp, err = ParseSourceDateEpoch(invalidValue)
require.ErrorContains(t, err, "invalid value:")
require.Nil(t, vp)
now := time.Now().UTC()
v := SourceDateEpochOrNow()
require.True(t, rightAfter(now, v), "now: %s, v: %s", now, v)
})
}