add refresh access token callback

amocrm · Apr 25, 2024 · 9c8e482 · 9c8e482
1 parent ea4bc87
commit 9c8e482
Show file tree

Hide file tree

Showing 2 changed files with 44 additions and 2 deletions.
diff --git a/src/AmoCRM/Client/AmoCRMApiClient.php b/src/AmoCRM/Client/AmoCRMApiClient.php
@@ -86,6 +86,11 @@ class AmoCRMApiClient
      */
     private $userAgent;
 
+    /**
+     * @var callable|null
+     */
+    private $refreshAccessTokenCallback;
+
     /**
      * AmoCRMApiClient constructor.
      *
@@ -181,6 +186,19 @@ public function onAccessTokenRefresh(callable $callback): self
         return $this;
     }
 
+    /**
+     * Устанавливаем callback, который будет вызван для обновления AccessToken`a библиотеки
+     *
+     * @param callable $callable
+     * @return $this
+     */
+    public function onRefreshAccessTokenCallback(callable $callable): self
+    {
+        $this->refreshAccessTokenCallback = $callable;
+
+        return $this;
+    }
+
     /**
      * Метод строит объект для совершения запросов для сервисов сущностей
      *
@@ -206,12 +224,18 @@ function (AccessToken $accessToken, string $baseAccountDomain) use ($oAuthClient
             }
         );
 
-        return new AmoCRMApiRequest(
+        $request = new AmoCRMApiRequest(
             $this->getAccessToken(),
             $oAuthClient,
             $this->getContextUserId(),
             $this->getUserAgent()
         );
+
+        if ($this->refreshAccessTokenCallback !== null) {
+            $request->setRefreshAccessTokenCallback($this->refreshAccessTokenCallback);
+        }
+
+        return $request;
     }
 
     /**

diff --git a/src/AmoCRM/Client/AmoCRMApiRequest.php b/src/AmoCRM/Client/AmoCRMApiRequest.php
@@ -107,6 +107,11 @@ class AmoCRMApiRequest
     /** @var string|null */
     private $userAgent = null;
 
+    /**
+     * @var callable
+     */
+    private $refreshAccessTokenCallback;
+
     /**
      * AmoCRMApiRequest constructor.
      *
@@ -126,6 +131,19 @@ public function __construct(
         $this->httpClient = $oAuthClient->getHttpClient();
         $this->contextUserId = $contextUserId;
         $this->userAgent = $userAgent;
+        $this->refreshAccessTokenCallback = function () {
+            return $this->oAuthClient->getAccessTokenByRefreshToken($this->accessToken);
+        };
+    }
+
+    public function getRefreshAccessTokenCallback(): callable
+    {
+        return $this->refreshAccessTokenCallback;
+    }
+
+    public function setRefreshAccessTokenCallback(callable $callback): void
+    {
+        $this->refreshAccessTokenCallback = $callback;
     }
 
     /**
@@ -138,7 +156,7 @@ private function refreshAccessToken(): void
             throw new AmoCRMoAuthApiException('Can not update LongLivedAccessToken');
         }
 
-        $newAccessToken = $this->oAuthClient->getAccessTokenByRefreshToken($this->accessToken);
+        $newAccessToken = $this->getRefreshAccessTokenCallback();
         $this->accessToken = $newAccessToken;
     }