<?php

declare(strict_types=1);

namespace App\Services\OpenApi;

use Illuminate\Http\Request;
//use App\Services\TomTool\TelegramV2;
use App\Services\TomTool\Flow;
use App\Services\TomTool\Telegram\Master as TeleMaster;
//use App\Services\TomTool\Telegram\Slave as TeleSlave;
use Telegram\Bot\Api;
use Telegram\Bot\Exceptions\TelegramSDKException;

final class Telegram
{
    public function post()
    {
        $oFlow = Flow::make("master::tgpost");
        
        $sArg = file_get_contents('php://input');
        $aArg = json_decode($sArg, true);
        
        $sBotCode = $aArg["sBotCode"] ?? '';
        $sChatCode = $aArg["sChatCode"] ?? '';
        $sBotToken = $aArg["sBotToken"] ?? '';
        $iChatId = (int) ($aArg["iChatId"] ?? 0);
        $enableMasterQueue = $aArg["enableMasterQueue"] ?? false; // 用不着了
        $sMsg = $aArg["sMsg"] ?? '';
        
        $r = TeleMaster::start()
                ->setBotCode($sBotCode)
                ->setChatCode($sChatCode)
                ->setBotToken($sBotToken)
                ->setChatId($iChatId)
                ->send($sMsg);
        
        return $oFlow->done();
    }
    
    
    
    public function queueAdd_meiyong(Request $oRequest)
    {
        $oResult = Flow::make("master::queueAdd");
        
        $sArg = $oRequest->post("arg");
        
        if (!$sArg) {
            return $oResult->fail("没有arg");
        }
        
        $oHttpQueue = new ModelHttpQueue();
        $oHttpQueue->name = "telegram";
        $oHttpQueue->arg = $sArg;
        $r = $oHttpQueue->save();
        
        if (!$r) {
            return $oResult->fail("进入队列失败");
        }
        
        return $oResult->done();
    }

    
}