[36] - Implementar endpoint Follow streamer (#44)

* [36] - Arreglar conflictos

* [36] - Arreglar conflictos DBClient

* [0] - Refactorizar servicios con streamers

* [36] - Arreglar conflictos migraciones usuario

* [36] - Crear excepciones forbidden y unauthorized

* [36] - Implementado error get token

* [36] - Devolver mensajes excepcionesd desde controller

* [36] - Añadir follow a routes

* [36] - Modificar streamerId a string en usuario_streamers

* [36] - Añadir excepcion para manejar error not found

* [36] - Manejar errores desde controlador

* [36] - Eliminar metodo innecesario post en ApiClient

* [36] - Refactorizar DBClient

* [36] - Refactorizar follow streamer manager

* [36] - Implementar request con username y streamerId

* [36] - Implementar metodos database y devolver errores en excepciones

* [36] - Manejar mensajes excepciones desde fuera del controller

* [36] - Refactorizar FollowStreamerManager

* [36] - Implementar tests de integracion

* [36] - Implementar tests unitarios

* [36] - Eliminar endpoint desactualizado de /users en /follow

---------

Co-authored-by: Santi Ayechu <santiayechu@gmail.com>

app/Exceptions/ForbiddenException.php

@@ -0,0 +1,11 @@
+<?php
+
+namespace App\Exceptions;
+
+use Exception;
+
+class ForbiddenException extends Exception
+{
+
+}
+

app/Exceptions/NotFoundException.php

@@ -0,0 +1,11 @@
+<?php
+
+namespace App\Exceptions;
+
+use Exception;
+
+class NotFoundException extends Exception
+{
+
+}
+

app/Exceptions/UnauthorizedException.php

@@ -0,0 +1,11 @@
+<?php
+
+namespace App\Exceptions;
+
+use Exception;
+
+class UnauthorizedException extends Exception
+{
+
+}
+

app/Infrastructure/FollowStreamer/AnalyticsFollowStreamerController.php

@@ -6,6 +6,12 @@
 use App\Infrastructure\Controllers\Controller;
 use Illuminate\Http\JsonResponse;
 use Illuminate\Http\Request;
+use App\Exceptions\ConflictException;
+use App\Exceptions\ForbiddenException;
+use App\Exceptions\InternalServerErrorException;
+use App\Exceptions\NotFoundException;
+use App\Exceptions\UnauthorizedException;
+use Illuminate\Http\Response;
 
 class AnalyticsFollowStreamerController extends Controller
 {
@@ -15,12 +21,25 @@ public function __construct(FollowStreamerManager $followManager)
     {
         $this->followManager = $followManager;
     }
-    public function __invoke(Request $request): JsonResponse
+
+    public function __invoke(AnalyticsFollowStreamerRequest $request): JsonResponse
     {
-        $userId = $request->input('userId');
+        $username = $request->input('username');
         $streamerId = $request->input('streamerId');
 
-        $followMessage = $this->followManager->getFollowMessage($userId, $streamerId);
-        return response()->json($followMessage);
+        try {
+            $followMessage = $this->followManager->getFollowMessage($username, $streamerId);
+            return response()->json($followMessage, Response::HTTP_OK);
+        } catch (ConflictException $e) {
+            return response()->json(['error' => $e->getMessage()], Response::HTTP_CONFLICT);
+        } catch (ForbiddenException $e) {
+            return response()->json(['error' => $e->getMessage()], Response::HTTP_FORBIDDEN);
+        } catch (NotFoundException $e) {
+            return response()->json(['error' => $e->getMessage()], Response::HTTP_NOT_FOUND);
+        } catch (UnauthorizedException $e) {
+            return response()->json(['error' => $e->getMessage()], Response::HTTP_UNAUTHORIZED);
+        } catch (InternalServerErrorException $e) {
+            return response()->json(['error' => $e->getMessage()], Response::HTTP_INTERNAL_SERVER_ERROR);
+        }
     }
 }

app/Infrastructure/FollowStreamer/AnalyticsFollowStreamerRequest.php

@@ -0,0 +1,31 @@
+<?php
+
+namespace App\Infrastructure\FollowStreamer;
+
+use Illuminate\Foundation\Http\FormRequest;
+
+class AnalyticsFollowStreamerRequest extends FormRequest
+{
+    public function authorize(): bool
+    {
+        return true;
+    }
+
+    public function rules(): array
+    {
+        return [
+            'username' => 'required|string',
+            'streamerId' => 'required|numeric',
+        ];
+    }
+
+    public function messages()
+    {
+        return [
+            'username.required' => 'El username es obligatorio',
+            'username.string' => 'El username debe ser una cadena de texto',
+            'streamerId.required' => 'El streamerId es obligatorio',
+            'streamerId.numeric' => 'El streamerId debe ser un número',
+        ];
+    }
+}

app/Services/ApiClient.php

@@ -58,26 +58,4 @@ public function makeCurlCall(string $apiUrl, array $apiHeaders): array
             'http_code' => $httpCode
         ];
     }
-
-    public function post(string $apiUrl, array $apiHeaders, $postData): array
-    {
-        $curl = curl_init();
-        curl_setopt_array($curl, [
-            CURLOPT_URL => $apiUrl,
-            CURLOPT_POST => true,
-            CURLOPT_POSTFIELDS => $postData,
-            CURLOPT_RETURNTRANSFER => true,
-            CURLOPT_HTTPHEADER => $apiHeaders
-        ]);
-
-        $apiResponse = curl_exec($curl);
-        $httpCode = curl_getinfo($curl, CURLINFO_HTTP_CODE);
-
-        curl_close($curl);
-
-        return [
-            'response' => $apiResponse,
-            'http_code' => $httpCode
-        ];
-    }
 }