Wabel\Zoho\CRM\Copy\ZohoDatabaseCopier::fetchFromZoho()

Complexity

Conditions	15
Paths	600

Size

Total Lines	105
Code Lines	66

Duplication

Lines	0
Ratio	0 %

Importance

Changes	3
Bugs	1	Features	1

<?php
    public function fetchFromZoho(AbstractZohoDao $dao, $incrementalSync = true, $twoWaysSync = true)
    {
        $tableName = ZohoDatabaseHelper::getTableName($dao, $this->prefix);

        if ($incrementalSync) {
            $this->logger->info("Copying incremental data for '$tableName'");
            //We need to check $lastActivity column exist.
            /* @var $existedColumns \Doctrine\DBAL\Schema\Column[] */
            $existedColumns = $this->connection->getSchemaManager()->listTableColumns($tableName);
            $existLastActivityTime = false;
            foreach ($existedColumns as $existedColumn) {
                if($existedColumn->getName() == 'lastActivityTime'){
                    $existLastActivityTime = true;
                    break;
                }
            }
            // To avoid checking this column when it is not used in a table.
            if($existLastActivityTime){
                /////'SHOW COLUMNS FROM '.$tableName.' LIKE `lastActivityTime`');
                // Let's get the last modification date:
                $lastActivityTime = $this->connection->fetchColumn('SELECT MAX(lastActivityTime) FROM '.$tableName);
                if ($lastActivityTime !== null) {
                    $lastActivityTime = new \DateTime($lastActivityTime);
                    $this->logger->info('Last activity time: '.$lastActivityTime->format('c'));
                    // Let's add one second to the last activity time (otherwise, we are fetching again the last record in DB).
                    $lastActivityTime->add(new \DateInterval('PT1S'));
                }

                $records = $dao->getRecords(null, null, $lastActivityTime);
                $deletedRecordIds = $dao->getDeletedRecordIds($lastActivityTime);
            }
        } else {
            $this->logger->notice("Copying FULL data for '$tableName'");
            $records = $dao->getRecords();
            $deletedRecordIds = [];
        }
        $this->logger->info('Fetched '.count($records).' records');

The variable $records does not seem to be defined for all execution paths leading up to this point.

        $table = $this->connection->getSchemaManager()->createSchema()->getTable($tableName);

        $flatFields = ZohoDatabaseHelper::getFlatFields($dao->getFields());

The method getFields() cannot be called from this context as it is declared protected in class Wabel\Zoho\CRM\AbstractZohoDao.

        $fieldsByName = [];
        foreach ($flatFields as $field) {
            $fieldsByName[$field['name']] = $field;
        }

        $select = $this->connection->prepare('SELECT * FROM '.$tableName.' WHERE id = :id');

        $this->connection->beginTransaction();

        foreach ($records as $record) {
            $data = [];
            $types = [];
            foreach ($table->getColumns() as $column) {
                if (in_array($column->getName(), ['id', 'uid'])) {
                    continue;
                } else {
                    $field = $fieldsByName[$column->getName()];
                    $getterName = $field['getter'];
                    $data[$column->getName()] = $record->$getterName();
                    $types[$column->getName()] = $column->getType()->getName();
                }
            }

            $select->execute(['id' => $record->getZohoId()]);
            $result = $select->fetch(\PDO::FETCH_ASSOC);
            if ($result === false) {
                $this->logger->debug("Inserting record with ID '".$record->getZohoId()."'.");

                $data['id'] = $record->getZohoId();
                $types['id'] = 'string';

                $this->connection->insert($tableName, $data, $types);

                foreach ($this->listeners as $listener) {
                    $listener->onInsert($data, $dao);
                }
            } else {
                $this->logger->debug("Updating record with ID '".$record->getZohoId()."'.");
                $identifier = ['id' => $record->getZohoId()];
                $types['id'] = 'string';

                $this->connection->update($tableName, $data, $identifier, $types);

                // Let's add the id for the update trigger
                $data['id'] = $record->getZohoId();
                foreach ($this->listeners as $listener) {
                    $listener->onUpdate($data, $result, $dao);
                }
            }
        }
        $sqlStatementUid = 'select uid from '.$this->connection->quoteIdentifier($tableName).' where id = :id';
        foreach ($deletedRecordIds as $id) {

The variable $deletedRecordIds does not seem to be defined for all execution paths leading up to this point.

            $uid = $this->connection->fetchColumn($sqlStatementUid, ['id' => $id]);
            $this->connection->delete($tableName, ['id' => $id]);
            if ($twoWaysSync) {
                // TODO: we could detect if there are changes to be updated to the server and try to warn with a log message
                // Also, let's remove the newly created field (because of the trigger) to avoid looping back to Zoho
                $this->connection->delete('local_delete', ['table_name' => $tableName, 'id' => $id]);
                $this->connection->delete('local_update', ['table_name' => $tableName, 'uid' => $uid]);
            }
        }

        $this->connection->commit();
    }
}