backgroundSleep: Use timex.Sleep

internal/timex/timeutil.go

@@ -1,6 +1,7 @@
 package timex
 
 import (
+	"context"
 	"sync"
 	"time"
 
@@ -41,3 +42,17 @@ func Equalish(old, new pgtype.Timestamptz) bool {
 	diff := old.Time.Sub(new.Time).Abs()
 	return diff < timeWindow
 }
+
+// Sleep is like time.Sleep, but it takes a context.
+// The return value is false
+// if the context cancelled before it could return.
+func Sleep(ctx context.Context, d time.Duration) bool {
+	timer := time.NewTimer(d)
+	defer timer.Stop()
+	select {
+	case <-timer.C:
+		return true
+	case <-ctx.Done():
+		return false
+	}
+}

pkg/api/routes-background.go

@@ -10,6 +10,7 @@ import (
 	"github.com/carlmjohnson/flowmatic"
 	"github.com/spotlightpa/almanack/internal/db"
 	"github.com/spotlightpa/almanack/internal/paginate"
+	"github.com/spotlightpa/almanack/internal/timex"
 	"github.com/spotlightpa/almanack/pkg/almanack"
 	"github.com/spotlightpa/almanack/pkg/almlog"
 )
@@ -27,10 +28,11 @@ func (app *appEnv) backgroundSleep(w http.ResponseWriter, r *http.Request) http.
 	if err != nil {
 		return app.jsonErr(err)
 	}
-	time.Sleep(duration)
+	ok := timex.Sleep(r.Context(), duration)
 	return app.jsonAccepted(struct {
 		SleptFor time.Duration `json:"slept-for"`
-	}{duration})
+		OK       bool          `json:"ok"`
+	}{duration, ok})
 }
 
 func (app *appEnv) backgroundCron(w http.ResponseWriter, r *http.Request) http.Handler {