Blah

Signed-off-by: Luís Cobucci <[email protected]>

composer.json

@@ -22,6 +22,7 @@
         "php-64bit": "^8.1",
         "ext-pcntl": "*",
         "psr/log": "^3.0",
+        "react/async": "^4.0",
         "react/socket": "^1.6"
     },
     "require-dev": {

docker-compose.yml

@@ -5,7 +5,7 @@ services:
       - ALLOW_ANONYMOUS_LOGIN=yes
 
   kafka1:
-    image: bitnami/kafka:2.8.0
+    image: bitnami/kafka:3.2.0
     ports:
       - "9093:9093"
     environment:
@@ -17,9 +17,7 @@ services:
       - KAFKA_INTER_BROKER_LISTENER_NAME=CLIENT
 
   kafka2:
-    image: bitnami/kafka:2.8.0
-    profiles:
-      - clustered
+    image: bitnami/kafka:3.2.0
     ports:
       - "9094:9094"
     environment:

phpstan-baseline.neon

@@ -1,9 +1,49 @@
 parameters:
 	ignoreErrors:
 		-
-			message: "#^Parameter \\#2 \\$data of method Lcobucci\\\\Kafka\\\\Protocol\\\\Buffer\\:\\:unpack\\(\\) expects string, mixed given\\.$#"
-			count: 5
-			path: src/Protocol/Buffer.php
+			message: "#^Cannot use array destructuring on array\\<int\\|string, array\\<int, array\\<int, int\\|Lcobucci\\\\Kafka\\\\Protocol\\\\API\\\\Request\\|string\\>\\|int\\|Lcobucci\\\\Kafka\\\\Protocol\\\\API\\\\Request\\|React\\\\Promise\\\\Deferred\\|string\\>\\|int\\|React\\\\Promise\\\\Deferred\\>\\|int\\.$#"
+			count: 1
+			path: src/Client/Channel.php
+
+		-
+			message: "#^Parameter \\#1 \\$errorCode of class Lcobucci\\\\Kafka\\\\Protocol\\\\API\\\\ApiVersionsResponse constructor expects int, mixed given\\.$#"
+			count: 1
+			path: src/Protocol/API/ApiVersionsResponse.php
+
+		-
+			message: "#^Parameter \\#2 \\$apiVersions of class Lcobucci\\\\Kafka\\\\Protocol\\\\API\\\\ApiVersionsResponse constructor expects array\\<int, array\\{api_key\\: int, min_version\\: int, max_version\\: int\\}\\>, mixed given\\.$#"
+			count: 1
+			path: src/Protocol/API/ApiVersionsResponse.php
+
+		-
+			message: "#^Parameter \\#3 \\$throttleTime of class Lcobucci\\\\Kafka\\\\Protocol\\\\API\\\\ApiVersionsResponse constructor expects int, mixed given\\.$#"
+			count: 1
+			path: src/Protocol/API/ApiVersionsResponse.php
+
+		-
+			message: "#^Parameter \\#1 \\$errorCode of class Lcobucci\\\\Kafka\\\\Protocol\\\\API\\\\MetadataResponse constructor expects int, mixed given\\.$#"
+			count: 1
+			path: src/Protocol/API/MetadataResponse.php
+
+		-
+			message: "#^Parameter \\#2 \\$apiVersions of class Lcobucci\\\\Kafka\\\\Protocol\\\\API\\\\MetadataResponse constructor expects array\\<int, array\\{api_key\\: int, min_version\\: int, max_version\\: int\\}\\>, mixed given\\.$#"
+			count: 1
+			path: src/Protocol/API/MetadataResponse.php
+
+		-
+			message: "#^Parameter \\#3 \\$throttleTime of class Lcobucci\\\\Kafka\\\\Protocol\\\\API\\\\MetadataResponse constructor expects int, mixed given\\.$#"
+			count: 1
+			path: src/Protocol/API/MetadataResponse.php
+
+		-
+			message: "#^Parameter \\#1 \\$definition of method Lcobucci\\\\Kafka\\\\Protocol\\\\Schema\\\\Parser\\:\\:parse\\(\\) expects array\\<string, array\\<string, mixed\\>\\|class\\-string\\<Lcobucci\\\\Kafka\\\\Protocol\\\\Type\\>\\>, array\\<string, array\\<string, mixed\\>\\|string\\> given\\.$#"
+			count: 1
+			path: src/Protocol/API/Request.php
+
+		-
+			message: "#^Parameter \\#1 \\$definition of method Lcobucci\\\\Kafka\\\\Protocol\\\\Schema\\\\Parser\\:\\:parse\\(\\) expects array\\<string, array\\<string, mixed\\>\\|class\\-string\\<Lcobucci\\\\Kafka\\\\Protocol\\\\Type\\>\\>, array\\<string, array\\<string, mixed\\>\\|string\\> given\\.$#"
+			count: 1
+			path: src/Protocol/API/Response.php
 
 		-
 			message: "#^Parameter \\#1 \\$data of method Lcobucci\\\\Kafka\\\\Protocol\\\\Schema\\:\\:validateField\\(\\) expects array\\<string, mixed\\>, mixed given\\.$#"
@@ -15,6 +55,21 @@ parameters:
 			count: 1
 			path: src/Protocol/Schema.php
 
+		-
+			message: "#^Parameter \\#1 \\$definition of method Lcobucci\\\\Kafka\\\\Protocol\\\\Schema\\\\Parser\\:\\:parse\\(\\) expects array\\<string, array\\<string, mixed\\>\\|class\\-string\\<Lcobucci\\\\Kafka\\\\Protocol\\\\Type\\>\\>, array\\<string, mixed\\> given\\.$#"
+			count: 1
+			path: src/Protocol/Schema/Parser.php
+
+		-
+			message: "#^Parameter \\#1 \\$fieldDefinition of method Lcobucci\\\\Kafka\\\\Protocol\\\\Schema\\\\Parser\\:\\:parseFieldType\\(\\) expects array\\<string, mixed\\>\\|class\\-string\\<Lcobucci\\\\Kafka\\\\Protocol\\\\Type\\>, mixed given\\.$#"
+			count: 1
+			path: src/Protocol/Schema/Parser.php
+
+		-
+			message: "#^Parameter \\#2 \\$nullable of class Lcobucci\\\\Kafka\\\\Protocol\\\\Type\\\\ArrayOf constructor expects bool, mixed given\\.$#"
+			count: 1
+			path: src/Protocol/Schema/Parser.php
+
 		-
 			message: "#^Parameter \\#3 \\.\\.\\.\\$values of function sprintf expects bool\\|float\\|int\\|string\\|null, mixed given\\.$#"
 			count: 1
@@ -65,11 +120,6 @@ parameters:
 			count: 1
 			path: src/Protocol/Type/Int8.php
 
-		-
-			message: "#^Parameter \\#1 \\$content of static method Lcobucci\\\\Kafka\\\\Protocol\\\\Buffer\\:\\:fromContent\\(\\) expects string, mixed given\\.$#"
-			count: 1
-			path: src/Protocol/Type/NonNullableBytes.php
-
 		-
 			message: "#^Parameter \\#1 \\$data of method Lcobucci\\\\Kafka\\\\Protocol\\\\Type\\:\\:guardClass\\(\\) expects object\\|null, mixed given\\.$#"
 			count: 1
@@ -80,11 +130,6 @@ parameters:
 			count: 2
 			path: src/Protocol/Type/NonNullableBytes.php
 
-		-
-			message: "#^Method Lcobucci\\\\Kafka\\\\Protocol\\\\Type\\\\NonNullableString\\:\\:read\\(\\) should return string but returns mixed\\.$#"
-			count: 1
-			path: src/Protocol/Type/NonNullableString.php
-
 		-
 			message: "#^Parameter \\#1 \\$data of method Lcobucci\\\\Kafka\\\\Protocol\\\\Type\\:\\:guardLength\\(\\) expects string\\|null, mixed given\\.$#"
 			count: 1
@@ -100,21 +145,11 @@ parameters:
 			count: 1
 			path: src/Protocol/Type/NonNullableString.php
 
-		-
-			message: "#^Parameter \\#1 \\$content of static method Lcobucci\\\\Kafka\\\\Protocol\\\\Buffer\\:\\:fromContent\\(\\) expects string, mixed given\\.$#"
-			count: 1
-			path: src/Protocol/Type/NullableBytes.php
-
 		-
 			message: "#^Parameter \\#1 \\$data of method Lcobucci\\\\Kafka\\\\Protocol\\\\Type\\:\\:guardClass\\(\\) expects object\\|null, mixed given\\.$#"
 			count: 1
 			path: src/Protocol/Type/NullableBytes.php
 
-		-
-			message: "#^Method Lcobucci\\\\Kafka\\\\Protocol\\\\Type\\\\NullableString\\:\\:read\\(\\) should return string\\|null but returns mixed\\.$#"
-			count: 1
-			path: src/Protocol/Type/NullableString.php
-
 		-
 			message: "#^Parameter \\#1 \\$data of method Lcobucci\\\\Kafka\\\\Protocol\\\\Type\\:\\:guardLength\\(\\) expects string\\|null, mixed given\\.$#"
 			count: 1