WIP: Sync proxy

src/Controller/Kobo/KoboAuthDeviceController.php

@@ -0,0 +1,42 @@
+<?php
+
+namespace App\Controller\Kobo;
+
+use App\Kobo\Proxy\KoboProxyConfiguration;
+use App\Kobo\Proxy\KoboStoreProxy;
+use GuzzleHttp\Exception\GuzzleException;
+use Psr\Log\LoggerInterface;
+use Symfony\Bundle\FrameworkBundle\Controller\AbstractController;
+use Symfony\Component\HttpFoundation\Request;
+use Symfony\Component\HttpFoundation\Response;
+use Symfony\Component\Routing\Attribute\Route;
+
+#[Route('/kobo/{accessKey}', name: 'kobo')]
+class KoboAuthDeviceController extends AbstractController
+{
+    public function __construct(
+        protected KoboProxyConfiguration $koboProxyConfiguration,
+        protected KoboStoreProxy $koboStoreProxy,
+        protected LoggerInterface $logger)
+    {
+    }
+
+    /**
+     * @throws GuzzleException
+     */
+    #[Route('/v1/auth/device', methods: ['GET', 'POST'])]
+    #[Route('/v1/auth/refresh', methods: ['GET', 'POST'])]
+    public function authDevice(Request $request): Response
+    {
+        if ($this->koboProxyConfiguration->useProxy()) {
+            return $this->koboStoreProxy->proxy(
+                $request, ['stream' => true]
+            );
+        }
+
+        $response = new Response();
+        $response->headers->set('Content-Type', 'application/json');
+
+        return $response;
+    }
+}

src/Controller/Kobo/KoboController.php

@@ -42,10 +42,7 @@ public function index(): Response
     #[Route('/v1/products/{uuid}/prices', requirements: ['uuid' => '^[a-zA-Z0-9\-]+$'], methods: ['GET', 'POST'])]
     #[Route('/v1/products/{uuid}/recommendations', requirements: ['uuid' => '^[a-zA-Z0-9\-]+$'], methods: ['GET', 'POST'])]
     #[Route('/v1/products/{uuid}/reviews', requirements: ['uuid' => '^[a-zA-Z0-9\-]+$'], methods: ['GET', 'POST'])]
-    #[Route('/v1/user/profile')]
     #[Route('/v1/configuration')]
-    #[Route('/v1/auth/device')]
-    #[Route('/v1/auth/refresh')]
     #[Route('/v1/library/borrow')]
     #[Route('/v1/auth/exchange')]
     #[Route('/v1/library/{uuid}', methods: ['DELETE'])]

src/Controller/Kobo/KoboSyncController.php

