Merge bearer token into request options if it's set

nordigen · Oct 9, 2023 · 91c402c · 91c402c
1 parent 9b2e30a
commit 91c402c
Showing 1 changed file with 19 additions and 0 deletions.
diff --git a/src/Http/RequestHandlerTrait.php b/src/Http/RequestHandlerTrait.php
@@ -14,9 +14,25 @@ trait RequestHandlerTrait
 
     protected ?string $accessToken = null;
 
+    private function mergeBearerToken(array $options): array {
+        if ($this->accessToken !== null) {
+            return array_merge(
+                $options,
+                [
+                    'headers' => array_merge(
+                        ["Authorization" => "Bearer {$this->accessToken}"],
+                        $options['headers'] ?? [],
+                    ),
+                ],
+            );
+        }
+        return $options;
+    }
+
     public function get(string $uri, array $options = []): ResponseInterface
     {
         try {
+            $options = $this->mergeBearerToken($options);
             $response = $this->httpClient->get($uri, $options);
             return $response;
         } catch (BadResponseException $exc) {
@@ -27,6 +43,7 @@ public function get(string $uri, array $options = []): ResponseInterface
     public function post(string $uri, array $options = []): ResponseInterface
     {
         try {
+            $options = $this->mergeBearerToken($options);
             $response = $this->httpClient->post($uri, $options);
             return $response;
         } catch (BadResponseException $exc) {
@@ -37,6 +54,7 @@ public function post(string $uri, array $options = []): ResponseInterface
     public function put(string $uri, array $options = []): ResponseInterface
     {
         try {
+            $options = $this->mergeBearerToken($options);
             $response = $this->httpClient->put($uri, $options);
             return $response;
         } catch (BadResponseException $exc) {
@@ -47,6 +65,7 @@ public function put(string $uri, array $options = []): ResponseInterface
     public function delete(string $uri, array $options = []): ResponseInterface
     {
         try {
+            $options = $this->mergeBearerToken($options);
             $response = $this->httpClient->delete($uri, $options);
             return $response;
         } catch (BadResponseException $exc) {