Order Hooks

add_action('fluent_cart/order_created', function ($data) {
    $order = $data['order'];

    // Push to an external warehouse/ERP system for pre-allocation
    wp_remote_post('https://erp.example.com/api/orders', [
        'body' => json_encode([
            'external_id' => $order->id,
            'customer_id' => $order->customer_id,
            'total'       => $order->total,
            'currency'    => $order->currency,
        ]),
        'headers' => ['Content-Type' => 'application/json'],
    ]);
}, 10, 1);

add_action('fluent_cart/order_paid_done', function ($data) {
    $order = $data['order'];

    // Enrol the customer in an external course platform
    foreach ($order->order_items as $item) {
        $courseId = get_post_meta($item->product_id, '_linked_course_id', true);
        if ($courseId) {
            enrol_user_in_course($order->customer_id, $courseId);
        }
    }
}, 10, 1);

add_action('fluent_cart/order_updated', function ($data) {
    $order    = $data['order'];
    $oldOrder = $data['old_order'];

    // Sync status changes to an external fulfilment service
    if ($order->status !== $oldOrder->status) {
        wp_remote_post('https://fulfilment.example.com/api/status', [
            'body' => json_encode([
                'order_id'   => $order->id,
                'old_status' => $oldOrder->status,
                'new_status' => $order->status,
            ]),
            'headers' => ['Content-Type' => 'application/json'],
        ]);
    }
}, 10, 1);

add_action('fluent_cart/order_deleted', function ($data) {
    $order = $data['order'];

    // Clean up custom meta and external references
    global $wpdb;
    $wpdb->delete("{$wpdb->prefix}custom_order_tracking", [
        'order_id' => $order->id,
    ]);

    // Notify external systems to purge their records too
    wp_remote_request('https://erp.example.com/api/orders/' . $order->id, [
        'method' => 'DELETE',
    ]);
}, 10, 1);

add_action('fluent_cart/order_canceled', function ($data) {
    $order = $data['order'];

    // Revoke any access that was provisionally granted
    $userId = get_user_meta_by_customer_id($order->customer_id);
    if ($userId) {
        revoke_provisional_access($userId, $order->id);
    }

    // Tag in CRM for win-back campaign
    if (function_exists('fluentcrm')) {
        $contact = FluentCrm\App\Models\Subscriber::where('email', $order->customer->email)->first();
        if ($contact) {
            $contact->attachTags([get_tag_id('order-canceled')]);
        }
    }
}, 10, 1);

add_action('fluent_cart/order_status_changed', function ($data) {
    $order = $data['order'];

    // Send a Slack notification when orders are completed
    if ($data['new_status'] === 'completed') {
        wp_remote_post('https://hooks.slack.com/services/XXX/YYY/ZZZ', [
            'body' => json_encode([
                'text' => sprintf(
                    'Order #%d completed — %s %s',
                    $order->id,
                    $order->currency,
                    number_format($order->total / 100, 2)
                ),
            ]),
            'headers' => ['Content-Type' => 'application/json'],
        ]);
    }
}, 10, 1);

add_action('fluent_cart/payment_status_changed', function ($data) {
    // Log all payment transitions for audit trail
    $logEntry = sprintf(
        '[%s] Order #%d payment: %s -> %s',
        current_time('mysql'),
        $data['order']->id,
        $data['old_status'],
        $data['new_status']
    );

    file_put_contents(
        WP_CONTENT_DIR . '/payment-audit.log',
        $logEntry . PHP_EOL,
        FILE_APPEND | LOCK_EX
    );
}, 10, 1);

// Trigger fulfilment only when payment is confirmed
add_action('fluent_cart/payment_status_changed_to_paid', function ($data) {
    $order = $data['order'];

    // Queue async fulfilment job
    as_enqueue_async_action('process_order_fulfilment', [
        'order_id' => $order->id,
    ], 'fulfilment');
}, 10, 1);

// Alert the team when a payment fails
add_action('fluent_cart/payment_status_changed_to_failed', function ($data) {
    wp_mail(
        get_option('admin_email'),
        'Payment Failed — Order #' . $data['order']->id,
        'A payment attempt has failed. Check the gateway logs.'
    );
}, 10, 1);

add_action('fluent_cart/order_fully_refunded', function ($data) {
    $order    = $data['order'];
    $customer = $data['customer'];

    // Revoke all access granted by this order
    revoke_order_access($order->id);

    // Deactivate any licence keys
    deactivate_licences_for_order($order->id);

    // Notify the customer
    wp_mail(
        $customer->email,
        'Refund Processed — Order #' . $order->id,
        sprintf(
            'Your refund of %s %s has been processed.',
            $order->currency,
            number_format($data['refunded_amount'] / 100, 2)
        )
    );
}, 10, 1);

add_action('fluent_cart/order_partially_refunded', function ($data) {
    $order = $data['order'];

    // Check which specific items were refunded and revoke only those
    foreach ($data['new_refunded_items'] as $item) {
        $courseId = get_post_meta($item->product_id, '_linked_course_id', true);
        if ($courseId) {
            unenrol_user_from_course($order->customer_id, $courseId);
        }
    }

    // Log for accounting reconciliation
    as_enqueue_async_action('sync_partial_refund_to_accounting', [
        'order_id'        => $order->id,
        'refunded_amount' => $data['refunded_amount'],
        'items'           => wp_list_pluck($data['new_refunded_items'], 'product_id'),
    ], 'accounting');
}, 10, 1);