<?php

namespace App\Http\Admin;

use Txj\Elastic\Facades\ES;
use GuzzleHttp\Client;
use Illuminate\Http\JsonResponse;
use Illuminate\Support\Facades\Request;


class ElasticController extends AdminBaseController
{
    protected ?Client $curl = null;

    public function __construct()
    {
        parent::__construct();

        $this->setWebsite(__NAMESPACE__);
        $this->isLoginJson();

        $this->curl = new Client();
    }

    /**
     * @return JsonResponse
     */
    public function ping()
    {
        $info = ES::client()->ping();
        return responseMessage(1002, '', $info);
    }

    public function clusterInfo()
    {
        $info = ES::client()->info();
        return responseMessage(1002, '', $info);
    }

    public function clusterHealth()
    {
        $info = ES::client()->cluster()->health();
        return responseMessage(1002, '', $info);
    }

    public function clusterSettings()
    {
        $info = ES::client()->cluster()->getSettings();
        return responseMessage(1002, '', $info);
    }

    public function catIndices()
    {
        $params = Request::all();
        $list = ES::client()->cat()->indices($params);

        foreach ($list as $key => $row){
            $info = ES::client()->indices()->getAlias(['index' => $row['index']]);
            $list[$key]['aliases'] = array_keys($info[$row['index']]['aliases']);
        }

        return responseMessage(1002, '', $list);
    }

    public function indexGetAlias()
    {
        $index = Request::input('index');
        if (empty($index)) {
            return responseMessage(2001, '参数错误！');
        }

        $info = ES::client()->indices()->getAlias(['index' => $index]);
        return responseMessage(1002, '', $info);
    }

    public function indexAddAlias()
    {
        $index = Request::input('index');
        $alias = Request::input('alias');
        if (empty($index) || empty($alias)) {
            return responseMessage(2001, '参数错误！');
        }

        $info = ES::client()->indices()->putAlias(['index' => $index, 'name' => $alias]);
        return responseMessage(1002, '', $info);
    }

    public function indexDeleteAlias()
    {
        $index = Request::input('index');
        $alias = Request::input('alias');
        if (empty($index) || empty($alias)) {
            return responseMessage(2001, '参数错误！');
        }

        $info = ES::client()->indices()->deleteAlias(['index' => $index, 'name' => $alias]);
        return responseMessage(1002, '', $info);
    }

    public function indexDelete()
    {
        $index = Request::input('index');
        if (empty($index)) {
            return responseMessage(2001, '参数错误！');
        }

        $info = ES::client()->indices()->delete(['index' => $index]);
        return responseMessage(1002, '', $info);
    }

    public function indexCreate()
    {
        $index = Request::input('index');
        if (empty($index)) {
            return responseMessage(2001, '参数错误！');
        }

        $info = ES::client()->indices()->create();
        return responseMessage(1002, '', $info);
    }

    public function indexStats()
    {
        $index = Request::input('index');
        if (empty($index)) {
            return responseMessage(2001, '参数错误！');
        }

        $info = ES::client()->indices()->stats(['index' => $index]);
        return responseMessage(1002, '', $info);
    }

    public function indexOpen()
    {
        $index = Request::input('index');
        if (empty($index)) {
            return responseMessage(2001, '参数错误！');
        }

        $info = ES::client()->indices()->open(['index' => $index]);
        return responseMessage(1002, '', $info);
    }

    public function indexClose()
    {
        $index = Request::input('index');
        if (empty($index)) {
            return responseMessage(2001, '参数错误！');
        }

        $info = ES::client()->indices()->close(['index' => $index]);
        return responseMessage(1002, '', $info);
    }

    public function indexRefresh()
    {
        $index = Request::input('index');
        if (empty($index)) {
            return responseMessage(2001, '参数错误！');
        }

        $info = ES::client()->indices()->refresh(['index' => $index]);
        return responseMessage(1002, '', $info);
    }

    public function indexFlush()
    {
        $index = Request::input('index');
        if (empty($index)) {
            return responseMessage(2001, '参数错误！');
        }

        $info = ES::client()->indices()->flush(['index' => $index]);
        return responseMessage(1002, '', $info);
    }

    public function indexPutSettings()
    {
        $index = Request::input('index');
        if (empty($index)) {
            return responseMessage(2001, '参数错误！');
        }

        $body = Request::input('body');
        if (empty($body)) {
            return responseMessage(2001, '参数错误！');
        }

        $info = ES::client()->indices()->putSettings([
            'index' => $index,
            'body' => $body
        ]);
        return responseMessage(1002, '', $info);
    }

    public function catNodes()
    {
        $h = Request::input('h');

        $params = [];
        if ($h) {
            $params = ['h' => $h];
        }

        $info = ES::client()->cat()->nodes($params);
        return responseMessage(1002, '', $info);
    }
}