revert migration

.github/workflows/publish.yml

@@ -5,6 +5,7 @@ on:
     branches:
       - master
       - dev
+      - db-migration
 
 env:
   REGISTRY: ghcr.io

cmd/main.go

@@ -7,7 +7,6 @@ import (
 	"airdao-mobile-api/pkg/logger"
 	"airdao-mobile-api/pkg/mongodb"
 	"airdao-mobile-api/services/health"
-	"airdao-mobile-api/services/migration"
 	"airdao-mobile-api/services/watcher"
 	"context"
 	"errors"
@@ -58,11 +57,6 @@ func main() {
 	}
 	zapLogger.Info("DB connected successfully")
 
-	err = migration.RunMigrations(db, cfg.MongoDb.MongoDbName, zapLogger)
-	if err != nil {
-		zapLogger.Fatalf("failed to run migration: %s", err)
-	}
-
 	// Firebase
 	firebaseClient, err := firebase.NewClient(cfg.Firebase.CredPath)
 	if err != nil {
@@ -109,25 +103,20 @@ func main() {
 		ServerHeader: "AIRDAO-Mobile-Api", // add custom server header
 	}
 
-	zapLogger.Info("Deleting watchers with stale data...")
-
 	// Run DeleteWatchersWithStaleData on start for check and delete stale data
 	if err := watcherService.DeleteWatchersWithStaleData(context.Background()); err != nil {
 		zapLogger.Errorf("failed to delete watchers with stale data - %v", err)
 	}
 
-	zapLogger.Info("Deleted watchers with stale data successfully")
-
 	// Run DeleteWatchersWithStaleData every 24 hours for check and delete stale data
 	go func() {
 		for {
-			time.Sleep(24 * time.Hour)
-
 			err := watcherService.DeleteWatchersWithStaleData(context.Background())
 			if err != nil {
 				zapLogger.Errorf("failed to delete watchers with stale data - %v", err)
 			}
-			zapLogger.Info("Deleted watchers with stale data successfully")
+
+			time.Sleep(24 * time.Hour)
 		}
 	}()
 
@@ -160,7 +149,7 @@ func main() {
 		}
 	}()
 
-	zapLogger.Infoln("Server started on port", cfg.Port)
+	zapLogger.Infoln("Server started on port %v", cfg.Port)
 
 	// Create a context that will be used to gracefully shut down the server
 	ctx, cancel = signal.NotifyContext(context.Background(), syscall.SIGINT, syscall.SIGTERM)