Add missing implementation (#6)

jastBytes · web-flow · commit b4a77441fa38 · 2021-10-15T11:08:19.000+02:00
diff --git a/cmd/eventstore/backup.go b/cmd/eventstore/backup.go
@@ -117,7 +117,13 @@ func runBackup(ctx context.Context, log logger.Logger, metricsPublisher backup.M
 }
 
 func runPurge(ctx context.Context, log logger.Logger, backupManger *eventstore.BackupManager) error {
-	return nil
+	result, err := backupManger.RunPurge(ctx)
+	if err != nil {
+		log.Error(err, "Failed to purge backups.", "BackupsLeft", result.BackupsLeft, "PurgedBackups", result.PurgedBackups)
+	} else {
+		log.Info("Purging outdated backups has been successful.", "BackupsLeft", result.BackupsLeft, "PurgedBackups", result.PurgedBackups)
+	}
+	return err
 }
 
 func init() {

Original file line number	Diff line number	Diff line change
`@@ -117,7 +117,13 @@ func runBackup(ctx context.Context, log logger.Logger, metricsPublisher backup.M`
`117`	`117`	`}`
`118`	`118`
`119`	`119`	`func runPurge(ctx context.Context, log logger.Logger, backupManger *eventstore.BackupManager) error {`
`120`		`- return nil`
	`120`	`+ result, err := backupManger.RunPurge(ctx)`
	`121`	`+ if err != nil {`
	`122`	`+ log.Error(err, "Failed to purge backups.", "BackupsLeft", result.BackupsLeft, "PurgedBackups", result.PurgedBackups)`
	`123`	`+ } else {`
	`124`	`+ log.Info("Purging outdated backups has been successful.", "BackupsLeft", result.BackupsLeft, "PurgedBackups", result.PurgedBackups)`
	`125`	`+ }`
	`126`	`+ return err`
`121`	`127`	`}`
`122`	`128`
`123`	`129`	`func init() {`