summaryrefslogtreecommitdiff
path: root/internal/queue/queue.go
diff options
context:
space:
mode:
authorPaul Buetow <paul@buetow.org>2024-10-23 23:09:55 +0300
committerPaul Buetow <paul@buetow.org>2024-10-23 23:09:55 +0300
commitbdcf87d33d73ad6b75c954e9b667ac084075746d (patch)
tree32997c45696a21e01e382908999920dcf8afda78 /internal/queue/queue.go
parentfcd9fe70899c2e30ea467d80c576b950f5f62be6 (diff)
fix error handling
Diffstat (limited to 'internal/queue/queue.go')
-rw-r--r--internal/queue/queue.go7
1 files changed, 4 insertions, 3 deletions
diff --git a/internal/queue/queue.go b/internal/queue/queue.go
index 75e0d20..2f8c780 100644
--- a/internal/queue/queue.go
+++ b/internal/queue/queue.go
@@ -17,6 +17,7 @@ import (
// Strictly, we only operate on .txt files, but we also accept .md as Obsidian creates only .md files.
var validExtensions = []string{".txt", ".md"}
+// TODO: Red alert when there are no messages to schedule, or less than N
func Run(args config.Args) error {
if err := queueEntries(args); err != nil {
return err
@@ -34,7 +35,7 @@ func queueEntries(args config.Args) error {
return filePath, slices.Contains(validExtensions, filepath.Ext(file.Name())) &&
file.Type().IsRegular()
})
- if err != err {
+ if err != nil {
return err
}
@@ -61,7 +62,7 @@ func queuePlatforms(args config.Args) error {
filePath := filepath.Join(dbDir, file.Name())
return filePath, strings.HasSuffix(file.Name(), ".queued")
})
- if err != err {
+ if err != nil {
return err
}
@@ -122,7 +123,7 @@ func deleteFiles(path, suffix string, olderThan time.Time) error {
filePath := filepath.Join(path, file.Name())
return filePath, strings.HasSuffix(filePath, suffix) && file.Type().IsRegular()
})
- if err != err {
+ if err != nil {
return err
}