update library jefyokta/oktaax

.env.example

@@ -0,0 +1,9 @@
+APP_NAME=Kamelapermai
+APP_HOST=kamela-permai.oktaa
+APP_PORT=8000
+APP_KEY=
+
+DB_HOST=127.0.0.1
+DB_NAME=Kamela
+DB_USER=root
+DB_PASSWORD=

README.md

@@ -1 +1,12 @@
 # kamela2
+
+### Requirement
+- wsl or docker (if you using windows)
+- php 8.1+
+- php-ext openswoole
+
+### Built with:
+Frontend: blade,tailwindcss,flowbite
+Backend: Php, jefyokta/oktaax
+Database: Mysql
+

app/Command/Command.php

@@ -2,14 +2,16 @@
 
 use Swoole\Coroutine;
 
+
 class Command
 {
+
+
     public function handle(array $argument)
     {
 
         switch ($argument[1]) {
             case 'start':
-
                 require_once __DIR__ . "/../../index.php";
                 break;
 
@@ -22,6 +24,23 @@ public function handle(array $argument)
                 $test =  require __DIR__ . "/../Test/Test.php";
                 $test->run();
                 break;
+            case "migrate":
+                require_once __DIR__ . "/../init.php";
+
+                foreach (glob(__DIR__ . "/../Models/*.php") as $model) {
+
+                    require  $model;
+
+                    $modelName = basename($model, ".php");
+                    $fullClassName = "Kamela\\Models\\" . $modelName;
+
+                    if (class_exists($fullClassName)) {
+                        $fullClassName::migrate();
+                    } else {
+                        echo "migration failed for $modelName\n";
+                    }
+                }
+                break;
             default:
                 # code...
                 break;

app/Controllers/AdminController.php

@@ -38,7 +38,7 @@ public function guest(Request $req, Response $res)
    {
       $guest = Guest::select("*");
 
-      if ($req->get['filter'] == null) {
+      if (!isset($req->get['filter'])) {
          $guest = $guest;
       } else {
          if ($req->get['filter'] ?? false) {

app/Models/Gallery.php

@@ -1,10 +1,16 @@
 <?php
-namespace Kamela\Models;
 
+namespace Kamela\Models;
 use oktaa\Database\Database;
 
 class Gallery extends Database
 {
     protected string $table = 'gallery';
 
-}
+    protected array $definition = [
+        "id" => "INT AUTO_INCREMENT PRIMARY KEY",
+        "typeid" => "VARCHAR(255) NOT NULL",
+        "img" => "VARCHAR(255) NOT NULL",
+        "name" => "VARCHAR(255) NOT NULL",
+    ];
+}

composer.json

@@ -1,6 +1,6 @@
 {
     "require": {
-        "jefyokta/oktaax": "^2.0.2",
+        "jefyokta/oktaax": "^2.0.3",
         "firebase/php-jwt": "^6.10",
         "vlucas/phpdotenv": "^5.6"
 

database/Database.php

@@ -7,6 +7,8 @@
 use PDOException;
 use InvalidArgumentException;
 use Oktaax\Console;
+use Swoole\Coroutine;
+use Swoole\Process;
 
 Runtime::enableCoroutine(true, SWOOLE_HOOK_ALL);
 
@@ -48,9 +50,15 @@ public function __construct()
 
             if (!$databaseExists) {
                 Console::warning(" database `{$this->db} doesnt'nt exist`");
-                Console::info("Creating....");
-                $pdo->exec("CREATE DATABASE `$this->db`");
-                Console::info("Database {$this->db} created!");
+
+                $accept = readline("wanna create it?[y/n]\n");
+                if (stripos($accept, 'y') === false) {
+                    exit(0);
+                } else {
+                    Console::info("Creating....");
+                    $pdo->exec("CREATE DATABASE `$this->db`");
+                    Console::info("Database {$this->db} created!");
+                }
             }
 
             $this->dbh = new PDO(config('db.connection') . ":host=$this->host;port=$this->port;dbname=$this->db", $this->user, $this->password);

index.php

@@ -226,23 +226,6 @@
     ]);
 });
 
-$app->get("/trigger", function ($req, $res) {
-    go(function () use ($res) {
-        $client = new Client('kamela-permai.oktaa', 8000, true);
-
-        if ($client->upgrade("/notification/house")) {
-            $message = json_encode([
-                'event' => 'booking',
-                'message' => 'Ada tamu baru yang membooking rumah!'
-            ]);
-            $client->push($message);
-            $res->end();
-        } else {
-            echo "Upgrade ke WebSocket gagal.";
-        }
-    });
-});
-
 
 $app->ws("/notification", [Notification::class, 'handle'])
     ->ws("/notification/house", [Notification::class, 'house']);
@@ -251,6 +234,6 @@
 
 $app
     ->withSSL(__DIR__ . "/cert/kamela-cert.pem", __DIR__ . "/cert/kamela-key.pem")
-    ->listen(8000, "kamela-permai.oktaa", function ($url) {
+    ->listen(3000, "kamela-permai.oktaa", function ($url) {
         Console::log("Server Started on {$url}");
     });

okta

@@ -1,8 +1,31 @@
+#!/usr/bin/env php
+
 <?php
+
+use Oktaax\Console;
+use Swoole\Coroutine;
+use Swoole\ExitException;
+
 require_once __DIR__ . "/app/Command/Command.php";
 
+require_once __DIR__ . "/vendor/autoload.php";
+
 $argument = $argv;
 
 
-$command = new Command();
-$command->handle($argument);
+if (count($argument) > 1) {
+
+    Coroutine::run(function () use ($argument) {
+        $command = new Command();
+        try {
+            $command->handle($argument);
+        } catch (ExitException $e) {
+            Console::info("Swoole Exit!");
+        } catch (\Throwable $th) {
+            Console::error($th->getMessage());
+        }
+    });
+} else {
+    echo "empty arguments!\n";
+
+}