DEV Community: Thiago Silva

PHP HyperF -> Firebase JWT

Thiago Silva — Mon, 09 Dec 2024 17:09:50 +0000

HyperF - Project

Simple system to validate JWT tokens and ensure authenticity and integrity in authentication processes.

Create - Project

composer create-project hyperf/hyperf-skeleton "project"

Install - Watcher

composer require hyperf/watcher --dev

Install - Firebase JWT

composer require firebase/php-jwt

Server - Start

cd project ;
php bin/hyperf.php server:watch ;

HyperF - APP

APP - Environment

JWT_KEY="***"

path: /project/.env

APP - Router

Router::addRoute(['GET', 'POST'], '/generate', 'App\Controller\ControllerJWT@generate');
Router::addRoute(['GET', 'POST'], '/decode', 'App\Controller\ControllerJWT@decode');

path: /project/config/routes.php

APP - Controller

namespace App\Controller;

use Hyperf\Di\Annotation\Inject;
use Hyperf\HttpServer\Contract\RequestInterface;
use Hyperf\HttpServer\Contract\ResponseInterface;

use function Hyperf\Support\env;

use Ramsey\Uuid\Uuid;

use Firebase\JWT\JWT;
use Firebase\JWT\Key;

class ControllerJWT
{
    #[Inject]
    protected RequestInterface $request;

    #[Inject]
    protected ResponseInterface $response;

    protected $jwt_key;

    public function __construct()
    {
        $this->jwt_key=env('JWT_KEY', '***');
    }

    public function generate()
    {
        $payload=[
            'uuid'=>Uuid::uuid4()->toString(),
            'token'=>sha1(str_shuffle('0123456789abcdefghijklmnopqrstuvwxyz')),
        ];
        $token=JWT::encode($payload, $this->jwt_key, 'HS256');
        return [
            'payload'=>$payload,
            'token'=>$token,
        ];
    }

    public function decode()
    {
        $token=$this->request->getHeader('Authorization')[0] ?? '';
        $token=str_replace('Bearer ', '', $token);
        try {
            $decode=JWT::decode($token, new Key($this->jwt_key, 'HS256'));
        } catch (\Exception $e){
            return $this->response->withStatus(401)->json(['token'=>'invalid']);
        }
        return [
            'token'=>$token,
            'decode'=>$decode,
        ];
    }

}

path: /project/app/Controller/ControllerJWT.php

Execute

GET - Generate Token

curl "http://127.0.0.1:9501/generate"

Response:
{
    "payload": {
        "uuid": "...0123",
        "token": "***"
    },
    "token": "***"
}

GET - Decode Token

curl "http://127.0.0.1:9501/decode" -H "Authorization: Bearer %token%"

Response:
{
    "token": "***",
    "decode": {
        "uuid": "...0123",
        "token": "***"
    }
}

https://github.com/thiagoeti/php-hyperf-firebase-jwt

Desktop

Thiago Silva — Tue, 19 Nov 2024 22:36:43 +0000

Apps and Containers for development desktop.

https://github.com/thiagoeti/desktop

PHP HyperF -> Overlapping and Concurrency

Thiago Silva — Fri, 28 Jun 2024 01:02:43 +0000

PHP: 8.3.7
PHP HyperF: 3.1.23

HyperF - Project

It is extremely important that HyperF processes do not overwrite shared variable data. This can occur with overload.

Create - Project

composer create-project hyperf/hyperf-skeleton "project"

Install - Watcher

composer require hyperf/watcher --dev

Install - UUID

composer require ramsey/uuid

Server - Start

cd project ;
php bin/hyperf.php server:watch ;

HyperF - APP

APP - Router

Router::addRoute(['GET', 'POST'], '/overlapping/data', 'App\Controller\ControllerOverlapping@data');
Router::addRoute(['GET', 'POST'], '/overlapping/value-a', 'App\Controller\ControllerOverlapping@value_a');
Router::addRoute(['GET', 'POST'], '/overlapping/value-b', 'App\Controller\ControllerOverlapping@value_b');
Router::addRoute(['GET', 'POST'], '/overlapping/value-c', 'App\Controller\ControllerOverlapping@value_c');

Router::addRoute(['GET', 'POST'], '/concurrency/data', 'App\Controller\ControllerConcurrency@data');
Router::addRoute(['GET', 'POST'], '/concurrency/value-a', 'App\Controller\ControllerConcurrency@value_a');
Router::addRoute(['GET', 'POST'], '/concurrency/value-b', 'App\Controller\ControllerConcurrency@value_b');
Router::addRoute(['GET', 'POST'], '/concurrency/value-c', 'App\Controller\ControllerConcurrency@value_c');

