joshuacoles/wallos
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

V1.0 add email notifications

Browse Source
This commit is contained in:
ellite
2023-11-10 11:45:01 +01:00
parent 65786aa191
commit 7c2e7f00b9
22 changed files with 7161 additions and 23 deletions
Download Patch File Download Diff File Expand all files Collapse all files
endpoints/cronjobs/conf.php
+6
View File
@@ -0,0 +1,6 @@
<?php
#Webroot path
$webPath = "/var/www/html/";
?>
endpoints/cronjobs/createdatabase.php
+61 -3
View File
@@ -1,9 +1,11 @@
<?php
$databaseFile = '/var/www/html/db/wallos.db';
require_once 'conf.php';
$databaseFile = $webPath . 'db/wallos.db';
if (!file_exists($databaseFile)) {
echo "Database does not exist. Creating it...";
echo "Database does not exist. Creating it...\n";
$db = new SQLite3($databaseFile, SQLITE3_OPEN_CREATE | SQLITE3_OPEN_READWRITE);
$db->busyTimeout(5000);
@@ -36,6 +38,7 @@ if (!file_exists($databaseFile)) {
payment_method_id INTEGER,
payer_user_id INTEGER,
category_id INTEGER,
notify BOOLEAN DEFAULT false,
FOREIGN KEY(currency_id) REFERENCES currencies(id),
FOREIGN KEY(cycle) REFERENCES cycles(id),
FOREIGN KEY(frequency) REFERENCES frequencies(id),
@@ -92,6 +95,16 @@ if (!file_exists($databaseFile)) {
date DATE NOT NULL
)');
$db-exec('CREATE TABLE notifications (
id INTEGER PRIMARY KEY,
enabled BOOLEAN DEFAULT false,
days INTEGER,
smtp_address VARCHAR(255),
smtp_port INTEGER,
smtp_username VARCHAR(255),
smtp_password VARCHAR(255)
)');
$db->exec("INSERT INTO categories (id, name) VALUES
(1, 'No category'),
(2, 'Entertainment'),
@@ -218,8 +231,53 @@ if (!file_exists($databaseFile)) {
(30, 'VeriFone', 'verifone.png'),
(31, 'WebMoney', 'webmoney.png')");
echo "Database created.\n";
} else {
echo "Database already exist. Skipping...";
echo "Database already exist. Checking for upgrades...\n";
$databaseFile = $webPath . 'db/wallos.db';
$db = new SQLite3($databaseFile);
$db->busyTimeout(5000);
if (!$db) {
die('Connection to the database failed.');
}
# v0.9 to v1.0
# Added new notifications table
# Added notify column to subscriptions table
$result = $db->query("SELECT name FROM sqlite_master WHERE type='table' AND name='notifications'");
if (!$result->fetchArray(SQLITE3_ASSOC)) {
$db->exec('CREATE TABLE notifications (
id INTEGER PRIMARY KEY,
enabled BOOLEAN DEFAULT false,
days INTEGER,
smtp_address VARCHAR(255),
smtp_port INTEGER,
smtp_username VARCHAR(255),
smtp_password VARCHAR(255)
)');
echo "Table 'notifications' created.\n";
} else {
echo "Table 'notifications' already exists.\n";
}
$result = $db->query("PRAGMA table_info(subscriptions)");
$notifyColumnExists = false;
while ($row = $result->fetchArray(SQLITE3_ASSOC)) {
if ($row['name'] === 'notify') {
$notifyColumnExists = true;
break;
}
}
if (!$notifyColumnExists) {
$db->exec('ALTER TABLE subscriptions ADD COLUMN notify BOOLEAN DEFAULT false');
echo "Column 'notify' added to table 'subscriptions'.\n";
} else {
echo "Column 'notify' already exists in table 'subscriptions'.\n";
}
}
?>
endpoints/cronjobs/sendnotifications.php
+89
View File
@@ -0,0 +1,89 @@
<?php
use PHPMailer\PHPMailer\PHPMailer;
use PHPMailer\PHPMailer\SMTP;
use PHPMailer\PHPMailer\Exception;
require_once 'conf.php';
require_once $webPath . 'includes/connect_endpoint_crontabs.php';
$query = "SELECT * FROM notifications WHERE id = 1";
$result = $db->query($query);
if ($row = $result->fetchArray(SQLITE3_ASSOC)) {
$notificationsEnabled = $row['enabled'];
$days = $row['days'];
$smtpAddress = $row["smtp_address"];
$smtpPort = $row["smtp_port"];
$smtpUsername = $row["smtp_username"];
$smtpPassword = $row["smtp_password"];
} else {
echo "Notifications are disabled. No need to run.";
}
if ($notificationsEnabled) {
$currencies = array();
$query = "SELECT * FROM currencies";
$result = $db->query($query);
while ($row = $result->fetchArray(SQLITE3_ASSOC)) {
$currencyId = $row['id'];
$currencies[$currencyId] = $row;
}
$querySubscriptions = "SELECT * FROM subscriptions WHERE notify = 1";
$resultSubscriptions = $db->query($querySubscriptions);
$notify = []; $i = 0;
$currentDate = new DateTime('now');
while ($rowSubscription = $resultSubscriptions->fetchArray(SQLITE3_ASSOC)) {
$nextPaymentDate = new DateTime($rowSubscription['next_payment']);
$difference = $currentDate->diff($nextPaymentDate)->days + 1;
if ($difference === $days) {
$notify[$i]['name'] = $rowSubscription['name'];
$notify[$i]['price'] = $rowSubscription['price'] . $currencies[$rowSubscription['currency_id']]['symbol'];
$i++;
}
}
if (!empty($notify)) {
require $webPath . 'libs/PHPMailer/PHPMailer.php';
require $webPath . 'libs/PHPMailer/SMTP.php';
require $webPath . 'libs/PHPMailer/Exception.php';
$dayText = $days == 1 ? "tomorrow" : "in " . $days . " days"
$message = "The following subscriptions are up for renewal " . $dayText . ":\n";
foreach ($notify as $subscription) {
$message .= $subscription['name'] . " for " . $subscription['price'] . "\n";
}
$mail = new PHPMailer(true);
$mail->isSMTP();
$mail->Host = $smtpAddress;
$mail->SMTPAuth = true;
$mail->Username = $smtpUsername;
$mail->Password = $smtpPassword;
$mail->SMTPSecure = 'tls';
$mail->Port = $smtpPort;
$getUser = "SELECT * FROM user WHERE id = 1";
$user = $db->querySingle($getUser, true);
$email = $user['email'];
$name = $user['username'];
$mail->setFrom('wallos@wallosapp.com', 'Wallos App');
$mail->addAddress($email, $name);
$mail->Subject = 'Wallos Notification';
$mail->Body = $message;
if ($mail->send()) {
echo "Notifications sent";
} else {
echo "Error sending notifications: " . $mail->ErrorInfo;
}
} else {
echo "Nothing to notify.";
}
}
?>
endpoints/cronjobs/updateexchange.php
+2 -1
View File
@@ -1,5 +1,6 @@
<?php
require_once '/var/www/html/includes/connect_endpoint_crontabs.php';
require_once 'conf.php';
require_once $webPath . 'includes/connect_endpoint_crontabs.php';
$query = "SELECT api_key FROM fixer";
$result = $db->query($query);
endpoints/cronjobs/updatenextpayment.php
+2 -1
View File
@@ -1,5 +1,6 @@
<?php
require_once '/var/www/html/includes/connect_endpoint_crontabs.php';
require_once 'conf.php';
require_once $webPath . 'includes/connect_endpoint_crontabs.php';
$currentDate = new DateTime();
$currentDateString = $currentDate->format('Y-m-d');
endpoints/notifications/save.php
+71
View File
@@ -0,0 +1,71 @@
<?php
require_once '../../includes/connect_endpoint.php';
session_start();
if ($_SERVER["REQUEST_METHOD"] === "POST") {
$postData = file_get_contents("php://input");
$data = json_decode($postData, true);
if (
!isset($data["days"]) || $data['days'] == "" ||
!isset($data["smtpaddress"]) || $data["smtpaddress"] == "" ||
!isset($data["smtpport"]) || $data["smtpport"] == "" ||
!isset($data["smtpusername"]) || $data["smtpusername"] == "" ||
!isset($data["smtppassword"]) || $data["smtppassword"] == ""
) {
$response = [
"success" => false,
"errorMessage" => "Please fill all fields"
];
echo json_encode($response);
} else {
$enabled = $data["enabled"];
$days = $data["days"];
$smtpAddress = $data["smtpaddress"];
$smtpPort = $data["smtpport"];
$smtpUsername = $data["smtpusername"];
$smtpPassword = $data["smtppassword"];
$query = "SELECT COUNT(*) FROM notifications";
$result = $db->querySingle($query);
if ($result === false) {
$response = [
"success" => false,
"errorMessage" => "Error saving notifications data"
];
echo json_encode($response);
} else {
if ($result == 0) {
$query = "INSERT INTO notifications (enabled, days, smtp_address, smtp_port, smtp_username, smtp_password)
VALUES (:enabled, :days, :smtpAddress, :smtpPort, :smtpUsername, :smtpPassword)";
} else {
$query = "UPDATE notifications
SET enabled = :enabled, days = :days, smtp_address = :smtpAddress, smtp_port = :smtpPort,
smtp_username = :smtpUsername, smtp_password = :smtpPassword";
}
$stmt = $db->prepare($query);
$stmt->bindValue(':enabled', $enabled, SQLITE3_INTEGER);
$stmt->bindValue(':days', $days, SQLITE3_INTEGER);
$stmt->bindValue(':smtpAddress', $smtpAddress, SQLITE3_TEXT);
$stmt->bindValue(':smtpPort', $smtpPort, SQLITE3_INTEGER);
$stmt->bindValue(':smtpUsername', $smtpUsername, SQLITE3_TEXT);
$stmt->bindValue(':smtpPassword', $smtpPassword, SQLITE3_TEXT);
if ($stmt->execute()) {
$response = [
"success" => true
];
echo json_encode($response);
} else {
$response = [
"success" => false,
"errorMessage" => "Error saving notification data"
];
echo json_encode($response);
}
}
}
}
?>
endpoints/notifications/sendtestmail.php
+72
View File
@@ -0,0 +1,72 @@
<?php
use PHPMailer\PHPMailer\PHPMailer;
use PHPMailer\PHPMailer\SMTP;
use PHPMailer\PHPMailer\Exception;
require_once '../../includes/connect_endpoint.php';
session_start();
if ($_SERVER["REQUEST_METHOD"] === "POST") {
$postData = file_get_contents("php://input");
$data = json_decode($postData, true);
if (
!isset($data["smtpaddress"]) || $data["smtpaddress"] == "" ||
!isset($data["smtpport"]) || $data["smtpport"] == "" ||
!isset($data["smtpusername"]) || $data["smtpusername"] == "" ||
!isset($data["smtppassword"]) || $data["smtppassword"] == ""
) {
$response = [
"success" => false,
"errorMessage" => "Please fill all fields"
];
echo json_encode($response);
} else {
require '../../libs/PHPMailer/PHPMailer.php';
require '../../libs/PHPMailer/SMTP.php';
require '../../libs/PHPMailer/Exception.php';
$smtpAddress = $data["smtpaddress"];
$smtpPort = $data["smtpport"];
$smtpUsername = $data["smtpusername"];
$smtpPassword = $data["smtppassword"];
$mail = new PHPMailer(true);
$mail->isSMTP();
$mail->Host = $smtpAddress;
$mail->SMTPAuth = true;
$mail->Username = $smtpUsername;
$mail->Password = $smtpPassword;
$mail->SMTPSecure = 'tls';
$mail->Port = $smtpPort;
$getUser = "SELECT * FROM user WHERE id = 1";
$user = $db->querySingle($getUser, true);
$email = $user['email'];
$name = $user['username'];
$mail->setFrom('wallos@wallosapp.com', 'Wallos App');
$mail->addAddress($email, $name);
$mail->Subject = 'Wallos Notification';
$mail->Body = 'This is a test notification. If you\'re seeing this, the configuration is correct.';
if ($mail->send()) {
$response = [
"success" => true,
];
echo json_encode($response);
} else {
$response = [
"success" => false,
"errorMessage" => "Error sending email." . $mail->ErrorInfo
];
echo json_encode($response);
}
}
}
?>
endpoints/subscription/add.php
+6 -4
View File
@@ -144,6 +144,7 @@
$notes = $_POST["notes"];
$logoUrl = $_POST['logo-url'];
$logo = "";
$notify = isset($_POST['notifications']) ? true : false;
if($logoUrl !== "") {
$logo = getLogoFromUrl($logoUrl, '../../images/uploads/logos/', $name);
@@ -155,15 +156,15 @@
if (!$isEdit) {
$sql = "INSERT INTO subscriptions (name, logo, price, currency_id, next_payment, cycle, frequency, notes,
payment_method_id, payer_user_id, category_id)
payment_method_id, payer_user_id, category_id, notify)
VALUES (:name, :logo, :price, :currencyId, :nextPayment, :cycle, :frequency, :notes,
:paymentMethodId, :payerUserId, :categoryId)";
:paymentMethodId, :payerUserId, :categoryId, :notify)";
} else {
$id = $_POST['id'];
if ($logo != "") {
$sql = "UPDATE subscriptions SET name = :name, logo = :logo, price = :price, currency_id = :currencyId, next_payment = :nextPayment, cycle = :cycle, frequency = :frequency, notes = :notes, payment_method_id = :paymentMethodId, payer_user_id = :payerUserId, category_id = :categoryId WHERE id = :id";
$sql = "UPDATE subscriptions SET name = :name, logo = :logo, price = :price, currency_id = :currencyId, next_payment = :nextPayment, cycle = :cycle, frequency = :frequency, notes = :notes, payment_method_id = :paymentMethodId, payer_user_id = :payerUserId, category_id = :categoryId, notify = :notify WHERE id = :id";
} else {
$sql = "UPDATE subscriptions SET name = :name, price = :price, currency_id = :currencyId, next_payment = :nextPayment, cycle = :cycle, frequency = :frequency, notes = :notes, payment_method_id = :paymentMethodId, payer_user_id = :payerUserId, category_id = :categoryId WHERE id = :id";
$sql = "UPDATE subscriptions SET name = :name, price = :price, currency_id = :currencyId, next_payment = :nextPayment, cycle = :cycle, frequency = :frequency, notes = :notes, payment_method_id = :paymentMethodId, payer_user_id = :payerUserId, category_id = :categoryId, notify = :notify WHERE id = :id";
}
}
@@ -184,6 +185,7 @@
$stmt->bindParam(':paymentMethodId', $paymentMethodId, SQLITE3_INTEGER);
$stmt->bindParam(':payerUserId', $payerUserId, SQLITE3_INTEGER);
$stmt->bindParam(':categoryId', $categoryId, SQLITE3_INTEGER);
$stmt->bindParam(':notify', $notify, SQLITE3_INTEGER);
if ($stmt->execute()) {
$success['status'] = "Success";
endpoints/subscription/get.php
+1
View File
@@ -24,6 +24,7 @@
$subscriptionData['payment_method_id'] = $row['payment_method_id'];
$subscriptionData['payer_user_id'] = $row['payer_user_id'];
$subscriptionData['category_id'] = $row['category_id'];
$subscriptionData['notify'] = $row['notify'];
$subscriptionJson = json_encode($subscriptionData);
header('Content-Type: application/json');