+
+ );
+ }
+
+ if (error || !subscription) {
+ return (
+
+
+
+
+ );
+ }
+
+ return (
+ {__('Failed to load subscription')}
+ +
+ {/* Back button and actions */}
+
+
+ {__('Related Orders')}
+ {__('All orders associated with this subscription')}
+
+
+
+
+
+
+
+ );
+}
diff --git a/admin-spa/src/routes/Subscriptions/index.tsx b/admin-spa/src/routes/Subscriptions/index.tsx
new file mode 100644
index 0000000..323fc95
--- /dev/null
+++ b/admin-spa/src/routes/Subscriptions/index.tsx
@@ -0,0 +1,332 @@
+import React, { useEffect } from 'react';
+import { useQuery, useMutation, useQueryClient } from '@tanstack/react-query';
+import { useNavigate, useSearchParams, Link } from 'react-router-dom';
+import { Repeat, MoreHorizontal, Play, Pause, XCircle, RefreshCw, Eye, Calendar, User, Package } from 'lucide-react';
+import { Button } from '@/components/ui/button';
+import { Badge } from '@/components/ui/badge';
+import {
+ Table,
+ TableBody,
+ TableCell,
+ TableHead,
+ TableHeader,
+ TableRow,
+} from '@/components/ui/table';
+import {
+ DropdownMenu,
+ DropdownMenuContent,
+ DropdownMenuItem,
+ DropdownMenuSeparator,
+ DropdownMenuTrigger,
+} from '@/components/ui/dropdown-menu';
+import {
+ Select,
+ SelectContent,
+ SelectItem,
+ SelectTrigger,
+ SelectValue,
+} from '@/components/ui/select';
+import { Skeleton } from '@/components/ui/skeleton';
+import { usePageHeader } from '@/contexts/PageHeaderContext';
+import { __ } from '@/lib/i18n';
+import { toast } from 'sonner';
+
+interface Subscription {
+ id: number;
+ user_id: number;
+ order_id: number;
+ product_id: number;
+ product_name: string;
+ user_name: string;
+ user_email: string;
+ status: 'pending' | 'active' | 'on-hold' | 'cancelled' | 'expired' | 'pending-cancel';
+ billing_schedule: string;
+ recurring_amount: string;
+ next_payment_date: string | null;
+ created_at: string;
+ can_pause: boolean;
+ can_resume: boolean;
+ can_cancel: boolean;
+}
+
+const statusColors: Record
+
+
+
+
+ {/* Status and product info */}
+
+ {subscription.can_pause && (
+
+ )}
+ {subscription.can_resume && (
+
+ )}
+ {subscription.status === 'active' && (
+
+ )}
+ {subscription.can_cancel && (
+
+ )}
+
+
+ {/* Subscription Info */}
+
+
+
+
+
+
+
+ {/* Customer Info */}
+
+
+ {__('Customer')}
+
+
+
+
+
+
+ {/* Related Orders */}
+
+ {__('Subscription Details')}
+
+ {statusLabels[subscription.status] || subscription.status}
+
+
+
+ {subscription.product_image ? (
+ 
+ ) : (
+
+
+
+
+ )}
+
+
+ {subscription.product_name}
++ {subscription.billing_schedule} +
++ {window.WNW_STORE?.currency_symbol}{subscription.recurring_amount} +
+
+
+
+ {subscription.cancel_reason && (
+
+
+ {subscription.next_payment_date && (
+ {__('Start Date')}
+ {new Date(subscription.start_date).toLocaleDateString()}
+
+
+ )}
+ {subscription.trial_end_date && (
+ {__('Next Payment')}
+ {new Date(subscription.next_payment_date).toLocaleDateString()}
+
+
+ )}
+ {subscription.end_date && (
+ {__('Trial End')}
+ {new Date(subscription.trial_end_date).toLocaleDateString()}
+
+
+ )}
+ {__('End Date')}
+ {new Date(subscription.end_date).toLocaleDateString()}
+
+
+ )}
+ {__('Cancel Reason')}
+ {subscription.cancel_reason}
+
+
+
+
+
+
+
+ {subscription.user_name}
+ {subscription.user_email}
+
+
+
+
+ {__('Payment Method')}
+
+
+
+
+ {__('Pause Count')}
+ {subscription.pause_count}
+
+
+ {__('Failed Payments')}
+ 0 ? 'text-red-600' : ''}>
+ {subscription.failed_payment_count}
+
+
+
+ {__('Parent Order')}
+
+ #{subscription.order_id}
+
+
+ {/* Header */}
+
+ );
+}
diff --git a/composer.json b/composer.json
deleted file mode 100644
index 3ff7086..0000000
--- a/composer.json
+++ /dev/null
@@ -1,12 +0,0 @@
-{
- "name": "woonoow/woonoow",
- "type": "wordpress-plugin",
- "autoload": {
- "psr-4": {
- "WooNooW\\": "plugin/includes/"
- }
- },
- "require": {
- "php": "^8.1"
- }
- }
\ No newline at end of file
diff --git a/composer.lock b/composer.lock
deleted file mode 100644
index d710809..0000000
--- a/composer.lock
+++ /dev/null
@@ -1,20 +0,0 @@
-{
- "_readme": [
- "This file locks the dependencies of your project to a known state",
- "Read more about it at https://getcomposer.org/doc/01-basic-usage.md#installing-dependencies",
- "This file is @generated automatically"
- ],
- "content-hash": "c8dfaf9b12dfc28774a5f4e2e71e84af",
- "packages": [],
- "packages-dev": [],
- "aliases": [],
- "minimum-stability": "stable",
- "stability-flags": {},
- "prefer-stable": false,
- "prefer-lowest": false,
- "platform": {
- "php": "^8.1"
- },
- "platform-dev": {},
- "plugin-api-version": "2.9.0"
-}
diff --git a/customer-spa/src/App.tsx b/customer-spa/src/App.tsx
index d46de44..d347893 100644
--- a/customer-spa/src/App.tsx
+++ b/customer-spa/src/App.tsx
@@ -19,6 +19,7 @@ import Wishlist from './pages/Wishlist';
import Login from './pages/Login';
import ForgotPassword from './pages/ForgotPassword';
import ResetPassword from './pages/ResetPassword';
+import OrderPay from './pages/OrderPay';
import { DynamicPageRenderer } from './pages/DynamicPage';
// Create QueryClient instance
@@ -101,6 +102,8 @@ function AppRoutes() {
+
+
+ {/* Table */}
+
+
+
+
+
+ {__('Total')}: {total} {__('subscriptions')}
+
+
+
+
+
+
+ {/* Pagination */}
+ {totalPages > 1 && (
+
+
+
+ {__('Page')} {page} {__('of')} {totalPages}
+
+
+
+ )}
+
+
+ );
+};
+
+export default SubscriptionTimeline;
diff --git a/customer-spa/src/pages/Account/OrderDetails.tsx b/customer-spa/src/pages/Account/OrderDetails.tsx
index 72df5a5..768dcf0 100644
--- a/customer-spa/src/pages/Account/OrderDetails.tsx
+++ b/customer-spa/src/pages/Account/OrderDetails.tsx
@@ -115,9 +115,19 @@ export default function OrderDetails() {
Subscription Timeline
+ +
+ {/* Connecting Line */}
+
+
+
+
+ {/* Start Node */}
+
+
+
+
+ {/* Middle Info (Interval) */}
+
+
+
+
+
+ Started
+ {formatDate(subscription.start_date)}
+
+
+
+ {/* Current Payment (Active/Due) Node */}
+
+ Every {intervalLabel}
+
+
+
+
+ {/* Next Future Node */}
+
+ {/* Pulse Effect */}
+
+
+
+
+
+ Payment Due
+ Now
+
+
+
+
+
+
+
+ Next Renewal
+ {subscription.next_payment_date ? formatDate(subscription.next_payment_date) : '...'}
+ Order #{order.order_number}
- - {order.status.replace('-', ' ').toUpperCase()} - +
+ {['pending', 'failed', 'on-hold'].includes(order.status) && (
+
+ Pay Now
+
+ )}
+
+ {order.status.replace('-', ' ').toUpperCase()}
+
+
diff --git a/customer-spa/src/pages/Account/SubscriptionDetail.tsx b/customer-spa/src/pages/Account/SubscriptionDetail.tsx
new file mode 100644
index 0000000..d6490c6
--- /dev/null
+++ b/customer-spa/src/pages/Account/SubscriptionDetail.tsx
@@ -0,0 +1,377 @@
+import React, { useState } from 'react';
+import { useParams, Link, useNavigate } from 'react-router-dom';
+import { useQuery, useMutation, useQueryClient } from '@tanstack/react-query';
+import { api } from '@/lib/api/client';
+import { Button } from '@/components/ui/button';
+import {
+ AlertDialog,
+ AlertDialogAction,
+ AlertDialogCancel,
+ AlertDialogContent,
+ AlertDialogDescription,
+ AlertDialogFooter,
+ AlertDialogHeader,
+ AlertDialogTitle,
+ AlertDialogTrigger,
+} from '@/components/ui/alert-dialog';
+import { ArrowLeft, Repeat, Pause, Play, XCircle, Calendar, Package, CreditCard, FileText } from 'lucide-react';
+import { toast } from 'sonner';
+import SEOHead from '@/components/SEOHead';
+import { formatPrice } from '@/lib/currency';
+
+interface SubscriptionOrder {
+ id: number;
+ order_id: number;
+ order_type: 'parent' | 'renewal' | 'switch' | 'resubscribe';
+ order_status: string;
+ created_at: string;
+}
+
+interface Subscription {
+ id: number;
+ product_id: number;
+ product_name: string;
+ product_image: string;
+ status: string;
+ billing_period: string;
+ billing_interval: number;
+ billing_schedule: string;
+ recurring_amount: string;
+ start_date: string;
+ trial_end_date: string | null;
+ next_payment_date: string | null;
+ end_date: string | null;
+ last_payment_date: string | null;
+ payment_method: string;
+ pause_count: number;
+ can_pause: boolean;
+ can_resume: boolean;
+ can_cancel: boolean;
+ orders: SubscriptionOrder[];
+}
+
+const statusStyles: Record = {
+ 'pending': 'bg-yellow-100 text-yellow-800',
+ 'active': 'bg-green-100 text-green-800',
+ 'on-hold': 'bg-blue-100 text-blue-800',
+ 'cancelled': 'bg-gray-100 text-gray-800',
+ 'expired': 'bg-red-100 text-red-800',
+ 'pending-cancel': 'bg-orange-100 text-orange-800',
+};
+
+const statusLabels: Record = {
+ 'pending': 'Pending',
+ 'active': 'Active',
+ 'on-hold': 'On Hold',
+ 'cancelled': 'Cancelled',
+ 'expired': 'Expired',
+ 'pending-cancel': 'Pending Cancel',
+};
+
+const orderTypeLabels: Record = {
+ 'parent': 'Initial Order',
+ 'renewal': 'Renewal',
+ 'switch': 'Plan Switch',
+ 'resubscribe': 'Resubscribe',
+};
+
+export default function SubscriptionDetail() {
+ const { id } = useParams<{ id: string }>();
+ const navigate = useNavigate();
+ const queryClient = useQueryClient();
+ const [actionLoading, setActionLoading] = useState(false);
+
+ const { data: subscription, isLoading, error } = useQuery({
+ queryKey: ['account-subscription', id],
+ queryFn: () => api.get(`/account/subscriptions/${id}`),
+ enabled: !!id,
+ });
+
+ const actionMutation = useMutation({
+ mutationFn: (action: string) => api.post(`/account/subscriptions/${id}/${action}`),
+ onSuccess: (_, action) => {
+ queryClient.invalidateQueries({ queryKey: ['account-subscription', id] });
+ queryClient.invalidateQueries({ queryKey: ['account-subscriptions'] });
+ const actionLabels: Record = {
+ 'pause': 'paused',
+ 'resume': 'resumed',
+ 'cancel': 'cancelled',
+ };
+ toast.success(`Subscription ${actionLabels[action] || action} successfully`);
+ setActionLoading(false);
+ },
+ onError: (error: any) => {
+ toast.error(error.message || 'Action failed');
+ setActionLoading(false);
+ },
+ });
+
+ const handleAction = (action: string) => {
+ setActionLoading(true);
+ actionMutation.mutate(action);
+ };
+
+ const handleRenew = async () => {
+ setActionLoading(true);
+ try {
+ const response = await api.post<{ order_id: number; status: string }>(`/account/subscriptions/${id}/renew`);
+
+ queryClient.invalidateQueries({ queryKey: ['account-subscription', id] });
+ queryClient.invalidateQueries({ queryKey: ['account-subscriptions'] });
+
+ toast.success('Renewal order created');
+
+ if (response.order_id) {
+ // Determine destination based on functionality
+ // If manual payment required or just improved UX, go to payment page
+ navigate(`/order-pay/${response.order_id}`);
+ }
+ } catch (error: any) {
+ toast.error(error.message || 'Failed to renew');
+ } finally {
+ setActionLoading(false);
+ }
+ };
+
+ // Find pending renewal order
+ const pendingRenewalOrder = subscription?.orders?.find(
+ o => o.order_type === 'renewal' &&
+ ['pending', 'wc-pending', 'on-hold', 'wc-on-hold', 'failed', 'wc-failed'].includes(o.order_status)
+ );
+
+ if (isLoading) {
+ return (
+ = {
+ 'pending': 'bg-yellow-100 text-yellow-800',
+ 'active': 'bg-green-100 text-green-800',
+ 'on-hold': 'bg-blue-100 text-blue-800',
+ 'cancelled': 'bg-gray-100 text-gray-800',
+ 'expired': 'bg-red-100 text-red-800',
+ 'pending-cancel': 'bg-orange-100 text-orange-800',
+};
+
+const statusLabels: Record = {
+ 'pending': 'Pending',
+ 'active': 'Active',
+ 'on-hold': 'On Hold',
+ 'cancelled': 'Cancelled',
+ 'expired': 'Expired',
+ 'pending-cancel': 'Pending Cancel',
+};
+
+export default function Subscriptions() {
+ const queryClient = useQueryClient();
+ const [actionLoading, setActionLoading] = useState(null);
+
+ const { data: subscriptions = [], isLoading } = useQuery({
+ queryKey: ['account-subscriptions'],
+ queryFn: () => api.get('/account/subscriptions'),
+ });
+
+ const actionMutation = useMutation({
+ mutationFn: ({ id, action }: { id: number; action: string }) =>
+ api.post(`/account/subscriptions/${id}/${action}`),
+ onSuccess: (_, { action }) => {
+ queryClient.invalidateQueries({ queryKey: ['account-subscriptions'] });
+ const actionLabels: Record = {
+ 'pause': 'paused',
+ 'resume': 'resumed',
+ 'cancel': 'cancelled',
+ };
+ toast.success(`Subscription ${actionLabels[action] || action} successfully`);
+ setActionLoading(null);
+ },
+ onError: (error: any) => {
+ toast.error(error.message || 'Action failed');
+ setActionLoading(null);
+ },
+ });
+
+ const handleAction = (id: number, action: string) => {
+ setActionLoading(id);
+ actionMutation.mutate({ id, action });
+ };
+
+ if (isLoading) {
+ return (
+ (null);
+ const [loading, setLoading] = useState(true);
+ const [selectedGateway, setSelectedGateway] = useState('');
+ const [processing, setProcessing] = useState(false);
+
+ useEffect(() => {
+ if (orderId) {
+ fetchOrder();
+ }
+ }, [orderId]);
+
+ const fetchOrder = async () => {
+ try {
+ const endpoint = `/checkout/order/${orderId}${orderKey ? `?key=${orderKey}` : ''}`;
+ const response = await api.get(endpoint);
+
+ if (response.error) {
+ toast.error(response.error);
+ return;
+ }
+ if (response.ok) {
+ setOrder(response as OrderDetailsResponse);
+ if (response.available_gateways?.length > 0) {
+ setSelectedGateway(response.available_gateways[0].id);
+ }
+ }
+ } catch (error) {
+ console.error('Failed to fetch order', error);
+ toast.error('Failed to load order details');
+ } finally {
+ setLoading(false);
+ }
+ };
+
+ const handlePayment = async () => {
+ if (!selectedGateway) {
+ toast.error('Please select a payment method');
+ return;
+ }
+
+ setProcessing(true);
+ try {
+ const response = await api.post(`/checkout/pay-order/${orderId}`, {
+ payment_method: selectedGateway,
+ key: orderKey
+ });
+
+ if (response.ok && response.redirect) {
+ window.location.href = response.redirect;
+ } else {
+ toast.error(response.error || 'Payment failed');
+ }
+ } catch (error) {
+ console.error('Payment error', error);
+ toast.error('An error occurred while processing payment');
+ } finally {
+ setProcessing(false);
+ }
+ };
+
+ // Helper to format price with proper currency locale
+ const formatPrice = (amount: number, currency: string) => {
+ try {
+ return new Intl.NumberFormat('id-ID', {
+ style: 'currency',
+ currency: currency,
+ minimumFractionDigits: 0,
+ maximumFractionDigits: 0,
+ }).format(amount);
+ } catch (e) {
+ // Fallback
+ return `${currency} ${amount.toFixed(0)}`;
+ }
+ };
+
+ if (loading) return \d+)', [
'methods' => 'GET',
- 'callback' => [ new self(), 'get_order' ],
+ 'callback' => [new self(), 'get_order'],
'permission_callback' => '__return_true', // Public, validated via order_key
'args' => [
'key' => [
@@ -53,8 +58,14 @@ class CheckoutController {
// Get available shipping rates for given address
register_rest_route($namespace, '/checkout/shipping-rates', [
'methods' => 'POST',
- 'callback' => [ new self(), 'get_shipping_rates' ],
- 'permission_callback' => [ \WooNooW\Api\Permissions::class, 'anon_or_wp_nonce' ],
+ 'callback' => [new self(), 'get_shipping_rates'],
+ 'permission_callback' => [\WooNooW\Api\Permissions::class, 'anon_or_wp_nonce'],
+ ]);
+ // Process payment for an existing order (e.g. renewal)
+ register_rest_route($namespace, '/checkout/pay-order/(?P\d+)', [
+ 'methods' => 'POST',
+ 'callback' => [new self(), 'pay_order'],
+ 'permission_callback' => '__return_true', // Validated via order key/owner in method
]);
}
@@ -68,7 +79,8 @@ class CheckoutController {
* shipping_method: "flat_rate:1" | "free_shipping:3" | ...
* }
*/
- public function quote(WP_REST_Request $r): array {
+ public function quote(WP_REST_Request $r): array
+ {
$__t0 = microtime(true);
$payload = $this->sanitize_payload($r);
@@ -162,7 +174,8 @@ class CheckoutController {
* Validates access via order_key (for guests) or logged-in customer ID
* GET /checkout/order/{id}?key=wc_order_xxx
*/
- public function get_order(WP_REST_Request $r): array {
+ public function get_order(WP_REST_Request $r): array
+ {
$order_id = absint($r['id']);
$order_key = sanitize_text_field($r->get_param('key') ?? '');
@@ -175,9 +188,12 @@ class CheckoutController {
return ['error' => __('Order not found', 'woonoow')];
}
- // Validate access: order_key must match OR user must be logged in and own the order
+ // Validate access: order_key must match OR user must be logged in and own the order (or be admin)
$valid_key = $order_key && hash_equals($order->get_order_key(), $order_key);
- $valid_owner = is_user_logged_in() && get_current_user_id() === $order->get_customer_id();
+ $valid_owner = is_user_logged_in() && (
+ get_current_user_id() === $order->get_customer_id() ||
+ current_user_can('manage_woocommerce')
+ );
if (!$valid_key && !$valid_owner) {
return ['error' => __('Unauthorized access to order', 'woonoow')];
@@ -197,7 +213,7 @@ class CheckoutController {
'image' => $product ? wp_get_attachment_image_url($product->get_image_id(), 'thumbnail') : null,
];
}
-
+
// Build shipping lines
$shipping_lines = [];
foreach ($order->get_shipping_methods() as $shipping_item) {
@@ -208,16 +224,16 @@ class CheckoutController {
'total' => wc_price($shipping_item->get_total()),
];
}
-
+
// Get tracking info from order meta (various plugins use different keys)
- $tracking_number = $order->get_meta('_tracking_number')
- ?: $order->get_meta('_wc_shipment_tracking_items')
+ $tracking_number = $order->get_meta('_tracking_number')
+ ?: $order->get_meta('_wc_shipment_tracking_items')
?: $order->get_meta('_rajaongkir_awb_number')
?: '';
- $tracking_url = $order->get_meta('_tracking_url')
+ $tracking_url = $order->get_meta('_tracking_url')
?: $order->get_meta('_rajaongkir_tracking_url')
?: '';
-
+
// Check for shipment tracking plugin format (array of tracking items)
if (is_array($tracking_number) && !empty($tracking_number)) {
$first_tracking = reset($tracking_number);
@@ -230,6 +246,7 @@ class CheckoutController {
'id' => $order->get_id(),
'number' => $order->get_order_number(),
'status' => $order->get_status(),
+ 'created_via' => $order->get_created_via(),
'subtotal' => (float) $order->get_subtotal(),
'discount_total' => (float) $order->get_discount_total(),
'shipping_total' => (float) $order->get_shipping_total(),
@@ -249,6 +266,28 @@ class CheckoutController {
'phone' => $order->get_billing_phone(),
],
'items' => $items,
+ 'subscription' => $this->get_subscription_for_response($order),
+ 'available_gateways' => $this->get_available_gateways_for_order($order),
+ ];
+ }
+
+ private function get_subscription_for_response($order)
+ {
+ if (!class_exists('\WooNooW\Modules\Subscription\SubscriptionManager')) {
+ return null;
+ }
+ $sub = \WooNooW\Modules\Subscription\SubscriptionManager::get_by_order_id($order->get_id());
+ if (!$sub) return null;
+
+ return [
+ 'id' => (int) $sub->id,
+ 'status' => $sub->status,
+ 'billing_period' => $sub->billing_period,
+ 'billing_interval' => (int) $sub->billing_interval,
+ 'start_date' => $sub->start_date,
+ 'next_payment_date' => $sub->next_payment_date,
+ 'end_date' => $sub->end_date,
+ 'recurring_amount' => (float) $sub->recurring_amount,
];
}
@@ -263,7 +302,8 @@ class CheckoutController {
* payment_method: "cod" | "bacs" | ...
* }
*/
- public function submit(WP_REST_Request $r): array {
+ public function submit(WP_REST_Request $r): array
+ {
$__t0 = microtime(true);
$payload = $this->sanitize_payload($r);
@@ -281,11 +321,11 @@ class CheckoutController {
if (is_user_logged_in()) {
$user_id = get_current_user_id();
$order->set_customer_id($user_id);
-
+
// Update user's billing information from checkout data
if (!empty($payload['billing'])) {
$billing = $payload['billing'];
-
+
// Update first name and last name
if (!empty($billing['first_name'])) {
update_user_meta($user_id, 'first_name', sanitize_text_field($billing['first_name']));
@@ -295,12 +335,12 @@ class CheckoutController {
update_user_meta($user_id, 'last_name', sanitize_text_field($billing['last_name']));
update_user_meta($user_id, 'billing_last_name', sanitize_text_field($billing['last_name']));
}
-
+
// Update billing phone
if (!empty($billing['phone'])) {
update_user_meta($user_id, 'billing_phone', sanitize_text_field($billing['phone']));
}
-
+
// Update billing email
if (!empty($billing['email'])) {
update_user_meta($user_id, 'billing_email', sanitize_email($billing['email']));
@@ -310,20 +350,20 @@ class CheckoutController {
// Guest checkout - check if auto-register is enabled
$customer_settings = \WooNooW\Compat\CustomerSettingsProvider::get_settings();
$auto_register = $customer_settings['auto_register_members'] ?? false;
-
+
if ($auto_register && !empty($payload['billing']['email'])) {
$email = sanitize_email($payload['billing']['email']);
-
+
// Check if user already exists
$existing_user = get_user_by('email', $email);
-
+
if ($existing_user) {
// User exists - link order to them
$order->set_customer_id($existing_user->ID);
} else {
// Create new user account
$password = wp_generate_password(12, true, true);
-
+
$userdata = [
'user_login' => $email,
'user_email' => $email,
@@ -333,24 +373,24 @@ class CheckoutController {
'display_name' => trim((sanitize_text_field($payload['billing']['first_name'] ?? '') . ' ' . sanitize_text_field($payload['billing']['last_name'] ?? ''))) ?: $email,
'role' => 'customer', // WooCommerce customer role
];
-
+
$new_user_id = wp_insert_user($userdata);
-
+
if (!is_wp_error($new_user_id)) {
// Link order to new user
$order->set_customer_id($new_user_id);
-
+
// Store temp password in user meta for email template
// The real password is already set via wp_insert_user
update_user_meta($new_user_id, '_woonoow_temp_password', $password);
-
+
// AUTO-LOGIN: Set authentication cookie so user is logged in after page reload
wp_set_auth_cookie($new_user_id, true);
wp_set_current_user($new_user_id);
-
+
// Set WooCommerce customer billing data
$customer = new \WC_Customer($new_user_id);
-
+
if (!empty($payload['billing']['first_name'])) $customer->set_billing_first_name(sanitize_text_field($payload['billing']['first_name']));
if (!empty($payload['billing']['last_name'])) $customer->set_billing_last_name(sanitize_text_field($payload['billing']['last_name']));
if (!empty($payload['billing']['email'])) $customer->set_billing_email(sanitize_email($payload['billing']['email']));
@@ -360,9 +400,9 @@ class CheckoutController {
if (!empty($payload['billing']['state'])) $customer->set_billing_state(sanitize_text_field($payload['billing']['state']));
if (!empty($payload['billing']['postcode'])) $customer->set_billing_postcode(sanitize_text_field($payload['billing']['postcode']));
if (!empty($payload['billing']['country'])) $customer->set_billing_country(sanitize_text_field($payload['billing']['country']));
-
+
$customer->save();
-
+
// Send new account email (WooCommerce will handle this automatically via hook)
do_action('woocommerce_created_customer', $new_user_id, $userdata, $password);
}
@@ -430,12 +470,12 @@ class CheckoutController {
// Fallback: use shipping_cost directly from frontend
// This handles API-based shipping like Rajaongkir where WC zones don't apply
$item = new \WC_Order_Item_Shipping();
-
+
// Parse method ID from shipping_method (format: "method_id:instance_id" or "method_id:instance_id:variant")
$parts = explode(':', $payload['shipping_method']);
$method_id = $parts[0] ?? 'shipping';
$instance_id = isset($parts[1]) ? (int)$parts[1] : 0;
-
+
$item->set_props([
'method_title' => sanitize_text_field($payload['shipping_title'] ?? 'Shipping'),
'method_id' => sanitize_text_field($method_id),
@@ -479,12 +519,73 @@ class CheckoutController {
];
}
+ /**
+ * Process payment for an existing order
+ * POST /checkout/pay-order/{id}
+ */
+ public function pay_order(WP_REST_Request $r): array
+ {
+ $order_id = absint($r['id']);
+ $order = wc_get_order($order_id);
+
+ if (!$order) {
+ return ['error' => __('Order not found', 'woonoow')];
+ }
+
+ // Validate access
+ $key = $r->get_param('key'); // optional if logged in
+ $valid_key = $key && hash_equals($order->get_order_key(), $key);
+ $valid_owner = is_user_logged_in() && (
+ get_current_user_id() === $order->get_customer_id() ||
+ current_user_can('manage_woocommerce')
+ );
+
+ if (!$valid_key && !$valid_owner) {
+ return ['error' => __('Unauthorized access', 'woonoow')];
+ }
+
+ if ($order->is_paid()) {
+ return ['error' => __('Order already paid', 'woonoow')];
+ }
+
+ $payment_method = wc_clean($r->get_param('payment_method'));
+ if (empty($payment_method)) {
+ return ['error' => __('Payment method required', 'woonoow')];
+ }
+
+ // Update payment method
+ $available = WC()->payment_gateways()->get_available_payment_gateways();
+ if (!isset($available[$payment_method])) {
+ return ['error' => __('Invalid payment method', 'woonoow')];
+ }
+
+ $gateway = $available[$payment_method];
+ $order->set_payment_method($gateway);
+ $order->save();
+
+ // Process payment
+ $result = $gateway->process_payment($order_id);
+
+ if (isset($result['result']) && $result['result'] === 'success') {
+ return [
+ 'ok' => true,
+ 'redirect' => $result['redirect'] ?? $order->get_checkout_order_received_url(),
+ ];
+ }
+
+ return [
+ 'error' => __('Payment failed', 'woonoow') . (isset($result['result']) ? ': ' . $result['result'] : ''),
+ 'messages' => wc_get_notices('error'),
+ ];
+ }
+
/**
* Get checkout fields with all filters applied
* Accepts: { items: [...], is_digital_only?: bool }
* Returns fields with required, hidden, etc. based on addons + cart context
*/
- public function get_fields(WP_REST_Request $r): array {
+ public function get_fields(WP_REST_Request $r): array
+ {
$json = $r->get_json_params();
$items = isset($json['items']) && is_array($json['items']) ? $json['items'] : [];
$is_digital_only = isset($json['is_digital_only']) ? (bool) $json['is_digital_only'] : false;
@@ -504,7 +605,7 @@ class CheckoutController {
foreach ($fieldset as $key => $field) {
// Check if field should be hidden
$hidden = false;
-
+
// Hide shipping fields if digital only (your existing logic)
if ($is_digital_only && $fieldset_key === 'shipping') {
$hidden = true;
@@ -534,7 +635,7 @@ class CheckoutController {
'priority' => $field['priority'] ?? 10,
'options' => $field['options'] ?? null, // For select fields
'custom' => !in_array($key, $this->get_standard_field_keys()), // Flag custom fields
- 'autocomplete'=> $field['autocomplete'] ?? '',
+ 'autocomplete' => $field['autocomplete'] ?? '',
'validate' => $field['validate'] ?? [],
// New fields for dynamic rendering
'input_class' => $field['input_class'] ?? [],
@@ -549,7 +650,7 @@ class CheckoutController {
}
// Sort by priority
- usort($formatted, function($a, $b) {
+ usort($formatted, function ($a, $b) {
return $a['priority'] <=> $b['priority'];
});
@@ -564,7 +665,8 @@ class CheckoutController {
* Get list of standard WooCommerce field keys
* Plugins can extend this list via the 'woonoow_standard_checkout_field_keys' filter
*/
- private function get_standard_field_keys(): array {
+ private function get_standard_field_keys(): array
+ {
$keys = [
'billing_first_name',
'billing_last_name',
@@ -588,7 +690,7 @@ class CheckoutController {
'shipping_postcode',
'order_comments',
];
-
+
/**
* Filter the list of standard checkout field keys.
* Plugins can add their own field keys to be recognized as "standard" (not custom).
@@ -600,14 +702,19 @@ class CheckoutController {
/** ----------------- Helpers ----------------- **/
- private function accurate_quote_via_wc_cart(array $payload): array {
- if (!WC()->customer) { WC()->customer = new \WC_Customer(get_current_user_id(), true); }
- if (!WC()->cart) { WC()->cart = new \WC_Cart(); }
+ private function accurate_quote_via_wc_cart(array $payload): array
+ {
+ if (!WC()->customer) {
+ WC()->customer = new \WC_Customer(get_current_user_id(), true);
+ }
+ if (!WC()->cart) {
+ WC()->cart = new \WC_Cart();
+ }
// Address context for taxes/shipping rules - set temporarily without saving to user profile
$ship = !empty($payload['shipping']) ? $payload['shipping'] : $payload['billing'];
if (!empty($payload['billing'])) {
- foreach (['country','state','postcode','city','address_1','address_2'] as $k) {
+ foreach (['country', 'state', 'postcode', 'city', 'address_1', 'address_2'] as $k) {
$setter = 'set_billing_' . $k;
if (method_exists(WC()->customer, $setter) && isset($payload['billing'][$k])) {
WC()->customer->{$setter}(wc_clean($payload['billing'][$k]));
@@ -615,7 +722,7 @@ class CheckoutController {
}
}
if (!empty($ship)) {
- foreach (['country','state','postcode','city','address_1','address_2'] as $k) {
+ foreach (['country', 'state', 'postcode', 'city', 'address_1', 'address_2'] as $k) {
$setter = 'set_shipping_' . $k;
if (method_exists(WC()->customer, $setter) && isset($ship[$k])) {
WC()->customer->{$setter}(wc_clean($ship[$k]));
@@ -685,7 +792,8 @@ class CheckoutController {
];
}
- private function sanitize_payload(WP_REST_Request $r): array {
+ private function sanitize_payload(WP_REST_Request $r): array
+ {
$json = $r->get_json_params();
$items = isset($json['items']) && is_array($json['items']) ? $json['items'] : [];
@@ -704,7 +812,7 @@ class CheckoutController {
];
}, $items),
'billing' => $billing,
- 'shipping'=> $shipping,
+ 'shipping' => $shipping,
'coupons' => $coupons,
'shipping_method' => isset($json['shipping_method']) ? wc_clean($json['shipping_method']) : null,
'payment_method' => isset($json['payment_method']) ? wc_clean($json['payment_method']) : null,
@@ -716,7 +824,8 @@ class CheckoutController {
];
}
- private function load_product(array $line) {
+ private function load_product(array $line)
+ {
$pid = (int)($line['variation_id'] ?? 0) ?: (int)($line['product_id'] ?? 0);
if (!$pid) {
return new WP_Error('bad_item', __('Invalid product id', 'woonoow'));
@@ -728,8 +837,9 @@ class CheckoutController {
return $product;
}
- private function only_address_fields(array $src): array {
- $keys = ['first_name','last_name','company','address_1','address_2','city','state','postcode','country','email','phone'];
+ private function only_address_fields(array $src): array
+ {
+ $keys = ['first_name', 'last_name', 'company', 'address_1', 'address_2', 'city', 'state', 'postcode', 'country', 'email', 'phone'];
$out = [];
foreach ($keys as $k) {
if (isset($src[$k])) $out[$k] = wc_clean(wp_unslash($src[$k]));
@@ -737,7 +847,8 @@ class CheckoutController {
return $out;
}
- private function estimate_shipping(array $address, ?string $chosen_method): float {
+ private function estimate_shipping(array $address, ?string $chosen_method): float
+ {
$country = wc_clean($address['country'] ?? '');
$postcode = wc_clean($address['postcode'] ?? '');
$state = wc_clean($address['state'] ?? '');
@@ -745,12 +856,14 @@ class CheckoutController {
$cache_key = 'wnw_ship_' . md5(json_encode([$country, $state, $postcode, $city, (string) $chosen_method]));
$cached = wp_cache_get($cache_key, 'woonoow');
- if ($cached !== false) { return (float) $cached; }
+ if ($cached !== false) {
+ return (float) $cached;
+ }
if (!$country) return 0.0;
$packages = [[
- 'destination' => compact('country','state','postcode','city'),
+ 'destination' => compact('country', 'state', 'postcode', 'city'),
'contents_cost' => 0, // not exact in v0
'contents' => [],
'applied_coupons' => [],
@@ -778,7 +891,8 @@ class CheckoutController {
return $cost;
}
- private function find_shipping_rate_for_order(WC_Order $order, string $chosen) {
+ private function find_shipping_rate_for_order(WC_Order $order, string $chosen)
+ {
$shipping = $order->get_address('shipping');
$packages = [[
'destination' => [
@@ -810,12 +924,13 @@ class CheckoutController {
* Get countries and states for checkout form
* Public endpoint - no authentication required
*/
- public function get_countries(): array {
+ public function get_countries(): array
+ {
$wc_countries = WC()->countries;
-
+
// Get allowed selling countries
$allowed = $wc_countries->get_allowed_countries();
-
+
// Format for frontend
$countries = [];
foreach ($allowed as $code => $name) {
@@ -824,7 +939,7 @@ class CheckoutController {
'name' => $name,
];
}
-
+
// Get states for all allowed countries
$states = [];
foreach (array_keys($allowed) as $country_code) {
@@ -833,10 +948,10 @@ class CheckoutController {
$states[$country_code] = $country_states;
}
}
-
+
// Get default country
$default_country = $wc_countries->get_base_country();
-
+
return [
'countries' => $countries,
'states' => $states,
@@ -849,16 +964,17 @@ class CheckoutController {
* POST /checkout/shipping-rates
* Body: { shipping: { country, state, city, postcode, destination_id? }, items: [...] }
*/
- public function get_shipping_rates(WP_REST_Request $r): array {
+ public function get_shipping_rates(WP_REST_Request $r): array
+ {
$payload = $r->get_json_params();
$shipping = $payload['shipping'] ?? [];
$items = $payload['items'] ?? [];
-
+
$country = wc_clean($shipping['country'] ?? '');
$state = wc_clean($shipping['state'] ?? '');
$city = wc_clean($shipping['city'] ?? '');
$postcode = wc_clean($shipping['postcode'] ?? '');
-
+
if (empty($country)) {
return [
'ok' => true,
@@ -866,10 +982,10 @@ class CheckoutController {
'message' => 'Country is required',
];
}
-
+
// Trigger hook for plugins to set session data (e.g., Rajaongkir destination_id)
do_action('woonoow/shipping/before_calculate', $shipping, $items);
-
+
// Set customer location for shipping calculation
if (WC()->customer) {
WC()->customer->set_shipping_country($country);
@@ -877,7 +993,7 @@ class CheckoutController {
WC()->customer->set_shipping_city($city);
WC()->customer->set_shipping_postcode($postcode);
}
-
+
// Build package for shipping calculation
$contents = [];
$contents_cost = 0;
@@ -893,7 +1009,7 @@ class CheckoutController {
];
$contents_cost += $price * $qty;
}
-
+
$package = [
'destination' => [
'country' => $country,
@@ -906,7 +1022,7 @@ class CheckoutController {
'applied_coupons' => [],
'user' => ['ID' => get_current_user_id()],
];
-
+
// Get matching shipping zone
$zone = WC_Shipping_Zones::get_zone_matching_package($package);
if (!$zone) {
@@ -916,11 +1032,11 @@ class CheckoutController {
'message' => 'No shipping zone matches your location',
];
}
-
+
// Get enabled shipping methods from zone
$methods = $zone->get_shipping_methods(true);
$rates = [];
-
+
foreach ($methods as $method) {
// Check if method has rates (some methods like live rate need to calculate)
if (method_exists($method, 'get_rates_for_package')) {
@@ -938,14 +1054,14 @@ class CheckoutController {
// Fallback for simple methods
$method_id = $method->id . ':' . $method->get_instance_id();
$cost = 0;
-
+
// Try to get cost from method
if (isset($method->cost)) {
$cost = (float) $method->cost;
} elseif (method_exists($method, 'get_option')) {
$cost = (float) $method->get_option('cost', 0);
}
-
+
$rates[] = [
'id' => $method_id,
'label' => $method->get_title(),
@@ -955,11 +1071,34 @@ class CheckoutController {
];
}
}
-
+
return [
'ok' => true,
'rates' => $rates,
'zone_name' => $zone->get_zone_name(),
];
}
-}
\ No newline at end of file
+
+ private function get_available_gateways_for_order(WC_Order $order): array
+ {
+ // Mock cart for gateways that check cart total
+ if (!WC()->cart) {
+ WC()->initialize_cart();
+ }
+ // We can't easily bake the order into the cart, but many gateways just check 'needs_payment'
+ // or country.
+
+ $gateways = WC()->payment_gateways()->get_available_payment_gateways();
+ $results = [];
+
+ foreach ($gateways as $gateway) {
+ $results[] = [
+ 'id' => $gateway->id,
+ 'title' => $gateway->get_title() ?: $gateway->method_title ?: ucfirst($gateway->id), // Fallbacks
+ 'description' => $gateway->get_description(),
+ 'icon' => $gateway->get_icon(),
+ ];
+ }
+ return $results;
+ }
+}
diff --git a/includes/Api/ProductsController.php b/includes/Api/ProductsController.php
index 1d45c21..766e1a7 100644
--- a/includes/Api/ProductsController.php
+++ b/includes/Api/ProductsController.php
@@ -424,6 +424,23 @@ class ProductsController {
update_post_meta($product->get_id(), '_woonoow_license_expiry_days', self::sanitize_number($data['license_duration_days']));
}
+ // Subscription meta
+ if (isset($data['subscription_enabled'])) {
+ update_post_meta($product->get_id(), '_woonoow_subscription_enabled', $data['subscription_enabled'] ? 'yes' : 'no');
+ }
+ if (isset($data['subscription_period'])) {
+ update_post_meta($product->get_id(), '_woonoow_subscription_period', sanitize_key($data['subscription_period']));
+ }
+ if (isset($data['subscription_interval'])) {
+ update_post_meta($product->get_id(), '_woonoow_subscription_interval', absint($data['subscription_interval']));
+ }
+ if (isset($data['subscription_trial_days'])) {
+ update_post_meta($product->get_id(), '_woonoow_subscription_trial_days', absint($data['subscription_trial_days']));
+ }
+ if (isset($data['subscription_signup_fee'])) {
+ update_post_meta($product->get_id(), '_woonoow_subscription_signup_fee', self::sanitize_number($data['subscription_signup_fee']));
+ }
+
// Handle variations for variable products
if ($type === 'variable' && !empty($data['attributes']) && is_array($data['attributes'])) {
self::save_product_attributes($product, $data['attributes']);
@@ -568,6 +585,23 @@ class ProductsController {
update_post_meta($product->get_id(), '_woonoow_license_expiry_days', self::sanitize_number($data['license_duration_days']));
}
+ // Subscription meta
+ if (isset($data['subscription_enabled'])) {
+ update_post_meta($product->get_id(), '_woonoow_subscription_enabled', $data['subscription_enabled'] ? 'yes' : 'no');
+ }
+ if (isset($data['subscription_period'])) {
+ update_post_meta($product->get_id(), '_woonoow_subscription_period', sanitize_key($data['subscription_period']));
+ }
+ if (isset($data['subscription_interval'])) {
+ update_post_meta($product->get_id(), '_woonoow_subscription_interval', absint($data['subscription_interval']));
+ }
+ if (isset($data['subscription_trial_days'])) {
+ update_post_meta($product->get_id(), '_woonoow_subscription_trial_days', absint($data['subscription_trial_days']));
+ }
+ if (isset($data['subscription_signup_fee'])) {
+ update_post_meta($product->get_id(), '_woonoow_subscription_signup_fee', self::sanitize_number($data['subscription_signup_fee']));
+ }
+
// Allow plugins to perform additional updates (Level 1 compatibility)
do_action('woonoow/product_updated', $product, $data, $request);
@@ -767,6 +801,13 @@ class ProductsController {
$data['license_activation_limit'] = get_post_meta($product->get_id(), '_license_activation_limit', true) ?: '';
$data['license_duration_days'] = get_post_meta($product->get_id(), '_license_duration_days', true) ?: '';
+ // Subscription fields
+ $data['subscription_enabled'] = get_post_meta($product->get_id(), '_woonoow_subscription_enabled', true) === 'yes';
+ $data['subscription_period'] = get_post_meta($product->get_id(), '_woonoow_subscription_period', true) ?: 'month';
+ $data['subscription_interval'] = get_post_meta($product->get_id(), '_woonoow_subscription_interval', true) ?: '1';
+ $data['subscription_trial_days'] = get_post_meta($product->get_id(), '_woonoow_subscription_trial_days', true) ?: '';
+ $data['subscription_signup_fee'] = get_post_meta($product->get_id(), '_woonoow_subscription_signup_fee', true) ?: '';
+
// Images array (URLs) for frontend - featured + gallery
$images = [];
$featured_image_id = $product->get_image_id();
diff --git a/includes/Api/Routes.php b/includes/Api/Routes.php
index b969796..1f68925 100644
--- a/includes/Api/Routes.php
+++ b/includes/Api/Routes.php
@@ -26,6 +26,7 @@ use WooNooW\Api\ModuleSettingsController;
use WooNooW\Api\CampaignsController;
use WooNooW\Api\DocsController;
use WooNooW\Api\LicensesController;
+use WooNooW\Api\SubscriptionsController;
use WooNooW\Frontend\ShopController;
use WooNooW\Frontend\CartController as FrontendCartController;
use WooNooW\Frontend\AccountController;
@@ -163,6 +164,9 @@ class Routes {
// Licenses controller (licensing module)
LicensesController::register_routes();
+ // Subscriptions controller (subscription module)
+ SubscriptionsController::register_routes();
+
// Modules controller
$modules_controller = new ModulesController();
$modules_controller->register_routes();
diff --git a/includes/Api/SubscriptionsController.php b/includes/Api/SubscriptionsController.php
new file mode 100644
index 0000000..0455c45
--- /dev/null
+++ b/includes/Api/SubscriptionsController.php
@@ -0,0 +1,476 @@
+ 'GET',
+ 'callback' => [__CLASS__, 'get_subscriptions'],
+ 'permission_callback' => function () {
+ return current_user_can('manage_woocommerce');
+ },
+ ]);
+
+ register_rest_route('woonoow/v1', '/subscriptions/(?P\d+)', [
+ 'methods' => 'GET',
+ 'callback' => [__CLASS__, 'get_subscription'],
+ 'permission_callback' => function () {
+ return current_user_can('manage_woocommerce');
+ },
+ ]);
+
+ register_rest_route('woonoow/v1', '/subscriptions/(?P\d+)', [
+ 'methods' => 'PUT',
+ 'callback' => [__CLASS__, 'update_subscription'],
+ 'permission_callback' => function () {
+ return current_user_can('manage_woocommerce');
+ },
+ ]);
+
+ register_rest_route('woonoow/v1', '/subscriptions/(?P\d+)/cancel', [
+ 'methods' => 'POST',
+ 'callback' => [__CLASS__, 'cancel_subscription'],
+ 'permission_callback' => function () {
+ return current_user_can('manage_woocommerce');
+ },
+ ]);
+
+ register_rest_route('woonoow/v1', '/subscriptions/(?P\d+)/renew', [
+ 'methods' => 'POST',
+ 'callback' => [__CLASS__, 'renew_subscription'],
+ 'permission_callback' => function () {
+ return current_user_can('manage_woocommerce');
+ },
+ ]);
+
+ register_rest_route('woonoow/v1', '/subscriptions/(?P\d+)/pause', [
+ 'methods' => 'POST',
+ 'callback' => [__CLASS__, 'pause_subscription'],
+ 'permission_callback' => function () {
+ return current_user_can('manage_woocommerce');
+ },
+ ]);
+
+ register_rest_route('woonoow/v1', '/subscriptions/(?P\d+)/resume', [
+ 'methods' => 'POST',
+ 'callback' => [__CLASS__, 'resume_subscription'],
+ 'permission_callback' => function () {
+ return current_user_can('manage_woocommerce');
+ },
+ ]);
+
+ // Customer routes
+ register_rest_route('woonoow/v1', '/account/subscriptions', [
+ 'methods' => 'GET',
+ 'callback' => [__CLASS__, 'get_customer_subscriptions'],
+ 'permission_callback' => function () {
+ return is_user_logged_in();
+ },
+ ]);
+
+ register_rest_route('woonoow/v1', '/account/subscriptions/(?P\d+)', [
+ 'methods' => 'GET',
+ 'callback' => [__CLASS__, 'get_customer_subscription'],
+ 'permission_callback' => function () {
+ return is_user_logged_in();
+ },
+ ]);
+
+ register_rest_route('woonoow/v1', '/account/subscriptions/(?P\d+)/cancel', [
+ 'methods' => 'POST',
+ 'callback' => [__CLASS__, 'customer_cancel'],
+ 'permission_callback' => function () {
+ return is_user_logged_in();
+ },
+ ]);
+
+ register_rest_route('woonoow/v1', '/account/subscriptions/(?P\d+)/pause', [
+ 'methods' => 'POST',
+ 'callback' => [__CLASS__, 'customer_pause'],
+ 'permission_callback' => function () {
+ return is_user_logged_in();
+ },
+ ]);
+
+ register_rest_route('woonoow/v1', '/account/subscriptions/(?P\d+)/resume', [
+ 'methods' => 'POST',
+ 'callback' => [__CLASS__, 'customer_resume'],
+ 'permission_callback' => function () {
+ return is_user_logged_in();
+ },
+ ]);
+
+ register_rest_route('woonoow/v1', '/account/subscriptions/(?P\d+)/renew', [
+ 'methods' => 'POST',
+ 'callback' => [__CLASS__, 'customer_renew'],
+ 'permission_callback' => function () {
+ return is_user_logged_in();
+ },
+ ]);
+ }
+
+ /**
+ * Get all subscriptions (admin)
+ */
+ public static function get_subscriptions(WP_REST_Request $request)
+ {
+ $args = [
+ 'status' => $request->get_param('status'),
+ 'product_id' => $request->get_param('product_id'),
+ 'user_id' => $request->get_param('user_id'),
+ 'limit' => $request->get_param('per_page') ?: 20,
+ 'offset' => (($request->get_param('page') ?: 1) - 1) * ($request->get_param('per_page') ?: 20),
+ ];
+
+ $subscriptions = SubscriptionManager::get_all($args);
+ $total = SubscriptionManager::count(['status' => $args['status']]);
+
+ // Enrich with product and user info
+ $enriched = [];
+ foreach ($subscriptions as $subscription) {
+ $enriched[] = self::enrich_subscription($subscription);
+ }
+
+ return new WP_REST_Response([
+ 'subscriptions' => $enriched,
+ 'total' => $total,
+ 'page' => $request->get_param('page') ?: 1,
+ 'per_page' => $args['limit'],
+ ]);
+ }
+
+ /**
+ * Get single subscription (admin)
+ */
+ public static function get_subscription(WP_REST_Request $request)
+ {
+ $subscription = SubscriptionManager::get($request->get_param('id'));
+
+ if (!$subscription) {
+ return new WP_Error('not_found', __('Subscription not found', 'woonoow'), ['status' => 404]);
+ }
+
+ $enriched = self::enrich_subscription($subscription);
+ $enriched['orders'] = SubscriptionManager::get_orders($subscription->id);
+
+ return new WP_REST_Response($enriched);
+ }
+
+ /**
+ * Update subscription (admin)
+ */
+ public static function update_subscription(WP_REST_Request $request)
+ {
+ global $wpdb;
+
+ $subscription = SubscriptionManager::get($request->get_param('id'));
+
+ if (!$subscription) {
+ return new WP_Error('not_found', __('Subscription not found', 'woonoow'), ['status' => 404]);
+ }
+
+ $data = $request->get_json_params();
+ $allowed_fields = ['status', 'next_payment_date', 'end_date', 'billing_period', 'billing_interval'];
+
+ $update_data = [];
+ $format = [];
+
+ foreach ($allowed_fields as $field) {
+ if (isset($data[$field])) {
+ $update_data[$field] = $data[$field];
+ $format[] = is_numeric($data[$field]) ? '%d' : '%s';
+ }
+ }
+
+ if (empty($update_data)) {
+ return new WP_Error('no_data', __('No valid fields to update', 'woonoow'), ['status' => 400]);
+ }
+
+ $table = $wpdb->prefix . 'woonoow_subscriptions';
+ $updated = $wpdb->update($table, $update_data, ['id' => $subscription->id], $format, ['%d']);
+
+ if ($updated === false) {
+ return new WP_Error('update_failed', __('Failed to update subscription', 'woonoow'), ['status' => 500]);
+ }
+
+ return new WP_REST_Response(['success' => true]);
+ }
+
+ /**
+ * Cancel subscription (admin)
+ */
+ public static function cancel_subscription(WP_REST_Request $request)
+ {
+ $data = $request->get_json_params();
+ $reason = $data['reason'] ?? 'Cancelled by admin';
+
+ $result = SubscriptionManager::cancel($request->get_param('id'), $reason);
+
+ if (!$result) {
+ return new WP_Error('cancel_failed', __('Failed to cancel subscription', 'woonoow'), ['status' => 500]);
+ }
+
+ return new WP_REST_Response(['success' => true]);
+ }
+
+ /**
+ * Renew subscription (admin - force immediate renewal)
+ */
+ public static function renew_subscription(WP_REST_Request $request)
+ {
+ $result = SubscriptionManager::renew($request->get_param('id'));
+
+ if (!$result) {
+ return new WP_Error('renew_failed', __('Failed to process renewal', 'woonoow'), ['status' => 500]);
+ }
+
+ return new WP_REST_Response(['success' => true, 'order_id' => $result['order_id']]);
+ }
+
+ /**
+ * Pause subscription (admin)
+ */
+ public static function pause_subscription(WP_REST_Request $request)
+ {
+ $result = SubscriptionManager::pause($request->get_param('id'));
+
+ if (!$result) {
+ return new WP_Error('pause_failed', __('Failed to pause subscription', 'woonoow'), ['status' => 500]);
+ }
+
+ return new WP_REST_Response(['success' => true]);
+ }
+
+ /**
+ * Resume subscription (admin)
+ */
+ public static function resume_subscription(WP_REST_Request $request)
+ {
+ $result = SubscriptionManager::resume($request->get_param('id'));
+
+ if (!$result) {
+ return new WP_Error('resume_failed', __('Failed to resume subscription', 'woonoow'), ['status' => 500]);
+ }
+
+ return new WP_REST_Response(['success' => true]);
+ }
+
+ /**
+ * Get customer's subscriptions
+ */
+ public static function get_customer_subscriptions(WP_REST_Request $request)
+ {
+ $user_id = get_current_user_id();
+ $subscriptions = SubscriptionManager::get_by_user($user_id, [
+ 'status' => $request->get_param('status'),
+ 'limit' => $request->get_param('per_page') ?: 20,
+ 'offset' => (($request->get_param('page') ?: 1) - 1) * ($request->get_param('per_page') ?: 20),
+ ]);
+
+ // Enrich each subscription
+ $enriched = [];
+ foreach ($subscriptions as $subscription) {
+ $enriched[] = self::enrich_subscription($subscription);
+ }
+
+ return new WP_REST_Response($enriched);
+ }
+
+ /**
+ * Get customer's subscription detail
+ */
+ public static function get_customer_subscription(WP_REST_Request $request)
+ {
+ $user_id = get_current_user_id();
+ $subscription = SubscriptionManager::get($request->get_param('id'));
+
+ if (!$subscription || $subscription->user_id != $user_id) {
+ return new WP_Error('not_found', __('Subscription not found', 'woonoow'), ['status' => 404]);
+ }
+
+ $enriched = self::enrich_subscription($subscription);
+ $enriched['orders'] = SubscriptionManager::get_orders($subscription->id);
+
+ return new WP_REST_Response($enriched);
+ }
+
+ /**
+ * Customer cancel their own subscription
+ */
+ public static function customer_cancel(WP_REST_Request $request)
+ {
+ // Check if customer cancellation is allowed
+ $settings = ModuleRegistry::get_settings('subscription');
+ if (empty($settings['allow_customer_cancel'])) {
+ return new WP_Error('not_allowed', __('Customer cancellation is not allowed', 'woonoow'), ['status' => 403]);
+ }
+
+ $user_id = get_current_user_id();
+ $subscription = SubscriptionManager::get($request->get_param('id'));
+
+ if (!$subscription || $subscription->user_id != $user_id) {
+ return new WP_Error('not_found', __('Subscription not found', 'woonoow'), ['status' => 404]);
+ }
+
+ $data = $request->get_json_params();
+ $reason = $data['reason'] ?? 'Cancelled by customer';
+
+ $result = SubscriptionManager::cancel($subscription->id, $reason);
+
+ if (!$result) {
+ return new WP_Error('cancel_failed', __('Failed to cancel subscription', 'woonoow'), ['status' => 500]);
+ }
+
+ return new WP_REST_Response(['success' => true]);
+ }
+
+ /**
+ * Customer pause their own subscription
+ */
+ public static function customer_pause(WP_REST_Request $request)
+ {
+ // Check if customer pause is allowed
+ $settings = ModuleRegistry::get_settings('subscription');
+ if (empty($settings['allow_customer_pause'])) {
+ return new WP_Error('not_allowed', __('Customer pause is not allowed', 'woonoow'), ['status' => 403]);
+ }
+
+ $user_id = get_current_user_id();
+ $subscription = SubscriptionManager::get($request->get_param('id'));
+
+ if (!$subscription || $subscription->user_id != $user_id) {
+ return new WP_Error('not_found', __('Subscription not found', 'woonoow'), ['status' => 404]);
+ }
+
+ $result = SubscriptionManager::pause($subscription->id);
+
+ if (!$result) {
+ return new WP_Error('pause_failed', __('Failed to pause subscription. Maximum pauses may have been reached.', 'woonoow'), ['status' => 500]);
+ }
+
+ return new WP_REST_Response(['success' => true]);
+ }
+
+ /**
+ * Customer resume their own subscription
+ */
+ public static function customer_resume(WP_REST_Request $request)
+ {
+ $user_id = get_current_user_id();
+ $subscription = SubscriptionManager::get($request->get_param('id'));
+
+ if (!$subscription || $subscription->user_id != $user_id) {
+ return new WP_Error('not_found', __('Subscription not found', 'woonoow'), ['status' => 404]);
+ }
+
+ $result = SubscriptionManager::resume($subscription->id);
+
+ if (!$result) {
+ return new WP_Error('resume_failed', __('Failed to resume subscription', 'woonoow'), ['status' => 500]);
+ }
+
+ return new WP_REST_Response(['success' => true]);
+ }
+
+ /**
+ * Customer renew their own subscription (Early Renewal)
+ */
+ public static function customer_renew(WP_REST_Request $request)
+ {
+ $user_id = get_current_user_id();
+ $subscription = SubscriptionManager::get($request->get_param('id'));
+
+ if (!$subscription || $subscription->user_id != $user_id) {
+ return new WP_Error('not_found', __('Subscription not found', 'woonoow'), ['status' => 404]);
+ }
+
+ // Check if subscription is active (for early renewal) or on-hold with no pending payment
+ if ($subscription->status !== 'active' && $subscription->status !== 'on-hold') {
+ return new WP_Error('not_allowed', __('Only active subscriptions can be renewed early', 'woonoow'), ['status' => 403]);
+ }
+
+ // Trigger renewal
+ $result = SubscriptionManager::renew($subscription->id);
+
+ // SubscriptionManager::renew returns array (success) or false (failed)
+ if (!$result) {
+ return new WP_Error('renew_failed', __('Failed to create renewal order', 'woonoow'), ['status' => 500]);
+ }
+
+ return new WP_REST_Response([
+ 'success' => true,
+ 'order_id' => $result['order_id'],
+ 'status' => $result['status']
+ ]);
+ }
+
+ /**
+ * Enrich subscription with product and user info
+ */
+ private static function enrich_subscription($subscription)
+ {
+ $enriched = (array) $subscription;
+
+ // Add product info
+ $product_id = $subscription->variation_id ?: $subscription->product_id;
+ $product = wc_get_product($product_id);
+ $enriched['product_name'] = $product ? $product->get_name() : __('Unknown Product', 'woonoow');
+ $enriched['product_image'] = $product ? wp_get_attachment_url($product->get_image_id()) : '';
+
+ // Add user info
+ $user = get_userdata($subscription->user_id);
+ $enriched['user_email'] = $user ? $user->user_email : '';
+ $enriched['user_name'] = $user ? $user->display_name : __('Unknown User', 'woonoow');
+
+ // Add computed fields
+ $enriched['is_active'] = $subscription->status === 'active';
+ $enriched['can_pause'] = $subscription->status === 'active';
+ $enriched['can_resume'] = $subscription->status === 'on-hold';
+ $enriched['can_cancel'] = in_array($subscription->status, ['active', 'on-hold', 'pending']);
+
+ // Format billing info
+ $period_labels = [
+ 'day' => __('day', 'woonoow'),
+ 'week' => __('week', 'woonoow'),
+ 'month' => __('month', 'woonoow'),
+ 'year' => __('year', 'woonoow'),
+ ];
+ $interval = $subscription->billing_interval > 1 ? $subscription->billing_interval . ' ' : '';
+ $period = $period_labels[$subscription->billing_period] ?? $subscription->billing_period;
+ if ($subscription->billing_interval > 1) {
+ $period .= 's'; // Pluralize
+ }
+ $enriched['billing_schedule'] = sprintf(__('Every %s%s', 'woonoow'), $interval, $period);
+
+ return $enriched;
+ }
+}
diff --git a/includes/Compat/NavigationRegistry.php b/includes/Compat/NavigationRegistry.php
index 5f871ec..a3b777e 100644
--- a/includes/Compat/NavigationRegistry.php
+++ b/includes/Compat/NavigationRegistry.php
@@ -13,7 +13,7 @@ if ( ! defined('ABSPATH') ) exit;
*/
class NavigationRegistry {
const NAV_OPTION = 'wnw_nav_tree';
- const NAV_VERSION = '1.2.0'; // Added Menus (Menu Editor)
+ const NAV_VERSION = '1.3.0'; // Added Subscriptions section
/**
* Initialize hooks
@@ -132,6 +132,8 @@ class NavigationRegistry {
// Future: Drafts, Recurring, etc.
],
],
+ // Subscriptions - only if module enabled
+ ...self::get_subscriptions_section(),
[
'key' => 'products',
'label' => __('Products', 'woonoow'),
@@ -242,6 +244,30 @@ class NavigationRegistry {
return $children;
}
+ /**
+ * Get subscriptions navigation section
+ * Returns empty array if module is not enabled
+ *
+ * @return array Subscriptions section or empty array
+ */
+ private static function get_subscriptions_section(): array {
+ if (!\WooNooW\Core\ModuleRegistry::is_enabled('subscription')) {
+ return [];
+ }
+
+ return [
+ [
+ 'key' => 'subscriptions',
+ 'label' => __('Subscriptions', 'woonoow'),
+ 'path' => '/subscriptions',
+ 'icon' => 'repeat',
+ 'children' => [
+ ['label' => __('All Subscriptions', 'woonoow'), 'mode' => 'spa', 'path' => '/subscriptions', 'exact' => true],
+ ],
+ ],
+ ];
+ }
+
/**
* Get the complete navigation tree
*
diff --git a/includes/Core/ModuleRegistry.php b/includes/Core/ModuleRegistry.php
index ad2e226..e57858d 100644
--- a/includes/Core/ModuleRegistry.php
+++ b/includes/Core/ModuleRegistry.php
@@ -1,4 +1,5 @@
[
'id' => 'newsletter',
@@ -68,6 +71,7 @@ class ModuleRegistry {
'category' => 'products',
'icon' => 'refresh-cw',
'default_enabled' => false,
+ 'has_settings' => true,
'features' => [
__('Recurring billing', 'woonoow'),
__('Subscription management', 'woonoow'),
@@ -91,19 +95,20 @@ class ModuleRegistry {
],
],
];
-
+
return $modules;
}
-
+
/**
* Get addon modules from AddonRegistry
*
* @return array
*/
- private static function get_addon_modules() {
+ private static function get_addon_modules()
+ {
$addons = apply_filters('woonoow/addon_registry', []);
$modules = [];
-
+
foreach ($addons as $addon_id => $addon) {
$modules[$addon_id] = [
'id' => $addon_id,
@@ -120,31 +125,33 @@ class ModuleRegistry {
'settings_component' => $addon['settings_component'] ?? null,
];
}
-
+
return $modules;
}
-
+
/**
* Get all modules (built-in + addons)
*
* @return array
*/
- public static function get_all_modules() {
+ public static function get_all_modules()
+ {
$builtin = self::get_builtin_modules();
$addons = self::get_addon_modules();
-
+
return array_merge($builtin, $addons);
}
-
+
/**
* Get categories dynamically from registered modules
*
* @return array Associative array of category_id => label
*/
- public static function get_categories() {
+ public static function get_categories()
+ {
$all_modules = self::get_all_modules();
$categories = [];
-
+
// Extract unique categories from modules
foreach ($all_modules as $module) {
$cat = $module['category'] ?? 'other';
@@ -152,27 +159,28 @@ class ModuleRegistry {
$categories[$cat] = self::get_category_label($cat);
}
}
-
+
// Sort by predefined order
$order = ['marketing', 'customers', 'products', 'shipping', 'payments', 'analytics', 'other'];
- uksort($categories, function($a, $b) use ($order) {
+ uksort($categories, function ($a, $b) use ($order) {
$pos_a = array_search($a, $order);
$pos_b = array_search($b, $order);
if ($pos_a === false) $pos_a = 999;
if ($pos_b === false) $pos_b = 999;
return $pos_a - $pos_b;
});
-
+
return $categories;
}
-
+
/**
* Get human-readable label for category
*
* @param string $category Category ID
* @return string
*/
- private static function get_category_label($category) {
+ private static function get_category_label($category)
+ {
$labels = [
'marketing' => __('Marketing & Sales', 'woonoow'),
'customers' => __('Customer Experience', 'woonoow'),
@@ -182,19 +190,20 @@ class ModuleRegistry {
'analytics' => __('Analytics & Reports', 'woonoow'),
'other' => __('Other Extensions', 'woonoow'),
];
-
+
return $labels[$category] ?? ucfirst($category);
}
-
+
/**
* Group modules by category
*
* @return array
*/
- public static function get_grouped_modules() {
+ public static function get_grouped_modules()
+ {
$all_modules = self::get_all_modules();
$grouped = [];
-
+
foreach ($all_modules as $module) {
$cat = $module['category'] ?? 'other';
if (!isset($grouped[$cat])) {
@@ -202,18 +211,19 @@ class ModuleRegistry {
}
$grouped[$cat][] = $module;
}
-
+
return $grouped;
}
-
+
/**
* Get enabled modules
*
* @return array
*/
- public static function get_enabled_modules() {
+ public static function get_enabled_modules()
+ {
$enabled = get_option('woonoow_enabled_modules', null);
-
+
// First time - use defaults
if ($enabled === null) {
$modules = self::get_all_modules();
@@ -225,89 +235,93 @@ class ModuleRegistry {
}
update_option('woonoow_enabled_modules', $enabled);
}
-
+
return $enabled;
}
-
+
/**
* Check if a module is enabled
*
* @param string $module_id
* @return bool
*/
- public static function is_enabled($module_id) {
+ public static function is_enabled($module_id)
+ {
$enabled = self::get_enabled_modules();
return in_array($module_id, $enabled);
}
-
+
/**
* Enable a module
*
* @param string $module_id
* @return bool
*/
- public static function enable($module_id) {
+ public static function enable($module_id)
+ {
$modules = self::get_all_modules();
-
+
if (!isset($modules[$module_id])) {
return false;
}
-
+
$enabled = self::get_enabled_modules();
-
+
if (!in_array($module_id, $enabled)) {
$enabled[] = $module_id;
update_option('woonoow_enabled_modules', $enabled);
-
+
// Clear navigation cache when module is toggled
if (class_exists('\WooNooW\Compat\NavigationRegistry')) {
\WooNooW\Compat\NavigationRegistry::flush();
}
-
+
do_action('woonoow/module/enabled', $module_id);
-
+
return true;
}
-
+
return false;
}
-
+
/**
* Disable a module
*
* @param string $module_id
* @return bool
*/
- public static function disable($module_id) {
+ public static function disable($module_id)
+ {
$enabled = self::get_enabled_modules();
-
+
if (in_array($module_id, $enabled)) {
$enabled = array_diff($enabled, [$module_id]);
update_option('woonoow_enabled_modules', array_values($enabled));
-
+
// Clear navigation cache when module is toggled
if (class_exists('\WooNooW\Compat\NavigationRegistry')) {
\WooNooW\Compat\NavigationRegistry::flush();
}
-
+
do_action('woonoow/module/disabled', $module_id);
-
+
return true;
}
-
+
return false;
}
-
+
/**
* Get modules by category
*
* @param string $category
* @return array
*/
- public static function get_by_category($category) {
+ public static function get_by_category($category)
+ {
$modules = self::get_all_modules();
$enabled = self::get_enabled_modules();
-
+
$result = [];
foreach ($modules as $module) {
if ($module['category'] === $category) {
@@ -315,23 +329,63 @@ class ModuleRegistry {
$result[] = $module;
}
}
-
return $result;
}
-
+
/**
* Get all modules with enabled status
*
* @return array
*/
- public static function get_all_with_status() {
+ public static function get_all_with_status()
+ {
$modules = self::get_all_modules();
$enabled = self::get_enabled_modules();
-
- foreach ($modules as $id => $module) {
- $modules[$id]['enabled'] = in_array($id, $enabled);
+
+ foreach ($modules as $id => &$module) {
+ $module['enabled'] = in_array($id, $enabled);
}
-
+
return $modules;
}
+
+ /**
+ * Get module settings
+ *
+ * @param string $module_id
+ * @return array
+ */
+ public static function get_settings($module_id)
+ {
+ $settings = get_option("woonoow_module_{$module_id}_settings", []);
+
+ // Apply defaults from schema if available
+ $schema = apply_filters('woonoow/module_settings_schema', []);
+
+ if (isset($schema[$module_id])) {
+ $defaults = self::get_schema_defaults($schema[$module_id]);
+ $settings = wp_parse_args($settings, $defaults);
+ }
+
+ return $settings;
+ }
+
+ /**
+ * Get default values from schema
+ *
+ * @param array $schema
+ * @return array
+ */
+ private static function get_schema_defaults($schema)
+ {
+ $defaults = [];
+
+ foreach ($schema as $key => $field) {
+ if (isset($field['default'])) {
+ $defaults[$key] = $field['default'];
+ }
+ }
+
+ return $defaults;
+ }
}
diff --git a/includes/Core/Notifications/EmailRenderer.php b/includes/Core/Notifications/EmailRenderer.php
index 2f1db61..d5a828a 100644
--- a/includes/Core/Notifications/EmailRenderer.php
+++ b/includes/Core/Notifications/EmailRenderer.php
@@ -1,4 +1,5 @@
get_template_settings($event_id, $recipient_type);
-
+
if (!$template_settings) {
return null;
}
-
+
// Get recipient email
$to = $this->get_recipient_email($recipient_type, $data);
-
+
if (!$to) {
return null;
}
-
+
// Get variables
$variables = $this->get_variables($event_id, $data, $extra_data);
-
+
// Replace variables in subject and content
$subject = $this->replace_variables($template_settings['subject'], $variables);
$content = $this->replace_variables($template_settings['body'], $variables);
-
+
// Parse cards in content
$content = $this->parse_cards($content);
-
+
// Get HTML template
$template_path = $this->get_design_template();
-
+
// Render final HTML
$html = $this->render_html($template_path, $content, $subject, $variables);
-
+
return [
'to' => $to,
'subject' => $subject,
'body' => $html,
];
}
-
+
/**
* Get template settings
*
@@ -80,30 +86,31 @@ class EmailRenderer {
* @param string $recipient_type
* @return array|null
*/
- private function get_template_settings($event_id, $recipient_type) {
+ private function get_template_settings($event_id, $recipient_type)
+ {
// Get saved template (with recipient_type for proper default template lookup)
$template = TemplateProvider::get_template($event_id, 'email', $recipient_type);
-
+
if (!$template) {
if (defined('WP_DEBUG') && WP_DEBUG) {
}
return null;
}
-
+
if (defined('WP_DEBUG') && WP_DEBUG) {
}
-
+
// Get design template preference
$settings = get_option('woonoow_notification_settings', []);
$design = $settings['email_design_template'] ?? 'modern';
-
+
return [
'subject' => $template['subject'] ?? '',
'body' => $template['body'] ?? '',
'design' => $design,
];
}
-
+
/**
* Get recipient email
*
@@ -111,23 +118,24 @@ class EmailRenderer {
* @param mixed $data
* @return string|null
*/
- private function get_recipient_email($recipient_type, $data) {
+ private function get_recipient_email($recipient_type, $data)
+ {
if ($recipient_type === 'staff') {
return get_option('admin_email');
}
-
+
// Customer
- if ($data instanceof \WC_Order) {
+ if ($data instanceof WC_Order) {
return $data->get_billing_email();
}
-
- if ($data instanceof \WC_Customer) {
+
+ if ($data instanceof WC_Customer) {
return $data->get_email();
}
-
+
return null;
}
-
+
/**
* Get variables for template
*
@@ -136,7 +144,8 @@ class EmailRenderer {
* @param array $extra_data
* @return array
*/
- private function get_variables($event_id, $data, $extra_data = []) {
+ private function get_variables($event_id, $data, $extra_data = [])
+ {
$variables = [
'site_name' => get_bloginfo('name'),
'site_title' => get_bloginfo('name'),
@@ -147,12 +156,12 @@ class EmailRenderer {
'support_email' => get_option('admin_email'),
'current_year' => date('Y'),
];
-
+
// Order variables
- if ($data instanceof \WC_Order) {
+ if ($data instanceof WC_Order) {
// Calculate estimated delivery (3-5 business days from now)
$estimated_delivery = date('F j', strtotime('+3 days')) . '-' . date('j', strtotime('+5 days'));
-
+
// Completion date (for completed orders)
$completion_date = '';
if ($data->get_date_completed()) {
@@ -160,13 +169,13 @@ class EmailRenderer {
} else {
$completion_date = date('F j, Y'); // Fallback to today
}
-
+
// Payment date
$payment_date = '';
if ($data->get_date_paid()) {
$payment_date = $data->get_date_paid()->date('F j, Y');
}
-
+
$variables = array_merge($variables, [
'order_number' => $data->get_order_number(),
'order_id' => $data->get_id(),
@@ -202,7 +211,7 @@ class EmailRenderer {
'tracking_url' => $data->get_meta('_tracking_url') ?: '#',
'shipping_carrier' => $data->get_meta('_shipping_carrier') ?: 'Standard Shipping',
]);
-
+
// Order items table
$items_html = '';
$items_html .= '
';
-
+
// Both naming conventions for compatibility
$variables['order_items'] = $items_html;
$variables['order_items_table'] = $items_html;
}
-
+
// Product variables
- if ($data instanceof \WC_Product) {
+ if ($data instanceof WC_Product) {
$variables = array_merge($variables, [
'product_id' => $data->get_id(),
'product_name' => $data->get_name(),
@@ -248,27 +257,27 @@ class EmailRenderer {
'stock_status' => $data->get_stock_status(),
]);
}
-
+
// Customer variables
- if ($data instanceof \WC_Customer) {
+ if ($data instanceof WC_Customer) {
// Get temp password from user meta (stored during auto-registration)
$user_temp_password = get_user_meta($data->get_id(), '_woonoow_temp_password', true);
-
+
// Generate login URL (pointing to SPA login instead of wp-login)
$appearance_settings = get_option('woonoow_appearance_settings', []);
$spa_page_id = $appearance_settings['general']['spa_page'] ?? 0;
$use_browser_router = $appearance_settings['general']['use_browser_router'] ?? true;
-
+
if ($spa_page_id) {
$spa_url = get_permalink($spa_page_id);
// Use path format for BrowserRouter, hash format for HashRouter
- $login_url = $use_browser_router
+ $login_url = $use_browser_router
? trailingslashit($spa_url) . 'login'
: $spa_url . '#/login';
} else {
$login_url = wp_login_url();
}
-
+
$variables = array_merge($variables, [
'customer_id' => $data->get_id(),
'customer_name' => $data->get_display_name(),
@@ -282,31 +291,32 @@ class EmailRenderer {
'shop_url' => get_permalink(wc_get_page_id('shop')),
]);
}
-
+
// Merge extra data
$variables = array_merge($variables, $extra_data);
-
+
return apply_filters('woonoow_email_variables', $variables, $event_id, $data);
}
-
+
/**
* Parse [card] tags and convert to HTML
*
* @param string $content
* @return string
*/
- private function parse_cards($content) {
+ private function parse_cards($content)
+ {
// Use a single unified regex to match BOTH syntaxes in document order
// This ensures cards are rendered in the order they appear
$combined_pattern = '/\[card(?::(\w+)|([^\]]*)?)\](.*?)\[\/card\]/s';
-
+
preg_match_all($combined_pattern, $content, $matches, PREG_SET_ORDER | PREG_OFFSET_CAPTURE);
-
+
if (empty($matches)) {
// No cards found, wrap entire content in a single card
return $this->render_card($content, []);
}
-
+
$html = '';
foreach ($matches as $match) {
// Determine which syntax was matched
@@ -314,7 +324,7 @@ class EmailRenderer {
$new_syntax_type = !empty($match[1][0]) ? $match[1][0] : null; // [card:type] format
$old_syntax_attrs = $match[2][0] ?? ''; // [card type="..."] format
$card_content = $match[3][0];
-
+
if ($new_syntax_type) {
// NEW syntax [card:type]
$attributes = ['type' => $new_syntax_type];
@@ -322,42 +332,43 @@ class EmailRenderer {
// OLD syntax [card type="..."] or [card]
$attributes = $this->parse_card_attributes($old_syntax_attrs);
}
-
+
$html .= $this->render_card($card_content, $attributes);
$html .= $this->render_card_spacing();
}
-
+
// Remove last spacing
$html = preg_replace('/]*class="card-spacing"[^>]*>.*?<\/table>\s*$/s', '', $html);
-
+
return $html;
}
-
+
/**
* Parse card attributes from [card ...] tag
*
* @param string $attr_string
* @return array
*/
- private function parse_card_attributes($attr_string) {
+ private function parse_card_attributes($attr_string)
+ {
$attributes = [
'type' => 'default',
'bg' => null,
];
-
+
// Parse type="highlight"
if (preg_match('/type=["\']([^"\']+)["\']/', $attr_string, $match)) {
$attributes['type'] = $match[1];
}
-
+
// Parse bg="url"
if (preg_match('/bg=["\']([^"\']+)["\']/', $attr_string, $match)) {
$attributes['bg'] = $match[1];
}
-
+
return $attributes;
}
-
+
/**
* Render a single card
*
@@ -365,13 +376,14 @@ class EmailRenderer {
* @param array $attributes
* @return string
*/
- private function render_card($content, $attributes) {
+ private function render_card($content, $attributes)
+ {
$type = $attributes['type'] ?? 'default';
$bg = $attributes['bg'] ?? null;
-
+
// Parse markdown in content
$content = MarkdownParser::parse($content);
-
+
// Get email customization settings for colors
// Use unified colors from Appearance > General > Colors
$appearance = get_option('woonoow_appearance_settings', []);
@@ -382,10 +394,10 @@ class EmailRenderer {
$hero_gradient_start = $colors['gradientStart'] ?? '#667eea';
$hero_gradient_end = $colors['gradientEnd'] ?? '#764ba2';
$hero_text_color = '#ffffff'; // Always white on gradient
-
+
// Parse button shortcodes with FULL INLINE STYLES for Gmail compatibility
// Helper function to generate button HTML
- $generateButtonHtml = function($url, $style, $text) use ($primary_color, $secondary_color, $button_text_color) {
+ $generateButtonHtml = function ($url, $style, $text) use ($primary_color, $secondary_color, $button_text_color) {
if ($style === 'outline') {
// Outline button - transparent background with border
$button_style = sprintf(
@@ -401,7 +413,7 @@ class EmailRenderer {
esc_attr($button_text_color)
);
}
-
+
// Use table-based button for better email client compatibility
return sprintf(
'
',
@@ -410,11 +422,11 @@ class EmailRenderer {
esc_html($text)
);
};
-
+
// NEW FORMAT: [button:style](url)Text[/button]
$content = preg_replace_callback(
'/\[button:(\w+)\]\(([^)]+)\)([^\[]+)\[\/button\]/',
- function($matches) use ($generateButtonHtml) {
+ function ($matches) use ($generateButtonHtml) {
$style = $matches[1]; // solid or outline
$url = $matches[2];
$text = trim($matches[3]);
@@ -422,11 +434,11 @@ class EmailRenderer {
},
$content
);
-
+
// OLD FORMAT: [button url="..." style="solid|outline"]Text[/button]
$content = preg_replace_callback(
'/\[button\s+url=["\']([^"\']+)["\'](?:\s+style=["\'](solid|outline)["\'])?\]([^\[]+)\[\/button\]/',
- function($matches) use ($generateButtonHtml) {
+ function ($matches) use ($generateButtonHtml) {
$url = $matches[1];
$style = $matches[2] ?? 'solid';
$text = trim($matches[3]);
@@ -434,15 +446,15 @@ class EmailRenderer {
},
$content
);
-
+
$class = 'card';
$style = 'width: 100%; background-color: #ffffff; border-radius: 8px;';
$content_style = 'padding: 32px 40px;';
-
+
// Add type class and styling
if ($type !== 'default') {
$class .= ' card-' . esc_attr($type);
-
+
// Apply gradient and text color for hero cards
if ($type === 'hero') {
$style .= sprintf(
@@ -451,7 +463,7 @@ class EmailRenderer {
esc_attr($hero_gradient_end)
);
$content_style .= sprintf(' color: %s;', esc_attr($hero_text_color));
-
+
// Add inline color to all headings and paragraphs for email client compatibility
$content = preg_replace(
'/<(h[1-6]|p)([^>]*)>/',
@@ -472,13 +484,13 @@ class EmailRenderer {
$style .= ' background-color: #fff8e1;';
}
}
-
+
// Add background image
if ($bg) {
$class .= ' card-bg';
$style .= ' background-image: url(' . esc_url($bg) . ');';
}
-
+
return sprintf(
'
+
+
+ );
+ }
+
+ if (error || !subscription) {
+ return (
+
+
+ );
+ }
+
+ return (
+ Failed to load subscription
+ +
+
+ );
+}
diff --git a/customer-spa/src/pages/Account/Subscriptions.tsx b/customer-spa/src/pages/Account/Subscriptions.tsx
new file mode 100644
index 0000000..da46a0e
--- /dev/null
+++ b/customer-spa/src/pages/Account/Subscriptions.tsx
@@ -0,0 +1,244 @@
+import React, { useState } from 'react';
+import { useQuery, useMutation, useQueryClient } from '@tanstack/react-query';
+import { Link } from 'react-router-dom';
+import { api } from '@/lib/api/client';
+import { Button } from '@/components/ui/button';
+import {
+ AlertDialog,
+ AlertDialogAction,
+ AlertDialogCancel,
+ AlertDialogContent,
+ AlertDialogDescription,
+ AlertDialogFooter,
+ AlertDialogHeader,
+ AlertDialogTitle,
+ AlertDialogTrigger,
+} from '@/components/ui/alert-dialog';
+import { Repeat, ChevronRight, Pause, Play, XCircle, Calendar, Package } from 'lucide-react';
+import { toast } from 'sonner';
+import SEOHead from '@/components/SEOHead';
+import { formatPrice } from '@/lib/currency';
+
+interface Subscription {
+ id: number;
+ product_id: number;
+ product_name: string;
+ product_image: string;
+ status: 'pending' | 'active' | 'on-hold' | 'cancelled' | 'expired' | 'pending-cancel';
+ billing_schedule: string;
+ recurring_amount: string;
+ next_payment_date: string | null;
+ start_date: string;
+ end_date: string | null;
+ can_pause: boolean;
+ can_resume: boolean;
+ can_cancel: boolean;
+}
+
+const statusStyles: Record
+
+
+ {/* Product Info Card */}
+
+
+
+
+
+ {statusLabels[subscription.status] || subscription.status}
+
+
+
+ + Started {new Date(subscription.start_date).toLocaleDateString()} +
+
+
+
+ {/* Billing Details */}
+
+ {subscription.product_image ? (
+
+ ) : (
+
+
+
+ )}
+
+
+ {subscription.product_name}
+{subscription.billing_schedule}
++ {formatPrice(subscription.recurring_amount)} + + /{subscription.billing_period} + +
+
+
+
+ {/* Actions */}
+ {(subscription.can_pause || subscription.can_resume || subscription.can_cancel) && (
+ Billing Details
+
+
+
+
+ {subscription.next_payment_date && (
+ Start Date
+{new Date(subscription.start_date).toLocaleDateString()}
+
+
+ )}
+ {subscription.trial_end_date && new Date(subscription.trial_end_date) > new Date() && (
+ Next Payment
+
+
+
+ )}
+ {subscription.end_date && (
+ Trial Ends
++ {new Date(subscription.trial_end_date).toLocaleDateString()} +
+
+
+ )}
+ End Date
+{new Date(subscription.end_date).toLocaleDateString()}
+
+
+ Payment Method
+
+
+
+ Times Paused
+{subscription.pause_count}
+
+
+ )}
+
+ {/* Related Orders */}
+ {subscription.orders && subscription.orders.length > 0 && (
+ Manage Subscription
+
+ {subscription.can_pause && (
+
+ )}
+ {subscription.can_resume && (
+
+ )}
+ {/* Early Renewal Button */}
+ {subscription.status === 'active' && (
+
+ )}
+
+ {/* Pay Pending Order Button */}
+ {pendingRenewalOrder && (
+
+ )}
+
+ {subscription.can_cancel && (
+
+
+
+
+
+
+ Cancel Subscription
+
+ Are you sure you want to cancel this subscription?
+ You will lose access at the end of your current billing period.
+
+
+
+ Keep Subscription
+ handleAction('cancel')}
+ className="bg-red-500 hover:bg-red-600"
+ >
+ Yes, Cancel
+
+
+
+
+ )}
+
+
+
+
+
+ )}
+
+
+
+ {subscription.orders.map((order) => (
+
+
+
+ Order #{order.order_id}
+
+ {orderTypeLabels[order.order_type] || order.order_type}
+
+
+
+ {new Date(order.created_at).toLocaleDateString()}
+
+
+ ))}
+
+
+
+ );
+ }
+
+ return (
+
+
+ );
+}
diff --git a/customer-spa/src/pages/Account/components/AccountLayout.tsx b/customer-spa/src/pages/Account/components/AccountLayout.tsx
index 64c32da..a9ce102 100644
--- a/customer-spa/src/pages/Account/components/AccountLayout.tsx
+++ b/customer-spa/src/pages/Account/components/AccountLayout.tsx
@@ -1,6 +1,6 @@
import React, { ReactNode, useState, useEffect } from 'react';
import { Link, useLocation } from 'react-router-dom';
-import { LayoutDashboard, ShoppingBag, Download, MapPin, Heart, User, LogOut, Key } from 'lucide-react';
+import { LayoutDashboard, ShoppingBag, Download, MapPin, Heart, User, LogOut, Key, Repeat } from 'lucide-react';
import { useModules } from '@/hooks/useModules';
import { api } from '@/lib/api/client';
import {
@@ -50,17 +50,19 @@ export function AccountLayout({ children }: AccountLayoutProps) {
const allMenuItems = [
{ id: 'dashboard', label: 'Dashboard', path: '/my-account', icon: LayoutDashboard },
{ id: 'orders', label: 'Orders', path: '/my-account/orders', icon: ShoppingBag },
+ { id: 'subscriptions', label: 'Subscriptions', path: '/my-account/subscriptions', icon: Repeat },
+ { id: 'licenses', label: 'Licenses', path: '/my-account/licenses', icon: Key },
{ id: 'downloads', label: 'Downloads', path: '/my-account/downloads', icon: Download },
{ id: 'addresses', label: 'Addresses', path: '/my-account/addresses', icon: MapPin },
- { id: 'wishlist', label: 'Wishlist', path: '/my-account/wishlist', icon: Heart },
- { id: 'licenses', label: 'Licenses', path: '/my-account/licenses', icon: Key },
{ id: 'account-details', label: 'Account Details', path: '/my-account/account-details', icon: User },
+ { id: 'wishlist', label: 'Wishlist', path: '/my-account/wishlist', icon: Heart },
];
// Filter out wishlist if module disabled or settings disabled, licenses if licensing disabled
const menuItems = allMenuItems.filter(item => {
if (item.id === 'wishlist') return isEnabled('wishlist') && wishlistEnabled;
if (item.id === 'licenses') return isEnabled('licensing');
+ if (item.id === 'subscriptions') return isEnabled('subscription');
return true;
});
diff --git a/customer-spa/src/pages/Account/index.tsx b/customer-spa/src/pages/Account/index.tsx
index 306f67d..5073b83 100644
--- a/customer-spa/src/pages/Account/index.tsx
+++ b/customer-spa/src/pages/Account/index.tsx
@@ -10,6 +10,8 @@ import Addresses from './Addresses';
import Wishlist from './Wishlist';
import AccountDetails from './AccountDetails';
import Licenses from './Licenses';
+import Subscriptions from './Subscriptions';
+import SubscriptionDetail from './SubscriptionDetail';
export default function Account() {
const user = (window as any).woonoowCustomer?.user;
@@ -32,6 +34,8 @@ export default function Account() {
+
+
+
+
+ {subscriptions.length === 0 ? (
+
+
+ + Manage your recurring subscriptions +
+
+
+ ) : (
+ You don't have any subscriptions yet.
++ Purchase a subscription product to get started. +
+
+ {subscriptions.map((sub) => (
+
+ )}
+
+
+ ))}
+
+
+
+ {/* Product Image */}
+ {sub.product_image ? (
+ 
+ ) : (
+
+
+ {/* Actions */}
+
+
+ )}
+
+ {/* Subscription Info */}
+
+
+
+
+
+
+
+
+ {statusLabels[sub.status] || sub.status}
+
+ {sub.product_name}
+{sub.billing_schedule}
+
+
+
+ Amount:
+
+ {formatPrice(sub.recurring_amount)}
+
+
+ {sub.next_payment_date && (
+
+
+ )}
+
+
+
+ {sub.can_pause && (
+
+ )}
+ {sub.can_resume && (
+
+ )}
+ {sub.can_cancel && (
+
+
+
+
+
+
+ Cancel Subscription
+
+ Are you sure you want to cancel this subscription?
+ You will lose access at the end of your current billing period.
+
+
+
+ Keep Subscription
+ handleAction(sub.id, 'cancel')}
+ className="bg-red-500 hover:bg-red-600"
+ >
+ Yes, Cancel
+
+
+
+
+ )}
+
+
+
+ View Details
+ Loading order details...
;
+ if (!order) return Order not found
;
+
+ const isRenewal = order.created_via === 'subscription_renewal';
+
+ return (
+
+
+ );
+};
+
+export default OrderPay;
diff --git a/includes/Api/CheckoutController.php b/includes/Api/CheckoutController.php
index 5e331d0..143c740 100644
--- a/includes/Api/CheckoutController.php
+++ b/includes/Api/CheckoutController.php
@@ -1,4 +1,5 @@
'POST',
- 'callback' => [ new self(), 'quote' ],
- 'permission_callback' => [ \WooNooW\Api\Permissions::class, 'anon_or_wp_nonce' ], // consider nonce check later
+ 'callback' => [new self(), 'quote'],
+ 'permission_callback' => [\WooNooW\Api\Permissions::class, 'anon_or_wp_nonce'], // consider nonce check later
]);
register_rest_route($namespace, '/checkout/submit', [
'methods' => 'POST',
- 'callback' => [ new self(), 'submit' ],
- 'permission_callback' => [ \WooNooW\Api\Permissions::class, 'anon_or_wp_nonce' ], // consider capability/nonce
+ 'callback' => [new self(), 'submit'],
+ 'permission_callback' => [\WooNooW\Api\Permissions::class, 'anon_or_wp_nonce'], // consider capability/nonce
]);
register_rest_route($namespace, '/checkout/fields', [
'methods' => 'POST',
- 'callback' => [ new self(), 'get_fields' ],
- 'permission_callback' => [ \WooNooW\Api\Permissions::class, 'anon_or_wp_nonce' ],
+ 'callback' => [new self(), 'get_fields'],
+ 'permission_callback' => [\WooNooW\Api\Permissions::class, 'anon_or_wp_nonce'],
]);
// Public countries endpoint for customer checkout form
register_rest_route($namespace, '/countries', [
'methods' => 'GET',
- 'callback' => [ new self(), 'get_countries' ],
+ 'callback' => [new self(), 'get_countries'],
'permission_callback' => '__return_true', // Public - needed for checkout
]);
// Public order view endpoint for thank you page
register_rest_route($namespace, '/checkout/order/(?PComplete Payment
+ + {order.subscription && ( +
+
+ )}
+
+
+
+
+
+
+
+
+ + This is a payment for your subscription renewal. + Completing this payment will extend your subscription period. +
+
+
+
+ Order Summary #{order.number}
+
+ {order.items.map((item) => (
+
+
+
+ ))}
+
+
+ {item.image ? (
+ 
+ ) : (
+
+
+ No img
+
+ )}
+
+
+ {item.name}
+ Qty: {item.qty}
+
+ {formatPrice(item.total, order.currency)}
+
+
+
+
+ Subtotal
+ {formatPrice(order.total, order.currency)}
+
+
+ Total to Pay
+ {formatPrice(order.total, order.currency)}
+
+
+
+ Select Payment Method
+ + {order.available_gateways.length === 0 ? ( +
+ No payment methods are available for this order. Please contact support.
+
+ ) : (
+
+ {order.available_gateways.map((gateway) => (
+
+ ))}
+
+ )}
+
+
+ | Qty | '; $items_html .= 'Price | '; $items_html .= '
|---|---|
| %s |
%s
%s', nl2br(esc_html($footer_text)), $social_html ); - + // Replace placeholders $html = str_replace('{{email_subject}}', esc_html($subject), $html); $html = str_replace('{{email_body_bg}}', esc_attr($body_bg), $html); @@ -633,15 +649,15 @@ class EmailRenderer { $html = str_replace('{{store_name}}', esc_html($variables['store_name']), $html); $html = str_replace('{{store_url}}', esc_url($variables['store_url']), $html); $html = str_replace('{{current_year}}', date('Y'), $html); - + // Replace all other variables foreach ($variables as $key => $value) { $html = str_replace('{{' . $key . '}}', $value, $html); } - + return $html; } - + /** * Get social icon URL * @@ -649,7 +665,8 @@ class EmailRenderer { * @param string $color 'white' or 'black' * @return string */ - private function get_social_icon_url($platform, $color = 'white') { + private function get_social_icon_url($platform, $color = 'white') + { // Use plugin URL constant if available, otherwise calculate from file path if (defined('WOONOOW_URL')) { $plugin_url = WOONOOW_URL; diff --git a/includes/Core/Notifications/TemplateProvider.bak.php b/includes/Core/Notifications/TemplateProvider.bak.php new file mode 100644 index 0000000..a5339e4 --- /dev/null +++ b/includes/Core/Notifications/TemplateProvider.bak.php @@ -0,0 +1,375 @@ + $event_id, + 'channel_id' => $channel_id, + 'recipient_type' => $recipient_type, + 'subject' => $template['subject'] ?? '', + 'body' => $template['body'] ?? '', + 'variables' => $template['variables'] ?? [], + 'updated_at' => current_time('mysql'), + ]; + + return update_option(self::OPTION_KEY, $templates); + } + + /** + * Delete template (revert to default) + * + * @param string $event_id Event ID + * @param string $channel_id Channel ID + * @param string $recipient_type Recipient type ('customer' or 'staff') + * @return bool + */ + public static function delete_template($event_id, $channel_id, $recipient_type = 'customer') { + $templates = get_option(self::OPTION_KEY, []); + + $key = "{$recipient_type}_{$event_id}_{$channel_id}"; + + if (isset($templates[$key])) { + unset($templates[$key]); + return update_option(self::OPTION_KEY, $templates); + } + + return false; + } + + /** + * Get WooCommerce email template content + * + * @param string $email_id WooCommerce email ID + * @return array|null + */ + private static function get_wc_email_template($email_id) { + if (!function_exists('WC')) { + return null; + } + + $mailer = \WC()->mailer(); + $emails = $mailer->get_emails(); + + if (isset($emails[$email_id])) { + $email = $emails[$email_id]; + return [ + 'subject' => $email->get_subject(), + 'heading' => $email->get_heading(), + 'enabled' => $email->is_enabled(), + ]; + } + + return null; + } + + /** + * Get default templates + * + * @return array + */ + public static function get_default_templates() { + $templates = []; + + // Get all events from EventRegistry (single source of truth) + $all_events = EventRegistry::get_all_events(); + + // Get email templates from DefaultTemplates + $allEmailTemplates = EmailDefaultTemplates::get_all_templates(); + + foreach ($all_events as $event) { + $event_id = $event['id']; + $recipient_type = $event['recipient_type']; + // Get template body from the new clean markdown source + $body = $allEmailTemplates[$recipient_type][$event_id] ?? ''; + $subject = EmailDefaultTemplates::get_default_subject($recipient_type, $event_id); + + // If template doesn't exist, create a simple fallback + if (empty($body)) { + $body = "[card]\n\n## Notification\n\nYou have a new notification about {$event_id}.\n\n[/card]"; + $subject = __('Notification from {store_name}', 'woonoow'); + } + + $templates["{$recipient_type}_{$event_id}_email"] = [ + 'event_id' => $event_id, + 'channel_id' => 'email', + 'recipient_type' => $recipient_type, + 'subject' => $subject, + 'body' => $body, + 'variables' => self::get_variables_for_event($event_id), + ]; + } + + // Add push notification templates + $templates['staff_order_placed_push'] = [ + 'event_id' => 'order_placed', + 'channel_id' => 'push', + 'recipient_type' => 'staff', + 'subject' => __('New Order #{order_number}', 'woonoow'), + 'body' => __('New order from {customer_name} - {order_total}', 'woonoow'), + 'variables' => self::get_order_variables(), + ]; + $templates['customer_order_processing_push'] = [ + 'event_id' => 'order_processing', + 'channel_id' => 'push', + 'recipient_type' => 'customer', + 'subject' => __('Order Processing', 'woonoow'), + 'body' => __('Your order #{order_number} is being processed', 'woonoow'), + 'variables' => self::get_order_variables(), + ]; + $templates['customer_order_completed_push'] = [ + 'event_id' => 'order_completed', + 'channel_id' => 'push', + 'recipient_type' => 'customer', + 'subject' => __('Order Completed', 'woonoow'), + 'body' => __('Your order #{order_number} has been completed!', 'woonoow'), + 'variables' => self::get_order_variables(), + ]; + $templates['staff_order_cancelled_push'] = [ + 'event_id' => 'order_cancelled', + 'channel_id' => 'push', + 'recipient_type' => 'staff', + 'subject' => __('Order Cancelled', 'woonoow'), + 'body' => __('Order #{order_number} has been cancelled', 'woonoow'), + 'variables' => self::get_order_variables(), + ]; + $templates['customer_order_refunded_push'] = [ + 'event_id' => 'order_refunded', + 'channel_id' => 'push', + 'recipient_type' => 'customer', + 'subject' => __('Order Refunded', 'woonoow'), + 'body' => __('Your order #{order_number} has been refunded', 'woonoow'), + 'variables' => self::get_order_variables(), + ]; + $templates['staff_low_stock_push'] = [ + 'event_id' => 'low_stock', + 'channel_id' => 'push', + 'recipient_type' => 'staff', + 'subject' => __('Low Stock Alert', 'woonoow'), + 'body' => __('{product_name} is running low on stock', 'woonoow'), + 'variables' => self::get_product_variables(), + ]; + $templates['staff_out_of_stock_push'] = [ + 'event_id' => 'out_of_stock', + 'channel_id' => 'push', + 'recipient_type' => 'staff', + 'subject' => __('Out of Stock Alert', 'woonoow'), + 'body' => __('{product_name} is now out of stock', 'woonoow'), + 'variables' => self::get_product_variables(), + ]; + $templates['customer_new_customer_push'] = [ + 'event_id' => 'new_customer', + 'channel_id' => 'push', + 'recipient_type' => 'customer', + 'subject' => __('Welcome!', 'woonoow'), + 'body' => __('Welcome to {store_name}, {customer_name}!', 'woonoow'), + 'variables' => self::get_customer_variables(), + ]; + $templates['customer_customer_note_push'] = [ + 'event_id' => 'customer_note', + 'channel_id' => 'push', + 'recipient_type' => 'customer', + 'subject' => __('Order Note Added', 'woonoow'), + 'body' => __('A note has been added to order #{order_number}', 'woonoow'), + 'variables' => self::get_order_variables(), + ]; + + return $templates; + } + + /** + * Get variables for a specific event + * + * @param string $event_id Event ID + * @return array + */ + private static function get_variables_for_event($event_id) { + // Product events + if (in_array($event_id, ['low_stock', 'out_of_stock'])) { + return self::get_product_variables(); + } + + // Customer events (but not order-related) + if ($event_id === 'new_customer') { + return self::get_customer_variables(); + } + + // Subscription events + if (strpos($event_id, 'subscription_') === 0) { + return self::get_subscription_variables(); + } + + // All other events are order-related + return self::get_order_variables(); + } + + /** + * Get available order variables + * + * @return array + */ + public static function get_order_variables() { + return [ + 'order_number' => __('Order Number', 'woonoow'), + 'order_total' => __('Order Total', 'woonoow'), + 'order_status' => __('Order Status', 'woonoow'), + 'order_date' => __('Order Date', 'woonoow'), + 'order_url' => __('Order URL', 'woonoow'), + 'order_items_list' => __('Order Items (formatted list)', 'woonoow'), + 'order_items_table' => __('Order Items (formatted table)', 'woonoow'), + 'payment_method' => __('Payment Method', 'woonoow'), + 'payment_url' => __('Payment URL (for pending payments)', 'woonoow'), + 'shipping_method' => __('Shipping Method', 'woonoow'), + 'tracking_number' => __('Tracking Number', 'woonoow'), + 'refund_amount' => __('Refund Amount', 'woonoow'), + 'customer_name' => __('Customer Name', 'woonoow'), + 'customer_email' => __('Customer Email', 'woonoow'), + 'customer_phone' => __('Customer Phone', 'woonoow'), + 'billing_address' => __('Billing Address', 'woonoow'), + 'shipping_address' => __('Shipping Address', 'woonoow'), + 'store_name' => __('Store Name', 'woonoow'), + 'store_url' => __('Store URL', 'woonoow'), + 'store_email' => __('Store Email', 'woonoow'), + ]; + } + + /** + * Get available product variables + * + * @return array + */ + public static function get_product_variables() { + return [ + 'product_name' => __('Product Name', 'woonoow'), + 'product_sku' => __('Product SKU', 'woonoow'), + 'product_url' => __('Product URL', 'woonoow'), + 'stock_quantity' => __('Stock Quantity', 'woonoow'), + 'store_name' => __('Store Name', 'woonoow'), + 'store_url' => __('Store URL', 'woonoow'), + ]; + } + + /** + * Get available customer variables + * + * @return array + */ + public static function get_customer_variables() { + return [ + 'customer_name' => __('Customer Name', 'woonoow'), + 'customer_email' => __('Customer Email', 'woonoow'), + 'customer_phone' => __('Customer Phone', 'woonoow'), + 'store_name' => __('Store Name', 'woonoow'), + 'store_url' => __('Store URL', 'woonoow'), + 'store_email' => __('Store Email', 'woonoow'), + ]; + } + + /** + * Get available subscription variables + * + * @return array + */ + public static function get_subscription_variables() { + return [ + 'subscription_id' => __('Subscription ID', 'woonoow'), + 'subscription_status' => __('Subscription Status', 'woonoow'), + 'product_name' => __('Product Name', 'woonoow'), + 'billing_period' => __('Billing Period (e.g., Monthly)', 'woonoow'), + 'recurring_amount' => __('Recurring Amount', 'woonoow'), + 'next_payment_date' => __('Next Payment Date', 'woonoow'), + 'end_date' => __('Subscription End Date', 'woonoow'), + 'cancel_reason' => __('Cancellation Reason', 'woonoow'), + 'customer_name' => __('Customer Name', 'woonoow'), + 'customer_email' => __('Customer Email', 'woonoow'), + 'store_name' => __('Store Name', 'woonoow'), + 'store_url' => __('Store URL', 'woonoow'), + 'my_account_url' => __('My Account URL', 'woonoow'), + ]; + } + + /** + * Replace variables in template + * + * @param string $content Content with variables + * @param array $data Data to replace variables + * @return string + */ + public static function replace_variables($content, $data) { + foreach ($data as $key => $value) { + $content = str_replace('{' . $key . '}', $value, $content); + } + + return $content; + } +} diff --git a/includes/Core/Notifications/TemplateProvider.php b/includes/Core/Notifications/TemplateProvider.php index 7c746e3..8b8d4e1 100644 --- a/includes/Core/Notifications/TemplateProvider.php +++ b/includes/Core/Notifications/TemplateProvider.php @@ -107,32 +107,6 @@ class TemplateProvider { return false; } - /** - * Get WooCommerce email template content - * - * @param string $email_id WooCommerce email ID - * @return array|null - */ - private static function get_wc_email_template($email_id) { - if (!function_exists('WC')) { - return null; - } - - $mailer = WC()->mailer(); - $emails = $mailer->get_emails(); - - if (isset($emails[$email_id])) { - $email = $emails[$email_id]; - return [ - 'subject' => $email->get_subject(), - 'heading' => $email->get_heading(), - 'enabled' => $email->is_enabled(), - ]; - } - - return null; - } - /** * Get default templates * @@ -264,6 +238,11 @@ class TemplateProvider { return self::get_customer_variables(); } + // Subscription events + if (strpos($event_id, 'subscription_') === 0) { + return self::get_subscription_variables(); + } + // All other events are order-related return self::get_order_variables(); } @@ -330,6 +309,29 @@ class TemplateProvider { ]; } + /** + * Get available subscription variables + * + * @return array + */ + public static function get_subscription_variables() { + return [ + 'subscription_id' => __('Subscription ID', 'woonoow'), + 'subscription_status' => __('Subscription Status', 'woonoow'), + 'product_name' => __('Product Name', 'woonoow'), + 'billing_period' => __('Billing Period (e.g., Monthly)', 'woonoow'), + 'recurring_amount' => __('Recurring Amount', 'woonoow'), + 'next_payment_date' => __('Next Payment Date', 'woonoow'), + 'end_date' => __('Subscription End Date', 'woonoow'), + 'cancel_reason' => __('Cancellation Reason', 'woonoow'), + 'customer_name' => __('Customer Name', 'woonoow'), + 'customer_email' => __('Customer Email', 'woonoow'), + 'store_name' => __('Store Name', 'woonoow'), + 'store_url' => __('Store URL', 'woonoow'), + 'my_account_url' => __('My Account URL', 'woonoow'), + ]; + } + /** * Replace variables in template * diff --git a/includes/Frontend/TemplateOverride.php b/includes/Frontend/TemplateOverride.php index ea7f3d7..cc65387 100644 --- a/includes/Frontend/TemplateOverride.php +++ b/includes/Frontend/TemplateOverride.php @@ -1,4 +1,5 @@ post_name; - + // Check if SPA page is set as WordPress frontpage $frontpage_id = (int) get_option('page_on_front'); $is_spa_frontpage = $frontpage_id && $frontpage_id === (int) $spa_page_id; - + if ($is_spa_frontpage) { // When SPA is frontpage, add root-level routes // /shop, /shop/* → SPA page @@ -115,28 +116,33 @@ class TemplateOverride 'index.php?page_id=' . $spa_page_id . '&woonoow_spa_path=shop/$matches[1]', 'top' ); - + // /product/* → SPA page add_rewrite_rule( '^product/(.*)$', 'index.php?page_id=' . $spa_page_id . '&woonoow_spa_path=product/$matches[1]', 'top' ); - + // /cart → SPA page add_rewrite_rule( '^cart/?$', 'index.php?page_id=' . $spa_page_id . '&woonoow_spa_path=cart', 'top' ); - - // /checkout → SPA page + + // /checkout, /checkout/* → SPA page add_rewrite_rule( '^checkout/?$', 'index.php?page_id=' . $spa_page_id . '&woonoow_spa_path=checkout', 'top' ); - + add_rewrite_rule( + '^checkout/(.*)$', + 'index.php?page_id=' . $spa_page_id . '&woonoow_spa_path=checkout/$matches[1]', + 'top' + ); + // /my-account, /my-account/* → SPA page add_rewrite_rule( '^my-account/?$', @@ -148,7 +154,7 @@ class TemplateOverride 'index.php?page_id=' . $spa_page_id . '&woonoow_spa_path=my-account/$matches[1]', 'top' ); - + // /login, /register, /reset-password → SPA page add_rewrite_rule( '^login/?$', @@ -165,6 +171,24 @@ class TemplateOverride 'index.php?page_id=' . $spa_page_id . '&woonoow_spa_path=reset-password', 'top' ); + + // /order-pay/* → SPA page + add_rewrite_rule( + '^order-pay/(.*)$', + 'index.php?page_id=' . $spa_page_id . '&woonoow_spa_path=order-pay/$matches[1]', + 'top' + ); + + // /order-pay/* → SPA page + add_rewrite_rule( + '^order-pay/(.*)$', + 'index.php?page_id=' . $spa_page_id . '&woonoow_spa_path=order-pay/$matches[1]', + 'top' + ); + + // /order-pay/* → SPA page (moved to checkout/pay/ in new structure) + // Removed direct order-pay rule to favor checkout subpath + } else { // Rewrite /slug to serve the SPA page (base URL) add_rewrite_rule( @@ -172,7 +196,7 @@ class TemplateOverride 'index.php?page_id=' . $spa_page_id, 'top' ); - + // Rewrite /slug/anything to serve the SPA page with path // React Router handles the path after that add_rewrite_rule( @@ -181,9 +205,9 @@ class TemplateOverride 'top' ); } - + // Register query var for the SPA path - add_filter('query_vars', function($vars) { + add_filter('query_vars', function ($vars) { $vars[] = 'woonoow_spa_path'; return $vars; }); @@ -249,32 +273,32 @@ class TemplateOverride $spa_page_id = $appearance_settings['general']['spa_page'] ?? 0; $spa_mode = $appearance_settings['general']['spa_mode'] ?? 'full'; $use_browser_router = $appearance_settings['general']['use_browser_router'] ?? true; - + // Only redirect when SPA mode is 'full' if ($spa_mode !== 'full') { return; } - + if (!$spa_page_id) { return; // No SPA page configured } - + // Skip if SPA is set as frontpage (serve_spa_for_frontpage_routes handles it) $frontpage_id = (int) get_option('page_on_front'); if ($frontpage_id && $frontpage_id === (int) $spa_page_id) { return; } - + // Already on SPA page, don't redirect global $post; if ($post && $post->ID == $spa_page_id) { return; } - + $spa_url = trailingslashit(get_permalink($spa_page_id)); - + // Helper function to build route URL based on router type - $build_route = function($path) use ($spa_url, $use_browser_router) { + $build_route = function ($path) use ($spa_url, $use_browser_router) { if ($use_browser_router) { // Path format: /store/cart return $spa_url . ltrim($path, '/'); @@ -282,13 +306,13 @@ class TemplateOverride // Hash format: /store/#/cart return rtrim($spa_url, '/') . '#/' . ltrim($path, '/'); }; - + // Check which WC page we're on and redirect if (is_shop()) { wp_redirect($build_route('shop'), 302); exit; } - + if (is_product()) { // Use get_queried_object() which returns the WP_Post, then get slug $product_post = get_queried_object(); @@ -298,29 +322,37 @@ class TemplateOverride exit; } } - + if (is_cart()) { wp_redirect($build_route('cart'), 302); exit; } - + if (is_checkout() && !is_order_received_page()) { + // Check for order-pay endpoint + if (is_wc_endpoint_url('order-pay')) { + global $wp; + $order_id = $wp->query_vars['order-pay']; + wp_redirect($build_route('order-pay/' . $order_id), 302); + exit; + } + wp_redirect($build_route('checkout'), 302); exit; } - + if (is_account_page()) { wp_redirect($build_route('my-account'), 302); exit; } - + // Redirect structural pages with WooNooW sections to SPA if (is_singular('page') && $post) { // Skip the SPA page itself and frontpage if ($post->ID == $spa_page_id || $post->ID == $frontpage_id) { return; } - + // Check if page has WooNooW structure $structure = get_post_meta($post->ID, '_wn_page_structure', true); if (!empty($structure) && !empty($structure['sections'])) { @@ -348,22 +380,22 @@ class TemplateOverride $appearance_settings = get_option('woonoow_appearance_settings', []); $spa_page_id = $appearance_settings['general']['spa_page'] ?? 0; $spa_mode = $appearance_settings['general']['spa_mode'] ?? 'full'; - + // Only run in full SPA mode if ($spa_mode !== 'full' || !$spa_page_id) { return; } - + // Check if SPA page is set as WordPress frontpage $frontpage_id = (int) get_option('page_on_front'); if (!$frontpage_id || $frontpage_id !== (int) $spa_page_id) { return; // SPA is not frontpage, let normal routing handle it } - + // Get the current request path relative to site root $request_uri = $_SERVER['REQUEST_URI'] ?? '/'; $home_path = parse_url(home_url(), PHP_URL_PATH); - + // Normalize request URI for subdirectory installs if ($home_path && $home_path !== '/') { $home_path = rtrim($home_path, '/'); @@ -375,7 +407,7 @@ class TemplateOverride $path = parse_url($request_uri, PHP_URL_PATH); $path = '/' . trim($path, '/'); - + // Define SPA routes that should be intercepted when SPA is frontpage $spa_routes = [ '/', // Frontpage itself @@ -385,37 +417,39 @@ class TemplateOverride '/my-account', // Account page '/login', // Login page '/register', // Register page + '/register', // Register page '/reset-password', // Password reset + '/order-pay', // Order pay page ]; - + // Check for exact matches or path prefixes $should_serve_spa = false; - + // Check exact matches if (in_array($path, $spa_routes)) { $should_serve_spa = true; } - + // Check path prefixes (for sub-routes) - $prefix_routes = ['/shop/', '/my-account/', '/product/']; + $prefix_routes = ['/shop/', '/my-account/', '/product/', '/checkout/']; foreach ($prefix_routes as $prefix) { if (strpos($path, $prefix) === 0) { $should_serve_spa = true; break; } } - + // Check for structural pages with WooNooW sections if (!$should_serve_spa && !empty($path) && $path !== '/') { // Try to find a page by slug matching the path $slug = trim($path, '/'); - + // Handle nested slugs (get the last part as the page slug) if (strpos($slug, '/') !== false) { $slug_parts = explode('/', $slug); $slug = end($slug_parts); } - + $page = get_page_by_path($slug); if ($page) { // Check if this page has WooNooW structure @@ -425,26 +459,26 @@ class TemplateOverride } } } - + // Not a SPA route if (!$should_serve_spa) { return; } - + // Prevent caching for dynamic SPA content nocache_headers(); - + // Load the SPA template directly and exit $spa_template = plugin_dir_path(dirname(dirname(__FILE__))) . 'templates/spa-full-page.php'; if (file_exists($spa_template)) { // Set up minimal WordPress environment for the template status_header(200); - + // Define constant to tell Assets to load unconditionally if (!defined('WOONOOW_SERVE_SPA')) { define('WOONOOW_SERVE_SPA', true); } - + // Include the SPA template include $spa_template; exit; @@ -487,12 +521,12 @@ class TemplateOverride // Check spa_mode from appearance settings FIRST $appearance_settings = get_option('woonoow_appearance_settings', []); $spa_mode = $appearance_settings['general']['spa_mode'] ?? 'full'; - + // If SPA is disabled, return original template immediately if ($spa_mode === 'disabled') { return $template; } - + // Check if current page is a designated SPA page if (self::is_spa_page()) { $spa_template = plugin_dir_path(dirname(dirname(__FILE__))) . 'templates/spa-full-page.php'; @@ -511,7 +545,7 @@ class TemplateOverride } } } - + // For spa_mode = 'checkout_only' if ($spa_mode === 'checkout_only') { if (is_checkout() || is_order_received_page() || is_account_page() || is_cart()) { @@ -634,7 +668,7 @@ class TemplateOverride private static function is_spa_page() { global $post; - + // Get SPA settings from appearance $appearance_settings = get_option('woonoow_appearance_settings', []); $spa_page_id = $appearance_settings['general']['spa_page'] ?? 0; @@ -716,7 +750,7 @@ class TemplateOverride return $template; } - + /** * Detect if current request is from a bot/crawler * Used to serve SSR content for SEO instead of SPA redirect @@ -730,10 +764,10 @@ class TemplateOverride if (empty($user_agent)) { return false; } - + // Convert to lowercase for case-insensitive matching $user_agent = strtolower($user_agent); - + // Known bot patterns $bot_patterns = [ // Search engine crawlers @@ -745,13 +779,13 @@ class TemplateOverride 'yandexbot', 'sogou', 'exabot', - + // Generic patterns 'crawler', 'spider', 'robot', 'scraper', - + // Social media bots (for link previews) 'facebookexternalhit', 'twitterbot', @@ -760,7 +794,7 @@ class TemplateOverride 'slackbot', 'telegrambot', 'discordbot', - + // Other known bots 'applebot', 'semrushbot', @@ -769,22 +803,22 @@ class TemplateOverride 'dotbot', 'petalbot', 'bytespider', - + // Prerender services 'prerender', 'headlesschrome', ]; - + // Check if User-Agent contains any bot pattern foreach ($bot_patterns as $pattern) { if (strpos($user_agent, $pattern) !== false) { return true; } } - + return false; } - + /** * Serve SSR content for bots * Renders page structure as static HTML for search engine indexing @@ -798,17 +832,17 @@ class TemplateOverride // Generate cache key $cache_id = $post_obj ? $post_obj->ID : $page_id; $cache_key = "wn_ssr_{$type}_{$cache_id}"; - + // Check cache TTL (default 1 hour, filterable) $cache_ttl = apply_filters('woonoow_ssr_cache_ttl', HOUR_IN_SECONDS); - + // Try to get cached content $cached = get_transient($cache_key); if ($cached !== false) { echo $cached; exit; } - + // Get page structure if ($type === 'page') { $structure = get_post_meta($page_id, '_wn_page_structure', true); @@ -816,103 +850,155 @@ class TemplateOverride // CPT template - type is the post_type like 'post', 'portfolio', etc. $structure = get_option("wn_template_{$type}", null); } - + if (empty($structure) || empty($structure['sections'])) { return false; // No structure, let normal WP handle it } - + // Render using PageSSR $post_data = null; if ($post_obj && $type !== 'page') { $placeholder_renderer = new PlaceholderRenderer(); $post_data = $placeholder_renderer->build_post_data($post_obj); } - + $ssr = new PageSSR(); $html = $ssr->render($structure['sections'], $post_data); - + if (empty($html)) { return false; } - + // Get page title $title = $type === 'page' ? get_the_title($page_id) : ''; if ($post_obj) { $title = get_the_title($post_obj); } - + // SEO data $seo_title = $title . ' - ' . get_bloginfo('name'); $seo_description = ''; - + // Try to get Yoast/Rank Math SEO data if ($type === 'page') { - $seo_title = get_post_meta($page_id, '_yoast_wpseo_title', true) ?: - get_post_meta($page_id, 'rank_math_title', true) ?: $seo_title; - $seo_description = get_post_meta($page_id, '_yoast_wpseo_metadesc', true) ?: - get_post_meta($page_id, 'rank_math_description', true) ?: ''; + $seo_title = get_post_meta($page_id, '_yoast_wpseo_title', true) ?: + get_post_meta($page_id, 'rank_math_title', true) ?: $seo_title; + $seo_description = get_post_meta($page_id, '_yoast_wpseo_metadesc', true) ?: + get_post_meta($page_id, 'rank_math_description', true) ?: ''; } elseif ($post_obj) { - $seo_title = get_post_meta($post_obj->ID, '_yoast_wpseo_title', true) ?: - get_post_meta($post_obj->ID, 'rank_math_title', true) ?: $seo_title; - $seo_description = get_post_meta($post_obj->ID, '_yoast_wpseo_metadesc', true) ?: - get_post_meta($post_obj->ID, 'rank_math_description', true) ?: - wp_trim_words(wp_strip_all_tags($post_obj->post_content), 30); + $seo_title = get_post_meta($post_obj->ID, '_yoast_wpseo_title', true) ?: + get_post_meta($post_obj->ID, 'rank_math_title', true) ?: $seo_title; + $seo_description = get_post_meta($post_obj->ID, '_yoast_wpseo_metadesc', true) ?: + get_post_meta($post_obj->ID, 'rank_math_description', true) ?: + wp_trim_words(wp_strip_all_tags($post_obj->post_content), 30); } - + // Output SSR HTML - start output buffering for caching ob_start(); - ?> - -> - - - -
-
-
-
-
-
-
+
+ >
+
+
+
+
+
+
+
+
+
+
+
+ID, $post_type, $post_obj);
@@ -946,4 +1032,3 @@ class TemplateOverride
}
}
}
-
diff --git a/includes/Modules/Licensing/LicenseManager.php b/includes/Modules/Licensing/LicenseManager.php
index 30e2e66..30cf5bb 100644
--- a/includes/Modules/Licensing/LicenseManager.php
+++ b/includes/Modules/Licensing/LicenseManager.php
@@ -323,6 +323,12 @@ class LicenseManager {
}
}
+ // Check subscription status if linked
+ $subscription_status = self::get_order_subscription_status($license['order_id']);
+ if ($subscription_status !== null && !in_array($subscription_status, ['active', 'pending-cancel'])) {
+ return new \WP_Error('subscription_inactive', __('Subscription is not active', 'woonoow'));
+ }
+
// Check activation limit
if ($license['activation_limit'] > 0 && $license['activation_count'] >= $license['activation_limit']) {
return new \WP_Error('activation_limit_reached', __('Activation limit reached', 'woonoow'));
@@ -433,8 +439,12 @@ class LicenseManager {
$is_expired = $license['expires_at'] && strtotime($license['expires_at']) < time();
+ // Check subscription status if linked
+ $subscription_status = self::get_order_subscription_status($license['order_id']);
+ $is_subscription_valid = $subscription_status === null || in_array($subscription_status, ['active', 'pending-cancel']);
+
return [
- 'valid' => $license['status'] === 'active' && !$is_expired,
+ 'valid' => $license['status'] === 'active' && !$is_expired && $is_subscription_valid,
'license_key' => $license['license_key'],
'status' => $license['status'],
'activation_limit' => (int) $license['activation_limit'],
@@ -444,9 +454,52 @@ class LicenseManager {
: -1,
'expires_at' => $license['expires_at'],
'is_expired' => $is_expired,
+ 'subscription_status' => $subscription_status,
+ 'subscription_active' => $is_subscription_valid,
];
}
+ /**
+ * Check if an order has a linked subscription and return its status
+ *
+ * @param int $order_id
+ * @return string|null Subscription status or null if no subscription
+ */
+ public static function get_order_subscription_status($order_id) {
+ // Check if subscription module is enabled
+ if (!ModuleRegistry::is_enabled('subscription')) {
+ return null;
+ }
+
+ global $wpdb;
+ $table = $wpdb->prefix . 'woonoow_subscription_orders';
+
+ // Check if table exists
+ $table_exists = $wpdb->get_var("SHOW TABLES LIKE '$table'");
+ if (!$table_exists) {
+ return null;
+ }
+
+ // Find subscription linked to this order
+ $subscription_id = $wpdb->get_var($wpdb->prepare(
+ "SELECT subscription_id FROM $table WHERE order_id = %d LIMIT 1",
+ $order_id
+ ));
+
+ if (!$subscription_id) {
+ return null;
+ }
+
+ // Get subscription status
+ $subscriptions_table = $wpdb->prefix . 'woonoow_subscriptions';
+ $status = $wpdb->get_var($wpdb->prepare(
+ "SELECT status FROM $subscriptions_table WHERE id = %d",
+ $subscription_id
+ ));
+
+ return $status;
+ }
+
/**
* Revoke license
*/
diff --git a/includes/Modules/Subscription/SubscriptionManager.php b/includes/Modules/Subscription/SubscriptionManager.php
new file mode 100644
index 0000000..f33b03d
--- /dev/null
+++ b/includes/Modules/Subscription/SubscriptionManager.php
@@ -0,0 +1,893 @@
+prefix . 'woonoow_subscriptions';
+ self::$table_subscription_orders = $wpdb->prefix . 'woonoow_subscription_orders';
+ }
+
+ /**
+ * Create database tables
+ */
+ public static function create_tables()
+ {
+ global $wpdb;
+
+ $charset_collate = $wpdb->get_charset_collate();
+ $table_subscriptions = $wpdb->prefix . 'woonoow_subscriptions';
+ $table_subscription_orders = $wpdb->prefix . 'woonoow_subscription_orders';
+
+ $sql_subscriptions = "CREATE TABLE $table_subscriptions (
+ id BIGINT UNSIGNED AUTO_INCREMENT PRIMARY KEY,
+ user_id BIGINT UNSIGNED NOT NULL,
+ order_id BIGINT UNSIGNED NOT NULL,
+ product_id BIGINT UNSIGNED NOT NULL,
+ variation_id BIGINT UNSIGNED DEFAULT NULL,
+ status ENUM('pending', 'active', 'on-hold', 'cancelled', 'expired', 'pending-cancel') DEFAULT 'pending',
+ billing_period ENUM('day', 'week', 'month', 'year') NOT NULL,
+ billing_interval INT UNSIGNED DEFAULT 1,
+ recurring_amount DECIMAL(12,4) DEFAULT 0,
+ start_date DATETIME NOT NULL,
+ trial_end_date DATETIME DEFAULT NULL,
+ next_payment_date DATETIME DEFAULT NULL,
+ end_date DATETIME DEFAULT NULL,
+ last_payment_date DATETIME DEFAULT NULL,
+ payment_method VARCHAR(100) DEFAULT NULL,
+ payment_meta LONGTEXT,
+ cancel_reason TEXT DEFAULT NULL,
+ pause_count INT UNSIGNED DEFAULT 0,
+ failed_payment_count INT UNSIGNED DEFAULT 0,
+ reminder_sent_at DATETIME DEFAULT NULL,
+ created_at DATETIME DEFAULT CURRENT_TIMESTAMP,
+ updated_at DATETIME DEFAULT CURRENT_TIMESTAMP ON UPDATE CURRENT_TIMESTAMP,
+ INDEX idx_user_id (user_id),
+ INDEX idx_order_id (order_id),
+ INDEX idx_product_id (product_id),
+ INDEX idx_status (status),
+ INDEX idx_next_payment (next_payment_date)
+ ) $charset_collate;";
+
+ $sql_orders = "CREATE TABLE $table_subscription_orders (
+ id BIGINT UNSIGNED AUTO_INCREMENT PRIMARY KEY,
+ subscription_id BIGINT UNSIGNED NOT NULL,
+ order_id BIGINT UNSIGNED NOT NULL,
+ order_type ENUM('parent', 'renewal', 'switch', 'resubscribe') DEFAULT 'renewal',
+ created_at DATETIME DEFAULT CURRENT_TIMESTAMP,
+ INDEX idx_subscription (subscription_id),
+ INDEX idx_order (order_id)
+ ) $charset_collate;";
+
+ require_once ABSPATH . 'wp-admin/includes/upgrade.php';
+ dbDelta($sql_subscriptions);
+ dbDelta($sql_orders);
+ }
+
+ /**
+ * Create subscription from order item
+ *
+ * @param \WC_Order $order
+ * @param \WC_Order_Item_Product $item
+ * @return int|false Subscription ID or false on failure
+ */
+ public static function create_from_order($order, $item)
+ {
+ global $wpdb;
+
+ $product_id = $item->get_product_id();
+ $variation_id = $item->get_variation_id();
+ $user_id = $order->get_user_id();
+
+ if (!$user_id) {
+ // Guest orders not supported for subscriptions
+ return false;
+ }
+
+ // Get subscription settings from product
+ $billing_period = get_post_meta($product_id, '_woonoow_subscription_period', true) ?: 'month';
+ $billing_interval = absint(get_post_meta($product_id, '_woonoow_subscription_interval', true)) ?: 1;
+ $trial_days = absint(get_post_meta($product_id, '_woonoow_subscription_trial_days', true));
+ $subscription_length = absint(get_post_meta($product_id, '_woonoow_subscription_length', true));
+
+ // Calculate dates
+ $now = current_time('mysql');
+ $start_date = $now;
+ $trial_end_date = null;
+
+ if ($trial_days > 0) {
+ $trial_end_date = date('Y-m-d H:i:s', strtotime($now . " + $trial_days days"));
+ $next_payment_date = $trial_end_date;
+ } else {
+ $next_payment_date = self::calculate_next_payment_date($now, $billing_period, $billing_interval);
+ }
+
+ // Calculate end date if subscription has fixed length
+ $end_date = null;
+ if ($subscription_length > 0) {
+ $end_date = self::calculate_end_date($start_date, $billing_period, $billing_interval, $subscription_length);
+ }
+
+ // Get recurring amount (product price)
+ $product = $item->get_product();
+ $recurring_amount = $product ? $product->get_price() : $item->get_total();
+
+ // Get payment method
+ $payment_method = $order->get_payment_method();
+ $payment_meta = json_encode([
+ 'method_title' => $order->get_payment_method_title(),
+ 'customer_id' => $order->get_customer_id(),
+ ]);
+
+ // Insert subscription
+ $inserted = $wpdb->insert(
+ self::$table_subscriptions,
+ [
+ 'user_id' => $user_id,
+ 'order_id' => $order->get_id(),
+ 'product_id' => $product_id,
+ 'variation_id' => $variation_id ?: null,
+ 'status' => 'active',
+ 'billing_period' => $billing_period,
+ 'billing_interval' => $billing_interval,
+ 'recurring_amount' => $recurring_amount,
+ 'start_date' => $start_date,
+ 'trial_end_date' => $trial_end_date,
+ 'next_payment_date' => $next_payment_date,
+ 'end_date' => $end_date,
+ 'last_payment_date' => $now,
+ 'payment_method' => $payment_method,
+ 'payment_meta' => $payment_meta,
+ ],
+ ['%d', '%d', '%d', '%d', '%s', '%s', '%d', '%f', '%s', '%s', '%s', '%s', '%s', '%s', '%s']
+ );
+
+ if (!$inserted) {
+ return false;
+ }
+
+ $subscription_id = $wpdb->insert_id;
+
+ // Link parent order to subscription
+ $wpdb->insert(
+ self::$table_subscription_orders,
+ [
+ 'subscription_id' => $subscription_id,
+ 'order_id' => $order->get_id(),
+ 'order_type' => 'parent',
+ ],
+ ['%d', '%d', '%s']
+ );
+
+ // Trigger action
+ do_action('woonoow/subscription/created', $subscription_id, $order, $item);
+
+ return $subscription_id;
+ }
+
+ /**
+ * Get subscription by ID
+ *
+ * @param int $subscription_id
+ * @return object|null
+ */
+ public static function get($subscription_id)
+ {
+ global $wpdb;
+
+ return $wpdb->get_row($wpdb->prepare(
+ "SELECT * FROM " . self::$table_subscriptions . " WHERE id = %d",
+ $subscription_id
+ ));
+ }
+
+ /**
+ * Get subscription by related order ID (parent or renewal)
+ *
+ * @param int $order_id
+ * @return object|null
+ */
+ public static function get_by_order_id($order_id)
+ {
+ global $wpdb;
+
+ $table_subscriptions = $wpdb->prefix . 'woonoow_subscriptions';
+ $table_subscription_orders = $wpdb->prefix . 'woonoow_subscription_orders';
+
+ // Join subscriptions table to get full subscription data
+ return $wpdb->get_row($wpdb->prepare(
+ "SELECT s.*
+ FROM $table_subscriptions s
+ JOIN $table_subscription_orders so ON s.id = so.subscription_id
+ WHERE so.order_id = %d",
+ $order_id
+ ));
+ }
+
+ /**
+ * Get subscriptions by user
+ *
+ * @param int $user_id
+ * @param array $args
+ * @return array
+ */
+ public static function get_by_user($user_id, $args = [])
+ {
+ global $wpdb;
+
+ $defaults = [
+ 'status' => null,
+ 'limit' => 20,
+ 'offset' => 0,
+ ];
+ $args = wp_parse_args($args, $defaults);
+
+ $where = "WHERE user_id = %d";
+ $params = [$user_id];
+
+ if ($args['status']) {
+ $where .= " AND status = %s";
+ $params[] = $args['status'];
+ }
+
+ $sql = $wpdb->prepare(
+ "SELECT * FROM " . self::$table_subscriptions . " $where ORDER BY created_at DESC LIMIT %d OFFSET %d",
+ array_merge($params, [$args['limit'], $args['offset']])
+ );
+
+ return $wpdb->get_results($sql);
+ }
+
+ /**
+ * Get all subscriptions (admin)
+ *
+ * @param array $args
+ * @return array
+ */
+ public static function get_all($args = [])
+ {
+ global $wpdb;
+
+ $defaults = [
+ 'status' => null,
+ 'product_id' => null,
+ 'user_id' => null,
+ 'limit' => 20,
+ 'offset' => 0,
+ 'search' => null,
+ ];
+ $args = wp_parse_args($args, $defaults);
+
+ $where = "WHERE 1=1";
+ $params = [];
+
+ if ($args['status']) {
+ $where .= " AND status = %s";
+ $params[] = $args['status'];
+ }
+
+ if ($args['product_id']) {
+ $where .= " AND product_id = %d";
+ $params[] = $args['product_id'];
+ }
+
+ if ($args['user_id']) {
+ $where .= " AND user_id = %d";
+ $params[] = $args['user_id'];
+ }
+
+ $order = "ORDER BY created_at DESC";
+ $limit = "LIMIT " . intval($args['limit']) . " OFFSET " . intval($args['offset']);
+
+ $sql = "SELECT * FROM " . self::$table_subscriptions . " $where $order $limit";
+
+ if (!empty($params)) {
+ $sql = $wpdb->prepare($sql, $params);
+ }
+
+ return $wpdb->get_results($sql);
+ }
+
+ /**
+ * Count subscriptions
+ *
+ * @param array $args
+ * @return int
+ */
+ public static function count($args = [])
+ {
+ global $wpdb;
+
+ $where = "WHERE 1=1";
+ $params = [];
+
+ if (!empty($args['status'])) {
+ $where .= " AND status = %s";
+ $params[] = $args['status'];
+ }
+
+ $sql = "SELECT COUNT(*) FROM " . self::$table_subscriptions . " $where";
+
+ if (!empty($params)) {
+ $sql = $wpdb->prepare($sql, $params);
+ }
+
+ return (int) $wpdb->get_var($sql);
+ }
+
+ /**
+ * Update subscription status
+ *
+ * @param int $subscription_id
+ * @param string $status
+ * @param string|null $reason
+ * @return bool
+ */
+ public static function update_status($subscription_id, $status, $reason = null)
+ {
+ global $wpdb;
+
+ $data = ['status' => $status];
+ $format = ['%s'];
+
+ if ($reason !== null) {
+ $data['cancel_reason'] = $reason;
+ $format[] = '%s';
+ }
+
+ $updated = $wpdb->update(
+ self::$table_subscriptions,
+ $data,
+ ['id' => $subscription_id],
+ $format,
+ ['%d']
+ );
+
+ if ($updated !== false) {
+ do_action('woonoow/subscription/status_changed', $subscription_id, $status, $reason);
+ }
+
+ return $updated !== false;
+ }
+
+ /**
+ * Cancel subscription
+ *
+ * @param int $subscription_id
+ * @param string $reason
+ * @param bool $immediate Force immediate cancellation
+ * @return bool
+ */
+ public static function cancel($subscription_id, $reason = '', $immediate = false)
+ {
+ $subscription = self::get($subscription_id);
+ if (!$subscription || in_array($subscription->status, ['cancelled', 'expired'])) {
+ return false;
+ }
+
+ // Default to pending-cancel if there's time left
+ $new_status = 'cancelled';
+ $now = current_time('mysql');
+
+ if (!$immediate && $subscription->next_payment_date && $subscription->next_payment_date > $now) {
+ $new_status = 'pending-cancel';
+ }
+
+ $success = self::update_status($subscription_id, $new_status, $reason);
+
+ if ($success) {
+ if ($new_status === 'pending-cancel') {
+ do_action('woonoow/subscription/pending_cancel', $subscription_id, $reason);
+ } else {
+ do_action('woonoow/subscription/cancelled', $subscription_id, $reason);
+ }
+ }
+
+ return $success;
+ }
+
+ /**
+ * Pause subscription
+ *
+ * @param int $subscription_id
+ * @return bool
+ */
+ public static function pause($subscription_id)
+ {
+ global $wpdb;
+
+ $subscription = self::get($subscription_id);
+ if (!$subscription || $subscription->status !== 'active') {
+ return false;
+ }
+
+ // Check max pause count
+ $settings = ModuleRegistry::get_settings('subscription');
+ $max_pause = $settings['max_pause_count'] ?? 3;
+
+ if ($max_pause > 0 && $subscription->pause_count >= $max_pause) {
+ return false;
+ }
+
+ $updated = $wpdb->update(
+ self::$table_subscriptions,
+ [
+ 'status' => 'on-hold',
+ 'pause_count' => $subscription->pause_count + 1,
+ ],
+ ['id' => $subscription_id],
+ ['%s', '%d'],
+ ['%d']
+ );
+
+ if ($updated !== false) {
+ do_action('woonoow/subscription/paused', $subscription_id);
+ }
+
+ return $updated !== false;
+ }
+
+ /**
+ * Resume subscription
+ *
+ * @param int $subscription_id
+ * @return bool
+ */
+ public static function resume($subscription_id)
+ {
+ global $wpdb;
+
+ $subscription = self::get($subscription_id);
+ if (!$subscription || !in_array($subscription->status, ['on-hold', 'pending-cancel'])) {
+ return false;
+ }
+
+ $update_data = ['status' => 'active'];
+ $format = ['%s'];
+
+ // Only recalculate payment date if resuming from on-hold
+ if ($subscription->status === 'on-hold') {
+ // Recalculate next payment date from now
+ $next_payment = self::calculate_next_payment_date(
+ current_time('mysql'),
+ $subscription->billing_period,
+ $subscription->billing_interval
+ );
+ $update_data['next_payment_date'] = $next_payment;
+ $format[] = '%s';
+ }
+
+ $updated = $wpdb->update(
+ self::$table_subscriptions,
+ $update_data,
+ ['id' => $subscription_id],
+ $format,
+ ['%d']
+ );
+
+ if ($updated !== false) {
+ do_action('woonoow/subscription/resumed', $subscription_id);
+ }
+
+ return $updated !== false;
+ }
+
+ /**
+ * Process renewal for a subscription
+ *
+ * @param int $subscription_id
+ * @return bool
+ */
+ /**
+ * Process renewal for a subscription
+ *
+ * @param int $subscription_id
+ * @return bool
+ */
+ public static function renew($subscription_id)
+ {
+ global $wpdb;
+
+ $subscription = self::get($subscription_id);
+ if (!$subscription || !in_array($subscription->status, ['active', 'on-hold'])) {
+ return false;
+ }
+
+ // Check for existing pending renewal order to prevent duplicates
+ $existing_pending = $wpdb->get_row($wpdb->prepare(
+ "SELECT so.order_id FROM " . self::$table_subscription_orders . " so
+ JOIN {$wpdb->posts} p ON so.order_id = p.ID
+ WHERE so.subscription_id = %d
+ AND so.order_type = 'renewal'
+ AND p.post_status IN ('wc-pending', 'pending', 'wc-on-hold', 'on-hold')",
+ $subscription_id
+ ));
+
+ if ($existing_pending) {
+ return ['success' => true, 'order_id' => (int) $existing_pending->order_id, 'status' => 'existing'];
+ }
+
+ // Create renewal order
+ $renewal_order = self::create_renewal_order($subscription);
+ if (!$renewal_order) {
+ // Failed to create order
+ self::handle_renewal_failure($subscription_id);
+ return false;
+ }
+
+ // Process payment
+ // Result can be: true (paid), false (failed), or 'manual' (waiting for payment)
+ $payment_result = self::process_renewal_payment($subscription, $renewal_order);
+
+ if ($payment_result === true) {
+ self::handle_renewal_success($subscription_id, $renewal_order);
+ return ['success' => true, 'order_id' => $renewal_order->get_id(), 'status' => 'complete'];
+ } elseif ($payment_result === 'manual') {
+ // Manual payment required
+
+ // CHECK: Is this an early renewal? (Next payment date is in future)
+ $now = current_time('mysql');
+ $is_early_renewal = $subscription->next_payment_date && $subscription->next_payment_date > $now;
+
+ if ($is_early_renewal) {
+ // Early renewal: Keep active, just waiting for payment
+ return ['success' => true, 'order_id' => $renewal_order->get_id(), 'status' => 'manual'];
+ }
+
+ // Normal/Overdue renewal: Set to on-hold
+ self::update_status($subscription_id, 'on-hold', 'awaiting_payment');
+ return ['success' => true, 'order_id' => $renewal_order->get_id(), 'status' => 'manual'];
+ } else {
+ // Auto-debit failed
+ self::handle_renewal_failure($subscription_id);
+ return false;
+ }
+ }
+
+ /**
+ * Create a renewal order
+ *
+ * @param object $subscription
+ * @return \WC_Order|false
+ */
+ private static function create_renewal_order($subscription)
+ {
+ global $wpdb;
+
+ // Get original order
+ $parent_order = wc_get_order($subscription->order_id);
+ if (!$parent_order) {
+ return false;
+ }
+
+ // Create new order
+ $renewal_order = wc_create_order([
+ 'customer_id' => $subscription->user_id,
+ 'status' => 'pending',
+ 'parent' => $subscription->order_id,
+ ]);
+
+ if (is_wp_error($renewal_order)) {
+ return false;
+ }
+
+ // Add product
+ $product = wc_get_product($subscription->variation_id ?: $subscription->product_id);
+ if ($product) {
+ $renewal_order->add_product($product, 1, [
+ 'total' => $subscription->recurring_amount,
+ 'subtotal' => $subscription->recurring_amount,
+ ]);
+ }
+
+ // Copy billing/shipping from parent
+ $renewal_order->set_address($parent_order->get_address('billing'), 'billing');
+ $renewal_order->set_address($parent_order->get_address('shipping'), 'shipping');
+ $renewal_order->set_payment_method($subscription->payment_method);
+
+ // Calculate totals
+ $renewal_order->calculate_totals();
+ $renewal_order->save();
+
+ // Link to subscription
+ $wpdb->insert(
+ self::$table_subscription_orders,
+ [
+ 'subscription_id' => $subscription->id,
+ 'order_id' => $renewal_order->get_id(),
+ 'order_type' => 'renewal',
+ ],
+ ['%d', '%d', '%s']
+ );
+
+ return $renewal_order;
+ }
+
+ /**
+ * Process payment for renewal order
+ *
+ * @param object $subscription
+ * @param \WC_Order $order
+ * @return bool
+ */
+ /**
+ * Process payment for renewal order
+ *
+ * @param object $subscription
+ * @param \WC_Order $order
+ * @return bool|string True if paid, false if failed, 'manual' if waiting
+ */
+ private static function process_renewal_payment($subscription, $order)
+ {
+ // Allow plugins to override payment processing completely
+ // Return true/false/'manual' to bypass default logic
+ $pre = apply_filters('woonoow_pre_process_subscription_payment', null, $subscription, $order);
+ if ($pre !== null) {
+ return $pre;
+ }
+
+ // Get payment gateway
+ $gateways = WC()->payment_gateways()->get_available_payment_gateways();
+ $gateway_id = $subscription->payment_method;
+
+ if (!isset($gateways[$gateway_id])) {
+ // Payment method not available - treat as failure so user can fix
+ $order->update_status('failed', __('Payment method not available for renewal', 'woonoow'));
+ return false;
+ }
+
+ $gateway = $gateways[$gateway_id];
+
+ // 1. Try Auto-Debit if supported
+ if (method_exists($gateway, 'process_subscription_renewal_payment')) {
+ $result = $gateway->process_subscription_renewal_payment($order, $subscription);
+ if (!is_wp_error($result) && $result) {
+ return true;
+ }
+ // If explicit failure from auto-debit, return false (will trigger retry logic)
+ return false;
+ }
+
+ // 2. Allow other plugins to handle auto-debit via filter (e.g. Stripe/PayPal adapters)
+ $external_result = apply_filters('woonoow_process_subscription_payment', null, $gateway, $order, $subscription);
+ if ($external_result !== null) {
+ return $external_result ? true : false;
+ }
+
+ // 3. Fallback: Manual Payment
+ // Set order to pending-payment
+ $order->update_status('pending', __('Awaiting manual renewal payment', 'woonoow'));
+
+ // Send renewal payment email to customer
+ do_action('woonoow/subscription/renewal_payment_due', $subscription->id, $order);
+
+ return 'manual'; // Return special status
+ }
+
+ /**
+ * Handle successful renewal
+ *
+ * @param int $subscription_id
+ * @param \WC_Order $order
+ */
+ public static function handle_renewal_success($subscription_id, $order)
+ {
+ global $wpdb;
+
+ $subscription = self::get($subscription_id);
+
+ // Calculate next payment date
+ // For early renewal, start from the current next_payment_date if it's in the future
+ // Otherwise start from now (for expired/overdue subscriptions)
+ $now = current_time('mysql');
+ $base_date = $now;
+
+ if ($subscription->next_payment_date && $subscription->next_payment_date > $now) {
+ $base_date = $subscription->next_payment_date;
+ }
+
+ $next_payment = self::calculate_next_payment_date(
+ $base_date,
+ $subscription->billing_period,
+ $subscription->billing_interval
+ );
+
+ // Check if subscription should end
+ if ($subscription->end_date && strtotime($next_payment) > strtotime($subscription->end_date)) {
+ $next_payment = null;
+ }
+
+ $wpdb->update(
+ self::$table_subscriptions,
+ [
+ 'status' => 'active',
+ 'next_payment_date' => $next_payment,
+ 'last_payment_date' => current_time('mysql'),
+ 'failed_payment_count' => 0,
+ ],
+ ['id' => $subscription_id],
+ ['%s', '%s', '%s', '%d'],
+ ['%d']
+ );
+
+ // Complete the order
+ $order->payment_complete();
+
+ do_action('woonoow/subscription/renewed', $subscription_id, $order);
+ }
+
+ /**
+ * Handle failed renewal
+ *
+ * @param int $subscription_id
+ */
+ private static function handle_renewal_failure($subscription_id)
+ {
+ global $wpdb;
+
+ $subscription = self::get($subscription_id);
+ $new_failed_count = $subscription->failed_payment_count + 1;
+
+ // Get settings
+ $settings = ModuleRegistry::get_settings('subscription');
+ $max_attempts = $settings['expire_after_failed_attempts'] ?? 3;
+
+ if ($new_failed_count >= $max_attempts) {
+ // Mark as expired
+ $wpdb->update(
+ self::$table_subscriptions,
+ [
+ 'status' => 'expired',
+ 'failed_payment_count' => $new_failed_count,
+ ],
+ ['id' => $subscription_id],
+ ['%s', '%d'],
+ ['%d']
+ );
+
+ do_action('woonoow/subscription/expired', $subscription_id, 'payment_failed');
+ } else {
+ // Just increment failed count
+ $wpdb->update(
+ self::$table_subscriptions,
+ ['failed_payment_count' => $new_failed_count],
+ ['id' => $subscription_id],
+ ['%d'],
+ ['%d']
+ );
+
+ do_action('woonoow/subscription/renewal_failed', $subscription_id, $new_failed_count);
+ }
+ }
+
+ /**
+ * Calculate next payment date
+ *
+ * @param string $from_date
+ * @param string $period
+ * @param int $interval
+ * @return string
+ */
+ public static function calculate_next_payment_date($from_date, $period, $interval = 1)
+ {
+ $interval = max(1, $interval);
+
+ switch ($period) {
+ case 'day':
+ $modifier = "+ $interval days";
+ break;
+ case 'week':
+ $modifier = "+ $interval weeks";
+ break;
+ case 'month':
+ $modifier = "+ $interval months";
+ break;
+ case 'year':
+ $modifier = "+ $interval years";
+ break;
+ default:
+ $modifier = "+ 1 month";
+ }
+
+ return date('Y-m-d H:i:s', strtotime($from_date . ' ' . $modifier));
+ }
+
+ /**
+ * Calculate subscription end date
+ *
+ * @param string $start_date
+ * @param string $period
+ * @param int $interval
+ * @param int $length
+ * @return string
+ */
+ private static function calculate_end_date($start_date, $period, $interval, $length)
+ {
+ $total_periods = $interval * $length;
+
+ switch ($period) {
+ case 'day':
+ $modifier = "+ $total_periods days";
+ break;
+ case 'week':
+ $modifier = "+ $total_periods weeks";
+ break;
+ case 'month':
+ $modifier = "+ $total_periods months";
+ break;
+ case 'year':
+ $modifier = "+ $total_periods years";
+ break;
+ default:
+ $modifier = "+ $total_periods months";
+ }
+
+ return date('Y-m-d H:i:s', strtotime($start_date . ' ' . $modifier));
+ }
+
+ /**
+ * Get subscriptions due for renewal
+ *
+ * @return array
+ */
+ public static function get_due_renewals()
+ {
+ global $wpdb;
+
+ $now = current_time('mysql');
+
+ return $wpdb->get_results($wpdb->prepare(
+ "SELECT * FROM " . self::$table_subscriptions . "
+ WHERE status = 'active'
+ AND next_payment_date IS NOT NULL
+ AND next_payment_date <= %s
+ ORDER BY next_payment_date ASC",
+ $now
+ ));
+ }
+
+ /**
+ * Get subscription orders
+ *
+ * @param int $subscription_id
+ * @return array
+ */
+ public static function get_orders($subscription_id)
+ {
+ global $wpdb;
+
+ return $wpdb->get_results($wpdb->prepare(
+ "SELECT so.*, p.post_status as order_status
+ FROM " . self::$table_subscription_orders . " so
+ LEFT JOIN {$wpdb->posts} p ON so.order_id = p.ID
+ WHERE so.subscription_id = %d
+ ORDER BY so.created_at DESC",
+ $subscription_id
+ ));
+ }
+}
diff --git a/includes/Modules/Subscription/SubscriptionModule.php b/includes/Modules/Subscription/SubscriptionModule.php
new file mode 100644
index 0000000..27f13aa
--- /dev/null
+++ b/includes/Modules/Subscription/SubscriptionModule.php
@@ -0,0 +1,563 @@
+prefix . 'woonoow_subscriptions';
+
+ // Check if table exists
+ if ($wpdb->get_var("SHOW TABLES LIKE '$table'") !== $table) {
+ SubscriptionManager::create_tables();
+ }
+ }
+
+ /**
+ * Handle module enable
+ */
+ public static function on_module_enabled($module_id)
+ {
+ if ($module_id === 'subscription') {
+ SubscriptionManager::create_tables();
+ }
+ }
+
+ /**
+ * Add subscription fields to product edit page
+ */
+ public static function add_product_subscription_fields()
+ {
+ global $post;
+
+ if (!ModuleRegistry::is_enabled('subscription')) {
+ return;
+ }
+
+ echo '