SIP2Client::connect() - Code Metrics - Inspection of "Fix binding mechanism" - lordelph/php-sip2 - Measure and Improve Code Quality continuously with Scrutinizer

Completed

Push — master ( 19120d...b3609d )

by Paul

created 2018-08-20 22:54 UTC

SIP2Client::connect() A

↳ Parent: SIP2Client

Complexity

Conditions	2
Paths	2

Size

Total Lines	13
Code Lines	8

Duplication

Lines	0
Ratio	0 %

Code Coverage

Tests	8
CRAP Score	2

Importance

Changes

Metric	Value
eloc	8
dl	0
loc	13
ccs	8
cts	8
cp	1
rs	10
c	0
b	0
f	0
cc	2
nc	2
nop	3
crap	2

<?php

namespace lordelph\SIP2;

/**
 * SIP2Client Class
 *
 * This class provides a method of communicating with an Integrated
 * Library System using 3M's SIP2 standard.
 *
 * @licence    https://opensource.org/licenses/MIT
 * @copyright  John Wohlers <[email protected]>
 * @copyright  Paul Dixon <[email protected]>
 */

use lordelph\SIP2\Exception\RuntimeException;
use lordelph\SIP2\Request\SIP2Request;
use lordelph\SIP2\Response\SIP2Response;
use Psr\Log\LoggerAwareInterface;
use Psr\Log\LoggerAwareTrait;
use Psr\Log\LoggerInterface;
use Psr\Log\NullLogger;
use Socket\Raw\Factory;
use Socket\Raw\Socket;

/**
 * SIP2Client provides a simple client for SIP2 library services
 *
 * In the specification, and the comments below, 'SC' (or Self Check) denotes the client, and ACS (or Automated
 * Circulation System) denotes the server.
 */
class SIP2Client implements LoggerAwareInterface
{
    use LoggerAwareTrait;

    //-----------------------------------------------------
    // request options
    //-----------------------------------------------------

    /**
     * @var array name=>value request defaults used for every request
     */
    private $default=[];

    //-----------------------------------------------------
    // connection handling
    //-----------------------------------------------------

    /** @var int maximum number of resends in the event of CRC failure */
    public $maxretry = 3;

    /** @var Socket */
    private $socket;

    /** @var Factory injectable factory for creating socket connections */
    private $socketFactory;

    /**
     * Constructor allows you to provide a PSR-3 logger, but you can also use the setLogger method
     * later on.
     *
     * @param LoggerInterface|null $logger
     */
    public function __construct(LoggerInterface $logger = null)
    {
        $this->logger = $logger ?? new NullLogger();
        $this->setDefault('InstitutionId', 'WohlersSIP');
    }

    public function setDefault($name, $value)
    {
        $this->default[$name] = $value;
    }

    /**
     * Allows an alternative socket factory to be injected. The allows us to
     * mock socket connections for testing
     *
     * @param Factory $factory
     */
    public function setSocketFactory(Factory $factory)
    {
        $this->socketFactory = $factory;
    }

    /**
     * Get the current socket factory, creating a default one if necessary
     * @return Factory
     */
    private function getSocketFactory()
    {
        if (is_null($this->socketFactory)) {
            $this->socketFactory = new Factory(); //@codeCoverageIgnore
        }
        return $this->socketFactory;
    }


    /**
     * @param SIP2Request $request
     * @return SIP2Response
     * @throws RuntimeException if server fails to produce a valid response
     */
    public function sendRequest(SIP2Request $request) : SIP2Response
    {
        foreach ($this->default as $name => $value) {
            $request->setDefault($name, $value);
        }

        $raw = $this->getRawResponse($request);
        return SIP2Response::parse($raw);
    }

    private function getRawResponse(SIP2Request $request, $depth = 0)
    {
        $result = '';
        $terminator = '';

        $message = $request->getMessageString();

        $this->logger->debug('SIP2: Sending SIP2 request '.trim($message));
        $this->socket->write($message);

        $this->logger->debug('SIP2: Request Sent, Reading response');

        while ($terminator != "\x0D") {
            //@codeCoverageIgnoreStart
            try {
                $terminator = $this->socket->recv(1, 0);
            } catch (\Exception $e) {
                break;
            }
            //@codeCoverageIgnoreEnd

            $result = $result . $terminator;
        }

        $this->logger->info("SIP2: result={$result}");

        // test message for CRC validity
        if (SIP2Response::checkCRC($result)) {
            $this->logger->debug("SIP2: Message from ACS passed CRC check");
        } else {
            //CRC check failed, we resend the request
            if ($depth < $this->maxretry) {
                $depth++;
                $this->logger->warning("SIP2: Message failed CRC check, retry {$depth})");
                $result = $this->getRawResponse($request, $depth);
            } else {
                $errMsg="SIP2: Failed to get valid CRC after {$this->maxretry} retries.";
                $this->logger->critical($errMsg);
                throw new RuntimeException($errMsg);
            }
        }

        return $result;
    }

