<?php
|
namespace JVBase\rest\routes;
|
|
use JVBase\JVB;
|
use JVBase\rest\PermissionHandler;
|
use JVBase\rest\Rest;
|
use JVBase\managers\Cache;
|
use JVBase\meta\Meta;
|
use JVBase\meta\Sanitizer;
|
use JVBase\rest\Route;
|
use WP_REST_Request;
|
use WP_REST_Response;
|
use WP_Error;
|
use Exception;
|
|
if (!defined('ABSPATH')) {
|
exit; // Exit if accessed directly
|
}
|
class SettingsRoutes extends Rest
|
{
|
protected int $count;
|
public function __construct()
|
{
|
$this->cacheName = 'user_settings';
|
parent::__construct();
|
// $this->action = 'dash-';
|
// $this->operation_type = 'user_settings';
|
$this->count = 1;
|
add_filter(BASE.'handle_bulk_operation', [$this, 'processOperation'], 10, 3);
|
}
|
|
/**
|
* Registers Settings Routes
|
* @return void
|
*/
|
public function registerRoutes():void
|
{
|
Route::for('settings')
|
->post([$this, 'saveSettings'])
|
->auth(PermissionHandler::combine(['admin', ['actionNonce' => 'dash-']]))
|
->rateLimit(20)
|
->register();
|
}
|
|
/**
|
* @param WP_REST_Request $request
|
*
|
* @return WP_REST_Response
|
*/
|
public function saveSettings(WP_REST_Request $request):WP_REST_Response
|
{
|
|
$data = $request->get_params();
|
error_log('User: '.print_r($data['user'], true));
|
error_log('Settings routes data: '.print_r($data, true));
|
$user_id = absint($data['user']??0);
|
if ($user_id === 0) {
|
return $this->unauthorized();
|
}
|
|
|
$fields = JVB()->getFields('user');
|
$meta = new Sanitizer();
|
$add = [];
|
global $types;
|
foreach ($data as $name => $value) {
|
if (!array_key_exists($name, $fields)) {
|
if ($name === 'notification_preferences') {
|
foreach ($value as $type => $options) {
|
if (array_key_exists(BASE.$type, $types)) {
|
$add[$type] = $options;
|
}
|
}
|
}
|
unset($data[$name]);
|
} else {
|
//Sanitize values
|
$data[$name] = $meta->sanitize($value, $fields[$name]);
|
if ($name === 'notify') {
|
Cache::for('usernames')->forget($user_id);
|
}
|
}
|
}
|
if (!empty($add)) {
|
$data['notification_preferences'] = $add;
|
}
|
|
JVB()->queue()->queueOperation(
|
'user_settings',
|
$user_id,
|
$data,
|
[
|
'count' => 1,
|
]
|
);
|
|
return $this->success([
|
'message' => 'Request received and queued',
|
'status' => 'queued'
|
]);
|
}
|
|
/**
|
* @param WP_Error|array $result
|
* @param object $operation
|
* @param array $data
|
*
|
* @return WP_Error|array
|
*/
|
public function processOperation(WP_Error|array $result, object $operation, array $data):array|WP_Error
|
{
|
if ($operation->type !== 'user_settings') {
|
return $result;
|
}
|
|
|
$user_id = $operation->user_id;
|
$meta = Meta::forUser($user_id);
|
$results = [];
|
$tempMeta = Meta::forOptions('options');
|
foreach ($data as $name => $value) {
|
if ($name == 'notification_preferences') {
|
return $this->saveNotificationPreferences($user_id, $value);
|
}
|
|
$temp = (is_array($value)) ? $value : json_decode($value);
|
|
if (is_array($temp)) {
|
$value = [];
|
foreach ($temp as $t) {
|
if (is_object($t)) {
|
$t = (array)$t;
|
}
|
$value[] = $t;
|
}
|
}
|
|
if ($name !== 'digest_override') { // digest_override should always reset to 'off'
|
if(array_key_exists($name, JVB_OPTIONS)) {
|
$results[] = $tempMeta->set($name, $value);
|
} else {
|
$results[] = $meta->set($name, $value);
|
}
|
|
}
|
$this->cache->flush();
|
}
|
|
return [
|
'success' => true,
|
'result' => $results,
|
];
|
}
|
|
/**
|
* @param int $user_id
|
* @param array $data
|
*
|
* @return WP_Error|array
|
*/
|
protected function saveNotificationPreferences(int $user_id, array $data):array|WP_Error
|
{
|
//TODO: This should be in with Notifications.php manager
|
//TODO: Check what cache we are using to store user's preferences for the daily/weekly/monthly sendouts
|
global $wpdb;
|
$table = $wpdb->prefix . BASE . 'notification_preferences';
|
|
if (!$this->checkUser($user_id)) {
|
return [
|
'success' => false,
|
'result' => 'User must be logged in to save preferences',
|
];
|
}
|
error_log('User Preferences: '.print_r($data, true));
|
$wpdb->query('START TRANSACTION');
|
|
try {
|
// Get global email digest setting (if provided)
|
$email_digest = get_user_meta($user_id, BASE . 'email_digest', true) ?: 'never';
|
|
// Process notification preferences by type
|
foreach ($data as $type => $items) {
|
if (!is_array($items)) {
|
continue;
|
}
|
|
foreach ($items as $item_id => $frequency) {
|
// Validate frequency
|
$valid_frequencies = ['never', 'daily', 'weekly', 'monthly'];
|
if (!in_array($frequency, $valid_frequencies)) {
|
continue;
|
}
|
|
// Replace or insert preference
|
$result = $wpdb->replace(
|
$table,
|
[
|
'user_id' => $user_id,
|
'notification_type' => $type,
|
'item_id' => $item_id,
|
'frequency' => $frequency,
|
'created_at' => current_time('mysql'),
|
'updated_at' => current_time('mysql')
|
],
|
['%d', '%s', '%d', '%s', '%s', '%s']
|
);
|
|
if ($wpdb->last_error) {
|
throw new Exception($wpdb->last_error);
|
}
|
}
|
}
|
|
// Success - commit transaction
|
$wpdb->query('COMMIT');
|
|
$this->cache->flush();
|
return [
|
'success' => true,
|
'result' => 'Notification preferences updated successfully'
|
];
|
|
} catch (Exception $e) {
|
// Failure - rollback transaction
|
$wpdb->query('ROLLBACK');
|
error_log('Error saving notification preferences: ' . $e->getMessage());
|
|
return [
|
'success' => false,
|
'message' => $e->getMessage()
|
];
|
}
|
}
|
}
|
