UserCheckStatus.php 1.6 KB

1234567891011121314151617181920212223242526272829303132333435363738394041424344454647
  1. <?php
  2. namespace Controllers;
  3. use Libs\ResponseLib;
  4. use Models\UserModel;
  5. use Psr\Http\Message\ServerRequestInterface;
  6. use Respect\Validation\Exceptions\ValidationException;
  7. use Respect\Validation\Validator as val;
  8. use React\Http\Message\Response;
  9. class UserCheckStatus
  10. {
  11. public function __invoke(ServerRequestInterface $request)
  12. {
  13. $body = json_decode((string)$request->getBody(), true) ?? [];
  14. try {
  15. val::key('numberToken', val::stringType()->notEmpty()->length(1, 255))
  16. ->assert($body);
  17. } catch (ValidationException $e) {
  18. return ResponseLib::sendFail("Validation failed: " . $e->getFullMessage(), [], "E_VALIDATE")->withStatus(400);
  19. }
  20. $numberToken = trim($body['numberToken']);
  21. try {
  22. $userModel = new UserModel();
  23. $user = $userModel->findByExternalId($numberToken);
  24. } catch (\Throwable $e) {
  25. return ResponseLib::sendFail('Database error: ' . $e->getMessage(), [], 'E_DATABASE')->withStatus(500);
  26. }
  27. $status = ($user && (int)$user['user_kyc'] === 1) ? 1 : 0;
  28. $responsePayload = ['status' => $status];
  29. $logLine = sprintf('[UserCheckStatus] Responding with payload: %s', json_encode($responsePayload, JSON_UNESCAPED_SLASHES));
  30. if (defined('STDERR')) {
  31. fwrite(STDERR, $logLine . PHP_EOL);
  32. fflush(STDERR);
  33. } else {
  34. error_log($logLine);
  35. }
  36. return Response::json($responsePayload)->withStatus(200);
  37. }
  38. }