backend-php/controllers/CompanyWithUserController.php

<?php

namespace Controllers;

use Libs\BashExecutor;
use Libs\ResponseLib;
use Models\CompanyModel;
use Models\UserModel;
use Psr\Http\Message\ServerRequestInterface;

class CompanyWithUserController
{
    public function __invoke(ServerRequestInterface $request)
    {
        $body = json_decode((string)$request->getBody(), true) ?? [];

        $required = [
            'company_name',
            'username','email','password','phone','address','city','state','zip','country',
            'kyc','birthdate','cpf'
        ];
        foreach ($required as $field) {
            if (!isset($body[$field]) || $body[$field] === '') {
                return ResponseLib::sendFail("Missing field: $field", [], "E_VALIDATE")->withStatus(400);
            }
        }
        if (!filter_var($body['email'], FILTER_VALIDATE_EMAIL)) {
            return ResponseLib::sendFail("Invalid email format", [], "E_VALIDATE")->withStatus(400);
        }
        if (strlen($body['password']) < 8) {
            return ResponseLib::sendFail("Password must be at least 8 characters", [], "E_VALIDATE")->withStatus(400);
        }

        try {
            $pdo = $GLOBALS['pdo'];
            $pdo->beginTransaction();

            $companyModel = new CompanyModel();
            $companyId = $companyModel->createCompany($body['company_name'], 'a');
            $roleId = 1;
            $chk = $pdo->prepare('SELECT 1 FROM "role" WHERE role_id = :rid');
            $chk->execute(['rid' => $roleId]);
            if (!$chk->fetchColumn()) {
                $pdo->rollBack();
                return ResponseLib::sendFail('Default role_id 1 not found', [], 'E_DATABASE')->withStatus(500);
            }

            $userModel = new UserModel();
            $userPayload = [
                'username' => $body['username'],
                'email' => $body['email'],
                'password' => $body['password'],
                'phone' => $body['phone'],
                'address' => $body['address'],
                'city' => $body['city'],
                'state' => $body['state'],
                'zip' => $body['zip'],
                'country' => $body['country'],
                'kyc' => (int)$body['kyc'],
                'birthdate' => (int)$body['birthdate'],
                'cpf' => $body['cpf'],
                'company_id' => $companyId,
                'role_id' => $roleId
            ];
            $userData = $userModel->createUser($userPayload);
            if (!$userData) {
                $pdo->rollBack();
                return ResponseLib::sendFail("Email already exists or creation failed", [], "E_VALIDATE")->withStatus(400);
            }

            $bin = dirname(__DIR__) . '/bin/easycli';
            $result = BashExecutor::run($bin . ' polygon create-new-address');
            if (($result['exitCode'] ?? 1) !== 0) {
                $pdo->rollBack();
                return ResponseLib::sendFail("Wallet generation failed", ['error' => $result['error'] ?? ''], "E_INTERNAL")->withStatus(500);
            }
            $output = trim((string)($result['output'] ?? ''));
            $parsed = [];
            foreach (preg_split('/\r?\n/', $output) as $line) {
                $line = trim($line);
                if ($line === '' || strpos($line, '=') === false) { continue; }
                [$k, $v] = explode('=', $line, 2);
                $parsed[trim($k)] = trim($v);
            }
            if (!isset($parsed['privateKey'], $parsed['publicKey'], $parsed['address'])) {
                $pdo->rollBack();
                return ResponseLib::sendFail("Wallet parsing failed", ['raw' => $output], "E_INTERNAL")->withStatus(500);
            }

            $stmt = $pdo->prepare('SELECT chain_id FROM "chain" WHERE chain_name = :name');
            $stmt->execute(['name' => 'primalchain']);
            $chainId = $stmt->fetchColumn();
            if (!$chainId) {
                $pdo->rollBack();
                return ResponseLib::sendFail("Chain not found", [], "E_DATABASE")->withStatus(500);
            }

            $stmt = $pdo->prepare('INSERT INTO "wallet" (company_id, wallet_public_key, wallet_address, wallet_private_key, wallet_flag, chain_id) VALUES (:company_id, :public_key, :address, :private_key, :flag, :chain_id) RETURNING wallet_id');
            $stmt->execute([
                'company_id' => $companyId,
                'public_key' => $parsed['publicKey'],
                'address' => $parsed['address'],
                'private_key' => $parsed['privateKey'],
                'flag' => 'a',
                'chain_id' => (int)$chainId
            ]);
            $walletId = (int)$stmt->fetchColumn();

            $pdo->commit();

            return ResponseLib::sendOk([
                'company_id' => $companyId,
                'role_id' => $roleId,
                'user' => $userData,
                'wallet_id' => $walletId,
                'wallet_address' => $parsed['address']
            ], 'S_CREATED');

        } catch (\Throwable $e) {
            if (isset($pdo) && $pdo->inTransaction()) { $pdo->rollBack(); }
            return ResponseLib::sendFail($e->getMessage(), [], 'E_DATABASE')->withStatus(500);
        }
    }
}