' . $sql_log . '
-
- | ' . ($dbg['src'] ?? $dbg['trace']) . ' [' . sprintf('%.3f', $dbg['time']) . ' s] ' . $this->db->query_info() . ' |
- ' . "[{$this->db->engine}] {$this->db->db_server}.{$this->db->selected_db}" . ' :: Query #' . ($this->db->num_queries + 1) . ' |
-
- | ' . $this->explain_hold . ' |
-
- ';
- foreach (array_keys($row) as $val) {
- $this->explain_hold .= '| ' . htmlspecialchars($val) . ' | ';
- }
- $this->explain_hold .= '
';
- }
- $this->explain_hold .= '';
- foreach (array_values($row) as $i => $val) {
- $class = !($i % 2) ? 'row1' : 'row2';
- $this->explain_hold .= '' . str_replace(["{$this->db->selected_db}.", ',', ';'], ['', ', ', ';
'], htmlspecialchars($val ?? '')) . ' | ';
- }
- $this->explain_hold .= '
';
-
- return $html_table;
-
- case 'display':
- echo '' . $this->explain_out . '
';
- break;
- }
-
- return false;
- }
-
- /**
- * Get debug statistics for display
- */
- public function getDebugStats(): array
- {
- return [
- 'num_queries' => count($this->dbg),
- 'sql_timetotal' => $this->db->sql_timetotal,
- 'queries' => $this->dbg,
- 'explain_out' => $this->explain_out
- ];
- }
-
- /**
- * Clear debug data
- */
- public function clearDebugData(): void
- {
- $this->dbg = [];
- $this->dbg_id = 0;
- $this->explain_hold = '';
- $this->explain_out = '';
- }
-
- /**
- * Mark next query as coming from Nette Explorer
- */
- public function markAsNetteExplorerQuery(): void
- {
- $this->is_nette_explorer_query = true;
- }
-
- /**
- * Reset Nette Explorer query flag
- */
- public function resetNetteExplorerFlag(): void
- {
- $this->is_nette_explorer_query = false;
- }
-}
diff --git a/legacy/src/Database/DatabaseFactory.php b/legacy/src/Database/DatabaseFactory.php
deleted file mode 100644
index 203c95961..000000000
--- a/legacy/src/Database/DatabaseFactory.php
+++ /dev/null
@@ -1,101 +0,0 @@
-close();
- }
- }
- self::$instances = [];
- Database::destroyInstances();
- }
-}
\ No newline at end of file
diff --git a/legacy/src/Database/DebugSelection.php b/legacy/src/Database/DebugSelection.php
deleted file mode 100644
index 7968c9dfb..000000000
--- a/legacy/src/Database/DebugSelection.php
+++ /dev/null
@@ -1,295 +0,0 @@
-selection = $selection;
- $this->db = $db;
- }
-
- /**
- * Magic method to delegate calls to the wrapped Selection
- */
- public function __call(string $name, array $arguments)
- {
- $result = call_user_func_array([$this->selection, $name], $arguments);
-
- // If result is another Selection, wrap it too
- if ($result instanceof Selection) {
- return new self($result, $this->db);
- }
-
- return $result;
- }
-
- /**
- * Magic method to delegate property access
- */
- public function __get(string $name)
- {
- return $this->selection->$name;
- }
-
- /**
- * Magic method to delegate property setting
- */
- public function __set(string $name, $value): void
- {
- $this->selection->$name = $value;
- }
-
- /**
- * Magic method to check if property is set
- */
- public function __isset(string $name): bool
- {
- return isset($this->selection->$name);
- }
-
- /**
- * Log query execution for debug panel
- */
- private function logQuery(string $method, array $arguments): void
- {
- if (!defined('SQL_DEBUG') || !SQL_DEBUG) {
- return;
- }
-
- // Use the actual SQL with substituted parameters for both logging and EXPLAIN
- $sql = $this->generateSqlForLogging($method, $arguments, false);
-
- // Mark this query as coming from Nette Explorer
- $this->db->debugger->markAsNetteExplorerQuery();
-
- // Set the query for debug logging
- $this->db->cur_query = $sql;
- $this->db->debug('start');
- }
-
- /**
- * Complete query logging after execution
- */
- private function completeQueryLogging(): void
- {
- if (!defined('SQL_DEBUG') || !SQL_DEBUG) {
- return;
- }
-
- // Note: explain('stop') is automatically called by debug('stop') when do_explain is true
- $this->db->debug('stop');
- }
-
- /**
- * Generate SQL representation for logging and EXPLAIN
- */
- private function generateSqlForLogging(string $method, array $arguments, bool $useRawSQL = true): string
- {
- // For SELECT operations, try to get the SQL from Nette
- if (in_array($method, ['fetch', 'fetchAll', 'count'], true)) {
- $sql = $useRawSQL ? $this->getSqlFromSelection() : $this->getSqlFromSelection(true);
-
- // Modify the SQL based on the method
- switch ($method) {
- case 'fetch':
- // If it doesn't already have LIMIT, add it
- if (!preg_match('/LIMIT\s+\d+/i', $sql)) {
- $sql .= ' LIMIT 1';
- }
- return $sql;
- case 'count':
- // Replace SELECT * with SELECT COUNT(*)
- return preg_replace('/^SELECT\s+\*/i', 'SELECT COUNT(*)', $sql);
- case 'fetchAll':
- default:
- return $sql;
- }
- }
-
- // For INSERT/UPDATE/DELETE, generate appropriate SQL
- $tableName = $this->selection->getName();
-
- return match ($method) {
- 'insert' => $this->generateInsertSql($tableName, $arguments),
- 'update' => $this->generateUpdateSql($tableName, $arguments, $useRawSQL),
- 'delete' => $this->generateDeleteSql($tableName, $useRawSQL),
- default => "-- Explorer method: {$method} on {$tableName}"
- };
- }
-
- /**
- * Generate INSERT SQL statement
- */
- private function generateInsertSql(string $tableName, array $arguments): string
- {
- if (!isset($arguments[0]) || !is_array($arguments[0])) {
- return "INSERT INTO {$tableName} (...) VALUES (...)";
- }
-
- $data = $arguments[0];
- $columns = implode(', ', array_keys($data));
- $values = implode(', ', array_map(
- static fn($v) => is_string($v) ? "'$v'" : $v,
- array_values($data)
- ));
-
- return "INSERT INTO {$tableName} ({$columns}) VALUES ({$values})";
- }
-
- /**
- * Generate UPDATE SQL statement
- */
- private function generateUpdateSql(string $tableName, array $arguments, bool $useRawSQL): string
- {
- $setPairs = [];
- if (isset($arguments[0]) && is_array($arguments[0])) {
- foreach ($arguments[0] as $key => $value) {
- $setPairs[] = "{$key} = " . (is_string($value) ? "'$value'" : $value);
- }
- }
-
- $setClause = !empty($setPairs) ? implode(', ', $setPairs) : '...';
- $sql = $this->getSqlFromSelection(!$useRawSQL);
-
- // Extract WHERE clause from the SQL
- if (preg_match('/WHERE\s+(.+?)(?:\s+ORDER\s+BY|\s+LIMIT|\s+GROUP\s+BY|$)/i', $sql, $matches)) {
- return "UPDATE {$tableName} SET {$setClause} WHERE " . trim($matches[1]);
- }
-
- return "UPDATE {$tableName} SET {$setClause}";
- }
-
- /**
- * Generate DELETE SQL statement
- */
- private function generateDeleteSql(string $tableName, bool $useRawSQL): string
- {
- $sql = $this->getSqlFromSelection(!$useRawSQL);
-
- // Extract WHERE clause from the SQL
- if (preg_match('/WHERE\s+(.+?)(?:\s+ORDER\s+BY|\s+LIMIT|\s+GROUP\s+BY|$)/i', $sql, $matches)) {
- return "DELETE FROM {$tableName} WHERE " . trim($matches[1]);
- }
-
- return "DELETE FROM {$tableName}";
- }
-
- /**
- * Get SQL from Nette Selection with optional parameter substitution
- */
- private function getSqlFromSelection(bool $replaceParameters = false): string
- {
- try {
- $reflectionClass = new ReflectionClass($this->selection);
- $sql = '';
-
- // Try getSql() method first
- if ($reflectionClass->hasMethod('getSql')) {
- $getSqlMethod = $reflectionClass->getMethod('getSql');
- $getSqlMethod->setAccessible(true);
- $sql = $getSqlMethod->invoke($this->selection);
- } else {
- // Try __toString() method as fallback
- $sql = (string)$this->selection;
- }
-
- // For EXPLAIN to work, we need to replace ? with actual values
- if ($replaceParameters) {
- $sql = preg_replace('/\?/', '1', $sql);
- }
-
- return $sql;
- } catch (Exception $e) {
- // Fall back to simple representation
- return "SELECT * FROM " . $this->selection->getName() . " WHERE 1=1";
- }
- }
-
- // Delegate common Selection methods with logging
- public function where(...$args): self
- {
- return new self($this->selection->where(...$args), $this->db);
- }
-
- public function order(...$args): self
- {
- return new self($this->selection->order(...$args), $this->db);
- }
-
- public function select(...$args): self
- {
- return new self($this->selection->select(...$args), $this->db);
- }
-
- public function limit(...$args): self
- {
- return new self($this->selection->limit(...$args), $this->db);
- }
-
- public function fetch()
- {
- $this->logQuery('fetch', []);
- $result = $this->selection->fetch();
- $this->completeQueryLogging();
- return $result;
- }
-
- public function fetchAll(): array
- {
- $this->logQuery('fetchAll', []);
- $result = $this->selection->fetchAll();
- $this->completeQueryLogging();
- return $result;
- }
-
- public function insert($data)
- {
- $this->logQuery('insert', [$data]);
- $result = $this->selection->insert($data);
- $this->completeQueryLogging();
- return $result;
- }
-
- public function update($data): int
- {
- $this->logQuery('update', [$data]);
- $result = $this->selection->update($data);
- $this->completeQueryLogging();
- return $result;
- }
-
- public function delete(): int
- {
- $this->logQuery('delete', []);
- $result = $this->selection->delete();
- $this->completeQueryLogging();
- return $result;
- }
-
- public function count(): int
- {
- $this->logQuery('count', []);
- $result = $this->selection->count();
- $this->completeQueryLogging();
- return $result;
- }
-}
diff --git a/legacy/src/Database/MigrationStatus.php b/legacy/src/Database/MigrationStatus.php
deleted file mode 100644
index ed73e038a..000000000
--- a/legacy/src/Database/MigrationStatus.php
+++ /dev/null
@@ -1,305 +0,0 @@
-migrationTable = BB_MIGRATIONS;
- $this->migrationPath = BB_ROOT . 'migrations';
- }
-
- /**
- * Get complete migration status information
- *
- * @return array Migration status data including applied/pending migrations
- */
- public function getMigrationStatus(): array
- {
- try {
- // Check if migration table exists using Nette Database Explorer
- $tableExists = $this->checkMigrationTableExists();
- $setupStatus = $this->getSetupStatus();
-
- if (!$tableExists) {
- return [
- 'table_exists' => false,
- 'current_version' => null,
- 'applied_migrations' => [],
- 'pending_migrations' => $this->getAvailableMigrations(),
- 'setup_status' => $setupStatus,
- 'requires_setup' => $setupStatus['needs_setup']
- ];
- }
-
- // Get applied migrations using Nette Database Explorer
- $appliedMigrations = DB()->query("
- SELECT version, migration_name, start_time, end_time
- FROM {$this->migrationTable}
- ORDER BY version ASC
- ")->fetchAll();
-
- // Convert Nette Result objects to arrays
- $appliedMigrationsArray = [];
- foreach ($appliedMigrations as $migration) {
- $appliedMigrationsArray[] = [
- 'version' => $migration->version,
- 'migration_name' => $migration->migration_name,
- 'start_time' => $migration->start_time,
- 'end_time' => $migration->end_time
- ];
- }
-
- // Get current version (latest applied)
- $currentVersion = null;
- if (!empty($appliedMigrationsArray)) {
- $currentVersion = end($appliedMigrationsArray)['version'];
- }
-
- // Get pending migrations
- $availableMigrations = $this->getAvailableMigrations();
- $appliedVersions = array_column($appliedMigrationsArray, 'version');
- $pendingMigrations = array_filter($availableMigrations, function ($migration) use ($appliedVersions) {
- return !in_array($migration['version'], $appliedVersions);
- });
-
- return [
- 'table_exists' => true,
- 'current_version' => $currentVersion,
- 'applied_migrations' => $appliedMigrationsArray,
- 'pending_migrations' => array_values($pendingMigrations),
- 'setup_status' => $setupStatus,
- 'requires_setup' => $setupStatus['needs_setup']
- ];
-
- } catch (\Exception $e) {
- bb_die('Error checking migration status: ' . $e->getMessage());
- }
- }
-
- /**
- * Determine setup status for existing installations
- *
- * @return array Setup status information
- */
- private function getSetupStatus(): array
- {
- try {
- // Check if core TorrentPier tables exist (indicates existing installation)
- $coreTablesExist = $this->checkCoreTablesExist();
- $migrationTableExists = $this->checkMigrationTableExists();
-
- if (!$coreTablesExist) {
- // Fresh installation
- return [
- 'type' => 'fresh',
- 'needs_setup' => false,
- 'message' => 'Fresh installation - migrations will run normally',
- 'action_required' => false
- ];
- }
-
- if (!$migrationTableExists) {
- // Existing installation without migration system
- return [
- 'type' => 'existing_needs_setup',
- 'needs_setup' => true,
- 'message' => 'Existing installation detected - migration setup required',
- 'action_required' => true,
- 'instructions' => 'Mark initial migrations as applied using --fake flag'
- ];
- }
-
- // Check if initial migrations are marked as applied
- $initialMigrationsApplied = $this->checkInitialMigrationsApplied();
-
- if (!$initialMigrationsApplied) {
- return [
- 'type' => 'existing_partial_setup',
- 'needs_setup' => true,
- 'message' => 'Migration table exists but initial migrations not marked as applied',
- 'action_required' => true,
- 'instructions' => 'Run: php vendor/bin/phinx migrate --fake --target=20250619000002'
- ];
- }
-
- // Fully set up
- return [
- 'type' => 'fully_setup',
- 'needs_setup' => false,
- 'message' => 'Migration system fully configured',
- 'action_required' => false
- ];
-
- } catch (\Exception $e) {
- return [
- 'type' => 'error',
- 'needs_setup' => false,
- 'message' => 'Error detecting setup status: ' . $e->getMessage(),
- 'action_required' => false
- ];
- }
- }
-
- /**
- * Check if core TorrentPier tables exist
- *
- * @return bool True if core tables exist
- */
- private function checkCoreTablesExist(): bool
- {
- try {
- $coreTable = 'bb_users'; // Key table that should exist in any TorrentPier installation
- $escapedTable = DB()->escape($coreTable);
- $result = DB()->query("
- SELECT COUNT(*) as table_count
- FROM information_schema.tables
- WHERE table_schema = DATABASE()
- AND table_name = '{$escapedTable}'
- ")->fetch();
-
- return $result && $result->table_count > 0;
- } catch (\Exception $e) {
- return false;
- }
- }
-
- /**
- * Check if initial migrations are marked as applied
- *
- * @return bool True if initial migrations are applied
- */
- private function checkInitialMigrationsApplied(): bool
- {
- try {
- $initialMigrationsCSV = implode(',', $this->initialMigrations);
- $result = DB()->query("
- SELECT COUNT(*) as migration_count
- FROM {$this->migrationTable}
- WHERE version IN ($initialMigrationsCSV)
- ")->fetch();
-
- return $result && $result->migration_count >= count($this->initialMigrations);
- } catch (\Exception $e) {
- return false;
- }
- }
-
- /**
- * Check if migration table exists
- *
- * @return bool True if table exists, false otherwise
- */
- private function checkMigrationTableExists(): bool
- {
- try {
- // Using simple query without parameters to avoid issues
- $escapedTable = DB()->escape($this->migrationTable);
- $result = DB()->query("
- SELECT COUNT(*) as table_count
- FROM information_schema.tables
- WHERE table_schema = DATABASE()
- AND table_name = '{$escapedTable}'
- ")->fetch();
-
- return $result && $result->table_count > 0;
- } catch (\Exception $e) {
- return false;
- }
- }
-
- /**
- * Get available migrations from filesystem
- *
- * @return array List of available migration files
- */
- private function getAvailableMigrations(): array
- {
- $migrations = [];
-
- if (is_dir($this->migrationPath)) {
- $files = glob($this->migrationPath . '/*.php');
- foreach ($files as $file) {
- $filename = basename($file);
- if (preg_match('/^(\d+)_(.+)\.php$/', $filename, $matches)) {
- $migrations[] = [
- 'version' => $matches[1],
- 'name' => $matches[2],
- 'filename' => $filename,
- 'file_path' => $file
- ];
- }
- }
- }
-
- // Sort by version
- usort($migrations, function ($a, $b) {
- return strcmp($a['version'], $b['version']);
- });
-
- return $migrations;
- }
-
- /**
- * Get database schema information
- *
- * @return array Database statistics and information
- */
- public function getSchemaInfo(): array
- {
- try {
- // Get database name using Nette Database Explorer
- $dbInfo = DB()->query("SELECT DATABASE() as db_name")->fetch();
-
- // Get table count using Nette Database Explorer
- $tableInfo = DB()->query("
- SELECT COUNT(*) as table_count
- FROM information_schema.tables
- WHERE table_schema = DATABASE()
- ")->fetch();
-
- // Get database size using Nette Database Explorer
- $sizeInfo = DB()->query("
- SELECT
- ROUND(SUM(data_length + index_length) / 1024 / 1024, 2) as size_mb
- FROM information_schema.tables
- WHERE table_schema = DATABASE()
- ")->fetch();
-
- return [
- 'database_name' => $dbInfo->db_name ?? 'Unknown',
- 'table_count' => $tableInfo->table_count ?? 0,
- 'size_mb' => $sizeInfo->size_mb ?? 0
- ];
-
- } catch (\Exception $e) {
- return [
- 'database_name' => 'Unknown',
- 'table_count' => 0,
- 'size_mb' => 0,
- 'error' => $e->getMessage()
- ];
- }
- }
-}
diff --git a/legacy/src/Dev.php b/legacy/src/Dev.php
deleted file mode 100644
index 8348c52f6..000000000
--- a/legacy/src/Dev.php
+++ /dev/null
@@ -1,442 +0,0 @@
-whoops = new Run;
-
- if ($this->isDebugEnabled()) {
- $this->getWhoopsOnPage();
- } else {
- $this->getWhoopsPlaceholder();
- }
- $this->getWhoopsLogger();
-
- if (!$this->isDevelopmentEnvironment()) {
- $this->getTelegramSender();
- $this->getBugsnag();
- }
-
- $this->whoops->register();
- }
-
- /**
- * Get the singleton instance of Dev
- */
- public static function getInstance(): Dev
- {
- if (self::$instance === null) {
- self::$instance = new self();
- }
- return self::$instance;
- }
-
- /**
- * Initialize the dev system (for compatibility)
- */
- public static function init(): Dev
- {
- return self::getInstance();
- }
-
- /**
- * [Whoops] Bugsnag handler
- *
- * @return void
- */
- private function getBugsnag(): void
- {
- if (!config()->get('bugsnag.enabled')) {
- return;
- }
-
- $bugsnag = Client::make(config()->get('bugsnag.api_key'));
- $this->whoops->pushHandler(function ($e) use ($bugsnag) {
- $bugsnag->notifyException($e);
- });
- }
-
- /**
- * [Whoops] Telegram handler
- *
- * @return void
- */
- private function getTelegramSender(): void
- {
- if (!config()->get('telegram_sender.enabled')) {
- return;
- }
-
- $telegramSender = new PlainTextHandler();
- $telegramSender->loggerOnly(true);
- $telegramSender->setLogger((new Logger(
- APP_NAME,
- [(new TelegramHandler(config()->get('telegram_sender.token'), (int)config()->get('telegram_sender.chat_id'), timeout: (int)config()->get('telegram_sender.timeout')))
- ->setFormatter(new TelegramFormatter())]
- )));
- $this->whoops->pushHandler($telegramSender);
- }
-
- /**
- * [Whoops] On page handler (in debug)
- *
- * @return void
- */
- private function getWhoopsOnPage(): void
- {
- /**
- * Show errors on page with enhanced database information
- */
- $prettyPageHandler = new \TorrentPier\Whoops\EnhancedPrettyPageHandler();
- foreach (config()->get('whoops.blacklist', []) as $key => $secrets) {
- foreach ($secrets as $secret) {
- $prettyPageHandler->blacklist($key, $secret);
- }
- }
- $this->whoops->pushHandler($prettyPageHandler);
-
- /**
- * Show log in browser console
- */
- $loggingInConsole = new PlainTextHandler();
- $loggingInConsole->loggerOnly(true);
- $loggingInConsole->setLogger((new Logger(
- APP_NAME,
- [(new BrowserConsoleHandler())
- ->setFormatter((new LineFormatter(null, null, true)))]
- )));
- $this->whoops->pushHandler($loggingInConsole);
- }
-
- /**
- * [Whoops] Logger handler
- *
- * @return void
- */
- private function getWhoopsLogger(): void
- {
- if ((int)ini_get('log_errors') !== 1) {
- return;
- }
-
- $loggingInFile = new PlainTextHandler();
- $loggingInFile->loggerOnly(true);
- $loggingInFile->setLogger((new Logger(
- APP_NAME,
- [(new StreamHandler(WHOOPS_LOG_FILE))
- ->setFormatter((new LineFormatter(null, null, true)))]
- )));
- $this->whoops->pushHandler($loggingInFile);
- }
-
- /**
- * [Whoops] Placeholder handler (non debug)
- *
- * @return void
- */
- private function getWhoopsPlaceholder(): void
- {
- $this->whoops->pushHandler(function ($e) {
- echo config()->get('whoops.error_message');
- echo "
Error: {$e->getMessage()}.";
- });
- }
-
- /**
- * Get SQL debug log (instance method)
- *
- * @return string
- * @throws Exception
- */
- public function getSqlLogInstance(): string
- {
- $log = '';
- $totalLegacyQueries = 0;
-
- // Check for legacy queries across all database instances
- $server_names = \TorrentPier\Database\DatabaseFactory::getServerNames();
- foreach ($server_names as $srv_name) {
- try {
- $db_obj = \TorrentPier\Database\DatabaseFactory::getInstance($srv_name);
- if (!empty($db_obj->debugger->legacy_queries)) {
- $totalLegacyQueries += count($db_obj->debugger->legacy_queries);
- }
- } catch (\Exception $e) {
- // Skip if server not available
- }
- }
-
- // Add warning banner if legacy queries were detected
- if ($totalLegacyQueries > 0) {
- $log .= ''
- . '⚠️ Legacy Query Warning: '
- . $totalLegacyQueries . ' quer' . ($totalLegacyQueries > 1 ? 'ies' : 'y') . ' with duplicate columns detected and automatically fixed. '
- . 'These queries should be updated to explicitly select columns. '
- . 'Check the legacy_queries.log file for details.'
- . '
';
- }
-
- // Get debug information from new database system
- foreach ($server_names as $srv_name) {
- try {
- $db_obj = \TorrentPier\Database\DatabaseFactory::getInstance($srv_name);
- $log .= !empty($db_obj->dbg) ? $this->getSqlLogHtml($db_obj, "database: $srv_name [{$db_obj->engine}]") : '';
- } catch (\Exception $e) {
- // Skip if server not available
- }
- }
-
- // Get cache system debug information
- $cacheSystem = \TorrentPier\Cache\UnifiedCacheSystem::getInstance();
- $cacheObjects = $cacheSystem->obj; // Uses magic __get method for backward compatibility
-
- foreach ($cacheObjects as $cache_name => $cache_obj) {
- if (!empty($cache_obj->db->dbg)) {
- $log .= $this->getSqlLogHtml($cache_obj->db, "cache: $cache_name [{$cache_obj->db->engine}]");
- } elseif (!empty($cache_obj->dbg)) {
- $log .= $this->getSqlLogHtml($cache_obj, "cache: $cache_name [{$cache_obj->engine}]");
- }
- }
-
- // Get datastore debug information
- $datastore = datastore();
- if (!empty($datastore->db->dbg)) {
- $log .= $this->getSqlLogHtml($datastore->db, "cache: datastore [{$datastore->db->engine}]");
- } elseif (!empty($datastore->dbg)) {
- $log .= $this->getSqlLogHtml($datastore, "cache: datastore [{$datastore->engine}]");
- }
-
- return $log;
- }
-
- /**
- * Sql debug status (instance method)
- *
- * @return bool
- */
- public function sqlDebugAllowedInstance(): bool
- {
- return (SQL_DEBUG && DBG_USER && !empty($_COOKIE['sql_log']));
- }
-
- /**
- * Get SQL query html log
- *
- * @param object $db_obj
- * @param string $log_name
- *
- * @return string
- * @throws Exception
- */
- private function getSqlLogHtml(object $db_obj, string $log_name): string
- {
- $log = '';
-
- foreach ($db_obj->dbg as $i => $dbg) {
- $id = "sql_{$i}_" . random_int(0, mt_getrandmax());
- $sql = $this->shortQueryInstance($dbg['sql'], true);
- $time = sprintf('%.3f', $dbg['time']);
- $perc = '[' . round($dbg['time'] * 100 / $db_obj->sql_timetotal) . '%]';
- // Use plain text version for title attribute to avoid HTML issues
- $info_plain = !empty($dbg['info_plain']) ? $dbg['info_plain'] . ' [' . $dbg['src'] . ']' : $dbg['src'];
- $info = !empty($dbg['info']) ? $dbg['info'] . ' [' . $dbg['src'] . ']' : $dbg['src'];
-
- // Check if this is a legacy query that needed compatibility fix
- $isLegacyQuery = !empty($dbg['is_legacy_query']);
- $rowClass = $isLegacyQuery ? 'sqlLogRow sqlLegacyRow' : 'sqlLogRow';
- $rowStyle = $isLegacyQuery ? ' style="background-color: #ffe6e6; border-left: 4px solid #dc3545; color: #721c24;"' : '';
- $legacyWarning = $isLegacyQuery ? '[LEGACY]' : '';
-
- $log .= ''
- . $legacyWarning
- . '' . $time . ' '
- . '' . $perc . ' '
- . '' . $sql . ''
- . ' # ' . $info . ' '
- . '
';
- }
-
- return '' . $log_name . '
' . $log;
- }
-
- /**
- * Short query (instance method)
- *
- * @param string $sql
- * @param bool $esc_html
- * @return string
- */
- public function shortQueryInstance(string $sql, bool $esc_html = false): string
- {
- $max_len = 100;
- $sql = str_compact($sql);
-
- if (!empty($_COOKIE['sql_log_full'])) {
- if (mb_strlen($sql, DEFAULT_CHARSET) > $max_len) {
- $sql = mb_substr($sql, 0, 50) . ' [...cut...] ' . mb_substr($sql, -50);
- }
- }
-
- return $esc_html ? htmlCHR($sql, true) : $sql;
- }
-
- // Static methods for backward compatibility (proxy to instance methods)
-
- /**
- * Get SQL debug log (static)
- *
- * @return string
- * @throws Exception
- * @deprecated Use dev()->getSqlLog() instead
- */
- public static function getSqlLog(): string
- {
- return self::getInstance()->getSqlLogInstance();
- }
-
- /**
- * Sql debug status (static)
- *
- * @return bool
- * @deprecated Use dev()->sqlDebugAllowed() instead
- */
- public static function sqlDebugAllowed(): bool
- {
- return self::getInstance()->sqlDebugAllowedInstance();
- }
-
- /**
- * Short query (static)
- *
- * @param string $sql
- * @param bool $esc_html
- * @return string
- * @deprecated Use dev()->shortQuery() instead
- */
- public static function shortQuery(string $sql, bool $esc_html = false): string
- {
- return self::getInstance()->shortQueryInstance($sql, $esc_html);
- }
-
- /**
- * Get SQL debug log (for dev() singleton usage)
- *
- * @return string
- * @throws Exception
- */
- public function getSqlDebugLog(): string
- {
- return $this->getSqlLogInstance();
- }
-
- /**
- * Check if SQL debugging is allowed (for dev() singleton usage)
- *
- * @return bool
- */
- public function checkSqlDebugAllowed(): bool
- {
- return $this->sqlDebugAllowedInstance();
- }
-
- /**
- * Format SQL query for display (for dev() singleton usage)
- *
- * @param string $sql
- * @param bool $esc_html
- * @return string
- */
- public function formatShortQuery(string $sql, bool $esc_html = false): string
- {
- return $this->shortQueryInstance($sql, $esc_html);
- }
-
- /**
- * Get Whoops instance
- *
- * @return Run
- */
- public function getWhoops(): Run
- {
- return $this->whoops;
- }
-
- /**
- * Check if debug mode is enabled
- *
- * @return bool
- */
- public function isDebugEnabled(): bool
- {
- return DBG_USER;
- }
-
- /**
- * Check if application is in development environment
- *
- * @return bool
- */
- public function isDevelopmentEnvironment(): bool
- {
- return APP_ENV === 'development';
- }
-
- /**
- * Prevent cloning of the singleton instance
- */
- private function __clone()
- {
- }
-
- /**
- * Prevent unserialization of the singleton instance
- */
- public function __wakeup()
- {
- throw new \Exception("Cannot unserialize a singleton.");
- }
-}
diff --git a/legacy/src/Emailer.php b/legacy/src/Emailer.php
deleted file mode 100644
index d31e3716e..000000000
--- a/legacy/src/Emailer.php
+++ /dev/null
@@ -1,217 +0,0 @@
-subject = $subject;
- }
-
- /**
- * Set recipient address
- *
- * @param string $email recipient address
- * @param string $name recipient name
- *
- * @return void
- */
- public function set_to(string $email, string $name): void
- {
- $this->to = new Address($email, $name);
- }
-
- /**
- * Setting an address for the response
- *
- * @param string $email recipient address
- *
- * @return void
- */
- public function set_reply(string $email): void
- {
- $this->reply = new Address($email);
- }
-
- /**
- * Setting the message template
- *
- * @param string $template_file
- * @param string $template_lang
- *
- * @return void
- */
- public function set_template(string $template_file, string $template_lang = ''): void
- {
- if (!$template_lang) {
- $template_lang = config()->get('default_lang');
- }
-
- if (empty($this->tpl_msg[$template_lang . $template_file])) {
- $tpl_file = LANG_ROOT_DIR . '/' . $template_lang . '/email/' . $template_file . '.html';
-
- if (!is_file($tpl_file)) {
- $tpl_file = LANG_ROOT_DIR . '/' . config()->get('default_lang') . '/email/' . $template_file . '.html';
-
- if (!is_file($tpl_file)) {
- throw new Exception('Could not find email template file: ' . $template_file);
- }
- }
-
- if (!$fd = fopen($tpl_file, 'rb')) {
- throw new Exception('Failed opening email template file: ' . $tpl_file);
- }
-
- $this->tpl_msg[$template_lang . $template_file] = fread($fd, filesize($tpl_file));
- fclose($fd);
- }
-
- $this->message = $this->tpl_msg[$template_lang . $template_file];
- }
-
- /**
- * Sending a message to recipients via Symfony Mailer
- *
- * @param string $email_format
- *
- * @return bool
- * @throws Exception
- */
- public function send(string $email_format = 'text/plain'): bool
- {
- global $lang;
-
- if (!config()->get('emailer.enabled')) {
- return false;
- }
-
- /** Replace vars and prepare message */
- $this->message = preg_replace('#\{([a-z0-9\-_]*?)}#is', "$\\1", $this->message);
- foreach ($this->vars as $key => $val) {
- $this->message = preg_replace(sprintf('/\$\{?%s\}?/', $key), $val, $this->message);
- }
- $this->message = trim($this->message);
-
- /** Set some variables */
- $this->subject = !empty($this->subject) ? $this->subject : $lang['EMAILER_SUBJECT']['EMPTY'];
-
- /** Prepare message */
- if (config()->get('emailer.smtp.enabled')) {
- if (!empty(config()->get('emailer.smtp.host'))) {
- $sslType = config()->get('emailer.smtp.ssl_type');
- if (empty($sslType)) {
- $sslType = null;
- }
- /** @var EsmtpTransport $transport external SMTP with SSL */
- $transport = (new EsmtpTransport(
- config()->get('emailer.smtp.host'),
- config()->get('emailer.smtp.port'),
- $sslType
- ))
- ->setUsername(config()->get('emailer.smtp.username'))
- ->setPassword(config()->get('emailer.smtp.password'));
- } else {
- $transport = new EsmtpTransport('localhost', 25);
- }
- } else {
- $transport = new SendmailTransport(config()->get('emailer.sendmail_command'));
- }
-
- $mailer = new Mailer($transport);
-
- /** @var Email $message */
- $message = (new Email())
- ->subject($this->subject)
- ->to($this->to)
- ->from(new Address(config()->get('board_email'), config()->get('board_email_sitename')))
- ->returnPath(new Address(config()->get('bounce_email')))
- ->replyTo($this->reply ?? new Address(config()->get('board_email')));
-
- /**
- * This non-standard header tells compliant autoresponders ("email holiday mode") to not
- * reply to this message because it's an automated email
- */
- $message->getHeaders()
- ->addTextHeader('X-Auto-Response-Suppress', 'OOF, DR, RN, NRN, AutoReply');
-
- switch ($email_format) {
- case EMAIL_TYPE_HTML:
- $message->html($this->message);
- break;
- case EMAIL_TYPE_TEXT:
- $message->text($this->message);
- break;
- default:
- throw new Exception('Unknown email format: ' . $email_format);
- }
-
- /** Send message */
- try {
- $mailer->send($message);
- } catch (TransportExceptionInterface $e) {
- bb_die('Failed sending email: ' . $e->getMessage());
- }
-
- return true;
- }
-
- /**
- * Set message template variables
- *
- * @param $vars
- *
- * @return void
- */
- public function assign_vars($vars): void
- {
- $this->vars = array_merge([
- 'BOARD_EMAIL' => config()->get('board_email'),
- 'SITENAME' => config()->get('board_email_sitename'),
- 'EMAIL_SIG' => !empty(config()->get('board_email_sig')) ? "-- \n" . config()->get('board_email_sig') : '',
- ], $vars);
- }
-}
diff --git a/legacy/src/Env.php b/legacy/src/Env.php
deleted file mode 100644
index 52e1e7cac..000000000
--- a/legacy/src/Env.php
+++ /dev/null
@@ -1,116 +0,0 @@
-addAdapter(PutenvAdapter::class);
- }
-
- static::$repository = $builder->immutable()->make();
- }
-
- return static::$repository;
- }
-
- /**
- * Gets the value of an environment variable.
- *
- * @param string $key
- * @param mixed|null $default
- * @return mixed
- */
- public static function get(string $key, mixed $default = null): mixed
- {
- return Option::fromValue(static::getRepository()->get($key))
- ->map(function ($value) {
- switch (strtolower($value)) {
- case 'true':
- case '(true)':
- return true;
- case 'false':
- case '(false)':
- return false;
- case 'empty':
- case '(empty)':
- return '';
- case 'null':
- case '(null)':
- return null;
- }
-
- if (preg_match('/\A([\'"])(.*)\1\z/', $value, $matches)) {
- return $matches[2];
- }
-
- return $value;
- })
- ->getOrCall(fn () => $default instanceof Closure ? $default() : $default);
- }
-}
diff --git a/legacy/src/Helpers/CronHelper.php b/legacy/src/Helpers/CronHelper.php
deleted file mode 100644
index d037fede5..000000000
--- a/legacy/src/Helpers/CronHelper.php
+++ /dev/null
@@ -1,138 +0,0 @@
- 2400) {
- self::enableBoard();
- self::releaseLockFile();
- }
- }
- }
-
- /**
- * Снятие блокировки крона (по файлу)
- *
- * @return void
- */
- public static function releaseLockFile(): void
- {
- if (is_file(CRON_RUNNING)) {
- rename(CRON_RUNNING, CRON_ALLOWED);
- }
- self::touchLockFile(CRON_ALLOWED);
- }
-
- /**
- * Создание файла блокировки
- *
- * @param string $lock_file
- * @return void
- */
- public static function touchLockFile(string $lock_file): void
- {
- file_write('', $lock_file, replace_content: true);
- }
-
- /**
- * Включение форума (при разблокировке крона)
- *
- * @return void
- */
- public static function enableBoard(): void
- {
- if (is_file(BB_DISABLED)) {
- rename(BB_DISABLED, BB_ENABLED);
- }
- }
-
- /**
- * Отключение форума (при блокировке крона)
- *
- * @return void
- */
- public static function disableBoard(): void
- {
- if (is_file(BB_ENABLED)) {
- rename(BB_ENABLED, BB_DISABLED);
- }
- }
-
- /**
- * Проверка наличия файла блокировки
- *
- * @return bool
- */
- public static function hasFileLock(): bool
- {
- $lock_obtained = false;
-
- if (is_file(CRON_ALLOWED)) {
- $lock_obtained = rename(CRON_ALLOWED, CRON_RUNNING);
- } elseif (is_file(CRON_RUNNING)) {
- self::releaseDeadlock();
- } elseif (!is_file(CRON_ALLOWED) && !is_file(CRON_RUNNING)) {
- file_write('', CRON_ALLOWED);
- $lock_obtained = rename(CRON_ALLOWED, CRON_RUNNING);
- }
-
- return $lock_obtained;
- }
-
- /**
- * Отслеживание запуска задач
- *
- * @param string $mode
- * @return void
- */
- public static function trackRunning(string $mode): void
- {
- if (!defined('START_MARK')) {
- define('START_MARK', TRIGGERS_DIR . '/cron_started_at_' . date('Y-m-d_H-i-s') . '_by_pid_' . getmypid());
- }
-
- switch ($mode) {
- case 'start':
- self::touchLockFile(CRON_RUNNING);
- file_write('', START_MARK);
- break;
- case 'end':
- if (is_file(START_MARK)) {
- unlink(START_MARK);
- }
- break;
- default:
- bb_simple_die("Invalid cron track mode: $mode");
- }
- }
-}
diff --git a/legacy/src/Helpers/IsHelper.php b/legacy/src/Helpers/IsHelper.php
deleted file mode 100644
index 4495eaa55..000000000
--- a/legacy/src/Helpers/IsHelper.php
+++ /dev/null
@@ -1,38 +0,0 @@
-getWrappedContainer()->set(Container::class, self::$container);
- self::$container->getWrappedContainer()->set('container', self::$container);
-
- return self::$container;
- }
-
- public static function getContainer(): ?Container
- {
- return self::$container;
- }
-
- public static function reset(): void
- {
- self::$container = null;
- }
-
- private static function loadEnvironment(string $rootPath): void
- {
- if (file_exists($rootPath . '/.env')) {
- $dotenv = Dotenv::createImmutable($rootPath);
- $dotenv->load();
- }
- }
-
- private static function loadConfiguration(string $rootPath, array $config): array
- {
- // Load base configuration
- $configPath = $rootPath . '/config';
-
- // Container configuration
- if (file_exists($configPath . '/container.php')) {
- $containerConfig = require $configPath . '/container.php';
- $config = array_merge($config, $containerConfig);
- }
-
- // Services configuration
- if (file_exists($configPath . '/services.php')) {
- $servicesConfig = require $configPath . '/services.php';
- $config['definitions'] = array_merge(
- $config['definitions'] ?? [],
- $servicesConfig
- );
- }
-
- // Database configuration
- if (file_exists($configPath . '/database.php')) {
- $config['database'] = require $configPath . '/database.php';
- }
-
- // Cache configuration
- if (file_exists($configPath . '/cache.php')) {
- $config['cache'] = require $configPath . '/cache.php';
- }
-
- // Environment from .env
- $config['environment'] = $_ENV['APP_ENV'] ?? 'development';
- $config['debug'] = filter_var($_ENV['APP_DEBUG'] ?? false, FILTER_VALIDATE_BOOLEAN);
-
- return $config;
- }
-}
diff --git a/legacy/src/Infrastructure/DependencyInjection/Container.php b/legacy/src/Infrastructure/DependencyInjection/Container.php
deleted file mode 100644
index 25254bd3c..000000000
--- a/legacy/src/Infrastructure/DependencyInjection/Container.php
+++ /dev/null
@@ -1,49 +0,0 @@
-container = $container;
- }
-
- public function get(string $id): mixed
- {
- return $this->container->get($id);
- }
-
- public function has(string $id): bool
- {
- return $this->container->has($id);
- }
-
- public function make(string $name, array $parameters = []): mixed
- {
- return $this->container->make($name, $parameters);
- }
-
- public function call(callable $callable, array $parameters = []): mixed
- {
- return $this->container->call($callable, $parameters);
- }
-
- public function injectOn(object $instance): object
- {
- return $this->container->injectOn($instance);
- }
-
- public function getWrappedContainer(): DIContainer
- {
- return $this->container;
- }
-}
diff --git a/legacy/src/Infrastructure/DependencyInjection/ContainerFactory.php b/legacy/src/Infrastructure/DependencyInjection/ContainerFactory.php
deleted file mode 100644
index e4424c230..000000000
--- a/legacy/src/Infrastructure/DependencyInjection/ContainerFactory.php
+++ /dev/null
@@ -1,93 +0,0 @@
-build();
- $container = new Container($diContainer);
-
- // Register and boot service providers
- self::registerProviders($container, $config);
-
- return $container;
- }
-
- private static function configureContainer(ContainerBuilder $builder, array $config): void
- {
- // Enable compilation in production for better performance
- $isProduction = ($config['environment'] ?? 'development') === 'production';
-
- if ($isProduction) {
- $builder->enableCompilation($config['compilation_dir'] ?? __DIR__ . '/../../../internal_data/cache/container');
- $builder->writeProxiesToFile(true, $config['proxies_dir'] ?? __DIR__ . '/../../../internal_data/cache/proxies');
- }
-
- // Enable autowiring by default
- $builder->useAutowiring($config['autowiring'] ?? true);
- }
-
- private static function addDefinitions(ContainerBuilder $builder, array $config): void
- {
- // Add config definitions first
- if (isset($config['definitions'])) {
- $builder->addDefinitions($config['definitions']);
- }
-
- // Add layer-specific definitions
- $builder->addDefinitions(DomainDefinitions::getDefinitions());
- $builder->addDefinitions(ApplicationDefinitions::getDefinitions());
- $builder->addDefinitions(InfrastructureDefinitions::getDefinitions($config));
- $builder->addDefinitions(PresentationDefinitions::getDefinitions());
-
- // Add custom definition files if provided
- if (isset($config['definition_files'])) {
- foreach ($config['definition_files'] as $file) {
- if (file_exists($file)) {
- $builder->addDefinitions($file);
- }
- }
- }
- }
-
- private static function registerProviders(Container $container, array $config): void
- {
- $providers = $config['providers'] ?? [];
-
- // Instantiate providers
- $instances = [];
- foreach ($providers as $providerClass) {
- if (class_exists($providerClass)) {
- $provider = new $providerClass();
- if ($provider instanceof ServiceProvider) {
- $instances[] = $provider;
- $provider->register($container);
- }
- }
- }
-
- // Boot all providers after registration
- foreach ($instances as $provider) {
- $provider->boot($container);
- }
- }
-}
diff --git a/legacy/src/Infrastructure/DependencyInjection/Definitions/ApplicationDefinitions.php b/legacy/src/Infrastructure/DependencyInjection/Definitions/ApplicationDefinitions.php
deleted file mode 100644
index d8e6d2842..000000000
--- a/legacy/src/Infrastructure/DependencyInjection/Definitions/ApplicationDefinitions.php
+++ /dev/null
@@ -1,46 +0,0 @@
- DI\factory(function (ContainerInterface $c) {
- // return new CommandBus($c);
- // }),
-
- // Query Bus
- // 'QueryBusInterface' => DI\factory(function (ContainerInterface $c) {
- // return new QueryBus($c);
- // }),
-
- // Event Dispatcher
- // 'EventDispatcherInterface' => DI\factory(function (ContainerInterface $c) {
- // return new EventDispatcher();
- // }),
-
- // Application Services
- // These typically orchestrate domain objects and handle use cases
-
- // Forum Handlers
- // 'TorrentPier\Application\Forum\Handler\CreatePostHandler' => DI\autowire(),
- // 'TorrentPier\Application\Forum\Handler\GetThreadListHandler' => DI\autowire(),
-
- // Tracker Handlers
- // 'TorrentPier\Application\Tracker\Handler\RegisterTorrentHandler' => DI\autowire(),
- // 'TorrentPier\Application\Tracker\Handler\ProcessAnnounceHandler' => DI\autowire(),
-
- // User Handlers
- // 'TorrentPier\Application\User\Handler\RegisterUserHandler' => DI\autowire(),
- // 'TorrentPier\Application\User\Handler\AuthenticateUserHandler' => DI\autowire(),
- ];
- }
-}
diff --git a/legacy/src/Infrastructure/DependencyInjection/Definitions/DomainDefinitions.php b/legacy/src/Infrastructure/DependencyInjection/Definitions/DomainDefinitions.php
deleted file mode 100644
index 330d5add0..000000000
--- a/legacy/src/Infrastructure/DependencyInjection/Definitions/DomainDefinitions.php
+++ /dev/null
@@ -1,32 +0,0 @@
- DI\factory(function (ContainerInterface $c) {
- // return $c->get('TorrentPier\Infrastructure\Persistence\Repository\ForumRepository');
- // }),
-
- // 'TorrentPier\Domain\Tracker\Repository\TorrentRepositoryInterface' => DI\factory(function (ContainerInterface $c) {
- // return $c->get('TorrentPier\Infrastructure\Persistence\Repository\TorrentRepository');
- // }),
-
- // 'TorrentPier\Domain\User\Repository\UserRepositoryInterface' => DI\factory(function (ContainerInterface $c) {
- // return $c->get('TorrentPier\Infrastructure\Persistence\Repository\UserRepository');
- // }),
- ];
- }
-}
diff --git a/legacy/src/Infrastructure/DependencyInjection/Definitions/InfrastructureDefinitions.php b/legacy/src/Infrastructure/DependencyInjection/Definitions/InfrastructureDefinitions.php
deleted file mode 100644
index ee64f60a1..000000000
--- a/legacy/src/Infrastructure/DependencyInjection/Definitions/InfrastructureDefinitions.php
+++ /dev/null
@@ -1,84 +0,0 @@
- DI\factory(function () use ($config) {
- // $dbConfig = $config['database'] ?? [];
- // $dsn = sprintf(
- // 'mysql:host=%s;port=%s;dbname=%s;charset=%s',
- // $dbConfig['host'] ?? '127.0.0.1',
- // $dbConfig['port'] ?? 3306,
- // $dbConfig['database'] ?? 'tp',
- // $dbConfig['charset'] ?? 'utf8mb4'
- // );
- //
- // return new Connection(
- // $dsn,
- // $dbConfig['username'] ?? 'root',
- // $dbConfig['password'] ?? ''
- // );
- // }),
-
- // Example: Cache Storage (implement when cache infrastructure is ready)
- // 'cache.storage' => DI\factory(function () use ($config) {
- // $cacheConfig = $config['cache'] ?? [];
- // $driver = $cacheConfig['driver'] ?? 'file';
- //
- // switch ($driver) {
- // case 'memcached':
- // $memcached = new \Memcached();
- // $memcached->addServer(
- // $cacheConfig['memcached']['host'] ?? '127.0.0.1',
- // $cacheConfig['memcached']['port'] ?? 11211
- // );
- // return new MemcachedStorage($memcached);
- //
- // case 'sqlite':
- // return new SQLiteStorage($cacheConfig['sqlite']['path'] ?? __DIR__ . '/../../../../internal_data/cache/cache.db');
- //
- // case 'file':
- // default:
- // return new FileStorage($cacheConfig['file']['path'] ?? __DIR__ . '/../../../../internal_data/cache');
- // }
- // }),
-
- // Example: Repository Implementations (implement when repositories are created)
- // 'TorrentPier\Infrastructure\Persistence\Repository\ForumRepository' => DI\autowire()
- // ->constructorParameter('connection', DI\get('database.connection.default'))
- // ->constructorParameter('cache', DI\get('cache.factory')),
-
- // Example: Email Service (implement when email infrastructure is ready)
- // 'EmailServiceInterface' => DI\factory(function (ContainerInterface $c) use ($config) {
- // $emailConfig = $config['email'] ?? [];
- // return new SmtpEmailService($emailConfig);
- // }),
-
- // Example: File Storage (implement when file storage abstraction is ready)
- // 'FileStorageInterface' => DI\factory(function (ContainerInterface $c) use ($config) {
- // $storageConfig = $config['storage'] ?? [];
- // return match ($storageConfig['driver'] ?? 'local') {
- // 's3' => new S3FileStorage($storageConfig['s3']),
- // default => new LocalFileStorage($storageConfig['local']['path'] ?? __DIR__ . '/../../../../internal_data/uploads'),
- // };
- // }),
- ];
- }
-}
diff --git a/legacy/src/Infrastructure/DependencyInjection/Definitions/PresentationDefinitions.php b/legacy/src/Infrastructure/DependencyInjection/Definitions/PresentationDefinitions.php
deleted file mode 100644
index 78a7e0566..000000000
--- a/legacy/src/Infrastructure/DependencyInjection/Definitions/PresentationDefinitions.php
+++ /dev/null
@@ -1,52 +0,0 @@
- DI\autowire(),
- // 'TorrentPier\Presentation\Http\Controllers\Web\ForumController' => DI\autowire(),
- // 'TorrentPier\Presentation\Http\Controllers\Web\TrackerController' => DI\autowire(),
- // 'TorrentPier\Presentation\Http\Controllers\Web\UserController' => DI\autowire(),
-
- // API Controllers
- // 'TorrentPier\Presentation\Http\Controllers\Api\UserController' => DI\autowire(),
- // 'TorrentPier\Presentation\Http\Controllers\Api\TorrentController' => DI\autowire(),
- // 'TorrentPier\Presentation\Http\Controllers\Api\ForumController' => DI\autowire(),
-
- // Admin Controllers
- // 'TorrentPier\Presentation\Http\Controllers\Admin\DashboardController' => DI\autowire(),
- // 'TorrentPier\Presentation\Http\Controllers\Admin\UserController' => DI\autowire(),
- // 'TorrentPier\Presentation\Http\Controllers\Admin\ForumController' => DI\autowire(),
- // 'TorrentPier\Presentation\Http\Controllers\Admin\TrackerController' => DI\autowire(),
-
- // Middleware
- // 'AuthenticationMiddleware' => DI\autowire('TorrentPier\Presentation\Http\Middleware\AuthenticationMiddleware'),
- // 'AuthorizationMiddleware' => DI\autowire('TorrentPier\Presentation\Http\Middleware\AuthorizationMiddleware'),
- // 'CorsMiddleware' => DI\autowire('TorrentPier\Presentation\Http\Middleware\CorsMiddleware'),
- // 'RateLimitMiddleware' => DI\autowire('TorrentPier\Presentation\Http\Middleware\RateLimitMiddleware'),
-
- // CLI Commands
- // 'TorrentPier\Presentation\Cli\Commands\CacheCommand' => DI\autowire(),
- // 'TorrentPier\Presentation\Cli\Commands\MigrateCommand' => DI\autowire(),
- // 'TorrentPier\Presentation\Cli\Commands\SeedCommand' => DI\autowire(),
- // 'TorrentPier\Presentation\Cli\Commands\TrackerCommand' => DI\autowire(),
-
- // View/Response Transformers
- // 'JsonResponseTransformer' => DI\autowire('TorrentPier\Presentation\Http\Responses\JsonResponseTransformer'),
- // 'HtmlResponseTransformer' => DI\autowire('TorrentPier\Presentation\Http\Responses\HtmlResponseTransformer'),
- ];
- }
-}
diff --git a/legacy/src/Infrastructure/DependencyInjection/ServiceProvider.php b/legacy/src/Infrastructure/DependencyInjection/ServiceProvider.php
deleted file mode 100644
index 6bd480beb..000000000
--- a/legacy/src/Infrastructure/DependencyInjection/ServiceProvider.php
+++ /dev/null
@@ -1,24 +0,0 @@
-sql_query($sql)) {
- bb_die('Could not obtain cron script');
- }
-
- while ($row = DB()->sql_fetchrow($result)) {
- $job = $row['cron_script'];
- $job_script = INC_DIR . '/cron/jobs/' . $job;
- require($job_script);
- }
- DB()->query("
- UPDATE " . BB_CRON . " SET
- last_run = NOW(),
- run_counter = run_counter + 1,
- next_run =
- CASE
- WHEN schedule = 'hourly' THEN
- DATE_ADD(NOW(), INTERVAL 1 HOUR)
- WHEN schedule = 'daily' THEN
- DATE_ADD(DATE_ADD(CURDATE(), INTERVAL 1 DAY), INTERVAL TIME_TO_SEC(run_time) SECOND)
- WHEN schedule = 'weekly' THEN
- DATE_ADD(
- DATE_ADD(DATE_SUB(CURDATE(), INTERVAL WEEKDAY(NOW()) DAY), INTERVAL 7 DAY),
- INTERVAL CONCAT(ROUND(run_day-1), ' ', run_time) DAY_SECOND)
- WHEN schedule = 'monthly' THEN
- DATE_ADD(
- DATE_ADD(DATE_SUB(CURDATE(), INTERVAL DAYOFMONTH(NOW())-1 DAY), INTERVAL 1 MONTH),
- INTERVAL CONCAT(ROUND(run_day-1), ' ', run_time) DAY_SECOND)
- ELSE
- DATE_ADD(NOW(), INTERVAL TIME_TO_SEC(run_interval) SECOND)
- END
- WHERE cron_id IN ($jobs)
- ");
- }
-
- /**
- * Delete cron jobs
- *
- * @param string $jobs
- */
- public static function delete_jobs(string $jobs): void
- {
- DB()->query("DELETE FROM " . BB_CRON . " WHERE cron_id IN ($jobs)");
- }
-
- /**
- * Toggle activity of cron jobs
- *
- * @param string $jobs
- * @param string $cron_action
- */
- public static function toggle_active(string $jobs, string $cron_action): void
- {
- $active = ($cron_action == 'disable') ? 0 : 1;
- DB()->query("UPDATE " . BB_CRON . " SET cron_active = $active WHERE cron_id IN ($jobs)");
- }
-
- /**
- * Validate cron admin post query
- *
- * @param array $cron_arr
- *
- * @return int|string
- */
- public static function validate_cron_post(array $cron_arr)
- {
- $errors = 'Errors in: ';
- $errnum = 0;
- if (!$cron_arr['cron_title']) {
- $errors .= 'cron title (empty value), ';
- $errnum++;
- }
- if (!$cron_arr['cron_script']) {
- $errors .= 'cron script (empty value), ';
- $errnum++;
- }
- if ($errnum > 0) {
- $result = $errors . ' total ' . $errnum . ' errors
Back';
- } else {
- $result = 1;
- }
- return $result;
- }
-
- /**
- * Insert cron job to database
- *
- * @param array $cron_arr
- */
- public static function insert_cron_job(array $cron_arr): void
- {
- $row = DB()->fetch_row("SELECT cron_title, cron_script FROM " . BB_CRON . " WHERE cron_title = '" . $_POST['cron_title'] . "' or cron_script = '" . $_POST['cron_script'] . "' ");
-
- if ($row) {
- global $lang;
-
- if ($_POST['cron_script'] == $row['cron_script']) {
- $langmode = $lang['SCRIPT_DUPLICATE'];
- } else {
- $langmode = $lang['TITLE_DUPLICATE'];
- }
-
- $message = $langmode . "
" . sprintf($lang['CLICK_RETURN_JOBS_ADDED'], "", "") . "
" . sprintf($lang['CLICK_RETURN_JOBS'], "", "") . "
" . sprintf($lang['CLICK_RETURN_ADMIN_INDEX'], "", "");
-
- bb_die($message);
- }
-
- $cron_active = $cron_arr['cron_active'];
- $cron_title = $cron_arr['cron_title'];
- $cron_script = $cron_arr['cron_script'];
- $schedule = $cron_arr['schedule'];
- $run_day = $cron_arr['run_day'];
- $run_time = $cron_arr['run_time'];
- $run_order = $cron_arr['run_order'];
- $last_run = $cron_arr['last_run'];
- $next_run = $cron_arr['next_run'];
- $run_interval = $cron_arr['run_interval'];
- $log_enabled = $cron_arr['log_enabled'];
- $log_file = $cron_arr['log_file'];
- $log_sql_queries = $cron_arr['log_sql_queries'];
- $disable_board = $cron_arr['disable_board'];
- $run_counter = $cron_arr['run_counter'];
-
- DB()->query("INSERT INTO " . BB_CRON . " (cron_active, cron_title, cron_script, schedule, run_day, run_time, run_order, last_run, next_run, run_interval, log_enabled, log_file, log_sql_queries, disable_board, run_counter) VALUES (
- $cron_active, '$cron_title', '$cron_script', '$schedule', '$run_day', '$run_time', '$run_order', '$last_run', '$next_run', '$run_interval', $log_enabled, '$log_file', $log_sql_queries, $disable_board, '$run_counter')");
- }
-
- /**
- * Update cron job in database
- *
- * @param array $cron_arr
- */
- public static function update_cron_job(array $cron_arr): void
- {
- $cron_id = $cron_arr['cron_id'];
- $cron_active = $cron_arr['cron_active'];
- $cron_title = DB()->escape($cron_arr['cron_title']);
- $cron_script = DB()->escape($cron_arr['cron_script']);
- $schedule = $cron_arr['schedule'];
- $run_day = $cron_arr['run_day'];
- $run_time = $cron_arr['run_time'];
- $run_order = $cron_arr['run_order'];
- $last_run = $cron_arr['last_run'];
- $next_run = $cron_arr['next_run'];
- $run_interval = $cron_arr['run_interval'];
- $log_enabled = $cron_arr['log_enabled'];
- $log_file = DB()->escape($cron_arr['log_file']);
- $log_sql_queries = $cron_arr['log_sql_queries'];
- $disable_board = $cron_arr['disable_board'];
- $run_counter = $cron_arr['run_counter'];
-
- DB()->query("UPDATE " . BB_CRON . " SET
- cron_active = '$cron_active',
- cron_title = '$cron_title',
- cron_script = '$cron_script',
- schedule = '$schedule',
- run_day = '$run_day',
- run_time = '$run_time',
- run_order = '$run_order',
- last_run = '$last_run',
- next_run = '$next_run',
- run_interval = '$run_interval',
- log_enabled = '$log_enabled',
- log_file = '$log_file',
- log_sql_queries = '$log_sql_queries',
- disable_board = '$disable_board',
- run_counter = '$run_counter'
- WHERE cron_id = $cron_id
- ");
- }
-}
diff --git a/legacy/src/Legacy/Admin/Torrent.php b/legacy/src/Legacy/Admin/Torrent.php
deleted file mode 100644
index d0e1b80ad..000000000
--- a/legacy/src/Legacy/Admin/Torrent.php
+++ /dev/null
@@ -1,141 +0,0 @@
-sql_query($sql)) {
- bb_die('Could not update ' . $table_name);
- }
-
- if (isset($_POST[$field_name])) {
- // Get new status
- $in_sql = [];
-
- foreach ($_POST[$field_name] as $i => $val) {
- $in_sql[] = (int)$val;
- }
-
- // Update status
- if ($in_sql = implode(',', $in_sql)) {
- $sql = "UPDATE $table_name
- SET $field_name = 1
- WHERE $key IN($in_sql)";
-
- if (!$result = DB()->sql_query($sql)) {
- bb_die('Could not update ' . $table_name);
- }
- }
- }
- }
-
- /**
- * Assign config variables to template
- *
- * @param array $default_cfg
- * @param array $cfg
- */
- public static function set_tpl_vars($default_cfg, $cfg)
- {
- global $template;
-
- foreach ($default_cfg as $config_name => $config_value) {
- $template->assign_vars([strtoupper($config_name) => htmlspecialchars($cfg[$config_name])]);
- }
- }
-
- /**
- * Assign boolean config variables to template
- *
- * @param array $default_cfg
- * @param array $cfg
- */
- public static function set_tpl_vars_bool($default_cfg, $cfg)
- {
- global $template, $lang;
-
- foreach ($default_cfg as $config_name => $config_value) {
- // YES/NO 'checked'
- $template->assign_vars([
- strtoupper($config_name) . '_YES' => ($cfg[$config_name]) ? HTML_CHECKED : '',
- strtoupper($config_name) . '_NO' => (!$cfg[$config_name]) ? HTML_CHECKED : '',
- ]);
- // YES/NO lang vars
- $template->assign_vars([
- 'L_' . strtoupper($config_name) . '_YES' => ($cfg[$config_name]) ? "$lang[YES]" : $lang['YES'],
- 'L_' . strtoupper($config_name) . '_NO' => (!$cfg[$config_name]) ? "$lang[NO]" : $lang['NO'],
- ]);
- }
- }
-
- /**
- * Assign language config variables to template
- *
- * @param array $default_cfg
- */
- public static function set_tpl_vars_lang($default_cfg)
- {
- global $template, $lang;
-
- foreach ($default_cfg as $config_name => $config_value) {
- $template->assign_vars([
- 'L_' . strtoupper($config_name) => $lang[$config_name] ?? '',
- 'L_' . strtoupper($config_name) . '_EXPL' => $lang[$config_name . '_expl'] ?? '',
- 'L_' . strtoupper($config_name) . '_HEAD' => $lang[$config_name . '_head'] ?? '',
- ]);
- }
- }
-
- /**
- * Update config table
- *
- * @param string $table_name
- * @param array $default_cfg
- * @param array $cfg
- * @param string $type
- */
- public static function update_config_table($table_name, $default_cfg, $cfg, $type)
- {
- foreach ($default_cfg as $config_name => $config_value) {
- if (isset($_POST[$config_name]) && $_POST[$config_name] != $cfg[$config_name]) {
- if ($type == 'str') {
- $config_value = $_POST[$config_name];
- } elseif ($type == 'bool') {
- $config_value = ($_POST[$config_name]) ? 1 : 0;
- } elseif ($type == 'num') {
- $config_value = abs((int)$_POST[$config_name]);
- } else {
- return;
- }
-
- bb_update_config([$config_name => $config_value], $table_name);
- }
- }
- }
-}
diff --git a/legacy/src/Sessions.php b/legacy/src/Sessions.php
deleted file mode 100644
index 97e0e773a..000000000
--- a/legacy/src/Sessions.php
+++ /dev/null
@@ -1,144 +0,0 @@
-get($id);
- }
-
- /**
- * Set userdata to cache
- *
- * @param array|null $userdata
- * @param bool $force
- *
- * @return bool
- */
- public static function cache_set_userdata(?array $userdata, bool $force = false): bool
- {
- if (!$userdata || (self::ignore_cached_userdata() && !$force)) {
- return false;
- }
-
- $id = ($userdata['user_id'] == GUEST_UID) ? $userdata['session_ip'] : $userdata['session_id'];
- return CACHE('session_cache')->set($id, $userdata, config()->get('session_update_intrv'));
- }
-
- /**
- * Delete userdata from cache
- *
- * @param array $userdata
- *
- * @return bool
- */
- public static function cache_rm_userdata(array $userdata): bool
- {
- if (!$userdata) {
- return false;
- }
-
- $id = ($userdata['user_id'] == GUEST_UID) ? $userdata['session_ip'] : $userdata['session_id'];
- return CACHE('session_cache')->rm($id);
- }
-
- /**
- * Delete user sessions from cache
- *
- * @param int|string $user_id
- */
- public static function cache_rm_user_sessions(int|string $user_id): void
- {
- $user_id = get_id_csv(explode(',', (string)$user_id));
-
- $rowset = DB()->fetch_rowset("SELECT session_id FROM " . BB_SESSIONS . " WHERE session_user_id IN($user_id)");
-
- foreach ($rowset as $row) {
- CACHE('session_cache')->rm($row['session_id']);
- }
- }
-
- /**
- * Update userdata in cache
- *
- * @param array|null $userdata
- *
- * @return bool
- */
- public static function cache_update_userdata(?array $userdata): bool
- {
- return self::cache_set_userdata($userdata, true);
- }
-
- /**
- * Update userdata in database
- *
- * @param array $userdata
- * @param array $sql_ary
- * @param bool $data_already_escaped
- *
- * @return bool
- */
- public static function db_update_userdata(array $userdata, array $sql_ary, bool $data_already_escaped = true): bool
- {
- if (!$userdata) {
- return false;
- }
-
- $sql_args = DB()->build_array('UPDATE', $sql_ary, $data_already_escaped);
- DB()->query("UPDATE " . BB_USERS . " SET $sql_args WHERE user_id = {$userdata['user_id']}");
-
- if (DB()->affected_rows()) {
- self::cache_rm_userdata($userdata);
- }
-
- return true;
- }
-
- /**
- * Delete user sessions from cache and database
- *
- * @param int|string $user_id
- */
- public static function delete_user_sessions(int|string $user_id): void
- {
- self::cache_rm_user_sessions($user_id);
-
- $user_id = get_id_csv(explode(',', (string)$user_id));
- DB()->query("DELETE FROM " . BB_SESSIONS . " WHERE session_user_id IN($user_id)");
- }
-}
diff --git a/legacy/src/Whoops/DatabaseErrorHandler.php b/legacy/src/Whoops/DatabaseErrorHandler.php
deleted file mode 100644
index 7668c28c1..000000000
--- a/legacy/src/Whoops/DatabaseErrorHandler.php
+++ /dev/null
@@ -1,393 +0,0 @@
-addToOutput) {
- return Handler::DONE;
- }
-
- $inspector = $this->getInspector();
-
- if (!$inspector) {
- return Handler::DONE;
- }
-
- $exception = $inspector->getException();
-
- // Add database information to the exception frames
- $this->addDatabaseContextToFrames($inspector);
-
- // Add global database state information
- $this->addGlobalDatabaseInfo($exception);
-
- return Handler::DONE;
- }
-
- /**
- * Set whether to add database info to output
- */
- public function setAddToOutput(bool $add): self
- {
- $this->addToOutput = $add;
- return $this;
- }
-
- /**
- * Set whether to include query history
- */
- public function setIncludeQueryHistory(bool $include): self
- {
- $this->includeQueryHistory = $include;
- return $this;
- }
-
- /**
- * Set maximum number of queries to show in history
- */
- public function setMaxQueryHistory(int $max): self
- {
- $this->maxQueryHistory = max(1, $max);
- return $this;
- }
-
- /**
- * Add database context information to exception frames
- */
- private function addDatabaseContextToFrames($inspector): void
- {
- if (!$inspector) {
- return;
- }
-
- $frames = $inspector->getFrames();
-
- if (!$frames || empty($frames)) {
- return;
- }
-
- foreach ($frames as $frame) {
- $frameData = [];
-
- // Check if this frame involves database operations
- $fileName = $frame->getFile();
- $className = $frame->getClass();
- $functionName = $frame->getFunction();
-
- // Detect database-related frames
- $isDatabaseFrame = $this->isDatabaseRelatedFrame($fileName, $className, $functionName);
-
- if ($isDatabaseFrame) {
- $frameData['database_context'] = $this->getCurrentDatabaseContext();
-
- // Add frame-specific database info
- $frame->addComment('Database Context', 'This frame involves database operations');
-
- foreach ($frameData['database_context'] as $key => $value) {
- if (is_string($value) || is_numeric($value)) {
- $frame->addComment("DB: $key", $value);
- } elseif (is_array($value) && !empty($value)) {
- $frame->addComment("DB: $key", json_encode($value, JSON_PRETTY_PRINT));
- }
- }
- }
- }
- }
-
- /**
- * Add global database information to the exception
- */
- private function addGlobalDatabaseInfo($exception): void
- {
- try {
- $databaseInfo = $this->collectDatabaseInformation();
-
- // Use Whoops' built-in method if available - this is the proper way
- if (method_exists($exception, 'setAdditionalInfo')) {
- $exception->setAdditionalInfo('Database Information', $databaseInfo);
- }
- // For PHP 8.2+ compatibility: Avoid dynamic properties completely
- // Instead, we'll add the info as frame comments on the first database-related frame
- else {
- $this->addDatabaseInfoAsFrameComments($databaseInfo);
- }
- } catch (\Exception $e) {
- // Don't let database info collection break error handling
- if (method_exists($exception, 'setAdditionalInfo')) {
- $exception->setAdditionalInfo('Database Info Error', $e->getMessage());
- }
- }
- }
-
- /**
- * Add database info as frame comments when setAdditionalInfo is not available
- */
- private function addDatabaseInfoAsFrameComments(array $databaseInfo): void
- {
- $inspector = $this->getInspector();
-
- if (!$inspector) {
- return;
- }
-
- $frames = $inspector->getFrames();
-
- // Find the first frame and add database info as comments
- if (!empty($frames) && is_array($frames) && isset($frames[0])) {
- $firstFrame = $frames[0];
- $firstFrame->addComment('=== Database Information ===', '');
-
- foreach ($databaseInfo as $key => $value) {
- if (is_string($value) || is_numeric($value)) {
- $firstFrame->addComment("DB Info - $key", $value);
- } elseif (is_array($value) && !empty($value)) {
- $firstFrame->addComment("DB Info - $key", json_encode($value, JSON_PRETTY_PRINT));
- }
- }
- }
- }
-
- /**
- * Check if a frame is related to database operations
- */
- private function isDatabaseRelatedFrame(?string $fileName, ?string $className, ?string $functionName): bool
- {
- if (!$fileName) {
- return false;
- }
-
- // Check file paths
- $databaseFiles = [
- '/Database/',
- '/database/',
- 'Database.php',
- 'DatabaseDebugger.php',
- 'DebugSelection.php',
- ];
-
- foreach ($databaseFiles as $dbFile) {
- if (str_contains($fileName, $dbFile)) {
- return true;
- }
- }
-
- // Check class names
- $databaseClasses = [
- 'Database',
- 'DatabaseDebugger',
- 'DebugSelection',
- 'DB',
- 'Nette\Database',
- ];
-
- if ($className) {
- foreach ($databaseClasses as $dbClass) {
- if (str_contains($className, $dbClass)) {
- return true;
- }
- }
- }
-
- // Check function names
- $databaseFunctions = [
- 'sql_query',
- 'fetch_row',
- 'fetch_rowset',
- 'sql_fetchrow',
- 'query',
- 'execute',
- ];
-
- if ($functionName) {
- foreach ($databaseFunctions as $dbFunc) {
- if (str_contains($functionName, $dbFunc)) {
- return true;
- }
- }
- }
-
- return false;
- }
-
- /**
- * Get current database context
- */
- private function getCurrentDatabaseContext(): array
- {
- $context = [];
-
- try {
- // Get main database instance
- if (function_exists('DB')) {
- $db = DB();
-
- $context['current_query'] = $db->cur_query ?? 'None';
- $context['database_server'] = $db->db_server ?? 'Unknown';
- $context['selected_database'] = $db->selected_db ?? 'Unknown';
-
- // Connection status
- $context['connection_status'] = $db->connection ? 'Active' : 'No connection';
-
- // Query stats
- $context['total_queries'] = $db->num_queries ?? 0;
- $context['total_time'] = isset($db->sql_timetotal) ? sprintf('%.3f sec', $db->sql_timetotal) : 'Unknown';
-
- // Recent error information
- $sqlError = $db->sql_error();
- if (!empty($sqlError['message'])) {
- $context['last_error'] = $sqlError;
- }
- }
- } catch (\Exception $e) {
- $context['error'] = 'Could not retrieve database context: ' . $e->getMessage();
- }
-
- return $context;
- }
-
- /**
- * Collect comprehensive database information
- */
- private function collectDatabaseInformation(): array
- {
- $info = [
- 'timestamp' => date('Y-m-d H:i:s'),
- 'request_uri' => $_SERVER['REQUEST_URI'] ?? 'CLI',
- 'user_ip' => $_SERVER['REMOTE_ADDR'] ?? 'Unknown',
- ];
-
- try {
- // Get information from all database servers
- if (class_exists('\TorrentPier\Database\DatabaseFactory')) {
- $serverNames = \TorrentPier\Database\DatabaseFactory::getServerNames();
-
- foreach ($serverNames as $serverName) {
- try {
- $db = \TorrentPier\Database\DatabaseFactory::getInstance($serverName);
-
- $serverInfo = [
- 'server_name' => $serverName,
- 'engine' => $db->engine ?? 'Unknown',
- 'host' => $db->db_server ?? 'Unknown',
- 'database' => $db->selected_db ?? 'Unknown',
- 'connection_status' => $db->connection ? 'Connected' : 'Disconnected',
- 'total_queries' => $db->num_queries ?? 0,
- 'total_time' => isset($db->sql_timetotal) ? sprintf('%.3f sec', $db->sql_timetotal) : 'Unknown',
- ];
-
- // Current query
- if (!empty($db->cur_query)) {
- $serverInfo['current_query'] = $this->formatQueryForDisplay($db->cur_query);
- }
-
- // Last error
- $sqlError = $db->sql_error();
- if (!empty($sqlError['message'])) {
- $serverInfo['last_error'] = $sqlError;
- }
-
- // Recent query history (if available and enabled)
- if ($this->includeQueryHistory && !empty($db->dbg)) {
- $recentQueries = array_slice($db->dbg, -$this->maxQueryHistory);
- $serverInfo['recent_queries'] = [];
-
- foreach ($recentQueries as $query) {
- $serverInfo['recent_queries'][] = [
- 'sql' => $this->formatQueryForDisplay($query['sql'] ?? 'Unknown'),
- 'time' => isset($query['time']) ? sprintf('%.3f sec', $query['time']) : 'Unknown',
- 'source' => $query['src'] ?? 'Unknown',
- ];
- }
- }
-
- $info['databases'][$serverName] = $serverInfo;
-
- } catch (\Exception $e) {
- $info['databases'][$serverName] = [
- 'error' => 'Could not retrieve info: ' . $e->getMessage()
- ];
- }
- }
- }
-
- // Legacy single database support
- if (function_exists('DB') && empty($info['databases'])) {
- $db = DB();
-
- $info['legacy_database'] = [
- 'engine' => $db->engine ?? 'Unknown',
- 'host' => $db->db_server ?? 'Unknown',
- 'database' => $db->selected_db ?? 'Unknown',
- 'connection_status' => $db->connection ? 'Connected' : 'Disconnected',
- 'total_queries' => $db->num_queries ?? 0,
- 'total_time' => isset($db->sql_timetotal) ? sprintf('%.3f sec', $db->sql_timetotal) : 'Unknown',
- ];
-
- if (!empty($db->cur_query)) {
- $info['legacy_database']['current_query'] = $this->formatQueryForDisplay($db->cur_query);
- }
-
- $sqlError = $db->sql_error();
- if (!empty($sqlError['message'])) {
- $info['legacy_database']['last_error'] = $sqlError;
- }
- }
-
- } catch (\Exception $e) {
- $info['collection_error'] = $e->getMessage();
- }
-
- return $info;
- }
-
- /**
- * Format SQL query for readable display
- */
- private function formatQueryForDisplay(string $query, int $maxLength = 500): string
- {
- // Remove comments at the start (debug info)
- $query = preg_replace('#^/\*.*?\*/#', '', $query);
- $query = trim($query);
-
- // Truncate if too long
- if (strlen($query) > $maxLength) {
- $query = substr($query, 0, $maxLength) . '... [truncated]';
- }
-
- return $query;
- }
-
- /**
- * Get priority - run after the main PrettyPageHandler
- */
- public function contentType(): ?string
- {
- return 'text/html';
- }
-}
diff --git a/legacy/src/Whoops/EnhancedPrettyPageHandler.php b/legacy/src/Whoops/EnhancedPrettyPageHandler.php
deleted file mode 100644
index 818b86559..000000000
--- a/legacy/src/Whoops/EnhancedPrettyPageHandler.php
+++ /dev/null
@@ -1,269 +0,0 @@
-connection ? 'Connected' : 'Disconnected';
- $info['Database Server'] = $db->db_server ?? 'Unknown';
- $info['Selected Database'] = $db->selected_db ?? 'Unknown';
- $info['Database Engine'] = $db->engine ?? 'Unknown';
- $info['Total Queries'] = $db->num_queries ?? 0;
-
- if (isset($db->sql_timetotal)) {
- $info['Total Query Time'] = sprintf('%.3f seconds', $db->sql_timetotal);
- }
-
- // Current/Last executed query
- if (!empty($db->cur_query)) {
- $info['Current Query'] = $this->formatSqlQuery($db->cur_query);
- }
-
- // Database error information
- $sqlError = $db->sql_error();
- if (!empty($sqlError['message'])) {
- $info['Last Database Error'] = [
- 'Code' => $sqlError['code'] ?? 'Unknown',
- 'Message' => $sqlError['message'],
- ];
- }
-
- // Connection details if available
- if ($db->connection) {
- try {
- $pdo = $db->connection->getPdo();
- if ($pdo) {
- $info['PDO Driver'] = $pdo->getAttribute(\PDO::ATTR_DRIVER_NAME) ?? 'Unknown';
- $info['Server Version'] = $pdo->getAttribute(\PDO::ATTR_SERVER_VERSION) ?? 'Unknown';
-
- // Current PDO error state
- $errorCode = $pdo->errorCode();
- if ($errorCode && $errorCode !== '00000') {
- $errorInfo = $pdo->errorInfo();
- $info['PDO Error State'] = [
- 'Code' => $errorCode,
- 'Info' => $errorInfo[2] ?? 'Unknown'
- ];
- }
- }
- } catch (\Exception $e) {
- $info['PDO Error'] = $e->getMessage();
- }
- }
- }
-
- // Get information from all database servers (new system)
- if (class_exists('\TorrentPier\Database\DatabaseFactory')) {
- try {
- $serverNames = \TorrentPier\Database\DatabaseFactory::getServerNames();
-
- if (count($serverNames) > 1) {
- foreach ($serverNames as $serverName) {
- try {
- $db = \TorrentPier\Database\DatabaseFactory::getInstance($serverName);
- $info["Server: $serverName"] = [
- 'Host' => $db->db_server ?? 'Unknown',
- 'Database' => $db->selected_db ?? 'Unknown',
- 'Queries' => $db->num_queries ?? 0,
- 'Connected' => $db->connection ? 'Yes' : 'No',
- ];
- } catch (\Exception $e) {
- $info["Server: $serverName"] = ['Error' => $e->getMessage()];
- }
- }
- }
- } catch (\Exception $e) {
- $info['Multi-Server Error'] = $e->getMessage();
- }
- }
-
- } catch (\Exception $e) {
- $info['Collection Error'] = $e->getMessage();
- }
-
- return $info;
- }
-
- /**
- * Get recent SQL queries from debug log
- */
- private function getRecentSqlQueries(): array
- {
- $queries = [];
-
- try {
- if (function_exists('DB')) {
- $db = DB();
-
- // Check if debug information is available
- if (!empty($db->dbg) && is_array($db->dbg)) {
- // Get last 5 queries
- $recentQueries = array_slice($db->dbg, -5);
-
- foreach ($recentQueries as $index => $queryInfo) {
- $queryNum = $index + 1;
- $queries["Query #$queryNum"] = [
- 'SQL' => $this->formatSqlQuery($queryInfo['sql'] ?? 'Unknown'),
- 'Time' => isset($queryInfo['time']) ? sprintf('%.3f sec', $queryInfo['time']) : 'Unknown',
- 'Source' => $queryInfo['src'] ?? 'Unknown',
- 'Info' => $queryInfo['info'] ?? '',
- ];
-
- // Add memory info if available
- if (isset($queryInfo['mem_before'], $queryInfo['mem_after'])) {
- $memUsed = $queryInfo['mem_after'] - $queryInfo['mem_before'];
- $queries["Query #$queryNum"]['Memory'] = sprintf('%+d bytes', $memUsed);
- }
- }
- }
-
- if (empty($queries)) {
- $queries['Info'] = 'No query debug information available. Enable debug mode to see recent queries.';
- }
- }
- } catch (\Exception $e) {
- $queries['Error'] = $e->getMessage();
- }
-
- return $queries;
- }
-
- /**
- * Get TorrentPier environment information
- */
- private function getTorrentPierEnvironment(): array
- {
- $env = [];
-
- try {
- // Basic environment
- $env['Application Environment'] = defined('APP_ENV') ? APP_ENV : 'Unknown';
- $env['Debug Mode'] = defined('DBG_USER') && DBG_USER ? 'Enabled' : 'Disabled';
- $env['SQL Debug'] = defined('SQL_DEBUG') && SQL_DEBUG ? 'Enabled' : 'Disabled';
-
- // Configuration status
- if (function_exists('config')) {
- $config = config();
- $env['Config Loaded'] = 'Yes';
- $env['TorrentPier Version'] = $config->get('tp_version', 'Unknown');
- $env['Board Title'] = $config->get('sitename', 'Unknown');
- } else {
- $env['Config Loaded'] = 'No';
- }
-
- // Cache system
- if (function_exists('CACHE')) {
- $env['Cache System'] = 'Available';
- }
-
- // Language system
- if (function_exists('lang')) {
- $env['Language System'] = 'Available';
- if (isset(lang()->getCurrentLanguage)) {
- $env['Current Language'] = lang()->getCurrentLanguage;
- }
- }
-
- // Memory and timing
- if (defined('TIMESTART')) {
- $env['Execution Time'] = sprintf('%.3f sec', microtime(true) - TIMESTART);
- }
-
- if (function_exists('sys')) {
- // Use plain text formatting for memory values (no HTML entities)
- $env['Peak Memory'] = str_replace(' ', ' ', humn_size(sys('mem_peak')));
- $env['Current Memory'] = str_replace(' ', ' ', humn_size(sys('mem')));
- }
-
- // Request information
- $env['Request Method'] = $_SERVER['REQUEST_METHOD'] ?? 'Unknown';
- $env['Request URI'] = $_SERVER['REQUEST_URI'] ?? 'CLI';
- $env['User Agent'] = $_SERVER['HTTP_USER_AGENT'] ?? 'Unknown';
- $env['Remote IP'] = $_SERVER['REMOTE_ADDR'] ?? 'Unknown';
-
- } catch (\Exception $e) {
- $env['Error'] = $e->getMessage();
- }
-
- return $env;
- }
-
- /**
- * Format SQL query for display
- */
- private function formatSqlQuery(string $query): string
- {
- // Remove debug comments
- $query = preg_replace('#^/\*.*?\*/#', '', $query);
- $query = trim($query);
-
- // Truncate very long queries but keep them readable
- if (strlen($query) > 1000) {
- return substr($query, 0, 1000) . "\n... [Query truncated - " . (strlen($query) - 1000) . " more characters]";
- }
-
- return $query;
- }
-
- /**
- * Override parent method to add database info and custom styling
- */
- public function handle()
- {
- // Add TorrentPier-specific database information dynamically
- try {
- $this->addDataTable('Database Information', $this->getDatabaseInformation());
- } catch (\Exception $e) {
- $this->addDataTable('Database Information', ['Error' => $e->getMessage()]);
- }
-
- try {
- $this->addDataTable('Recent SQL Queries', $this->getRecentSqlQueries());
- } catch (\Exception $e) {
- $this->addDataTable('Recent SQL Queries', ['Error' => $e->getMessage()]);
- }
-
- try {
- $this->addDataTable('TorrentPier Environment', $this->getTorrentPierEnvironment());
- } catch (\Exception $e) {
- $this->addDataTable('TorrentPier Environment', ['Error' => $e->getMessage()]);
- }
-
- return parent::handle();
- }
-}
diff --git a/legacy/src/helpers.php b/legacy/src/helpers.php
deleted file mode 100644
index b01f1bea5..000000000
--- a/legacy/src/helpers.php
+++ /dev/null
@@ -1,50 +0,0 @@
-get($id);
- } catch (NotFoundExceptionInterface $e) {
- throw new RuntimeException("Service '$id' not found in container: " . $e->getMessage(), 0, $e);
- } catch (ContainerExceptionInterface $e) {
- throw new RuntimeException("Container error while resolving '$id': " . $e->getMessage(), 0, $e);
- }
- }
-}
diff --git a/legacy/styles/js/libs/legacy.js b/legacy/styles/js/legacy.js
similarity index 100%
rename from legacy/styles/js/libs/legacy.js
rename to legacy/styles/js/legacy.js
diff --git a/resources/js/components/app-logo.tsx b/resources/js/components/app-logo.tsx
index 69bdcb84d..0df3d5226 100644
--- a/resources/js/components/app-logo.tsx
+++ b/resources/js/components/app-logo.tsx
@@ -7,7 +7,7 @@ export default function AppLogo() {
- Laravel Starter Kit
+ TorrentPier
);