Plasma\Drivers\MySQL\Messages\OkResponseMessage

Complexity

Total Complexity

10

Size/Duplication

Total Lines	124
Duplicated Lines	0 %

Test Coverage

Coverage

74.07%

Importance

Changes	2
Bugs	0	Features	0

5 Methods

Rating	Name	Duplication	Size	Complexity
A	getParser()	0	2	1
A	__construct()	0	2	1
A	getID()	0	2	1
A	parseMessage()	0	29	6
A	setParserState()	0	2	1

<?php
/**
 * Plasma Driver MySQL component
 * Copyright 2018-2019 PlasmaPHP, All Rights Reserved
 *
 * Website: https://github.com/PlasmaPHP
 * License: https://github.com/PlasmaPHP/driver-mysql/blob/master/LICENSE
*/

namespace Plasma\Drivers\MySQL\Messages;

/**
 * Represents an Ok Response Message.
 */
class OkResponseMessage implements \Plasma\Drivers\MySQL\Messages\MessageInterface {
    /**
     * Count of affected rows by the last query.
     * @var int
     */
    public $affectedRows;
    
    /**
     * Last inserted ID by the last `INSERT` query.
     * @var int
     */
    public $lastInsertedID;
    
    /**
     * The server status flags.
     * @var int
     * @see \Plasma\Drivers\MySQL\StatusFlags
     */
    public $statusFlags;
    
    /**
     * Count of warnings.
     * @var int
     */
    public $warningsCount;
    
    /**
     * Server session information, if any.
     * @var string|null
     */
    public $sessionInfo;
    
    /**
     * Server session state changes, if any.
     * @var string|null
     */
    public $sessionStateChanges;
    
    /**
     * Human readable status information, if any.
     * @var string|null
     */
    public $info;
    
    /**
     * @var \Plasma\Drivers\MySQL\ProtocolParser
     * @internal
     */
    protected $parser;
    
    /**
     * Constructor.
     * @param \Plasma\Drivers\MySQL\ProtocolParser  $parser
     * @internal
     */
    function __construct(\Plasma\Drivers\MySQL\ProtocolParser $parser) {
        $this->parser = $parser;
    }
    
    /**
     * Get the identifier for the packet.
     * @return string
     * @internal
     */
    static function getID(): string {
        return "\x00";
    }
    
    /**
     * Parses the message, once the complete string has been received.
     * Returns false if not enough data has been received, or the remaining buffer.
     * @param \Plasma\BinaryBuffer  $buffer
     * @return bool
     * @throws \Plasma\Drivers\MySQL\Messages\ParseException
     * @internal
     */
    function parseMessage(\Plasma\BinaryBuffer $buffer): bool {
        try {
            $handshake = $this->parser->getHandshakeMessage();
            if(!$handshake) {
                throw new \Plasma\Drivers\MySQL\Messages\ParseException('No handshake message when receiving ok response packet');
            }
            
            $this->affectedRows = $buffer->readIntLength();
            $this->lastInsertedID = $buffer->readIntLength();
            
            $this->statusFlags = $buffer->readInt2();
            $this->warningsCount = $buffer->readInt2();
            
            if(($handshake->capability & \Plasma\Drivers\MySQL\CapabilityFlags::CLIENT_SESSION_TRACK) !== 0) {
                if($buffer->getSize() > 0) {
                    $this->sessionInfo = $buffer->readStringLength();
                    
                    if(($this->statusFlags & \Plasma\Drivers\MySQL\StatusFlags::SERVER_SESSION_STATE_CHANGED) !== 0) {
                        $this->sessionStateChanges = $buffer->readStringLength();
                    }
                }
            } else {
                $this->info = $buffer->getContents();
                $buffer->clear();
            }
            
            return true;
        } catch (\OverflowException $e) {
            return false;
        }
    }
    
    /**
     * Get the parser which created this message.
     * @return \Plasma\Drivers\MySQL\ProtocolParser
     * @internal
     */
    function getParser(): \Plasma\Drivers\MySQL\ProtocolParser {
        return $this->parser;
    }
    
    /**
     * Sets the parser state, if necessary. If not, return `-1`.
     * @return int
     * @internal
     */
    function setParserState(): int {
        return \Plasma\Drivers\MySQL\ProtocolParser::STATE_OK;
    }
}