entities

type FileSystemRepo interface {
	MkAlldirIfnotExists(paths []string) error
	CreateFilesInDirectories(directoryList []string, fileNames []string) error
	GetMigrationFilesFromDirectory(directory string, database int) []string
	GetMigrationsFromFiles(string, []string, string) (*[]PGMigration, error)
}

type MigrationEntry struct {
	Name    string
	MigType string
	Created time.Time
}

type MigratorConfig struct {
	Database  int
	Extention string
	Migrator  MigratorService
}

type MigratorService interface {
	// MigrateUp(0) will run all migrations
	// MigrateUp(2) will run next 2 migrations
	MigrateUp(int) error
	// MigrateDown(0) will run all down migrations
	// MigrateDown(2) will run next 2 migrations
	MigrateDown(int) error
	CleanMigrationTable() error
	GetMigrationEntries() (*[]MigrationEntry, error)
}

type PGMigration struct {
	Name  string
	Query string
	Type  string
}

type PGRepo interface {
	CreateMigrationTableIfNotExists() error
	GetLastAppliedMigrationFromDatabase() (*MigrationEntry, error)
	ApplyMigration(migration *PGMigration) error
	GetMigrationEntries() (*[]MigrationEntry, error)
	CleanMigrationTable() error
}