first commit

Author: chaz6chez

.gitignore

@@ -0,0 +1,8 @@
+/runtime
+/.idea
+/.vscode
+/vendor
+*.log
+.env
+/tests/tmp
+/tests/.phpunit.result.cache

LICENSE

@@ -186,7 +186,7 @@
       same "printed page" as the copyright notice for easier
       identification within third-party archives.
 
-   Copyright [yyyy] [name of copyright owner]
+   Copyright 2025 workbunny [https://github.com/workbunny]
 
    Licensed under the Apache License, Version 2.0 (the "License");
    you may not use this file except in compliance with the License.

composer.json

@@ -0,0 +1,24 @@
+{
+  "name": "workbunny/mysql-protocol",
+  "type": "library",
+  "license": "Apache-2.0",
+  "description": "The MySQL protocol implemented by PHP",
+  "authors": [
+    {
+      "name": "chaz6chez",
+      "email": "[email protected]"
+    }
+  ],
+  "require": {
+    "php": ">=8.1"
+  },
+  "autoload": {
+    "psr-4": {
+      "Workbunny\\MysqlProtocol\\": "src",
+      "Protocols\\" : "protocols"
+    }
+  },
+  "suggest": {
+    "workerman/workerman": "workerman implementation supporting the MySQL protocol"
+  }
+}

protocols/MySQL.php

@@ -0,0 +1,68 @@
+<?php
+
+declare(strict_types=1);
+
+namespace Protocols;
+
+use nWorkbunny\MysqlProtocol\Utils\Binary;
+use nWorkbunny\MysqlProtocol\Utils\Packet;
+use Workerman\Connection\ConnectionInterface;
+use Workerman\Worker;
+
+class MySQL
+{
+
+    /**
+     * Check the integrity of the package.
+     * Please return the length of package.
+     * If length is unknown please return 0 that means waiting for more data.
+     * If the package has something wrong please return -1 the connection will be closed.
+     *
+     * @param string $buffer
+     * @param ConnectionInterface $connection
+     * @return int
+     */
+    public static function input(string $buffer, ConnectionInterface $connection): int
+    {
+        try {
+            $data = Packet::parser(function (Binary $binary) {
+                return [];
+            }, $binary = new Binary($buffer));
+            return 4 + $data['packet_length'];
+        } catch (\Throwable $throwable) {
+            Worker::safeEcho("Error: {$throwable->getMessage()}\n");
+            $connection->close();
+            return 0;
+        }
+    }
+
+    /**
+     * Decode package and emit onMessage($message) callback, $message is the result that decode returned.
+     *
+     * @param string $buffer
+     * @param ConnectionInterface $connection
+     * @return Binary|null
+     */
+    public static function decode(string $buffer, ConnectionInterface $connection): ?Binary
+    {
+        try {
+            return new Binary($buffer);
+        } catch (\Throwable $throwable) {
+            Worker::safeEcho("Error: {$throwable->getMessage()}\n");
+            $connection->close();
+            return null;
+        }
+    }
+
+    /**
+     * Encode package before sending to client.
+     *
+     * @param Binary $data
+     * @param ConnectionInterface $connection
+     * @return string
+     */
+    public static function encode(Binary $data, ConnectionInterface $connection): string
+    {
+        return $data->pack();
+    }
+}

src/Constants/Capabilities.php

@@ -0,0 +1,49 @@
+<?php
+
+declare(strict_types=1);
+
+namespace nWorkbunny\MysqlProtocol\Constants;
+
+enum Capabilities: int
+{
+    // new more secure passwords
+    case CLIENT_LONG_PASSWORD = 1;
+    // Found instead of affected rows
+    case CLIENT_FOUND_ROWS = 2;
+    // Get all column flags
+    case CLIENT_LONG_FLAG = 4;
+    // One can specify db on connect
+    case CLIENT_CONNECT_WITH_DB = 8;
+    // Don't allow database.table.column
+    case CLIENT_NO_SCHEMA = 16;
+    // Can use compression protocol
+    case CLIENT_COMPRESS = 32;
+    // Odbc client
+    case CLIENT_ODBC = 64;
+    // Can use LOAD DATA LOCAL
+    case CLIENT_LOCAL_FILES = 128;
+    // Ignore spaces before '('
+    case CLIENT_IGNORE_SPACE = 256;
+    // New 4.1 protocol This is an interactive client
+    case CLIENT_PROTOCOL_41 = 512;
+    // This is an interactive client
+    case CLIENT_INTERACTIVE = 1024;
+    // Switch to SSL after handshake
+    case CLIENT_SSL = 2048;
+    // IGNORE sigpipes
+    case CLIENT_IGNORE_SIGPIPE = 4096;
+    // Client knows about transactions
+    case CLIENT_TRANSACTIONS = 8192;
+    // Old flag for 4.1 protocol
+    case CLIENT_RESERVED = 16384;
+    // New 4.1 authentication
+    case CLIENT_SECURE_CONNECTION = 32768;
+    // Enable/disable multi-stmt support
+    case CLIENT_MULTI_STATEMENTS = 65536;
+    // Enable/disable multi-results
+    case CLIENT_MULTI_RESULTS = 131072;
+    case CLIENT_PLUGIN_AUTH = 524288;
+    case CLIENT_CONNECT_ATTRS = 1048576;
+    case CLIENT_PLUGIN_AUTH_LENENC_CLIENT_DATA = 2097152;
+}
+