path: /project/config/routes.php

APP - Controller - Overlapping

namespace App\Controller;

class ControllerOverlapping
{
    public $data;

    public function __construct()
    {
        $this->data='';
    }

    public function data()
    {
        return $this->data;
    }

    public function value_a()
    {
        $this->data='Value A';
        return $this->data;
    }

    public function value_b()
    {
        $this->data='Value B';
        return $this->data;
    }

    public function value_C()
    {
        $this->data='Value C';
        return $this->data;
    }

}

path: /project/app/Controller/ControllerOverlapping.php

APP - Controller - Control

namespace App\Controller;

use Ramsey\Uuid\Uuid;

class ControllerConcurrency
{
    public $data;

    public function __construct()
    {
        $this->data=array();
    }

    public function start()
    {
        $key=Uuid::uuid4()->toString();
        return $key;
    }

    public function end($key)
    {
        $data=$this->data[$key];
        unset($this->data[$key]);
        return $data;
    }

    public function data()
    {
        return $this->data;
    }

    public function value_a()
    {
        $key=$this->start();
        $this->data[$key]='Value A';
        $data=$this->end($key);
        return $data;
    }

    public function value_b()
    {
        $key=Uuid::uuid4()->toString();
        $this->data[$key]='Value B';
        $data=$this->end($key);
        return $data;
    }

    public function value_C()
    {
        $key=Uuid::uuid4()->toString();
        $this->data[$key]='Value C';
        $data=$this->end($key);
        return $data;
    }

}

path: /project/app/Controller/ControllerConcurrency.php

Execute

GET - Concurrency

curl "http://127.0.0.1:9501/overlapping/data"
Result: ''

curl "http://127.0.0.1:9501/overlapping/value-a"
Result: 'Value A'

curl "http://127.0.0.1:9501/overlapping/data"
Result: 'Value A'

curl "http://127.0.0.1:9501/overlapping/value-b"
Result: 'Value B'

curl "http://127.0.0.1:9501/overlapping/data"
Result: 'Value B'

GET - Control

curl "http://127.0.0.1:9501/concurrency/data"
Result: ''

curl "http://127.0.0.1:9501/concurrency/value-a"
Result: 'Value A'

curl "http://127.0.0.1:9501/concurrency/data"
Result: ''

curl "http://127.0.0.1:9501/concurrency/value-b"
Result: 'Value B'

curl "http://127.0.0.1:9501/concurrency/data"
Result: ''

curl "http://127.0.0.1:9501/concurrency/value-a" && \
curl "http://127.0.0.1:9501/concurrency/value-a" && \
curl "http://127.0.0.1:9501/concurrency/value-c" ;
Result: 'Value A', 'Value B', 'Value C'

curl "http://127.0.0.1:9501/concurrency/data"
Result: ''

https://github.com/thiagoeti/php-hyperf-overlapping-concurrency

PHP HyperF + MariaDB -> Async / Parallel

Thiago Silva — Tue, 25 Jun 2024 00:16:28 +0000

PHP: 8.3.7
PHP HyperF: 3.1.23
MariaDB: 11.3.2

HyperF - Project

System test for executing database queries in parallel or asynchronously.

Create - Project

composer create-project hyperf/hyperf-skeleton "project"

Install - Watcher

composer require hyperf/watcher --dev

Install - DB Library

composer require hyperf/database
composer require hyperf/db-connection

Server - Start

cd project ;
php bin/hyperf.php server:watch ;

MariaDB - Database

The data model is in meta tables, just for example.

Database - Project

CREATE DATABASE `project`;

Table - Family

CREATE TABLE `family` (
    `id` tinyint(3) unsigned NOT NULL,
    `name` varchar(40) DEFAULT NULL,
    PRIMARY KEY (`id`)
) ENGINE=InnoDB DEFAULT CHARSET=utf8;

Table - Pets

CREATE TABLE `pet` (
    `id` tinyint(3) unsigned NOT NULL,
    `name` varchar(40) DEFAULT NULL,
    PRIMARY KEY (`id`)
) ENGINE=InnoDB DEFAULT CHARSET=utf8;

Table - Car

CREATE TABLE `car` (
    `id` tinyint(3) unsigned NOT NULL,
    `name` varchar(40) DEFAULT NULL,
    PRIMARY KEY (`id`)
) ENGINE=InnoDB DEFAULT CHARSET=utf8;

