Completed
Push — master ( bfdf06...0a840f )
by Rougin
02:54
created

CreateMigrationCommand::execute()   B

Complexity

Conditions 4
Paths 3

Size

Total Lines 24
Code Lines 13

Duplication

Lines 0
Ratio 0 %

Code Coverage

Tests 14
CRAP Score 4

Importance

Changes 0
Metric Value
dl 0
loc 24
ccs 14
cts 14
cp 1
rs 8.6845
c 0
b 0
f 0
cc 4
eloc 13
nc 3
nop 2
crap 4
1
<?php
2
3
namespace Rougin\Refinery\Commands;
4
5
use Symfony\Component\Console\Input\InputOption;
6
use Symfony\Component\Console\Input\InputArgument;
7
use Symfony\Component\Console\Input\InputInterface;
8
use Symfony\Component\Console\Output\OutputInterface;
9
10
/**
11
 * Create Migration Command
12
 *
13
 * Creates a new migration file based on its file name.
14
 *
15
 * @package Refinery
16
 * @author  Rougin Royce Gutib <[email protected]>
17
 */
18
class CreateMigrationCommand extends AbstractCommand
19
{
20
    /**
21
     * Checks whether the command is enabled or not in the current environment.
22
     *
23
     * @return boolean
24
     */
25 3
    public function isEnabled()
26
    {
27 3
        return true;
28
    }
29
30
    /**
31
     * Sets the configurations of the specified command.
32
     *
33
     * @return void
34
     */
35 33
    protected function configure()
36
    {
37 33
        $this->setName('create')
38 33
            ->setDescription('Creates a new migration file')
39 33
            ->addArgument('name', InputArgument::REQUIRED, 'Name of the migration file')
40 33
            ->addOption('from-database', null, InputOption::VALUE_NONE, 'Generates a migration based from the database')
41 33
            ->addOption('sequential', null, InputOption::VALUE_NONE, 'Generates a migration file with a sequential identifier')
42 33
            ->addOption('type', null, InputOption::VALUE_OPTIONAL, 'Data type of the column', 'varchar')
43 33
            ->addOption('length', null, InputOption::VALUE_OPTIONAL, 'Length of the column', 50)
44 33
            ->addOption('auto_increment', null, InputOption::VALUE_OPTIONAL, 'Generates an "AUTO_INCREMENT" flag on the column', false)
45 33
            ->addOption('default', null, InputOption::VALUE_OPTIONAL, 'Generates a default value in the column definition', '')
46 33
            ->addOption('null', null, InputOption::VALUE_OPTIONAL, 'Generates a "NULL" value in the column definition', false)
47 33
            ->addOption('primary', null, InputOption::VALUE_OPTIONAL, 'Generates a "PRIMARY" value in the column definition', false)
48 33
            ->addOption('unsigned', null, InputOption::VALUE_OPTIONAL, 'Generates an "UNSIGNED" value in the column definition', false);
49 33
    }
50
51
    /**
52
     * Executes the command.
53
     *
54
     * @param  \Symfony\Component\Console\Input\InputInterface   $input
55
     * @param  \Symfony\Component\Console\Output\OutputInterface $output
56
     * @return object|\Symfony\Component\Console\Output\OutputInterface
57
     */
58 27
    protected function execute(InputInterface $input, OutputInterface $output)
59
    {
60 27
        $fileName = $this->getFileName($input->getArgument('name'), $input->getOption('sequential'));
61 27
        $keywords = $this->getKeywords($input->getArgument('name'));
62
63 27
        if ($input->getOption('from-database') && $keywords[0] != 'create') {
64 3
            $message = '--from-database is only available to create_*table*_table keyword';
65
66 3
            throw new \InvalidArgumentException($message);
67
        }
68
69 24
        $data = $this->prepareData($input, $keywords);
70
71 24
        if ($data['command_name'] != 'create') {
72 6
            $data = $this->defineColumns($input, $keywords, $data);
73 6
        }
74
75 24
        $rendered = $this->renderer->render('Migration.twig', $data);
76 24
        $rendered = str_replace("));\n\n\t}", "));\n\t}", $rendered);
77
78 24
        $this->filesystem->write('application/migrations/' . $fileName . '.php', $rendered);
79
80 24
        return $output->writeln('<info>"' . $fileName . '" has been created.</info>');
81
    }
82
83
    /**
84
     * Defines the columns to be included in the migration.
85
     *
86
     * @param  \Symfony\Component\Console\Input\InputInterface $input
87
     * @param  array                                           $keywords
88
     * @param  array                                           $data
89
     * @return array
90
     */
91 6
    protected function defineColumns(InputInterface $input, array $keywords, array $data)
92
    {
93 6
        $data['table_name'] = $keywords[1];
94
95 6
        array_push($data['columns'], $this->setColumn($input, $keywords[2]));
96
97 6
        if ($data['command_name'] == 'modify') {
98 3
            foreach ($this->describe->getTable($data['table_name']) as $column) {
99 3
                $column->getField() != $keywords[2] || array_push($data['defaults'], $column);
100 3
            }
101 3
        }
102
103 6
        return $data;
104
    }
105
106
    /**
107
     * Gets the file name of the specified migration.
108
     *
109
     * @param  string  $name
110
     * @param  boolean $isSequential
111
     * @return string
112
     */
113 27
    protected function getFileName($name, $isSequential = false)
114
    {
115 27
        $migrationType = $this->getMigrationType();
116
117 27
        $fileName = date('YmdHis') . '_' . underscore($name);
118
119 27
        if ($migrationType == 'sequential' || $isSequential) {
120 3
            $number = 1;
121
122 3
            $files = new \FilesystemIterator(APPPATH . 'migrations', \FilesystemIterator::SKIP_DOTS);
123
124 3
            $number += iterator_count($files);
125
126 3
            $sequence = sprintf('%03d', $number);
127 3
            $fileName = $sequence . '_' . substr($fileName, 15);
128 3
        }
129
130 27
        return $fileName;
131
    }
132
133
    /**
134
     * Gets the defined keywords from the command.
135
     *
136
     * @param  string $name
137
     * @return array
138
     */
139 27
    protected function getKeywords($name)
140
    {
141 27
        $empty = [ '', '', '' ];
142 27
        $path  = APPPATH . 'migrations';
143
144 27
        file_exists($path) || mkdir($path);
145
146 27
        preg_match('/(.*?)_(.*?)_table/', underscore($name), $keywords);
147
148 27
        if (strpos($keywords[2], '_in') !== false) {
149 9
            preg_match('/(.*?)_(.*?)_in_(.*?)_table/', underscore($name), $keywords);
150
151 9
            $temp = $keywords[3];
152
153 9
            $keywords[3] = $keywords[2];
154 9
            $keywords[2] = $temp;
155 9
        }
156
157 27
        array_shift($keywords);
158
159 27
        $keywords = array_replace($empty, $keywords);
160
161 27
        return $keywords;
162
    }
163
164
    /**
165
     * Prepares the data to be inserted in the template.
166
     *
167
     * @param  \Symfony\Component\Console\Input\InputInterface $input
168
     * @param  array                                           $keywords
169
     * @return array
170
     */
171 24
    protected function prepareData(InputInterface $input, array $keywords)
172
    {
173 24
        $data = [];
174
175 24
        $data['command_name'] = $keywords[0];
176 24
        $data['data_types']   = [ 'string' => 'VARCHAR', 'integer' => 'INT' ];
177 24
        $data['class_name']   = underscore($input->getArgument('name'));
178 24
        $data['table_name']   = $keywords[1];
179
180 24
        $data['columns']  = [];
181 24
        $data['defaults'] = [];
182
183 24
        if ($input->getOption('from-database') && $data['command_name'] == 'create') {
184 3
            $data['columns'] = $this->describe->getTable($data['table_name']);
185 3
        }
186
187 24
        return $data;
188
    }
189
190
    /**
191
     * Sets properties for a specified column
192
     *
193
     * @param  \Symfony\Component\Console\Input\InputInterface $input
194
     * @param  string                                          $fieldName
195
     * @return \Rougin\Describe\Column
196
     */
197 6
    protected function setColumn(InputInterface $input, $fieldName)
198
    {
199 6
        $column = new \Rougin\Describe\Column;
200
201 6
        $column->setField($fieldName);
202 6
        $column->setNull($input->getOption('null'));
203 6
        $column->setDataType($input->getOption('type'));
204 6
        $column->setLength($input->getOption('length'));
205 6
        $column->setPrimary($input->getOption('primary'));
206 6
        $column->setUnsigned($input->getOption('unsigned'));
207 6
        $column->setDefaultValue($input->getOption('default'));
208 6
        $column->setAutoIncrement($input->getOption('auto_increment'));
209
210 6
        return $column;
211
    }
212
}
213