Wabel / zoho-crm-copy-db

src/ZohoDatabaseCopier.php

Unused Use Statements -1 removed lines

@@ -6,7 +6,6 @@
 use Psr\Log\LoggerInterface;
 use Psr\Log\NullLogger;
 use Wabel\Zoho\CRM\AbstractZohoDao;
-use Wabel\Zoho\CRM\Request\Response;
 use zcrmsdk\crm\crud\ZCRMRecord;
 use zcrmsdk\crm\exception\ZCRMException;
 

Spacing +14 added lines, -14 removed lines

@@ -71,11 +71,11 @@ 
     {
         $users = $this->zohoUserService->getUsers();
         $tableName = 'users';
-        $this->logger->info('Fetched ' . count($users) . ' records');
+        $this->logger->info('Fetched '.count($users).' records');
 
         $table = $this->connection->getSchemaManager()->createSchema()->getTable($tableName);
 
-        $select = $this->connection->prepare('SELECT * FROM ' . $tableName . ' WHERE id = :id');
+        $select = $this->connection->prepare('SELECT * FROM '.$tableName.' WHERE id = :id');
 
         $this->connection->beginTransaction();
         foreach ($users as $user) {
@@ -112,14 +112,14 @@ 
             $select->execute(['id' => $user->getId()]);
             $result = $select->fetch(\PDO::FETCH_ASSOC);
             if ($result === false && $data) {
-                $this->logger->debug("Inserting record with ID '" . $user->getId() . "'.");
+                $this->logger->debug("Inserting record with ID '".$user->getId()."'.");
 
                 $data['id'] = $user->getId();
                 $types['id'] = 'string';
 
                 $this->connection->insert($tableName, $data, $types);
             } elseif ($data) {
-                $this->logger->debug("Updating record with ID '" . $user->getId() . "'.");
+                $this->logger->debug("Updating record with ID '".$user->getId()."'.");
                 $identifier = ['id' => $user->getId()];
                 $types['id'] = 'string';
                 $this->connection->update($tableName, $data, $identifier, $types);
@@ -150,15 +150,15 @@ 
                 $tableDetail = $this->connection->getSchemaManager()->listTableDetails($tableName);
                 $lastActivityTime = null;
                 if ($tableDetail->hasColumn('modifiedTime')) {
-                    $lastActivityTime = $this->connection->fetchColumn('SELECT MAX(modifiedTime) FROM ' . $tableName);
+                    $lastActivityTime = $this->connection->fetchColumn('SELECT MAX(modifiedTime) FROM '.$tableName);
                 }
                 if (!$lastActivityTime && $tableDetail->hasColumn('createdTime')) {
-                    $lastActivityTime = $this->connection->fetchColumn('SELECT MAX(createdTime) FROM ' . $tableName);
+                    $lastActivityTime = $this->connection->fetchColumn('SELECT MAX(createdTime) FROM '.$tableName);
                 }
 
                 if ($lastActivityTime !== null) {
                     $lastActivityTime = new \DateTime($lastActivityTime, new \DateTimeZone($dao->getZohoClient()->getTimezone()));
-                    $this->logger->info('Last modified time: ' . $lastActivityTime->format(\DateTime::ATOM));
+                    $this->logger->info('Last modified time: '.$lastActivityTime->format(\DateTime::ATOM));
                     // 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'));
                 }
@@ -171,7 +171,7 @@ 
                 $deletedRecords = [];
             }
         } catch (ZCRMException $exception) {
-            $this->logger->error('Error when getting records for module ' . $tableName . ': ' . $exception->getMessage(), [
+            $this->logger->error('Error when getting records for module '.$tableName.': '.$exception->getMessage(), [
                 'exception' => $exception
             ]);
             if ($throwErrors) {
@@ -179,11 +179,11 @@ 
             }
             return;
         }
-        $this->logger->info('Fetched ' . count($records) . ' records');
+        $this->logger->info('Fetched '.count($records).' records');
 
         $table = $this->connection->getSchemaManager()->createSchema()->getTable($tableName);
 
-        $select = $this->connection->prepare('SELECT * FROM ' . $tableName . ' WHERE id = :id');
+        $select = $this->connection->prepare('SELECT * FROM '.$tableName.' WHERE id = :id');
 
         $this->connection->beginTransaction();
 
@@ -216,7 +216,7 @@ 
             $select->execute(['id' => $record->getZohoId()]);
             $result = $select->fetch(\PDO::FETCH_ASSOC);
             if ($result === false) {
-                $this->logger->debug("Inserting record with ID '" . $record->getZohoId() . "'.");
+                $this->logger->debug("Inserting record with ID '".$record->getZohoId()."'.");
 
                 $data['id'] = $record->getZohoId();
                 $types['id'] = 'string';
@@ -227,7 +227,7 @@ 
                     $listener->onInsert($data, $dao);
                 }
             } else {
-                $this->logger->debug("Updating record with ID '" . $record->getZohoId() . "'.");
+                $this->logger->debug("Updating record with ID '".$record->getZohoId()."'.");
                 $identifier = ['id' => $record->getZohoId()];
                 $types['id'] = 'string';
 
@@ -240,7 +240,7 @@ 
                 }
             }
         }
