wip: more things

Author: heiytor

api/Dockerfile

@@ -51,6 +51,9 @@ RUN go mod download
 
 COPY ./api/entrypoint-dev.sh /entrypoint.sh
 
+RUN mkdir -p /migrations
+COPY ./api/store/pg/migrations/ /migrations/
+
 WORKDIR $GOPATH/src/github.com/shellhub-io/shellhub/api
 
 RUN mkdir -p /templates
@@ -68,6 +71,9 @@ COPY --from=builder /go/src/github.com/shellhub-io/shellhub/api/api /api
 
 RUN mkdir -p /templates
 
+RUN mkdir -p /migrations
+COPY ./api/store/pg/migrations/ /migrations/
+
 COPY ./install.sh /templates/install.sh
 
 ENTRYPOINT /api server

api/store/pg/migrations/20250310204541_create_devices_table.down.sql

@@ -0,0 +1 @@
+DROP TABLE IF EXISTS devices;

api/store/pg/options/run-migration.go

@@ -30,36 +30,38 @@ func RunMigrations() Option {
 			return err
 		}
 
-		log.WithField("path", migrationsPath).Info("Applying migrations")
-
 		m, err := migrate.NewWithDatabaseInstance("file://"+migrationsPath, envs.DefaultBackend.Get("POSTGRES_DB"), driver)
 		if err != nil {
+			log.WithError(err).Error("failed to create migrate instance")
+
 			return errors.Join(ErrMigrationFail, err)
 		}
 
 		if version, dirty, _ := m.Version(); dirty {
 			log.WithField("version", version).
 				WithField("dirty", dirty).
-				Info("migrations are dirty. manual fix required")
+				WithError(err).
+				Error("migrations are dirty. manual fix required")
 
 			return errors.Join(ErrMigrationFail, err)
 		}
 
+		log.WithField("path", migrationsPath).Info("applying migrations")
+
 		if err := m.Up(); err != nil && err != migrate.ErrNoChange {
+			log.WithError(err).Error("failed to apply migrations")
+
 			return errors.Join(ErrMigrationFail, err)
 		}
 
+		log.Info("migrations applied")
+
 		return nil
 	}
 }
 
 func fetchMigrationsPath() (string, error) {
-	cwd, err := os.Getwd()
-	if err != nil {
-		return "", err
-	}
-
-	migrationsPath := filepath.Join(cwd, "store", "pg", "migrations")
+	migrationsPath := filepath.Join("/", "migrations")
 
 	if _, err := os.Stat(migrationsPath); os.IsNotExist(err) {
 		log.WithField("path", migrationsPath).Info("Migrations directory not found, creating it")
@@ -70,5 +72,33 @@ func fetchMigrationsPath() (string, error) {
 		return "", err
 	}
 
+	files, err := os.ReadDir(migrationsPath)
+	if err != nil {
+		log.WithError(err).WithField("path", migrationsPath).Error("failed to read migrations directory")
+		return "", err
+	}
+
+	if len(files) == 0 {
+		log.Error("no migration files found in directory")
+	} else {
+		log.WithField("path", migrationsPath).WithField("total_files", len(files)).Info("migration files directory content:")
+
+		for i, file := range files {
+			fileInfo, err := file.Info()
+			if err != nil {
+				log.WithField("filename", file.Name()).WithError(err).Warn("failed to get file info")
+				continue
+			}
+
+			log.WithFields(log.Fields{
+				"index":  i,
+				"name":   file.Name(),
+				"size":   fileInfo.Size(),
+				"is_dir": file.IsDir(),
+				"mode":   fileInfo.Mode().String(),
+			}).Info("migration file")
+		}
+	}
+
 	return migrationsPath, nil
 }