cclilshy/p-ripple-framework

dev-main 2024-02-20 08:48 UTC

Requires

• php: >=8.3
• ext-event: *
• ext-pcntl: *
• ext-pdo: *
• ext-posix: *
• ext-redis: *
• ext-sockets: *
• ext-zend-opcache: *
• cclilshy/p-ripple: dev-main
• cclilshy/p-ripple-http-service: dev-main
• cclilshy/p-ripple-illuminate-database: dev-main
• cclilshy/p-ripple-protocol-websocket: dev-main
• cclilshy/p-ripple-redis: dev-main
• illuminate/validation: ^10.40
• illuminate/view: ^10.31
• symfony/dotenv: ^7.0

MIT

• cclilshy

README

内核 https://github.com/cloudtay/p-ripple

内核文档 https://cloudtay.github.io/p-ripple-document/

The documentation is being assembled, so check out the controller examples

Directory

ROOT
├──── app - 应用目录
│     ├── construct        # 构建服务
│     ├── http             # HTTP应用程序
│     │     ├── attribute  # HTTP注解解析器
│     │     ├── controller # HTTP控制器
│     │     ├── middleware # HTTP中间件
│     │     ├── public     # HTTP公共目录
│     │     ├── route      # HTTP路由
│     │     ├── service    # HTTP业务服务
│     │     └── view       # HTTP视图
│     ├── model            # 模型
│     └── service          # 常驻服务
├──── component            # 组件目录
├──── config               # 配置目录
├──── resource             # 资源目录
│     ├── cert             # 证书目录
│     ├── database         # 数据库目录
│     └── lang             # 语言目录
└──── runtime              # 运行时目录

Example

<?php

namespace app\http\controller;

use app\http\attribute\PreventLoggedRequest;
use app\http\attribute\PreventNotLoggedRequest;
use app\http\attribute\Validate;
use app\http\service\validator\LoginFormValidator;
use app\model\UserModel;
use app\service\WebSocketService;
use Cclilshy\PRipple\Core\Coroutine\Coroutine;
use Cclilshy\PRipple\Core\Event\Event;
use Cclilshy\PRipple\Facade\RPC;
use Cclilshy\PRipple\Framework\Exception\JsonException;
use Cclilshy\PRipple\Framework\Facades\Log;
use Cclilshy\PRipple\Framework\Route\Route;
use Cclilshy\PRipple\Framework\Session\Session;
use Cclilshy\PRipple\Http\Service\Request;
use Cclilshy\PRipple\PRipple;
use Generator;
use Illuminate\Support\Facades\View;
use RedisException;
use Throwable;
use function Co\async;

/**
 * @Class IndexController
 */
class IndexController
{
    public static function index(Request $request): Generator
    {
        return yield $request->respondBody('Hello,World!');
    }

    #[PreventNotLoggedRequest]
    public static function info(Request $request): Generator
    {
        return yield $request->respondJson([
            'code' => 0,
            'msg'  => 'success',
            'data' => [
                'pid'       => posix_getpid(),
                'rpc'       => array_keys(RPC::getInstance()->rpcServiceConnections),
                'configure' => PRipple::getArgument()
            ]
        ]);
    }

    #[PreventNotLoggedRequest]
    public static function data(Request $request): Generator
    {
        $data = UserModel::query()->first();
        return yield $request->respondJson([
            'code' => 0,
            'msg'  => 'success',
            'data' => $data
        ]);
    }

    #[PreventNotLoggedRequest]
    public static function notice(Request $request): Generator
    {
        if ($message = $request->query('message')) {
            // 请求结束后执行
            $request->defer(fn() => Log::write("notice:$message"));
            RPC::call([WebSocketService::class, 'sendMessageToAll'], $message);
            return yield $request->respondJson([
                'code' => 0,
                'msg'  => 'success',
                'data' => [
                    'message' => $message
                ]
            ]);
        }
        return yield $request->respondJson([
            'code' => 1,
            'msg'  => 'error',
            'data' => [
                'message' => 'message is required'
            ],
        ]);
    }

    /**
     * @throws JsonException
     * @throws RedisException
     */
    #[PreventLoggedRequest]
    #[Validate(LoginFormValidator::class)]
    public static function login(Request $request, Validate $validate, Session $session): Generator
    {
        if ($validate->validator->fails()) {
            $request->defer(fn() => Log::write("[login failed:{$request->header('REMOTE_ADDR')}]"));
            throw new JsonException($validate->validator->errors()->first());
        } else {
            $session->set('username', $username = $request->query('username'));
            return yield $request->respondJson([
                'code' => 0,
                'msg'  => 'success',
                'data' => [
                    'message' => 'welcome,' . $username
                ],
            ]);
        }
    }


    #[PreventNotLoggedRequest]
    public static function logout(Request $request, Session $session): Generator
    {
        try {
            $session->clear();
        } catch (RedisException $exception) {
            return yield $request->respondJson([
                'code' => -1,
                'msg'  => 'error',
                'data' => [
                    'message' => $exception->getMessage()
                ],
            ]);
        }
        yield $request->respondJson([
            'code' => 0,
            'msg'  => 'success',
            'data' => [
                'message' => 'logout success'
            ]
        ]);
    }

    /**
     * @param Request $request
     * @return Generator
     */
    public static function download(Request $request): Generator
    {
        yield $request->respondFile(__DIR__ . '/IndexController.php', 'Index.php');
    }

    /**
     * @param Request $request
     * @return Generator
     */
    public static function upload(Request $request): Generator
    {
        if ($request->method === Route::GET) {
            $template = View::make('upload', ['title' => 'please select upload file'])->render();
            return yield $request->respondBody($template);
        } else {
            if ($request->upload) {
                $files = [];

                $request->on(Request::ON_UPLOAD, function (Event $event) use (&$files) {
                    $event->data['size'] = filesize($event->data['path']);
                    $event->data['md5']  = md5_file($event->data['path']);
                    $files[]             = $event->data;
                    RPC::call([WebSocketService::class, 'sendMessageToAll'], 'Upload File Info:' . json_encode($event->data));
                });


                $request->then(function () use ($request, &$files) {
                    $request->client->send($request->respondJson([
                        'files' => $files
                    ]));
                });
            }
        }
    }

    /**
     * @throws Throwable
     */
    public static function sleep(Request $request): Generator
    {
        \Co\sleep(3);
        yield $request->respondBody('sleep 3s');
    }
}