Reverb_Opencart_Extension/upload/admin/controller/extension/module/reverb.php

<?php
class ControllerExtensionModuleReverb extends Controller {

    private $error = [];

    // -------------------------------------------------------------------------
    // Main settings page
    // -------------------------------------------------------------------------

    public function index() {
        $this->load->language('extension/module/reverb');
        $this->load->model('extension/module/reverb');
        $this->load->model('setting/setting');
        $this->load->model('catalog/category');

        $this->document->setTitle($this->language->get('heading_title'));

        if ($this->request->server['REQUEST_METHOD'] === 'POST' && $this->validate()) {
            $this->model_setting_setting->editSetting('module_reverb', $this->request->post);
            // Save category mappings separately (they come as a sub-array)
            if (isset($this->request->post['module_reverb_category_mappings'])) {
                $this->model_extension_module_reverb->saveCategoryMappings(
                    $this->request->post['module_reverb_category_mappings']
                );
            }
            $this->session->data['success'] = $this->language->get('text_success');
            $this->response->redirect($this->url->link('extension/module/reverb', 'user_token=' . $this->session->data['user_token'], true));
        }

        $data = $this->buildBreadcrumbs();

        // Pull saved settings into $data
        $fields = [
            'module_reverb_api_token',
            'module_reverb_status',
            'module_reverb_sync_direction',
            'module_reverb_sync_categories',
            'module_reverb_shipping_domestic',
            'module_reverb_shipping_international',
        ];
        foreach ($fields as $key) {
            $data[$key] = $this->request->post[$key] ?? $this->config->get($key);
        }

        // Defaults
        $data['module_reverb_sync_direction']      = $data['module_reverb_sync_direction'] ?? 'push';
        $data['module_reverb_sync_categories']     = $data['module_reverb_sync_categories'] ?? [];
        $data['module_reverb_shipping_domestic']   = $data['module_reverb_shipping_domestic'] ?? '0.00';
        $data['module_reverb_shipping_international'] = $data['module_reverb_shipping_international'] ?? '0.00';

        // All OC categories for the multi-select
        $data['categories'] = $this->getCategoryTree();

        // Category mappings for the mapping tab
        $data['category_mappings']    = $this->model_extension_module_reverb->getCategoryMappings();
        $data['reverb_categories']    = $this->model_extension_module_reverb->getReverbCategories();
        $data['module_reverb_category_mappings'] = $data['category_mappings'];

        // Sync log
        $data['sync_log'] = $this->model_extension_module_reverb->getSyncLog(200);

        // Alerts
        $data['error_warning'] = $this->error['warning'] ?? '';
        $data['success']       = $this->session->data['success'] ?? '';
        unset($this->session->data['success']);

        $data['action']     = $this->url->link('extension/module/reverb', 'user_token=' . $this->session->data['user_token'], true);
        $data['cancel']     = $this->url->link('marketplace/extension', 'user_token=' . $this->session->data['user_token'] . '&type=module', true);
        $data['sync_url']   = $this->url->link('extension/module/reverb/sync', 'user_token=' . $this->session->data['user_token'], true);
        $data['categories_url'] = $this->url->link('extension/module/reverb/reverbCategories', 'user_token=' . $this->session->data['user_token'], true);

        $data['header']      = $this->load->controller('common/header');
        $data['column_left'] = $this->load->controller('common/column_left');
        $data['footer']      = $this->load->controller('common/footer');

        $this->response->setOutput($this->load->view('extension/module/reverb', $data));
    }

    // -------------------------------------------------------------------------
    // Install / Uninstall
    // -------------------------------------------------------------------------

    public function install() {
        $this->load->model('extension/module/reverb');
        $this->model_extension_module_reverb->install();

        // Register events for order pulling (admin side)
        $this->load->model('setting/event');
        $this->model_setting_event->addEvent(
            'reverb',
            'admin/model/catalog/product/editProduct/after',
            'extension/module/reverb/eventProductSave'
        );
        $this->model_setting_event->addEvent(
            'reverb',
            'admin/model/catalog/product/addProduct/after',
            'extension/module/reverb/eventProductAddSave'
        );
    }

    public function uninstall() {
        $this->load->model('extension/module/reverb');
        $this->model_extension_module_reverb->uninstall();

        $this->load->model('setting/event');
        $this->model_setting_event->deleteEventByCode('reverb');
    }

    // -------------------------------------------------------------------------
    // Event handlers (called by OC event system on product save)
    // -------------------------------------------------------------------------

    public function eventProductSave(&$route, &$args, &$output) {
        $product_id = (int)$args[0];
        $this->saveProductReverb($product_id);
    }

    public function eventProductAddSave(&$route, &$args, &$output) {
        // $output holds the new product_id for addProduct
        $product_id = (int)$output;
        if ($product_id) {
            $this->saveProductReverb($product_id);
        }
    }

