make helper class

Author: Ahed92Wakim

composer.json

@@ -12,7 +12,10 @@
     "autoload": {
         "psr-4": {
             "MysqlDeadlocks\\RetryHelper\\": "src/"
-        }
+        },
+        "files": [
+            "src/Helper.php"
+        ]
     },
     "extra": {
         "laravel": {

src/RetryHelper.php renamed to src/DBTransactionRetryHelper.php

@@ -5,18 +5,18 @@
 use Illuminate\Support\Facades\DB;
 use Illuminate\Database\QueryException;
 
-class RetryHelper
+class DBTransactionRetryHelper
 {
     /**
      * Perform a database transaction with retry logic in case of deadlocks.
      *
      * @param callable $callback The transaction logic to execute.
      * @param int $maxRetries Number of times to retry on deadlock.
-     * @param int $retryDelay Delay between retries in milliseconds.
+     * @param int $retryDelay Delay between retries in seconds.
      * @return mixed
      * @throws QueryException
      */
-    public static function transactionWithRetry(callable $callback, $maxRetries = 5, $retryDelay = 200)
+    public static function transactionWithRetry(callable $callback, int $maxRetries = 3, int $retryDelay = 2)
     {
         $attempt = 0;
 
@@ -27,16 +27,26 @@ public static function transactionWithRetry(callable $callback, $maxRetries = 5,
 
             } catch (QueryException $e) {
                 // Check if the error is a deadlock (MySQL error code 1213)
-                if ($e->getCode() === '1213') {
+                if ($e->getCode() == 1213 || $e->getCode() == 40001 || $e->errorInfo[1] == 1213) {
                     $attempt++;
 
                     if ($attempt >= $maxRetries) {
+                        // Generate log when max retries are reached
+                        generateLog([
+                            'ExceptionName' => get_class($e),
+                            'QueryException' => $e->getMessage(),
+                            'url' => request()->getUri() ?? null,
+                            'method' => request()->getMethod() ?? null,
+                            'token' => request()->header()['authorization'] ?? null,
+                            'userId' => request()->user()->id ?? null,
+                            'trace' => getDebugBacktraceArray() ?? null,
+                        ],'mysql-deadlocks-logs');
                         // Throw the exception if max retries are reached
                         throw $e;
                     }
 
                     // Wait before retrying
-                    usleep($retryDelay * 1000); // Convert milliseconds to microseconds
+                    sleep($retryDelay); // Convert seconds to microseconds
                 } else {
                     // Re-throw exception if it's not a deadlock
                     throw $e;

src/Helper.php

@@ -0,0 +1,35 @@
+<?php
+
+
+use Illuminate\Support\Facades\Log;
+
+if (! function_exists('getDebugBacktraceArray')) {
+    function getDebugBacktraceArray(): array
+    {
+        $steps = [];
+        foreach (debug_backtrace() as $step) {
+            $steps[] = [
+                'file' => $step['file'] ?? '',
+                'class' => $step['class'] ?? '',
+                'function' => $step['function'] ?? '',
+                'line' => $step['line'] ?? '',
+            ];
+        }
+        return $steps;
+    }
+}
+
+if (! function_exists('generateLog')) {
+    function generateLog($var, $logFileName): void
+    {
+        if (is_null($logFileName)) {
+            $logFilePath = storage_path('logs/general_'.now()->toDateString().'.log');
+        } else {
+            $logFilePath = storage_path("logs/{$logFileName}_".now()->toDateString().'.log');
+        }
+        Log::build([
+            'driver' => 'single',
+            'path' => $logFilePath,
+        ])->error(var_export($var, true));
+    }
+}