smi2 / phpClickHouse

src/Transport/StreamInsert.php

<?php

Missing declare(strict_types=1).

namespace ClickHouseDB\Transport;

use ClickHouseDB\Statement;

/**
 * Class StreamInsert

Documentation comment contains forbidden comment "Class StreamInsert".

 * @deprecated

Expected 1 lines between description and annotations, found 0.

Incorrect annotations group.

 * @package ClickHouseDB\Transport

Use of annotation @package is forbidden.

 */
class StreamInsert
{
    /**

Found multi-line comment for property \ClickHouseDB\Transport\StreamInsert::$source with single line content, use one-line comment instead.

     * @var resource
     */
    private $source;

    /**

Found multi-line comment for property \ClickHouseDB\Transport\StreamInsert::$request with single line content, use one-line comment instead.

     * @var CurlerRequest
     */
    private $request;

    /**

Found multi-line comment for property \ClickHouseDB\Transport\StreamInsert::$curlerRolling with single line content, use one-line comment instead.

     * @var CurlerRolling
     */
    private $curlerRolling;

    /**
     * @param resource $source

Expected 11 spaces after parameter type; 1 found

     * @param CurlerRequest $request

Expected 6 spaces after parameter type; 1 found

Method \ClickHouseDB\Transport\StreamInsert::__construct() has useless @param annotation for parameter $request.

     * @param CurlerRolling|null $curlerRolling
     */
    public function __construct($source, CurlerRequest $request, $curlerRolling=null)

Incorrect spacing between argument "$curlerRolling" and equals sign; expected 1 but found 0

Incorrect spacing between default value and equals sign for argument "$curlerRolling"; expected 1 but found 0

Method \ClickHouseDB\Transport\StreamInsert::__construct() does not have native type hint for its parameter $curlerRolling but it should be possible to add it based on @param annotation "CurlerRolling|null".

    {
        if (!is_resource($source)) {

Function is_resource() should not be referenced via a fallback global name, but via a use statement.

Expected 1 lines after "if", found 0.

Expected 1 space after NOT operator; 0 found

            throw new \InvalidArgumentException('Argument $source must be resource');

Class \InvalidArgumentException should not be referenced via a fully qualified name, but via a use statement.

        }
        if ($curlerRolling instanceof CurlerRolling)

Expected 1 lines after "if", found 0.

        {
            $this->curlerRolling = $curlerRolling;
        } else {
            $this->curlerRolling = new CurlerRolling();
        }
        $this->source = $source;

Equals sign not aligned with surrounding assignments; expected 2 spaces but found 1 space

        $this->request = $request;
    }

    /**
     * @param callable $callback function for stream read data

Incorrect annotations group.

     * @return \ClickHouseDB\Statement

Class \ClickHouseDB\Statement should not be referenced via a fully qualified name, but via a use statement.

     * @throws \Exception

Class \Exception should not be referenced via a fully qualified name, but via a use statement.

     */
    public function insert($callback)

Method \ClickHouseDB\Transport\StreamInsert::insert() does not have native type hint for its parameter $callback but it should be possible to add it based on @param annotation "callable".

Method \ClickHouseDB\Transport\StreamInsert::insert() does not have native return type hint for its return value but it should be possible to add it based on @return annotation "\ClickHouseDB\Statement".

    {
        try {
            if (!is_callable($callback)) {

Function is_callable() should not be referenced via a fallback global name, but via a use statement.

Expected 1 space after NOT operator; 0 found

                throw new \InvalidArgumentException('Argument $callback can not be called as a function');

Class \InvalidArgumentException should not be referenced via a fully qualified name, but via a use statement.

            }

            //

Empty comment

            $this->request->header('Transfer-Encoding', 'chunked');
            $this->request->setReadFunction($callback);
            $this->curlerRolling->execOne($this->request, true);
            $statement = new Statement($this->request);
            $statement->error();
            return $statement;

Expected 1 lines before "return", found 0.

        } finally {
            fclose($this->source);

Function fclose() should not be referenced via a fallback global name, but via a use statement.

        }
    }
}