src/ApplicationBundle/Modules/Api/Controller/ActivityLogController.php line 25

Open in your IDE?
  1. <?php
  3. namespace ApplicationBundle\Modules\Api\Controller;
  5. use ApplicationBundle\Modules\Authentication\Constants\UserConstants;
  6. use ApplicationBundle\Controller\GenericController;
  7. use ApplicationBundle\Interfaces\SessionCheckInterface;
  8. use ApplicationBundle\Modules\Api\Service\ActivityLogService;
  9. use InvalidArgumentException;
  10. use Symfony\Component\HttpFoundation\JsonResponse;
  11. use Symfony\Component\HttpFoundation\Request;
  13. /**
  14.  * CC7e-#5 (2026-07-15) — SECURITY: gated. Declared no gate, and auth is OPT-IN, so
  15.  * `POST /api/activity/log` reached the business logic unauthenticated (dev: 400 validation error —
  16.  * a validation error is the controller answering, not a caller being refused).
  17.  *
  18.  * Gating matches this class's OWN stated intent: its comment says it routes the write to "the
  19.  * LOGGED-IN TENANT's DB" and calls switchToSessionTenantDb(). It assumed a session it never
  20.  * enforced — so without one there was no tenant to switch to, and an anonymous write landed
  21.  * wherever the default connection pointed. The assumption is now the contract.
  22.  */
  23. class ActivityLogController extends GenericController implements SessionCheckInterface
  24. {
  25.     public function logAction(Request $request): JsonResponse
  26.     {
  27.         $payload = $this->extractPayload($request);
  29.         // Route the write to the LOGGED-IN TENANT's DB. SessionListener switches the
  30.         // default connection with reset=false, which only rewrites the params and does
  31.         // NOT move an already-open connection — so an /api write can land in the box
  32.         // DEFAULT database (every tenant's activity funneled there, its own Activity
  33.         // Dashboard read empty). Force a reconnect (reset=true) to the session tenant.
  34.         $this->switchToSessionTenantDb($request);
  36.         $service = new ActivityLogService($this->getDoctrine()->getManager());
  38.         try {
  39.             $activityLog = $service->log($payload);
  40.         } catch (InvalidArgumentException $exception) {
  41.             return new JsonResponse([
  42.                 'success' => false,
  43.                 'code' => 'HB_VALIDATION_ERROR',
  44.                 'message' => 'Validation failed',
  45.                 'errors' => [$exception->getMessage()],
  46.             ], 400);
  47.         } catch (\Throwable $exception) {
  48.             return new JsonResponse([
  49.                 'success' => false,
  50.                 'code' => 'HB_INTERNAL_ERROR',
  51.                 'message' => 'Activity log could not be saved',
  52.             ], 500);
  53.         }
  55.         return new JsonResponse([
  56.             'success' => true,
  57.             'code' => 'HB_OK',
  58.             'message' => 'Activity logged successfully',
  59.             'data' => [
  60.                 'id' => $activityLog->getId(),
  61.                 'user_id' => $activityLog->getUserId(),
  62.                 'session_id' => $activityLog->getSessionId(),
  63.                 'route' => $activityLog->getRoute(),
  64.                 'action_type' => $activityLog->getActionType(),
  65.                 'duration_seconds' => $activityLog->getDurationSeconds(),
  66.                 'created_at' => $activityLog->getCreatedAt() ? $activityLog->getCreatedAt()->format('Y-m-d H:i:s') : null,
  67.             ],
  68.         ], 201);
  69.     }
  71.     /**
  72.      * Force-reconnect the default EM to the session tenant's DB (reset=true) so the
  73.      * activity row is written to the right tenant, not the box default. Best-effort:
  74.      * any failure leaves the existing connection and never breaks logging.
  75.      */
  76.     private function switchToSessionTenantDb(Request $request): void
  77.     {
  78.         try {
  79.             $appId = (int) $request->getSession()->get(UserConstants::USER_APP_ID);
  80.             if ($appId <= 0) {
  81.                 return;
  82.             }
  83.             $emGoc = $this->getDoctrine()->getManager('company_group');
  84.             $goc = $emGoc->getRepository('CompanyGroupBundle\\Entity\\CompanyGroup')
  85.                 ->findOneBy(['appId' => $appId]);
  86.             if (!$goc || !$goc->getDbName()) {
  87.                 return;
  88.             }
  89.             $this->container->get('application_connector')->resetConnection(
  90.                 'default',
  91.                 $goc->getDbName(),
  92.                 $goc->getDbUser(),
  93.                 $goc->getDbPass(),
  94.                 $goc->getDbHost(),
  95.                 true
  96.             );
  97.         } catch (\Throwable $e) {
  98.             // never break activity logging on the tenant-switch path
  99.         }
  100.     }
  102.     private function extractPayload(Request $request): array
  103.     {
  104.         $contentType = strtolower((string) $request->headers->get('Content-Type', ''));
  105.         $rawContent = trim((string) $request->getContent());
  107.         if ($rawContent !== '' && strpos($contentType, 'application/json') !== false) {
  108.             $decoded = json_decode($rawContent, true);
  110.             return is_array($decoded) ? $decoded : [];
  111.         }
  113.         return $request->request->all();
  114.     }
  115. }