    private function saveProductReverb($product_id) {
        if (!isset($this->request->post['reverb_sync_enabled'])) {
            return;
        }
        $this->load->model('extension/module/reverb');
        $this->model_extension_module_reverb->saveProductMap($product_id, [
            'sync_enabled'         => (int)(bool)$this->request->post['reverb_sync_enabled'],
            'condition_uuid'       => $this->request->post['reverb_condition_uuid'] ?? '',
            'reverb_category_uuid' => $this->request->post['reverb_category_uuid'] ?? '',
        ]);
    }

    // -------------------------------------------------------------------------
    // Manual sync (AJAX)
    // -------------------------------------------------------------------------

    public function sync() {
        $this->load->language('extension/module/reverb');
        $this->load->model('extension/module/reverb');

        $json = ['success' => false];

        if (!$this->user->hasPermission('modify', 'extension/module/reverb')) {
            $json['error'] = $this->language->get('error_permission');
            $this->response->addHeader('Content-Type: application/json');
            $this->response->setOutput(json_encode($json));
            return;
        }

        $settings = $this->buildSettings();

        if (empty($settings['api_token'])) {
            $json['error'] = $this->language->get('error_api_token');
            $this->response->addHeader('Content-Type: application/json');
            $this->response->setOutput(json_encode($json));
            return;
        }

        $allowed_categories = $this->config->get('module_reverb_sync_categories') ?? [];
        $products           = $this->model_extension_module_reverb->getSyncEnabledProducts((array)$allowed_categories);

        $pushed = 0;
        $errors = 0;

        foreach ($products as $product) {
            try {
                $this->model_extension_module_reverb->syncProductToReverb($product, $product, $settings);
                $this->model_extension_module_reverb->log($product['product_id'], 'push', 'success', 'Synced: ' . $product['name']);
                $pushed++;
            } catch (Exception $e) {
                $this->model_extension_module_reverb->log($product['product_id'], 'push', 'error', $e->getMessage());
                $errors++;
            }
        }

        $json['success'] = true;
        $json['message'] = sprintf($this->language->get('text_sync_complete'), $pushed, $errors);

        $this->response->addHeader('Content-Type: application/json');
        $this->response->setOutput(json_encode($json));
    }

    // -------------------------------------------------------------------------
    // Reverb categories (AJAX — for category mapping dropdowns)
    // -------------------------------------------------------------------------

    public function reverbCategories() {
        $this->load->model('extension/module/reverb');

        $categories = $this->model_extension_module_reverb->getReverbCategories();

        $this->response->addHeader('Content-Type: application/json');
        $this->response->setOutput(json_encode(['categories' => $categories]));
    }

    // -------------------------------------------------------------------------
    // Per-product tab (loaded inline via OCMOD template include)
    // The data is passed through the OCMOD PHP patch, not via a separate request.
    // -------------------------------------------------------------------------

    // -------------------------------------------------------------------------
    // Helpers
    // -------------------------------------------------------------------------

    private function validate() {
        if (!$this->user->hasPermission('modify', 'extension/module/reverb')) {
            $this->error['warning'] = $this->language->get('error_permission');
        }

        $token = $this->request->post['module_reverb_api_token'] ?? '';
        if (empty(trim($token))) {
            $this->error['warning'] = $this->language->get('error_api_token');
        }

        return empty($this->error);
    }

    private function buildBreadcrumbs() {
        return [
            'heading_title' => $this->language->get('heading_title'),
            'breadcrumbs'   => [
                [
                    'text' => $this->language->get('text_home'),
                    'href' => $this->url->link('common/dashboard', 'user_token=' . $this->session->data['user_token'], true),
                ],
                [
                    'text' => $this->language->get('text_extension'),
                    'href' => $this->url->link('marketplace/extension', 'user_token=' . $this->session->data['user_token'] . '&type=module', true),
                ],
                [
                    'text' => $this->language->get('heading_title'),
                    'href' => $this->url->link('extension/module/reverb', 'user_token=' . $this->session->data['user_token'], true),
                ],
            ],
        ];
    }

    private function buildSettings() {
        return [
            'api_token'              => $this->config->get('module_reverb_api_token'),
            'sync_direction'         => $this->config->get('module_reverb_sync_direction') ?? 'push',
            'shipping_domestic'      => $this->config->get('module_reverb_shipping_domestic') ?? '0',
            'shipping_international' => $this->config->get('module_reverb_shipping_international') ?? '0',
            'currency'               => $this->config->get('config_currency') ?? 'AUD',
            'store_url'              => $this->config->get('config_url') ?? '',
        ];
    }

    private function getCategoryTree($parent_id = 0, $indent = '') {
        $this->load->model('catalog/category');
        $categories = [];
        $results = $this->model_catalog_category->getCategories(['parent_id' => $parent_id]);
        foreach ($results as $cat) {
            $categories[] = [
                'category_id' => $cat['category_id'],
                'name'        => $indent . $cat['name'],
            ];
            $children = $this->getCategoryTree($cat['category_id'], $indent . '&nbsp;&nbsp;&nbsp;');
            $categories = array_merge($categories, $children);
        }
        return $categories;
    }
}