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\Modules\Api\Service\ActivityLogService;
  8. use InvalidArgumentException;
  9. use Symfony\Component\HttpFoundation\JsonResponse;
  10. use Symfony\Component\HttpFoundation\Request;
  12. class ActivityLogController extends GenericController
  13. {
  14.     public function logAction(Request $request): JsonResponse
  15.     {
  16.         $payload = $this->extractPayload($request);
  18.         // Route the write to the LOGGED-IN TENANT's DB. SessionListener switches the
  19.         // default connection with reset=false, which only rewrites the params and does
  20.         // NOT move an already-open connection — so an /api write can land in the box
  21.         // DEFAULT database (every tenant's activity funneled there, its own Activity
  22.         // Dashboard read empty). Force a reconnect (reset=true) to the session tenant.
  23.         $this->switchToSessionTenantDb($request);
  25.         $service = new ActivityLogService($this->getDoctrine()->getManager());
  27.         try {
  28.             $activityLog = $service->log($payload);
  29.         } catch (InvalidArgumentException $exception) {
  30.             return new JsonResponse([
  31.                 'success' => false,
  32.                 'code' => 'HB_VALIDATION_ERROR',
  33.                 'message' => 'Validation failed',
  34.                 'errors' => [$exception->getMessage()],
  35.             ], 400);
  36.         } catch (\Throwable $exception) {
  37.             return new JsonResponse([
  38.                 'success' => false,
  39.                 'code' => 'HB_INTERNAL_ERROR',
  40.                 'message' => 'Activity log could not be saved',
  41.             ], 500);
  42.         }
  44.         return new JsonResponse([
  45.             'success' => true,
  46.             'code' => 'HB_OK',
  47.             'message' => 'Activity logged successfully',
  48.             'data' => [
  49.                 'id' => $activityLog->getId(),
  50.                 'user_id' => $activityLog->getUserId(),
  51.                 'session_id' => $activityLog->getSessionId(),
  52.                 'route' => $activityLog->getRoute(),
  53.                 'action_type' => $activityLog->getActionType(),
  54.                 'duration_seconds' => $activityLog->getDurationSeconds(),
  55.                 'created_at' => $activityLog->getCreatedAt() ? $activityLog->getCreatedAt()->format('Y-m-d H:i:s') : null,
  56.             ],
  57.         ], 201);
  58.     }
  60.     /**
  61.      * Force-reconnect the default EM to the session tenant's DB (reset=true) so the
  62.      * activity row is written to the right tenant, not the box default. Best-effort:
  63.      * any failure leaves the existing connection and never breaks logging.
  64.      */
  65.     private function switchToSessionTenantDb(Request $request): void
  66.     {
  67.         try {
  68.             $appId = (int) $request->getSession()->get(UserConstants::USER_APP_ID);
  69.             if ($appId <= 0) {
  70.                 return;
  71.             }
  72.             $emGoc = $this->getDoctrine()->getManager('company_group');
  73.             $goc = $emGoc->getRepository('CompanyGroupBundle\\Entity\\CompanyGroup')
  74.                 ->findOneBy(['appId' => $appId]);
  75.             if (!$goc || !$goc->getDbName()) {
  76.                 return;
  77.             }
  78.             $this->container->get('application_connector')->resetConnection(
  79.                 'default',
  80.                 $goc->getDbName(),
  81.                 $goc->getDbUser(),
  82.                 $goc->getDbPass(),
  83.                 $goc->getDbHost(),
  84.                 true
  85.             );
  86.         } catch (\Throwable $e) {
  87.             // never break activity logging on the tenant-switch path
  88.         }
  89.     }
  91.     private function extractPayload(Request $request): array
  92.     {
  93.         $contentType = strtolower((string) $request->headers->get('Content-Type', ''));
  94.         $rawContent = trim((string) $request->getContent());
  96.         if ($rawContent !== '' && strpos($contentType, 'application/json') !== false) {
  97.             $decoded = json_decode($rawContent, true);
  99.             return is_array($decoded) ? $decoded : [];
  100.         }
  102.         return $request->request->all();
  103.     }
  104. }