Add AIApi for AI recommendations service, implement ApiGatewayController::getRecommendedProducts for fetching recommended products, update routes and environment variables for AI service integration, and enhance docker-compose.yml configuration.

Author: OmmrGAZAR315

app/External_Apis/Apis/AIApi.php

@@ -0,0 +1,19 @@
+<?php
+
+namespace App\External_Apis\Apis;
+
+class AIApi extends BasicApi
+{
+
+    private const string CONFIG_KEY = 'ai_url';
+
+    public static function getAIApi(): string
+    {
+        return self::getBaseUrl() . 'api/recommendations';
+    }
+
+    protected static function getConfigKey(): string
+    {
+        return self::CONFIG_KEY;
+    }
+}

app/External_Apis/Apis/BasicApi.php

@@ -14,7 +14,6 @@ abstract protected static function getConfigKey(): string;
 
     public static function getBaseUrl(): string
     {
-//        USER_SERVICE_URL=http://user-webserver/
         return config('services.microservices.' . static::getConfigKey());
     }
 

app/Http/Controllers/ApiGatewayController.php

@@ -0,0 +1,58 @@
+<?php
+
+namespace App\Http\Controllers;
+
+use App\External_Apis\Apis\AIApi;
+use App\External_Apis\Services\ProductService;
+use App\Grpc\Services\GrpcService;
+use Illuminate\Http\Client\ConnectionException;
+use Illuminate\Http\Request;
+use Illuminate\Support\Facades\Http;
+use Symfony\Component\HttpFoundation\Response;
+
+class ApiGatewayController extends BaseController
+{
+    public function __construct(
+        private readonly ProductService $productService,
+        private readonly GrpcService    $grpcService
+    )
+    {
+    }
+    //
+
+    /**
+     * @throws ConnectionException
+     */
+    public function getRecommendedProducts(Request $request)
+    {
+        try {
+            $res = Http::withToken($request->bearerToken())->get(AIApi::getAIApi());
+            if ($res->failed())
+                throw new ConnectionException('Failed to connect to AI API', $res->status());
+            $recommendedProductData = $res->json('data', []);
+            $request->merge($this->productService->injectUserId());
+            $request->merge(['recommended_product_ids' => data_get($recommendedProductData, 'id')]);
+            $res = $this->grpcService->proxyRequest(
+                $request,
+                'product',
+                'listProducts',
+            );
+            if ($res->getStatusCode() == Response::HTTP_OK) {
+                $filteredProductData = ($res->getData(true));
+                $filteredProductData = array_map(function ($productData) {
+                    $productData['percentage'] = $recommendedProductData['compatibility_score'] ?? 0;
+                    return $productData;
+                }, data_get($filteredProductData, 'data', []));
+
+                return $res->setData($filteredProductData);
+                return $res;
+            } else
+                throw new ConnectionException('Failed to fetch products', $res->getStatusCode());
+        } catch (ConnectionException $e) {
+            return response()->json([
+                'message' => 'Connection error',
+                'error' => $e->getMessage()
+            ], 500);
+        }
+    }
+}

config/services.php

@@ -39,5 +39,6 @@
         'user_url' => env('USER_SERVICE_URL', 'http://user-webserver/'),
         'product_url' => env('PRODUCT_SERVICE_URL', 'http://product-webserver/'),
         'order_url' => env('ORDER_SERVICE_URL', 'http://order-webserver/'),
+        'ai_url' => env('AI_SERVICE_URL', 'http://ai-service/'),
     ]
 ];

docker-compose.yml

@@ -2,7 +2,7 @@ services:
     api-gw:
         build:
             context: .
-        image: ommrgazar315/api-gw:2.0
+        image: ommrgazar315/api-gw:2.0_grpc
         container_name: api-gw
         restart: unless-stopped
         working_dir: /var/www
@@ -31,6 +31,10 @@ services:
             - DB_DATABASE=api-gw_db
             - DB_USERNAME=laravel
             - DB_PASSWORD=api-gw_pass
+            - PRODUCT_SERVICE_URL=http://product-webserver/
+            - USER_SERVICE_URL=http://user-webserver/
+            - ORDER_SERVICE_URL=http://order-webserver/
+            - AI_SERVICE_URL=http://ai-webserver/
 
     api-gw_db:
         image: mysql:8.0

routes/api.php

@@ -1,5 +1,6 @@
 <?php
 
+use App\Http\Controllers\ApiGatewayController;
 use App\Http\Controllers\AuthApiController;
 use App\Http\Controllers\GoogleApiController;
 use App\Http\Controllers\OfferApiController;
@@ -68,3 +69,6 @@
 
 Route::post('products/batch', [ProductApiController::class, 'batch']);
 Route::post('/offers/batch', [OfferApiController::class, 'batch']);
+
+// AI Service
+Route::post('/recommendations', [ApiGatewayController::class, 'getRecommendedProducts'])->middleware('authenticate');