|
|
@@ -0,0 +1,200 @@
|
|
|
+<?php declare(strict_types=1);
|
|
|
+
|
|
|
+include __DIR__ . '/vendor/autoload.php';
|
|
|
+
|
|
|
+use Ripple\Http\Server;
|
|
|
+use Ripple\Worker\Manager;
|
|
|
+
|
|
|
+use function Co\repeat;
|
|
|
+use function Co\wait;
|
|
|
+
|
|
|
+class Setup
|
|
|
+{
|
|
|
+ public static PDO $pdo;
|
|
|
+ public static string $dateFormatted;
|
|
|
+
|
|
|
+ public static PDOStatement $queryWorldWhereID;
|
|
|
+ public static PDOStatement $updateWorldRandomNumber;
|
|
|
+ public static PDOStatement $queryFortune;
|
|
|
+
|
|
|
+ public static function dateRefresh(): void
|
|
|
+ {
|
|
|
+ try {
|
|
|
+ $date = new DateTime('now', new DateTimeZone('GMT'));
|
|
|
+ } catch (Throwable $e) {
|
|
|
+ return;
|
|
|
+ }
|
|
|
+ Setup::$dateFormatted = $date->format('D, d M Y H:i:s T');
|
|
|
+ }
|
|
|
+
|
|
|
+
|
|
|
+ /**
|
|
|
+ * @return int
|
|
|
+ */
|
|
|
+ public static function randomInt(): int
|
|
|
+ {
|
|
|
+ try {
|
|
|
+ return \random_int(1, 10000);
|
|
|
+ } catch (Throwable $e) {
|
|
|
+ return mt_rand(1, 10000);
|
|
|
+ }
|
|
|
+ }
|
|
|
+
|
|
|
+ /**
|
|
|
+ * @param mixed $value
|
|
|
+ *
|
|
|
+ * @return int
|
|
|
+ */
|
|
|
+ public static function clamp(mixed $value): int
|
|
|
+ {
|
|
|
+ if (!\is_numeric($value) || $value < 1) {
|
|
|
+ return 1;
|
|
|
+ }
|
|
|
+ if ($value > 500) {
|
|
|
+ return 500;
|
|
|
+ }
|
|
|
+ return \intval($value);
|
|
|
+ }
|
|
|
+
|
|
|
+ /**
|
|
|
+ * @param string $template
|
|
|
+ * @param array $data
|
|
|
+ *
|
|
|
+ * @return string
|
|
|
+ */
|
|
|
+ public static function render(string $template, array $data = []): string
|
|
|
+ {
|
|
|
+ foreach ($data as $key => $value) {
|
|
|
+ $$key = $value;
|
|
|
+ }
|
|
|
+
|
|
|
+ \ob_start();
|
|
|
+ include $template;
|
|
|
+ return \ob_get_clean();
|
|
|
+ }
|
|
|
+}
|
|
|
+
|
|
|
+$manager = new Manager();
|
|
|
+$worker = new class() extends \Ripple\Worker {
|
|
|
+ /*** @var \Ripple\Http\Server */
|
|
|
+ public Server $server;
|
|
|
+
|
|
|
+ /**
|
|
|
+ * @param \Ripple\Worker\Manager $manager
|
|
|
+ *
|
|
|
+ * @return void
|
|
|
+ */
|
|
|
+ public function register(Manager $manager): void
|
|
|
+ {
|
|
|
+ $this->count = 64;
|
|
|
+ $this->server = new Server('http://0.0.0.0:8080');
|
|
|
+ }
|
|
|
+
|
|
|
+ /**
|
|
|
+ * @return void
|
|
|
+ */
|
|
|
+ public function boot(): void
|
|
|
+ {
|
|
|
+ Setup::dateRefresh();
|
|
|
+ repeat(static fn () => Setup::dateRefresh(), 1);
|
|
|
+
|
|
|
+ Setup::$pdo = new \PDO(
|
|
|
+ 'mysql:host=tfb-database;port=3306;dbname=hello_world',
|
|
|
+ 'benchmarkdbuser',
|
|
|
+ 'benchmarkdbpass',
|
|
|
+ [
|
|
|
+ \PDO::ATTR_DEFAULT_FETCH_MODE => \PDO::FETCH_ASSOC,
|
|
|
+ \PDO::ATTR_EMULATE_PREPARES => false,
|
|
|
+ \PDO::ATTR_ERRMODE => \PDO::ERRMODE_EXCEPTION,
|
|
|
+ ]
|
|
|
+ );
|
|
|
+
|
|
|
+ Setup::$queryWorldWhereID = Setup::$pdo->prepare('SELECT id, randomNumber FROM World WHERE id = ?');
|
|
|
+ Setup::$updateWorldRandomNumber = Setup::$pdo->prepare('UPDATE World SET randomNumber = ? WHERE id = ?');
|
|
|
+ Setup::$queryFortune = Setup::$pdo->prepare('SELECT * FROM `Fortune`');
|
|
|
+ $this->server->onRequest(fn (Server\Request $request) => $this->onRequest($request));
|
|
|
+ $this->server->listen();
|
|
|
+ }
|
|
|
+
|
|
|
+ /**
|
|
|
+ * @param \Ripple\Http\Server\Request $request
|
|
|
+ *
|
|
|
+ * @return void
|
|
|
+ */
|
|
|
+ public function onRequest(Server\Request $request): void
|
|
|
+ {
|
|
|
+ switch ($request->SERVER['REQUEST_URI']) {
|
|
|
+ case '/json':
|
|
|
+ $request->respondJson(
|
|
|
+ ['message' => 'Hello, World!'],
|
|
|
+ ['Date' => Setup::$dateFormatted]
|
|
|
+ );
|
|
|
+ break;
|
|
|
+
|
|
|
+ case '/db':
|
|
|
+ $statement = Setup::$queryWorldWhereID;
|
|
|
+ $statement->execute([Setup::randomInt()]);
|
|
|
+ $request->respondJson($statement->fetch(), ['Date' => Setup::$dateFormatted]);
|
|
|
+ break;
|
|
|
+
|
|
|
+ case '/queries':
|
|
|
+ $queries = Setup::clamp($request->GET['queries'] ?? 1);
|
|
|
+ $results = [];
|
|
|
+ $statement = Setup::$queryWorldWhereID;
|
|
|
+ while ($queries--) {
|
|
|
+ $statement->execute([Setup::randomInt()]);
|
|
|
+ $results[] = $statement->fetch();
|
|
|
+ }
|
|
|
+ $request->respondJson($results, ['Date' => Setup::$dateFormatted]);
|
|
|
+
|
|
|
+ break;
|
|
|
+ case '/fortunes':
|
|
|
+ $rows = Setup::$pdo->query('SELECT * FROM `Fortune`')?->fetchAll();
|
|
|
+ $rows[] = ['id' => 0, 'message' => 'Additional fortune added at request time.'];
|
|
|
+ \usort($rows, function ($a, $b) {
|
|
|
+ return $a['message'] <=> $b['message'];
|
|
|
+ });
|
|
|
+
|
|
|
+ $request->respondHtml(
|
|
|
+ Setup::render('fortunes.php', ['rows' => $rows]),
|
|
|
+ [
|
|
|
+ 'Date' => Setup::$dateFormatted,
|
|
|
+ 'Content-Type' => 'text/html; charset=UTF-8'
|
|
|
+ ]
|
|
|
+ );
|
|
|
+ break;
|
|
|
+
|
|
|
+ case '/updates':
|
|
|
+ $queries = Setup::clamp($request->GET['queries'] ?? 1);
|
|
|
+ $results = [];
|
|
|
+ $statement = Setup::$queryWorldWhereID;
|
|
|
+ $update = Setup::$updateWorldRandomNumber;
|
|
|
+ while ($queries--) {
|
|
|
+ $statement->execute([Setup::randomInt()]);
|
|
|
+ $row = $statement->fetch();
|
|
|
+ $row['randomNumber'] = Setup::randomInt();
|
|
|
+ $results[] = $row;
|
|
|
+ $update->execute([$row['randomNumber'], $row['id']]);
|
|
|
+ }
|
|
|
+ $request->respondJson($results, ['Date' => Setup::$dateFormatted]);
|
|
|
+ break;
|
|
|
+
|
|
|
+ case '/plaintext':
|
|
|
+ $request->respond(
|
|
|
+ 'Hello, World!',
|
|
|
+ [
|
|
|
+ 'Content-Type' => 'text/plain; charset=utf-8',
|
|
|
+ 'Date' => Setup::$dateFormatted
|
|
|
+ ]
|
|
|
+ );
|
|
|
+ break;
|
|
|
+
|
|
|
+ default:
|
|
|
+ $request->respond('Not Found', [], 404);
|
|
|
+ }
|
|
|
+ }
|
|
|
+};
|
|
|
+
|
|
|
+$manager->addWorker($worker);
|
|
|
+$manager->run();
|
|
|
+wait();
|
cclilshy