<?php

namespace app\controller;

use support\Request;
use Workerman\RedisQueue\Client;

class GiteeController
{
    public function mkserver(Request $request)
    {
        // 检查字段是否存在且为字符串
        if ($request->header('x-gitee-token') === 'giteemkserver') {
            // 注意：这里的命令必须是你完全信任的，并且已经被正确验证和过滤的  
            $command = 'bash /jim/webman/bash/giteemkserverstart.sh';
            // 使用 exec() 函数执行命令  
            $output = [];
            $returnVar = null;
            exec($command, $output, $returnVar);
            // 检查命令是否成功执行  
            if ($returnVar !== 0) {
                // 命令执行失败，处理错误  
                return json(['code' => 500, 'msg' => "命令执行失败，返回码: " . $returnVar . "\n" . "错误输出:\n" . implode("\n", $output)]);
            } else {
                // 命令执行成功，处理输出  
                return json(['code' => 200, 'msg' => "命令执行成功\n输出:\n" . implode("\n", $output) . 'Webhook received successfully!']);
            }
        } else {
            // 如果字段不存在或不是字符串，返回错误响应
            return json(['code' => 400, 'msg' => 'Invalid or missing custom header.']);
        }
    }

    public function mkios(Request $request)
    {
        // 检查字段是否存在且为字符串
        if ($request->header('x-gitee-token') === 'giteemkios') {
            // 队列名
            $queue = 'package-queue';
            $data = 'mkios';
            // 投递消息
            $client = new Client('redis://127.0.0.1:6379');
            $client->send($queue, $data);
            return json(['code' => 200, 'msg' => 'redis did send' . 'Webhook received successfully!']);
        } else {
            // 如果字段不存在或不是字符串，返回错误响应
            return json(['code' => 400, 'msg' => 'Invalid or missing custom header.']);
        }
    }
}