SIP2Client::setDefault() - Code Metrics - Inspection of "Add setDefault and remove no-longer-required membe..." - lordelph/php-sip2 - Measure and Improve Code Quality continuously with Scrutinizer

Completed

Branch — breakout (13405a)

by Paul

created 2018-07-29 10:46 UTC

SIP2Client::setDefault() A

↳ Parent: SIP2Client

Complexity

Conditions	1
Paths	1

Size

Total Lines	3
Code Lines	1

Duplication

Lines	0
Ratio	0 %

Code Coverage

Tests	2
CRAP Score	1

Importance

Changes

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

<?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
     * @throws RuntimeException if connection cannot be established
     */
    public function connect($address, $bind = null)
    {
        $this->logger->debug("SIP2Client: Attempting connection to $address");

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

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

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

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

    /**
     * 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		* @throws RuntimeException if connection cannot be established
168		*/
169	5	public function connect($address, $bind = null)
170		{
171	5	$this->logger->debug("SIP2Client: Attempting connection to $address");
172
173	5	$this->socket = $this->getSocketFactory()->createFromString($address, $scheme);
174
175		try {
176	5	if (!empty($bind)) {
177	1	$this->logger->debug("SIP2Client: binding socket to $bind");
178	1	$this->socket->bind($bind);
179		}
180
181	5	$this->socket->connect($address);
182	1	} catch (\Exception $e) {
183	1	$this->socket->close();
184	1	$this->socket = null;
185	1	$this->logger->error("SIP2Client: Failed to connect: " . $e->getMessage());
186	1	throw new RuntimeException("Connection failure", 0, $e);
187		}
188
189	4	$this->logger->debug("SIP2Client: connected");
190	4	}
191
192		/**
193		* Disconnect from ACS
194		*/
195	1	public function disconnect()
196		{
197	1	$this->socket->close();
198	1	$this->socket = null;
199	1	}
200		}
201

lordelph / php-sip2

Branch — breakout (13405a)

SIP2Client::setDefault() A

Complexity

Size

Duplication

Code Coverage

Importance

Duplication Side-by-Side

Filter issues like