← All changes | src/admin/class-migrations.php +74 -60 3.0 → 3.2.21 View file →

		@@ -8,75 +8,89 @@
8	8	*
9	9	*/
10	10	class Migrations {
11	11
12		- /**
13		- * @var float
14		- */
15		- protected $version_from = 0;
16	12
17		- /**
18		- * @var float
19		- */
20		- protected $version_to = 0;
	13	+ /**
	14	+ * @var float
	15	+ */
	16	+ protected $version_from = 0;
21	17
22		- /**
23		- * @var string
24		- */
25		- protected $migrations_dir = '';
	18	+ /**
	19	+ * @var float
	20	+ */
	21	+ protected $version_to = 0;
26	22
27		- /**
28		- * @param float $from
29		- * @param float $to
30		- * @param string $migrations_dir
31		- */
32		- public function __construct( $from, $to, $migrations_dir ) {
33		- $this->version_from = $from;
34		- $this->version_to = $to;
35		- $this->migrations_dir = $migrations_dir;
36		- }
	23	+ /**
	24	+ * @var string
	25	+ */
	26	+ protected $migrations_dir = '';
37	27
38		- /**
39		- * Run the various upgrade routines, all the way up to the latest version
40		- */
41		- public function run() {
42		- $migrations = $this->find_migrations();
43		- // run in sub-function for scope
44		- array_map( array( $this, 'run_migration' ), $migrations );
45		- }
	28	+ /**
	29	+ * @param float $from
	30	+ * @param float $to
	31	+ * @param string $migrations_dir
	32	+ */
	33	+ public function __construct( $from, $to, $migrations_dir ) {
	34	+ $this->version_from = $from;
	35	+ $this->version_to = $to;
	36	+ $this->migrations_dir = $migrations_dir;
	37	+ }
46	38
47		- /**
48		- * @return array
49		- */
50		- public function find_migrations() {
51		- $files = glob( rtrim( $this->migrations_dir, '/' ) . '/*.php' );
52		- $migrations = array();
	39	+ /**
	40	+ * Run the various upgrade routines, all the way up to the latest version
	41	+ */
	42	+ public function run() {
	43	+ $migrations = $this->find_migrations();
	44	+ // run in sub-function for scope
	45	+ array_map( array( $this, 'run_migration' ), $migrations );
	46	+ }
53	47
54		- foreach( $files as $file ) {
55		- $migration = basename( $file );
56		- $parts = explode( '-', $migration );
57		- $version = $parts[0];
	48	+ /**
	49	+ * @return array
	50	+ */
	51	+ public function find_migrations() {
	52	+ $files = glob( rtrim( $this->migrations_dir, '/' ) . '/*.php' );
	53	+ $migrations = array();
58	54
59		- if( version_compare( $this->version_from, $version, '<' ) ) {
60		- $migrations[] = $file;
61		- }
62		- }
	55	+ // return empty array when glob returns non-array value.
	56	+ if ( ! is_array( $files ) ) {
	57	+ return $migrations;
	58	+ }
63	59
64		- return $migrations;
65		- }
	60	+ foreach ( $files as $file ) {
	61	+ $migration = basename( $file );
	62	+ $parts = explode( '-', $migration );
	63	+ $version = $parts[0];
66	64
67		- /**
68		- * Include a migration file and runs it.
69		- *
70		- * @param string $file
71		- *
72		- * @throws Exception
73		- */
74		- protected function run_migration( $file ) {
	65	+ // check if migration file is not for an even higher version
	66	+ if ( version_compare( $version, $this->version_to, '>' ) ) {
	67	+ continue;
	68	+ }
75	69
76		- if( ! file_exists( $file ) ) {
77		- throw new Exception( "Migration file $file does not exist.");
78		- }
	70	+ // check if we ran migration file before.
	71	+ if ( version_compare( $this->version_from, $version, '>=' ) ) {
	72	+ continue;
	73	+ }
79	74
80		- include $file;
81		- }
82		-}
	75	+ // schedule migration file for running
	76	+ $migrations[] = $file;
	77	+ }
	78	+
	79	+ return $migrations;
	80	+ }
	81	+
	82	+ /**
	83	+ * Include a migration file and runs it.
	84	+ *
	85	+ * @param string $file
	86	+ *
	87	+ * @throws Exception
	88	+ */
	89	+ protected function run_migration( $file ) {
	90	+ if ( ! file_exists( $file ) ) {
	91	+ throw new Exception( "Migration file $file does not exist." );
	92	+ }
	93	+
	94	+ include $file;
	95	+ }
	96	+}