hazza/Phraseanet
1
0
Fork 0
mirror of https://github.com/alchemy-fr/Phraseanet.git synced 2025-10-18 15:33:15 +00:00
Code Issues Packages Projects Releases Wiki Activity

fix: Undefined class constant 'RECORD_EDIT_QUEUE' after editing

Browse Source 
CS
This commit is contained in:
jygaulier
2020-12-22 12:39:56 +01:00
parent f2f5db3df6
commit f85f0df95e
1 changed files with 15 additions and 5 deletions
Download Patch File Download Diff File Expand all files Collapse all files

20
lib/Alchemy/Phrasea/WorkerManager/Subscriber/RecordSubscriber.php
View File

@@ -21,6 +21,8 @@ use Alchemy\Phrasea\WorkerManager\Queue\MessagePublisher;
use Alchemy\Phrasea\WorkerManager\Worker\CreateRecordWorker; use Alchemy\Phrasea\WorkerManager\Worker\CreateRecordWorker;
use Alchemy\Phrasea\WorkerManager\Worker\Factory\WorkerFactoryInterface; use Alchemy\Phrasea\WorkerManager\Worker\Factory\WorkerFactoryInterface;
use Alchemy\Phrasea\WorkerManager\Worker\Resolver\TypeBasedWorkerResolver; use Alchemy\Phrasea\WorkerManager\Worker\Resolver\TypeBasedWorkerResolver;
use databox;
use Exception;
use Symfony\Component\EventDispatcher\EventSubscriberInterface; use Symfony\Component\EventDispatcher\EventSubscriberInterface;
class RecordSubscriber implements EventSubscriberInterface class RecordSubscriber implements EventSubscriberInterface
@@ -122,7 +124,7 @@ class RecordSubscriber implements EventSubscriberInterface
$em->persist($workerRunningJob); $em->persist($workerRunningJob);
$em->flush(); $em->flush();
$em->commit(); $em->commit();
} catch (\Exception $e) { } catch (Exception $e) {
$em->rollback(); $em->rollback();
} }
} }
@@ -243,7 +245,7 @@ class RecordSubscriber implements EventSubscriberInterface
$em->persist($workerRunningJob); $em->persist($workerRunningJob);
$em->flush(); $em->flush();
$em->commit(); $em->commit();
} catch (\Exception $e) { } catch (Exception $e) {
$em->rollback(); $em->rollback();
} }
} }
@@ -294,19 +296,27 @@ class RecordSubscriber implements EventSubscriberInterface
] ]
]; ];
$this->messagePublisher->publishMessage($payload, MessagePublisher::RECORD_EDIT_QUEUE); $this->messagePublisher->publishMessage($payload, MessagePublisher::RECORD_EDIT_TYPE);
} }
public static function getSubscribedEvents() public static function getSubscribedEvents()
{ {
return [ return [
/** @uses onRecordCreated */
RecordEvents::CREATED => 'onRecordCreated', RecordEvents::CREATED => 'onRecordCreated',
/** @uses onSubdefinitionCreate */
RecordEvents::SUBDEFINITION_CREATE => 'onSubdefinitionCreate', RecordEvents::SUBDEFINITION_CREATE => 'onSubdefinitionCreate',
/** @uses onDelete */
RecordEvents::DELETE => 'onDelete', RecordEvents::DELETE => 'onDelete',
/** @uses onSubdefinitionCreationFailure */
WorkerEvents::SUBDEFINITION_CREATION_FAILURE => 'onSubdefinitionCreationFailure', WorkerEvents::SUBDEFINITION_CREATION_FAILURE => 'onSubdefinitionCreationFailure',
/** @uses onRecordsWriteMeta */
WorkerEvents::RECORDS_WRITE_META => 'onRecordsWriteMeta', WorkerEvents::RECORDS_WRITE_META => 'onRecordsWriteMeta',
/** @uses onStoryCreateCover */
WorkerEvents::STORY_CREATE_COVER => 'onStoryCreateCover', WorkerEvents::STORY_CREATE_COVER => 'onStoryCreateCover',
/** @uses onSubdefinitionWritemeta */
WorkerEvents::SUBDEFINITION_WRITE_META => 'onSubdefinitionWritemeta', WorkerEvents::SUBDEFINITION_WRITE_META => 'onSubdefinitionWritemeta',
/** @uses onRecordEditInWorker */
WorkerEvents::RECORD_EDIT_IN_WORKER => 'onRecordEditInWorker' WorkerEvents::RECORD_EDIT_IN_WORKER => 'onRecordEditInWorker'
]; ];
} }
@@ -322,12 +332,12 @@ class RecordSubscriber implements EventSubscriberInterface
} }
/** /**
* @param \databox $databox * @param databox $databox
* @param string $subdefType * @param string $subdefType
* @param string $subdefName * @param string $subdefName
* @return bool * @return bool
*/ */
private function isSubdefMetadataUpdateRequired(\databox $databox, $subdefType, $subdefName) private function isSubdefMetadataUpdateRequired(databox $databox, $subdefType, $subdefName)
{ {
if ($databox->get_subdef_structure()->hasSubdef($subdefType, $subdefName)) { if ($databox->get_subdef_structure()->hasSubdef($subdefType, $subdefName)) {
return $databox->get_subdef_structure()->get_subdef($subdefType, $subdefName)->isMetadataUpdateRequired(); return $databox->get_subdef_structure()->get_subdef($subdefType, $subdefName)->isMetadataUpdateRequired();