From e223ddfb4f13589b5b332653050df7cf5d5d4647 Mon Sep 17 00:00:00 2001 From: Kacper Donat Date: Sun, 14 Apr 2024 20:17:21 +0200 Subject: [PATCH] TASK-35: Send orders to CRM --- .env | 2 + behat.yml.dist | 1 + composer.json | 3 + composer.lock | 556 ++++++++++++++++++--- config/packages/framework.yaml | 8 + config/packages/validator.yaml | 11 + config/services_test.yaml | 5 + features/accept-order.feature | 53 ++ src/Aggregate/AcceptOrderCommand.php | 16 + src/Contract/OrderDto.php | 18 +- src/Controller/OrderController.php | 45 ++ src/Exception/ClientNotExistsException.php | 7 + src/Service/ClientService.php | 18 + src/Service/OrderService.php | 23 + symfony.lock | 12 + tests/App/Service/OrderServiceTest.php | 61 +++ tests/Behat/CrmContext.php | 20 + 17 files changed, 778 insertions(+), 81 deletions(-) create mode 100644 config/packages/validator.yaml create mode 100644 features/accept-order.feature create mode 100644 src/Aggregate/AcceptOrderCommand.php create mode 100644 src/Controller/OrderController.php create mode 100644 src/Exception/ClientNotExistsException.php create mode 100644 src/Service/OrderService.php create mode 100644 tests/App/Service/OrderServiceTest.php create mode 100644 tests/Behat/CrmContext.php diff --git a/.env b/.env index 8274b7f..e7370cf 100644 --- a/.env +++ b/.env @@ -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" diff --git a/behat.yml.dist b/behat.yml.dist index a8e916d..6d6d3f3 100644 --- a/behat.yml.dist +++ b/behat.yml.dist @@ -3,6 +3,7 @@ default: default: contexts: - App\Tests\Behat\ApiCallContext + - App\Tests\Behat\ClientsContext extensions: FriendsOfBehat\SymfonyExtension: diff --git a/composer.json b/composer.json index f0ed1b9..b74397b 100644 --- a/composer.json +++ b/composer.json @@ -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.*", diff --git a/composer.lock b/composer.lock index 08010a7..2c9e050 100644 --- a/composer.lock +++ b/composer.lock @@ -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", diff --git a/config/packages/framework.yaml b/config/packages/framework.yaml index 877eb25..c605ab1 100644 --- a/config/packages/framework.yaml +++ b/config/packages/framework.yaml @@ -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 diff --git a/config/packages/validator.yaml b/config/packages/validator.yaml new file mode 100644 index 0000000..dd47a6a --- /dev/null +++ b/config/packages/validator.yaml @@ -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 diff --git a/config/services_test.yaml b/config/services_test.yaml index d0d92b3..540e252 100644 --- a/config/services_test.yaml +++ b/config/services_test.yaml @@ -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)%" diff --git a/features/accept-order.feature b/features/accept-order.feature new file mode 100644 index 0000000..f87d895 --- /dev/null +++ b/features/accept-order.feature @@ -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 diff --git a/src/Aggregate/AcceptOrderCommand.php b/src/Aggregate/AcceptOrderCommand.php new file mode 100644 index 0000000..6fea95c --- /dev/null +++ b/src/Aggregate/AcceptOrderCommand.php @@ -0,0 +1,16 @@ +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()); } } diff --git a/src/Controller/OrderController.php b/src/Controller/OrderController.php new file mode 100644 index 0000000..d134c99 --- /dev/null +++ b/src/Controller/OrderController.php @@ -0,0 +1,45 @@ +clientService->getClient($orderDto->getClientId()), + ); + + $this->orderService->acceptOrder($command); + + return new Response(); + } catch (ClientNotExistsException) { + return new Response(status: Response::HTTP_UNPROCESSABLE_ENTITY); + } + } + +} diff --git a/src/Exception/ClientNotExistsException.php b/src/Exception/ClientNotExistsException.php new file mode 100644 index 0000000..c93d329 --- /dev/null +++ b/src/Exception/ClientNotExistsException.php @@ -0,0 +1,7 @@ +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()); diff --git a/src/Service/OrderService.php b/src/Service/OrderService.php new file mode 100644 index 0000000..820de8a --- /dev/null +++ b/src/Service/OrderService.php @@ -0,0 +1,23 @@ +crmClient->request('POST', '/order', [ + 'body' => $this->serializer->serialize($command->order, format: 'json') + ]); + } +} diff --git a/symfony.lock b/symfony.lock index a836845..e9aea8c 100644 --- a/symfony.lock +++ b/symfony.lock @@ -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" + ] } } diff --git a/tests/App/Service/OrderServiceTest.php b/tests/App/Service/OrderServiceTest.php new file mode 100644 index 0000000..6a1e771 --- /dev/null +++ b/tests/App/Service/OrderServiceTest.php @@ -0,0 +1,61 @@ +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 + ); + } + +} diff --git a/tests/Behat/CrmContext.php b/tests/Behat/CrmContext.php new file mode 100644 index 0000000..ee147ff --- /dev/null +++ b/tests/Behat/CrmContext.php @@ -0,0 +1,20 @@ +