-        $sqlStatementUid = 'select uid from ' . $this->connection->quoteIdentifier($tableName) . ' where id = :id';
+        $sqlStatementUid = 'select uid from '.$this->connection->quoteIdentifier($tableName).' where id = :id';
         foreach ($deletedRecords as $deletedRecord) {
             $uid = $this->connection->fetchColumn($sqlStatementUid, ['id' => $deletedRecord->getEntityId()]);
             $this->connection->delete($tableName, ['id' => $deletedRecord->getEntityId()]);
@@ -251,7 +251,7 @@ 
                 $this->connection->delete('local_update', ['table_name' => $tableName, 'uid' => $uid]);
             }
         }
-        $this->logger->info('Deleted ' . count($deletedRecords) . ' records');
+        $this->logger->info('Deleted '.count($deletedRecords).' records');
 
         $this->connection->commit();
     }

src/ZohoDatabaseModelSync.php

Switch Indentation +91 added lines, -91 removed lines

@@ -110,80 +110,80 @@ 
             $options = [];
             // Note: full list of types available here: https://www.zoho.com/crm/help/customization/custom-fields.html
             switch ($field->getType()) {
-            case 'fileupload':
-                $type = 'string';
-                $length = $field->getMaxlength() && $field->getMaxlength() > 0?$field->getMaxlength() : 255;
-                break;
-            case 'lookup':
-                $type = 'string';
-                $length = $field->getMaxlength() && $field->getMaxlength() > 0?$field->getMaxlength() : 100;
-                $index = true;
-                break;
-            case 'userlookup':
-            case 'ownerlookup':
-                $type = 'string';
-                $index = true;
-                $length = $field->getMaxlength() && $field->getMaxlength() > 0?$field->getMaxlength() : 25;
-                break;
-            case 'formula':
-                // Note: a Formula can return any type, but we have no way to know which type it returns...
-                $type = 'string';
-                $length = $field->getMaxlength() && $field->getMaxlength() > 0?$field->getMaxlength() : 100;
-                break;
-            case 'datetime':
-                $type = 'datetime';
-                break;
-            case 'date':
-                $type = 'date';
-                break;
-            case 'boolean':
-                $type = 'boolean';
-                break;
-            case 'textarea':
-                $type = 'text';
-                break;
-            case 'bigint':
-                $type = 'bigint';
-                break;
-            case 'phone':
-            case 'text':
-            case 'url':
-            case 'email':
-            case 'picklist':
-            case 'website':
-                $type = 'string';
-                $length = $field->getMaxlength() && $field->getMaxlength() > 0?$field->getMaxlength() : 255;
-                break;
-            case 'multiselectlookup':
-            case 'multiuserlookup':
-            case 'multiselectpicklist':
-                $type = 'text';
-                break;
-            case 'percent':
-                $type = 'integer';
-                break;
-            case 'double':
-                $type = 'float';
-                break;
-            case 'autonumber':
-            case 'integer':
-                $type = 'integer';
-                $length = $field->getMaxlength() && $field->getMaxlength() > 0?$field->getMaxlength() : 255;
-                break;
-            case 'currency':
-            case 'decimal':
-                $type = 'decimal';
-                $options['scale'] = 2;
-                break;
-            case 'consent_lookup':
-            case 'profileimage':
-            case 'ALARM':
-            case 'RRULE':
-            case 'event_reminder':
-                continue 2;
+                case 'fileupload':
+                    $type = 'string';
+                    $length = $field->getMaxlength() && $field->getMaxlength() > 0?$field->getMaxlength() : 255;
                     break;
-            default:
-                throw new \RuntimeException('Unknown type "'.$field->getType().'"');
+                case 'lookup':
+                    $type = 'string';
+                    $length = $field->getMaxlength() && $field->getMaxlength() > 0?$field->getMaxlength() : 100;
+                    $index = true;
+                    break;
+                case 'userlookup':
+                case 'ownerlookup':
+                    $type = 'string';
+                    $index = true;
+                    $length = $field->getMaxlength() && $field->getMaxlength() > 0?$field->getMaxlength() : 25;
+                    break;
+                case 'formula':
+                    // Note: a Formula can return any type, but we have no way to know which type it returns...
+                    $type = 'string';
+                    $length = $field->getMaxlength() && $field->getMaxlength() > 0?$field->getMaxlength() : 100;
+                    break;
+                case 'datetime':
+                    $type = 'datetime';
+                    break;
+                case 'date':
+                    $type = 'date';
+                    break;
+                case 'boolean':
+                    $type = 'boolean';
+                    break;
+                case 'textarea':
+                    $type = 'text';
+                    break;
+                case 'bigint':
+                    $type = 'bigint';
+                    break;
+                case 'phone':
+                case 'text':
+                case 'url':
+                case 'email':
+                case 'picklist':
+                case 'website':
+                    $type = 'string';
+                    $length = $field->getMaxlength() && $field->getMaxlength() > 0?$field->getMaxlength() : 255;
+                    break;
+                case 'multiselectlookup':
+                case 'multiuserlookup':
+                case 'multiselectpicklist':
+                    $type = 'text';
+                    break;
+                case 'percent':
+                    $type = 'integer';
+                    break;
+                case 'double':
+                    $type = 'float';
+                    break;
+                case 'autonumber':
+                case 'integer':
+                    $type = 'integer';
+                    $length = $field->getMaxlength() && $field->getMaxlength() > 0?$field->getMaxlength() : 255;
+                    break;
+                case 'currency':
+                case 'decimal':
+                    $type = 'decimal';
+                    $options['scale'] = 2;
+                    break;
+                case 'consent_lookup':
+                case 'profileimage':
+                case 'ALARM':
+                case 'RRULE':
+                case 'event_reminder':
+                    continue 2;
+                        break;
+                default:
+                    throw new \RuntimeException('Unknown type "'.$field->getType().'"');
             }
 
             if ($length) {
@@ -228,24 +228,24 @@ 
             $length = null;
             $index = false;
             switch ($field) {
-            case 'zuid':
-                $type = 'string';
-                $length = 100;
-                $index = true;
-                break;
-            case 'name':
-            case 'email':
-                $type = 'string';
-                $length = 255;
-                $index = true;
-                break;
-            case 'phone':
-            case 'website':
-                $type = 'text';
-                break;
-            default:
-                $type = 'string';
-                $length = 100;
+                case 'zuid':
+                    $type = 'string';
+                    $length = 100;
+                    $index = true;
+                    break;
+                case 'name':
+                case 'email':
+                    $type = 'string';
+                    $length = 255;
+                    $index = true;
+                    break;
+                case 'phone':
+                case 'website':
+                    $type = 'text';
+                    break;
+                default:
+                    $type = 'string';
+                    $length = 100;
             }
 
             $options = [];

src/LocalChangesTracker.php

Spacing +5 added lines, -5 removed lines

@@ -49,7 +49,7 @@ 
         $localDelete = $schema->createTable('local_delete');
         $localDelete->addColumn('table_name', 'string', ['length' => 100]);
         $localDelete->addColumn('uid', 'string', ['length' => 36]);
-        $localDelete->addColumn('id', 'string', ['length' => 100,'notnull'=>false]);
+        $localDelete->addColumn('id', 'string', ['length' => 100, 'notnull'=>false]);
         $localDelete->setPrimaryKey(array('table_name', 'uid'));
         $localDelete->addUniqueIndex(['id', 'table_name']);
 
@@ -62,7 +62,7 @@ 
     public function createUuidInsertTrigger(Table $table)
     {
         $triggerName = sprintf('TRG_%s_SETUUIDBEFOREINSERT', $table->getName());
-        $this->logger->info('Creating ' . $triggerName . ' trigger for table ' . $table->getName() . '...');
+        $this->logger->info('Creating '.$triggerName.' trigger for table '.$table->getName().'...');
 
         //Fix - temporary MySQL 5.7 strict mode
         $sql = sprintf(
@@ -91,7 +91,7 @@ 
     public function createInsertTrigger(Table $table)
     {
         $triggerName = sprintf('TRG_%s_ONINSERT', $table->getName());
-        $this->logger->info('Creating ' . $triggerName . ' trigger for table ' . $table->getName() . '...');
+        $this->logger->info('Creating '.$triggerName.' trigger for table '.$table->getName().'...');
 
         $sql = sprintf(
             '
@@ -116,7 +116,7 @@ 
     public function createDeleteTrigger(Table $table)
     {
         $triggerName = sprintf('TRG_%s_ONDELETE', $table->getName());
-        $this->logger->info('Creating ' . $triggerName . ' trigger for table ' . $table->getName() . '...');
+        $this->logger->info('Creating '.$triggerName.' trigger for table '.$table->getName().'...');
 
         $sql = sprintf(
             '
@@ -141,7 +141,7 @@ 
     public function createUpdateTrigger(Table $table)
     {
         $triggerName = sprintf('TRG_%s_ONUPDATE', $table->getName());
-        $this->logger->info('Creating ' . $triggerName . ' trigger for table ' . $table->getName() . '...');
+        $this->logger->info('Creating '.$triggerName.' trigger for table '.$table->getName().'...');
 
         $innerCode = '';
 

src/ZohoSyncDatabaseCommand.php

Spacing +5 added lines, -5 removed lines

@@ -101,7 +101,7 @@ 
         $this->zohoDatabaseModelSync = $zohoDatabaseModelSync;
         $this->zohoDatabaseCopier = $zohoDatabaseCopier;
         $this->zohoDatabaseSync = $zohoDatabaseSync;
-        $this->zohoEntitiesGenerator =  $zohoEntitiesGenerator;
+        $this->zohoEntitiesGenerator = $zohoEntitiesGenerator;
         $this->zohoClient = $zohoClient;
         $this->pathZohoDaos = $pathZohoDaos;
         $this->namespaceZohoDaos = $namespaceZohoDaos;
@@ -138,7 +138,7 @@ 
             if ($input->getOption('log-path') && $input->getOption('clear-logs')) {
                 $this->logger->notice('Clearing logs...');
                 $path = $input->getOption('log-path');
-                $logFile = $path . '/ZCRMClientLibrary.log';
+                $logFile = $path.'/ZCRMClientLibrary.log';
                 if (file_exists($logFile)) {
                     if (is_writable($logFile)) {
                         if (file_put_contents($logFile, '') === false) {
@@ -152,7 +152,7 @@ 
                 }
             }
 
-            if(!$input->getOption('limit')) {
+            if (!$input->getOption('limit')) {
                 ini_set('memory_limit', '-1');
             }
 
@@ -177,7 +177,7 @@ 
             if ($input->getOption('log-path') && $input->getOption('dump-logs')) {
                 $this->logger->info('Dumping logs...');
                 $path = $input->getOption('log-path');
-                $logFile = $path . '/ZCRMClientLibrary.log';
+                $logFile = $path.'/ZCRMClientLibrary.log';
                 if (file_exists($logFile)) {
                     if (is_readable($logFile)) {
                         $this->logger->info(file_get_contents($logFile));
@@ -291,7 +291,7 @@ 
     {
         $this->logger->notice('Starting to push data from local database into Zoho CRM...');
         foreach ($this->zohoDaos as $zohoDao) {
-            if($zohoDao->getFieldFromFieldName('createdTime')) {
+            if ($zohoDao->getFieldFromFieldName('createdTime')) {
                 $this->zohoDatabaseSync->pushToZoho($zohoDao);
             }
         }