@@ -92,8 +92,9 @@ discard block |
||
| 92 | 92 | */ |
| 93 | 93 | public function setUpdateInterval($updateInterval) |
| 94 | 94 | { |
| 95 | - if ($updateInterval <= 0) |
|
| 96 | - throw new \RuntimeException('Invalid update interval specified'); |
|
| 95 | + if ($updateInterval <= 0) { |
|
| 96 | + throw new \RuntimeException('Invalid update interval specified'); |
|
| 97 | + } |
|
| 97 | 98 | |
| 98 | 99 | $this->_updateInterval = $updateInterval; |
| 99 | 100 | } |
@@ -133,8 +134,9 @@ discard block |
||
| 133 | 134 | */ |
| 134 | 135 | public function setListenPort($listenPort) |
| 135 | 136 | { |
| 136 | - if ($listenPort < 1 || $listenPort > 65535) |
|
| 137 | - throw new \RuntimeException('Invalid port specified'); |
|
| 137 | + if ($listenPort < 1 || $listenPort > 65535) { |
|
| 138 | + throw new \RuntimeException('Invalid port specified'); |
|
| 139 | + } |
|
| 138 | 140 | |
| 139 | 141 | $this->_listenPort = $listenPort; |
| 140 | 142 | } |
@@ -142,7 +142,7 @@ |
||
| 142 | 142 | if ($configuration === false) |
| 143 | 143 | throw new InvalidConfigurationException('Failed to parse the specified configuration file'); |
| 144 | 144 | |
| 145 | - $instances = []; |
|
| 145 | + $instances = []; |
|
| 146 | 146 | |
| 147 | 147 | // Parse sections |
| 148 | 148 | foreach ($configuration as $section => $values) |
@@ -124,23 +124,26 @@ discard block |
||
| 124 | 124 | private function parseConfiguration(InputInterface $input) |
| 125 | 125 | { |
| 126 | 126 | // Check that the configuration file exists |
| 127 | - if (!file_exists($input->getArgument('configFile'))) |
|
| 128 | - throw new InvalidConfigurationException('The specified configuration file does not exist'); |
|
| 127 | + if (!file_exists($input->getArgument('configFile'))) { |
|
| 128 | + throw new InvalidConfigurationException('The specified configuration file does not exist'); |
|
| 129 | + } |
|
| 129 | 130 | |
| 130 | 131 | // Check that the database exists and is writable |
| 131 | 132 | $databasePath = $input->getArgument('databaseFile'); |
| 132 | 133 | |
| 133 | - if (!file_exists($databasePath)) |
|
| 134 | - throw new InvalidConfigurationException('The specified database path does not exist'); |
|
| 135 | - else if (!is_writable($databasePath)) |
|
| 136 | - throw new InvalidConfigurationException('The specified database path is not writable'); |
|
| 134 | + if (!file_exists($databasePath)) { |
|
| 135 | + throw new InvalidConfigurationException('The specified database path does not exist'); |
|
| 136 | + } else if (!is_writable($databasePath)) { |
|
| 137 | + throw new InvalidConfigurationException('The specified database path is not writable'); |
|
| 138 | + } |
|
| 137 | 139 | |
| 138 | 140 | // Parse the configuration file |
| 139 | 141 | $configuration = parse_ini_file($input->getArgument('configFile'), true); |
| 140 | 142 | |
| 141 | 143 | // Check that the file was parsed |
| 142 | - if ($configuration === false) |
|
| 143 | - throw new InvalidConfigurationException('Failed to parse the specified configuration file'); |
|
| 144 | + if ($configuration === false) { |
|
| 145 | + throw new InvalidConfigurationException('Failed to parse the specified configuration file'); |
|
| 146 | + } |
|
| 144 | 147 | |
| 145 | 148 | $instances = []; |
| 146 | 149 | |
@@ -157,8 +160,9 @@ discard block |
||
| 157 | 160 | $instance = new Instance($name, $address, $port); |
| 158 | 161 | |
| 159 | 162 | // Optionally set credentials |
| 160 | - if (isset($values['username']) && isset($values['password'])) |
|
| 161 | - $instance->setCredentials($values['username'], $values['password']); |
|
| 163 | + if (isset($values['username']) && isset($values['password'])) { |
|
| 164 | + $instance->setCredentials($values['username'], $values['password']); |
|
| 165 | + } |
|
| 162 | 166 | |
| 163 | 167 | $instances[] = $instance; |
| 164 | 168 | break; |
@@ -166,8 +170,9 @@ discard block |
||
| 166 | 170 | } |
| 167 | 171 | |
| 168 | 172 | // Validate the configuration. We need at least one instance. |
| 169 | - if (empty($instances)) |
|
| 170 | - throw new InvalidConfigurationException('No instances defined, you need to specify at least one instance'); |
|
| 173 | + if (empty($instances)) { |
|
| 174 | + throw new InvalidConfigurationException('No instances defined, you need to specify at least one instance'); |
|
| 175 | + } |
|
| 171 | 176 | |
| 172 | 177 | // Create the configuration object |
| 173 | 178 | $config = new Configuration($databasePath, $instances); |
@@ -196,8 +201,9 @@ discard block |
||
| 196 | 201 | */ |
| 197 | 202 | private static function getSectionType($section) |
| 198 | 203 | { |
| 199 | - if (substr($section, 0, 8) === 'instance') |
|
| 200 | - return Configuration::SECTION_TYPE_INSTANCE; |
|
| 204 | + if (substr($section, 0, 8) === 'instance') { |
|
| 205 | + return Configuration::SECTION_TYPE_INSTANCE; |
|
| 206 | + } |
|
| 201 | 207 | |
| 202 | 208 | throw new InvalidConfigurationException('Unknown section "' . $section . '"'); |
| 203 | 209 | } |
@@ -330,7 +330,7 @@ discard block |
||
| 330 | 330 | $propertyNames = []; |
| 331 | 331 | $serializableProperties = array_diff($cls->getProperties(), $cls->getProperties(\ReflectionProperty::IS_STATIC)); |
| 332 | 332 | |
| 333 | - foreach($serializableProperties as $property) { |
|
| 333 | + foreach ($serializableProperties as $property) { |
|
| 334 | 334 | $propertyNames[] = $property->getName(); |
| 335 | 335 | } |
| 336 | 336 | |
@@ -572,7 +572,7 @@ discard block |
||
| 572 | 572 | $con = Propel::getServiceContainer()->getWriteConnection(ChannelTableMap::DATABASE_NAME); |
| 573 | 573 | } |
| 574 | 574 | |
| 575 | - $con->transaction(function () use ($con) { |
|
| 575 | + $con->transaction(function() use ($con) { |
|
| 576 | 576 | $deleteQuery = ChildChannelQuery::create() |
| 577 | 577 | ->filterByPrimaryKey($this->getPrimaryKey()); |
| 578 | 578 | $ret = $this->preDelete($con); |
@@ -607,7 +607,7 @@ discard block |
||
| 607 | 607 | $con = Propel::getServiceContainer()->getWriteConnection(ChannelTableMap::DATABASE_NAME); |
| 608 | 608 | } |
| 609 | 609 | |
| 610 | - return $con->transaction(function () use ($con) { |
|
| 610 | + return $con->transaction(function() use ($con) { |
|
| 611 | 611 | $isInsert = $this->isNew(); |
| 612 | 612 | $ret = $this->preSave($con); |
| 613 | 613 | if ($isInsert) { |
@@ -868,7 +868,7 @@ discard block |
||
| 868 | 868 | $key = 'Instance'; |
| 869 | 869 | } |
| 870 | 870 | |
| 871 | - $result[$key] = $this->aInstance->toArray($keyType, $includeLazyLoadColumns, $alreadyDumpedObjects, true); |
|
| 871 | + $result[$key] = $this->aInstance->toArray($keyType, $includeLazyLoadColumns, $alreadyDumpedObjects, true); |
|
| 872 | 872 | } |
| 873 | 873 | if (null !== $this->collSubscriptions) { |
| 874 | 874 | |
@@ -1273,7 +1273,7 @@ discard block |
||
| 1273 | 1273 | public function getSubscriptions(Criteria $criteria = null, ConnectionInterface $con = null) |
| 1274 | 1274 | { |
| 1275 | 1275 | $partial = $this->collSubscriptionsPartial && !$this->isNew(); |
| 1276 | - if (null === $this->collSubscriptions || null !== $criteria || $partial) { |
|
| 1276 | + if (null === $this->collSubscriptions || null !== $criteria || $partial) { |
|
| 1277 | 1277 | if ($this->isNew() && null === $this->collSubscriptions) { |
| 1278 | 1278 | // return empty collection |
| 1279 | 1279 | $this->initSubscriptions(); |
@@ -1411,7 +1411,7 @@ discard block |
||
| 1411 | 1411 | */ |
| 1412 | 1412 | protected function doAddSubscription(ChildSubscription $subscription) |
| 1413 | 1413 | { |
| 1414 | - $this->collSubscriptions[]= $subscription; |
|
| 1414 | + $this->collSubscriptions[] = $subscription; |
|
| 1415 | 1415 | $subscription->setChannel($this); |
| 1416 | 1416 | } |
| 1417 | 1417 | |
@@ -1428,7 +1428,7 @@ discard block |
||
| 1428 | 1428 | $this->subscriptionsScheduledForDeletion = clone $this->collSubscriptions; |
| 1429 | 1429 | $this->subscriptionsScheduledForDeletion->clear(); |
| 1430 | 1430 | } |
| 1431 | - $this->subscriptionsScheduledForDeletion[]= clone $subscription; |
|
| 1431 | + $this->subscriptionsScheduledForDeletion[] = clone $subscription; |
|
| 1432 | 1432 | $subscription->setChannel(null); |
| 1433 | 1433 | } |
| 1434 | 1434 | |
@@ -537,7 +537,7 @@ discard block |
||
| 537 | 537 | |
| 538 | 538 | // use transaction because $criteria could contain info |
| 539 | 539 | // for more than one table or we could emulating ON DELETE CASCADE, etc. |
| 540 | - return $con->transaction(function () use ($con) { |
|
| 540 | + return $con->transaction(function() use ($con) { |
|
| 541 | 541 | $affectedRows = 0; // initialize var to track total num of affected rows |
| 542 | 542 | $affectedRows += parent::doDeleteAll($con); |
| 543 | 543 | // Because this db requires some delete cascade/set null emulation, we have to |
@@ -572,7 +572,7 @@ discard block |
||
| 572 | 572 | |
| 573 | 573 | // use transaction because $criteria could contain info |
| 574 | 574 | // for more than one table or we could emulating ON DELETE CASCADE, etc. |
| 575 | - return $con->transaction(function () use ($con, $criteria) { |
|
| 575 | + return $con->transaction(function() use ($con, $criteria) { |
|
| 576 | 576 | $affectedRows = 0; // initialize var to track total num of affected rows |
| 577 | 577 | |
| 578 | 578 | ChannelTableMap::removeInstanceFromPool($criteria); |
@@ -343,7 +343,7 @@ discard block |
||
| 343 | 343 | $propertyNames = []; |
| 344 | 344 | $serializableProperties = array_diff($cls->getProperties(), $cls->getProperties(\ReflectionProperty::IS_STATIC)); |
| 345 | 345 | |
| 346 | - foreach($serializableProperties as $property) { |
|
| 346 | + foreach ($serializableProperties as $property) { |
|
| 347 | 347 | $propertyNames[] = $property->getName(); |
| 348 | 348 | } |
| 349 | 349 | |
@@ -700,7 +700,7 @@ discard block |
||
| 700 | 700 | $con = Propel::getServiceContainer()->getWriteConnection(ConnectionTableMap::DATABASE_NAME); |
| 701 | 701 | } |
| 702 | 702 | |
| 703 | - $con->transaction(function () use ($con) { |
|
| 703 | + $con->transaction(function() use ($con) { |
|
| 704 | 704 | $deleteQuery = ChildConnectionQuery::create() |
| 705 | 705 | ->filterByPrimaryKey($this->getPrimaryKey()); |
| 706 | 706 | $ret = $this->preDelete($con); |
@@ -735,7 +735,7 @@ discard block |
||
| 735 | 735 | $con = Propel::getServiceContainer()->getWriteConnection(ConnectionTableMap::DATABASE_NAME); |
| 736 | 736 | } |
| 737 | 737 | |
| 738 | - return $con->transaction(function () use ($con) { |
|
| 738 | + return $con->transaction(function() use ($con) { |
|
| 739 | 739 | $isInsert = $this->isNew(); |
| 740 | 740 | $ret = $this->preSave($con); |
| 741 | 741 | if ($isInsert) { |
@@ -1020,7 +1020,7 @@ discard block |
||
| 1020 | 1020 | $key = 'Instance'; |
| 1021 | 1021 | } |
| 1022 | 1022 | |
| 1023 | - $result[$key] = $this->aInstance->toArray($keyType, $includeLazyLoadColumns, $alreadyDumpedObjects, true); |
|
| 1023 | + $result[$key] = $this->aInstance->toArray($keyType, $includeLazyLoadColumns, $alreadyDumpedObjects, true); |
|
| 1024 | 1024 | } |
| 1025 | 1025 | if (null !== $this->aUser) { |
| 1026 | 1026 | |
@@ -1035,7 +1035,7 @@ discard block |
||
| 1035 | 1035 | $key = 'User'; |
| 1036 | 1036 | } |
| 1037 | 1037 | |
| 1038 | - $result[$key] = $this->aUser->toArray($keyType, $includeLazyLoadColumns, $alreadyDumpedObjects, true); |
|
| 1038 | + $result[$key] = $this->aUser->toArray($keyType, $includeLazyLoadColumns, $alreadyDumpedObjects, true); |
|
| 1039 | 1039 | } |
| 1040 | 1040 | } |
| 1041 | 1041 | |
@@ -671,7 +671,7 @@ discard block |
||
| 671 | 671 | |
| 672 | 672 | // use transaction because $criteria could contain info |
| 673 | 673 | // for more than one table or we could emulating ON DELETE CASCADE, etc. |
| 674 | - return $con->transaction(function () use ($con) { |
|
| 674 | + return $con->transaction(function() use ($con) { |
|
| 675 | 675 | $affectedRows = 0; // initialize var to track total num of affected rows |
| 676 | 676 | $affectedRows += parent::doDeleteAll($con); |
| 677 | 677 | // Because this db requires some delete cascade/set null emulation, we have to |
@@ -706,7 +706,7 @@ discard block |
||
| 706 | 706 | |
| 707 | 707 | // use transaction because $criteria could contain info |
| 708 | 708 | // for more than one table or we could emulating ON DELETE CASCADE, etc. |
| 709 | - return $con->transaction(function () use ($con, $criteria) { |
|
| 709 | + return $con->transaction(function() use ($con, $criteria) { |
|
| 710 | 710 | $affectedRows = 0; // initialize var to track total num of affected rows |
| 711 | 711 | |
| 712 | 712 | ConnectionTableMap::removeInstanceFromPool($criteria); |
@@ -354,7 +354,7 @@ discard block |
||
| 354 | 354 | $propertyNames = []; |
| 355 | 355 | $serializableProperties = array_diff($cls->getProperties(), $cls->getProperties(\ReflectionProperty::IS_STATIC)); |
| 356 | 356 | |
| 357 | - foreach($serializableProperties as $property) { |
|
| 357 | + foreach ($serializableProperties as $property) { |
|
| 358 | 358 | $propertyNames[] = $property->getName(); |
| 359 | 359 | } |
| 360 | 360 | |
@@ -528,7 +528,7 @@ discard block |
||
| 528 | 528 | $con = Propel::getServiceContainer()->getWriteConnection(InstanceTableMap::DATABASE_NAME); |
| 529 | 529 | } |
| 530 | 530 | |
| 531 | - $con->transaction(function () use ($con) { |
|
| 531 | + $con->transaction(function() use ($con) { |
|
| 532 | 532 | $deleteQuery = ChildInstanceQuery::create() |
| 533 | 533 | ->filterByPrimaryKey($this->getPrimaryKey()); |
| 534 | 534 | $ret = $this->preDelete($con); |
@@ -563,7 +563,7 @@ discard block |
||
| 563 | 563 | $con = Propel::getServiceContainer()->getWriteConnection(InstanceTableMap::DATABASE_NAME); |
| 564 | 564 | } |
| 565 | 565 | |
| 566 | - return $con->transaction(function () use ($con) { |
|
| 566 | + return $con->transaction(function() use ($con) { |
|
| 567 | 567 | $isInsert = $this->isNew(); |
| 568 | 568 | $ret = $this->preSave($con); |
| 569 | 569 | if ($isInsert) { |
@@ -707,7 +707,7 @@ discard block |
||
| 707 | 707 | |
| 708 | 708 | // check the columns in natural order for more readable SQL queries |
| 709 | 709 | if ($this->isColumnModified(InstanceTableMap::COL_NAME)) { |
| 710 | - $modifiedColumns[':p' . $index++] = 'name'; |
|
| 710 | + $modifiedColumns[':p' . $index++] = 'name'; |
|
| 711 | 711 | } |
| 712 | 712 | |
| 713 | 713 | $sql = sprintf( |
@@ -1223,7 +1223,7 @@ discard block |
||
| 1223 | 1223 | public function getUsers(Criteria $criteria = null, ConnectionInterface $con = null) |
| 1224 | 1224 | { |
| 1225 | 1225 | $partial = $this->collUsersPartial && !$this->isNew(); |
| 1226 | - if (null === $this->collUsers || null !== $criteria || $partial) { |
|
| 1226 | + if (null === $this->collUsers || null !== $criteria || $partial) { |
|
| 1227 | 1227 | if ($this->isNew() && null === $this->collUsers) { |
| 1228 | 1228 | // return empty collection |
| 1229 | 1229 | $this->initUsers(); |
@@ -1361,7 +1361,7 @@ discard block |
||
| 1361 | 1361 | */ |
| 1362 | 1362 | protected function doAddUser(ChildUser $user) |
| 1363 | 1363 | { |
| 1364 | - $this->collUsers[]= $user; |
|
| 1364 | + $this->collUsers[] = $user; |
|
| 1365 | 1365 | $user->setInstance($this); |
| 1366 | 1366 | } |
| 1367 | 1367 | |
@@ -1378,7 +1378,7 @@ discard block |
||
| 1378 | 1378 | $this->usersScheduledForDeletion = clone $this->collUsers; |
| 1379 | 1379 | $this->usersScheduledForDeletion->clear(); |
| 1380 | 1380 | } |
| 1381 | - $this->usersScheduledForDeletion[]= clone $user; |
|
| 1381 | + $this->usersScheduledForDeletion[] = clone $user; |
|
| 1382 | 1382 | $user->setInstance(null); |
| 1383 | 1383 | } |
| 1384 | 1384 | |
@@ -1448,7 +1448,7 @@ discard block |
||
| 1448 | 1448 | public function getConnections(Criteria $criteria = null, ConnectionInterface $con = null) |
| 1449 | 1449 | { |
| 1450 | 1450 | $partial = $this->collConnectionsPartial && !$this->isNew(); |
| 1451 | - if (null === $this->collConnections || null !== $criteria || $partial) { |
|
| 1451 | + if (null === $this->collConnections || null !== $criteria || $partial) { |
|
| 1452 | 1452 | if ($this->isNew() && null === $this->collConnections) { |
| 1453 | 1453 | // return empty collection |
| 1454 | 1454 | $this->initConnections(); |
@@ -1586,7 +1586,7 @@ discard block |
||
| 1586 | 1586 | */ |
| 1587 | 1587 | protected function doAddConnection(ChildConnection $connection) |
| 1588 | 1588 | { |
| 1589 | - $this->collConnections[]= $connection; |
|
| 1589 | + $this->collConnections[] = $connection; |
|
| 1590 | 1590 | $connection->setInstance($this); |
| 1591 | 1591 | } |
| 1592 | 1592 | |
@@ -1603,7 +1603,7 @@ discard block |
||
| 1603 | 1603 | $this->connectionsScheduledForDeletion = clone $this->collConnections; |
| 1604 | 1604 | $this->connectionsScheduledForDeletion->clear(); |
| 1605 | 1605 | } |
| 1606 | - $this->connectionsScheduledForDeletion[]= clone $connection; |
|
| 1606 | + $this->connectionsScheduledForDeletion[] = clone $connection; |
|
| 1607 | 1607 | $connection->setInstance(null); |
| 1608 | 1608 | } |
| 1609 | 1609 | |
@@ -1698,7 +1698,7 @@ discard block |
||
| 1698 | 1698 | public function getChannels(Criteria $criteria = null, ConnectionInterface $con = null) |
| 1699 | 1699 | { |
| 1700 | 1700 | $partial = $this->collChannelsPartial && !$this->isNew(); |
| 1701 | - if (null === $this->collChannels || null !== $criteria || $partial) { |
|
| 1701 | + if (null === $this->collChannels || null !== $criteria || $partial) { |
|
| 1702 | 1702 | if ($this->isNew() && null === $this->collChannels) { |
| 1703 | 1703 | // return empty collection |
| 1704 | 1704 | $this->initChannels(); |
@@ -1836,7 +1836,7 @@ discard block |
||
| 1836 | 1836 | */ |
| 1837 | 1837 | protected function doAddChannel(ChildChannel $channel) |
| 1838 | 1838 | { |
| 1839 | - $this->collChannels[]= $channel; |
|
| 1839 | + $this->collChannels[] = $channel; |
|
| 1840 | 1840 | $channel->setInstance($this); |
| 1841 | 1841 | } |
| 1842 | 1842 | |
@@ -1853,7 +1853,7 @@ discard block |
||
| 1853 | 1853 | $this->channelsScheduledForDeletion = clone $this->collChannels; |
| 1854 | 1854 | $this->channelsScheduledForDeletion->clear(); |
| 1855 | 1855 | } |
| 1856 | - $this->channelsScheduledForDeletion[]= clone $channel; |
|
| 1856 | + $this->channelsScheduledForDeletion[] = clone $channel; |
|
| 1857 | 1857 | $channel->setInstance(null); |
| 1858 | 1858 | } |
| 1859 | 1859 | |
@@ -1923,7 +1923,7 @@ discard block |
||
| 1923 | 1923 | public function getSubscriptions(Criteria $criteria = null, ConnectionInterface $con = null) |
| 1924 | 1924 | { |
| 1925 | 1925 | $partial = $this->collSubscriptionsPartial && !$this->isNew(); |
| 1926 | - if (null === $this->collSubscriptions || null !== $criteria || $partial) { |
|
| 1926 | + if (null === $this->collSubscriptions || null !== $criteria || $partial) { |
|
| 1927 | 1927 | if ($this->isNew() && null === $this->collSubscriptions) { |
| 1928 | 1928 | // return empty collection |
| 1929 | 1929 | $this->initSubscriptions(); |
@@ -2061,7 +2061,7 @@ discard block |
||
| 2061 | 2061 | */ |
| 2062 | 2062 | protected function doAddSubscription(ChildSubscription $subscription) |
| 2063 | 2063 | { |
| 2064 | - $this->collSubscriptions[]= $subscription; |
|
| 2064 | + $this->collSubscriptions[] = $subscription; |
|
| 2065 | 2065 | $subscription->setInstance($this); |
| 2066 | 2066 | } |
| 2067 | 2067 | |
@@ -2078,7 +2078,7 @@ discard block |
||
| 2078 | 2078 | $this->subscriptionsScheduledForDeletion = clone $this->collSubscriptions; |
| 2079 | 2079 | $this->subscriptionsScheduledForDeletion->clear(); |
| 2080 | 2080 | } |
| 2081 | - $this->subscriptionsScheduledForDeletion[]= clone $subscription; |
|
| 2081 | + $this->subscriptionsScheduledForDeletion[] = clone $subscription; |
|
| 2082 | 2082 | $subscription->setInstance(null); |
| 2083 | 2083 | } |
| 2084 | 2084 | |
@@ -619,7 +619,7 @@ discard block |
||
| 619 | 619 | |
| 620 | 620 | // use transaction because $criteria could contain info |
| 621 | 621 | // for more than one table or we could emulating ON DELETE CASCADE, etc. |
| 622 | - return $con->transaction(function () use ($con) { |
|
| 622 | + return $con->transaction(function() use ($con) { |
|
| 623 | 623 | $affectedRows = 0; // initialize var to track total num of affected rows |
| 624 | 624 | $affectedRows += parent::doDeleteAll($con); |
| 625 | 625 | // Because this db requires some delete cascade/set null emulation, we have to |
@@ -654,7 +654,7 @@ discard block |
||
| 654 | 654 | |
| 655 | 655 | // use transaction because $criteria could contain info |
| 656 | 656 | // for more than one table or we could emulating ON DELETE CASCADE, etc. |
| 657 | - return $con->transaction(function () use ($con, $criteria) { |
|
| 657 | + return $con->transaction(function() use ($con, $criteria) { |
|
| 658 | 658 | $affectedRows = 0; // initialize var to track total num of affected rows |
| 659 | 659 | |
| 660 | 660 | InstanceTableMap::removeInstanceFromPool($criteria); |
@@ -371,7 +371,7 @@ discard block |
||
| 371 | 371 | $propertyNames = []; |
| 372 | 372 | $serializableProperties = array_diff($cls->getProperties(), $cls->getProperties(\ReflectionProperty::IS_STATIC)); |
| 373 | 373 | |
| 374 | - foreach($serializableProperties as $property) { |
|
| 374 | + foreach ($serializableProperties as $property) { |
|
| 375 | 375 | $propertyNames[] = $property->getName(); |
| 376 | 376 | } |
| 377 | 377 | |
@@ -845,7 +845,7 @@ discard block |
||
| 845 | 845 | $con = Propel::getServiceContainer()->getWriteConnection(SubscriptionTableMap::DATABASE_NAME); |
| 846 | 846 | } |
| 847 | 847 | |
| 848 | - $con->transaction(function () use ($con) { |
|
| 848 | + $con->transaction(function() use ($con) { |
|
| 849 | 849 | $deleteQuery = ChildSubscriptionQuery::create() |
| 850 | 850 | ->filterByPrimaryKey($this->getPrimaryKey()); |
| 851 | 851 | $ret = $this->preDelete($con); |
@@ -880,7 +880,7 @@ discard block |
||
| 880 | 880 | $con = Propel::getServiceContainer()->getWriteConnection(SubscriptionTableMap::DATABASE_NAME); |
| 881 | 881 | } |
| 882 | 882 | |
| 883 | - return $con->transaction(function () use ($con) { |
|
| 883 | + return $con->transaction(function() use ($con) { |
|
| 884 | 884 | $isInsert = $this->isNew(); |
| 885 | 885 | $ret = $this->preSave($con); |
| 886 | 886 | if ($isInsert) { |
@@ -1206,7 +1206,7 @@ discard block |
||
| 1206 | 1206 | $key = 'Instance'; |
| 1207 | 1207 | } |
| 1208 | 1208 | |
| 1209 | - $result[$key] = $this->aInstance->toArray($keyType, $includeLazyLoadColumns, $alreadyDumpedObjects, true); |
|
| 1209 | + $result[$key] = $this->aInstance->toArray($keyType, $includeLazyLoadColumns, $alreadyDumpedObjects, true); |
|
| 1210 | 1210 | } |
| 1211 | 1211 | if (null !== $this->aUser) { |
| 1212 | 1212 | |
@@ -1221,7 +1221,7 @@ discard block |
||
| 1221 | 1221 | $key = 'User'; |
| 1222 | 1222 | } |
| 1223 | 1223 | |
| 1224 | - $result[$key] = $this->aUser->toArray($keyType, $includeLazyLoadColumns, $alreadyDumpedObjects, true); |
|
| 1224 | + $result[$key] = $this->aUser->toArray($keyType, $includeLazyLoadColumns, $alreadyDumpedObjects, true); |
|
| 1225 | 1225 | } |
| 1226 | 1226 | if (null !== $this->aChannel) { |
| 1227 | 1227 | |
@@ -1236,7 +1236,7 @@ discard block |
||
| 1236 | 1236 | $key = 'Channel'; |
| 1237 | 1237 | } |
| 1238 | 1238 | |
| 1239 | - $result[$key] = $this->aChannel->toArray($keyType, $includeLazyLoadColumns, $alreadyDumpedObjects, true); |
|
| 1239 | + $result[$key] = $this->aChannel->toArray($keyType, $includeLazyLoadColumns, $alreadyDumpedObjects, true); |
|
| 1240 | 1240 | } |
| 1241 | 1241 | } |
| 1242 | 1242 | |