src/ApplicationBundle/Modules/BankConnect/Controller/BankConnectController.php line 33

Open in your IDE?
  1. <?php
  3. namespace ApplicationBundle\Modules\BankConnect\Controller;
  5. use ApplicationBundle\Controller\GenericController;
  6. use ApplicationBundle\Entity\FinancialConnector;
  7. use ApplicationBundle\Interfaces\SessionCheckInterface;
  8. use ApplicationBundle\Modules\Aspire\Aspire;
  9. use ApplicationBundle\Modules\Authentication\Constants\UserConstants;
  10. use ApplicationBundle\Modules\BankConnect\ConnectorCredentialService;
  11. use ApplicationBundle\Modules\BankConnect\ConnectorRegistry;
  12. use Symfony\Component\HttpFoundation\JsonResponse;
  13. use Symfony\Component\HttpFoundation\Request;
  14. use Symfony\Component\HttpFoundation\Response;
  16. /**
  17.  * BC2 — the tenant-facing "connect a bank" UI over the unified connector registry
  18.  * ({@see FinancialConnector}). One screen for every provider: list connectors + status, add/edit
  19.  * one, pause/resume, delete, and sync-now. Credentials never leave this box in the clear —
  20.  * secrets are encrypted on save ({@see ConnectorCredentialService}) and only ever shown redacted.
  21.  *
  22.  * Aspire (adapter #1) keeps its detailed setup in the Aspire module; here it is "linked" by
  23.  * pointing a registry row at an existing AspireConnection, so the unified screen can drive it
  24.  * (sync-now → the proven Aspire::syncConnection) without duplicating its credentials.
  25.  */
  26. class BankConnectController extends GenericController implements SessionCheckInterface
  27. {
  28.     private function boot(): void
  29.     {
  30.         ConnectorCredentialService::ensureKey($this->container);
  31.     }
  33.     public function indexAction(Request $request): Response
  34.     {
  35.         $this->boot();
  36.         $em = $this->getDoctrine()->getManager();
  37.         $companyId = $request->getSession()->get(UserConstants::USER_COMPANY_ID);
  39.         $connectors = $em->getRepository('ApplicationBundle\\Entity\\FinancialConnector')
  40.             ->findBy(array('companyId' => $companyId), array('id' => 'DESC'));
  42.         // Existing Aspire connections available to link (so the tenant picks, never hand-types).
  43.         $aspireConnections = $em->getRepository('ApplicationBundle\\Entity\\AspireConnection')
  44.             ->findBy(array('companyId' => $companyId), array('id' => 'DESC'));
  46.         return $this->render('@BankConnect/pages/bank_connect.html.twig', array(
  47.             'connectors'        => $connectors,
  48.             'aspireConnections' => $aspireConnections,
  49.             'builtProviders'    => ConnectorRegistry::BUILT,
  50.             'plannedProviders'  => ConnectorRegistry::PLANNED,
  51.             'keyAvailable'      => ConnectorCredentialService::keyAvailable(),
  52.             'page_title'        => 'Bank Connections',
  53.         ));
  54.     }
  56.     /** POST /bank-connect/save — create or update one connector. */
  57.     public function saveAction(Request $request): JsonResponse
  58.     {
  59.         $this->boot();
  60.         $em = $this->getDoctrine()->getManager();
  61.         $companyId = (int) $request->getSession()->get(UserConstants::USER_COMPANY_ID);
  63.         $id       = (int) $request->request->get('id', 0);
  64.         $provider = strtolower(trim((string) $request->request->get('provider', '')));
  65.         $label    = trim((string) $request->request->get('label', ''));
  66.         $schedule = trim((string) $request->request->get('schedule_cron', ''));
  68.         if ($provider === '') {
  69.             return new JsonResponse(array('success' => false, 'message' => 'Provider is required.'));
  70.         }
  71.         if (!in_array($provider, ConnectorRegistry::knownProviders(), true)) {
  72.             return new JsonResponse(array('success' => false, 'message' => 'Unknown provider.'));
  73.         }
  75.         if ($id) {
  76.             $c = $em->getRepository('ApplicationBundle\\Entity\\FinancialConnector')->find($id);
  77.             if (!$c || (int) $c->getCompanyId() !== $companyId) {
  78.                 return new JsonResponse(array('success' => false, 'message' => 'Not found.'));
  79.             }
  80.         } else {
  81.             $c = new FinancialConnector();
  82.             $c->setCompanyId($companyId ?: 1);
  83.             $c->setStatus(FinancialConnector::STATUS_ACTIVE);
  84.             $c->setCreatedAt(new \DateTime());
  85.         }
  87.         $c->setProvider($provider);
  88.         $c->setLabel($label !== '' ? $label : ucfirst($provider));
  89.         $c->setScheduleCron($schedule !== '' ? $schedule : null);
  90.         $c->setUpdatedAt(new \DateTime());
  92.         if ($provider === 'aspire') {
  93.             // Aspire creds live on the AspireConnection — link, don't duplicate.
  94.             $linked = (int) $request->request->get('linked_aspire_connection_id', 0);
  95.             if ($linked <= 0) {
  96.                 return new JsonResponse(array('success' => false, 'message' => 'Choose an Aspire connection to link.'));
  97.             }
  98.             $ac = $em->getRepository('ApplicationBundle\\Entity\\AspireConnection')->find($linked);
  99.             if (!$ac || (int) $ac->getCompanyId() !== $companyId) {
  100.                 return new JsonResponse(array('success' => false, 'message' => 'Aspire connection not found.'));
  101.             }
  102.             $c->setAuthType(FinancialConnector::AUTH_API_KEY);
  103.             $c->setLinkedAspireConnectionId($linked);
  104.         } else {
  105.             // Other providers: creds are entered here → ENCRYPTED at rest. Refuse to store in the
  106.             // clear (fail closed) if no encryption key is configured on the box.
  107.             $credsJson = trim((string) $request->request->get('credentials', ''));
  108.             if ($credsJson !== '') {
  109.                 if (!ConnectorCredentialService::keyAvailable()) {
  110.                     return new JsonResponse(array('success' => false, 'message' => 'Encryption key not configured — cannot store credentials securely. Set app_encryption_key first.'));
  111.                 }
  112.                 $creds = json_decode($credsJson, true);
  113.                 if (!is_array($creds)) {
  114.                     // Accept a bare token too (e.g. Wise API token pasted directly).
  115.                     $creds = array('token' => $credsJson);
  116.                 }
  117.                 $c->setCredentialsEnc(ConnectorCredentialService::encrypt($creds));
  118.             }
  119.             $c->setAuthType($provider === 'wise' ? FinancialConnector::AUTH_API_KEY : FinancialConnector::AUTH_OAUTH2);
  120.         }
  122.         $accountRefs = trim((string) $request->request->get('account_refs', ''));
  123.         if ($accountRefs !== '') { $c->setAccountRefs($accountRefs); }
  125.         $em->persist($c);
  126.         $em->flush();
  128.         return new JsonResponse(array('success' => true, 'id' => $c->getId()));
  129.     }
  131.     /** POST /bank-connect/{id}/toggle — pause ⇄ resume. */
  132.     public function toggleAction(Request $request, int $id): JsonResponse
  133.     {
  134.         $this->boot();
  135.         $c = $this->ownedConnector($request, $id);
  136.         if (!$c) { return new JsonResponse(array('success' => false, 'message' => 'Not found.')); }
  137.         $c->setStatus($c->getStatus() === FinancialConnector::STATUS_ACTIVE
  138.             ? FinancialConnector::STATUS_PAUSED : FinancialConnector::STATUS_ACTIVE);
  139.         $c->setUpdatedAt(new \DateTime());
  140.         $this->getDoctrine()->getManager()->flush();
  141.         return new JsonResponse(array('success' => true, 'status' => $c->getStatus()));
  142.     }
  144.     /** POST /bank-connect/{id}/delete. */
  145.     public function deleteAction(Request $request, int $id): JsonResponse
  146.     {
  147.         $this->boot();
  148.         $c = $this->ownedConnector($request, $id);
  149.         if (!$c) { return new JsonResponse(array('success' => false, 'message' => 'Not found.')); }
  150.         $em = $this->getDoctrine()->getManager();
  151.         $em->remove($c);
  152.         $em->flush();
  153.         return new JsonResponse(array('success' => true));
  154.     }
  156.     /** POST /bank-connect/{id}/sync — sync one connector now (Aspire → proven syncConnection). */
  157.     public function syncNowAction(Request $request, int $id): JsonResponse
  158.     {
  159.         $this->boot();
  160.         $c = $this->ownedConnector($request, $id);
  161.         if (!$c) { return new JsonResponse(array('success' => false, 'message' => 'Not found.')); }
  163.         $em = $this->getDoctrine()->getManager();
  164.         $loginId = (int) $request->getSession()->get(UserConstants::USER_LOGIN_ID);
  166.         if (strtolower((string) $c->getProvider()) === 'aspire') {
  167.             $ac = $c->getLinkedAspireConnectionId()
  168.                 ? $em->getRepository('ApplicationBundle\\Entity\\AspireConnection')->find((int) $c->getLinkedAspireConnectionId())
  169.                 : null;
  170.             if (!$ac) { return new JsonResponse(array('success' => false, 'message' => 'Linked Aspire connection missing.')); }
  171.             $res = Aspire::syncConnection($ac, $em, $loginId, 'connect-ui');
  172.             $c->setLastSyncAt(new \DateTime());
  173.             $c->setLastSyncStatus(!empty($res['success']) ? 'ok' : 'error');
  174.             $c->setLastSyncError(!empty($res['success']) ? null : ($res['error'] ?? 'sync error'));
  175.             $em->flush();
  176.             if (empty($res['success'])) {
  177.                 return new JsonResponse(array('success' => false, 'message' => $res['error'] ?? 'Sync failed.'));
  178.             }
  179.             return new JsonResponse(array('success' => true, 'detail' => sprintf('Fetched %d, new %d, posted %d.',
  180.                 $res['fetched'] ?? 0, $res['new'] ?? 0, $res['auto_posted'] ?? 0)));
  181.         }
  183.         return new JsonResponse(array('success' => false, 'message' => ucfirst($c->getProvider()) . ' sync ships in a later phase (BC3/BC4).'));
  184.     }
  186.     private function ownedConnector(Request $request, int $id)
  187.     {
  188.         $companyId = (int) $request->getSession()->get(UserConstants::USER_COMPANY_ID);
  189.         $c = $this->getDoctrine()->getManager()->getRepository('ApplicationBundle\\Entity\\FinancialConnector')->find($id);
  190.         return ($c && (int) $c->getCompanyId() === $companyId) ? $c : null;
  191.     }
  192. }