mirror of
https://github.com/macintoshplus/mongo-php-driver.git
synced 2026-03-30 04:42:15 +02:00
4f693030b9
We no create a /tmp/PHONGO-SERVERS.json file upon launching the servers which stores the server IDs and connection string (including auth). This makes it much faster to look up the available servers
144 lines
7.1 KiB
PHP
144 lines
7.1 KiB
PHP
<?php
|
|
$SERVERS = array();
|
|
$FILENAME = sys_get_temp_dir() . "/PHONGO-SERVERS.json";
|
|
|
|
function lap() {
|
|
static $then = 0;
|
|
static $now;
|
|
|
|
$now = microtime(true);
|
|
$ret = $now - $then;
|
|
$then = $now;
|
|
return $ret;
|
|
}
|
|
|
|
|
|
if (!($HOST = getenv("MONGODB_ORCHESTRATION_HOST"))) {
|
|
$HOST = "192.168.112.10";
|
|
}
|
|
|
|
if (!($PORT = getenv("MONGODB_ORCHESTRATION_PORT"))) {
|
|
$PORT = "8889";
|
|
}
|
|
|
|
if (!($BASE = getenv("mongodb_orchestration_base"))) {
|
|
$BASE = "/phongo/";
|
|
}
|
|
|
|
$MO = "http://$HOST:$PORT";
|
|
|
|
$PRESETS = [
|
|
"standalone" => [
|
|
"scripts/presets/standalone.json",
|
|
"scripts/presets/standalone-ssl.json",
|
|
"scripts/presets/standalone-auth.json",
|
|
"scripts/presets/standalone-x509.json",
|
|
"scripts/presets/standalone-plain.json",
|
|
],
|
|
"replicasets" => [
|
|
"scripts/presets/replicaset.json",
|
|
],
|
|
];
|
|
|
|
function make_ctx($preset, $method = "POST") {
|
|
$opts = [
|
|
"http" => [
|
|
"timeout" => 30,
|
|
"method" => $method,
|
|
"header" => "Accept: application/json\r\n" .
|
|
"Content-type: application/x-www-form-urlencoded",
|
|
"content" => json_encode(array("preset" => $preset)),
|
|
"ignore_errors" => true,
|
|
],
|
|
];
|
|
$ctx = stream_context_create($opts);
|
|
return $ctx;
|
|
}
|
|
|
|
function failed($result) {
|
|
echo "\n\n";
|
|
echo join("\n", $result);
|
|
exit();
|
|
}
|
|
|
|
|
|
|
|
printf("Cleaning out previous processes, if any ");
|
|
lap();
|
|
/* Remove all pre-existing ReplicaSets */
|
|
$replicasets = file_get_contents($MO . "/replica_sets", false, make_ctx($BASE, "GET"));
|
|
$replicasets = json_decode($replicasets, true);
|
|
foreach($replicasets["replica_sets"] as $replicaset) {
|
|
$uri = $MO . "/replica_sets/" . $replicaset["id"];
|
|
file_get_contents($uri, false, make_ctx($BASE, "DELETE"));
|
|
echo ".";
|
|
}
|
|
echo " ";
|
|
/* Remove all pre-existing servers */
|
|
$servers = file_get_contents($MO . "/servers", false, make_ctx($BASE, "GET"));
|
|
$servers = json_decode($servers, true);
|
|
foreach($servers["servers"] as $server) {
|
|
$uri = $MO . "/servers/" . $server["id"];
|
|
file_get_contents($uri, false, make_ctx($BASE, "DELETE"));
|
|
echo ".";
|
|
}
|
|
printf("\t(took: %.2f secs)\n", lap());
|
|
|
|
foreach($PRESETS["standalone"] as $preset) {
|
|
lap();
|
|
$json = json_decode(file_get_contents($preset), true);
|
|
printf("Starting %-20s ... ", $json["id"]);
|
|
|
|
$result = file_get_contents($MO . "/servers", false, make_ctx($BASE . $preset));
|
|
$decode = json_decode($result, true);
|
|
if (!isset($decode["id"])) {
|
|
failed($decode);
|
|
}
|
|
|
|
$SERVERS[$decode["id"]] = isset($decode["mongodb_auth_uri"]) ? $decode["mongodb_auth_uri"] : $decode["mongodb_uri"];
|
|
printf("'%s'\t(took: %.2f secs)\n", $SERVERS[$decode["id"]], lap());
|
|
}
|
|
echo "---\n";
|
|
|
|
foreach($PRESETS["replicasets"] as $preset) {
|
|
lap();
|
|
$json = json_decode(file_get_contents($preset), true);
|
|
printf("Starting %-20s ... ", $json["id"]);
|
|
|
|
$result = file_get_contents($MO . "/replica_sets", false, make_ctx($BASE . $preset));
|
|
$decode = json_decode($result, true);
|
|
if (!isset($decode["id"])) {
|
|
failed($decode);
|
|
}
|
|
$SERVERS[$decode["id"]] = isset($decode["mongodb_auth_uri"]) ? $decode["mongodb_auth_uri"] : $decode["mongodb_uri"];
|
|
printf("'%s'\t(took: %.2f secs)\n", $SERVERS[$decode["id"]], lap());
|
|
}
|
|
|
|
file_put_contents($FILENAME, json_encode($SERVERS, JSON_PRETTY_PRINT));
|
|
|
|
/*
|
|
wget --body-data='' --method='GET' --header='Accept: application/json' --header='Content-type: application/x-www-form-urlencoded' http://192.168.112.10:8889/servers
|
|
wget --body-data='' --method='DELETE' --header='Accept: application/json' --header='Content-type: application/x-www-form-urlencoded' http://192.168.112.10:8889/servers/STANDALONE-AUTH
|
|
wget --body-data='' --method='DELETE' --header='Accept: application/json' --header='Content-type: application/x-www-form-urlencoded' http://192.168.112.10:8889/servers/STANDALONE
|
|
wget --body-data='' --method='DELETE' --header='Accept: application/json' --header='Content-type: application/x-www-form-urlencoded' http://192.168.112.10:8889/servers/RS-two
|
|
wget --body-data='' --method='DELETE' --header='Accept: application/json' --header='Content-type: application/x-www-form-urlencoded' http://192.168.112.10:8889/servers/RS-arbiter
|
|
wget --body-data='' --method='DELETE' --header='Accept: application/json' --header='Content-type: application/x-www-form-urlencoded' http://192.168.112.10:8889/servers/STANDALONE-PLAIN
|
|
wget --body-data='' --method='DELETE' --header='Accept: application/json' --header='Content-type: application/x-www-form-urlencoded' http://192.168.112.10:8889/servers/STANDALONE-X509
|
|
wget --body-data='' --method='DELETE' --header='Accept: application/json' --header='Content-type: application/x-www-form-urlencoded' http://192.168.112.10:8889/servers/RS-one
|
|
wget --body-data='' --method='DELETE' --header='Accept: application/json' --header='Content-type: application/x-www-form-urlencoded' http://192.168.112.10:8889/servers/STANDALONE-SSL
|
|
|
|
wget --body-data='' --method='GET' --header='Accept: application/json' --header='Content-type: application/x-www-form-urlencoded' http://192.168.112.10:8889/replica_sets
|
|
wget --body-data='' --method='DELETE' --header='Accept: application/json' --header='Content-type: application/x-www-form-urlencoded' http://192.168.112.10:8889/replica_sets/REPLICASET
|
|
|
|
wget --body-data='' --method='GET' --header='Accept: application/json' --header='Content-type: application/x-www-form-urlencoded' http://192.168.112.10:8889/
|
|
wget --body-data='' --method='GET' --header='Accept: application/json' --header='Content-type: application/x-www-form-urlencoded' http://192.168.112.10:8889/servers
|
|
wget --body-data='' --method='GET' --header='Accept: application/json' --header='Content-type: application/x-www-form-urlencoded' http://192.168.112.10:8889/replica_sets
|
|
|
|
wget --body-data='{"preset":"\/phongo\/\/scripts\/presets\/standalone.json"}' --method='POST' --header='Accept: application/json' --header='Content-type: application/x-www-form-urlencoded' http://192.168.112.10:8889/servers
|
|
wget --body-data='{"preset":"\/phongo\/\/scripts\/presets\/standalone-ssl.json"}' --method='POST' --header='Accept: application/json' --header='Content-type: application/x-www-form-urlencoded' http://192.168.112.10:8889/servers
|
|
wget --body-data='{"preset":"\/phongo\/\/scripts\/presets\/standalone-auth.json"}' --method='POST' --header='Accept: application/json' --header='Content-type: application/x-www-form-urlencoded' http://192.168.112.10:8889/servers
|
|
wget --body-data='{"preset":"\/phongo\/\/scripts\/presets\/standalone-x509.json"}' --method='POST' --header='Accept: application/json' --header='Content-type: application/x-www-form-urlencoded' http://192.168.112.10:8889/servers
|
|
wget --body-data='{"preset":"\/phongo\/\/scripts\/presets\/standalone-plain.json"}' --method='POST' --header='Accept: application/json' --header='Content-type: application/x-www-form-urlencoded' http://192.168.112.10:8889/servers
|
|
wget --body-data='{"preset":"\/phongo\/\/scripts\/presets\/replicaset.json"}' --method='POST' --header='Accept: application/json' --header='Content-type: application/x-www-form-urlencoded' http://192.168.112.10:8889/replica_sets
|
|
*/
|