diff --git a/api/cmd/feeds.go b/api/cmd/feeds.go index ed9e7bb..8f2f448 100644 --- a/api/cmd/feeds.go +++ b/api/cmd/feeds.go @@ -51,6 +51,7 @@ func (h *Handler) AddFeed(c echo.Context) error { log.Printf("Add feed error: %v", err) return echo.NewHTTPError(500, "internal server error") } + h.sync.SyncFeed(feed) return c.JSON(201, feed) } diff --git a/api/cmd/main.go b/api/cmd/main.go index 2421627..1ed9eb6 100644 --- a/api/cmd/main.go +++ b/api/cmd/main.go @@ -19,6 +19,7 @@ type Handler struct { feeds vex.FeedService entries vex.EntryService users vex.UserService + sync vex.SyncService jwtSecret []byte } @@ -55,9 +56,8 @@ func main() { users: vex.NewUserService(db), jwtSecret: []byte(os.Getenv("JWT_SECRET")), } - sync := vex.NewSyncService(&reader, &h.feeds, &h.entries) - - go sync.SyncFeedsForever() + h.sync = vex.NewSyncService(&reader, &h.feeds, &h.entries) + go h.sync.SyncFeedsForever() e := echo.New() e.Validator = &Validator{validator: validator.New()}