diff options
| author | Paul Buetow <paul@buetow.org> | 2024-10-01 10:55:50 +0300 |
|---|---|---|
| committer | Paul Buetow <paul@buetow.org> | 2024-10-01 10:55:50 +0300 |
| commit | bc6a3e478a7e0efc12c30be9f74ef5c3ff7a63fb (patch) | |
| tree | b426efbe9de7dbd3e083263338380b3d97019f55 /internal/schedule/schedule.go | |
| parent | 74bcb110cba9cd22b88c561115e332d500de7716 (diff) | |
some more foo
Diffstat (limited to 'internal/schedule/schedule.go')
| -rw-r--r-- | internal/schedule/schedule.go | 9 |
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 { |
