index.php

<?php

declare(strict_types=1);

use Nyholm\Psr7\Factory\Psr17Factory;
use Nyholm\Psr7\Response;
use Nyholm\Psr7\Stream;
use Nyholm\Psr7Server\ServerRequestCreator;
use Shopware\App\SDK\AppConfiguration;
use Shopware\App\SDK\AppLifecycle;
use Shopware\App\SDK\Authentication\ResponseSigner;
use Shopware\App\SDK\Context\ContextResolver;
use Shopware\App\SDK\Context\InAppPurchase\InAppPurchaseProvider;
use Shopware\App\SDK\Context\InAppPurchase\SBPStoreKeyFetcher;
use Shopware\App\SDK\HttpClient\ClientFactory;
use Shopware\App\SDK\Response\ActionButtonResponse;
use Shopware\App\SDK\Response\PaymentResponse;
use Shopware\App\SDK\Registration\RegistrationService;
use Shopware\App\SDK\Shop\ShopResolver;
use Shopware\App\SDK\TaxProvider\CalculatedTax;
use Shopware\App\SDK\TaxProvider\TaxProviderResponseBuilder;
use Shopware\App\SDK\Test\MockShop;

require __DIR__ . '/../vendor/autoload.php';
require __DIR__ . '/helper.php';
require __DIR__ . '/FileRepository.php';

$psr17Factory = new Psr17Factory();

$creator = new ServerRequestCreator(
    $psr17Factory,
    $psr17Factory,
    $psr17Factory,
    $psr17Factory
);

$serverRequest = $creator->fromGlobals();

$app = new AppConfiguration('Foo', 'test', 'http://localhost:6001/register/callback');

$fileShopRepository = new FileShopRepository();
$registrationService = new RegistrationService($app, $fileShopRepository);
$shopResolver = new ShopResolver($fileShopRepository);
$appLifecycle = new AppLifecycle($registrationService, $shopResolver, $fileShopRepository);
$inAppPurchaseProvider = new InAppPurchaseProvider(new SBPStoreKeyFetcher(
    (new ClientFactory())->createClient(new MockShop('shopId', 'shopUrl', 'shopSecret'))
));
$contextResolver = new ContextResolver($inAppPurchaseProvider);
$signer = new ResponseSigner();

