bel
/
show-rss
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

debatably better

main
Bel LaPointe 2025-04-27 11:49:57 -06:00
parent 19b6d180e7
commit ec1f0e007a
2 changed files with 3 additions and 16 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

13
src/cmd/cron/main.go
View File

@ -26,12 +26,7 @@ func Main(ctx context.Context) error {
} }
func One(ctx context.Context) error { func One(ctx context.Context) error {
f, err := feeds.New(ctx) return feeds.ForEach(ctx, func(feed feeds.Feed) error {
if err != nil {
return err
}
return f.ForEach(ctx, func(feed feeds.Feed) error {
if err := one(ctx, feed); err != nil { if err := one(ctx, feed); err != nil {
return fmt.Errorf("failed to cron %s (%+v): %w", feed.Entry.ID, feed.Version, err) return fmt.Errorf("failed to cron %s (%+v): %w", feed.Entry.ID, feed.Version, err)
} }
@ -56,9 +51,5 @@ func one(ctx context.Context, feed feeds.Feed) error {
return fmt.Errorf("should GET %s", feed.Version.URL) return fmt.Errorf("should GET %s", feed.Version.URL)
f, err := feeds.New(ctx) return feeds.Executed(ctx, feed.Entry.ID, feed.Version.Created)
if err != nil {
return fmt.Errorf("failed new feeds to executed %s: %w", feed.Entry.ID, err)
}
return f.Executed(ctx, feed.Entry.ID, feed.Version.Created)
} }

6
src/cmd/cron/main_test.go
View File

@ -38,12 +38,8 @@ func TestOne(t *testing.T) {
ctx := db.Test(t, ctx) ctx := db.Test(t, ctx)
f, err := feeds.New(ctx)
if err != nil {
t.Fatal(err)
}
for i := 0; i < 2; i++ { for i := 0; i < 2; i++ {
if _, err := f.Insert(ctx, fmt.Sprintf("%s?idx=%d", s.URL, i), "* * * * *"); err != nil { if _, err := feeds.Insert(ctx, fmt.Sprintf("%s?idx=%d", s.URL, i), "* * * * *"); err != nil {
t.Fatal(err) t.Fatal(err)
} }
} }