@@ -113,7 +113,7 @@ func NewManager(cfg config.Config, store store.Store, logger zerolog.Logger) (Ma
113113 if cfg .ClearCache {
114114 // Clear the cache from disk
115115 if err := impl .ClearFromDisk (); err != nil {
116- logger .Warn ().Err (err ).Msg ("failed to load cache from disk, starting with empty cache" )
116+ logger .Warn ().Err (err ).Msg ("failed to clear cache from disk, starting with empty cache" )
117117 }
118118 } else {
119119 // Load existing cache from disk
@@ -267,19 +267,9 @@ func (m *implementation) LoadFromDisk() error {
267267}
268268
269269func (m * implementation ) ClearFromDisk () error {
270- cfgDir := filepath .Join (m .config .RootDir , "data" )
271-
272- if err := os .RemoveAll (filepath .Join (cfgDir , headerCacheDir )); err != nil {
273- return fmt .Errorf ("failed to clear header cache from disk: %w" , err )
274- }
275-
276- if err := os .RemoveAll (filepath .Join (cfgDir , dataCacheDir )); err != nil {
277- return fmt .Errorf ("failed to clear data cache from disk: %w" , err )
278- }
279-
280- if err := os .RemoveAll (filepath .Join (cfgDir , pendingEventsCacheDir )); err != nil {
281- return fmt .Errorf ("failed to clear pending events cache from disk: %w" , err )
270+ cachePath := filepath .Join (m .config .RootDir , "data" , cacheDir )
271+ if err := os .RemoveAll (cachePath ); err != nil {
272+ return fmt .Errorf ("failed to clear cache from disk: %w" , err )
282273 }
283-
284274 return nil
285275}
0 commit comments