true, 'cookie_samesite' => 'Lax', 'use_strict_mode' => true, ]); } if (empty($_SESSION['installer_csrf']) || !is_string($_SESSION['installer_csrf'])) { $_SESSION['installer_csrf'] = bin2hex(random_bytes(32)); } function instaladorCsrfHeader(): string { $h = $_SERVER['HTTP_X_INSTALLER_CSRF'] ?? ''; return is_string($h) ? trim($h) : ''; } function instaladorRequireCsrf(): void { if (empty($_SESSION['installer_csrf']) || !is_string($_SESSION['installer_csrf'])) { throw new Exception('Sessão inválida. Recarregue a página do instalador.'); } $sent = instaladorCsrfHeader(); if ($sent === '' || !hash_equals($_SESSION['installer_csrf'], $sent)) { throw new Exception('Pedido recusado (CSRF). Recarregue a página e tente novamente.'); } } function instaladorStatePath(): string { return __DIR__ . DIRECTORY_SEPARATOR . 'config' . DIRECTORY_SEPARATOR . 'installer_state.json'; } /** @return array */ function instaladorReadState(): array { $p = instaladorStatePath(); if (!is_readable($p)) { return []; } $j = json_decode((string) file_get_contents($p), true); return is_array($j) ? $j : []; } /** @param array $merge */ function instaladorWriteStateMerge(array $merge): void { $dir = dirname(instaladorStatePath()); if (!is_dir($dir) && !@mkdir($dir, 0755, true)) { return; } $cur = instaladorReadState(); file_put_contents( instaladorStatePath(), json_encode(array_merge($cur, $merge), JSON_PRETTY_PRINT | JSON_UNESCAPED_UNICODE) ); } function instaladorPathIsInsideDir(string $path, string $rootDir): bool { $path = realpath($path); $root = realpath($rootDir); if ($path === false || $root === false) { return false; } $path = str_replace('\\', '/', $path); $root = str_replace('\\', '/', $root); return $path === $root || str_starts_with($path, $root . '/'); } function instaladorSanitizeMysqlHost(string $raw): string { $s = trim($raw); if ($s === '' || strlen($s) > 255) { return ''; } if (!preg_match('/^[a-zA-Z0-9.\-_:]+$/', $s)) { return ''; } return $s; } function instaladorSanitizeMysqlUser(string $raw): string { $s = trim($raw); if ($s === '' || strlen($s) > 128) { return ''; } if (!preg_match('/^[a-zA-Z0-9_\-.@]+$/', $s)) { return ''; } return $s; } function instaladorSanitizeMysqlDatabaseName(string $raw): string { $s = trim($raw); if ($s === '' || strlen($s) > 64) { return ''; } if (!preg_match('/^[a-zA-Z0-9_]+$/', $s)) { return ''; } return $s; } /** * Extração segura do ZIP (anti Zip Slip); ignora instalador.php embutido. * * @return list */ function instaladorZipExtractSafe(ZipArchive $zip, string $extractDir): array { $extractRoot = realpath($extractDir); if ($extractRoot === false) { throw new Exception('Diretório de extração inválido.'); } $outNames = []; for ($i = 0; $i < $zip->numFiles; $i++) { $stat = $zip->statIndex($i); if (!is_array($stat) || !isset($stat['name'])) { continue; } $name = (string) $stat['name']; if ($name === '' || str_ends_with($name, '/')) { continue; } $norm = str_replace('\\', '/', $name); if ($norm[0] === '/' || preg_match('#(^|/)\\.\\.(/|$)#', $norm)) { continue; } if (strcasecmp(basename($norm), 'instalador.php') === 0) { continue; } $destPath = $extractDir . DIRECTORY_SEPARATOR . str_replace('/', DIRECTORY_SEPARATOR, $norm); $destParent = dirname($destPath); if (!is_dir($destParent)) { if (!@mkdir($destParent, 0755, true)) { throw new Exception('Não foi possível criar pastas para extração.'); } } $rp = realpath($destParent); if ($rp === false || !instaladorPathIsInsideDir($rp, $extractRoot)) { throw new Exception('Entrada ZIP inválida (tentativa de path traversal).'); } $bytes = $zip->getFromIndex($i); if ($bytes === false) { continue; } if (file_put_contents($destPath, $bytes) !== false) { $outNames[] = $norm; } } return $outNames; } /* * Endpoints JSON — executar antes de qualquer require do projecto (constants/database/functions * podem emitir BOM, avisos ou HTML e corromper a resposta; o fetch do browser mostraria «HTML em vez de JSON»). */ if (isset($_GET['installer_status']) && ($_SERVER['REQUEST_METHOD'] ?? '') === 'GET') { header('Content-Type: application/json; charset=utf-8'); $dbSql = __DIR__ . DIRECTORY_SEPARATOR . 'db.sql'; $configDir = __DIR__ . DIRECTORY_SEPARATOR . 'config'; $state = instaladorReadState(); echo json_encode([ 'success' => true, 'requirements' => [ 'php_version_ok' => version_compare(PHP_VERSION, '7.4.0', '>='), 'php_version' => PHP_VERSION, 'ext_curl' => extension_loaded('curl'), 'ext_pdo_mysql' => extension_loaded('pdo_mysql'), 'ext_zip' => extension_loaded('zip'), 'config_writable' => is_dir($configDir) ? is_writable($configDir) : is_writable(__DIR__), 'installer_dir_writable' => is_writable(__DIR__), ], 'files' => [ 'db_sql' => is_file($dbSql) && is_readable($dbSql), 'database_json' => is_file($configDir . DIRECTORY_SEPARATOR . 'database.json'), ], 'state' => [ 'package_extracted' => !empty($state['package_extracted']), 'extracted_at' => $state['extracted_at'] ?? null, ], 'csrf_token' => $_SESSION['installer_csrf'] ?? '', ], JSON_UNESCAPED_UNICODE); exit; } if (isset($_GET['save_db']) && ($_SERVER['REQUEST_METHOD'] ?? '') === 'POST') { header('Content-Type: application/json; charset=utf-8'); try { instaladorRequireCsrf(); $input = file_get_contents('php://input'); $dbData = json_decode($input, true); if (!$dbData || !is_array($dbData)) { throw new Exception('JSON inválido ou vazio.'); } $host = instaladorSanitizeMysqlHost((string) ($dbData['host'] ?? '')); $user = instaladorSanitizeMysqlUser((string) ($dbData['user'] ?? '')); $dbName = instaladorSanitizeMysqlDatabaseName((string) ($dbData['database'] ?? '')); if ($host === '' || $user === '' || $dbName === '') { throw new Exception('Host, utilizador ou nome da base de dados inválido (use apenas caracteres permitidos).'); } $password = isset($dbData['password']) && is_string($dbData['password']) ? $dbData['password'] : ''; if (strlen($password) > 512) { throw new Exception('Senha demasiado longa.'); } $configDir = __DIR__ . DIRECTORY_SEPARATOR . 'config'; if (!file_exists($configDir)) { if (!mkdir($configDir, 0755, true)) { throw new Exception('Não foi possível criar o diretório config. Verifique as permissões.'); } } $configFile = $configDir . DIRECTORY_SEPARATOR . 'database.json'; $configDataPrev = []; if (file_exists($configFile)) { $existingContent = file_get_contents($configFile); if ($existingContent !== false) { $existingData = json_decode($existingContent, true); if (is_array($existingData)) { $configDataPrev = $existingData; unset($configDataPrev['codigo_sistema']); } } } $licSrc = array_key_exists('licenca', $dbData) ? trim((string) $dbData['licenca']) : trim((string) ($configDataPrev['licenca'] ?? '')); if (strlen($licSrc) > 512) { throw new Exception('Campo de licença inválido.'); } $panelUrlSrc = array_key_exists('panel_license_url', $dbData) ? trim((string) $dbData['panel_license_url']) : trim((string) ($configDataPrev['panel_license_url'] ?? '')); $configData = [ 'host' => $host, 'user' => $user, 'password' => $password, 'database' => $dbName, 'licenca' => $licSrc, ]; if ($panelUrlSrc !== '') { if (strlen($panelUrlSrc) > 512) { throw new Exception('URL do painel demasiado longa.'); } $configData['panel_license_url'] = $panelUrlSrc; } $jsonContent = json_encode($configData, JSON_PRETTY_PRINT | JSON_UNESCAPED_UNICODE); $result = file_put_contents($configFile, $jsonContent); if ($result === false) { throw new Exception('Não foi possível salvar o arquivo. Verifique as permissões do diretório config.'); } error_log('Instalador save_db: database=' . $dbName . ', host=' . $host . ', user=' . $user); $dbSqlCheck = __DIR__ . DIRECTORY_SEPARATOR . 'db.sql'; $importSql = is_file($dbSqlCheck) && is_readable($dbSqlCheck); echo json_encode([ 'success' => true, 'message' => 'Configuração salva com sucesso!', 'file' => $configFile, 'import_sql' => $importSql, ], JSON_UNESCAPED_UNICODE); } catch (Exception $e) { http_response_code(500); echo json_encode([ 'success' => false, 'message' => $e->getMessage(), ], JSON_UNESCAPED_UNICODE); } exit; } if (isset($_GET['test_db']) && ($_SERVER['REQUEST_METHOD'] ?? '') === 'POST') { header('Content-Type: application/json; charset=utf-8'); try { instaladorRequireCsrf(); $input = file_get_contents('php://input'); $d = json_decode($input, true); if (!$d || !is_array($d)) { throw new Exception('JSON inválido.'); } $host = instaladorSanitizeMysqlHost((string) ($d['host'] ?? '')); $user = instaladorSanitizeMysqlUser((string) ($d['user'] ?? '')); $dbName = instaladorSanitizeMysqlDatabaseName((string) ($d['database'] ?? '')); if ($host === '' || $user === '' || $dbName === '') { throw new Exception('Host, utilizador ou nome da base inválidos.'); } $password = isset($d['password']) && is_string($d['password']) ? $d['password'] : ''; $dsn = 'mysql:host=' . $host . ';charset=utf8mb4'; $pdo = new PDO($dsn, $user, $password, [ PDO::ATTR_ERRMODE => PDO::ERRMODE_EXCEPTION, PDO::ATTR_TIMEOUT => 8, ]); $stmt = $pdo->prepare('SELECT SCHEMA_NAME FROM INFORMATION_SCHEMA.SCHEMATA WHERE SCHEMA_NAME = ? LIMIT 1'); $stmt->execute([$dbName]); $exists = (bool) $stmt->fetchColumn(); echo json_encode([ 'success' => true, 'message' => $exists ? 'Ligação OK. A base de dados já existe (será utilizada).' : 'Ligação OK. A base de dados ainda não existe (será criada na importação).', 'database_exists' => $exists, ], JSON_UNESCAPED_UNICODE); } catch (Exception $e) { http_response_code(400); echo json_encode([ 'success' => false, 'message' => $e->getMessage(), ], JSON_UNESCAPED_UNICODE); } exit; } if (isset($_GET['check_progress'])) { header('Content-Type: application/json; charset=utf-8'); $progressFile = __DIR__ . DIRECTORY_SEPARATOR . 'import_progress.json'; if (file_exists($progressFile)) { $progress = json_decode((string) file_get_contents($progressFile), true); echo json_encode(is_array($progress) ? $progress : ['step' => 'idle', 'message' => 'Progresso inválido.', 'progress' => 0, 'total' => 0, 'percentage' => 0], JSON_UNESCAPED_UNICODE); } else { echo json_encode([ 'step' => 'idle', 'message' => 'Aguardando início da importação...', 'progress' => 0, 'total' => 0, 'percentage' => 0, ], JSON_UNESCAPED_UNICODE); } exit; } /** * Caminho URL deste ficheiro para pedidos fetch (JSON). * Se usássemos só SCRIPT_NAME, com rewrite para index.php ou inclusão deste script, * o browser chamaria index.php?save_db=1 e recebia HTML em vez de JSON. */ function instaladorWebPathSelf(): string { $docRoot = isset($_SERVER['DOCUMENT_ROOT']) ? realpath((string) $_SERVER['DOCUMENT_ROOT']) : false; $fileReal = realpath(__FILE__); if ($docRoot !== false && $fileReal !== false && strpos($fileReal, $docRoot) === 0) { $rel = substr($fileReal, strlen($docRoot)); $rel = str_replace('\\', '/', $rel); return '/' . ltrim($rel, '/'); } return isset($_SERVER['SCRIPT_NAME']) ? (string) $_SERVER['SCRIPT_NAME'] : ''; } // Instalador mínimo: só grava config/database.json localmente — sem carregar database.php / constants.php / functions.php. $projectRoot = __DIR__; if (!defined('SITE_NAME')) { define('SITE_NAME', 'Instalação'); } if (!function_exists('formatDate')) { function formatDate($date, $format = 'd/m/Y') { if (empty($date)) { return '-'; } try { $dateObj = new DateTime($date); return $dateObj->format($format); } catch (Exception $e) { return $date; } } } $missingFiles = []; $apiKey = ''; $sistemas = []; $erro = null; $carregando = false; // Função para remover diretório recursivamente function removeDirectory($dir) { if (!file_exists($dir)) { return true; } if (!is_dir($dir)) { return unlink($dir); } foreach (scandir($dir) as $item) { if ($item == '.' || $item == '..') { continue; } if (!removeDirectory($dir . DIRECTORY_SEPARATOR . $item)) { return false; } } return rmdir($dir); } /** * Remove todos os ficheiros .sql sob $root (recursivo, ex.: ficheiros extraídos do ZIP). */ function instalador_delete_all_sql_files(string $root): int { if (!is_dir($root)) { return 0; } $deleted = 0; try { $dirIt = new RecursiveDirectoryIterator($root, FilesystemIterator::SKIP_DOTS); $it = new RecursiveIteratorIterator($dirIt, RecursiveIteratorIterator::CHILD_FIRST); foreach ($it as $file) { if ($file->isFile() && strcasecmp(substr($file->getFilename(), -4), '.sql') === 0) { if (@unlink($file->getPathname())) { $deleted++; } } } } catch (Throwable $e) { error_log('instalador_delete_all_sql_files: ' . $e->getMessage()); } return $deleted; } // Cancelar instalação: apaga tudo em __DIR__ exceto o próprio instalador (ficheiro actual) if (isset($_GET['limpar_pasta_instalacao']) && $_SERVER['REQUEST_METHOD'] === 'POST') { header('Content-Type: application/json; charset=UTF-8'); try { instaladorRequireCsrf(); unset($_SESSION['installer']); $root = realpath(__DIR__); if ($root === false) { throw new Exception('Não foi possível resolver o diretório da instalação.'); } $manter = basename(__FILE__); $entries = @scandir($root); if ($entries === false) { throw new Exception('Não foi possível listar a pasta.'); } foreach ($entries as $name) { if ($name === '.' || $name === '..') { continue; } if (strcasecmp($name, $manter) === 0) { continue; } $path = $root . DIRECTORY_SEPARATOR . $name; if (is_dir($path)) { if (!removeDirectory($path)) { throw new Exception('Não foi possível remover a pasta: ' . $name); } } else { if (!@unlink($path)) { throw new Exception('Não foi possível remover o ficheiro: ' . $name); } } } echo json_encode([ 'success' => true, 'message' => 'Pasta limpa. Mantido apenas ' . $manter . '.', ], JSON_UNESCAPED_UNICODE); } catch (Exception $e) { http_response_code(500); echo json_encode([ 'success' => false, 'message' => $e->getMessage(), ], JSON_UNESCAPED_UNICODE); } exit; } if (isset($_GET['import_sql']) && $_SERVER['REQUEST_METHOD'] === 'POST') { header('Content-Type: application/json'); try { instaladorRequireCsrf(); // Ler configuração do database.json $configFile = __DIR__ . DIRECTORY_SEPARATOR . 'config' . DIRECTORY_SEPARATOR . 'database.json'; if (!file_exists($configFile)) { throw new Exception('Arquivo de configuração não encontrado. Configure o banco de dados primeiro.'); } $configContent = file_get_contents($configFile); $config = json_decode($configContent, true); if (!$config) { throw new Exception('Erro ao ler arquivo de configuração.'); } // Validar configuração (anti injeção em identificadores SQL) $config['host'] = instaladorSanitizeMysqlHost((string) ($config['host'] ?? '')); $config['user'] = instaladorSanitizeMysqlUser((string) ($config['user'] ?? '')); $config['database'] = instaladorSanitizeMysqlDatabaseName((string) ($config['database'] ?? '')); if ($config['host'] === '' || $config['user'] === '' || $config['database'] === '') { throw new Exception('Configuração de banco de dados inválida ou incompleta.'); } // SQL enviado no ZIP (à frente do instalador), nome convencionado: db.sql $sqlFile = __DIR__ . DIRECTORY_SEPARATOR . 'db.sql'; if (!file_exists($sqlFile) || !is_readable($sqlFile)) { throw new Exception('Ficheiro db.sql não encontrado nesta pasta (deve vir no pacote ZIP).'); } // Ler conteúdo do arquivo SQL $sqlContent = file_get_contents($sqlFile); if (empty($sqlContent)) { throw new Exception('Arquivo SQL está vazio.'); } // Função para atualizar progresso $progressFile = __DIR__ . DIRECTORY_SEPARATOR . 'import_progress.json'; function updateProgress($step, $message, $progress = 0, $total = 0) { global $progressFile; $data = [ 'step' => $step, 'message' => $message, 'progress' => $progress, 'total' => $total, 'percentage' => $total > 0 ? round(($progress / $total) * 100, 1) : 0, 'timestamp' => time() ]; file_put_contents($progressFile, json_encode($data, JSON_UNESCAPED_UNICODE)); } // Limpar arquivo de progresso anterior if (file_exists($progressFile)) { unlink($progressFile); } updateProgress('connecting', 'Conectando ao servidor MySQL...', 0, 0); // Conectar ao MySQL try { $dsn = "mysql:host={$config['host']};charset=utf8mb4"; $pdo = new PDO($dsn, $config['user'], $config['password'] ?? '', [ PDO::ATTR_ERRMODE => PDO::ERRMODE_EXCEPTION, PDO::ATTR_DEFAULT_FETCH_MODE => PDO::FETCH_ASSOC, PDO::ATTR_TIMEOUT => 10 ]); updateProgress('connected', 'Conexão estabelecida com sucesso!', 1, 10); } catch (PDOException $e) { updateProgress('error', 'Erro ao conectar: ' . $e->getMessage(), 0, 0); throw new Exception('Erro ao conectar ao MySQL: ' . $e->getMessage()); } // Verificar se o banco de dados existe updateProgress('checking_db', 'Verificando se o banco de dados existe...', 2, 10); try { $chkDb = $pdo->prepare('SELECT SCHEMA_NAME FROM INFORMATION_SCHEMA.SCHEMATA WHERE SCHEMA_NAME = ? LIMIT 1'); $chkDb->execute([$config['database']]); $dbExists = (bool) $chkDb->fetchColumn(); if ($dbExists) { updateProgress('db_exists', 'Banco de dados já existe.', 3, 10); } else { updateProgress('creating_db', 'Criando banco de dados...', 3, 10); $pdo->exec("CREATE DATABASE `{$config['database']}` CHARACTER SET utf8mb4 COLLATE utf8mb4_unicode_ci"); updateProgress('db_created', 'Banco de dados criado com sucesso!', 4, 10); } } catch (PDOException $e) { updateProgress('error', 'Erro ao verificar/criar banco: ' . $e->getMessage(), 0, 0); throw new Exception('Erro ao verificar/criar banco de dados: ' . $e->getMessage()); } // Selecionar o banco de dados updateProgress('selecting_db', 'Selecionando banco de dados...', 4, 10); try { $pdo->exec("USE `{$config['database']}`"); updateProgress('db_selected', 'Banco de dados selecionado.', 5, 10); } catch (PDOException $e) { updateProgress('error', 'Erro ao selecionar banco: ' . $e->getMessage(), 0, 0); throw new Exception('Erro ao selecionar banco de dados: ' . $e->getMessage()); } updateProgress('parsing_sql', 'Processando arquivo SQL...', 6, 10); // Processar arquivo SQL // Primeiro, processar DELIMITER e blocos com delimitadores alternativos $lines = explode("\n", $sqlContent); $processedLines = []; $inDelimiterBlock = false; $currentDelimiter = ';'; $currentBlock = ''; foreach ($lines as $lineNum => $line) { $trimmedLine = trim($line); // Detectar comandos DELIMITER if (preg_match('/^\s*DELIMITER\s+(.+)$/i', $trimmedLine, $matches)) { $newDelimiter = trim($matches[1]); // Se já estávamos em um bloco, finalizar o bloco anterior if ($inDelimiterBlock && !empty($currentBlock)) { $processedLines[] = rtrim($currentBlock) . ';'; $currentBlock = ''; } if ($newDelimiter === '$$' || $newDelimiter === '//' || $newDelimiter === ';;') { $inDelimiterBlock = true; $currentDelimiter = $newDelimiter; } else { // Voltar para delimitador padrão $inDelimiterBlock = false; $currentDelimiter = ';'; } continue; // Não adicionar linha DELIMITER } // Se estamos em um bloco com delimitador alternativo if ($inDelimiterBlock) { // Verificar se é o fim do bloco (delimitador no final da linha) $delimiterPattern = preg_quote($currentDelimiter, '/'); if (preg_match('/' . $delimiterPattern . '\s*$/', $trimmedLine)) { // Remover delimitador e adicionar ao bloco $lineWithoutDelimiter = preg_replace('/' . $delimiterPattern . '\s*$/', '', $trimmedLine); $currentBlock .= $lineWithoutDelimiter . "\n"; // Finalizar bloco $processedLines[] = rtrim($currentBlock) . ';'; $currentBlock = ''; $inDelimiterBlock = false; $currentDelimiter = ';'; } else { // Continuar acumulando o bloco $currentBlock .= $line . "\n"; } } else { $processedLines[] = $line; } } // Se ainda há um bloco aberto, finalizar if ($inDelimiterBlock && !empty($currentBlock)) { $processedLines[] = rtrim($currentBlock) . ';'; } $sqlContent = implode("\n", $processedLines); // Remover comentários condicionais do MySQL (/*!40101 ... */) - processar o conteúdo $sqlContent = preg_replace_callback('/\/\*!\d+\s+(.*?)\s*\*\//s', function($matches) { return $matches[1]; // Manter apenas o conteúdo SQL }, $sqlContent); // Remover comentários de linha (-- comentário) $sqlContent = preg_replace('/--.*$/m', '', $sqlContent); // Remover comentários de bloco (/* comentário */) - mas manter os condicionais já processados $sqlContent = preg_replace('/\/\*[^!].*?\*\//s', '', $sqlContent); // Remover comandos SET que podem causar problemas $sqlContent = preg_replace('/^\s*SET\s+SQL_MODE\s*=.*?;?\s*$/mi', '', $sqlContent); $sqlContent = preg_replace('/^\s*SET\s+time_zone\s*=.*?;?\s*$/mi', '', $sqlContent); $sqlContent = preg_replace('/^\s*START\s+TRANSACTION\s*;?\s*$/mi', '', $sqlContent); $sqlContent = preg_replace('/^\s*COMMIT\s*;?\s*$/mi', '', $sqlContent); // Normalizar quebras de linha $sqlContent = str_replace(["\r\n", "\r"], "\n", $sqlContent); // Dividir o SQL em comandos individuais usando uma abordagem mais simples e robusta $sqlCommands = []; $currentCommand = ''; $inString = false; $stringChar = ''; $depth = 0; $inBeginBlock = false; $len = strlen($sqlContent); for ($i = 0; $i < $len; $i++) { $char = $sqlContent[$i]; $prevChar = ($i > 0) ? $sqlContent[$i - 1] : ''; $nextChars = ($i < $len - 1) ? substr($sqlContent, $i, min(20, $len - $i)) : ''; // Detectar início de string if (!$inString && ($char === '"' || $char === "'" || $char === '`')) { $inString = true; $stringChar = $char; $currentCommand .= $char; } // Detectar fim de string elseif ($inString && $char === $stringChar) { // Verificar se não é escape (contar escapes consecutivos) $escapeCount = 0; $j = $i - 1; while ($j >= 0 && $sqlContent[$j] === '\\') { $escapeCount++; $j--; } if ($escapeCount % 2 === 0) { $inString = false; $stringChar = ''; } $currentCommand .= $char; } // Processar caracteres fora de strings elseif (!$inString) { // Detectar BEGIN if (preg_match('/\bBEGIN\b/i', $nextChars)) { $inBeginBlock = true; } // Contar parênteses if ($char === '(') { $depth++; $currentCommand .= $char; } elseif ($char === ')') { $depth--; $currentCommand .= $char; } // Processar ponto e vírgula elseif ($char === ';') { // Se estamos em um bloco BEGIN, verificar se há END if ($inBeginBlock && $depth === 0) { $remaining = substr($sqlContent, $i + 1, 500); // Procurar por END seguido de ponto e vírgula if (preg_match('/^\s*\bEND\b\s*;/i', $remaining)) { // Continuar acumulando até encontrar END; $currentCommand .= $char; continue; } } // Dividir apenas se não estiver dentro de parênteses ou blocos BEGIN if ($depth === 0 && !$inBeginBlock) { $cmd = trim($currentCommand); // Validar comando antes de adicionar if (!empty($cmd) && strlen($cmd) > 3 && !preg_match('/^(USE|SET\s+@OLD_|SET\s+NAMES)/i', $cmd)) { $sqlCommands[] = $cmd; } $currentCommand = ''; } else { $currentCommand .= $char; } } // Detectar END em blocos BEGIN elseif ($inBeginBlock && $depth === 0 && preg_match('/\bEND\b/i', $nextChars)) { // Adicionar END $currentCommand .= $char; // Avançar até o final de END $i++; while ($i < $len && preg_match('/[A-Za-z0-9_]/', $sqlContent[$i])) { $currentCommand .= $sqlContent[$i]; $i++; } $i--; // Ajustar para o loop principal // Pular espaços while ($i + 1 < $len && ctype_space($sqlContent[$i + 1])) { $i++; } // Se há ponto e vírgula, finalizar comando if ($i + 1 < $len && $sqlContent[$i + 1] === ';') { $currentCommand .= ';'; $i++; // Pular o ; $cmd = trim($currentCommand); if (!empty($cmd) && strlen($cmd) > 3) { $sqlCommands[] = $cmd; } $currentCommand = ''; $inBeginBlock = false; } else { $inBeginBlock = false; } } else { $currentCommand .= $char; } } else { $currentCommand .= $char; } } // Adicionar último comando se houver $lastCmd = trim($currentCommand); if (!empty($lastCmd) && strlen($lastCmd) > 3 && !preg_match('/^(USE|SET\s+@OLD_|SET\s+NAMES)/i', $lastCmd)) { $sqlCommands[] = $lastCmd; } // Filtrar e validar comandos $sqlCommands = array_filter($sqlCommands, function($cmd) { $cmd = trim($cmd); // Remover comandos muito curtos, vazios ou inválidos if (empty($cmd) || strlen($cmd) < 4) { return false; } // Ignorar comandos problemáticos if (preg_match('/^(USE\s+|SET\s+@OLD_|SET\s+NAMES|COMMIT|START\s+TRANSACTION)/i', $cmd)) { return false; } // Verificar se não contém apenas espaços, quebras de linha ou caracteres especiais if (preg_match('/^[\s\n\r;]+$/', $cmd)) { return false; } // Verificar se contém pelo menos uma palavra-chave SQL válida $validKeywords = ['CREATE', 'INSERT', 'UPDATE', 'DELETE', 'ALTER', 'DROP', 'SELECT', 'TRIGGER', 'VIEW']; $hasValidKeyword = false; foreach ($validKeywords as $keyword) { if (stripos($cmd, $keyword) !== false) { $hasValidKeyword = true; break; } } if (!$hasValidKeyword) { return false; } // Verificar se não termina apenas com ponto e vírgula ou espaços $cmdWithoutSpaces = trim($cmd, " \t\n\r\0\x0B;"); if (empty($cmdWithoutSpaces)) { return false; } // Verificar se não contém apenas caracteres não imprimíveis if (!preg_match('/[a-zA-Z0-9_`\(\)]/', $cmd)) { return false; } return true; }); // Reindexar array $sqlCommands = array_values($sqlCommands); $totalCommands = count($sqlCommands); updateProgress('parsed', "Arquivo SQL processado. {$totalCommands} comandos encontrados.", 7, 10); if ($totalCommands === 0) { updateProgress('error', 'Nenhum comando SQL válido encontrado no arquivo.', 0, 0); throw new Exception('Nenhum comando SQL válido encontrado no arquivo.'); } $executed = 0; $errors = []; updateProgress('executing', "Executando comandos SQL... (0/{$totalCommands})", 0, $totalCommands); // Executar cada comando SQL foreach ($sqlCommands as $index => $command) { $command = trim($command); if (empty($command)) { error_log("Comando vazio encontrado no índice: " . $index); continue; } // Validação adicional antes de executar if (strlen($command) < 4) { error_log("Comando muito curto ignorado: " . substr($command, 0, 50)); continue; } // Validar comando antes de executar $cmdTrimmed = trim($command); if (empty($cmdTrimmed) || strlen($cmdTrimmed) < 4) { error_log("Comando vazio ou muito curto ignorado no índice: " . $index); continue; } // Verificar se contém apenas espaços ou caracteres especiais if (preg_match('/^[\s\n\r\t;]+$/', $cmdTrimmed)) { error_log("Comando contém apenas espaços/caracteres especiais ignorado no índice: " . $index); continue; } // Atualizar progresso $currentProgress = $index + 1; $percentage = round(($currentProgress / $totalCommands) * 100, 1); updateProgress('executing', "Executando comando {$currentProgress}/{$totalCommands} ({$percentage}%)", $currentProgress, $totalCommands); try { $pdo->exec($command); $executed++; } catch (PDOException $e) { $errorMsg = $e->getMessage(); $errorCode = $e->getCode(); // Ignorar erros comuns que não são críticos $ignoreErrors = [ 'already exists', 'Duplicate', 'Unknown database', 'Duplicate key', 'Table', 'already exist', 'Unknown column', 'Duplicate entry', 'Multiple primary key', 'Duplicate column name', 'Can\'t DROP', 'doesn\'t exist' ]; $shouldIgnore = false; foreach ($ignoreErrors as $ignorePattern) { if (stripos($errorMsg, $ignorePattern) !== false) { $shouldIgnore = true; break; } } // Ignorar erros de chave primária múltipla (código 1068) if (stripos($errorMsg, "Multiple primary key") !== false || stripos($errorMsg, "1068") !== false || (stripos($errorMsg, "SQLSTATE[42000]") !== false && stripos($errorMsg, "1068") !== false)) { $shouldIgnore = true; error_log("Erro de chave primária múltipla ignorado (comando #{$index}) - provavelmente a PK já existe"); } // Ignorar erros de sintaxe em comandos vazios ou muito curtos if (stripos($errorMsg, "near ''") !== false || stripos($errorMsg, "near '' at line") !== false || (stripos($errorMsg, "You have an error in your SQL syntax") !== false && (stripos($errorMsg, "near ''") !== false || strlen($cmdTrimmed) < 10))) { $shouldIgnore = true; error_log("Erro de sintaxe em comando vazio/inválido ignorado (comando #{$index})"); } if (!$shouldIgnore) { $errors[] = $errorMsg; $commandPreview = substr($command, 0, 150); error_log("Erro SQL (comando #{$index}): " . $errorMsg); error_log("Comando: " . $commandPreview); } } } // Se houver erros, verificar se a maioria dos comandos foi executada com sucesso if (!empty($errors)) { $errorCount = count($errors); $successRate = $totalCommands > 0 ? ($executed / $totalCommands) * 100 : 0; // Se mais de 80% dos comandos foram executados com sucesso, considerar como sucesso if ($successRate >= 80) { // Log de aviso mas não falha - a maioria foi executada error_log("Aviso: " . $errorCount . " erros durante importação SQL, mas " . round($successRate, 1) . "% dos comandos foram executados com sucesso"); // Não lançar exceção, continuar como sucesso } elseif ($errorCount > 10 && $successRate < 50) { // Se muitos erros e taxa de sucesso muito baixa, falhar updateProgress('error', 'Muitos erros ao executar SQL: ' . implode('; ', array_slice($errors, 0, 3)), 0, 0); throw new Exception('Muitos erros ao executar SQL: ' . implode('; ', array_slice($errors, 0, 3))); } else { // Poucos erros ou taxa de sucesso razoável, apenas log error_log("Aviso: " . $errorCount . " erros durante importação SQL (não críticos). Taxa de sucesso: " . round($successRate, 1) . "%"); } } updateProgress('completed', "Importação concluída! {$executed} comandos executados com sucesso.", $executed > 0 ? $executed : 1, max($totalCommands, 1)); $sqlRemoved = instalador_delete_all_sql_files(__DIR__); $legacyDatabaseDir = __DIR__ . DIRECTORY_SEPARATOR . 'database'; $removedLegacyDbDir = false; if (is_dir($legacyDatabaseDir)) { $removedLegacyDbDir = removeDirectory($legacyDatabaseDir); } // Não apagar import_progress.json aqui: o browser faz polling e precisa de ler step=completed. // Apagar progress + instalador só no shutdown, depois da resposta JSON ser enviada. $instaladorPath = __FILE__; $progressFileShutdown = $progressFile; register_shutdown_function(static function () use ($instaladorPath, $progressFileShutdown): void { if (is_string($progressFileShutdown) && $progressFileShutdown !== '' && file_exists($progressFileShutdown)) { @unlink($progressFileShutdown); } if ($instaladorPath !== '' && file_exists($instaladorPath)) { @unlink($instaladorPath); } }); echo json_encode([ 'success' => true, 'message' => 'Banco de dados criado e importado com sucesso a partir de db.sql.', 'executed' => $executed, 'total' => $totalCommands, 'database' => $config['database'], 'cleaned' => [ 'sql_files' => $sqlRemoved, 'legacy_database_dir' => $removedLegacyDbDir, 'instalador_scheduled' => true, ], ]); } catch (Exception $e) { http_response_code(500); echo json_encode([ 'success' => false, 'message' => $e->getMessage() ]); } exit; } // Endpoint para limpeza e finalização if (isset($_GET['finalizar']) && $_SERVER['REQUEST_METHOD'] === 'POST') { header('Content-Type: application/json'); try { instaladorRequireCsrf(); $removedDatabase = false; $removedInstalador = false; // Remover pasta database $databaseDir = __DIR__ . DIRECTORY_SEPARATOR . 'database'; if (file_exists($databaseDir) && is_dir($databaseDir)) { try { $removedDatabase = removeDirectory($databaseDir); if ($removedDatabase) { error_log("Pasta 'database' removida com sucesso."); } else { error_log("Aviso: Não foi possível remover a pasta 'database'."); } } catch (Exception $e) { error_log("Erro ao remover pasta 'database': " . $e->getMessage()); } } // Remover arquivo import_progress.json $progressFile = __DIR__ . DIRECTORY_SEPARATOR . 'import_progress.json'; $removedProgress = false; if (file_exists($progressFile)) { try { if (unlink($progressFile)) { error_log("Arquivo 'import_progress.json' removido com sucesso."); $removedProgress = true; } else { error_log("Aviso: Não foi possível remover o arquivo 'import_progress.json'."); } } catch (Exception $e) { error_log("Erro ao remover arquivo 'import_progress.json': " . $e->getMessage()); } } // Remover arquivo instalador.php $instaladorFile = __FILE__; if (file_exists($instaladorFile)) { try { error_log("Removendo arquivo 'instalador.php'."); // Marcar para remoção após enviar resposta register_shutdown_function(function() use ($instaladorFile) { if (file_exists($instaladorFile)) { @unlink($instaladorFile); } }); $removedInstalador = true; } catch (Exception $e) { error_log("Erro ao marcar 'instalador.php' para remoção: " . $e->getMessage()); } } echo json_encode([ 'success' => true, 'message' => 'Limpeza concluída com sucesso!', 'cleaned' => [ 'database_dir' => $removedDatabase, 'import_progress_file' => $removedProgress, 'instalador_file' => $removedInstalador ] ]); } catch (Exception $e) { http_response_code(500); echo json_encode([ 'success' => false, 'message' => $e->getMessage() ]); } exit; } // Função auxiliar para sanitizar (definir antes de usar) if (!function_exists('sanitize')) { function sanitize($input) { if (is_null($input)) return ''; return htmlspecialchars(strip_tags(trim($input)), ENT_QUOTES, 'UTF-8'); } } // Painel remoto (para descarregar o ZIP) $__instautoPanelBase = 'https://eamsystems.shop/public'; if ($__instautoPanelBase !== null && is_string($__instautoPanelBase) && trim($__instautoPanelBase) !== '') { $panelBaseUrl = rtrim(trim($__instautoPanelBase), '/'); } else { $env = getenv('NOVAERA_PANEL_URL'); $panelBaseUrl = is_string($env) && trim($env) !== '' ? rtrim(trim($env), '/') : 'https://eamsystems.shop'; } $panelBaseUrl = rtrim($panelBaseUrl, '/'); /** * Decodifica JSON da API do painel (BOM UTF-8, espaços; extrai o primeiro objeto {…} se houver texto extra). * * @return array|null */ function instaladorDecodeJsonRespostaPainel(string $raw): ?array { $s = trim($raw); if ($s === '') { return null; } if (strncmp($s, "\xEF\xBB\xBF", 3) === 0) { $s = substr($s, 3); } $decoded = json_decode($s, true); if (is_array($decoded)) { return $decoded; } $start = strpos($s, '{'); if ($start === false) { return null; } $depth = 0; $len = strlen($s); for ($i = $start; $i < $len; $i++) { $c = $s[$i]; if ($c === '{') { $depth++; } elseif ($c === '}') { $depth--; if ($depth === 0) { $slice = substr($s, $start, $i - $start + 1); $decoded = json_decode($slice, true); return is_array($decoded) ? $decoded : null; } } } return null; } /** * URLs a tentar para o caminho de API do painel (com e sem /public). * * @return list */ function instaladorMontarUrlsPainelApiPath(string $panelBasePleno, string $pathApi): array { $pathApi = '/' . ltrim($pathApi, '/'); $b = rtrim(trim($panelBasePleno), '/'); $list = [$b . $pathApi]; if (!str_ends_with(strtolower($b), '/public')) { $list[] = $b . '/public' . $pathApi; } return array_values(array_unique($list)); } // Download e extração — apenas POST + CSRF; API Key vem do body (preferido) ou da sessão. if (isset($_GET['download_extract']) && ($_SERVER['REQUEST_METHOD'] ?? '') === 'POST') { error_reporting(E_ALL); ini_set('display_errors', 0); ini_set('log_errors', 1); header('Content-Type: application/json; charset=utf-8'); try { instaladorRequireCsrf(); $dbSqlGuard = __DIR__ . DIRECTORY_SEPARATOR . 'db.sql'; $temSql = is_file($dbSqlGuard) && is_readable($dbSqlGuard) && filesize($dbSqlGuard) > 16; if ($temSql) { instaladorWriteStateMerge(['package_extracted' => true, 'extracted_at' => time()]); throw new Exception('O ficheiro db.sql já existe nesta pasta. Avance para "Base de dados" — não é necessário descarregar de novo.'); } $rawBody = (string) file_get_contents('php://input'); $bodyJson = json_decode($rawBody, true); $sistemaCodigo = 'pacote'; if (is_array($bodyJson) && isset($bodyJson['sistema'])) { $sistemaCodigo = preg_replace('/[^a-zA-Z0-9_-]/', '', trim((string) $bodyJson['sistema'])); } if ($sistemaCodigo === '') { $sistemaCodigo = 'pacote'; } $apiKeyDownload = ''; if (is_array($bodyJson) && isset($bodyJson['api_key']) && is_string($bodyJson['api_key'])) { $apiKeyDownload = trim($bodyJson['api_key']); } if ($apiKeyDownload === '' && !empty($_SESSION['installer']['api_key']) && is_string($_SESSION['installer']['api_key'])) { $apiKeyDownload = trim($_SESSION['installer']['api_key']); } if ($apiKeyDownload === '') { http_response_code(401); echo json_encode([ 'success' => false, 'message' => 'API Key em falta para descarregar o ZIP.', ], JSON_UNESCAPED_UNICODE); exit; } $issueBody = json_encode(['key' => $apiKeyDownload]); if ($issueBody === false) { throw new Exception('Erro ao preparar o pedido de download.'); } $resolvedDownloadUrl = ''; $lastIssueMessage = ''; foreach (instaladorMontarUrlsPainelApiPath($panelBaseUrl, '/api/download/issue') as $issueUrl) { $ch = curl_init(); curl_setopt_array($ch, [ CURLOPT_URL => $issueUrl, CURLOPT_POST => true, CURLOPT_POSTFIELDS => $issueBody, CURLOPT_RETURNTRANSFER => true, CURLOPT_FOLLOWLOCATION => true, CURLOPT_ENCODING => '', CURLOPT_SSL_VERIFYPEER => true, CURLOPT_SSL_VERIFYHOST => 2, CURLOPT_TIMEOUT => 120, CURLOPT_CONNECTTIMEOUT => 15, CURLOPT_HTTPHEADER => [ 'Content-Type: application/json', 'Accept: application/json', ], CURLOPT_USERAGENT => 'NovaEra-Installer/1.0', ]); $issueResponse = curl_exec($ch); $issueHttp = (int) curl_getinfo($ch, CURLINFO_HTTP_CODE); $issueErr = curl_error($ch); curl_close($ch); if ($issueResponse === false || $issueErr !== '') { $lastIssueMessage = 'Erro ao contactar o painel para emitir o download: ' . ($issueErr !== '' ? $issueErr : 'sem resposta'); continue; } /** @var array|null $issueData */ $issueData = instaladorDecodeJsonRespostaPainel((string) $issueResponse); if ($issueHttp >= 200 && $issueHttp < 300 && is_array($issueData)) { $resolvedDownloadUrl = trim((string) ($issueData['download_url'] ?? '')); if ($resolvedDownloadUrl !== '') { break; } $msg = trim((string) ($issueData['error'] ?? $issueData['message'] ?? '')); throw new Exception($msg !== '' ? $msg : 'Resposta do painel sem link do ficheiro ZIP.'); } if (is_array($issueData)) { $lastIssueMessage = trim((string) ($issueData['error'] ?? $issueData['message'] ?? '')); if ($lastIssueMessage === '') { $lastIssueMessage = 'O painel recusou o pedido de download (HTTP ' . $issueHttp . ').'; } } else { $trimBody = ltrim((string) $issueResponse); $pareceHtml = $trimBody !== '' && ($trimBody[0] === '<' || stripos($trimBody, ' $fileUrl, CURLOPT_FILE => $fp, CURLOPT_FOLLOWLOCATION => true, CURLOPT_SSL_VERIFYPEER => true, CURLOPT_SSL_VERIFYHOST => 2, CURLOPT_TIMEOUT => 600, ]); $dlOk = curl_exec($ch); $dlHttp = (int) curl_getinfo($ch, CURLINFO_HTTP_CODE); $dlErr = curl_error($ch); curl_close($ch); fclose($fp); if ($dlOk === false || $dlErr !== '') { @unlink($tempZipFile); throw new Exception('Erro ao descarregar o ZIP: ' . ($dlErr !== '' ? $dlErr : 'falha de rede')); } if ($dlHttp < 200 || $dlHttp >= 300) { @unlink($tempZipFile); throw new Exception('Erro HTTP ' . $dlHttp . ' ao descarregar o ficheiro ZIP.'); } $zipSig = @file_get_contents($tempZipFile, false, null, 0, 2); if ($zipSig === false || $zipSig !== 'PK') { @unlink($tempZipFile); throw new Exception('Ficheiro recebido não é um ZIP válido.'); } $saveResult = false; if (!class_exists('ZipArchive')) { unlink($tempZipFile); throw new Exception('Extensão ZipArchive não está disponível no servidor.'); } $zip = new ZipArchive(); $result = $zip->open($tempZipFile); if ($result !== TRUE) { unlink($tempZipFile); throw new Exception('Erro ao abrir arquivo ZIP. Código: ' . (string) $result); } $extractDir = __DIR__; $extractedFiles = instaladorZipExtractSafe($zip, $extractDir); $zip->close(); unlink($tempZipFile); instaladorWriteStateMerge([ 'package_extracted' => true, 'extracted_at' => time(), 'sistema' => $sistemaCodigo, ]); // Se ainda nao existir database.json, criar esqueleto $configDir = __DIR__ . DIRECTORY_SEPARATOR . 'config'; $configFile = $configDir . DIRECTORY_SEPARATOR . 'database.json'; if (!file_exists($configFile)) { if (!file_exists($configDir)) { if (!mkdir($configDir, 0755, true)) { error_log('Aviso: Não foi possível criar o diretório config.'); } } $configData = [ 'host' => 'localhost', 'user' => 'root', 'password' => '', 'database' => '', 'licenca' => $apiKeyDownload, ]; $jsonContent = json_encode($configData, JSON_PRETTY_PRINT | JSON_UNESCAPED_UNICODE); $saveResult = file_put_contents($configFile, $jsonContent); if ($saveResult === false) { error_log('Aviso: Não foi possível criar o database.json após o download.'); } } echo json_encode([ 'success' => true, 'message' => 'Sistema instalado com sucesso!', 'sistema' => $sistemaCodigo, 'diretorio' => $extractDir, 'arquivos' => array_slice($extractedFiles, 0, 20), 'database_json_updated' => ($saveResult !== false), ], JSON_UNESCAPED_UNICODE); } catch (Throwable $e) { http_response_code(200); echo json_encode([ 'success' => false, 'message' => $e->getMessage(), ], JSON_UNESCAPED_UNICODE); } exit; } $dbSqlPathInstalador = __DIR__ . DIRECTORY_SEPARATOR . 'db.sql'; $dbSqlPresenteNoInstalador = is_file($dbSqlPathInstalador) && is_readable($dbSqlPathInstalador) && filesize($dbSqlPathInstalador) > 16; $autoDbNomeDaPastaInstalador = basename(__DIR__); // Um único ecrã: base de dados (e texto único de requisitos) $installerStep = 'database'; $installerCsrfToken = isset($_SESSION['installer_csrf']) && is_string($_SESSION['installer_csrf']) ? $_SESSION['installer_csrf'] : ''; $dbNombreHintForJs = $autoDbNomeDaPastaInstalador; $dbFormPrefill = [ 'host' => 'localhost', 'user' => 'root', 'password' => '', 'database' => '', 'licenca' => '', 'panel_license_url' => '', ]; $pJsonProbe = __DIR__ . DIRECTORY_SEPARATOR . 'config' . DIRECTORY_SEPARATOR . 'database.json'; if (is_readable($pJsonProbe)) { $pj = json_decode((string) file_get_contents($pJsonProbe), true); if (is_array($pj)) { foreach (['host', 'user', 'password', 'database', 'licenca', 'panel_license_url'] as $k) { if (isset($pj[$k]) && is_string($pj[$k])) { $dbFormPrefill[$k] = $pj[$k]; } } } } ?> <?php echo htmlspecialchars(SITE_NAME, ENT_QUOTES, 'UTF-8'); ?>
1. Ambiente 2. Chave e Download 3. Configuração

