1
|
|
|
<?php |
2
|
|
|
|
3
|
|
|
/** |
4
|
|
|
* This file is part of the PHP Generics package. |
5
|
|
|
* |
6
|
|
|
* @package Generics |
7
|
|
|
*/ |
8
|
|
|
namespace Generics\Socket; |
9
|
|
|
|
10
|
|
|
/** |
11
|
|
|
* This class provides a basic client socket implementation |
12
|
|
|
* |
13
|
|
|
* @author Maik Greubel <[email protected]> |
14
|
|
|
*/ |
15
|
|
|
class ClientSocket extends Socket |
16
|
|
|
{ |
17
|
|
|
|
18
|
|
|
/** |
19
|
|
|
* Whether the socket is connected |
20
|
|
|
* |
21
|
|
|
* @var boolean |
22
|
|
|
*/ |
23
|
|
|
private $conntected; |
24
|
|
|
|
25
|
|
|
/** |
26
|
|
|
* Create a new client socket |
27
|
|
|
* |
28
|
|
|
* @param Endpoint $endpoint |
29
|
|
|
* The endpoint to use |
30
|
|
|
* @param resource $clientHandle |
31
|
|
|
* optional existing client handle |
32
|
|
|
*/ |
33
|
15 |
View Code Duplication |
public function __construct(Endpoint $endpoint, $clientHandle = null) |
34
|
|
|
{ |
35
|
15 |
|
$this->endpoint = $endpoint; |
36
|
15 |
|
$this->handle = $clientHandle; |
37
|
15 |
|
$this->conntected = false; |
38
|
|
|
|
39
|
15 |
|
if (! is_resource($clientHandle)) { |
40
|
15 |
|
parent::__construct($endpoint); |
41
|
|
|
} |
42
|
15 |
|
} |
43
|
|
|
|
44
|
|
|
/** |
45
|
|
|
* Connect to remote endpoint |
46
|
|
|
* |
47
|
|
|
* @throws SocketException |
48
|
|
|
*/ |
49
|
13 |
|
public function connect() |
50
|
|
|
{ |
51
|
13 |
|
if (!is_resource($this->handle)) { |
52
|
1 |
|
throw new SocketException("Socket is not available"); |
53
|
|
|
} |
54
|
12 |
View Code Duplication |
if (! @socket_connect($this->handle, $this->endpoint->getAddress(), $this->endpoint->getPort())) { |
|
|
|
|
55
|
1 |
|
$code = socket_last_error($this->handle); |
56
|
1 |
|
throw new SocketException(socket_strerror($code), array(), $code); |
57
|
|
|
} |
58
|
11 |
|
$this->conntected = true; |
59
|
11 |
|
} |
60
|
|
|
|
61
|
|
|
/** |
62
|
|
|
* Disconnects the socket |
63
|
|
|
* |
64
|
|
|
* @throws SocketException |
65
|
|
|
*/ |
66
|
5 |
|
public function disconnect() |
67
|
|
|
{ |
68
|
5 |
|
if (! $this->conntected) { |
69
|
|
|
throw new SocketException("Socket is not connected"); |
70
|
|
|
} |
71
|
|
|
|
72
|
5 |
|
$this->close(); |
73
|
5 |
|
} |
74
|
|
|
|
75
|
|
|
/** |
76
|
|
|
* Whether the client is connected |
77
|
|
|
* |
78
|
|
|
* @return bool |
79
|
|
|
*/ |
80
|
12 |
|
public function isConnected():bool |
81
|
|
|
{ |
82
|
12 |
|
return $this->conntected; |
83
|
|
|
} |
84
|
|
|
|
85
|
|
|
/** |
86
|
|
|
* |
87
|
|
|
* @see \Generics\Socket\ClientSocket::disconnect() |
88
|
|
|
*/ |
89
|
15 |
|
public function close() |
90
|
|
|
{ |
91
|
15 |
|
parent::close(); |
92
|
15 |
|
$this->conntected = false; |
93
|
15 |
|
} |
94
|
|
|
|
95
|
|
|
/** |
96
|
|
|
* |
97
|
|
|
* {@inheritdoc} |
98
|
|
|
* @see \Generics\Socket\Socket::isWriteable() |
99
|
|
|
*/ |
100
|
1 |
|
public function isWriteable():bool |
101
|
|
|
{ |
102
|
1 |
|
if (! $this->isConnected()) { |
103
|
1 |
|
return false; |
104
|
|
|
} |
105
|
|
|
|
106
|
1 |
|
return parent::isWriteable(); |
107
|
|
|
} |
108
|
|
|
} |
109
|
|
|
|
Duplicated code is one of the most pungent code smells. If you need to duplicate the same code in three or more different places, we strongly encourage you to look into extracting the code into a single class or operation.
You can also find more detailed suggestions in the “Code” section of your repository.