| @@ -50,16 +50,30 @@ | ||
| 50 | 50 | public function find_migrations() { |
| 51 | 51 | $files = glob( rtrim( $this->migrations_dir, '/' ) . '/*.php' ); |
| 52 | 52 | $migrations = array(); |
| 53 | 53 | |
| 54 | + // return empty array when glob returns non-array value. | |
| 55 | + if( ! is_array( $files ) ) { | |
| 56 | + return $migrations; | |
| 57 | + } | |
| 58 | + | |
| 54 | 59 | foreach( $files as $file ) { |
| 55 | 60 | $migration = basename( $file ); |
| 56 | 61 | $parts = explode( '-', $migration ); |
| 57 | 62 | $version = $parts[0]; |
| 58 | 63 | |
| 59 | - if( version_compare( $this->version_from, $version, '<' ) ) { | |
| 60 | - $migrations[] = $file; | |
| 64 | + // check if migration file is not for an even higher version | |
| 65 | + if( version_compare( $version, $this->version_to, '>' ) ) { | |
| 66 | + continue; | |
| 61 | 67 | } |
| 68 | + | |
| 69 | + // check if we ran migration file before. | |
| 70 | + if( version_compare( $this->version_from, $version, '>=' ) ) { | |
| 71 | + continue; | |
| 72 | + } | |
| 73 | + | |
| 74 | + // schedule migration file for running | |
| 75 | + $migrations[] = $file; | |
| 62 | 76 | } |
| 63 | 77 | |
| 64 | 78 | return $migrations; |
| 65 | 79 | } |