ytake / php-presto-client

src/AuthenticatedClientSession.php

Indentation +147 added lines, -147 removed lines

@@ -27,190 +27,190 @@
  * @author Yuuki Takezawa <yuuki.takezawa@comnect.jp.net>
  */
 class AuthenticatedClientSession {
-  /** @var string */
-  protected $host;
-
-  /** @var string */
-  protected $catalog;
-
-  /** @var UuidInterface */
-  protected $transactionId;
-
-  /** @var string */
-  protected $schema = 'default';
-
-  /** @var string */
-  protected $header = [];
-
-  /** @var string */
-  protected $user = 'presto';
-  /** @var string */
-  protected $username = 'admin';
-  /** @var string */
-  protected $password = 'password';
-  /** @var string */
-  protected $source = PrestoHeaders::PRESTO_SOURCE_VALUE;
-
-  /** @var Property[] */
-  protected $property = [];
-
-  /** @var PreparedStatement[] */
-  protected $preparedStatement = [];
-
-  /**
-   * PrestoSession constructor.
-   *
-   * @param string $host
-   * @param string $catalog
-   */
-  public function __construct(string $host, string $catalog, string $username, string $password)
-  {
+    /** @var string */
+    protected $host;
+
+    /** @var string */
+    protected $catalog;
+
+    /** @var UuidInterface */
+    protected $transactionId;
+
+    /** @var string */
+    protected $schema = 'default';
+
+    /** @var string */
+    protected $header = [];
+
+    /** @var string */
+    protected $user = 'presto';
+    /** @var string */
+    protected $username = 'admin';
+    /** @var string */
+    protected $password = 'password';
+    /** @var string */
+    protected $source = PrestoHeaders::PRESTO_SOURCE_VALUE;
+
+    /** @var Property[] */
+    protected $property = [];
+
+    /** @var PreparedStatement[] */
+    protected $preparedStatement = [];
+
+    /**
+     * PrestoSession constructor.
+     *
+     * @param string $host
+     * @param string $catalog
+     */
+    public function __construct(string $host, string $catalog, string $username, string $password)
+    {
     $this->host = $host;
     $this->catalog = $catalog;
     $this->username = $username;
     $this->password = $password;
-  }
+    }
 
-  /**
-   * @param string $schema
-   */
-  public function setSchema(string $schema)
-  {
+    /**
+     * @param string $schema
+     */
+    public function setSchema(string $schema)
+    {
     $this->schema = $schema;
-  }
+    }
 
-  /**
-   * @param array $header
-   */
-  public function setHeader(array $header)
-  {
+    /**
+     * @param array $header
+     */
+    public function setHeader(array $header)
+    {
     $this->header = $header;
-  }
+    }
 
-  /**
-   * @param string $user
-   */
-  public function setUser(string $user)
-  {
+    /**
+     * @param string $user
+     */
+    public function setUser(string $user)
+    {
     $this->user = $user;
-  }
+    }
 
-  /**
-   * @param string $source
-   */
-  public function setSource(string $source)
-  {
+    /**
+     * @param string $source
+     */
+    public function setSource(string $source)
+    {
     $this->source = $source;
-  }
+    }
 
-  /**
-   * @param UuidInterface $transactionId
-   */
-  public function setTransactionId(UuidInterface $transactionId)
-  {
+    /**
+     * @param UuidInterface $transactionId
+     */
+    public function setTransactionId(UuidInterface $transactionId)
+    {
     $this->transactionId = $transactionId;
-  }
+    }
 
-  /**
-   * @param Property $property
-   */
-  public function setProperty(Property $property)
-  {
+    /**
+     * @param Property $property
+     */
+    public function setProperty(Property $property)
+    {
     $this->property[] = $property;
-  }
+    }
 
-  /**
-   * @param PreparedStatement $preparedStatement
-   */
-  public function setPreparedStatement(PreparedStatement $preparedStatement)
-  {
+    /**
+     * @param PreparedStatement $preparedStatement
+     */
+    public function setPreparedStatement(PreparedStatement $preparedStatement)
+    {
     $this->preparedStatement[] = $preparedStatement;
-  }
+    }
 
-  /**
-   * @return Property[]
-   */
-  public function getProperty(): array
-  {
+    /**
+     * @return Property[]
+     */
+    public function getProperty(): array
+    {
     return $this->property;
-  }
+    }
 
-  /**
-   * @return PreparedStatement[]
-   */
-  public function getPreparedStatement(): array
-  {
+    /**
+     * @return PreparedStatement[]
+     */
+    public function getPreparedStatement(): array
+    {
     return $this->preparedStatement;
-  }
+    }
 
-  /**
-   * @return string
-   */
-  public function getHost(): string
-  {
+    /**
+     * @return string
+     */
+    public function getHost(): string
+    {
     return $this->host;
-  }
+    }
 
-  /**
-   * @return string
-   */
-  public function getCatalog(): string
-  {
+    /**
+     * @return string
+     */
+    public function getCatalog(): string
+    {
     return $this->catalog;
-  }
+    }
 
-  /**
-   * @return array
-   */
-  public function getHeader(): array
-  {
+    /**
+     * @return array
+     */
+    public function getHeader(): array
+    {
     return $this->header;
-  }
+    }
 
-  /**
-   * @return string
-   */
-  public function getSchema(): string
-  {
+    /**
+     * @return string
+     */
+    public function getSchema(): string
+    {
     return $this->schema;
-  }
+    }
 
-  /**
-   * @return string
-   */
-  public function getUser(): string
-  {
+    /**
+     * @return string
+     */
+    public function getUser(): string
+    {
     return $this->user;
-  }
+    }
 
-  /**
-   * @return string
-   */
-  public function getSource(): string
-  {
+    /**
+     * @return string
+     */
+    public function getSource(): string
+    {
     return $this->source;
-  }
-  /**
-   * @return string
-   */
-  public function getUsername(): string
-  {
+    }
+    /**
+     * @return string
+     */
+    public function getUsername(): string
+    {
     return $this->username;
-  }
-  /**
-   * @return string
-   */
-  public function getPassword(): string
-  {
+    }
+    /**
+     * @return string
+     */
+    public function getPassword(): string
+    {
     return $this->password;
-  }
+    }
 
-  /**
-   * @return UuidInterface|null
-   */
-  public function getTransactionId()
-  {
+    /**
+     * @return UuidInterface|null
+     */
+    public function getTransactionId()
+    {
     return $this->transactionId;
-  }
+    }
 
 }

