<?php

/**
 * JSON-RPC functions
 *
 * (C) 2003-2025 Anope Team
 * Contact us at team@anope.org
 */

class AnopeRPC
{
    /**
     * The RPC host
     *
     * @var string
     */
    private $host;

    /**
     * Initiate a new AnopeRPC instance
     *
     * @param $host
     */
    public function __construct($host)
    {
        $this->host = $host;
    }

    /**
     * Run an RPC command. Name should be a query name and params an array of parameters, eg:
     * $this->raw("checkAuthentication", ["adam", "qwerty"]);
     * If successful returns back an array of useful information.
     *
     * Note that $params["id"] is reserved for query ID, you may set it to something if you wish.
     * If you do, the same ID will be passed back with the reply from Anope.
     *
     * @param $name
     * @param $params
     * @return array|null
     */
    public function run($name, $params)
    {
        $request = json_encode([
            "jsonrpc" => "2.0",
            "id" => uniqid(),
            "method" => $name,
            "params" => $params,
        ]);
        $context = stream_context_create(["http" => [
            "method" => "POST",
            "header" => "Content-Type: application/json",
            "content" => $request]]);

        $inbuf = file_get_contents($this->host, false, $context);
        $response = json_decode($inbuf, true);

        if ($response) {
            return $response;
        }

        return null;
    }

    /**
     * Do Command on Service as User, eg:
     * $anope->command("ChanServ", "Adam", "REGISTER #adam");
     * Returns an array of information regarding the command execution, if
     * If 'online' is set to yes, then the reply to the command was sent to the user on IRC.
     * If 'online' is set to no, then the reply to the command is in the array member 'return'
     *
     * @param $service
     * @param $user
     * @param $command
     * @return array|null
     */
    public function command($service, $user, $command)
    {
        return $this->run("command", [$service, $user, $command]);
    }

    /**
     * Check an account/nick name and password to see if they are valid
     * Returns the account display name if valid
     *
     * @param $account
     * @param $pass
     * @return string|null
     */
    public function auth($account, $pass)
    {
        $ret = $this->run("checkAuthentication", [$account, $pass]);

        if ($ret && array_key_exists("result", $ret) && array_key_exists("account", $ret["result"])) {
            return $ret["result"]["account"];
        }

        return null;
    }

    /**
     * Returns an array of misc stats regarding Anope
     *
     * @return array|null
     */
    public function stats()
    {
        return $this->run("stats", null);
    }

    /**
     * Look up data for a channel
     * Returns an array containing channel information, or an array of size one
     * (just containing the name) if the channel does not exist
     *
     * @param $channel
     * @return array|null
     */
    public function channel($channel)
    {
        return $this->run("anope.channel", [$channel]);
    }

    /**
     * Sent a notice to a user.
     * Returns an array containing channel information, or an array of size one
     * (just containing the name) if the channel does not exist
     *
     * @param $source
     * @param $target
     * @param $message
     * @return array|null
     */
    public function notice($source, $target, $message)
    {
        return $this->run("anope.messageUser", [$source, $target, $message]);
    }

    /**
     * Like channel(), but different.
     *
     * @param $user
     * @return array|null
     */
    public function user($user)
    {
        return $this->run("anope.user", [$user]);
    }
}

$anope = new AnopeRPC("http://127.0.0.1:8080/jsonrpc");