| @@ 154-169 (lines=16) @@ | ||
| 151 | return $this->getWorkers()->get("scheduler")->getOutputChannel()->send('refresh'); |
|
| 152 | ||
| 153 | }) |
|
| 154 | ->add('scheduler:add', function(Schedule $data, $daemon) { |
|
| 155 | ||
| 156 | $manager = new ScheduleManager( |
|
| 157 | $this->getConfiguration(), |
|
| 158 | $this->getLogger(), |
|
| 159 | $this->getEvents(), |
|
| 160 | $this->getEntityManager() |
|
| 161 | ); |
|
| 162 | ||
| 163 | $id = $manager->add($data); |
|
| 164 | ||
| 165 | $this->getWorkers()->get("scheduler")->getOutputChannel()->send('refresh'); |
|
| 166 | ||
| 167 | return $id; |
|
| 168 | ||
| 169 | }) |
|
| 170 | ->add('scheduler:get', function($id, $daemon) { |
|
| 171 | ||
| 172 | $manager = new ScheduleManager( |
|
| @@ 194-209 (lines=16) @@ | ||
| 191 | return $manager->getByName($name); |
|
| 192 | ||
| 193 | }) |
|
| 194 | ->add('scheduler:edit', function(Schedule $data, $daemon) { |
|
| 195 | ||
| 196 | $manager = new ScheduleManager( |
|
| 197 | $this->getConfiguration(), |
|
| 198 | $this->getLogger(), |
|
| 199 | $this->getEvents(), |
|
| 200 | $this->getEntityManager() |
|
| 201 | ); |
|
| 202 | ||
| 203 | $edit = $manager->edit($data); |
|
| 204 | ||
| 205 | $this->getWorkers()->get("scheduler")->getOutputChannel()->send('refresh'); |
|
| 206 | ||
| 207 | return $edit; |
|
| 208 | ||
| 209 | }) |
|
| 210 | ->add('scheduler:enable', function($name, $daemon) { |
|
| 211 | ||
| 212 | $manager = new ScheduleManager( |
|
| @@ 210-225 (lines=16) @@ | ||
| 207 | return $edit; |
|
| 208 | ||
| 209 | }) |
|
| 210 | ->add('scheduler:enable', function($name, $daemon) { |
|
| 211 | ||
| 212 | $manager = new ScheduleManager( |
|
| 213 | $this->getConfiguration(), |
|
| 214 | $this->getLogger(), |
|
| 215 | $this->getEvents(), |
|
| 216 | $this->getEntityManager() |
|
| 217 | ); |
|
| 218 | ||
| 219 | $edit = $manager->enable($name); |
|
| 220 | ||
| 221 | $this->getWorkers()->get("scheduler")->getOutputChannel()->send('refresh'); |
|
| 222 | ||
| 223 | return $edit; |
|
| 224 | ||
| 225 | }) |
|
| 226 | ->add('scheduler:edit', function($name, $daemon) { |
|
| 227 | ||
| 228 | $manager = new ScheduleManager( |
|
| @@ 226-241 (lines=16) @@ | ||
| 223 | return $edit; |
|
| 224 | ||
| 225 | }) |
|
| 226 | ->add('scheduler:edit', function($name, $daemon) { |
|
| 227 | ||
| 228 | $manager = new ScheduleManager( |
|
| 229 | $this->getConfiguration(), |
|
| 230 | $this->getLogger(), |
|
| 231 | $this->getEvents(), |
|
| 232 | $this->getEntityManager() |
|
| 233 | ); |
|
| 234 | ||
| 235 | $edit = $manager->disable($name); |
|
| 236 | ||
| 237 | $this->getWorkers()->get("scheduler")->getOutputChannel()->send('refresh'); |
|
| 238 | ||
| 239 | return $edit; |
|
| 240 | ||
| 241 | }); |
|
| 242 | ||
| 243 | } |
|
| 244 | ||