From e6672fe38ce5d99f3b3f026154f777aded7361de Mon Sep 17 00:00:00 2001
From: Jake Vanderwerf <get@jakevanderwerf.ca>
Date: Thu, 29 Jan 2026 17:36:53 +0000
Subject: [PATCH] =Starting refactor of Meta and Routes to fluent-style
---
inc/rest/routes/QueueRoutes.php | 55 ++++++++++++++++++++++++++++---------------------------
1 files changed, 28 insertions(+), 27 deletions(-)
diff --git a/inc/rest/routes/QueueRoutes.php b/inc/rest/routes/QueueRoutes.php
index b26bc70..3654ae0 100644
--- a/inc/rest/routes/QueueRoutes.php
+++ b/inc/rest/routes/QueueRoutes.php
@@ -3,7 +3,7 @@
use Exception;
use JVBase\JVB;
-use JVBase\managers\CacheManager;
+use JVBase\managers\Cache;
use JVBase\rest\RestRouteManager;
use WP_REST_Request;
use WP_REST_Response;
@@ -11,26 +11,26 @@
use DateTimeZone;
if (!defined('ABSPATH')) {
- exit; // Exit if accessed directly
+ exit; // Exit if accessed directly
}
class QueueRoutes extends RestRouteManager
{
- public function __construct()
- {
- $this->cache_name = 'queue';
- $this->cache_ttl = 300;
- parent::__construct();
+ public function __construct()
+ {
+ $this->cache_name = 'queue';
+ $this->cache_ttl = 300;
+ parent::__construct();
if (JVB_TESTING) {
- $this->cache->clear();
+ $this->cache->flush();
}
- }
+ }
- /**
- * Registers queue routes
- * @return void
- */
+ /**
+ * Registers queue routes
+ * @return void
+ */
public function registerRoutes():void
{
register_rest_route($this->namespace, '/queue', [
@@ -81,12 +81,12 @@
]);
}
- /**
- * Get queue operations with optional filtering
- *
- * @param WP_REST_Request $request
- * @return WP_REST_Response
- */
+ /**
+ * Get queue operations with optional filtering
+ *
+ * @param WP_REST_Request $request
+ * @return WP_REST_Response
+ */
public function getQueue(WP_REST_Request $request): WP_REST_Response
{
$user_id = $request->get_param('user');
@@ -94,7 +94,8 @@
$ids = $request->get_param('ids');
$limit = intval($request->get_param('limit'));
// Use base class user-specific header checking
- $cache_check = $this->checkUserHeaders($request, $user_id, 'queue');
+ $key = $this->cache->generateKey(['user'=> $user_id, 'status'=> $status, 'ids'=> $ids, 'limit'=> $limit]);
+ $cache_check = $this->checkHeaders($request, $key);
if ($cache_check) {
return $cache_check;
}
@@ -241,12 +242,12 @@
return $base_title;
}
- /**
- * Update operation status (dismiss or retry)
- *
- * @param WP_REST_Request $request
- * @return WP_REST_Response
- */
+ /**
+ * Update operation status (dismiss or retry)
+ *
+ * @param WP_REST_Request $request
+ * @return WP_REST_Response
+ */
public function handleAction(WP_REST_Request $request): WP_REST_Response
{
$data = $request->get_json_params();
@@ -285,7 +286,7 @@
$result = $this->processQueueAction($action, $operations, $user_id);
if ($result['success']) {
- CacheManager::updateTimestamp("user_{$user_id}");
+ Cache::touch($user_id);
}
return new WP_REST_Response($result);
--
Gitblit v1.10.0