# yatra/3.0.14.2/app/Migrations/MigrationController.php

Yatra – Travel Booking & Tour Operator Software, version 3.0.14.2. 219 lines.

- Page: https://pluginprobe.com/plugins/yatra/3.0.14.2/code/app/Migrations/MigrationController.php
- Raw: https://pluginprobe.com/plugins/yatra/3.0.14.2/raw/app/Migrations/MigrationController.php
- Modified: 2026-04-14T03:47:24+00:00

Line numbers below start at 1. Link to a line or a range by appending a fragment to the
page URL, for example `https://pluginprobe.com/plugins/yatra/3.0.14.2/code/app/Migrations/MigrationController.php#L10-L20`.

```php
<?php
/**
 * Migration Controller - REST API endpoints for migration
 * 
 * @package Yatra\Migration
 * @since 3.0.0
 */

namespace Yatra\Migration;

use WP_REST_Request;
use WP_REST_Response;
use Yatra\Migration\MigrationProgress;

class MigrationController
{
    private $service;
    
    public function __construct()
    {
        $this->service = new MigrationProgress();
    }

    /**
     * Clear migration data (progress/logs)
     */
    public function clear(WP_REST_Request $request): WP_REST_Response
    {
        try {
            $result = $this->service->clearMigrationData();

            return new WP_REST_Response($result, 200);

        } catch (\Exception $e) {
            return new WP_REST_Response([
                'success' => false,
                'error' => $e->getMessage(),
            ], 500);
        }
    }
    
    /**
     * Register REST API routes
     */
    public function registerRoutes(): void
    {
        register_rest_route('yatra/v1', '/migration/status', [
            'methods' => 'GET',
            'callback' => [$this, 'getStatus'],
            'permission_callback' => [$this, 'checkPermission'],
        ]);
        
        register_rest_route('yatra/v1', '/migration/migrate', [
            'methods' => 'POST',
            'callback' => [$this, 'migrate'],
            'permission_callback' => [$this, 'checkPermission'],
            'args' => [
                'data_type' => [
                    'required' => true,
                    'type' => 'string',
                ],
                'force' => [
                    'type' => 'boolean',
                    'default' => false,
                ],
            ],
        ]);
        
        register_rest_route('yatra/v1', '/migration/migrate-all', [
            'methods' => 'POST',
            'callback' => [$this, 'migrateAll'],
            'permission_callback' => [$this, 'checkPermission'],
            'args' => [
                'force' => [
                    'type' => 'boolean',
                    'default' => false,
                ],
            ],
        ]);
        
        register_rest_route('yatra/v1', '/migration/progress', [
            'methods' => 'GET',
            'callback' => [$this, 'getProgress'],
            'permission_callback' => [$this, 'checkPermission'],
        ]);
        
        register_rest_route('yatra/v1', '/migration/cancel', [
            'methods' => 'POST',
            'callback' => [$this, 'cancel'],
            'permission_callback' => [$this, 'checkPermission'],
        ]);

        register_rest_route('yatra/v1', '/migration/clear', [
            'methods' => 'POST',
            'callback' => [$this, 'clear'],
            'permission_callback' => [$this, 'checkPermission'],
        ]);
    }
    
    /**
     * Get migration status
     */
    public function getStatus(WP_REST_Request $request): WP_REST_Response
    {
        try {
            $status = $this->service->getStatus();
            
            return new WP_REST_Response($status, 200);
            
        } catch (\Exception $e) {
            return new WP_REST_Response([
                'success' => false,
                'message' => $e->getMessage(),
            ], 500);
        }
    }
    
    /**
     * Migrate specific data type
     */
    public function migrate(WP_REST_Request $request): WP_REST_Response
    {
        try {
            $dataType = $request->get_param('data_type');
            $force = (bool) $request->get_param('force');
            
            $result = $this->service->migrate($dataType, $force);
            
            return new WP_REST_Response($result, 200);
            
        } catch (\Exception $e) {
            return new WP_REST_Response([
                'success' => false,
                'message' => $e->getMessage(),
            ], 500);
        }
    }
    
    /**
     * Migrate all data types
     */
    public function migrateAll(WP_REST_Request $request): WP_REST_Response
    {
        try {
            $force = (bool) $request->get_param('force');
            $results = $this->service->migrateAll($force);
            
            // Return results directly - service already returns proper structure
            return new WP_REST_Response($results, 200);
            
        } catch (\Exception $e) {
            return new WP_REST_Response([
                'success' => false,
                'error' => $e->getMessage(),
            ], 500);
        }
    }
    
    /**
     * Get migration progress
     */
    public function getProgress(WP_REST_Request $request): WP_REST_Response
    {
        try {
            $progress = $this->service->getMigrationProgress();
            
            return new WP_REST_Response($progress, 200);
            
        } catch (\Exception $e) {
            return new WP_REST_Response([
                'success' => false,
                'message' => $e->getMessage(),
            ], 500);
        }
    }
    
    /**
     * Cancel migration
     */
    public function cancel(WP_REST_Request $request): WP_REST_Response
    {
        try {
            $result = $this->service->cancelMigration();
            
            return new WP_REST_Response($result, 200);
            
        } catch (\Exception $e) {
            return new WP_REST_Response([
                'success' => false,
                'error' => $e->getMessage(),
            ], 500);
        }
    }
    
    /**
     * Check if user has permission
     */
    public function checkPermission()
    {
        if (!is_user_logged_in()) {
            return new \WP_Error(
                'rest_forbidden',
                __('You must be logged in to perform this action.', 'yatra'),
                ['status' => 401]
            );
        }

        if (!current_user_can('manage_options')) {
            return new \WP_Error(
                'rest_forbidden',
                __('You do not have permission to perform this action.', 'yatra'),
                ['status' => 403]
            );
        }

        return true;
    }
}

```