zinan / php-microservices

microservices/application/user_management/tests/BaseTestCase.php

Spacing +4 added lines, -4 removed lines

@@ -48,11 +48,11 @@
             $request = $request->withParsedBody($requestData);
         }
         $response = new Response();
-        $settings = require __DIR__ . '/../src/settings.php';
+        $settings = require __DIR__.'/../src/settings.php';
         $app = new App($settings);
-        require __DIR__ . '/../src/dependencies.php';
-        require __DIR__ . '/../src/middleware.php';
-        require __DIR__ . '/../src/routes.php';
+        require __DIR__.'/../src/dependencies.php';
+        require __DIR__.'/../src/middleware.php';
+        require __DIR__.'/../src/routes.php';
         $response = $app->process($request, $response);
         return $response;
     }

microservices/application/user_management/public/index.php

Spacing +6 added lines, -6 removed lines

@@ -13,15 +13,15 @@
  */
 
 ini_set('date.timezone', 'Europe/Istanbul');
-require __DIR__ . '/../vendor/autoload.php';
+require __DIR__.'/../vendor/autoload.php';
 session_start();
-$settings = require __DIR__ . '/../src/settings.php';
+$settings = require __DIR__.'/../src/settings.php';
 $app = new \Slim\App($settings);
-require __DIR__ . '/../src/dependencies.php';
-require __DIR__ . '/../src/middleware.php';
-require __DIR__ . '/../src/routes.php';
+require __DIR__.'/../src/dependencies.php';
+require __DIR__.'/../src/middleware.php';
+require __DIR__.'/../src/routes.php';
 
-Sentry\init(['dsn' => 'https://8c9d7d4e841c421482d60533dc100833@sentry.io/1491710' ]);
+Sentry\init(['dsn' => 'https://8c9d7d4e841c421482d60533dc100833@sentry.io/1491710']);
 
 $app->run();
 

microservices/application/comment_management/src/Application.php

Spacing +9 added lines, -9 removed lines

