Commit 68d6287

committed

More simple api

1 parent e89604e commit 68d6287Copy full SHA for 68d6287

File tree

1 file changed

+32

-82

lines changed

Server.php

1 file changed

+32

-82

lines changed

`‎Server.php‎`

Lines changed: 32 additions & 82 deletions

Original file line number	Diff line number	Diff line change
`@@ -15,124 +15,74 @@`
`15`	`15`	`*`
`16`	`16`	`* @package WebSocket`
`17`	`17`	`* @author Gemblue`
`18`		`- *`
`19`	`18`	`*/`
`20`	`19`
`21`	`20`	`class WebSocket {`
`22`	`21`
`23`		`- public $address;`
`24`		`- public $port;`
	`22`	`+ /** Props */`
`25`	`23`	`public $server;`
`26`	`24`	`public $client;`
`27`		`- public $key;`
`28`	`25`
`29`	`26`	`/**`
`30`		`- * Construct a socket`
	`27`	`+ * Create a socket`
`31`	`28`	`*/`
`32`		`- public function __construct(string $address, int $port) {`
	`29`	`+ public function create(string $address, int $port) {`
`33`	`30`
`34`		`- $this->address = $address;`
`35`		`- $this->post = $port;`
	`31`	`+ // Create socket.`
	`32`	`+ $this->server = socket_create(AF_INET, SOCK_STREAM, SOL_TCP);`
`36`	`33`
`37`		`- if (!$this->server = socket_create(AF_INET, SOCK_STREAM, SOL_TCP)) {`
`38`		`- throw new Exception('Failed to create a socket');`
`39`		`- }`
`40`		`- }`
`41`		`-`
`42`		`- public function setOption() {`
`43`		`-`
`44`		`- if (!socket_set_option($this->server, SOL_SOCKET, SO_REUSEADDR, 1)) {`
`45`		`- throw new Exception('Failed to set option');`
`46`		`- }`
`47`		`-`
`48`		`- return $this;`
`49`		`-`
`50`		`- }`
`51`		`-`
`52`		`- public function bind() {`
`53`		`-`
`54`		`-`
`55`		`- if (!socket_bind($this->server, $this->address, $this->port)) {`
`56`		`- throw new Exception('Failed to bind');`
`57`		`- }`
`58`		`-`
`59`		`- return $this;`
`60`		`-`
`61`		`- }`
`62`		`-`
`63`		`- public function listen() {`
	`34`	`+ socket_set_option($this->server, SOL_SOCKET, SO_REUSEADDR, 1);`
	`35`	`+ socket_bind($this->server, $address, $port);`
	`36`	`+ socket_listen($this->server);`
`64`	`37`
`65`		`- if (!socket_listen($this->server)) {`
`66`		`- throw new Exception('Failed to listen');`
`67`		`- }`
`68`		`-`
`69`		`- if (!$this->client = socket_accept($this->server)) {`
`70`		`- throw new Exception('Failed to accept');`
`71`		`- }`
`72`		`-`
`73`		`- return $this;`
`74`		`-`
`75`	`38`	`}`
`76`	`39`
`77`	`40`	`/**`
`78`		`- * Handshake`
	`41`	`+ * Handshake.`
`79`	`42`	`*`
`80`		`- * Writing websocket protocol headers`
	`43`	`+ * Simple handshake to client with headers.`
`81`	`44`	`*/`
`82`	`45`	`public function handshake() {`
	`46`	`+ // Set client.`
	`47`	`+ $this->client = socket_accept($this->server);`
`83`	`48`
	`49`	`+ // Read client.`
`84`	`50`	`$request = socket_read($this->client, 5000);`
`85`		`-`
`86`		`- // Match websocket key`
`87`		`- preg_match('#Sec-WebSocket-Key: (.*)\r\n#', $request, $matches);`
`88`	`51`
`89`		`- $this->key = base64_encode(pack(`
	`52`	`+ preg_match('#Sec-WebSocket-Key: (.*)\r\n#', $request, $matches);`
	`53`	`+ $key = base64_encode(pack(`
`90`	`54`	`'H*',`
`91`	`55`	`sha1($matches[1] . '258EAFA5-E914-47DA-95CA-C5AB0DC85B11')`
`92`	`56`	`));`
`93`		`-`
`94`		`- // Build websocket content header!`
	`57`	`+`
	`58`	`+ // Setup headers.`
`95`	`59`	`$headers = "HTTP/1.1 101 Switching Protocols\r\n";`
`96`	`60`	`$headers .= "Upgrade: websocket\r\n";`
`97`		`- $headers .= "server: Upgrade\r\n";`
	`61`	`+ $headers .= "Connection: Upgrade\r\n";`
`98`	`62`	`$headers .= "Sec-WebSocket-Version: 13\r\n";`
`99`		`- $headers .= "Sec-WebSocket-Accept: {$this->key}\r\n\r\n";`
	`63`	`+ $headers .= "Sec-WebSocket-Accept: $key\r\n\r\n";`
`100`	`64`
`101`		`- // Writing a content.`
	`65`	`+ // Write headers.`
`102`	`66`	`socket_write($this->client, $headers, strlen($headers));`
`103`		`-`
`104`		`- // Return log message, outside the loop.`
`105`		`- echo "Writing headers .. \n";`
`106`		`-`
	`67`	`+`
`107`	`68`	`}`
`108`	`69`
`109`	`70`	`/**`
`110`		`- * Broadcast`
	`71`	`+ * Emit`
`111`	`72`	`*`
`112`		`- * Writing socket content with loop.`
	`73`	`+ * Method to emit message.`
`113`	`74`	`*/`
`114`		`- public function broadcast(string$message) {`
	`75`	`+ public function emit($message) {`
`115`	`76`
`116`		`- socket_write($this->client, chr(129) . chr(strlen($message)) . $message);`
`117`		`-`
`118`		`- }`
`119`		`-`
`120`		`- /**`
`121`		`- * Close.`
`122`		`- */`
`123`		`- public function __destruct()`
`124`		`- {`
`125`		`- socket_close($this->socket);`
`126`		`- }`
	`77`	`+ $response = chr(129) . chr(strlen($message)) . $message;`
	`78`	`+ socket_write($this->client, $response);`
`127`	`79`
	`80`	`+ }`
`128`	`81`	`}`
`129`	`82`
`130`		`-// Mantap, sekarang kita coba.`
`131`		`-$websocket = new WebSocket("127.0.0.1", 12345);`
`132`		`-`
`133`		`-$websocket->setOption()`
`134`		`- ->bind()`
`135`		`- ->listen()`
`136`		`- ->handshake();`
	`83`	`+// Let's consume the class.`
	`84`	`+$websocket = new WebSocket();`
`137`	`85`
`138`		`-$websocket->broadcast('Halo kakak!');`
	`86`	`+$websocket->create("127.0.0.1", 12345);`
	`87`	`+$websocket->handshake();`
	`88`	`+$websocket->emit('Halo kakak, lagi apa!');`

0 commit comments

Comments

(0)

Navigation Menu

Search code, repositories, users, issues, pull requests...

Provide feedback

Saved searches

Use saved searches to filter your results more quickly

Uh oh!

Commit 68d6287

File tree

1 file changed

1 file changed

`‎Server.php‎`

0 commit comments