Method tryToReadMetadata has 42 lines of code (exceeds 25 allowed). Consider refactoring.

Open

    protected function tryToReadMetadata()
    {
        $serialized_metadata = fgets($this->file_pointer);
        if (!$serialized_metadata) {
            return new BulkStreamError(

Method generate has 41 lines of code (exceeds 25 allowed). Consider refactoring.

Open

    public static function generate(ConnectorMap $connector_map)
    {
        $details = [];
        $failing = 0;
        $working = 0;

Method guardCommandPreConditions has 40 lines of code (exceeds 25 allowed). Consider refactoring.

Open

    protected function guardCommandPreConditions(AggregateRootCommandInterface $command)
    {
        if ($this->getHistory()->isEmpty()) {
            throw new HistoryEmptyError(
                sprintf(

Function applyValues has a Cognitive Complexity of 13 (exceeds 5 allowed). Consider refactoring.

Open

    protected function applyValues(EmbeddedEntityEventInterface $event)
    {
        if (!is_callable([$event, 'getData'])) {
            throw new RuntimeError('Event instance is not support due to lack of a getData method.');
        }

• Read up
  Read up

Method validateValues has 39 lines of code (exceeds 25 allowed). Consider refactoring.

Open

    protected function validateValues(array $values)
    {
        $errors = [];
        $sanitized_values = [];

Method updateAffectedRelatives has 39 lines of code (exceeds 25 allowed). Consider refactoring.

Open

    protected function updateAffectedRelatives(
        ProjectionMap $affected_relatives_map,
        ProjectionInterface $source_projection
    ) {
        $referenced_identifier = $source_projection->getIdentifier();

Method applyEmbeddedEntityEvent has 38 lines of code (exceeds 25 allowed). Consider refactoring.

Open

    protected function applyEmbeddedEntityEvent(
        EmbeddedEntityEventInterface $embedded_entity_event,
        $auto_commit = true
    ) {
        $attribute_name = $embedded_entity_event->getParentAttributeName();

Method moveTempFileToFinalLocation has 38 lines of code (exceeds 25 allowed). Consider refactoring.

Open

    protected function moveTempFileToFinalLocation($location, EntityTypeInterface $art)
    {
        $from_uri = $this->filesystem_service->createTempUri($location, $art); // from temporary storage
        $to_uri = $this->filesystem_service->createUri($location, $art); // to final storage

Method processEmbeddedEntityCommand has 37 lines of code (exceeds 25 allowed). Consider refactoring.

Open

    protected function processEmbeddedEntityCommand(CommandInterface $command, array $custom_event_state = [])
    {
        $event_class = $command->getEventClass();
        $attribute_name = $command->getParentAttributeName();

Method applyValues has 36 lines of code (exceeds 25 allowed). Consider refactoring.

Open

    protected function applyValues(EmbeddedEntityEventInterface $event)
    {
        if (!is_callable([$event, 'getData'])) {
            throw new RuntimeError('Event instance is not support due to lack of a getData method.');
        }

Method executeHandlers has 36 lines of code (exceeds 25 allowed). Consider refactoring.

Open

    public function executeHandlers($channel_name, EventInterface $event, $subscription_index)
    {
        if (!$this->channel_map->hasKey($channel_name)) {
            throw new RuntimeError(
                sprintf(

Method createInitialData has 36 lines of code (exceeds 25 allowed). Consider refactoring.

Open

    protected function createInitialData(
        CreateAggregateRootCommand $create_command,
        StateMachineInterface $state_machine
    ) {
        $type = $this->getType();

Method read has 34 lines of code (exceeds 25 allowed). Consider refactoring.

Open

    public function read($identifier, SettingsInterface $settings = null)
    {
        try {
            $view_params = [
                'startkey' => sprintf(self::STARTKEY_FILTER, $identifier),

Method mirrorReferencedProjection has 34 lines of code (exceeds 25 allowed). Consider refactoring.

Open

    protected function mirrorReferencedProjection(EntityReferenceInterface $projection)
    {
        $projection_type = $projection->getType();
        $mirrored_attribute_map = $projection_type->getAttributes()->filter(
            function (AttributeInterface $attribute) {

Method translateFilters has 34 lines of code (exceeds 25 allowed). Consider refactoring.

Open

    protected function translateFilters(CriteriaList $filter_criteria_list)
    {
        $elasticsearch_filters = [];
        foreach ($filter_criteria_list as $criteria) {
            if ($criteria instanceof CriteriaContainerInterface) {

Method proceedWorkflow has 34 lines of code (exceeds 25 allowed). Consider refactoring.

Open

    public function proceedWorkflow(ProceedWorkflowCommand $workflow_command, StateMachineInterface $state_machine)
    {
        $this->guardCommandPreConditions($workflow_command);

        if ($workflow_command->getCurrentStateName() !== $this->getWorkflowState()) {

Similar blocks of code found in 2 locations. Consider refactoring.

Open

        if ($this->databaseExists($migration_target)) {
            $client = $this->getConnection($migration_target);
            $database_name = $this->getDatabaseName($migration_target);
            $response = $client->delete('/' . $database_name);
            if ($response->getStatusCode() !== 200) {

• Read up
  Read up

Similar blocks of code found in 2 locations. Consider refactoring.

Open

        try {
            $client = $this->getConnection($migration_target);
            $database_name = $this->getDatabaseName($migration_target);
            $response = $client->put('/' . $database_name);
            if ($response->getStatusCode() !== 201) {

• Read up
  Read up

Method getStatus has 33 lines of code (exceeds 25 allowed). Consider refactoring.

Open

    public function getStatus()
    {
        if ($this->config->has('fake_status')) {
            return new Status($this, $this->config->get('fake_status'));
        }

Method loadMigrations has 33 lines of code (exceeds 25 allowed). Consider refactoring.

Open

    public function loadMigrations()
    {
        $migration_dir = $this->config->get('directory');
        if (!is_dir($migration_dir) || !is_readable($migration_dir)) {
            throw new RuntimeError(sprintf('Given migration path is not a readable directory: %s', $migration_dir));