fix: increase batch payload size limit from 32KB (#110)

Author: cat-ph

lib/Consumer/ForkCurl.php

@@ -74,10 +74,9 @@ public function flushBatch($messages)
 
         $cmd .= " '" . $url . "'";
 
-        // Verify message size is below than 32KB
-        if (strlen($payload) >= 32 * 1024) {
+        if (strlen($payload) >= self::MAX_BATCH_PAYLOAD_SIZE) {
             if ($this->debug()) {
-                $msg = "Message size is larger than 32KB";
+                $msg = "Message size is larger than " . self::MAX_BATCH_PAYLOAD_SIZE_HUMAN;
                 error_log("[PostHog][" . $this->type . "] " . $msg);
             }
 

lib/Consumer/LibCurl.php

@@ -56,10 +56,9 @@ public function flushBatch($messages)
         $body = $this->payload($messages);
         $payload = json_encode($body);
 
-        // Verify message size is below than 32KB
-        if (strlen($payload) >= 32 * 1024) {
+        if (strlen($payload) >= self::MAX_BATCH_PAYLOAD_SIZE) {
             if ($this->debug()) {
-                $msg = "Message size is larger than 32KB";
+                $msg = "Message size is larger than " . self::MAX_BATCH_PAYLOAD_SIZE_HUMAN;
                 error_log("[PostHog][" . $this->type . "] " . $msg);
             }
 

lib/Consumer/Socket.php

@@ -200,10 +200,9 @@ private function createBody($host, $content)
         $req .= "\r\n";
         $req .= $content;
 
-        // Verify message size is below than 32KB
-        if (strlen($req) >= 32 * 1024) {
+        if (strlen($req) >= self::MAX_BATCH_PAYLOAD_SIZE) {
             if ($this->debug()) {
-                $msg = "Message size is larger than 32KB";
+                $msg = "Message size is larger than " . self::MAX_BATCH_PAYLOAD_SIZE_HUMAN;
                 error_log("[PostHog][" . $this->type . "] " . $msg);
             }
 

lib/QueueConsumer.php

@@ -4,6 +4,9 @@
 
 abstract class QueueConsumer extends Consumer
 {
+    protected const MAX_BATCH_PAYLOAD_SIZE = 1024 * 1024; // 1MB
+    protected const MAX_BATCH_PAYLOAD_SIZE_HUMAN = (self::MAX_BATCH_PAYLOAD_SIZE / 1024) . 'KB';
+
     protected $type = "QueueConsumer";
 
     protected $queue;