kadet/iteo
1
0
Fork 0
Code Issues Pull Requests Projects Releases Wiki Activity

TASK-35: Send orders to CRM

Browse Source
This commit is contained in:
Kacper Donat 2024-04-14 20:17:21 +02:00
parent d6fdec2a8b
commit e223ddfb4f
17 changed files with 778 additions and 81 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
.env
View File

@ -22,3 +22,5 @@ APP_SECRET=ff44e0bb0862dabdb2d0a1ba40f489d9
###> doctrine/doctrine-bundle ###
DATABASE_URL="mysql://iteo:iteo@mariadb:3306/iteo?serverVersion=10.11.2-MariaDB&charset=utf8mb4"
###< doctrine/doctrine-bundle ###
APP_CRM_BASE_URL="http://crm.local"

1
behat.yml.dist
View File

@ -3,6 +3,7 @@ default:
default:
contexts:
- App\Tests\Behat\ApiCallContext
- App\Tests\Behat\ClientsContext
extensions:
FriendsOfBehat\SymfonyExtension:

3
composer.json
View File

@ -18,11 +18,13 @@
"symfony/dotenv": "7.0.*",
"symfony/flex": "^2",
"symfony/framework-bundle": "7.0.*",
"symfony/http-client": "7.0.*",
"symfony/property-access": "7.0.*",
"symfony/property-info": "7.0.*",
"symfony/runtime": "7.0.*",
"symfony/serializer": "7.0.*",
"symfony/uid": "7.0.*",
"symfony/validator": "7.0.*",
"symfony/yaml": "7.0.*"
},
"config": {
@ -76,6 +78,7 @@
},
"require-dev": {
"friends-of-behat/symfony-extension": "^2.0",
"mockery/mockery": "^1.6",
"phpunit/phpunit": "^9.5",
"symfony/browser-kit": "7.0.*",
"symfony/css-selector": "7.0.*",

556
composer.lock generated
View File

@ -4,7 +4,7 @@
"Read more about it at https://getcomposer.org/doc/01-basic-usage.md#installing-dependencies",
"This file is @generated automatically"
],
"content-hash": "e63cd12b3ea9a5ca7203ce3e59ec7678",
"content-hash": "51cd32c43082b3312c47499f02f2c2ea",
"packages": [
{
"name": "doctrine/cache",
@ -3097,6 +3097,176 @@
],
"time": "2024-03-27T19:55:25+00:00"
},
{
"name": "symfony/http-client",
"version": "v7.0.6",
"source": {
"type": "git",
"url": "https://github.com/symfony/http-client.git",
"reference": "6e70473909f46fe5dd3b994a0f1b20ecb6b2f858"
},
"dist": {
"type": "zip",
"url": "https://api.github.com/repos/symfony/http-client/zipball/6e70473909f46fe5dd3b994a0f1b20ecb6b2f858",
"reference": "6e70473909f46fe5dd3b994a0f1b20ecb6b2f858",
"shasum": ""
},
"require": {
"php": ">=8.2",
"psr/log": "^1|^2|^3",
"symfony/http-client-contracts": "^3.4.1",
"symfony/service-contracts": "^2.5|^3"
},
"conflict": {
"php-http/discovery": "<1.15",
"symfony/http-foundation": "<6.4"
},
"provide": {
"php-http/async-client-implementation": "*",
"php-http/client-implementation": "*",
"psr/http-client-implementation": "1.0",
"symfony/http-client-implementation": "3.0"
},
"require-dev": {
"amphp/amp": "^2.5",
"amphp/http-client": "^4.2.1",
"amphp/http-tunnel": "^1.0",
"amphp/socket": "^1.1",
"guzzlehttp/promises": "^1.4|^2.0",
"nyholm/psr7": "^1.0",
"php-http/httplug": "^1.0|^2.0",
"psr/http-client": "^1.0",
"symfony/dependency-injection": "^6.4|^7.0",
"symfony/http-kernel": "^6.4|^7.0",
"symfony/messenger": "^6.4|^7.0",
"symfony/process": "^6.4|^7.0",
"symfony/stopwatch": "^6.4|^7.0"
},
"type": "library",
"autoload": {
"psr-4": {
"Symfony\\Component\\HttpClient\\": ""
},
"exclude-from-classmap": [
"/Tests/"
]
},
"notification-url": "https://packagist.org/downloads/",
"license": [
"MIT"
],
"authors": [
{
"name": "Nicolas Grekas",
"email": "p@tchwork.com"
},
{
"name": "Symfony Community",
"homepage": "https://symfony.com/contributors"
}
],
"description": "Provides powerful methods to fetch HTTP resources synchronously or asynchronously",
"homepage": "https://symfony.com",
"keywords": [
"http"
],
"support": {
"source": "https://github.com/symfony/http-client/tree/v7.0.6"
},
"funding": [
{
"url": "https://symfony.com/sponsor",
"type": "custom"
},
{
"url": "https://github.com/fabpot",
"type": "github"
},
{
"url": "https://tidelift.com/funding/github/packagist/symfony/symfony",
"type": "tidelift"
}
],
"time": "2024-04-01T20:49:44+00:00"
},
{
"name": "symfony/http-client-contracts",
"version": "v3.4.2",
"source": {
"type": "git",
"url": "https://github.com/symfony/http-client-contracts.git",
"reference": "b6b5c876b3a4ed74460e2c5ac53bbce2f12e2a7e"
},
"dist": {
"type": "zip",
"url": "https://api.github.com/repos/symfony/http-client-contracts/zipball/b6b5c876b3a4ed74460e2c5ac53bbce2f12e2a7e",
"reference": "b6b5c876b3a4ed74460e2c5ac53bbce2f12e2a7e",
"shasum": ""
},
"require": {
"php": ">=8.1"
},
"type": "library",
"extra": {
"branch-alias": {
"dev-main": "3.4-dev"
},
"thanks": {
"name": "symfony/contracts",
"url": "https://github.com/symfony/contracts"
}
},
"autoload": {
"psr-4": {
"Symfony\\Contracts\\HttpClient\\": ""
},
"exclude-from-classmap": [
"/Test/"
]
},
"notification-url": "https://packagist.org/downloads/",
"license": [
"MIT"
],
"authors": [
{
"name": "Nicolas Grekas",
"email": "p@tchwork.com"
},
{
"name": "Symfony Community",
"homepage": "https://symfony.com/contributors"
}
],
"description": "Generic abstractions related to HTTP clients",
"homepage": "https://symfony.com",
"keywords": [
"abstractions",
"contracts",
"decoupling",
"interfaces",
"interoperability",
"standards"
],
"support": {
"source": "https://github.com/symfony/http-client-contracts/tree/v3.4.2"
},
"funding": [
{
"url": "https://symfony.com/sponsor",
"type": "custom"
},
{
"url": "https://github.com/fabpot",
"type": "github"
},
{
"url": "https://tidelift.com/funding/github/packagist/symfony/symfony",
"type": "tidelift"
}
],
"time": "2024-04-01T18:51:09+00:00"
},
{
"name": "symfony/http-foundation",
"version": "v7.0.6",
@ -4325,6 +4495,84 @@
],
"time": "2024-02-01T13:17:36+00:00"
},
{
"name": "symfony/translation-contracts",
"version": "v3.4.2",
"source": {
"type": "git",
"url": "https://github.com/symfony/translation-contracts.git",
"reference": "43810bdb2ddb5400e5c5e778e27b210a0ca83b6b"
},
"dist": {
"type": "zip",
"url": "https://api.github.com/repos/symfony/translation-contracts/zipball/43810bdb2ddb5400e5c5e778e27b210a0ca83b6b",
"reference": "43810bdb2ddb5400e5c5e778e27b210a0ca83b6b",
"shasum": ""
},
"require": {
"php": ">=8.1"
},
"type": "library",
"extra": {
"branch-alias": {
"dev-main": "3.4-dev"
},
"thanks": {
"name": "symfony/contracts",
"url": "https://github.com/symfony/contracts"
}
},
"autoload": {
"psr-4": {
"Symfony\\Contracts\\Translation\\": ""
},
"exclude-from-classmap": [
"/Test/"
]
},
"notification-url": "https://packagist.org/downloads/",
"license": [
"MIT"
],
"authors": [
{
"name": "Nicolas Grekas",
"email": "p@tchwork.com"
},
{
"name": "Symfony Community",
"homepage": "https://symfony.com/contributors"
}
],
"description": "Generic abstractions related to translation",
"homepage": "https://symfony.com",
"keywords": [
"abstractions",
"contracts",
"decoupling",
"interfaces",
"interoperability",
"standards"
],
"support": {
"source": "https://github.com/symfony/translation-contracts/tree/v3.4.2"
},
"funding": [
{
"url": "https://symfony.com/sponsor",
"type": "custom"
},
{
"url": "https://github.com/fabpot",
"type": "github"
},
{
"url": "https://tidelift.com/funding/github/packagist/symfony/symfony",
"type": "tidelift"
}
],
"time": "2024-01-23T14:51:35+00:00"
},
{
"name": "symfony/uid",
"version": "v7.0.3",
@ -4399,6 +4647,100 @@
],
"time": "2024-01-23T15:02:46+00:00"
},
{
"name": "symfony/validator",
"version": "v7.0.6",
"source": {
"type": "git",
"url": "https://github.com/symfony/validator.git",
"reference": "a2df2c63b7944a162dee86ab8065f2f91b7d6e36"
},
"dist": {
"type": "zip",
"url": "https://api.github.com/repos/symfony/validator/zipball/a2df2c63b7944a162dee86ab8065f2f91b7d6e36",
"reference": "a2df2c63b7944a162dee86ab8065f2f91b7d6e36",
"shasum": ""
},
"require": {
"php": ">=8.2",
"symfony/polyfill-ctype": "~1.8",
"symfony/polyfill-mbstring": "~1.0",
"symfony/polyfill-php83": "^1.27",
"symfony/translation-contracts": "^2.5|^3"
},
"conflict": {
"doctrine/lexer": "<1.1",
"symfony/dependency-injection": "<6.4",
"symfony/doctrine-bridge": "<7.0",
"symfony/expression-language": "<6.4",
"symfony/http-kernel": "<6.4",
"symfony/intl": "<6.4",
"symfony/property-info": "<6.4",
"symfony/translation": "<6.4.3|>=7.0,<7.0.3",
"symfony/yaml": "<6.4"
},
"require-dev": {
"egulias/email-validator": "^2.1.10|^3|^4",
"symfony/cache": "^6.4|^7.0",
"symfony/config": "^6.4|^7.0",
"symfony/console": "^6.4|^7.0",
"symfony/dependency-injection": "^6.4|^7.0",
"symfony/expression-language": "^6.4|^7.0",
"symfony/finder": "^6.4|^7.0",
"symfony/http-client": "^6.4|^7.0",
"symfony/http-foundation": "^6.4|^7.0",
"symfony/http-kernel": "^6.4|^7.0",
"symfony/intl": "^6.4|^7.0",
"symfony/mime": "^6.4|^7.0",
"symfony/property-access": "^6.4|^7.0",
"symfony/property-info": "^6.4|^7.0",
"symfony/translation": "^6.4.3|^7.0.3",
"symfony/yaml": "^6.4|^7.0"
},
"type": "library",
"autoload": {
"psr-4": {
"Symfony\\Component\\Validator\\": ""
},
"exclude-from-classmap": [
"/Tests/"
]
},
"notification-url": "https://packagist.org/downloads/",
"license": [
"MIT"
],
"authors": [
{
"name": "Fabien Potencier",
"email": "fabien@symfony.com"
},
{
"name": "Symfony Community",
"homepage": "https://symfony.com/contributors"
}
],
"description": "Provides tools to validate values",
"homepage": "https://symfony.com",
"support": {
"source": "https://github.com/symfony/validator/tree/v7.0.6"
},
"funding": [
{
"url": "https://symfony.com/sponsor",
"type": "custom"
},
{
"url": "https://github.com/fabpot",
"type": "github"
},
{
"url": "https://tidelift.com/funding/github/packagist/symfony/symfony",
"type": "tidelift"
}
],
"time": "2024-03-28T09:20:36+00:00"
},
{
"name": "symfony/var-dumper",
"version": "v7.0.6",
@ -4956,6 +5298,57 @@
},
"time": "2024-01-11T14:57:03+00:00"
},
{
"name": "hamcrest/hamcrest-php",
"version": "v2.0.1",
"source": {
"type": "git",
"url": "https://github.com/hamcrest/hamcrest-php.git",
"reference": "8c3d0a3f6af734494ad8f6fbbee0ba92422859f3"
},
"dist": {
"type": "zip",
"url": "https://api.github.com/repos/hamcrest/hamcrest-php/zipball/8c3d0a3f6af734494ad8f6fbbee0ba92422859f3",
"reference": "8c3d0a3f6af734494ad8f6fbbee0ba92422859f3",
"shasum": ""
},
"require": {
"php": "^5.3|^7.0|^8.0"
},
"replace": {
"cordoval/hamcrest-php": "*",
"davedevelopment/hamcrest-php": "*",
"kodova/hamcrest-php": "*"
},
"require-dev": {
"phpunit/php-file-iterator": "^1.4 || ^2.0",
"phpunit/phpunit": "^4.8.36 || ^5.7 || ^6.5 || ^7.0"
},
"type": "library",
"extra": {
"branch-alias": {
"dev-master": "2.1-dev"
}
},
"autoload": {
"classmap": [
"hamcrest"
]
},
"notification-url": "https://packagist.org/downloads/",
"license": [
"BSD-3-Clause"
],
"description": "This is the PHP port of Hamcrest Matchers",
"keywords": [
"test"
],
"support": {
"issues": "https://github.com/hamcrest/hamcrest-php/issues",
"source": "https://github.com/hamcrest/hamcrest-php/tree/v2.0.1"
},
"time": "2020-07-09T08:09:16+00:00"
},
{
"name": "masterminds/html5",
"version": "2.9.0",
@ -5023,6 +5416,89 @@
},
"time": "2024-03-31T07:05:07+00:00"
},
{
"name": "mockery/mockery",
"version": "1.6.11",
"source": {
"type": "git",
"url": "https://github.com/mockery/mockery.git",
"reference": "81a161d0b135df89951abd52296adf97deb0723d"
},
"dist": {
"type": "zip",
"url": "https://api.github.com/repos/mockery/mockery/zipball/81a161d0b135df89951abd52296adf97deb0723d",
"reference": "81a161d0b135df89951abd52296adf97deb0723d",
"shasum": ""
},
"require": {
"hamcrest/hamcrest-php": "^2.0.1",
"lib-pcre": ">=7.0",
"php": ">=7.3"
},
"conflict": {
"phpunit/phpunit": "<8.0"
},
"require-dev": {
"phpunit/phpunit": "^8.5 || ^9.6.17",
"symplify/easy-coding-standard": "^12.1.14"
},
"type": "library",
"autoload": {
"files": [
"library/helpers.php",
"library/Mockery.php"
],
"psr-4": {
"Mockery\\": "library/Mockery"
}
},
"notification-url": "https://packagist.org/downloads/",
"license": [
"BSD-3-Clause"
],
"authors": [
{
"name": "Pádraic Brady",
"email": "padraic.brady@gmail.com",
"homepage": "https://github.com/padraic",
"role": "Author"
},
{
"name": "Dave Marshall",
"email": "dave.marshall@atstsolutions.co.uk",
"homepage": "https://davedevelopment.co.uk",
"role": "Developer"
},
{
"name": "Nathanael Esayeas",
"email": "nathanael.esayeas@protonmail.com",
"homepage": "https://github.com/ghostwriter",
"role": "Lead Developer"
}
],
"description": "Mockery is a simple yet flexible PHP mock object framework",
"homepage": "https://github.com/mockery/mockery",
"keywords": [
"BDD",
"TDD",
"library",
"mock",
"mock objects",
"mockery",
"stub",
"test",
"test double",
"testing"
],
"support": {
"docs": "https://docs.mockery.io/",
"issues": "https://github.com/mockery/mockery/issues",
"rss": "https://github.com/mockery/mockery/releases.atom",
"security": "https://github.com/mockery/mockery/security/advisories",
"source": "https://github.com/mockery/mockery"
},
"time": "2024-03-21T18:34:15+00:00"
},
{
"name": "myclabs/deep-copy",
"version": "1.11.1",
@ -7171,84 +7647,6 @@
],
"time": "2024-02-22T20:27:20+00:00"
},
{
"name": "symfony/translation-contracts",
"version": "v3.4.2",
"source": {
"type": "git",
"url": "https://github.com/symfony/translation-contracts.git",
"reference": "43810bdb2ddb5400e5c5e778e27b210a0ca83b6b"
},
"dist": {
"type": "zip",
"url": "https://api.github.com/repos/symfony/translation-contracts/zipball/43810bdb2ddb5400e5c5e778e27b210a0ca83b6b",
"reference": "43810bdb2ddb5400e5c5e778e27b210a0ca83b6b",
"shasum": ""
},
"require": {
"php": ">=8.1"
},
"type": "library",
"extra": {
"branch-alias": {
"dev-main": "3.4-dev"
},
"thanks": {
"name": "symfony/contracts",
"url": "https://github.com/symfony/contracts"
}
},
"autoload": {
"psr-4": {
"Symfony\\Contracts\\Translation\\": ""
},
"exclude-from-classmap": [
"/Test/"
]
},
"notification-url": "https://packagist.org/downloads/",
"license": [
"MIT"
],
"authors": [
{
"name": "Nicolas Grekas",
"email": "p@tchwork.com"
},
{
"name": "Symfony Community",
"homepage": "https://symfony.com/contributors"
}
],
"description": "Generic abstractions related to translation",
"homepage": "https://symfony.com",
"keywords": [
"abstractions",
"contracts",
"decoupling",
"interfaces",
"interoperability",
"standards"
],
"support": {
"source": "https://github.com/symfony/translation-contracts/tree/v3.4.2"
},
"funding": [
{
"url": "https://symfony.com/sponsor",
"type": "custom"
},
{
"url": "https://github.com/fabpot",
"type": "github"
},
{
"url": "https://tidelift.com/funding/github/packagist/symfony/symfony",
"type": "tidelift"
}
],
"time": "2024-01-23T14:51:35+00:00"
},
{
"name": "theseer/tokenizer",
"version": "1.2.3",

8
config/packages/framework.yaml
View File

@ -9,6 +9,14 @@ framework:
#esi: true
#fragments: true
http_client:
scoped_clients:
crm.client:
base_uri: '%env(APP_CRM_BASE_URL)%'
headers:
Accept: 'application/json'
Content-Type: 'application/json'
when@test:
framework:
test: true

11
config/packages/validator.yaml Normal file
View File

@ -0,0 +1,11 @@
framework:
validation:
# Enables validator auto-mapping support.
# For instance, basic validation constraints will be inferred from Doctrine's metadata.
#auto_mapping:
# App\Entity\: []
when@test:
framework:
validation:
not_compromised_password: false

5
config/services_test.yaml
View File

@ -5,3 +5,8 @@ services:
App\Tests\Behat\:
resource: '../tests/Behat/*'
crm.client:
class: Symfony\Component\HttpClient\MockHttpClient
arguments:
$baseUri: "%env(APP_CRM_BASE_URL)%"

53
features/accept-order.feature Normal file
View File

@ -0,0 +1,53 @@
Feature:
Frontend is able to send requests that will be processed by the application.
Background:
Given there exist following clients:
| clientId | name | initialBalance | currentBalance |
| 018edd2e-894a-78d7-b10c-16e05ca933a3 | Kacper | 10000 | 5000 |
Scenario: Frontend is able to send new orders
Given the request has the following body:
"""
{
"orderId": "018eddae-ff52-7813-9f88-ada9e61a76f3",
"clientId": "018edd2e-894a-78d7-b10c-16e05ca933a3",
"products": [
{ "productId": "p1", "quantity": 2, "price": 20.0, "weight": 100 },
{ "productId": "p2", "quantity": 1, "price": 100.0, "weight": 200 },
{ "productId": "p3", "quantity": 5, "price": 200.0, "weight": 100 },
{ "productId": "p4", "quantity": 1, "price": 50.0, "weight": 400 },
{ "productId": "p5", "quantity": 10, "price": 10.0, "weight": 100 }
]
}
"""
When I send a POST request to "/orders"
Then the response status should be 200
Scenario: Frontend must send properly formatted order request
Given the request has the following body:
"""
{
"orderId": "018eddae-ff52-7813-9f88-ada9e61a76f3"
}
"""
When I send a POST request to "/orders"
Then the response status should be 422
Scenario: Frontend must send valid client reference
Given the request has the following body:
"""
{
"orderId": "018eddae-ff52-7813-9f88-ada9e61a76f3",
"clientId": "00000000-0000-0000-0000-000000000000",
"products": [
{ "productId": "p1", "quantity": 2, "price": 20.0, "weight": 100 },
{ "productId": "p2", "quantity": 1, "price": 100.0, "weight": 200 },
{ "productId": "p3", "quantity": 5, "price": 200.0, "weight": 100 },
{ "productId": "p4", "quantity": 1, "price": 50.0, "weight": 400 },
{ "productId": "p5", "quantity": 10, "price": 10.0, "weight": 100 }
]
}
"""
When I send a POST request to "/orders"
Then the response status should be 422

16
src/Aggregate/AcceptOrderCommand.php Normal file
View File

@ -0,0 +1,16 @@
<?php
namespace App\Aggregate;
use App\Contract\OrderDto;
use App\Entity\Client;
use Symfony\Component\Uid\Uuid;
readonly class AcceptOrderCommand
{
public function __construct(
public OrderDto $order,
public Client $client,
) {
}
}

18
src/Contract/OrderDto.php
View File

@ -9,6 +9,7 @@ class OrderDto
public function __construct(
private Uuid $orderId,
private Uuid $clientId,
/** @var ProductDto[] */
private array $products,
) {
}
@ -35,11 +36,24 @@ class OrderDto
public function getProducts(): array
{
return $this->products;
return array_values($this->products);
}
public function setProducts(array $products): void
{
$this->products = $products;
$this->products = array_combine(
array_map(fn (ProductDto $product) => $product->getProductId(), $products),
array_values($products)
);
}
public function addProduct(ProductDto $product): void
{
$this->products[$product->getProductId()] = $product;
}
public function removeProduct(ProductDto $product): void
{
$this->products = array_filter($this->products, fn (ProductDto $other) => $other->getProductId() != $product->getProductId());
}
}

