@@ -17,67 +17,67 @@ |
||
| 17 | 17 | */ |
| 18 | 18 | interface ShellInterface |
| 19 | 19 | { |
| 20 | - /** |
|
| 21 | - * Prints the name of current/workinf directory |
|
| 22 | - */ |
|
| 23 | - public function pwd(); |
|
| 20 | + /** |
|
| 21 | + * Prints the name of current/workinf directory |
|
| 22 | + */ |
|
| 23 | + public function pwd(); |
|
| 24 | 24 | |
| 25 | - /** |
|
| 26 | - * Lists all directory contents |
|
| 27 | - * |
|
| 28 | - * @param string $path |
|
| 29 | - */ |
|
| 30 | - public function ls($path); |
|
| 25 | + /** |
|
| 26 | + * Lists all directory contents |
|
| 27 | + * |
|
| 28 | + * @param string $path |
|
| 29 | + */ |
|
| 30 | + public function ls($path); |
|
| 31 | 31 | |
| 32 | - /** |
|
| 33 | - * Changes the current/working directory |
|
| 34 | - * |
|
| 35 | - * @param string $path |
|
| 36 | - */ |
|
| 37 | - public function cd($path); |
|
| 32 | + /** |
|
| 33 | + * Changes the current/working directory |
|
| 34 | + * |
|
| 35 | + * @param string $path |
|
| 36 | + */ |
|
| 37 | + public function cd($path); |
|
| 38 | 38 | |
| 39 | - /** |
|
| 40 | - * Creates a file |
|
| 41 | - * |
|
| 42 | - * @param string $file |
|
| 43 | - */ |
|
| 44 | - public function touch($file); |
|
| 39 | + /** |
|
| 40 | + * Creates a file |
|
| 41 | + * |
|
| 42 | + * @param string $file |
|
| 43 | + */ |
|
| 44 | + public function touch($file); |
|
| 45 | 45 | |
| 46 | - /** |
|
| 47 | - * Deletes files or directories |
|
| 48 | - * |
|
| 49 | - * @param string $file |
|
| 50 | - */ |
|
| 51 | - public function rm($file); |
|
| 46 | + /** |
|
| 47 | + * Deletes files or directories |
|
| 48 | + * |
|
| 49 | + * @param string $file |
|
| 50 | + */ |
|
| 51 | + public function rm($file); |
|
| 52 | 52 | |
| 53 | - /** |
|
| 54 | - * Prints the name of current/workinf directory |
|
| 55 | - * |
|
| 56 | - * @param string $source |
|
| 57 | - * @param string $dest |
|
| 58 | - */ |
|
| 59 | - public function cp($source, $dest); |
|
| 53 | + /** |
|
| 54 | + * Prints the name of current/workinf directory |
|
| 55 | + * |
|
| 56 | + * @param string $source |
|
| 57 | + * @param string $dest |
|
| 58 | + */ |
|
| 59 | + public function cp($source, $dest); |
|
| 60 | 60 | |
| 61 | - /** |
|
| 62 | - * Moves or renames files |
|
| 63 | - * |
|
| 64 | - * @param string $oldfile |
|
| 65 | - * @param string $newfile |
|
| 66 | - */ |
|
| 67 | - public function mv($oldfile, $newfile); |
|
| 61 | + /** |
|
| 62 | + * Moves or renames files |
|
| 63 | + * |
|
| 64 | + * @param string $oldfile |
|
| 65 | + * @param string $newfile |
|
| 66 | + */ |
|
| 67 | + public function mv($oldfile, $newfile); |
|
| 68 | 68 | |
| 69 | - /** |
|
| 70 | - * Creates directories |
|
| 71 | - * |
|
| 72 | - * @param string $dir |
|
| 73 | - * @param string $dest |
|
| 74 | - */ |
|
| 75 | - public function mkdir($dir, $dest); |
|
| 69 | + /** |
|
| 70 | + * Creates directories |
|
| 71 | + * |
|
| 72 | + * @param string $dir |
|
| 73 | + * @param string $dest |
|
| 74 | + */ |
|
| 75 | + public function mkdir($dir, $dest); |
|
| 76 | 76 | |
| 77 | - /** |
|
| 78 | - * Deletes empty directories |
|
| 79 | - * |
|
| 80 | - * @param string $dir |
|
| 81 | - */ |
|
| 82 | - public function rmdir($dir); |
|
| 77 | + /** |
|
| 78 | + * Deletes empty directories |
|
| 79 | + * |
|
| 80 | + * @param string $dir |
|
| 81 | + */ |
|
| 82 | + public function rmdir($dir); |
|
| 83 | 83 | } |
| 84 | 84 | \ No newline at end of file |
@@ -119,7 +119,7 @@ discard block |
||
| 119 | 119 | |
| 120 | 120 | throw new \RuntimeException("Could not create the socket"); |
| 121 | 121 | } |
| 122 | - } |
|
| 122 | + } |
|
| 123 | 123 | |
| 124 | 124 | /** |
| 125 | 125 | * Binds the socket |
@@ -143,8 +143,8 @@ discard block |
||
| 143 | 143 | * |
| 144 | 144 | * @return bool |
| 145 | 145 | */ |
| 146 | - public function close() |
|
| 147 | - { |
|
| 146 | + public function close() |
|
| 147 | + { |
|
| 148 | 148 | return socket_close($this->socket); |
| 149 | - } |
|
| 149 | + } |
|
| 150 | 150 | } |
| 151 | 151 | \ No newline at end of file |
@@ -26,18 +26,18 @@ discard block |
||
| 26 | 26 | * |
| 27 | 27 | * @return string |
| 28 | 28 | */ |
| 29 | - public function read($socket) |
|
| 30 | - { |
|
| 31 | - if (($message = @socket_read($socket, 1024)) === false) |
|
| 32 | - { |
|
| 33 | - $errno = socket_last_error(); |
|
| 34 | - $this->error($errno, socket_strerror($errno)); |
|
| 29 | + public function read($socket) |
|
| 30 | + { |
|
| 31 | + if (($message = @socket_read($socket, 1024)) === false) |
|
| 32 | + { |
|
| 33 | + $errno = socket_last_error(); |
|
| 34 | + $this->error($errno, socket_strerror($errno)); |
|
| 35 | 35 | |
| 36 | - throw new \RuntimeException("Could not read message from client socket"); |
|
| 37 | - } |
|
| 36 | + throw new \RuntimeException("Could not read message from client socket"); |
|
| 37 | + } |
|
| 38 | 38 | |
| 39 | - return $message; |
|
| 40 | - } |
|
| 39 | + return $message; |
|
| 40 | + } |
|
| 41 | 41 | |
| 42 | 42 | /** |
| 43 | 43 | * Sends a message to client socket |
@@ -49,18 +49,18 @@ discard block |
||
| 49 | 49 | * |
| 50 | 50 | * @return integer |
| 51 | 51 | */ |
| 52 | - public function send($socket, $message) |
|
| 53 | - { |
|
| 54 | - if (($bytes = @socket_write($socket, $message, strlen($message))) === false) |
|
| 55 | - { |
|
| 56 | - $errno = socket_last_error(); |
|
| 57 | - $this->error($errno, socket_strerror($errno)); |
|
| 52 | + public function send($socket, $message) |
|
| 53 | + { |
|
| 54 | + if (($bytes = @socket_write($socket, $message, strlen($message))) === false) |
|
| 55 | + { |
|
| 56 | + $errno = socket_last_error(); |
|
| 57 | + $this->error($errno, socket_strerror($errno)); |
|
| 58 | 58 | |
| 59 | - throw new \RuntimeException("Could not send message to the client socket"); |
|
| 60 | - } |
|
| 59 | + throw new \RuntimeException("Could not send message to the client socket"); |
|
| 60 | + } |
|
| 61 | 61 | |
| 62 | - return $bytes; |
|
| 63 | - } |
|
| 62 | + return $bytes; |
|
| 63 | + } |
|
| 64 | 64 | |
| 65 | 65 | /** |
| 66 | 66 | * Sets socket to listening |
@@ -71,54 +71,54 @@ discard block |
||
| 71 | 71 | * |
| 72 | 72 | * @return null |
| 73 | 73 | */ |
| 74 | - public function listen(Array $eventHandlers = array()) |
|
| 75 | - { |
|
| 76 | - $event = $eventHandlers; |
|
| 77 | - $clousure = function(){}; |
|
| 74 | + public function listen(Array $eventHandlers = array()) |
|
| 75 | + { |
|
| 76 | + $event = $eventHandlers; |
|
| 77 | + $clousure = function(){}; |
|
| 78 | 78 | |
| 79 | - if (!array_key_exists('success', $event)) |
|
| 80 | - $event["success"] = $clousure; |
|
| 79 | + if (!array_key_exists('success', $event)) |
|
| 80 | + $event["success"] = $clousure; |
|
| 81 | 81 | |
| 82 | - if (!array_key_exists('error', $event)) |
|
| 83 | - $event["error"] = $clousure; |
|
| 82 | + if (!array_key_exists('error', $event)) |
|
| 83 | + $event["error"] = $clousure; |
|
| 84 | 84 | |
| 85 | - $listener = false; |
|
| 85 | + $listener = false; |
|
| 86 | 86 | |
| 87 | - if (!($listener = @socket_listen($this->socket, 30))) |
|
| 88 | - { |
|
| 89 | - $errno = socket_last_error(); |
|
| 90 | - $this->error($errno, socket_strerror($errno)); |
|
| 87 | + if (!($listener = @socket_listen($this->socket, 30))) |
|
| 88 | + { |
|
| 89 | + $errno = socket_last_error(); |
|
| 90 | + $this->error($errno, socket_strerror($errno)); |
|
| 91 | 91 | |
| 92 | - throw new \RuntimeException("Could not set socket to listen"); |
|
| 93 | - } |
|
| 94 | - else { |
|
| 92 | + throw new \RuntimeException("Could not set socket to listen"); |
|
| 93 | + } |
|
| 94 | + else { |
|
| 95 | 95 | |
| 96 | - echo "\n"; |
|
| 97 | - echo "Server Started : " . date('Y-m-d H:i:s') . "\n"; |
|
| 98 | - echo "Master socket : " . $this->socket . "\n"; |
|
| 99 | - echo "Listening on : " . $this->host . " port " . $this->port . "\n\n"; |
|
| 96 | + echo "\n"; |
|
| 97 | + echo "Server Started : " . date('Y-m-d H:i:s') . "\n"; |
|
| 98 | + echo "Master socket : " . $this->socket . "\n"; |
|
| 99 | + echo "Listening on : " . $this->host . " port " . $this->port . "\n\n"; |
|
| 100 | 100 | |
| 101 | - $socket = $this->socket; |
|
| 101 | + $socket = $this->socket; |
|
| 102 | 102 | |
| 103 | - if (!($spawn = @socket_accept($this->socket))) |
|
| 104 | - { |
|
| 105 | - $errno = socket_last_error(); |
|
| 106 | - $this->error($errno, socket_strerror($errno)); |
|
| 103 | + if (!($spawn = @socket_accept($this->socket))) |
|
| 104 | + { |
|
| 105 | + $errno = socket_last_error(); |
|
| 106 | + $this->error($errno, socket_strerror($errno)); |
|
| 107 | 107 | |
| 108 | - throw new \RuntimeException("Could not accept incoming connection"); |
|
| 109 | - } |
|
| 108 | + throw new \RuntimeException("Could not accept incoming connection"); |
|
| 109 | + } |
|
| 110 | 110 | |
| 111 | - $input = $this->read($spawn); |
|
| 111 | + $input = $this->read($spawn); |
|
| 112 | 112 | |
| 113 | - $input = trim($input); |
|
| 114 | - call_user_func($event["success"], $input, $this, $spawn); |
|
| 113 | + $input = trim($input); |
|
| 114 | + call_user_func($event["success"], $input, $this, $spawn); |
|
| 115 | 115 | |
| 116 | - socket_close($spawn); |
|
| 117 | - } |
|
| 116 | + socket_close($spawn); |
|
| 117 | + } |
|
| 118 | 118 | |
| 119 | - if (!$listener) |
|
| 120 | - call_user_func($event["error"], $this->getLastError()); |
|
| 119 | + if (!$listener) |
|
| 120 | + call_user_func($event["error"], $this->getLastError()); |
|
| 121 | 121 | |
| 122 | - return $listener; |
|
| 123 | - } |
|
| 122 | + return $listener; |
|
| 123 | + } |
|
| 124 | 124 | } |
| 125 | 125 | \ No newline at end of file |
@@ -131,7 +131,7 @@ |
||
| 131 | 131 | if (\PEAR::isError($mail)) |
| 132 | 132 | { |
| 133 | 133 | $this->error( |
| 134 | - $mail->getCode(), $mail->getMessage() |
|
| 134 | + $mail->getCode(), $mail->getMessage() |
|
| 135 | 135 | ); |
| 136 | 136 | |
| 137 | 137 | return false; |
@@ -22,10 +22,10 @@ |
||
| 22 | 22 | * |
| 23 | 23 | * @var integer |
| 24 | 24 | */ |
| 25 | - const FILE_PERMISSION_DENIED = 1; |
|
| 26 | - const FILE_NOT_FOUND = 2; |
|
| 27 | - const FILE_EXISTS = 3; |
|
| 28 | - const NOT_DIRECTORY = 4; |
|
| 25 | + const FILE_PERMISSION_DENIED = 1; |
|
| 26 | + const FILE_NOT_FOUND = 2; |
|
| 27 | + const FILE_EXISTS = 3; |
|
| 28 | + const NOT_DIRECTORY = 4; |
|
| 29 | 29 | |
| 30 | 30 | /** |
| 31 | 31 | * Common JSON errors |
@@ -22,14 +22,14 @@ discard block |
||
| 22 | 22 | * |
| 23 | 23 | * @param array $where |
| 24 | 24 | */ |
| 25 | - public function select(Array $where); |
|
| 25 | + public function select(Array $where); |
|
| 26 | 26 | |
| 27 | 27 | /** |
| 28 | 28 | * Insert statement |
| 29 | 29 | * |
| 30 | 30 | * @param array $data |
| 31 | 31 | */ |
| 32 | - public function insert(Array $data); |
|
| 32 | + public function insert(Array $data); |
|
| 33 | 33 | |
| 34 | 34 | /** |
| 35 | 35 | * Update statement |
@@ -37,12 +37,12 @@ discard block |
||
| 37 | 37 | * @param array $set |
| 38 | 38 | * @param array $where |
| 39 | 39 | */ |
| 40 | - public function update(Array $set, Array $where); |
|
| 40 | + public function update(Array $set, Array $where); |
|
| 41 | 41 | |
| 42 | 42 | /** |
| 43 | 43 | * Delete statement |
| 44 | 44 | * |
| 45 | 45 | * @param array $where |
| 46 | 46 | */ |
| 47 | - public function delete(Array $where); |
|
| 47 | + public function delete(Array $where); |
|
| 48 | 48 | } |
| 49 | 49 | \ No newline at end of file |