entities

type DatabaseRepo interface {
	CreateMigrationTableIfNotExists() error
	GetLastAppliedMigrationFromDatabase() (*MigrationEntry, error)
	ApplyMigration(migration *SqlMigration) error
	GetMigrationEntries() (*[]MigrationEntry, error)
	DeleteMigrationTable() error
}

type FileSystemRepo interface {
	MkAlldirIfnotExists(paths []string) error
	CreateFilesInDirectories(directoryList []string, fileNames []string) error
	GetMigrationFilesFromDirectory(directory string, database int) []string
	GetMigrationsFromFiles(string, []string, string) (*[]SqlMigration, error)
	RemoveFilesFromDirectories(directoryList []string, fileNames []string) 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
	DeleteMigrationTable() error
	GetMigrationEntries() (*[]MigrationEntry, error)
}

type SqlMigration struct {
	Name  string
	Query string
	Type  string
}