if (str_starts_with($serverRequest->getUri()->getPath(), '/register/authorize')) {
    send($appLifecycle->register($serverRequest));
} elseif (str_starts_with($serverRequest->getUri()->getPath(), '/register/callback')) {
    send($appLifecycle->registerConfirm($serverRequest));
} elseif (str_starts_with($serverRequest->getUri()->getPath(), '/webhook/app.deleted')) {
    send($appLifecycle->delete($serverRequest));
} elseif (str_starts_with($serverRequest->getUri()->getPath(), '/webhook/app.activated')) {
    send($appLifecycle->activate($serverRequest));
} elseif (str_starts_with($serverRequest->getUri()->getPath(), '/webhook/app.deactivated')) {
    send($appLifecycle->deactivate($serverRequest));
} elseif (str_starts_with($serverRequest->getUri()->getPath(), '/webhook/product.written')) {
    $shop = $shopResolver->resolveShop($serverRequest);
    $webhook = $contextResolver->assembleWebhook($serverRequest, $shop);

    error_log(sprintf('Got request from shop %s for event %s', $shop->getShopUrl(), $webhook->eventName));
} elseif (str_starts_with($serverRequest->getUri()->getPath(), '/tax/process')) {
    $shop = $shopResolver->resolveShop($serverRequest);
    $taxProviderContext = $contextResolver->assembleTaxProvider($serverRequest, $shop);

    $builder = new TaxProviderResponseBuilder();

    // Add tax for each line item
    foreach ($taxProviderContext->cart->getLineItems() as $item) {
        $taxRate = 50;

        $taxProviderContext = $item->getPrice()->getTotalPrice() * $taxRate / 100;

        $builder->addLineItemTax($item->getUniqueIdentifier(), new CalculatedTax(
            $taxProviderContext,
            $taxRate,
            $item->getPrice()->getTotalPrice()
        ));
    }

    send($signer->signResponse($builder->build(), $shop));
} elseif (str_starts_with($serverRequest->getUri()->getPath(), '/payment/pay')) {
    $shop = $shopResolver->resolveShop($serverRequest);
    $payment = $contextResolver->assemblePaymentPay($serverRequest, $shop);

    // do payment stuff
    error_log($payment->order->getOrderNumber());

    send($signer->signResponse(PaymentResponse::paid(), $shop));
} elseif (str_starts_with($serverRequest->getUri()->getPath(), '/payment/async-pay')) {
    $shop = $shopResolver->resolveShop($serverRequest);
    $payment = $contextResolver->assemblePaymentPay($serverRequest, $shop);

    // do payment stuff
    error_log($payment->order->getOrderNumber());

    send($signer->signResponse(PaymentResponse::redirect($payment->returnUrl), $shop));
} elseif (str_starts_with($serverRequest->getUri()->getPath(), '/payment/finalize')) {
    $shop = $shopResolver->resolveShop($serverRequest);

    $payment = $contextResolver->assemblePaymentFinalize($serverRequest, $shop);

    $signer = new ResponseSigner();

    send($signer->signResponse(PaymentResponse::paid(), $shop));
} elseif (str_starts_with($serverRequest->getUri()->getPath(), '/payment/validate')) {
    $shop = $shopResolver->resolveShop($serverRequest);

    $payment = $contextResolver->assemblePaymentValidate($serverRequest, $shop);

    send($signer->signResponse(PaymentResponse::validateSuccess(['myValue' => 1]), $shop));
} elseif (str_starts_with($serverRequest->getUri()->getPath(), '/payment/capture')) {
    $shop = $shopResolver->resolveShop($serverRequest);

    $capture = $contextResolver->assemblePaymentCapture($serverRequest, $shop);

    error_log((string)$capture->requestData['myValue']);

    $signer = new ResponseSigner();

    send($signer->signResponse(PaymentResponse::paid(), $shop));
} elseif (str_starts_with($serverRequest->getUri()->getPath(), '/module/test')) {
    $shop = $shopResolver->resolveShop($serverRequest);
    $module = $contextResolver->assembleModule($serverRequest, $shop);

    error_log(sprintf('Got module request language: %s, user language: %s', $module->contentLanguage, $module->userLanguage));

    header('Content-Type: text/html');
    echo '<h1>Hello World</h1>';
    echo "<script>
    window.parent.postMessage('sw-app-loaded', '*');
    </script>";
} elseif (str_starts_with($serverRequest->getUri()->getPath(), '/action/product')) {
    $shop = $shopResolver->resolveShop($serverRequest);
    $actionButton = $contextResolver->assembleActionButton($serverRequest, $shop);
    error_log(sprintf('Got request from shop %s for action %s and ids %s', $shop->getShopUrl(), $actionButton->action, implode(', ', $actionButton->ids)));

    send($signer->signResponse(ActionButtonResponse::notification('success', 'foo'), $shop));
} elseif (str_starts_with($serverRequest->getUri()->getPath(), '/storefront/action')) {
    $response = (new Response())
        ->withHeader('Access-Control-Allow-Origin', '*')
        ->withHeader('Access-Control-Allow-Methods', 'GET, POST, OPTIONS')
        ->withHeader('Access-Control-Allow-Headers', 'shopware-app-shop-id, shopware-app-token');

    if ($_SERVER['REQUEST_METHOD'] === 'OPTIONS') {
        send($response);
        return;
    }

    $shop = $shopResolver->resolveShop($serverRequest);

    $storefront = $contextResolver->assembleStorefrontRequest($serverRequest, $shop);

    $response = $response
        ->withHeader('Content-Type', 'application/json')
        ->withBody(Stream::create(json_encode([
            'success' => true,
            'data' => [
                'foo' => 'bar'
            ]
        ], JSON_THROW_ON_ERROR)));

    send($response);
} else {
    http_response_code(404);
}