Commit bca7df7f authored by Jeremy Mikola's avatar Jeremy Mikola

PHPLIB-63: Refactor to avoid else condition and void methods

parent a0aceaf4
...@@ -312,13 +312,9 @@ class Collection ...@@ -312,13 +312,9 @@ class Collection
$serverInfo = $server->getInfo(); $serverInfo = $server->getInfo();
$maxWireVersion = isset($serverInfo['maxWireVersion']) ? $serverInfo['maxWireVersion'] : 0; $maxWireVersion = isset($serverInfo['maxWireVersion']) ? $serverInfo['maxWireVersion'] : 0;
if ($maxWireVersion >= 2) { return ($maxWireVersion >= 2)
$this->createIndexesCommand($server, $indexes); ? $this->createIndexesCommand($server, $indexes)
} else { : $this->createIndexesLegacy($server, $indexes);
$this->createIndexesLegacy($server, $indexes);
}
return array_map(function(IndexInput $index) { return (string) $index; }, $indexes);
} }
/** /**
...@@ -1213,7 +1209,8 @@ class Collection ...@@ -1213,7 +1209,8 @@ class Collection
* command. * command.
* *
* @param Server $server * @param Server $server
* @param array $indexes * @param IndexInput[] $indexes
* @return string[] The names of the created indexes
*/ */
private function createIndexesCommand(Server $server, array $indexes) private function createIndexesCommand(Server $server, array $indexes)
{ {
...@@ -1222,6 +1219,8 @@ class Collection ...@@ -1222,6 +1219,8 @@ class Collection
'indexes' => $indexes, 'indexes' => $indexes,
)); ));
$server->executeCommand($this->dbname, $command); $server->executeCommand($this->dbname, $command);
return array_map(function(IndexInput $index) { return (string) $index; }, $indexes);
} }
/** /**
...@@ -1229,7 +1228,8 @@ class Collection ...@@ -1229,7 +1228,8 @@ class Collection
* "system.indexes" collection (MongoDB <2.6). * "system.indexes" collection (MongoDB <2.6).
* *
* @param Server $server * @param Server $server
* @param array $indexes * @param IndexInput[] $indexes
* @return string[] The names of the created indexes
*/ */
private function createIndexesLegacy(Server $server, array $indexes) private function createIndexesLegacy(Server $server, array $indexes)
{ {
...@@ -1240,6 +1240,8 @@ class Collection ...@@ -1240,6 +1240,8 @@ class Collection
} }
$server->executeBulkWrite($this->dbname . '.system.indexes', $bulk); $server->executeBulkWrite($this->dbname . '.system.indexes', $bulk);
return array_map(function(IndexInput $index) { return (string) $index; }, $indexes);
} }
/** /**
......
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment