diff --git a/internal/daemon/daemon.go b/internal/daemon/daemon.go index 550a72b..c88093f 100644 --- a/internal/daemon/daemon.go +++ b/internal/daemon/daemon.go @@ -106,12 +106,19 @@ func (d *daemon) runWorker(ctx context.Context, isTesting bool, testingInterval return case <-stopTestingCh: d.logger.Info("Testing interval expired, stopping service") + if err := d.notifications.DBQueueClear(); err != nil { d.logger.Error(fmt.Sprintf("failed to clear notifications queue: %v", err)) } + if err := d.analyzer.ClearDBData(); err != nil { d.logger.Error(fmt.Sprintf("failed to clear analyzer data: %v", err)) } + + if err := d.firewall.ClearDBData(); err != nil { + d.logger.Error(fmt.Sprintf("failed to clear firewall data: %v", err)) + } + d.Stop() return case <-d.stopCh: