Added possibility to create one shot job from scheduled job (#4)

Update doc screenshots

CHANGELOG.md

@@ -1,3 +1,10 @@
+# Version 4.4.0
+* Added possibility to create one shot job from scheduled job
+
+# Version 4.3.0
+
+* Replaced date field with date picker
+
 # Version 4.2.0
 
 * Added error count columns to job tables

src/Controller/JobController.php

@@ -7,12 +7,14 @@ namespace CodeRhapsodie\EzDataflowBundle\Controller;
 use CodeRhapsodie\DataflowBundle\Entity\Job;
 use CodeRhapsodie\EzDataflowBundle\Form\CreateOneshotType;
 use CodeRhapsodie\EzDataflowBundle\Gateway\JobGateway;
+use CodeRhapsodie\EzDataflowBundle\Gateway\ScheduledDataflowGateway;
 use Ibexa\Contracts\AdminUi\Controller\Controller;
 use Ibexa\Contracts\AdminUi\Notification\NotificationHandlerInterface;
 use Ibexa\Core\MVC\Symfony\Security\Authorization\Attribute;
 use Symfony\Component\HttpFoundation\JsonResponse;
 use Symfony\Component\HttpFoundation\Request;
 use Symfony\Component\HttpFoundation\Response;
+use Symfony\Component\HttpKernel\Exception\NotFoundHttpException;
 use Symfony\Component\Routing\Annotation\Route;
 use Symfony\Component\Routing\Generator\UrlGeneratorInterface;
 use Symfony\Contracts\Translation\TranslatorInterface;
@@ -28,15 +30,19 @@ class JobController extends Controller
     private $notificationHandler;
     /** @var \Symfony\Contracts\Translation\TranslatorInterface */
     private $translator;
+    /** @var \CodeRhapsodie\EzDataflowBundle\Gateway\ScheduledDataflowGateway  */
+    private $scheduledDataflowGateway;
 
     public function __construct(
         JobGateway $jobGateway,
         NotificationHandlerInterface $notificationHandler,
-        TranslatorInterface $translator
+        TranslatorInterface $translator,
+        ScheduledDataflowGateway $scheduledDataflowGateway
     ) {
         $this->jobGateway = $jobGateway;
         $this->notificationHandler = $notificationHandler;
         $this->translator = $translator;
+        $this->scheduledDataflowGateway = $scheduledDataflowGateway;
     }
 
     /**
@@ -104,4 +110,37 @@ class JobController extends Controller
             ]),
         ]);
     }
+
+    /**
+     * @Route("/run-oneshot/{id}", name="coderhapsodie.ezdataflow.job.run-oneshot", methods={"GET"})
+     */
+    public function runOneShot(int $id): Response
+    {
+        $this->denyAccessUnlessGranted(new Attribute('ezdataflow', 'view'));
+
+        $scheduledDataflow = $this->scheduledDataflowGateway->find($id);
+
+        if ($scheduledDataflow === null) {
+            throw new NotFoundHttpException();
+        }
+
+        $newOneshotJob = new Job();
+        $newOneshotJob->setOptions($scheduledDataflow->getOptions());
+        $newOneshotJob->setLabel("Manual " . $scheduledDataflow->getLabel());
+        $newOneshotJob->setScheduledDataflowId($scheduledDataflow->getId());
+        $newOneshotJob->setRequestedDate((new \DateTime())->add(new \DateInterval('PT1H')));
+        $newOneshotJob->setDataflowType($scheduledDataflow->getDataflowType());
+
+        $form = $this->createForm(CreateOneshotType::class, $newOneshotJob, [
+            'action' => $this->generateUrl('coderhapsodie.ezdataflow.job.create'),
+        ]);
+
+        return new JsonResponse([
+            'form' => $this->renderView('@ibexadesign/ezdataflow/parts/form_modal.html.twig', [
+                'form' => $form->createView(),
+                'id' => 'modal-new-oneshot',
+                'mode' => 'oneshot',
+            ]),
+        ]);
+    }
 }

src/Resources/config/services.yaml

@@ -38,6 +38,7 @@ services:
             $jobGateway: '@CodeRhapsodie\EzDataflowBundle\Gateway\JobGateway'
             $notificationHandler: '@Ibexa\Contracts\AdminUi\Notification\NotificationHandlerInterface'
             $translator: '@translator'
+            $scheduledDataflowGateway: '@CodeRhapsodie\EzDataflowBundle\Gateway\ScheduledDataflowGateway'
         calls:
             - [ 'setContainer', [ '@service_container' ] ]
             - [ 'performAccessCheck', [ ] ]

src/Resources/translations/messages.en.yaml

@@ -16,6 +16,7 @@ coderhapsodie.ezdataflow.workflow.list.history: History
 coderhapsodie.ezdataflow.workflow.list.edit: Edit
 coderhapsodie.ezdataflow.workflow.list.disable: Disable
 coderhapsodie.ezdataflow.workflow.list.enable: Enable
