mirror of
https://github.com/holo-gfx/mangadex.git
synced 2024-11-25 01:38:21 -05:00
233 lines
9.2 KiB
PHP
233 lines
9.2 KiB
PHP
<?php
|
|
switch ($function) {
|
|
case 'turn_on':
|
|
$turn_on = isset($_POST["turn_on"]) ? 1 : 0;
|
|
|
|
$sql->modify('turn_on', ' UPDATE mangadex_user_options SET md_at_home = ? WHERE user_id = ? ', [$turn_on, $user->user_id]);
|
|
|
|
$memcached->delete("user_$user->user_id");
|
|
|
|
$details = $user->user_id;
|
|
|
|
$result = 1;
|
|
break;
|
|
|
|
case 'request_client':
|
|
$upload = prepare_numeric($_POST['upload']);
|
|
$download = prepare_numeric($_POST['download']);
|
|
$disk = prepare_numeric($_POST['disk']);
|
|
$ip = $_POST['ip'];
|
|
$speedtest = $_POST['speedtest'];
|
|
$read_rules = isset($_POST["read_rules"]) ? 1 : 0;
|
|
|
|
$count_ip = $sql->prep('count_ip', ' SELECT count(*) FROM mangadex_clients WHERE client_ip = ? ', [$ip], 'fetchColumn', '', -1);
|
|
$count_clients = $sql->prep('count_clients', ' SELECT count(*) FROM mangadex_clients WHERE user_id = ? ', [$user->user_id], 'fetchColumn', '', -1);
|
|
|
|
if (!$user->user_id)
|
|
$error .= display_alert('danger', 'Failed', "Your session has timed out. Please log in again.");
|
|
elseif ($upload < 40)
|
|
$error .= display_alert('danger', 'Failed', "Your upload speed must be at least 40 Mbps.");
|
|
elseif ($download < 40)
|
|
$error .= display_alert('danger', 'Failed', "Your download speed must be at least 40 Mbps.");
|
|
elseif ($upload > 65535)
|
|
$error .= display_alert('danger', 'Failed', "Your upload speed is too high.");
|
|
elseif ($download > 65535)
|
|
$error .= display_alert('danger', 'Failed', "Your download speed is too high.");
|
|
elseif ($disk < 40)
|
|
$error .= display_alert('danger', 'Failed', "Your disk cache allocation must be at least 40 GB.");
|
|
elseif ($disk > 65535)
|
|
$error .= display_alert('danger', 'Failed', "Your disk cache allocation is too high.");
|
|
elseif (!preg_match('/^(?:[0-9]{1,3}\.){3}[0-9]{1,3}$/', $ip))
|
|
$error .= display_alert('danger', 'Failed', "That doesn't look like a IPv4 address.");
|
|
elseif ($count_ip)
|
|
$error .= display_alert('danger', 'Failed', "Your IP has already been used.");
|
|
elseif ($count_clients > 5)
|
|
$error .= display_alert('danger', 'Failed', "You have reached the limit of clients you can request. For more clients, please PM ixlone.");
|
|
elseif (!$read_rules)
|
|
$error .= display_alert('danger', 'Failed', "Go and read the rules.");
|
|
elseif (strlen($ip) > 15)
|
|
$error .= display_alert('danger', 'Failed', "IPv4 addresses only.");
|
|
|
|
if (!$error) {
|
|
$sql->modify('request_client', '
|
|
INSERT INTO mangadex_clients (client_id, user_id, upload_speed, download_speed, disk_cache_size, speedtest, client_ip, client_continent, client_country)
|
|
VALUES (NULL, ?, ?, ?, ?, ?, ?, ?, ?)
|
|
', [$user->user_id, $upload, $download, $disk, $speedtest, $ip, get_continent_code($ip), get_country_code($ip)]);
|
|
|
|
$memcached->delete("user_{$user->user_id}_clients");
|
|
|
|
$details = $user->user_id;
|
|
}
|
|
else {
|
|
$details = $error;
|
|
print $error; //returns "" or a message
|
|
}
|
|
|
|
$result = ($details) ? 0 : 1;
|
|
break;
|
|
|
|
case 'client_rotate':
|
|
$client_id = prepare_numeric($_GET['client_id']);
|
|
|
|
if (validate_level($user, 'admin')) {
|
|
$client = $sql->prep('client_user_id', ' SELECT user_id, upload_speed FROM mangadex_clients WHERE client_id = ? ', [$client_id], 'fetch', PDO::FETCH_ASSOC, -1);
|
|
|
|
try {
|
|
$client_secret = $mdAtHomeClient->rotateUser($client_id);
|
|
|
|
$sql->modify('client_rotate', ' UPDATE mangadex_clients SET client_secret = ? WHERE client_id = ? LIMIT 1 ', [$client_secret, $client_id]);
|
|
|
|
$memcached->delete("user_{$user->user_id}_clients");
|
|
|
|
// send the user an automated message
|
|
|
|
$subject = "Your MangaDex@Home client secret has been reset.";
|
|
$message = "Hello,\n\n" .
|
|
"Your MangaDex@Home client secret has been reset to $client_secret";
|
|
|
|
$sender_id = 1; // Default MangaDex user; TODO: remove hardcoded value?
|
|
$recipient_id = $client['user_id'];
|
|
|
|
$thread_id = $sql->modify('msg_send', ' INSERT INTO mangadex_pm_threads (thread_id, thread_subject, sender_id, recipient_id, thread_timestamp, sender_read, recipient_read, sender_deleted, recipient_deleted)
|
|
VALUES (NULL, ?, ?, ?, UNIX_TIMESTAMP(), 1, 0, 0, 0) ', [$subject, $sender_id, $recipient_id]);
|
|
|
|
$sql->modify('msg_send', ' INSERT INTO mangadex_pm_msgs (msg_id, thread_id, user_id, timestamp, text)
|
|
VALUES (NULL, ?, ?, UNIX_TIMESTAMP(), ?) ', [$thread_id, $sender_id, $message]);
|
|
|
|
$memcached->delete("user_{$recipient_id}_unread_msgs");
|
|
|
|
$details = $id;
|
|
|
|
} catch (Throwable $t) {
|
|
// Send to sentry
|
|
trigger_error($t->getMessage(), E_USER_WARNING);
|
|
|
|
$details = $t->getMessage();
|
|
print display_alert('danger', 'Failed', $details); //fail
|
|
}
|
|
|
|
}
|
|
else {
|
|
$details = "Error.";
|
|
print display_alert('danger', 'Failed', $details); //fail
|
|
}
|
|
|
|
$result = (!is_numeric($details)) ? 0 : 1;
|
|
|
|
break;
|
|
|
|
case 'client_approve':
|
|
$client_id = prepare_numeric($_GET['client_id']);
|
|
|
|
if (validate_level($user, 'admin')) {
|
|
$client = $sql->prep('client_user_id', '
|
|
SELECT clients.user_id, clients.upload_speed, users.username, users.email
|
|
FROM mangadex_clients AS clients
|
|
LEFT JOIN mangadex_users AS users
|
|
ON users.user_id = clients.user_id
|
|
WHERE clients.client_id = ?
|
|
LIMIT 1
|
|
', [$client_id], 'fetch', PDO::FETCH_ASSOC, -1);
|
|
|
|
try {
|
|
$bytes = $client['upload_speed'] / 8 * 1000000;
|
|
$client_secret = $mdAtHomeClient->registerUser($client['user_id'], $client_id, $client['username'], $bytes);
|
|
|
|
$sql->modify('client_approve', ' UPDATE mangadex_clients SET approved = 1, timestamp = UNIX_TIMESTAMP(), client_secret = ? WHERE client_id = ? LIMIT 1 ', [$client_secret, $client_id]);
|
|
|
|
$memcached->delete("user_{$user->user_id}_clients");
|
|
|
|
// send the user an automated message
|
|
|
|
$subject = "Your MangaDex@Home client application has been accepted.";
|
|
$message = "Hello,\n\n" .
|
|
"Your MangaDex@Home client application has been accepted. Thank you for hosting a client! Please check the [url=https://mangadex.org/md_at_home/clients]My clients[/url] page for instructions on setting up the client.";
|
|
|
|
$sender_id = 1; // Default MangaDex user; TODO: remove hardcoded value?
|
|
$recipient_id = $client['user_id'];
|
|
|
|
$thread_id = $sql->modify('msg_send', ' INSERT INTO mangadex_pm_threads (thread_id, thread_subject, sender_id, recipient_id, thread_timestamp, sender_read, recipient_read, sender_deleted, recipient_deleted)
|
|
VALUES (NULL, ?, ?, ?, UNIX_TIMESTAMP(), 1, 0, 0, 0) ', [$subject, $sender_id, $recipient_id]);
|
|
|
|
$sql->modify('msg_send', ' INSERT INTO mangadex_pm_msgs (msg_id, thread_id, user_id, timestamp, text)
|
|
VALUES (NULL, ?, ?, UNIX_TIMESTAMP(), ?) ', [$thread_id, $sender_id, $message]);
|
|
|
|
//email them
|
|
$to = $client['email'];
|
|
$subject = "Your MangaDex@Home client application has been accepted - {$client['username']}";
|
|
$body = "Hello,\n\n" .
|
|
"Your MangaDex@Home client application has been accepted. Thank you for hosting a client! Please check https://mangadex.org/md_at_home/clients for instructions on setting up the client.
|
|
|
|
Please connect your client as soon as possible. Clients that do not connect within 3 days of being approved will have re-apply for a new secret.";
|
|
|
|
send_email($to, $subject, $body);
|
|
|
|
$memcached->delete("user_{$recipient_id}_unread_msgs");
|
|
|
|
$details = $id;
|
|
|
|
} catch (Throwable $t) {
|
|
// Send to sentry
|
|
trigger_error($t->getMessage(), E_USER_WARNING);
|
|
|
|
$details = "MangaDex@Home error.";
|
|
print display_alert('danger', 'Failed', $details); //fail
|
|
}
|
|
|
|
}
|
|
else {
|
|
$details = "Error.";
|
|
print display_alert('danger', 'Failed', $details); //fail
|
|
}
|
|
|
|
$result = (!is_numeric($details)) ? 0 : 1;
|
|
|
|
break;
|
|
|
|
case 'client_reject':
|
|
$client_id = prepare_numeric($_GET['client_id']);
|
|
|
|
if (validate_level($user, 'admin')) {
|
|
$sql->modify('client_reject', ' UPDATE mangadex_clients SET approved = 0 WHERE client_id = ? LIMIT 1 ', [$client_id]);
|
|
|
|
$client_user_id = $sql->prep('client_user_id', ' SELECT user_id FROM mangadex_clients WHERE client_id = ? ', [$client_id], 'fetchColumn', '', -1);
|
|
|
|
// send the user an automated message
|
|
|
|
$subject = "Your MangaDex@Home client application has been rejected.";
|
|
$message = "Hello,\n\n" .
|
|
"Your MangaDex@Home client application has been rejected. Please PM ixlone to discuss your application.";
|
|
|
|
$sender_id = 1; // Default MangaDex user; TODO: remove hardcoded value?
|
|
$recipient_id = $client_user_id;
|
|
|
|
$thread_id = $sql->modify('msg_send', ' INSERT INTO mangadex_pm_threads (thread_id, thread_subject, sender_id, recipient_id, thread_timestamp, sender_read, recipient_read, sender_deleted, recipient_deleted)
|
|
VALUES (NULL, ?, ?, ?, UNIX_TIMESTAMP(), 1, 0, 0, 0) ', [$subject, $sender_id, $recipient_id]);
|
|
|
|
$sql->modify('msg_send', ' INSERT INTO mangadex_pm_msgs (msg_id, thread_id, user_id, timestamp, text)
|
|
VALUES (NULL, ?, ?, UNIX_TIMESTAMP(), ?) ', [$thread_id, $sender_id, $message]);
|
|
|
|
$memcached->delete("user_{$recipient_id}_unread_msgs");
|
|
|
|
$memcached->delete("user_{$user->user_id}_clients");
|
|
|
|
$details = $id;
|
|
}
|
|
else {
|
|
$details = "Error.";
|
|
print display_alert('danger', 'Failed', $details); //fail
|
|
}
|
|
|
|
$result = (!is_numeric($details)) ? 0 : 1;
|
|
|
|
break;
|
|
|
|
case 'edit_client':
|
|
die();
|
|
break;
|
|
|
|
case 'delete_client':
|
|
die();
|
|
break;
|
|
}
|