<?php

declare(strict_types=1);

/**
 * Reliable module.
 *
 * This file is part of MadelineProto.
 * MadelineProto is free software: you can redistribute it and/or modify it under the terms of the GNU Affero General Public License as published by the Free Software Foundation, either version 3 of the License, or (at your option) any later version.
 * MadelineProto is distributed in the hope that it will be useful, but WITHOUT ANY WARRANTY; without even the implied warranty of MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.
 * See the GNU Affero General Public License for more details.
 * You should have received a copy of the GNU General Public License along with MadelineProto.
 * If not, see <http://www.gnu.org/licenses/>.
 *
 * @author    Daniil Gentili <daniil@daniil.it>
 * @copyright 2016-2025 Daniil Gentili <daniil@daniil.it>
 * @license   https://opensource.org/licenses/AGPL-3.0 AGPLv3
 * @link https://docs.madelineproto.xyz MadelineProto documentation
 */

namespace danog\MadelineProto\MTProtoSession;

use danog\MadelineProto\Logger;
use danog\MadelineProto\MTProto;
use Revolt\EventLoop;

/**
 * Manages responses.
 *
 * @internal
 */
trait Reliable
{
    /**
     * Called when receiving a new_msg_detailed_info.
     */
    public function onNewMsgDetailedInfo(array $content): void
    {
        /*if (isset($this->incoming_messages[$content['answer_msg_id']])) {
            $this->incoming_messages[$content['answer_msg_id']]->ack();
        } else {
            EventLoop::queue($this->objectCall(...), 'msg_resend_req', ['msg_ids' => [$content['answer_msg_id']]]);
        }*/
    }
    /**
     * Called when receiving a msg_detailed_info.
     */
    public function onMsgDetailedInfo(array $content): void
    {
        if (isset($this->new_outgoing[$content['msg_id']])) {
            $this->onNewMsgDetailedInfo($content);
        }
    }
    /**
     * Called when receiving a msg_resend_req.
     */
    public function onMsgResendReq(array $content, int $current_msg_id): void
    {
        $ok = true;
        foreach ($content['msg_ids'] as $msg_id) {
            if (!isset($this->new_outgoing[$msg_id])) {
                $ok = false;
            }
        }
        if ($ok) {
            foreach ($content['msg_ids'] as $msg_id) {
                if (isset($this->new_outgoing[$msg_id])) {
                    $this->methodRecall($this->new_outgoing[$msg_id]);
                }
            }
        } else {
            $this->sendMsgsStateInfo($content['msg_ids'], $current_msg_id);
        }
    }
    /**
     * Called when receiving a msg_resend_ans_req.
     */
    public function onMsgResendAnsReq(array $content, int $current_msg_id): void
    {
        $this->sendMsgsStateInfo($content['msg_ids'], $current_msg_id);
    }

    /**
     * Called when receiving a msgs_all_info.
     */
    public function onMsgsAllInfo(array $content): void
    {
        foreach ($content['msg_ids'] as $key => $msg_id) {
            $info = \ord($content['info'][$key]);
            $status = 'Status for message id '.$msg_id.': ';
            foreach (MTProto::MSGS_INFO_FLAGS as $flag => $description) {
                if (($info & $flag) !== 0) {
                    $status .= $description;
                }
            }
            $this->API->logger($status, Logger::NOTICE);
        }
    }
    /**
     * Send state info for message IDs.
     *
     * @param array $msg_ids    Message IDs to send info about
     * @param int   $req_msg_id Message ID of msgs_state_req that initiated this
     */
    public function sendMsgsStateInfo(array $msg_ids, int $req_msg_id): void
    {
        /*$this->API->logger('Sending state info for '.\count($msg_ids).' message IDs');
        $info = '';
        foreach ($msg_ids as $msg_id) {
            $cur_info = 0;
            if (!isset($this->incoming_messages[$msg_id])) {
                $shifted = $msg_id >> 32;
                if ($shifted > (time() + $this->time_delta + 30)) {
                    $this->API->logger("Do not know anything about {$msg_id} and it is too big");
                    $cur_info |= 3;
                } elseif ($shifted < (time() + $this->time_delta - 300)) {
                    $this->API->logger("Do not know anything about {$msg_id} and it is too small");
                    $cur_info |= 1;
                } else {
                    $this->API->logger("Do not know anything about {$msg_id}");
                    $cur_info |= 2;
                }
            } else {
                $this->API->logger("Know about {$msg_id}");
                $cur_info = $this->incoming_messages[$msg_id]->getState();
            }
            $info .= \chr($cur_info);
        }
        EventLoop::queue($this->objectCall(...), 'msgs_state_info', ['req_msg_id' => $req_msg_id, 'info' => $info]);*/
    }
}