diff --git a/server/runner/memopayload/runner.go b/server/runner/memopayload/runner.go index 527a16f42..a746e648c 100644 --- a/server/runner/memopayload/runner.go +++ b/server/runner/memopayload/runner.go @@ -4,7 +4,6 @@ import ( "context" "log/slog" "slices" - "time" "github.com/pkg/errors" "github.com/usememos/gomark/ast" @@ -25,23 +24,7 @@ func NewRunner(store *store.Store) *Runner { } } -// Schedule runner every 12 hours. -const runnerInterval = time.Hour * 12 - -func (r *Runner) Run(ctx context.Context) { - ticker := time.NewTicker(runnerInterval) - defer ticker.Stop() - - for { - select { - case <-ticker.C: - r.RunOnce(ctx) - case <-ctx.Done(): - return - } - } -} - +// RunOnce rebuilds the payload of all memos. func (r *Runner) RunOnce(ctx context.Context) { memos, err := r.Store.ListMemos(ctx, &store.FindMemo{}) if err != nil { diff --git a/server/server.go b/server/server.go index 38314f355..43b986fa3 100644 --- a/server/server.go +++ b/server/server.go @@ -147,11 +147,11 @@ func (s *Server) StartBackgroundRunners(ctx context.Context) { versionRunner := version.NewRunner(s.Store, s.Profile) versionRunner.RunOnce(ctx) memopayloadRunner := memopayload.NewRunner(s.Store) + // Rebuild all memos' payload after server starts. memopayloadRunner.RunOnce(ctx) go s3presignRunner.Run(ctx) go versionRunner.Run(ctx) - go memopayloadRunner.Run(ctx) } func (s *Server) getOrUpsertWorkspaceBasicSetting(ctx context.Context) (*storepb.WorkspaceBasicSetting, error) {