@@ -49,6 +49,10 @@ public function __construct(
     #[Route('/v1/library/sync', name: 'api_endpoint_v1_library_sync')]
     public function apiEndpoint(KoboDevice $kobo, SyncToken $syncToken, Request $request): Response
     {
+        // if (true) {
+        //     return $this->koboStoreProxy->proxy($request);
+        // }
+
         $forced = $kobo->isForceSync() || $request->query->has('force');
         $count = $this->koboSyncedBookRepository->countByKoboDevice($kobo);
         if ($forced || $count === 0) {

src/Controller/Kobo/KoboUserProfileController.php

@@ -0,0 +1,47 @@
+<?php
+
+namespace App\Controller\Kobo;
+
+use App\Kobo\Proxy\KoboProxyConfiguration;
+use App\Kobo\Proxy\KoboStoreProxy;
+use Symfony\Bundle\FrameworkBundle\Controller\AbstractController;
+use Symfony\Component\HttpFoundation\Request;
+use Symfony\Component\HttpFoundation\Response;
+use Symfony\Component\Routing\Attribute\Route;
+
+#[Route('/kobo/{accessKey}', name: 'kobo')]
+class KoboUserProfileController extends AbstractController
+{
+    public function __construct(
+        protected KoboProxyConfiguration $koboProxyConfiguration,
+        protected KoboStoreProxy $koboStoreProxy,
+    ) {
+    }
+
+    #[Route('/v1/user/profile')]
+    public function userProfile(Request $request): Response
+    {
+        if ($this->koboProxyConfiguration->useProxy()) {
+            return $this->koboStoreProxy->proxy($request);
+        }
+
+        $tokenParts = [];
+        $tokenParts[] = base64_encode((string) json_encode([
+            'typ' => 1,
+            'ver' => 'v1',
+            'ptyp' => 'ApiUserToken',
+        ]));
+        $tokenParts[] = base64_encode((string) json_encode([
+            'LoyaltyMembershipVersion' => 2147483647,
+            'LastModifiedTime' => -62135596800,
+            'BuildVersion' => '1.0.0',
+            'LifetimeTagsHash' => -790277027,
+        ]));
+
+        $response = new Response();
+        $response->headers->set('Content-Type', 'application/json');
+        $response->headers->set('X-Kobo-Apitoken', base64_encode((string) json_encode(['x-kobo-profile-token' => implode('.', $tokenParts)])));
+
+        return $response;
+    }
+}

src/Kobo/Proxy/KoboProxyLogger.php

@@ -54,10 +54,14 @@ protected function onFailure(RequestInterface $request): \Closure
 
     private function log(RequestInterface $request, ?ResponseInterface $response = null, ?\Throwable $error = null): void
     {
+        $body = $response?->getBody()->__toString();
+        $response?->getBody()->rewind();
+
         $this->logger->info(sprintf('Proxied: %s', (string) $request->getUri()), [
             'method' => $request->getMethod(),
             'status' => $response?->getStatusCode(),
             'token_hash' => md5($this->accessToken),
+            'body' => $body,
         ]);
 
         if ($error instanceof \Throwable) {

src/Kobo/Proxy/KoboStoreProxy.php

@@ -4,6 +4,7 @@
 
 use App\Security\KoboTokenExtractor;
 use GuzzleHttp\Client;
+use GuzzleHttp\Cookie\CookieJar;
 use GuzzleHttp\Exception\GuzzleException;
 use GuzzleHttp\Promise\PromiseInterface;
 use Nyholm\Psr7\Factory\Psr17Factory;
@@ -90,9 +91,14 @@ private function _proxy(Request $request, string $hostname, array $config = []):
         $psrRequest = $this->convertRequest($request, $hostname);
 
         $accessToken = $this->tokenExtractor->extractAccessToken($request) ?? 'unknown';
+        $jar = new CookieJar();
+        if ($psrRequest instanceof ServerRequestInterface) {
+            $jar = CookieJar::fromArray($psrRequest->getCookieParams(), $psrRequest->getUri()->getHost());
+        }
 
         $client = new Client();
         $psrResponse = $client->send($psrRequest, [
+            'cookies' => $jar,
             'base_uri' => $hostname,
             'handler' => $this->koboProxyLoggerFactory->createStack($accessToken),
             'http_errors' => false,
@@ -108,25 +114,59 @@ protected function getTransformedUrl(Request $request): UriInterface
         $psrRequest = $this->toPsrRequest($request);
         $hostname = $this->configuration->isImageHostUrl($psrRequest) ? $this->configuration->getImageApiUrl() : $this->configuration->getStoreApiUrl();
 
-        return $this->transformUrl($psrRequest, $hostname);
+        return $this->transformUrl($psrRequest, $hostname, $request->getScheme());
     }
 
-    private function transformUrl(ServerRequestInterface $psrRequest, string $hostname): UriInterface
+    private function transformUrl(ServerRequestInterface $psrRequest, string $hostname, string $scheme): UriInterface
     {
         $host = parse_url($hostname, PHP_URL_HOST);
         $host = $host === false ? $hostname : $host;
         $host = $host ?? $hostname;
         $path = $this->tokenExtractor->getOriginalPath($psrRequest, $psrRequest->getUri()->getPath());
 
-        return $psrRequest->getUri()->withHost($host)->withPath($path);
+        return $psrRequest->getUri()
+            ->withHost($host)
+            ->withPath($path)
+            ->withScheme($scheme)
+        ;
     }
 
     private function toPsrRequest(Request $request): ServerRequestInterface
     {
         $psr17Factory = new Psr17Factory();
         $psrHttpFactory = new PsrHttpFactory($psr17Factory, $psr17Factory, $psr17Factory, $psr17Factory);
 
-        return $psrHttpFactory->createRequest($request);
+        $request = clone $request;
+
+        // Remove server attributes
+        foreach ($request->server->all() as $key => $value) {
+            if ($key !== 'HTTPS' && $key !== 'X-Forwarded-Proto') {
+                $request->server->remove($key);
+            }
+        }
+
+        // Remove route attributes
+        foreach ($request->attributes->all() as $key => $value) {
+            $request->attributes->remove($key);
+        }
+
+        // Remove cookies
+        foreach ($request->cookies->all() as $key => $value) {
+            if (in_array($key, ['PHPSESSID', 'XDEBUG_SESSION'], true)) {
+                $request->cookies->remove($key);
+            }
+        }
+
+        // Remove headers
+        foreach ($request->headers->all() as $key => $value) {
+            if (str_starts_with($key, 'x-forwarded-') || $key === 'x-real-ip' || $key === 'cookie') {
+                $request->headers->remove($key);
+            }
+        }
+
+        return $psrHttpFactory->createRequest($request)
+            ->withCookieParams($request->cookies->all())
+        ;
     }
 
     public function proxyAsync(Request $request, bool $streamAllowed): PromiseInterface
@@ -137,8 +177,13 @@ public function proxyAsync(Request $request, bool $streamAllowed): PromiseInterf
         $accessToken = $this->tokenExtractor->extractAccessToken($request) ?? 'unknown';
 
         $client = new Client();
+        $jar = new CookieJar();
+        if ($psrRequest instanceof ServerRequestInterface) {
+            $jar = CookieJar::fromArray($psrRequest->getCookieParams(), $psrRequest->getUri()->getHost());
+        }
 
         return $client->sendAsync($psrRequest, [
+            'cookies' => $jar,
             'base_uri' => $hostname,
             'handler' => $this->koboProxyLoggerFactory->createStack($accessToken),
             'http_errors' => false,
@@ -154,11 +199,10 @@ private function convertRequest(Request $request, string $hostname): RequestInte
         $host = parse_url($hostname, PHP_URL_HOST);
         $host = $host === false ? $hostname : $host;
         $request->headers->set('Host', $host);
-        $request->server->set('HTTPS', 'on'); // Force HTTPS (for cli)
         $psrRequest = $this->toPsrRequest($request);
         $psrRequest = $this->cleanup($psrRequest);
 
-        $url = $this->transformUrl($psrRequest, $hostname);
+        $url = $this->transformUrl($psrRequest, $hostname, $request->getScheme());
 
         return $psrRequest->withUri($url);
     }