+coderhapsodie.ezdataflow.workflow.list.runonce: Run now
 coderhapsodie.ezdataflow.history.title: History
 coderhapsodie.ezdataflow.history.list.title: 'Executions list'
 coderhapsodie.ezdataflow.history.list.name: Name

src/Resources/translations/messages.fr.yaml

@@ -16,6 +16,7 @@ coderhapsodie.ezdataflow.workflow.list.history: Historique
 coderhapsodie.ezdataflow.workflow.list.edit: Éditer
 coderhapsodie.ezdataflow.workflow.list.disable: Désactiver
 coderhapsodie.ezdataflow.workflow.list.enable: Activer
+coderhapsodie.ezdataflow.workflow.list.runonce: Lancer maintenant
 coderhapsodie.ezdataflow.history.title: Historique
 coderhapsodie.ezdataflow.history.list.title: 'Liste des exécutions'
 coderhapsodie.ezdataflow.history.list.name: Nom

src/Resources/views/themes/admin/ezdataflow/Dashboard/oneshot.html.twig

@@ -1,10 +1,11 @@
 {%- block content -%}
     {% set actions %}
         <button
-            type="button"
-            class="btn ibexa-btn ibexa-btn--tertiary ibexa-btn--small"
-            data-bs-toggle="modal"
-            data-bs-target="#modal-new-oneshot"
+                id="create-oneshot-button"
+                type="button"
+                class="btn ibexa-btn ibexa-btn--tertiary ibexa-btn--small"
+                data-bs-toggle="modal"
+                data-bs-target="#modal-new-oneshot"
         >
             <svg class="ibexa-icon ibexa-icon--small ibexa-icon--create">
                 <use xlink:href="{{ ibexa_icon_path('create') }}"></use>
@@ -53,6 +54,16 @@
                     })
                 ;
             });
+            const createButton = document.getElementById('create-oneshot-button')
+
+            if (createButton) {
+                createButton.addEventListener('click', () => {
+                    const oneShotModal = document.getElementById('modal-new-oneshot');
+                    oneShotModal.querySelector('#create_oneshot_label').value = '';
+                    oneShotModal.querySelector('#create_oneshot_options').value = '';
+                    oneShotModal.querySelector('.flatpickr.flatpickr-input').parentNode.parentNode.ibexaInstance.flatpickrInstance.setDate(new Date(), true);
+                });
+            }
         });
     </script>
 {%- endblock -%}

src/Resources/views/themes/admin/ezdataflow/parts/tab/schedule_list.html.twig

@@ -40,6 +40,15 @@
                     <use xlink:href="{{ ibexa_icon_path('edit') }}"></use>
                 </svg>
             </a>
+            <button
+               class="btn ibexa-btn ibexa-btn--ghost run-oneshot ibexa-btn--no-text"
+               data-url="{{ path('coderhapsodie.ezdataflow.job.run-oneshot', {id: item.id}) }}"
+               title="{{ 'coderhapsodie.ezdataflow.workflow.list.runonce'|trans }}"
+            >
+                <svg class="ibexa-icon ibexa-icon--small ibexa-icon--create">
+                    <use xlink:href="{{ ibexa_icon_path('create') }}"></use>
+                </svg>
+            </button>
             {% if item.enabled %}
                 <a href="{{ path('coderhapsodie.ezdataflow.workflow.disable', {id: item.id}) }}"
                    class="btn ibexa-btn ibexa-btn--ghost ibexa-btn--no-text"
@@ -125,3 +134,27 @@
         {% endif %}
     </div>
 </div>
+
+<script>
+    document.querySelectorAll(".run-oneshot").forEach((el) => {
+        el.addEventListener('click', () => {
+            const oneShotModal = document.getElementById('modal-new-oneshot');
+
+            fetch(el.getAttribute('data-url'))
+                .then(response => response.json())
+                .then(result => {
+                    const node = document.createElement('div');
+                    node.innerHTML = result.form;
+                    oneShotModal.querySelector('#create_oneshot_label').value = node.querySelector('#create_oneshot_label').value;
+                    oneShotModal.querySelector('#create_oneshot_options').value = node.querySelector('#create_oneshot_options').value;
+                    oneShotModal.querySelector('.ibexa-dropdown').ibexaInstance.selectOption(node.querySelector('#create_oneshot_dataflowType').value)
+                    oneShotModal.querySelector('.flatpickr.flatpickr-input').parentNode.parentNode.ibexaInstance.flatpickrInstance.setDate(new Date(), true);
+                })
+                .then(() => {
+                    bootstrap.Tab.getOrCreateInstance(document.querySelector('#ibexa-tab-label-coderhapsodie-ezdataflow-code-rhapsodie-ezdataflow-oneshot')).show()
+                    bootstrap.Modal.getOrCreateInstance(oneShotModal).show()
+                })
+
+        });
+    });
+</script>