src/StatementClient.php

Spacing +7 added lines, -7 removed lines

@@ -94,8 +94,8 @@ 
         $this->headers = array_merge(
             [
                 PrestoHeaders::PRESTO_USER => $this->session->getUser(),
-                'User-Agent'               => $this->session->getSource() . '/' . PrestoHeaders::VERSION,
-                'Authorization'            => 'Basic ' . base64_encode($this->session->getUsername() . ':' . $this->session->getPassword()),
+                'User-Agent'               => $this->session->getSource().'/'.PrestoHeaders::VERSION,
+                'Authorization'            => 'Basic '.base64_encode($this->session->getUsername().':'.$this->session->getPassword()),
             ],
             $this->session->getHeader()
         );
@@ -119,7 +119,7 @@ 
             $sessions = [];
             /** @var Property $property */
             foreach ($sessionProperty as $property) {
-                $sessions[] = $property->getKey() . '=' . $property->getValue();
+                $sessions[] = $property->getKey().'='.$property->getValue();
             }
             $request = $request->withAddedHeader(
                 PrestoHeaders::PRESTO_SESSION,
@@ -131,7 +131,7 @@ 
             $statements = [];
             foreach ($preparedStatements as $preparedStatement) {
                 $statements[] = urlencode($preparedStatement->getKey())
-                    . '=' . urlencode($preparedStatement->getValue());
+                    . '='.urlencode($preparedStatement->getValue());
             }
             $request = $request->withAddedHeader(
                 PrestoHeaders::PRESTO_PREPARED_STATEMENT,
@@ -152,7 +152,7 @@ 
     public function execute(int $timeout = 500000, bool $debug = false)
     {
         $normalize = UriNormalizer::normalize(
-            new Uri($this->session->getHost() . StatementClient::STATEMENT_URI),
+            new Uri($this->session->getHost().StatementClient::STATEMENT_URI),
             UriNormalizer::REMOVE_DUPLICATE_SLASHES
         );
         $request = new Request(RequestMethodInterface::METHOD_POST, $normalize, $this->headers);
@@ -212,9 +212,9 @@ 
                 'timeout' => $timeout,
                 'debug'   => $debug,
             ]);
-            $promise->then(function (ResponseInterface $response) {
+            $promise->then(function(ResponseInterface $response) {
                 $this->fulfilled = (StatusCodeInterface::STATUS_NO_CONTENT === $response->getStatusCode());
-            }, function (RequestException $e) {
+            }, function(RequestException $e) {
                 throw new RequestFailedException($e->getMessage(), $e->getCode(), $e);
             });
             $promise->wait();