Table - Family Setting

CREATE TABLE `family_setting` (
    `id_family` tinyint(3) unsigned NOT NULL,
    `type` varchar(10) DEFAULT NULL,
    `key` tinyint(3) unsigned NOT NULL,
    KEY (`id_family`),
    KEY (`type`),
    KEY (`key`)
) ENGINE=InnoDB DEFAULT CHARSET=utf8;

Populate - ALL

INSERT INTO `family` (`id`, `name`) VALUES(1, 'Family 1');
INSERT INTO `family` (`id`, `name`) VALUES(2, 'Family 2');
INSERT INTO `family` (`id`, `name`) VALUES(3, 'Family 3');

INSERT INTO `pet` (`id`, `name`) VALUES(1, 'Pet 1');
INSERT INTO `pet` (`id`, `name`) VALUES(2, 'Pet 2');
INSERT INTO `pet` (`id`, `name`) VALUES(3, 'Pet 3');

INSERT INTO `car` (`id`, `name`) VALUES(1, 'Car 1');
INSERT INTO `car` (`id`, `name`) VALUES(2, 'Car 2');
INSERT INTO `car` (`id`, `name`) VALUES(3, 'Car 3');

INSERT INTO `family_setting` (`id_family`, `type`, `key`) VALUES(1, 'pet', 1);
INSERT INTO `family_setting` (`id_family`, `type`, `key`) VALUES(1, 'pet', 2);
INSERT INTO `family_setting` (`id_family`, `type`, `key`) VALUES(1, 'car', 3);
INSERT INTO `family_setting` (`id_family`, `type`, `key`) VALUES(2, 'car', 1);
INSERT INTO `family_setting` (`id_family`, `type`, `key`) VALUES(2, 'car', 2);
INSERT INTO `family_setting` (`id_family`, `type`, `key`) VALUES(3, 'pet', 3);

HyperF - APP

Database Config - MariaDB

DB_DRIVER=mysql
DB_HOST=localhost
DB_PORT=3306
DB_DATABASE=project
DB_USERNAME=root
DB_PASSWORD=master

path: /project/.env

APP - Router

Router::addRoute(['GET', 'POST'], '/family', 'App\Controller\ControllerFamily@data');
Router::addRoute(['GET', 'POST'], '/family/mount', 'App\Controller\ControllerFamily@mount');

path: /project/config/routes.php

APP - Model - Family

namespace App\Model;

use Hyperf\DbConnection\Db;

class ModelFamily extends Model
{
    static public function data()
    {
        $family=Db::select('SELECT * FROM `family`;');
        return $family;
    }

    static public function mount()
    {
        $parallel=new \Hyperf\Coroutine\Parallel();

        $parallel->add(function(){
            $data=Db::select('SELECT * FROM `family`;');
            return $data;
        });

        $parallel->add(function(){
            $data=Db::select('SELECT * FROM `pet`;');
            sleep(2); // important add time test
            return $data;
        });

        $parallel->add(function(){
            $data=Db::select('SELECT * FROM `car`;');
            sleep(1); // important add time test
            return $data;
        });

        $parallel->add(function(){
            $data=Db::select('SELECT * FROM `family_setting`;');
            return $data;
        });

        $result=$parallel->wait();
        $result=[
            'family'=>$result[0],
            'pet'=>$result[1],
            'car'=>$result[2],
            'family_setting'=>$result[3],
        ];

        return $result;
    }
}

path: /project/app/Model/ModelFamily.php

APP - Controller - Family

namespace App\Controller;

use \App\Model\ModelFamily;

class ControllerFamily
{
    public function data()
    {
        $family=ModelFamily::data();
        return $family;
    }
    public function mount()
    {
        $data=ModelFamily::mount();
        return $data;
    }
}

path: /project/app/Controller/ControllerFamily.php

Execute

GET - Family

curl "http://127.0.0.1:9501/family" | jq .

[
    {
        "id": 1,
        "name": "Family 1"
    },
    {
        "id": 2,
        "name": "Family 2"
    },
    {
        "id": 3,
        "name": "Family 3"
    }
]

GET - Mount

curl "http://127.0.0.1:9501/family/mount" | jq .