@@ -37,8 +37,8 @@ 
     public function __construct()
     {
         defined('DS') ?: define('DS', DIRECTORY_SEPARATOR);
-        defined('ENVROOT') ?: define('ENVROOT', dirname(__DIR__) . DS);
-        if (file_exists(ENVROOT . '.env')) {
+        defined('ENVROOT') ?: define('ENVROOT', dirname(__DIR__).DS);
+        if (file_exists(ENVROOT.'.env')) {
             $dotenv = new Dotenv(ENVROOT);
             try {
                 $dotenv->load();
@@ -71,7 +71,7 @@ 
         }
 
         if ($_SERVER['REQUEST_URI'] == '/comment/list') {
-            $post = json_decode(file_get_contents('php://input'),true);
+            $post = json_decode(file_get_contents('php://input'), true);
             $product_id = $post['product_id'];
             $comments = $this->db->prepare('SELECT * FROM comments where product_id=:product_id');
             $comments->execute(['product_id'=>$product_id]);
@@ -82,13 +82,13 @@ 
         if ($_SERVER['REQUEST_URI'] == '/comment/add') {
 
             $token = $this->getToken();
-            if(!$token) {
+            if (!$token) {
                 die(json_encode(['error'=>'authentication error!']));
             }
 
             $client = new Client();
             $headers = [
-                'Authorization' => 'Bearer ' . $token,
+                'Authorization' => 'Bearer '.$token,
                 'Accept'        => 'application/json',
             ];
             $res = $client->request('GET', 'http://user_management_nginx_1/user/checkToken',
@@ -98,16 +98,16 @@ 
                 ]
             );
             $httpCode = $res->getStatusCode();
-            if($httpCode!=200)
+            if ($httpCode != 200)
             {
                 die(json_encode(['error'=>'authentication error!']));
             }
 
-            $response = json_decode($res->getBody(),1);
+            $response = json_decode($res->getBody(), 1);
 
 
 
-            $post = json_decode(file_get_contents('php://input'),true);
+            $post = json_decode(file_get_contents('php://input'), true);
 
             $data = [
                 'product_id' => $post['product_id'],
@@ -118,7 +118,7 @@ 
             ];
             $sql = "INSERT INTO comments (product_id, comment, user_id, user_name, comment_date) VALUES 
                     (:product_id, :comment, :user_id, :user_name, :comment_date)";
-            $stmt= $this->db->prepare($sql);
+            $stmt = $this->db->prepare($sql);
             $stmt->execute($data);
 
             die(json_encode(['id'=>$this->db->lastInsertId()], JSON_UNESCAPED_UNICODE));

microservices/application/comment_management/public/index.php

Spacing +1 added lines, -1 removed lines

@@ -16,7 +16,7 @@
 require_once __DIR__.'/../vendor/autoload.php';
 
 
-Sentry\init(['dsn' => 'https://8c9d7d4e841c421482d60533dc100833@sentry.io/1491710' ]);
+Sentry\init(['dsn' => 'https://8c9d7d4e841c421482d60533dc100833@sentry.io/1491710']);
 
 $app = new CommentManagement\Application();
 $app->run();

microservices/application/order_management/src/RabbitMQ/Publisher.php

Spacing +1 added lines, -1 removed lines

@@ -32,7 +32,7 @@
             $this->queue->isAutoDelete()
         );
 
-        $message = new AMQPMessage(json_encode(['product_id'=>1,'product_name'=>'deneme'], JSON_UNESCAPED_SLASHES), array('delivery_mode' => 2));
+        $message = new AMQPMessage(json_encode(['product_id'=>1, 'product_name'=>'deneme'], JSON_UNESCAPED_SLASHES), array('delivery_mode' => 2));
         $channel->basic_publish($message, '', $this->queue->getName());
 
 //        $channel->queue_declare(

microservices/application/order_management/src/Application.php

Spacing +2 added lines, -2 removed lines

@@ -31,8 +31,8 @@
     public function __construct()
     {
         defined('DS') ?: define('DS', DIRECTORY_SEPARATOR);
-        defined('ENVROOT') ?: define('ENVROOT', dirname(__DIR__) . DS);
-        if (file_exists(ENVROOT . '.env')) {
+        defined('ENVROOT') ?: define('ENVROOT', dirname(__DIR__).DS);
+        if (file_exists(ENVROOT.'.env')) {
             $dotenv = new Dotenv(ENVROOT);
             try {
                 $dotenv->load();

microservices/application/order_management/src/Worker/OrderQueue/OrderQueueController.php

Spacing +2 added lines, -2 removed lines

@@ -31,11 +31,11 @@
     {
         $consumer = new Consumer(new OrderQueue());
 
-        $consumer->addCallback(function (AMQPMessage $message) {
+        $consumer->addCallback(function(AMQPMessage $message) {
             //echo (':::'.$message);
         });
 
-        $consumer->work(function (string $output) {
+        $consumer->work(function(string $output) {
             //echo $output."\n";
         });
     }

microservices/application/order_management/public/index.php

Spacing +1 added lines, -1 removed lines

@@ -16,7 +16,7 @@
 
 require_once __DIR__.'/../vendor/autoload.php';
 
-Sentry\init(['dsn' => 'https://8c9d7d4e841c421482d60533dc100833@sentry.io/1491710' ]);
+Sentry\init(['dsn' => 'https://8c9d7d4e841c421482d60533dc100833@sentry.io/1491710']);
 
 $app = new OrderManagement\Application();
 

microservices/application/category_management/src/Application.php

Spacing +9 added lines, -9 removed lines

@@ -36,8 +36,8 @@ 
     public function __construct()
     {
         defined('DS') ?: define('DS', DIRECTORY_SEPARATOR);
-        defined('ENVROOT') ?: define('ENVROOT', dirname(__DIR__) . DS);
-        if (file_exists(ENVROOT . '.env')) {
+        defined('ENVROOT') ?: define('ENVROOT', dirname(__DIR__).DS);
+        if (file_exists(ENVROOT.'.env')) {
             $dotenv = new Dotenv(ENVROOT);
             try {
                 $dotenv->load();
@@ -79,13 +79,13 @@ 
         if ($_SERVER['REQUEST_URI'] == '/category/add') {
 
             $token = $this->getToken();
-            if(!$token) {
+            if (!$token) {
                 die(json_encode(['error'=>'authentication error!']));
             }
 
             $client = new Client();
             $headers = [
-                'Authorization' => 'Bearer ' . $token,
+                'Authorization' => 'Bearer '.$token,
                 'Accept'        => 'application/json',
             ];
             $res = $client->request('GET', 'http://user_management_nginx_1/user/checkToken',
@@ -95,26 +95,26 @@ 
                 ]
             );
             $httpCode = $res->getStatusCode();
-            if($httpCode!=200)
+            if ($httpCode != 200)
             {
                 die(json_encode(['error'=>'authentication error!']));
             }
 
 
-            $response = json_decode($res->getBody(),1);
+            $response = json_decode($res->getBody(), 1);
             $isAdmin = $response['user']['is_admin'];
 
-            if(!$isAdmin) {
+            if (!$isAdmin) {
                 die(json_encode(['error'=>'admin only!']));
             }
 
-            $post = json_decode(file_get_contents('php://input'),true);
+            $post = json_decode(file_get_contents('php://input'), true);
 
             $data = [
                 'category_name' => $post['category_name']
             ];
             $sql = "INSERT INTO categories (category_name) VALUES (:category_name)";
-            $stmt= $this->db->prepare($sql);
+            $stmt = $this->db->prepare($sql);
             $stmt->execute($data);
 
             die(json_encode(['id'=>$this->db->lastInsertId()]));