45
src/Controller/OrderController.php Normal file
View File

@ -0,0 +1,45 @@
<?php
declare(strict_types=1);
namespace App\Controller;
use App\Aggregate\AcceptOrderCommand;
use App\Contract\OrderDto;
use App\Exception\ClientNotExistsException;
use App\Service\ClientService;
use App\Service\OrderService;
use Symfony\Component\HttpFoundation\Response;
use Symfony\Component\HttpKernel\Attribute\AsController;
use Symfony\Component\HttpKernel\Attribute\MapRequestPayload;
use Symfony\Component\Routing\Attribute\Route;
#[AsController]
#[Route(path: '/orders', name: 'orders_')]
readonly class OrderController
{
public function __construct(
private ClientService $clientService,
private OrderService $orderService,
) {
}
#[Route(name: 'accept', methods: ['POST'])]
public function accept(#[MapRequestPayload] OrderDto $orderDto): Response
{
try {
$command = new AcceptOrderCommand(
order: $orderDto,
client: $this->clientService->getClient($orderDto->getClientId()),
);
$this->orderService->acceptOrder($command);
return new Response();
} catch (ClientNotExistsException) {
return new Response(status: Response::HTTP_UNPROCESSABLE_ENTITY);
}
}
}

7
src/Exception/ClientNotExistsException.php Normal file
View File

@ -0,0 +1,7 @@
<?php
namespace App\Exception;
class ClientNotExistsException extends \LogicException
{
}

18
src/Service/ClientService.php
View File

@ -4,7 +4,9 @@ namespace App\Service;
use App\Entity\Client;
use App\Exception\ClientAlreadyExistsException;
use App\Exception\ClientNotExistsException;
use App\Repository\ClientRepository;
use Symfony\Component\Uid\Uuid;
class ClientService
{
@ -13,6 +15,22 @@ class ClientService
) {
}
/**
* @throws \App\Exception\ClientNotExistsException
*/
public function getClient(Uuid $clientId): Client
{
$client = $this->clientRepository->find($clientId);
if (!$client) {
throw new ClientNotExistsException(
message: sprintf('Client with id "%s" does not exist.', $clientId->toRfc4122())
);
}
return $client;
}
public function createNewClient(Client $client): Client
{
$existing = $this->clientRepository->find($client->getClientId());

23
src/Service/OrderService.php Normal file
View File

@ -0,0 +1,23 @@
<?php
namespace App\Service;
use App\Aggregate\AcceptOrderCommand;
use Symfony\Component\Serializer\SerializerInterface;
use Symfony\Contracts\HttpClient\HttpClientInterface;
class OrderService
{
public function __construct(
private readonly HttpClientInterface $crmClient,
private readonly SerializerInterface $serializer,
) {
}
public function acceptOrder(AcceptOrderCommand $command)
{
$this->crmClient->request('POST', '/order', [
'body' => $this->serializer->serialize($command->order, format: 'json')
]);
}
}

12
symfony.lock
View File

@ -159,5 +159,17 @@
"version": "7.0",
"ref": "0df5844274d871b37fc3816c57a768ffc60a43a5"
}
},
"symfony/validator": {
"version": "7.0",
"recipe": {
"repo": "github.com/symfony/recipes",
"branch": "main",
"version": "7.0",
"ref": "8c1c4e28d26a124b0bb273f537ca8ce443472bfd"
},
"files": [
"config/packages/validator.yaml"
]
}
}

