Fixed issue in DAS too

This commit is contained in:
Pinga 2023-11-02 12:48:39 +02:00
parent 76ec107f71
commit b906febeeb

View file

@ -25,22 +25,23 @@ $server->set([
'package_eof' => "\r\n" 'package_eof' => "\r\n"
]); ]);
// Connect to the database
try {
$c = require_once 'config.php';
$pdo = new PDO("{$c['db_type']}:host={$c['db_host']};dbname={$c['db_database']}", $c['db_username'], $c['db_password']);
$pdo->setAttribute(PDO::ATTR_ERRMODE, PDO::ERRMODE_EXCEPTION);
} catch (PDOException $e) {
$server->send($fd, "Error connecting to database");
$server->close($fd);
}
// Register a callback to handle incoming connections // Register a callback to handle incoming connections
$server->on('connect', function ($server, $fd) { $server->on('connect', function ($server, $fd) {
echo "Client connected: {$fd}\r\n"; echo "Client connected: {$fd}\r\n";
}); });
// Register a callback to handle incoming requests // Register a callback to handle incoming requests
$server->on('receive', function ($server, $fd, $reactorId, $data) { $server->on('receive', function ($server, $fd, $reactorId, $data) use ($c, $pdo) {
// Connect to the database
try {
$c = require_once 'config.php';
$pdo = new PDO("{$c['db_type']}:host={$c['db_host']};dbname={$c['db_database']}", $c['db_username'], $c['db_password']);
$pdo->setAttribute(PDO::ATTR_ERRMODE, PDO::ERRMODE_EXCEPTION);
} catch (PDOException $e) {
$server->send($fd, "Error connecting to database");
$server->close($fd);
}
// Validate and sanitize the domain name // Validate and sanitize the domain name
$domain = trim($data); $domain = trim($data);