    /**
     * Connect to ACS via SIP2
     *
     * The $bind parameter can be useful where a machine which has multiple outbound connections and its important
     * to control which one is used (normally because the remote SIP2 service is firewalled to particular IPs
     *
     * @param string $address ip:port of remote SIP2 service
     * @param string|null $bind local ip to bind socket to
     * @param int $timeout number of seconds to allow for connection to succeed
     */
    public function connect($address, $bind = null, $timeout = 15)
    {
        $this->logger->debug("SIP2Client: Attempting connection to $address");

        try {
            $this->socket = $this->createClient($address, $bind, $timeout);
        } catch (\Exception $e) {
            $this->socket = null;
            $this->logger->error("SIP2Client: Failed to connect: " . $e->getMessage());
            throw new RuntimeException("Connection failure", 0, $e);
        }

        $this->logger->debug("SIP2Client: connected");
    }

    /**
     * A 'missing' factory method which allows us to establish a socket bound to a particular interface
     * @param $address
     * @param $bind
     * @param $timeout
     * @return Socket
     * @throws \Exception
     */
    private function createClient($address, $bind, $timeout) : Socket
    {
        $factory = $this->getSocketFactory();

        $socket = $factory->createFromString($address, $scheme);

        try {
            if (!empty($bind)) {
                $this->logger->debug("SIP2Client: binding socket to $bind");
                $socket->bind($bind);
            }

            if ($timeout === null) {
                $socket->connect($address);
            } else {
                // connectTimeout enables non-blocking mode, so turn blocking on again
                $socket->connectTimeout($address, $timeout);
                $socket->setBlocking(true);
            }
        } catch (\Exception $e) {
            $socket->close();
            throw $e;
        }

        return $socket;
    }


    /**
     * Disconnect from ACS
     */
    public function disconnect()
    {
        $this->socket->close();
        $this->socket = null;
    }
}


