Update log msgs from spec updated in API mode

cmd/api-firewall/internal/updater/updater.go

@@ -3,6 +3,7 @@ package updater
 import (
 	"os"
 	"runtime/debug"
+	"slices"
 	"sync"
 	"time"
 
@@ -15,6 +16,10 @@ import (
 	"github.com/wallarm/api-firewall/internal/platform/database"
 )
 
+const (
+	logPrefix = "Regular OpenAPI specification updater"
+)
+
 type Updater interface {
 	Start() error
 	Shutdown() error
@@ -74,32 +79,41 @@ func (s *Specification) Run() {
 			// load new schemes
 			newSpecDB, err := s.Load()
 			if err != nil {
-				s.logger.WithFields(logrus.Fields{"error": err}).Error("Updating OpenAPI specification")
+				s.logger.WithFields(logrus.Fields{"error": err}).Errorf("%s: loading specifications", logPrefix)
 				continue
 			}
 
 			// do not downgrade the db version
 			if s.sqlLiteStorage.Version() > newSpecDB.Version() {
-				s.logger.Error("Regular update checker: version of the new DB structure is lower then current one (V2)")
+				s.logger.Errorf("%s: version of the new DB structure is lower then current one (V2)", logPrefix)
 				continue
 			}
 
 			if s.sqlLiteStorage.ShouldUpdate(newSpecDB) {
-				s.logger.Debugf("OpenAPI specifications has been updated. The schemas with the following IDs were updated: %v", newSpecDB.SchemaIDs())
+				s.logger.Debugf("%s: OpenAPI specifications with the following IDs were updated: %v", logPrefix, newSpecDB.SchemaIDs())
+
+				// find new IDs and log them
+				newScemaIDs := newSpecDB.SchemaIDs()
+				oldSchemaIDs := s.sqlLiteStorage.SchemaIDs()
+				for _, ns := range newScemaIDs {
+					if !slices.Contains(oldSchemaIDs, ns) {
+						s.logger.Infof("%s: fetched new OpenAPI specification from the database with id: %d", logPrefix, ns)
+					}
+				}
 
 				s.lock.Lock()
 				s.sqlLiteStorage = newSpecDB
 				s.api.Handler = handlersAPI.Handlers(s.lock, s.cfg, s.shutdown, s.logger, s.sqlLiteStorage, s.allowedIPCache, s.waf)
 				s.health.OpenAPIDB = s.sqlLiteStorage
 				if err := s.sqlLiteStorage.AfterLoad(s.cfg.PathToSpecDB); err != nil {
-					s.logger.WithFields(logrus.Fields{"error": err}).Error("Regular update checker: error in after specification loading function")
+					s.logger.WithFields(logrus.Fields{"error": err}).Errorf("%s: error in after specification loading function", logPrefix)
 				}
 				s.lock.Unlock()
 
 				continue
 			}
 
-			s.logger.Debugf("regular update checker: new OpenAPI specifications not found")
+			s.logger.Debugf("%s: new OpenAPI specifications not found", logPrefix)
 		case <-s.stop:
 			updateTicker.Stop()
 			return
@@ -117,7 +131,7 @@ func (s *Specification) Start() error {
 
 // Shutdown function stops update process
 func (s *Specification) Shutdown() error {
-	defer s.logger.Infof("specification updater: stopped")
+	defer s.logger.Infof("%s: stopped", logPrefix)
 
 	// close worker and finish Start function
 	for i := 0; i < 2; i++ {