FastAPNS\ClientStreamSocket

Complexity

Total Complexity

16

Size/Duplication

Total Lines	102
Duplicated Lines	0 %

Coupling/Cohesion

Components	1
Dependencies	0

Importance

Changes	2
Bugs	0	Features	0

9 Methods

Rating	Name	Duplication	Size	Complexity
A	__construct()	0	6	1
A	connect()	0	12	2
A	disconnect()	0	3	1
A	reconnect()	0	4	1
A	isConnected()	0	3	1
A	write()	0	9	2
A	read()	0	5	1
A	readFeedback()	0	13	3
A	status()	0	17	4

<?php

namespace FastAPNS;

class ClientStreamSocket {
  const FASTAPNS_DEFAULT_GATEWAY_HOST = 'gateway.push.apple.com';
  const FASTAPNS_DEFAULT_GATEWAY_PORT = 2195;
  const FASTAPNS_STATUS_TIMEOUT = 3;

  const FASTAPNS_WRITE_SUCCESS = 1;
  const FASTAPNS_STATUS_WRITABLE = 2;
  const FASTAPNS_STATUS_READABLE = 3;
  const FASTAPNS_STATUS_NONE = 4;

  private $local_cert;
  private $passphrase;
  private $host;
  private $port;

  private $stream_socket_client;

  public function __construct($local_cert, $passphrase = '', $host = ClientStreamSocket::FASTAPNS_DEFAULT_GATEWAY_HOST, $port = ClientStreamSocket::FASTAPNS_DEFAULT_GATEWAY_PORT) {
    $this->local_cert = $local_cert;
    $this->passphrase = $passphrase;
    $this->host = $host;
    $this->port = $port;
  }

  public function connect() {
    $streamContext = stream_context_create();

    stream_context_set_option($streamContext, 'ssl', 'local_cert', $this->local_cert);
    stream_context_set_option($streamContext, 'ssl', 'passphrase', $this->passphrase);

    $this->stream_socket_client = stream_socket_client('ssl://' . $this->host . ':' . $this->port, $error, $errorString, 2, STREAM_CLIENT_CONNECT, $streamContext);

    if (!empty($error)) {
      throw new \Exception('Error creating stream socket client: ' . $errorString);
    }
  }

  public function disconnect() {
    fclose($this->stream_socket_client);
  }

  public function reconnect() {
    $this->disconnect();
    $this->connect();
  }

  public function isConnected() {
    return !empty($this->stream_socket_client);
  }

  /**
   * @param $notification_bytes
   * @return bool
   */
  public function write($notification_bytes) {
    try {
      fwrite($this->stream_socket_client, $notification_bytes);

      return ClientStreamSocket::FASTAPNS_WRITE_SUCCESS;
    } catch (\Exception $e) {
      return $this->status();
    }
  }

  public function read() {
    $bytes = fread($this->stream_socket_client, 6);

    return unpack("C1command/C1status/N1identifier", $bytes);
  }

  public function readFeedback() {
    $feedback = array();

    while(!feof($this->stream_socket_client)) {
      $data = fread($this->stream_socket_client, 38);

      if(strlen($data)) {
        $feedback[] = unpack("N1timestamp/n1length/H*devtoken", $data);
      }
    }

    return $feedback;
  }

  public function status($readOnly = FALSE) {
    $read = array($this->stream_socket_client);
    $write = $readOnly ? NULL : array($this->stream_socket_client);
    $except = NULL;

    stream_select($read, $write, $except, ClientStreamSocket::FASTAPNS_STATUS_TIMEOUT);

    if (!empty($write)) {
      return ClientStreamSocket::FASTAPNS_STATUS_WRITABLE;
    }

    if (!empty($read)) {
      return ClientStreamSocket::FASTAPNS_STATUS_READABLE;
    }

    return ClientStreamSocket::FASTAPNS_STATUS_NONE;
  }
}