61
tests/App/Service/OrderServiceTest.php Normal file
View File

@ -0,0 +1,61 @@
<?php
namespace App\Service;
use App\Aggregate\AcceptOrderCommand;
use App\Contract\OrderDto;
use App\Contract\ProductDto;
use App\Entity\Client;
use PHPUnit\Framework\TestCase;
use Symfony\Component\Serializer\SerializerInterface;
use Symfony\Component\Uid\Uuid;
use Symfony\Contracts\HttpClient\HttpClientInterface;
class OrderServiceTest extends TestCase
{
private const ORDER_ID = '018eddae-ff52-7813-9f88-ada9e61a76f3';
private const CLIENT_ID = '018edd2e-894a-78d7-b10c-16e05ca933a3';
private function createValidOrderDto(): OrderDto
{
return new OrderDto(
orderId: Uuid::fromRfc4122(self::ORDER_ID),
clientId: Uuid::fromRfc4122(self::CLIENT_ID),
products: [
new ProductDto('p1', 1, 100, 100),
new ProductDto('p2', 2, 300, 100),
new ProductDto('p3', 3, 200, 100),
new ProductDto('p4', 4, 400, 700),
new ProductDto('p5', 5, 800, 700),
]
);
}
public function testCrmGetsCalledOnValidOrderRequest()
{
$httpClientMock = $this->getMockBuilder(HttpClientInterface::class)->getMock();
$serializerMock = $this->getMockBuilder(SerializerInterface::class)->getMock();
$sut = new OrderService($httpClientMock, $serializerMock);
$httpClientMock->expects($this->once())->method('request')->with('POST', '/order');
$order = new AcceptOrderCommand(
$this->createValidOrderDto(),
$this->createClient(balance: 10000)
);
$sut->acceptOrder($order);
}
private function createClient(int $balance): Client
{
return new Client(
clientId: Uuid::fromRfc4122(self::CLIENT_ID),
name: 'Stub',
initialBalance: $balance,
currentBalance: $balance
);
}
}

20
tests/Behat/CrmContext.php Normal file
View File

@ -0,0 +1,20 @@
<?php
namespace Behat;
use App\Entity\Client;
use App\Repository\ClientRepository;
use Behat\Behat\Context\Context;
use Behat\Behat\Tester\Exception\PendingException;
use Behat\Gherkin\Node\TableNode;
use Doctrine\ORM\EntityManagerInterface;
use PHPUnit\Framework\Assert;
use Symfony\Component\HttpClient\MockHttpClient;
use Symfony\Component\Uid\Uuid;
class CrmContext implements Context
{
public function __construct(
protected readonly MockHttpClient $crmClient,
) {}
}