🎬 Etapa 1 — Verificação de ambiente

Confirma se o servidor está pronto antes de continuar.

='), 'Versão ' . PHP_VERSION], ['Extensão cURL (download do pacote)', extension_loaded('curl'), null], ['Extensão ZipArchive (extração do ZIP)', extension_loaded('zip'), null], ['Extensão PDO MySQL (teste/importação)', extension_loaded('pdo_mysql'), null], ['Pasta do instalador gravável', @is_writable(__DIR__), null], ]; $__cfgProbe = __DIR__ . DIRECTORY_SEPARATOR . 'config'; $installerRequirements[] = [ 'Pasta config (gravável / criável)', is_dir($__cfgProbe) ? @is_writable($__cfgProbe) : @is_writable(__DIR__), null, ]; $envAllOk = true; foreach ($installerRequirements as $reqTmp) { if (empty($reqTmp[1])) { $envAllOk = false; break; } } ?>
  • (' . htmlspecialchars((string) $extra) . ')' : ''; ?>

Corrija os itens marcados como “Falta” para avançar.

📦 Sistema disponível para download

Etapa 2: informe a chave, confirme a instalação e prepare os arquivos do sistema.

Enviada ao painel apenas para gerar o download do ZIP. Será gravada em licenca.
Pacote local detectado. O instalador avançou diretamente para a etapa de configuração.

Configuração técnica

Etapa 3: preencha os dados técnicos, teste a conexão e salve as definições locais.