1		<?php
2
3		namespace lordelph\SIP2;
4
5		/**
6		* SIP2Client Class
7		*
8		* This class provides a method of communicating with an Integrated
9		* Library System using 3M's SIP2 standard.
10		*
11		* @licence https://opensource.org/licenses/MIT
12		* @copyright John Wohlers <[email protected]>
13		* @copyright Paul Dixon <[email protected]>
14		*/
15
16		use lordelph\SIP2\Exception\RuntimeException;
17		use lordelph\SIP2\Request\SIP2Request;
18		use lordelph\SIP2\Response\SIP2Response;
19		use Psr\Log\LoggerAwareInterface;
20		use Psr\Log\LoggerAwareTrait;
21		use Psr\Log\LoggerInterface;
22		use Psr\Log\NullLogger;
23		use Socket\Raw\Factory;
24		use Socket\Raw\Socket;
25
26		/**
27		* SIP2Client provides a simple client for SIP2 library services
28		*
29		* In the specification, and the comments below, 'SC' (or Self Check) denotes the client, and ACS (or Automated
30		* Circulation System) denotes the server.
31		*/
32		class SIP2Client implements LoggerAwareInterface
33		{
34		use LoggerAwareTrait;
35
36		//-----------------------------------------------------
37		// request options
38		//-----------------------------------------------------
39
40		/**
41		* @var array name=>value request defaults used for every request
42		*/
43		private $default=[];
44
45		//-----------------------------------------------------
46		// connection handling
47		//-----------------------------------------------------
48
49		/** @var int maximum number of resends in the event of CRC failure */
50		public $maxretry = 3;
51
52		/** @var Socket */
53		private $socket;
54
55		/** @var Factory injectable factory for creating socket connections */
56		private $socketFactory;
57
58		/**
59		* Constructor allows you to provide a PSR-3 logger, but you can also use the setLogger method
60		* later on.
61		*
62		* @param LoggerInterface\|null $logger
63		*/
64	5	public function __construct(LoggerInterface $logger = null)
65		{
66	5	$this->logger = $logger ?? new NullLogger();
67	5	$this->setDefault('InstitutionId', 'WohlersSIP');
68	5	}
69
70	5	public function setDefault($name, $value)
71		{
72	5	$this->default[$name] = $value;
73	5	}
74
75		/**
76		* Allows an alternative socket factory to be injected. The allows us to
77		* mock socket connections for testing
78		*
79		* @param Factory $factory
80		*/
81	5	public function setSocketFactory(Factory $factory)
82		{
83	5	$this->socketFactory = $factory;
84	5	}
85
86		/**
87		* Get the current socket factory, creating a default one if necessary
88		* @return Factory
89		*/
90	5	private function getSocketFactory()
91		{
92	5	if (is_null($this->socketFactory)) {
93		$this->socketFactory = new Factory(); //@codeCoverageIgnore
94		}
95	5	return $this->socketFactory;
96		}
97
98
99		/**
100		* @param SIP2Request $request
101		* @return SIP2Response
102		* @throws RuntimeException if server fails to produce a valid response
103		*/
104	3	public function sendRequest(SIP2Request $request) : SIP2Response
105		{
106	3	foreach ($this->default as $name => $value) {
107	3	$request->setDefault($name, $value);
108		}
109
110	3	$raw = $this->getRawResponse($request);
111	2	return SIP2Response::parse($raw);
112		}
113
114	3	private function getRawResponse(SIP2Request $request, $depth = 0)
115		{
116	3	$result = '';
117	3	$terminator = '';
118
119	3	$message = $request->getMessageString();
120
121	3	$this->logger->debug('SIP2: Sending SIP2 request '.trim($message));
122	3	$this->socket->write($message);
123
124	3	$this->logger->debug('SIP2: Request Sent, Reading response');
125
126	3	while ($terminator != "\x0D") {
127		//@codeCoverageIgnoreStart
128		try {
129		$terminator = $this->socket->recv(1, 0);
130		} catch (\Exception $e) {
131		break;
132		}
133		//@codeCoverageIgnoreEnd
134
135	3	$result = $result . $terminator;
136		}
137
138	3	$this->logger->info("SIP2: result={$result}");
139
140		// test message for CRC validity
141	3	if (SIP2Response::checkCRC($result)) {
142	2	$this->logger->debug("SIP2: Message from ACS passed CRC check");
143		} else {
144		//CRC check failed, we resend the request
145	2	if ($depth < $this->maxretry) {
146	2	$depth++;
147	2	$this->logger->warning("SIP2: Message failed CRC check, retry {$depth})");
148	2	$result = $this->getRawResponse($request, $depth);
149		} else {
150	1	$errMsg="SIP2: Failed to get valid CRC after {$this->maxretry} retries.";
151	1	$this->logger->critical($errMsg);
152	1	throw new RuntimeException($errMsg);
153		}
154		}
155
156	2	return $result;
157		}
158
159		/**
160		* Connect to ACS via SIP2
161		*
162		* The $bind parameter can be useful where a machine which has multiple outbound connections and its important
163		* to control which one is used (normally because the remote SIP2 service is firewalled to particular IPs
164		*
165		* @param string $address ip:port of remote SIP2 service
166		* @param string\|null $bind local ip to bind socket to
167		* @param int $timeout number of seconds to allow for connection to succeed
168		*/
169	5	public function connect($address, $bind = null, $timeout = 15)
170		{
171	5	$this->logger->debug("SIP2Client: Attempting connection to $address");
172
173		try {
174	5	$this->socket = $this->createClient($address, $bind, $timeout);
175	1	} catch (\Exception $e) {
176	1	$this->socket = null;
177	1	$this->logger->error("SIP2Client: Failed to connect: " . $e->getMessage());
178	1	throw new RuntimeException("Connection failure", 0, $e);
179		}
180
181	4	$this->logger->debug("SIP2Client: connected");
182	4	}
183
184		/**
185		* A 'missing' factory method which allows us to establish a socket bound to a particular interface
186		* @param $address
187		* @param $bind
188		* @param $timeout
189		* @return Socket
190		* @throws \Exception
191		*/
192	5	private function createClient($address, $bind, $timeout) : Socket
193		{
194	5	$factory = $this->getSocketFactory();
195
196	5	$socket = $factory->createFromString($address, $scheme);
197
198		try {
199	5	if (!empty($bind)) {
200	1	$this->logger->debug("SIP2Client: binding socket to $bind");
201	1	$socket->bind($bind);
202		}
203
204	5	if ($timeout === null) {
205		$socket->connect($address);
206		} else {
207		// connectTimeout enables non-blocking mode, so turn blocking on again
208	5	$socket->connectTimeout($address, $timeout);
209	4	$socket->setBlocking(true);
210		}
211	1	} catch (\Exception $e) {
212	1	$socket->close();
213	1	throw $e;
214		}
215
216	4	return $socket;
217		}
218
219
220		/**
221		* Disconnect from ACS
222		*/
223	1	public function disconnect()
224		{
225	1	$this->socket->close();
226	1	$this->socket = null;
227	1	}
228		}
229

lordelph / php-sip2

Push — master ( 19120d...b3609d )

SIP2Client::connect() A

Complexity

Size

Duplication

Code Coverage

Importance

Duplication Side-by-Side

Filter issues like