{
    "family": [
        {
            "id": 1,
            "name": "Family 1"
        },
        ...
    ],
    "pet": [
        {
            "id": 1,
            "name": "Pet 1"
        },
        ...
    ],
    "car": [
        {
            "id": 1,
            "name": "Car 1"
        },
        ...
    ],
    "family_setting": [
        {
            "id_family": 1,
            "type": "pet",
            "key": 1
        },
        {
            "id_family": 1,
            "type": "pet",
            "key": 2
        },
        ...
    ]
}

https://github.com/thiagoeti/php-hyperf-mariadb-async-parrallel

PHP HyperF -> Overhead + Circuit Breaker

Thiago Silva — Tue, 18 Jun 2024 02:11:37 +0000

HyperF - Project

This test execute calc of Fibonacci to show how HyperF behaves with overload, after use the maximum CPU and requests, the next requests do not respond, the system get into a circuit breaker.

Create - Project

composer create-project hyperf/hyperf-skeleton "project"

Install - Watcher

composer require hyperf/watcher --dev

Server - Start

cd project ;
php bin/hyperf.php server:watch ;

HyperF - PHP

Set a time limit of one minute just for testing.

set_time_limit(60);

Path: project/bin/hyperf.php

HyperF - APP

APP - Config - Server

Limit to one process and one request at a time.

return [
    'settings' => [
        Constant::OPTION_WORKER_NUM => 1,
        Constant::OPTION_MAX_REQUEST => 1,
    ],
];

Path: project/config/autoload/server.php

APP - Router

Router::addRoute(['GET', 'POST'], '/stress', 'App\Controller\ControllerOverhead@stress');
Router::addRoute(['GET', 'POST'], '/data', 'App\Controller\ControllerOverhead@data');

Path: project/config/routes.php

APP - Controller - Overhead

namespace App\Controller;

class ControllerOverhead
{
    public function fibonacci($number)
    {
        if($number==0)
            return 0;
        elseif($number==1)
            return 1;
        else
            return ($this->fibonacci($number-1)+$this->fibonacci($number-2));
    }
    public function stress()
    {
        $time=microtime(true);
        $fibonacci=$this->fibonacci(40);
        $data=[
            'time'=>microtime(true)-$time,
            'fibonacci'=>$fibonacci,
        ];
        return $data;
    }
    public function data()
    {
        $time=microtime(true);
        $content='data';
        $data=[
            'time'=>microtime(true)-$time,
            'content'=>$content,
        ];
        return $data;
    }
}

Path: project/app/Controller/ControllerOverhead.php

Execute

GET - Data

curl "http://127.0.0.1:9501/data"
Response OK

GET - Stress

curl "http://127.0.0.1:9501/stress"
Wait... Response OK

GET - Overload

curl "http://127.0.0.1:9501/stress" && curl "http://127.0.0.1:9501/data"
Wait... Error -> Response only first request

Conclusion

The greater the processing power and network of your server, the greater the HyperF configuration can be.
In HyperF is default settings, the number of workers is equal the number of CPUs, and 100k requests maximum.

https://github.com/thiagoeti/php-hyperf-overhead-circuit-breaker

Docker + MariaDB

Thiago Silva — Thu, 13 Jun 2024 22:46:14 +0000

Database popular among developers.

Get container pull.

docker pull "mariadb"

Create network for data.

docker network create "mariadb"

Create volume for data.

docker volume create "mariadb"
ln -s "/var/lib/docker/volumes/mariadb" "/data/volume/"

Create and run container.

docker run --name "mariadb" \
    -p 3306:3306 \
    --network "mariadb" \
    -v "mariadb":"/var/lib/mariadb" \
    -e MARIADB_ROOT_PASSWORD="master" \
    --restart=always \
    -d "mariadb":"latest"

Database access "MARIADB_ROOT_PASSWORD".

Start container.

docker start "mariadb"

Access container.

docker exec -it "mariadb" "/bin/bash"

https://github.com/thiagoeti/docker-mariadb

Docker + Portainer

Thiago Silva — Thu, 06 Jun 2024 02:27:13 +0000

Tool for management of container in Docker.

Get container pull.

docker pull "portainer/portainer"

Create volume for data.

docker volume create "portainer"
ln -s "/var/lib/docker/volumes/portainer" "/data/volume/"

Create and run container.

docker run --name "portainer" \
    -p 9000:9000 \
    -v "/var/run/docker.sock:/var/run/docker.sock" \
    -v "portainer":"/data" \
    --restart=always \
    -d "portainer/portainer"

Start container.

docker start "portainer"

Insert user and password in first access.

user: portainer
password: ***

Important: if not first access machine in 5 minutes expire

https://github.com/thiagoeti/docker-portainer