summaryrefslogtreecommitdiff
path: root/internal/schedule/schedule.go
diff options
context:
space:
mode:
authorPaul Buetow <paul@buetow.org>2024-10-01 10:55:50 +0300
committerPaul Buetow <paul@buetow.org>2024-10-01 10:55:50 +0300
commitbc6a3e478a7e0efc12c30be9f74ef5c3ff7a63fb (patch)
treeb426efbe9de7dbd3e083263338380b3d97019f55 /internal/schedule/schedule.go
parent74bcb110cba9cd22b88c561115e332d500de7716 (diff)
some more foo
Diffstat (limited to 'internal/schedule/schedule.go')
-rw-r--r--internal/schedule/schedule.go9
1 files changed, 7 insertions, 2 deletions
diff --git a/internal/schedule/schedule.go b/internal/schedule/schedule.go
index 9a9121e..4ed3094 100644
--- a/internal/schedule/schedule.go
+++ b/internal/schedule/schedule.go
@@ -5,6 +5,7 @@ import (
"fmt"
"log"
"os"
+ "path/filepath"
"strings"
"codeberg.org/snonux/gos/internal/config"
@@ -31,8 +32,12 @@ func Run(args config.Args, platform string) (entry.Entry, error) {
}
// Schedule random qeued entry for platform
- ent, err := oi.ReadDirRandomEntry(dir, func(file os.DirEntry) bool {
- return strings.HasSuffix(file.Name(), ".queued")
+ // TODO: Rename ReadDirRandomEntry to ReadDirRandom
+ ent, err := oi.ReadDirRandomEntry(dir, func(file os.DirEntry) (entry.Entry, bool) {
+ if ent, err := entry.New(filepath.Join(dir, file.Name())); err != nil {
+ return ent, ent.State == entry.Queued
+ }
+ return entry.Zero, false
})
if err != nil {