Added lambda on exception in retryTransaction

Author: Илья

src/Table.php

@@ -487,14 +487,16 @@ public function retryTransaction(Closure $userFunc, bool $idempotent = null, Ret
         }
 
         if (isset($options['idempotent']) && !is_null($idempotent)){
-            throw new Exception('...');
+            throw new \YdbPlatform\Ydb\Exception('Idempotent flag set in 2 params');
         }
-        else if (!isset($options['idempotent'])) {
+        else if (!is_null($idempotent)) {
             $options['idempotent'] = $idempotent;
+        } else {
+            $options['idempotent'] = false;
         }
 
         if (isset($options['retryParams']) && !is_null($params)){
-            throw new Exception('...');
+            throw new \YdbPlatform\Ydb\Exception('RetryParams set in 2 params');
         }
         else if (!isset($options['retryParams'])) {
             $options['retryParams'] = $params;

tests/CheckParamsInRetryTransactionTest.php

@@ -0,0 +1,53 @@
+<?php
+
+namespace YdbPlatform\Ydb\Test;
+
+use PHPUnit\Framework\TestCase;
+use YdbPlatform\Ydb\Exception;
+use YdbPlatform\Ydb\Retry\RetryParams;
+use YdbPlatform\Ydb\Session;
+use YdbPlatform\Ydb\Ydb;
+use YdbPlatform\Ydb\YdbTable;
+
+class CheckParamsInRetryTransactionTest extends TestCase
+{
+    public function testRun()
+    {
+        $config = [
+
+            // Database path
+            'database' => '/local',
+
+            // Database endpoint
+            'endpoint' => 'localhost:2136',
+
+            // Auto discovery (dedicated server only)
+            'discovery' => false,
+
+            // IAM config
+            'iam_config' => [
+                'anonymous' => true,
+                'insecure' => true
+            ],
+        ];
+
+        $ydb = new Ydb($config);
+
+        $table = $ydb->table();
+
+        try {
+            $table->retryTransaction(function (Session $session){}, true, null, ['idempotent'=>true]);
+            throw new \Exception('retryTransaction does not throw exception');
+        } catch (\YdbPlatform\Ydb\Exception $e){
+            self::assertEquals(1,1);
+        }
+
+        try {
+            $table->retryTransaction(function (Session $session){}, null, new RetryParams(), ['retryParams'=>new RetryParams()]);
+            throw new \Exception('retryTransaction does not throw exception');
+        } catch (\YdbPlatform\Ydb\Exception $e){
+            self::assertEquals(1,1);
+        }
+
+    }
+}