TechDivision\Import\Plugins\SubjectPlugin::process()

Complexity

Conditions	7
Paths	68

Size

Total Lines

60

Duplication

Lines	0
Ratio	0 %

Code Coverage

Tests	22
CRAP Score	7.3112

Importance

Changes

0

<?php
    public function process()
    {

        try {
            // immediately add the PID to lock this import process
            $this->lock();

            // load the plugin's subjects
            $subjects = $this->getPluginConfiguration()->getSubjects();

            // initialize the array for the status
            $status = array();

            // initialize the status information for the subjects
            /** @var \TechDivision\Import\Configuration\SubjectConfigurationInterface $subject */
            foreach ($subjects as $subject) {
                $status[$subject->getPrefix()] = array();
            }

            // and update it in the registry
            $this->getRegistryProcessor()->mergeAttributesRecursive(RegistryKeys::STATUS, $status);

            // process all the subjects found in the system configuration
            /** @var \TechDivision\Import\Configuration\SubjectConfigurationInterface $subject */
            foreach ($subjects as $subject) {
                $this->processSubject($subject);
            }

            // update the number of imported bunches
            $this->getRegistryProcessor()->mergeAttributesRecursive(
                RegistryKeys::STATUS,
                array(RegistryKeys::BUNCHES => $this->bunches)
            );

            // stop the application, because we didn't process any file
            if ($this->bunches === 0) {
                throw new MissingFilesException(
                    sprintf(
                        'Operation %s has been stopped because no import files can be found in directory %s',
                        $this->getConfiguration()->getOperationName(),
                        $this->getConfiguration()->getSourceDir()
                    )
                );
            }

        } catch (MissingOkFileException $mofe) {
            // stop the application if we can't find the mandatory OK file
            $this->getApplication()->stop($mofe->getMessage());
        } catch (MissingFilesException $mfe) {
            // stop the application if can't find at least one file to process
            $this->getApplication()->stop($mfe->getMessage());
        } catch (\Exception $e) {
            // re-throw the exception
            throw $e;
        } finally {
            // finally, if a PID has been set, remove it
            // from the PID file to unlock the importer
            $this->unlock();
        }
    }