Wabel / zoho-crm-copy-db

src/ZohoDatabaseCopier.php

Braces +1 added lines, -2 removed lines

@@ -246,8 +246,7 @@
             foreach ($table->getColumns() as $column) {
                 if (in_array($column->getName(),['id','uid'])) {
                     continue;
-                }
-                else {
+                } else {
                     $field = $fieldsByName[$column->getName()];
                     $getterName = $field['getter'];
                     $data[$column->getName()] = $record->$getterName();

Spacing +5 added lines, -5 removed lines

@@ -75,7 +75,7 @@ 
      */
     public function fetchFromZoho(AbstractZohoDao $dao, $incrementalSync = true, $twoWaysSync = true)
     {
-        $tableName = ZohoDatabaseHelper::getTableName($dao,$this->prefix);
+        $tableName = ZohoDatabaseHelper::getTableName($dao, $this->prefix);
 
         if ($incrementalSync) {
             $this->logger->info("Copying incremental data for '$tableName'");
@@ -113,7 +113,7 @@ 
             $data = [];
             $types = [];
             foreach ($table->getColumns() as $column) {
-                if (in_array($column->getName(),['id','uid'])) {
+                if (in_array($column->getName(), ['id', 'uid'])) {
                     continue;
                 }
                 else {
@@ -154,12 +154,12 @@ 
         $sqlStatementUid = 'select uid from '.$this->connection->quoteIdentifier($tableName).' where id = :id';
         foreach ($deletedRecordIds as $id) {
             $uid = $this->connection->fetchColumn($sqlStatementUid, ['id' => $id]);
-            $this->connection->delete($tableName, [ '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->delete('local_delete', ['table_name' => $tableName, 'id' => $id]);
+                $this->connection->delete('local_update', ['table_name' => $tableName, 'uid' => $uid]);
             }
         }
 

src/LocalChangesTracker.php

Spacing +2 added lines, -2 removed lines

@@ -50,9 +50,9 @@
         $localDelete = $schema->createTable("local_delete");
         $localDelete->addColumn("table_name", 'string', ['length' => 100]);
         $localDelete->addColumn("uid", 'integer');
-        $localDelete->addColumn("id",  'string', ['length' => 100]);
+        $localDelete->addColumn("id", 'string', ['length' => 100]);
         $localDelete->setPrimaryKey(array("table_name", "uid"));
-        $localDelete->addUniqueIndex(['id','table_name']);
+        $localDelete->addUniqueIndex(['id', 'table_name']);
 
         $dbalTableDiffService = new DbalTableDiffService($this->connection, $this->logger);
         $dbalTableDiffService->createOrUpdateTable($localUpdate);

src/ZohoDatabaseHelper.php

Doc Comments +1 added lines

@@ -16,6 +16,7 @@
      * Computes the name of the table based on the DAO plural module name.
      *
      * @param AbstractZohoDao $dao
+     * @param string $prefix
      *
      * @return string
      */

src/ZohoDatabasePusher.php

Indentation +5 added lines, -5 removed lines

@@ -106,11 +106,11 @@
                 $rowsDeleted[] = $row['uid'];
             }
             if($update && isset($row['updated_fieldname'])){
-               $columnName = $row['updated_fieldname'];
-               $zohoBean->getZohoId()?:$zohoBean->setZohoId($row['id']);
-               $this->updateDataZohoBean($zohoBean, $fieldsMatching, $columnName, $row[$columnName]);
-               $zohoBeans[$row['uid']] = $zohoBean;
-               $rowsDeleted[] = $row['uid'];
+                $columnName = $row['updated_fieldname'];
+                $zohoBean->getZohoId()?:$zohoBean->setZohoId($row['id']);
+                $this->updateDataZohoBean($zohoBean, $fieldsMatching, $columnName, $row[$columnName]);
+                $zohoBeans[$row['uid']] = $zohoBean;
+                $rowsDeleted[] = $row['uid'];
             }
         }
         $zohoDao->save($zohoBeans);

Spacing +22 added lines, -22 removed lines

@@ -53,7 +53,7 @@ 
      * @param AbstractZohoDao $zohoDao
      * @return array
      */
-    private function findMethodValues(AbstractZohoDao $zohoDao){
+    private function findMethodValues(AbstractZohoDao $zohoDao) {
         $fieldsMatching = array();
         foreach ($zohoDao->getFields() as $fieldsDescriptor) {
             foreach (array_values($fieldsDescriptor) as $fieldDescriptor) {
@@ -72,14 +72,14 @@ 
      * @param AbstractZohoDao $zohoDao
      * @param string $localTable
      */
-    public function pushDataToZoho(AbstractZohoDao $zohoDao, $update = false){
+    public function pushDataToZoho(AbstractZohoDao $zohoDao, $update = false) {
         $localTable = $update ? 'local_update' : 'local_insert';
         $fieldsMatching = $this->findMethodValues($zohoDao);
-        $tableName = ZohoDatabaseHelper::getTableName($zohoDao,$this->prefix);
+        $tableName = ZohoDatabaseHelper::getTableName($zohoDao, $this->prefix);
         $rowsDeleted = [];
         $statement = $this->connection->createQueryBuilder();
         $statement->select('zcrm.*');
-        if($update){
+        if ($update) {
             $statement->addSelect('l.field_name as updated_fieldname');
         }
         $statement->from($localTable, 'l')
@@ -94,29 +94,29 @@ 
         while ($row = $results->fetch()) {
             $beanClassName = $zohoDao->getBeanClassName();
             /* @var $zohoBean ZohoBeanInterface */
-            if(isset($zohoBeans[$row['uid']])){
+            if (isset($zohoBeans[$row['uid']])) {
                 $zohoBean = $zohoBeans[$row['uid']];
-            }else{
+            } else {
                 $zohoBean = new $beanClassName();
             }
  
-            if(!$update){
+            if (!$update) {
                 $this->insertDataZohoBean($zohoBean, $fieldsMatching, $row);
-                $zohoBeans[$row['uid']] =  $zohoBean;
+                $zohoBeans[$row['uid']] = $zohoBean;
                 $rowsDeleted[] = $row['uid'];
             }
-            if($update && isset($row['updated_fieldname'])){
+            if ($update && isset($row['updated_fieldname'])) {
                $columnName = $row['updated_fieldname'];
-               $zohoBean->getZohoId()?:$zohoBean->setZohoId($row['id']);
+               $zohoBean->getZohoId() ?: $zohoBean->setZohoId($row['id']);
                $this->updateDataZohoBean($zohoBean, $fieldsMatching, $columnName, $row[$columnName]);
                $zohoBeans[$row['uid']] = $zohoBean;
                $rowsDeleted[] = $row['uid'];
             }
         }
         $zohoDao->save($zohoBeans);
-        if(!$update){
+        if (!$update) {
             foreach ($zohoBeans as $uid => $zohoBean) {
-                $this->connection->update($tableName, [ 'id'=>$zohoBean->getZohoId() ], ['uid'=>$uid ]);
+                $this->connection->update($tableName, ['id'=>$zohoBean->getZohoId()], ['uid'=>$uid]);
             }
         }
         $this->connection->executeUpdate('delete from '.$localTable.' where uid in ( :rowsDeleted)',
@@ -153,10 +153,10 @@ 
      * @param type $columnName
      * @param type $valueDb
      */
-    private function updateDataZohoBean(ZohoBeanInterface $zohoBean, array $fieldsMatching, $columnName, $valueDb){
-        if (!in_array($columnName,['id','uid']) || (isset($fieldsMatching[$columnName]))) {
+    private function updateDataZohoBean(ZohoBeanInterface $zohoBean, array $fieldsMatching, $columnName, $valueDb) {
+        if (!in_array($columnName, ['id', 'uid']) || (isset($fieldsMatching[$columnName]))) {
             $type = $fieldsMatching[$columnName]['type'];
-            $value = is_null($valueDb)?$valueDb:$this->formatValueToBeans($type, $valueDb);
+            $value = is_null($valueDb) ? $valueDb : $this->formatValueToBeans($type, $valueDb);
             $zohoBean->{$fieldsMatching[$columnName]['setter']}($value);
         }
     }
@@ -167,7 +167,7 @@ 
      * @param mixed $value
      * @return mixed
      */
-    private function formatValueToBeans($type ,$value)
+    private function formatValueToBeans($type, $value)
     {
         switch ($type) {
             case 'Date':
@@ -184,9 +184,9 @@ 
      * Run deleted rows to Zoho : local_delete.
      * @param AbstractZohoDao $zohoDao
      */
-    public function pushDeletedRows(AbstractZohoDao $zohoDao){
+    public function pushDeletedRows(AbstractZohoDao $zohoDao) {
         $localTable = 'local_delete';
-        $tableName = ZohoDatabaseHelper::getTableName($zohoDao,$this->prefix);
+        $tableName = ZohoDatabaseHelper::getTableName($zohoDao, $this->prefix);
         $statement = $this->connection->createQueryBuilder();
         $statement->select('l.id')
         ->from($localTable, 'l')
@@ -197,7 +197,7 @@ 
         $results = $statement->execute();
         while ($row = $results->fetch()) {
             $zohoDao->delete($row['id']);
-            $this->connection->delete($localTable, ['table_name' => $tableName,'id' => $row['id']]);
+            $this->connection->delete($localTable, ['table_name' => $tableName, 'id' => $row['id']]);
         }
 }
     
@@ -205,7 +205,7 @@ 
      * Run inserted rows to Zoho : local_insert.
      * @param AbstractZohoDao $zohoDao
      */
-    public function pushInsertedRows(AbstractZohoDao $zohoDao){
+    public function pushInsertedRows(AbstractZohoDao $zohoDao) {
         return $this->pushDataToZoho($zohoDao);
     }
 
@@ -213,8 +213,8 @@ 
      * Run updated rows to Zoho : local_update.
      * @param AbstractZohoDao $zohoDao
      */
-    public function pushUpdatedRows(AbstractZohoDao $zohoDao){
-        $this->pushDataToZoho($zohoDao,true);
+    public function pushUpdatedRows(AbstractZohoDao $zohoDao) {
+        $this->pushDataToZoho($zohoDao, true);
     }
 
     /**

Braces +1 added lines, -1 removed lines

@@ -96,7 +96,7 @@
             /* @var $zohoBean ZohoBeanInterface */
             if(isset($zohoBeans[$row['uid']])){
                 $zohoBean = $zohoBeans[$row['uid']];
-            }else{
+            } else{
                 $zohoBean = new $beanClassName();
             }
  

src/ZohoDatabaseModelSync.php

Spacing +1 added lines, -1 removed lines

@@ -72,7 +72,7 @@
             $this->localChangesTracker->createTrackingTables();
         }
 
-        $tableName = ZohoDatabaseHelper::getTableName($dao,$this->prefix);
+        $tableName = ZohoDatabaseHelper::getTableName($dao, $this->prefix);
         $this->logger->info("Synchronizing DB Model for ".$tableName);
 
         $schema = new Schema();

src/ZohoSyncDatabaseCommand.php

Spacing +3 added lines, -3 removed lines

@@ -102,7 +102,7 @@ 
      * Sychronizes the model of the database with Zoho records.
      * @param OutputInterface $output
      */
-    private function syncModel(InputInterface $input, OutputInterface $output){
+    private function syncModel(InputInterface $input, OutputInterface $output) {
         $this->zohoDatabaseModelSync->setLogger(new ConsoleLogger($output));
 
         $twoWaysSync = !$input->getOption('fetch-only');
@@ -120,7 +120,7 @@ 
      * @param InputInterface $input
      * @param OutputInterface $output
      */
-    private function fetchDb(InputInterface $input, OutputInterface $output){
+    private function fetchDb(InputInterface $input, OutputInterface $output) {
 
         if ($input->getOption('reset')) {
             $incremental = false;
@@ -143,7 +143,7 @@ 
      * Run the push Db command.
      * @param OutputInterface $output
      */
-    private function pushDb(OutputInterface $output){
+    private function pushDb(OutputInterface $output) {
         $this->zohoDatabaseSync->setLogger(new ConsoleLogger($output));
 
         $output->writeln('Starting synchronize Zoho data into Zoho CRM.');