+
+
+
+
+
+ The analytics and reporting features are currently disabled.
+ All core functionality including AI response generation remains fully operational.
+
No rules configured yet.
+ + ++ For advanced users: edit the complete rules configuration in JSON format. +
+ + +Message: ""
+Final Category:
+ + +Matched Rule: (Priority: )
+ +Rule Match: No rules matched
+ + + +AI Suggestion:
+ + +Configure Envato Market purchase code validation for your products.
+ + +/?page=install&token=YOUR_INSTALL_TOKEN once (same browser) or append ?token=YOUR_INSTALL_TOKEN here one time to unlock.';
+ exit;
+}
+// RPAI_HOOK:guard_passed
diff --git a/admin/index.php b/admin/index.php
new file mode 100644
index 0000000..23c4c16
--- /dev/null
+++ b/admin/index.php
@@ -0,0 +1,167 @@
+ '1', 'name' => 'Mock User', 'email' => 'mock@example.com',
+ 'message' => 'Mock support message', 'category' => 'Mock',
+ 'created_at' => date('Y-m-d H:i:s')]
+ ];
+} else {
+ try {
+ $stmt = $db->query('SELECT * FROM submissions ORDER BY id DESC LIMIT 100');
+ $rows = $stmt->fetchAll(PDO::FETCH_ASSOC);
+ } catch (\Throwable $e) {
+ $rows = [];
+ $dbError = $e->getMessage();
+ }
+}
+
+// Get current settings for dashboard
+$purchaseValidation = Settings::get('purchase_validation_enabled', false);
+$aiCategorization = Settings::get('ai_categorization_enabled', true);
+$totalSubmissions = count($rows);
+$categories = [];
+foreach ($rows as $row) {
+ $cat = $row['category'] ?? 'Unknown';
+ $categories[$cat] = ($categories[$cat] ?? 0) + 1;
+}
+?>
+
+
+
+
+
+ Configure AI providers, license validation, email settings, and security options.
+ Advanced Settings +Configure purchase code validation, API tokens, and allowed products.
+ Manage Envato Settings +Set up categorization rules, enable AI assistance, and test message classification.
+ Manage Categories +Customize automated email responses and notification templates.
+ Manage Emails +Monitor provider status, connection health, and system performance.
+ View Health +Last checked:
+ + +<iframe src="" width="100%" height="700" frameborder="0"></iframe>+
<form method="post" action="" accept-charset="utf-8" style="max-width:720px;margin:0 auto;font-family:system-ui,-apple-system,Segoe UI,Roboto,Arial,sans-serif"> + <label style="display:block;margin:8px 0">Name + <input name="name" required style="width:100%;padding:8px;border:1px solid #ccc;border-radius:4px"> + </label> + <label style="display:block;margin:8px 0">Email + <input type="email" name="email" required style="width:100%;padding:8px;border:1px solid #ccc;border-radius:4px"> + </label> + <label style="display:block;margin:8px 0">Message + <textarea name="message" required rows="6" style="width:100%;padding:8px;border:1px solid #ccc;border-radius:4px"></textarea> + </label> + <label style="display:block;margin:8px 0">Product Name + <input name="product_name" style="width:100%;padding:8px;border:1px solid #ccc;border-radius:4px"> + </label> + <label style="display:block;margin:8px 0">Tone + <select name="tone" style="width:100%;padding:8px;border:1px solid #ccc;border-radius:4px"> + <option value="friendly">Friendly</option> + <option value="professional">Professional</option> + </select> + </label> + <label style="display:block;margin:8px 0">Purchase Code (optional) + <input name="purchase_code" style="width:100%;padding:8px;border:1px solid #ccc;border-radius:4px"> + </label> + <button type="submit" style="display:inline-block;padding:10px 16px;border:0;border-radius:6px;cursor:pointer">Send</button> +</form>+
| ID | +Name | +Category | +Product | +Date | +Action | +|
|---|---|---|---|---|---|---|
| + | + | + | + | + | + | + |
' . htmlspecialchars($message) . '
'; + } + echo 'Please correct the issues above and try again.
'; + echo '← Go Back'; + echo '🔄 Try Again'; + echo ''; + echo ''; + } + protected static function envExists(): bool { + return file_exists(__DIR__ . DIRECTORY_SEPARATOR . '..' . DIRECTORY_SEPARATOR . '..' . DIRECTORY_SEPARATOR . '.env'); + } + protected static function isInstalled(): bool { + try { + $pdo = Database::createSafe(); + if (!$pdo) { + return false; // No database connection available + } + $stmt = $pdo->query("SHOW TABLES LIKE 'submissions'"); + $row = $stmt ? $stmt->fetch(PDO::FETCH_NUM) : false; + return $row ? true : false; + } catch (\Throwable $e) { + self::logLine('Installed check failed: ' . $e->getMessage()); + return false; + } + } + protected static function tokenOk(): bool { + $provided = $_GET['token'] ?? ''; + $envPresent = self::envExists(); + $expected = $envPresent ? (Env::get('INSTALL_TOKEN') ?? '') : (\defined('INSTALL_FALLBACK_TOKEN') ? INSTALL_FALLBACK_TOKEN : 'setup123'); + $ok = $expected !== '' && hash_equals((string)$expected, (string)$provided); + self::logLine('Token check: source=' . ($envPresent?'.env':'fallback') . ' result=' . ($ok?'OK':'FAIL')); // Token value masked for security + return $ok; + } + public static function run(){ + if (session_status() === PHP_SESSION_NONE) { session_start(); } + self::logLine('Visit installer: params=' . json_encode(['page'=>$_GET['page']??null])); + if (!self::tokenOk()) { + http_response_code(403); + echo 'Invalid token'; + return; + } + if (session_status() === PHP_SESSION_ACTIVE) { + session_regenerate_id(true); + } + $_SESSION['rpai_admin_unlocked'] = true; + $_SESSION['rpai_admin_timeout'] = time() + 1800; // 30 minute timeout + $installed = self::isInstalled(); + self::logLine('Installed? ' . ($installed?'yes':'no')); + if (($_SERVER['REQUEST_METHOD'] ?? 'GET') === 'POST') { + // handle POST install; accept db and advanced options + $dbHost = trim($_POST['db_host'] ?? ''); + $dbName = trim($_POST['db_name'] ?? ''); + $dbUser = trim($_POST['db_user'] ?? ''); + $dbPass = $_POST['db_pass'] ?? ''; // Don't trim passwords + + // Enhanced input validation + $errors = []; + if ($dbHost === '') $errors[] = 'Database host is required'; + if ($dbName === '') $errors[] = 'Database name is required'; + if ($dbUser === '') $errors[] = 'Database user is required'; + if (!preg_match('/^[a-zA-Z0-9._-]+$/', $dbName)) $errors[] = 'Invalid database name format'; + if (strlen($dbName) > 64) $errors[] = 'Database name too long (max 64 characters)'; + + if (!empty($errors)) { + self::logLine('Validation failed: ' . implode(', ', $errors)); + self::displayError('Validation Error', $errors); + return; + } + + // Advanced options + $openaiKey = trim($_POST['openai_key'] ?? ''); + $smtpHost = trim($_POST['smtp_host'] ?? ''); + $smtpPort = trim($_POST['smtp_port'] ?? ''); + $smtpUser = trim($_POST['smtp_user'] ?? ''); + $smtpPass = trim($_POST['smtp_pass'] ?? ''); + $envatoToken = trim($_POST['envato_token'] ?? ''); + + // Build env data with production-ready defaults + $envData = [ + 'APP_ENV' => 'production', + 'APP_DEBUG' => 'false', + 'APP_KEY' => base64_encode(random_bytes(32)), + 'DB_CONNECTION' => 'mysql', + 'DB_HOST' => $dbHost, + 'DB_NAME' => $dbName, + 'DB_USER' => $dbUser, + 'DB_PASS' => $dbPass, + 'INSTALL_TOKEN' => 'setup123', + ]; + + // Add OpenAI config if provided + if ($openaiKey !== '') { + $envData['OPENAI_API_KEY'] = $openaiKey; + } + + // Add SMTP config if provided + if ($smtpHost !== '' && $smtpUser !== '') { + $envData['MAIL_TRANSPORT'] = 'smtp'; + $envData['SMTP_HOST'] = $smtpHost; + $envData['SMTP_PORT'] = $smtpPort ?: '587'; + $envData['SMTP_USER'] = $smtpUser; + if ($smtpPass !== '') { + $envData['SMTP_PASS'] = $smtpPass; + } + } + + // Add Envato config if provided + if ($envatoToken !== '') { + $envData['ENVATO_PERSONAL_TOKEN'] = $envatoToken; + } + + // write env + EnvWriter::write($envData, __DIR__ . DIRECTORY_SEPARATOR . '..' . DIRECTORY_SEPARATOR . '..' . DIRECTORY_SEPARATOR . '.env'); + self::logLine('Wrote .env with ' . count($envData) . ' keys (secrets masked).'); + + try { + self::logLine('Starting database setup phase'); + + // Step 1: Test initial connection + $dsn = "mysql:host={$dbHost}"; + $adminPdo = null; + try { + $adminPdo = new \PDO($dsn, $dbUser, $dbPass, [ + \PDO::ATTR_ERRMODE => \PDO::ERRMODE_EXCEPTION, + \PDO::ATTR_TIMEOUT => 10 + ]); + self::logLine('Initial database connection successful'); + } catch (\PDOException $e) { + $sanitizedError = preg_replace('/password[^\s]*/i', 'password=***', $e->getMessage()); + self::logLine('Database connection failed: ' . $sanitizedError); + self::displayError('Database Connection Failed', [ + 'Could not connect to database server', + 'Please verify your host, username, and password', + 'MySQL Error: ' . $sanitizedError + ]); + return; + } + + // Step 2: Create/verify database + try { + $adminPdo->exec("CREATE DATABASE IF NOT EXISTS `{$dbName}` CHARACTER SET utf8mb4 COLLATE utf8mb4_unicode_ci"); + self::logLine('Database created/verified with UTF8MB4 charset'); + } catch (\PDOException $e) { + $sanitizedError = preg_replace('/password[^\s]*/i', 'password=***', $e->getMessage()); + self::logLine('Database creation failed: ' . $sanitizedError); + self::displayError('Database Creation Failed', [ + 'Could not create or access database: ' . $dbName, + 'Please ensure the user has CREATE privileges', + 'MySQL Error: ' . $sanitizedError + ]); + return; + } + + // Step 3: Connect to specific database + $dsn = "mysql:host={$dbHost};dbname={$dbName};charset=utf8mb4"; + $pdo = null; + try { + $pdo = new \PDO($dsn, $dbUser, $dbPass, [ + \PDO::ATTR_ERRMODE => \PDO::ERRMODE_EXCEPTION, + \PDO::ATTR_DEFAULT_FETCH_MODE => \PDO::FETCH_ASSOC + ]); + self::logLine('Connected to target database successfully'); + } catch (\PDOException $e) { + $sanitizedError = preg_replace('/password[^\s]*/i', 'password=***', $e->getMessage()); + self::logLine('Target database connection failed: ' . $sanitizedError); + self::displayError('Database Access Failed', [ + 'Could not connect to database: ' . $dbName, + 'Database may have been created but is not accessible', + 'MySQL Error: ' . $sanitizedError + ]); + return; + } + + // Step 4: Create tables with transaction support + try { + $pdo->beginTransaction(); + $tables = SqlSchema::createAllTables(); + $createdTables = []; + + foreach ($tables as $i => $tableSQL) { + try { + $pdo->exec($tableSQL); + $createdTables[] = 'Table ' . ($i + 1); + self::logLine('Created table: ' . ($i + 1) . '/' . count($tables)); + } catch (\PDOException $e) { + $sanitizedError = preg_replace('/password[^\s]*/i', 'password=***', $e->getMessage()); + self::logLine('Table creation failed at step ' . ($i + 1) . ': ' . $sanitizedError); + if ($pdo->inTransaction()) { $pdo->rollBack(); } + self::displayError('Table Creation Failed', [ + 'Failed to create table ' . ($i + 1) . ' of ' . count($tables), + 'All changes have been rolled back', + 'MySQL Error: ' . $sanitizedError + ]); + return; + } + } + + $pdo->commit(); + self::logLine('All tables created successfully: ' . count($tables) . ' tables'); + + } catch (\Throwable $e) { + if ($pdo && $pdo->inTransaction()) { + $pdo->rollBack(); + self::logLine('Transaction rolled back due to error'); + } + throw $e; + } + + // Success response + echo 'ReplyPilot-AI has been successfully installed and configured.
'; + echo 'ReplyPilot-AI is already set up and ready to use.
'; + echo 'Go to Admin'; + echo 'Let\'s set up your AI-powered support system.
'; + echo ''; + echo ''; + echo ''; + } +} +?> diff --git a/app/Installer/Migrator.php b/app/Installer/Migrator.php new file mode 100644 index 0000000..1fe7468 --- /dev/null +++ b/app/Installer/Migrator.php @@ -0,0 +1,509 @@ +db = new Database(); + $this->logger = new Logger(); + $this->currentVersion = $this->getCurrentVersion(); + $this->migrations = $this->loadMigrations(); + } + + /** + * Check if migration is needed + */ + public function needsMigration(): bool + { + $installedVersion = Settings::get('app_version', '1.0.0'); + return version_compare($installedVersion, $this->currentVersion, '<'); + } + + /** + * Run auto-migration + */ + public function migrate(): array + { + $results = [ + 'success' => true, + 'from_version' => Settings::get('app_version', '1.0.0'), + 'to_version' => $this->currentVersion, + 'migrations_run' => [], + 'errors' => [] + ]; + + try { + $this->db->beginTransaction(); + + // Ensure migration tracking table exists + $this->createMigrationTable(); + + // Run pending migrations + foreach ($this->migrations as $version => $migration) { + if ($this->shouldRunMigration($version, $results['from_version'])) { + $this->logger->info("Running migration for version {$version}"); + + $migrationResult = $this->runMigration($migration); + $results['migrations_run'][] = [ + 'version' => $version, + 'description' => $migration['description'], + 'success' => $migrationResult['success'] + ]; + + if (!$migrationResult['success']) { + $results['errors'][] = "Migration {$version}: " . $migrationResult['error']; + $results['success'] = false; + break; + } + + $this->recordMigration($version, $migration['description']); + } + } + + if ($results['success']) { + Settings::set('app_version', $this->currentVersion); + $this->db->commit(); + $this->logger->info("Migration completed successfully to version {$this->currentVersion}"); + } else { + $this->db->rollback(); + $this->logger->error("Migration failed: " . implode(', ', $results['errors'])); + } + + } catch (\Exception $e) { + $this->db->rollback(); + $results['success'] = false; + $results['errors'][] = $e->getMessage(); + $this->logger->error("Migration exception: " . $e->getMessage()); + } + + return $results; + } + + /** + * Get current application version + */ + protected function getCurrentVersion(): string + { + // Read from composer.json or version file + $composerPath = dirname(__DIR__, 2) . '/composer.json'; + if (file_exists($composerPath)) { + $composer = json_decode(file_get_contents($composerPath), true); + return $composer['version'] ?? '2.0.0'; + } + return '2.0.0'; + } + + /** + * Load migration definitions + */ + protected function loadMigrations(): array + { + return [ + '1.5.0' => [ + 'description' => 'Add analytics tables', + 'sql' => [ + "CREATE TABLE IF NOT EXISTS ai_analytics ( + id int AUTO_INCREMENT PRIMARY KEY, + provider varchar(50) NOT NULL, + model varchar(100) NOT NULL, + message_length int DEFAULT 0, + response_length int DEFAULT 0, + tokens_used int DEFAULT 0, + response_time decimal(8,3) DEFAULT 0.000, + category varchar(50) DEFAULT 'Support', + confidence decimal(3,2) DEFAULT 0.00, + cached boolean DEFAULT false, + tone varchar(20) DEFAULT 'friendly', + product_name varchar(255) DEFAULT '', + success boolean DEFAULT true, + error_message text NULL, + created_at datetime NOT NULL, + KEY idx_created_at (created_at), + KEY idx_provider (provider), + KEY idx_success (success) + ) ENGINE=InnoDB DEFAULT CHARSET=utf8mb4", + + "CREATE TABLE IF NOT EXISTS license_analytics ( + id int AUTO_INCREMENT PRIMARY KEY, + validator varchar(50) NOT NULL, + code_length int DEFAULT 0, + validation_time decimal(8,3) DEFAULT 0.000, + success boolean DEFAULT false, + error_message text NULL, + product_name varchar(255) DEFAULT '', + created_at datetime NOT NULL, + KEY idx_created_at (created_at), + KEY idx_validator (validator) + ) ENGINE=InnoDB DEFAULT CHARSET=utf8mb4" + ], + 'settings' => [ + 'analytics_enabled' => true, + 'analytics_retention_days' => 90 + ] + ], + + '1.8.0' => [ + 'description' => 'Add response cache table', + 'sql' => [ + "CREATE TABLE IF NOT EXISTS response_cache ( + id int AUTO_INCREMENT PRIMARY KEY, + message text NOT NULL, + message_hash varchar(64) NOT NULL, + tone varchar(20) NOT NULL, + product_name varchar(255) NOT NULL, + reply text NOT NULL, + category varchar(50) NOT NULL, + confidence decimal(3,2) DEFAULT 0.00, + tokens_used int DEFAULT 0, + hit_count int DEFAULT 1, + expires_at datetime NOT NULL, + created_at datetime NOT NULL, + last_accessed datetime NULL, + KEY idx_hash_tone_product (message_hash, tone, product_name), + KEY idx_expires (expires_at), + UNIQUE KEY unique_cache (message_hash, tone, product_name) + ) ENGINE=InnoDB DEFAULT CHARSET=utf8mb4" + ], + 'settings' => [ + 'response_cache_enabled' => true, + 'cache_ttl' => 3600, + 'cache_similarity_threshold' => 0.85 + ] + ], + + '2.0.0' => [ + 'description' => 'Add system health monitoring', + 'sql' => [ + "CREATE TABLE IF NOT EXISTS system_health_log ( + id int AUTO_INCREMENT PRIMARY KEY, + metric_name varchar(100) NOT NULL, + metric_value decimal(10,4) NOT NULL, + metric_unit varchar(20) DEFAULT '', + status enum('healthy','warning','critical') DEFAULT 'healthy', + details json NULL, + created_at datetime NOT NULL, + KEY idx_metric_created (metric_name, created_at), + KEY idx_status (status) + ) ENGINE=InnoDB DEFAULT CHARSET=utf8mb4", + + "CREATE TABLE IF NOT EXISTS migration_history ( + id int AUTO_INCREMENT PRIMARY KEY, + version varchar(20) NOT NULL, + description text NOT NULL, + executed_at datetime NOT NULL, + UNIQUE KEY unique_version (version) + ) ENGINE=InnoDB DEFAULT CHARSET=utf8mb4" + ], + 'settings' => [ + 'health_monitoring_enabled' => true, + 'health_check_interval' => 300, + 'error_alerting_enabled' => false + ] + ] + ]; + } + + /** + * Check if migration should run + */ + protected function shouldRunMigration(string $migrationVersion, string $installedVersion): bool + { + // Check if already run + $result = $this->db->query( + "SELECT id FROM migration_history WHERE version = ?", + [$migrationVersion] + ); + + if (!empty($result)) { + return false; // Already run + } + + // Check version requirements + return version_compare($installedVersion, $migrationVersion, '<'); + } + + /** + * Run individual migration + */ + protected function runMigration(array $migration): array + { + try { + // Run SQL commands + if (!empty($migration['sql'])) { + foreach ($migration['sql'] as $sql) { + $this->db->query($sql); + } + } + + // Apply settings + if (!empty($migration['settings'])) { + foreach ($migration['settings'] as $key => $value) { + if (!Settings::has($key)) { + Settings::set($key, $value); + } + } + } + + // Run custom migration function if exists + if (!empty($migration['function']) && is_callable($migration['function'])) { + call_user_func($migration['function'], $this->db); + } + + return ['success' => true]; + + } catch (\Exception $e) { + return [ + 'success' => false, + 'error' => $e->getMessage() + ]; + } + } + + /** + * Record migration in history + */ + protected function recordMigration(string $version, string $description): void + { + $this->db->query( + "INSERT INTO migration_history (version, description, executed_at) VALUES (?, ?, NOW())", + [$version, $description] + ); + } + + /** + * Create migration tracking table + */ + protected function createMigrationTable(): void + { + $sql = "CREATE TABLE IF NOT EXISTS migration_history ( + id int AUTO_INCREMENT PRIMARY KEY, + version varchar(20) NOT NULL, + description text NOT NULL, + executed_at datetime NOT NULL, + UNIQUE KEY unique_version (version) + ) ENGINE=InnoDB DEFAULT CHARSET=utf8mb4"; + + $this->db->query($sql); + } + + /** + * Get migration history + */ + public function getMigrationHistory(): array + { + try { + return $this->db->query( + "SELECT * FROM migration_history ORDER BY executed_at DESC" + ); + } catch (\Exception $e) { + return []; + } + } + + /** + * Check system health before migration + */ + public function checkMigrationReadiness(): array + { + $checks = [ + 'database_connection' => $this->checkDatabaseConnection(), + 'disk_space' => $this->checkDiskSpace(), + 'php_version' => $this->checkPhpVersion(), + 'required_extensions' => $this->checkRequiredExtensions(), + 'write_permissions' => $this->checkWritePermissions() + ]; + + $allPassed = array_reduce($checks, function($carry, $check) { + return $carry && $check['status'] === 'ok'; + }, true); + + return [ + 'ready' => $allPassed, + 'checks' => $checks + ]; + } + + /** + * Database connection check + */ + protected function checkDatabaseConnection(): array + { + try { + $this->db->query("SELECT 1"); + return ['status' => 'ok', 'message' => 'Database connection working']; + } catch (\Exception $e) { + return ['status' => 'error', 'message' => 'Database connection failed: ' . $e->getMessage()]; + } + } + + /** + * Disk space check + */ + protected function checkDiskSpace(): array + { + $freeBytes = disk_free_space('.'); + $freeGB = round($freeBytes / (1024 * 1024 * 1024), 2); + + if ($freeGB < 1) { + return ['status' => 'warning', 'message' => "Low disk space: {$freeGB}GB available"]; + } + + return ['status' => 'ok', 'message' => "{$freeGB}GB available"]; + } + + /** + * PHP version check + */ + protected function checkPhpVersion(): array + { + $version = PHP_VERSION; + if (version_compare($version, '8.0.0', '<')) { + return ['status' => 'error', 'message' => "PHP {$version} is too old (8.0+ required)"]; + } + + return ['status' => 'ok', 'message' => "PHP {$version}"]; + } + + /** + * Required extensions check + */ + protected function checkRequiredExtensions(): array + { + $required = ['pdo', 'pdo_mysql', 'json', 'curl', 'openssl']; + $missing = []; + + foreach ($required as $ext) { + if (!extension_loaded($ext)) { + $missing[] = $ext; + } + } + + if (!empty($missing)) { + return ['status' => 'error', 'message' => 'Missing extensions: ' . implode(', ', $missing)]; + } + + return ['status' => 'ok', 'message' => 'All required extensions loaded']; + } + + /** + * Write permissions check + */ + protected function checkWritePermissions(): array + { + $paths = [ + dirname(__DIR__, 2) . '/storage/logs', + dirname(__DIR__, 2) . '/storage' + ]; + + $errors = []; + foreach ($paths as $path) { + if (!is_writable($path)) { + $errors[] = $path; + } + } + + if (!empty($errors)) { + return ['status' => 'error', 'message' => 'Not writable: ' . implode(', ', $errors)]; + } + + return ['status' => 'ok', 'message' => 'All paths writable']; + } + + /** + * Create backup before migration + */ + public function createBackup(): array + { + try { + $backupDir = dirname(__DIR__, 2) . '/storage/backups'; + if (!is_dir($backupDir)) { + mkdir($backupDir, 0755, true); + } + + $timestamp = date('Y-m-d_H-i-s'); + $backupFile = "{$backupDir}/backup_before_migration_{$timestamp}.json"; + + // Backup critical settings + $backup = [ + 'version' => Settings::get('app_version', '1.0.0'), + 'timestamp' => date('Y-m-d H:i:s'), + 'settings' => $this->exportSettings(), + 'database_schema' => $this->exportDatabaseSchema() + ]; + + file_put_contents($backupFile, json_encode($backup, JSON_PRETTY_PRINT)); + + return [ + 'success' => true, + 'backup_file' => $backupFile, + 'size' => filesize($backupFile) + ]; + + } catch (\Exception $e) { + return [ + 'success' => false, + 'error' => $e->getMessage() + ]; + } + } + + /** + * Export current settings + */ + protected function exportSettings(): array + { + // Get all non-sensitive settings + $settings = []; + $sensitiveKeys = ['envato_personal_token', 'openai_api_key', 'app_key']; + + try { + $allSettings = Settings::getAll(); + foreach ($allSettings as $key => $value) { + if (!in_array($key, $sensitiveKeys)) { + $settings[$key] = $value; + } + } + } catch (\Exception $e) { + // Settings table might not exist yet + } + + return $settings; + } + + /** + * Export database schema information + */ + protected function exportDatabaseSchema(): array + { + try { + $tables = $this->db->query("SHOW TABLES"); + $schema = []; + + foreach ($tables as $table) { + $tableName = array_values($table)[0]; + $columns = $this->db->query("DESCRIBE {$tableName}"); + $schema[$tableName] = $columns; + } + + return $schema; + + } catch (\Exception $e) { + return ['error' => $e->getMessage()]; + } + } +} diff --git a/app/Installer/SqlSchema.php b/app/Installer/SqlSchema.php new file mode 100644 index 0000000..0b5e54d --- /dev/null +++ b/app/Installer/SqlSchema.php @@ -0,0 +1,149 @@ + \ No newline at end of file diff --git a/app/Registry/ProviderRegistry.php b/app/Registry/ProviderRegistry.php new file mode 100644 index 0000000..bc20716 --- /dev/null +++ b/app/Registry/ProviderRegistry.php @@ -0,0 +1,304 @@ + self::getAIProviderConfiguration(), + 'license_validators' => self::getLicenseValidatorConfiguration(), + 'active_providers' => self::getActiveProviders(), + 'system_settings' => self::getSystemSettings() + ]; + } + + /** + * Get AI provider configuration + */ + protected static function getAIProviderConfiguration(): array + { + $available = AIProviderFactory::getAvailableProviders(); + $schemas = AIProviderFactory::getConfigSchemas(); + $active = Settings::get('ai_provider', 'openai'); + + $config = []; + foreach ($available as $name => $info) { + $config[$name] = [ + 'name' => $name, + 'display_name' => ucfirst($name), + 'available' => $info['available'], + 'active' => $name === $active, + 'info' => $info['info'], + 'schema' => $schemas[$name] ?? [], + 'settings' => self::getProviderSettings('ai', $name) + ]; + } + + return $config; + } + + /** + * Get license validator configuration + */ + protected static function getLicenseValidatorConfiguration(): array + { + $available = LicenseValidatorFactory::getAvailableValidators(); + $schemas = LicenseValidatorFactory::getConfigSchemas(); + $active = Settings::get('license_validator', 'envato'); + + $config = []; + foreach ($available as $name => $info) { + $config[$name] = [ + 'name' => $name, + 'display_name' => ucfirst($name), + 'available' => $info['available'], + 'active' => $name === $active, + 'info' => $info['info'], + 'schema' => $schemas[$name] ?? [], + 'settings' => self::getProviderSettings('license', $name) + ]; + } + + return $config; + } + + /** + * Get settings for a specific provider + */ + protected static function getProviderSettings(string $type, string $provider): array + { + $settings = []; + $prefix = $provider . '_'; + + // Get regular settings + $allSettings = Settings::get('*', []); // Assuming Settings supports wildcard + foreach ($allSettings as $key => $value) { + if (strpos($key, $prefix) === 0) { + $settings[substr($key, strlen($prefix))] = $value; + } + } + + // Note: Secure settings are not included for security reasons + + return $settings; + } + + /** + * Get currently active providers + */ + protected static function getActiveProviders(): array + { + return [ + 'ai' => Settings::get('ai_provider', 'openai'), + 'license' => Settings::get('license_validator', 'envato') + ]; + } + + /** + * Get system-wide settings + */ + protected static function getSystemSettings(): array + { + return [ + 'purchase_validation_enabled' => Settings::get('purchase_validation_enabled', false), + 'purchase_code_enabled' => Settings::get('purchase_code_enabled', false), + 'purchase_code_required' => Settings::get('purchase_code_required', false), + 'ai_categorization_enabled' => Settings::get('ai_categorization_enabled', true), + 'ajax_rate_limit' => Settings::get('ajax_rate_limit', 6), + 'session_timeout' => Settings::get('session_timeout', 3600), + 'ai_token_limit' => Settings::get('ai_token_limit', 1000), + 'mail_transport' => Settings::get('mail_transport', 'smtp'), + 'mail_from_name' => Settings::get('mail_from_name', 'ReplyPilot AI'), + 'mail_from_address' => Settings::get('mail_from_address', 'noreply@example.com') + ]; + } + + /** + * Validate provider configuration + */ + public static function validateConfiguration(string $type, string $provider, array $config): array + { + try { + if ($type === 'ai') { + $instance = AIProviderFactory::create($provider); + return $instance->validateConfig($config); + } elseif ($type === 'license') { + $instance = LicenseValidatorFactory::create($provider); + return $instance->validateConfig($config); + } + } catch (\Throwable $e) { + return [ + 'valid' => false, + 'errors' => ['Configuration validation failed: ' . $e->getMessage()] + ]; + } + + return ['valid' => false, 'errors' => ['Unknown provider type']]; + } + + /** + * Update provider configuration + */ + public static function updateProviderConfiguration(string $type, string $provider, array $config): bool + { + try { + // Validate configuration first + $validation = self::validateConfiguration($type, $provider, $config); + if (!$validation['valid']) { + return false; + } + + // Save settings + foreach ($config as $key => $value) { + $settingKey = $provider . '_' . $key; + + // Determine if setting should be encrypted + if (in_array($key, ['api_key', 'personal_token', 'secret', 'password'])) { + Settings::setSecure($settingKey, $value); + } else { + Settings::set($settingKey, $value); + } + } + + return true; + } catch (\Throwable $e) { + error_log('Failed to update provider configuration: ' . $e->getMessage()); + return false; + } + } + + /** + * Get health check for all providers + */ + public static function getHealthCheck(): array + { + $health = [ + 'overall_status' => 'healthy', + 'ai_providers' => [], + 'license_validators' => [], + 'issues' => [] + ]; + + // Check AI providers + foreach (AIProviderFactory::getAvailableProviders() as $name => $info) { + $status = 'unknown'; + $message = 'Not tested'; + + try { + $instance = AIProviderFactory::create($name); + $test = $instance->testConnection(); + $status = $test['available'] ? 'healthy' : 'unhealthy'; + $message = $test['message']; + } catch (\Throwable $e) { + $status = 'error'; + $message = $e->getMessage(); + $health['issues'][] = "AI Provider {$name}: {$message}"; + } + + $health['ai_providers'][$name] = [ + 'status' => $status, + 'message' => $message + ]; + } + + // Check license validators + foreach (LicenseValidatorFactory::getAvailableValidators() as $name => $info) { + $status = 'unknown'; + $message = 'Not tested'; + + try { + $instance = LicenseValidatorFactory::create($name); + $test = $instance->testConnection(); + $status = $test['connected'] ? 'healthy' : 'unhealthy'; + $message = $test['message']; + } catch (\Throwable $e) { + $status = 'error'; + $message = $e->getMessage(); + $health['issues'][] = "License Validator {$name}: {$message}"; + } + + $health['license_validators'][$name] = [ + 'status' => $status, + 'message' => $message + ]; + } + + // Determine overall status + if (!empty($health['issues'])) { + $health['overall_status'] = 'degraded'; + } + + return $health; + } + + /** + * Export configuration for backup/migration + */ + public static function exportConfiguration(): array + { + $export = [ + 'version' => '1.0', + 'exported_at' => date('Y-m-d H:i:s'), + 'configuration' => self::getConfiguration() + ]; + + // Remove sensitive data + foreach ($export['configuration']['ai_providers'] as &$provider) { + unset($provider['settings']['api_key']); + unset($provider['settings']['secret']); + } + + foreach ($export['configuration']['license_validators'] as &$validator) { + unset($validator['settings']['personal_token']); + unset($validator['settings']['api_key']); + } + + return $export; + } + + /** + * Import configuration from backup + */ + public static function importConfiguration(array $config): bool + { + try { + if (!isset($config['configuration'])) { + throw new \InvalidArgumentException('Invalid configuration format'); + } + + $configuration = $config['configuration']; + + // Import system settings + if (isset($configuration['system_settings'])) { + foreach ($configuration['system_settings'] as $key => $value) { + Settings::set($key, $value); + } + } + + // Import active providers + if (isset($configuration['active_providers'])) { + foreach ($configuration['active_providers'] as $type => $provider) { + Settings::set($type . '_provider', $provider); + } + } + + return true; + } catch (\Throwable $e) { + error_log('Failed to import configuration: ' . $e->getMessage()); + return false; + } + } +} diff --git a/app/Repository/EmailRepository.php b/app/Repository/EmailRepository.php new file mode 100644 index 0000000..8856c59 --- /dev/null +++ b/app/Repository/EmailRepository.php @@ -0,0 +1,32 @@ +pdo = $pdo; } + + public function logOutbound(int $submissionId, string $to, string $subject, string $body, string $status='sent', ?string $providerId=null, ?string $error=null): void { + $stmt = $this->pdo->prepare("INSERT INTO emails (submission_id, direction, `to`, subject, body, sent_at, status, provider_message_id, error) VALUES (?,?,?,?,?, NOW(), ?, ?, ?)"); + $stmt->execute([$submissionId, 'outbound', $to, $subject, $body, $status, $providerId, $error]); + } + + /** + * @param int[] $submissionIds + * @return arrayAn error occurred. Please try again.
'; + exit; + } + } + } + + public static function handleShutdown() { + $error = error_get_last(); + if ($error && in_array($error['type'], [E_ERROR, E_CORE_ERROR, E_COMPILE_ERROR, E_PARSE])) { + $correlationId = self::getCorrelationId(); + $route = self::getCurrentRoute(); + $paramKeys = self::getRequestParamKeys(); + + $context = [ + 'type' => 'fatal_error', + 'file' => $error['file'], + 'line' => $error['line'], + 'route' => $route, + 'param_keys' => $paramKeys, + 'correlation_id' => $correlationId + ]; + + self::log('Fatal Error: ' . $error['message'], $context); + + // For AJAX requests, return JSON error envelope + if (self::isAjaxRequest() && !headers_sent()) { + http_response_code(500); + header('Content-Type: application/json; charset=utf-8'); + echo json_encode([ + 'ok' => false, + 'error' => [ + 'id' => 'fatal_error', + 'message' => 'Fatal server error', + 'hint' => 'Please try again or contact support' + ], + 'request_id' => $correlationId + ]); + } + } + } + + private static function getCurrentRoute() { + $script = $_SERVER['SCRIPT_NAME'] ?? ''; + $query = $_SERVER['QUERY_STRING'] ?? ''; + $method = $_SERVER['REQUEST_METHOD'] ?? 'GET'; + + $route = $method . ' ' . $script; + if ($query) { + // Only log query parameter keys, not values + parse_str($query, $params); + $route .= '?' . implode('&', array_keys($params)); + } + + return $route; + } + + private static function getRequestParamKeys() { + $keys = []; + + // GET parameters + if (!empty($_GET)) { + $keys['GET'] = array_keys($_GET); + } + + // POST parameters (keys only, no values for security) + if (!empty($_POST)) { + $keys['POST'] = array_keys($_POST); + } + + return $keys; + } + + private static function getCorrelationId() { + static $id = null; + if ($id === null) { + $id = bin2hex(random_bytes(8)); + } + return $id; + } + + private static function isAjaxRequest() { + return ( + !empty($_SERVER['HTTP_X_REQUESTED_WITH']) && + strtolower($_SERVER['HTTP_X_REQUESTED_WITH']) === 'xmlhttprequest' + ) || ( + !empty($_SERVER['CONTENT_TYPE']) && + strpos($_SERVER['CONTENT_TYPE'], 'application/json') !== false + ) || ( + !empty($_SERVER['HTTP_ACCEPT']) && + strpos($_SERVER['HTTP_ACCEPT'], 'application/json') !== false + ); + } + + private static function log($message, $context = []) { + if (self::$logger) { + // Use existing logger + self::$logger->error($message, $context); + } else { + // Fallback to file logging + $logEntry = [ + 'timestamp' => date('Y-m-d H:i:s'), + 'message' => $message, + 'context' => $context + ]; + + $logDir = __DIR__ . '/../../storage/logs'; + if (!is_dir($logDir)) { + @mkdir($logDir, 0755, true); + } + + $logFile = $logDir . '/error-' . date('Y-m-d') . '.log'; + @error_log(json_encode($logEntry) . "\n", 3, $logFile); + } + } +} diff --git a/app/Support/Logger.php b/app/Support/Logger.php new file mode 100644 index 0000000..c2d4157 --- /dev/null +++ b/app/Support/Logger.php @@ -0,0 +1,71 @@ +logPath = $path; + $dir = dirname($this->logPath); + if (!is_dir($dir)) { + @mkdir($dir, 0775, true); + } + $this->mono = null; + if ($this->bootstrapMonolog()) { + $this->mono = new \Monolog\Logger('app'); + $this->mono->pushHandler(new \Monolog\Handler\StreamHandler($this->logPath, \Monolog\Logger::DEBUG)); + } + } + + protected function bootstrapMonolog(): bool + { + if (class_exists('Monolog\\Logger') && class_exists('Monolog\\Handler\\StreamHandler')) { + return true; + } + // Try to include Monolog manually if no composer autoload + $base = __DIR__ . '/../../vendor/monolog/monolog/src/Monolog/'; + $files = [ + 'Logger.php', + 'Handler/StreamHandler.php', + 'Level.php', + 'DateTimeImmutable.php' + ]; + foreach ($files as $f) { + $p = $base . $f; + if (file_exists($p)) { + require_once $p; + } + } + return class_exists('Monolog\\Logger') && class_exists('Monolog\\Handler\\StreamHandler'); + } + + public static function create(): self + { + $logPath = __DIR__ . '/../../storage/logs/app.log'; + return new self($logPath); + } + + protected function write(string $level, string $message, array $context = []): void + { + if ($this->mono) { + $lvl = strtoupper($level); + $lvlConst = defined('Monolog\\Logger::' . $lvl) ? constant('Monolog\\Logger::' . $lvl) : \Monolog\Logger::INFO; + $this->mono->log($lvlConst, $message, $context); + return; + } + $date = date('Y-m-d H:i:s'); + $line = "[$date] $level: " . $message; + if (!empty($context)) { + $line .= ' ' . json_encode($context); + } + $line .= PHP_EOL; + file_put_contents($this->logPath, $line, FILE_APPEND); + } + + public function info(string $message, array $context = []): void { $this->write('info', $message, $context); } + public function error(string $message, array $context = []): void { $this->write('error', $message, $context); } + public function debug(string $message, array $context = []): void { $this->write('debug', $message, $context); } +} +?> \ No newline at end of file diff --git a/app/Support/Mailer.php b/app/Support/Mailer.php new file mode 100644 index 0000000..243143e --- /dev/null +++ b/app/Support/Mailer.php @@ -0,0 +1,98 @@ +bootstrapPHPMailer()) { + try { + $mail = new \PHPMailer\PHPMailer\PHPMailer(true); + $mail->CharSet = 'UTF-8'; + $mail->isSMTP(); + $mail->Timeout = 10; + $mail->Host = Env::get('SMTP_HOST', ''); + $mail->Port = (int) Env::get('SMTP_PORT', 587); + $mail->SMTPAuth = Env::get('SMTP_AUTH', 'true') !== 'false'; + $mail->Username = Env::get('SMTP_USERNAME', ''); + $mail->Password = Env::get('SMTP_PASS', ''); + $encryption = strtolower((string) Env::get('SMTP_ENCRYPTION', 'tls')); + if ($encryption === 'ssl') { + $mail->SMTPSecure = \PHPMailer\PHPMailer\PHPMailer::ENCRYPTION_SMTPS; + } elseif ($encryption === 'tls') { + $mail->SMTPSecure = \PHPMailer\PHPMailer\PHPMailer::ENCRYPTION_STARTTLS; + } // else: none + + if ($from) { + $mail->setFrom($from, $fromName ?: ''); + $mail->addReplyTo($from, $fromName ?: ''); + } + $mail->addAddress($to); + $mail->Subject = $subject; + $mail->isHTML(true); + $mail->Body = $html; + if ($text) { $mail->AltBody = $text; } + + $mail->send(); + return true; + } catch (\Throwable $e) { + $domain = substr($to, strpos($to, '@') + 1); + error_log('SMTP send failed to ' . $domain . ': ' . $e->getMessage()); + // fall back to native mail() + } + } + + // Fallback: native mail() + $headers = []; + $headers[] = 'MIME-Version: 1.0'; + $headers[] = 'Content-type: text/html; charset=UTF-8'; + if ($from) { + $fromHeader = $fromName ? sprintf('"%s" <%s>', $fromName, $from) : $from; + $headers[] = 'From: ' . $fromHeader; + $headers[] = 'Reply-To: ' . $fromHeader; + } + $ok = mail($to, '=?UTF-8?B?'.base64_encode($subject).'?=', $html, implode("\r\n", $headers)); + if (!$ok) { + $domain = substr($to, strpos($to, '@') + 1); + error_log('mail() fallback failed to ' . $domain); + } + return $ok; + } +} +?> \ No newline at end of file diff --git a/app/Support/MailerMock.php b/app/Support/MailerMock.php new file mode 100644 index 0000000..2d7ef46 --- /dev/null +++ b/app/Support/MailerMock.php @@ -0,0 +1,16 @@ +optimizationRules = []; + $this->categoryPrompts = []; + $this->toneModifiers = []; + } + + /** + * Optimize a prompt for better AI responses - RETURNS INPUT UNCHANGED + */ + public function optimize(string $basePrompt, array $context = []): array + { + // Prompt optimization is disabled - return input unchanged + $originalTokens = $this->estimateTokens($basePrompt); + + return [ + 'original_prompt' => $basePrompt, + 'optimized_prompt' => $basePrompt, // No optimization applied + 'optimizations_applied' => [], // No optimizations + 'original_tokens' => $originalTokens, + 'optimized_tokens' => $originalTokens, // Same as original + 'token_savings' => 0, // No savings + 'compression_ratio' => 0 // No compression + ]; + } + + /** + * Estimate token count for a prompt + */ + protected function estimateTokens(string $text): int + { + // Rough estimation: 1 token ≈ 4 characters for English + return (int) ceil(strlen($text) / 4); + } + + /** + * Analyze prompt effectiveness - RETURNS MINIMAL ANALYSIS + */ + public function analyzePrompt(string $prompt): array + { + return [ + 'length' => strlen($prompt), + 'estimated_tokens' => $this->estimateTokens($prompt), + 'has_structured_output' => false, + 'tone_clarity' => 0, + 'specificity_score' => 0, + 'suggestions' => ['Prompt optimization is currently disabled'] + ]; + } + + /** + * Get optimization statistics - RETURNS EMPTY STATS + */ + public function getOptimizationStats(): array + { + return [ + 'total_optimizations' => 0, + 'total_tokens_saved' => 0, + 'average_compression' => 0, + 'most_effective_rules' => [] + ]; + } + + /** + * Get configuration schema for admin interface - RETURNS DISABLED CONFIG + */ + public static function getConfigSchema(): array + { + return [ + 'prompt_optimization_enabled' => [ + 'type' => 'checkbox', + 'label' => 'Enable Prompt Optimization (Currently Disabled)', + 'default' => false, + 'help' => 'Prompt optimization functionality is temporarily disabled', + 'disabled' => true + ], + 'prompt_compression_enabled' => [ + 'type' => 'checkbox', + 'label' => 'Enable Prompt Compression (Currently Disabled)', + 'default' => false, + 'help' => 'Prompt optimization functionality is temporarily disabled', + 'disabled' => true + ], + 'prompt_structured_output' => [ + 'type' => 'checkbox', + 'label' => 'Enforce Structured Output (Currently Disabled)', + 'default' => true, + 'help' => 'Prompt optimization functionality is temporarily disabled', + 'disabled' => true + ] + ]; + } +} diff --git a/app/Support/ResponseCache.php b/app/Support/ResponseCache.php new file mode 100644 index 0000000..2c1be22 --- /dev/null +++ b/app/Support/ResponseCache.php @@ -0,0 +1,139 @@ +db = ModeHelper::isMock() ? new DatabaseMock() : new Database(); + $this->defaultTtl = 3600; // Static default + $this->similarityThreshold = 0.85; // Static default + } + + /** + * Get cached response for similar message - ALWAYS RETURNS NULL (cache miss) + */ + public function get(string $message, string $tone, string $productName): ?array + { + // Response caching is disabled - always return cache miss + return null; + } + + /** + * Store response in cache - NO-OP + */ + public function set(string $message, string $tone, string $productName, array $response): void + { + // Response caching is disabled - do nothing + return; + } + + /** + * Clean expired cache entries - NO-OP + */ + public function cleanExpired(): int + { + // No cache entries to clean + return 0; + } + + /** + * Clear all cache entries - NO-OP + */ + public function clear(): void + { + // Nothing to clear + return; + } + + /** + * Get cache statistics - RETURNS EMPTY STATS + */ + public function getStats(): array + { + return [ + 'total_entries' => 0, + 'active_entries' => 0, + 'total_hits' => 0, + 'tokens_saved' => 0, + 'popular_entries' => [], + 'by_product' => [] + ]; + } + + /** + * Optimize cache - NO-OP RETURNS NOT OPTIMIZED + */ + public function optimize(): array + { + return [ + 'optimized' => false, + 'total_entries' => 0, + 'removed' => 0 + ]; + } + + /** + * Create cache table schema - NO-OP + */ + public static function createTable(Database $db): void + { + // Cache table creation is disabled - table may exist but won't be used + return; + } + + /** + * Get cache settings for admin interface - RETURNS DISABLED CONFIG + */ + public static function getConfigSchema(): array + { + return [ + 'response_cache_enabled' => [ + 'type' => 'checkbox', + 'label' => 'Enable Response Caching (Currently Disabled)', + 'default' => false, + 'help' => 'Response caching functionality is temporarily disabled', + 'disabled' => true + ], + 'cache_ttl' => [ + 'type' => 'number', + 'label' => 'Cache TTL (seconds) - Disabled', + 'min' => 300, + 'max' => 86400, + 'default' => 3600, + 'help' => 'Response caching functionality is temporarily disabled', + 'disabled' => true + ], + 'cache_similarity_threshold' => [ + 'type' => 'range', + 'label' => 'Similarity Threshold - Disabled', + 'min' => 0.5, + 'max' => 1.0, + 'step' => 0.05, + 'default' => 0.85, + 'help' => 'Response caching functionality is temporarily disabled', + 'disabled' => true + ], + 'cache_max_entries' => [ + 'type' => 'number', + 'label' => 'Max Cache Entries - Disabled', + 'min' => 100, + 'max' => 50000, + 'default' => 10000, + 'help' => 'Response caching functionality is temporarily disabled', + 'disabled' => true + ] + ]; + } +} diff --git a/app/Support/Settings.php b/app/Support/Settings.php new file mode 100644 index 0000000..b1c1481 --- /dev/null +++ b/app/Support/Settings.php @@ -0,0 +1,147 @@ + self::toBool(Env::get('PURCHASE_VALIDATION_ENABLED', '0')), + 'purchase_code_enabled' => self::toBool(Env::get('PURCHASE_CODE_ENABLED', '0')), + 'purchase_code_required' => self::toBool(Env::get('PURCHASE_CODE_REQUIRED', '0')), + 'ai_categorization_enabled' => true, + 'ai_categorization_confidence_threshold' => 0.8, + ]; + self::$cache = $seed; + self::save(); + error_log('Settings seeded from .env (purchase flags)'); + } else { + $json = @file_get_contents($p); + $arr = json_decode($json, true); + self::$cache = is_array($arr) ? $arr : []; + } + } + + protected static function ensureSecureLoaded(): void { + if (self::$secureCache !== null) return; + + $p = self::securePath(); + if (!is_file($p)) { + self::$secureCache = []; + self::saveSecure(); + } else { + $json = @file_get_contents($p); + $arr = json_decode($json, true); + self::$secureCache = is_array($arr) ? $arr : []; + } + } + + protected static function save(): void { + $p = self::path(); + $dir = dirname($p); + if (!is_dir($dir)) { @mkdir($dir, 0775, true); } + @file_put_contents($p, json_encode(self::$cache, JSON_PRETTY_PRINT|JSON_UNESCAPED_SLASHES)); + } + + protected static function saveSecure(): void { + $p = self::securePath(); + $dir = dirname($p); + if (!is_dir($dir)) { @mkdir($dir, 0775, true); } + @file_put_contents($p, json_encode(self::$secureCache, JSON_PRETTY_PRINT|JSON_UNESCAPED_SLASHES)); + } + + protected static function toBool($v): bool { + $s = strtolower((string)$v); + return in_array($s, ['1','true','yes','on'], true); + } + + public static function get(string $key, $default = null) { + self::ensureLoaded(); + return array_key_exists($key, self::$cache) ? self::$cache[$key] : $default; + } + + public static function set(string $key, $value): void { + self::ensureLoaded(); + self::$cache[$key] = $value; + self::save(); + } + + /** + * Store sensitive data encrypted + */ + public static function setSecure(string $key, string $value): void { + self::ensureSecureLoaded(); + self::$secureCache[$key] = self::encrypt($value); + self::saveSecure(); + } + + /** + * Retrieve and decrypt sensitive data + */ + public static function getSecure(string $key, string $default = ''): string { + self::ensureSecureLoaded(); + if (!array_key_exists($key, self::$secureCache)) { + return $default; + } + try { + return self::decrypt(self::$secureCache[$key]); + } catch (\Throwable $e) { + error_log('Settings decryption error for key ' . $key . ': ' . $e->getMessage()); + return $default; + } + } + + /** + * Remove sensitive data + */ + public static function removeSecure(string $key): void { + self::ensureSecureLoaded(); + unset(self::$secureCache[$key]); + self::saveSecure(); + } +} diff --git a/bootstrap.php b/bootstrap.php new file mode 100644 index 0000000..7ec4f24 --- /dev/null +++ b/bootstrap.php @@ -0,0 +1,57 @@ +info('request', ['mode' => (ModeHelper::isMock() ? 'mock' : 'prod'), 'installed' => ModeHelper::isInstalled()]); + +// Lazy database factory - only connects when called +$dbFactory = function() { + if (ModeHelper::shouldUseMockDB()) { + return DatabaseMock::create(); + } else { + return Database::createSafe(); + } +}; + +$GLOBALS['container'] = [ + 'logger' => $logger, + 'db_factory' => $dbFactory, +]; diff --git a/commits.txt b/commits.txt new file mode 100644 index 0000000..99a8249 --- /dev/null +++ b/commits.txt @@ -0,0 +1,160 @@ +# Git Commit Messages Index +# Format:| + | + |
|---|
ReplyPilot AI needs to be installed and configured.
'; + echo ''; + echo ''; + exit; +} + +// Get form configuration from settings +$purchaseCodeEnabled = Settings::get('purchase_code_enabled', false); +$purchaseCodeRequired = Settings::get('purchase_code_required', false); + +if ($_SERVER['REQUEST_METHOD'] === 'POST') { + $name = trim(Request::input('name')); + $email = trim(Request::input('email')); + $msg = trim(Request::input('message')); + $tone = trim(Request::input('tone', 'friendly')); + $purchase = trim(Request::input('purchase_code', '')); + + // Validate purchase code if needed + $productName = ''; + $error = ''; + + // Validate email format + if (!filter_var($email, FILTER_VALIDATE_EMAIL)) { + $error = 'Please provide a valid email address'; + } + + // Check if purchase code is required + if (empty($error) && $purchaseCodeRequired && $purchase === '') { + $error = 'Purchase code is required'; + } elseif (empty($error) && $purchase !== '') { + [$valid, $productName, $validationError] = LicenseValidator::validate($purchase); + if (!$valid) { + $error = $validationError ?: 'Invalid purchase code'; + } + } + + if (empty($error)) { + $prompt = OpenAIHandler::buildSmartPrompt($msg, $tone, $productName ?: 'Your Product'); + + // Use unified mode helper for AI service selection + $aiService = ModeHelper::isMock() ? OpenAIHandlerMock::class : OpenAIHandler::class; + $ai = $aiService::query($prompt); + + // Use unified mode helper for repository selection + $repo = ModeHelper::isMock() ? new SubmissionRepositoryMock($db) : new SubmissionRepository($db); + $ref = $repo->save([ + 'name' => $name, + 'email' => $email, + 'message' => $msg, + 'tone' => $tone, + 'purchase_code' => $purchase, + 'product_name' => $productName, + 'category' => $ai['category'], + 'ai_reply' => $ai['reply'] + ]); + + // Allow this session to access the created ticket + TicketHelper::allowAccess($ref); + + // Use unified mode helper for mailer selection + $mailer = ModeHelper::isMock() ? new MailerMock() : new Mailer(); + $mailer->send($email, 'Your Reply from AI', $ai['reply']); + + // Redirect to thank you page with ticket reference + header('Location: thank-you.php?ref=' . urlencode($ref)); + exit; + } +} +?> + + + + + +We typically respond within 1–2 business days.
+ + +Your message has been received. We'll get back to you soon.
+ + +Ticket # has been created.
+ View my Ticket +Submitted:
+ +Backup file: {$backup['backup_file']}";
+ } else {
+ echo "";
+ foreach ($history as $record) {
+ echo "✅ {$record['version']} - {$record['description']} ({$record['executed_at']})\n";
+ }
+ echo "";
+ } else {
+ echo '