Skip to content

Commit

Permalink
V1.0 add email notifications
Browse files Browse the repository at this point in the history
  • Loading branch information
ellite committed Nov 10, 2023
1 parent 65786aa commit 7c2e7f0
Show file tree
Hide file tree
Showing 22 changed files with 7,161 additions and 23 deletions.
2 changes: 1 addition & 1 deletion Dockerfile
Original file line number Diff line number Diff line change
Expand Up @@ -55,7 +55,7 @@ RUN chmod +x /var/www/html/startup.sh
# Expose port 80 for Nginx
EXPOSE 80

ARG SOFTWARE_VERSION=0.9.0
ARG SOFTWARE_VERSION=1.0.0

# Start both PHP-FPM, Nginx
CMD ["sh", "-c", "/var/www/html/startup.sh"]
8 changes: 6 additions & 2 deletions README.md
Original file line number Diff line number Diff line change
Expand Up @@ -48,6 +48,7 @@ See instructions to run Wallos below.
- curl
- gd
- imagick
- openssl
- sqlite3

#### Docker
Expand All @@ -63,10 +64,13 @@ Download or clone this repo and move the files into your web root - usually `/va
Add the following scripts to your cronjobs with `crontab -e`

```bash
0 0 * * * php /var/www/html/endpoints/cronjobs/updatenextpayment.php >> /var/log/cron/updatenextpayment.log 2>&1
0 1 * * * php /var/www/html/endpoints/cronjobs/updateexchange.php >> /var/log/cron/updateexchange.log 2>&1
0 1 * * * php /var/www/html/endpoints/cronjobs/updatenextpayment.php >> /var/log/cron/updatenextpayment.log 2>&1
0 2 * * * php /var/www/html/endpoints/cronjobs/updateexchange.php >> /var/log/cron/updateexchange.log 2>&1
0 9 * * * php /var/www/html/endpoints/cronjobs/sendnotifications.php >> /var/log/cron/sendnotifications.log 2>&1
```

If your web root is not `/var/www/html/` adjust both the cronjobs above and `/endpoints/cronjobs/conf.php` accordingly.

#### Docker

```bash
Expand Down
7 changes: 4 additions & 3 deletions cronjobs
Original file line number Diff line number Diff line change
@@ -1,3 +1,4 @@
# Run the script every day
0 0 * * * /usr/local/bin/php /var/www/html/endpoints/cronjobs/updatenextpayment.php >> /var/log/cron/updatenextpayment.log 2>&1
0 1 * * * /usr/local/bin/php /var/www/html/endpoints/cronjobs/updateexchange.php >> /var/log/cron/updateexchange.log 2>&1
# Run the scripts every day
0 1 * * * /usr/local/bin/php /var/www/html/endpoints/cronjobs/updatenextpayment.php >> /var/log/cron/updatenextpayment.log 2>&1
0 2 * * * /usr/local/bin/php /var/www/html/endpoints/cronjobs/updateexchange.php >> /var/log/cron/updateexchange.log 2>&1
0 9 * * * /usr/local/bin/php /var/www/html/endpoints/cronjobs/sendnotifications.php >> /var/log/cron/sendnotifications.log 2>&1
13 changes: 12 additions & 1 deletion db/commands.sql
Original file line number Diff line number Diff line change
Expand Up @@ -27,6 +27,7 @@ CREATE TABLE subscriptions (
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),
Expand Down Expand Up @@ -81,7 +82,17 @@ CREATE TABLE last_exchange_update (

CREATE TABLE last_update_next_payment_date (
date DATE NOT NULL
)
);

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)
);

INSERT INTO categories (id, name) VALUES
(1, 'No category'),
Expand Down
Binary file modified db/wallos.db
Binary file not shown.
6 changes: 6 additions & 0 deletions endpoints/cronjobs/conf.php
Original file line number Diff line number Diff line change
@@ -0,0 +1,6 @@
<?php

#Webroot path
$webPath = "/var/www/html/";

?>
64 changes: 61 additions & 3 deletions endpoints/cronjobs/createdatabase.php
Original file line number Diff line number Diff line change
@@ -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);

Expand Down Expand Up @@ -36,6 +38,7 @@
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),
Expand Down Expand Up @@ -92,6 +95,16 @@
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'),
Expand Down Expand Up @@ -218,8 +231,53 @@
(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";
}

}

?>
89 changes: 89 additions & 0 deletions endpoints/cronjobs/sendnotifications.php
Original file line number Diff line number Diff line change
@@ -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('[email protected]', '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.";
}

}
?>
3 changes: 2 additions & 1 deletion endpoints/cronjobs/updateexchange.php
Original file line number Diff line number Diff line change
@@ -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);
Expand Down
3 changes: 2 additions & 1 deletion endpoints/cronjobs/updatenextpayment.php
Original file line number Diff line number Diff line change
@@ -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');
Expand Down
71 changes: 71 additions & 0 deletions endpoints/notifications/save.php
Original file line number Diff line number Diff line change
@@ -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);
}
}
}
}
?>
Loading

0 comments on commit 7c2e7f0

Please sign in to comment.