| | |
| | | |
| | | use DateTime; |
| | | use DateTimeZone; |
| | | use JVBase\integrations\services\Cloudflare; |
| | | use JVBase\managers\Errors; |
| | | use JVBase\registrar\Registrar; |
| | | use JVBase\managers\OperationQueue; |
| | | use JVBase\managers\Cache; |
| | |
| | | * @param string $nonceName nonce name to check |
| | | * @param string|null $nonce optional additional nonce to check |
| | | * |
| | | * @return void|WP_Error |
| | | */ |
| | | public function verifyNonce(WP_REST_Request $request, string $nonceName = 'wp_rest', string|null $nonce = null):mixed |
| | | { |
| | | * @return bool|WP_Error |
| | | */ |
| | | public function verifyNonce(WP_REST_Request $request, string $nonceName = 'wp_rest', string|null $nonce = null): bool|WP_Error |
| | | { |
| | | $nonce = (!is_null($nonce)) ? $nonce : $request->get_header('X-WP-Nonce'); |
| | | |
| | | if (!wp_verify_nonce($nonce, $nonceName)) { |
| | |
| | | * |
| | | * @return bool|WP_Error Whether or not we can proceed |
| | | */ |
| | | public function checkPermission(WP_REST_Request $request):bool |
| | | public function checkPermission(WP_REST_Request $request):bool|WP_Error |
| | | { |
| | | // Check rate limits first |
| | | if (!$this->rate_limiter->checkLimit($request)) { |
| | |
| | | return false; |
| | | } |
| | | // Verify nonces |
| | | $this->verifyNonce($request, 'wp_rest'); |
| | | $this->verifyNonce($request); |
| | | if ($this->action!=='') { |
| | | $this->verifyNonce($request, $this->action . $user_id, $request->get_header('action_nonce')); |
| | | } |
| | |
| | | |
| | | protected function checkContent(string $content, bool $bool = false):string|bool |
| | | { |
| | | $result = JVB_CONTENT[$content]??JVB_TAXONOMY[$content]??JVB_USER[$content]??''; |
| | | if ($bool) { |
| | | return $result !== ''; |
| | | } |
| | | return $result; |
| | | return (bool)Registrar::getInstance($content); |
| | | } |
| | | |
| | | |
| | |
| | | protected function logError(string $message, array $context = [], string $severity = 'error') |
| | | { |
| | | try { |
| | | JVB()->error()->log( |
| | | Errors::getInstance()->log( |
| | | 'artist_invitations', // component |
| | | $message, |
| | | $context, |
| | |
| | | */ |
| | | protected function checkUser(int $userID): bool |
| | | { |
| | | $cache = Cache::for('checkUser', DAY_IN_SECONDS)->connect('user'); |
| | | $cache = Cache::for('checkUser', 'user',DAY_IN_SECONDS); |
| | | |
| | | return $cache->remember($userID, function() use ($userID) { |
| | | return (bool)get_userdata($userID); |
| | |
| | | */ |
| | | protected function checkShop(int $shopID): bool |
| | | { |
| | | $cache = Cache::for('checkShop',DAY_IN_SECONDS)->connect('taxonomy'); |
| | | $cache = Cache::for('checkShop', 'term',DAY_IN_SECONDS); |
| | | |
| | | return $cache->remember($shopID, function() use ($shopID) { |
| | | return (bool)term_exists($shopID, BASE . 'shop'); |
| | |
| | | } |
| | | |
| | | $taxonomy = jvbCheckBase($taxonomy); |
| | | $cache = Cache::for('checkTerm', DAY_IN_SECONDS)->connect('taxonomy'); |
| | | $cache = Cache::for('checkTerm', 'term', DAY_IN_SECONDS); |
| | | |
| | | return $cache->remember($termID, function() use ($termID, $taxonomy) { |
| | | return (bool)term_exists($termID, $taxonomy); |
| | |
| | | */ |
| | | public function isVerifiedUser(int $user_id): bool |
| | | { |
| | | $cache = Cache::for('verifiedUsers', DAY_IN_SECONDS)->connect('user'); |
| | | $cache = Cache::for('verifiedUsers', 'user',DAY_IN_SECONDS); |
| | | |
| | | return $cache->remember($user_id, function() use ($user_id) { |
| | | return user_can($user_id, 'skip_moderation'); |
| | |
| | | |
| | | // Keep existing author filtering logic |
| | | $authorQuery = []; |
| | | foreach (Registrar::getFeatured('can_create', 'user') as $type) { |
| | | foreach (Registrar::withFeature('can_create', 'user') as $type) { |
| | | if (array_key_exists($type, $data)) { |
| | | $artist_ids = array_map( |
| | | 'absint', |
| | |
| | | protected function isTimeline($args, $data):bool |
| | | { |
| | | $post_types = is_array($args['post_type']) ? $args['post_type'] : [$args['post_type']]; |
| | | $areTimeline = array_map(function($type) { return BASE.$type; },Registrar::getFeatured('is_timeline', 'post')); |
| | | $areTimeline = array_map(function($type) { return BASE.$type; },Registrar::withFeature('is_timeline', 'post')); |
| | | return !empty(array_intersect($post_types, $areTimeline)); |
| | | } |
| | | |
| | |
| | | } |
| | | |
| | | // ========== HTTP CACHING METHODS ========== |
| | | |
| | | /** |
| | | * Check HTTP caching headers (ETag and If-Modified-Since) |
| | | * Returns 304 Not Modified if content hasn't changed |
| | | * |
| | | * @param WP_REST_Request $request The REST request |
| | | * @param string|array $content_types Content type(s) to check timestamps for |
| | | * @param array $additional_params Additional params for ETag uniqueness (e.g., user_id, filters) |
| | | * @return WP_REST_Response|null Returns 304 response if not modified, null to continue processing |
| | | * @param WP_REST_Request $request |
| | | * @param int|string|array $key Content type(s) to check timestamps for |
| | | * @param string|array $group Additional params for ETag uniqueness (e.g., user_id, filters) |
| | | * @return WP_REST_Response|false Returns 304 response if not modified, null to continue processing |
| | | */ |
| | | protected function checkHeaders( |
| | | WP_REST_Request $request, |
| | |
| | | $key = $cache->generateKey($key); |
| | | } |
| | | |
| | | // Prefer tag freshness if available |
| | | $tags = $cache->getTags(); |
| | | |
| | | $lastModified = $tags |
| | | ? $cache->getLastModifiedForTags($tags) |
| | | : $cache::lastModified($group); |
| | | |
| | | $lastModified = $cache::lastModified($group); |
| | | |
| | | if (!$lastModified) { |
| | | return false; |
| | |
| | | |
| | | // Use existing error handler |
| | | try { |
| | | JVB()->error()->log( |
| | | Errors::getInstance()->log( |
| | | 'security_audit', |
| | | $event, |
| | | $context, |
| | | 'info' |
| | | ); |
| | | } catch (\Exception $e) { |
| | | } catch (Exception $e) { |
| | | // Fallback to error_log if handler fails |
| | | error_log("Security Audit: {$event} - " . json_encode($context)); |
| | | } |
| | |
| | | |
| | | protected function verifyTurnstile(string $token): bool |
| | | { |
| | | if (!Site::hasIntegration('cloudflare') || !JVB()->connect('cloudflare')->isSetUp()) { |
| | | if (!Site::hasIntegration('cloudflare') || !Cloudflare::getInstance()->isSetUp()) { |
| | | return true; |
| | | } |
| | | |
| | |
| | | return false; |
| | | } |
| | | |
| | | return JVB()->connect('cloudflare')->verifyTurnstile($token); |
| | | return Cloudflare::getInstance()->verifyTurnstile($token); |
| | | } |
| | | } |