AgentRpcExample.php

<?php

declare(strict_types=1);

namespace imperazim\easylibrary\examples\agent;

use imperazim\agent\api\AgentRpcAPI;
use imperazim\agent\api\AgentRuntimeAPI;
use imperazim\agent\constant\AgentRpcMethods;
use imperazim\agent\event\AgentRpcResponseReceivedEvent;
use pocketmine\event\Listener;

final class AgentRpcExample implements Listener{
    public function requestServerStatus(string $serverId) : int{
        if(!AgentRuntimeAPI::isAvailable()){
            return 0;
        }

        $response = AgentRpcAPI::toServer($serverId, AgentRpcMethods::SERVER_STATUS, [], 10);
        return (int) ($response['request_id'] ?? 0);
    }

    public function onRpcResponse(AgentRpcResponseReceivedEvent $event) : void{
        if($event->getMethod() !== AgentRpcMethods::SERVER_STATUS){
            return;
        }

        if(!$event->isOk()){
            $error = $event->getError();
            // Store/report the failed response.
            return;
        }

        $result = $event->getResult();
        // Use server status result.
    }
}