110 lines
2.7 KiB
PHP
110 lines
2.7 KiB
PHP
<?php
|
|
/**
|
|
* @copyright Copyright (c) 2016 Robin Appelman <robin@icewind.nl>
|
|
* This file is licensed under the Licensed under the MIT license:
|
|
* http://opensource.org/licenses/MIT
|
|
*
|
|
*/
|
|
|
|
namespace Icewind\SMB\Wrapped;
|
|
|
|
use Icewind\SMB\Change;
|
|
use Icewind\SMB\Exception\Exception;
|
|
use Icewind\SMB\Exception\RevisionMismatchException;
|
|
use Icewind\SMB\INotifyHandler;
|
|
|
|
class NotifyHandler implements INotifyHandler {
|
|
/** @var Connection */
|
|
private $connection;
|
|
|
|
/** @var string */
|
|
private $path;
|
|
|
|
/** @var bool */
|
|
private $listening = true;
|
|
|
|
// see error.h
|
|
const EXCEPTION_MAP = [
|
|
ErrorCodes::RevisionMismatch => RevisionMismatchException::class,
|
|
];
|
|
|
|
/**
|
|
* @param Connection $connection
|
|
* @param string $path
|
|
*/
|
|
public function __construct(Connection $connection, string $path) {
|
|
$this->connection = $connection;
|
|
$this->path = $path;
|
|
}
|
|
|
|
/**
|
|
* Get all changes detected since the start of the notify process or the last call to getChanges
|
|
*
|
|
* @return Change[]
|
|
*/
|
|
public function getChanges(): array {
|
|
if (!$this->listening) {
|
|
return [];
|
|
}
|
|
stream_set_blocking($this->connection->getOutputStream(), false);
|
|
$lines = [];
|
|
while (($line = $this->connection->readLine())) {
|
|
$this->checkForError($line);
|
|
$lines[] = $line;
|
|
}
|
|
stream_set_blocking($this->connection->getOutputStream(), true);
|
|
return array_values(array_filter(array_map([$this, 'parseChangeLine'], $lines)));
|
|
}
|
|
|
|
/**
|
|
* Listen actively to all incoming changes
|
|
*
|
|
* Note that this is a blocking process and will cause the process to block forever if not explicitly terminated
|
|
*
|
|
* @param callable(Change):?bool $callback
|
|
*/
|
|
public function listen(callable $callback): void {
|
|
if ($this->listening) {
|
|
$this->connection->read(function (string $line) use ($callback): bool {
|
|
$this->checkForError($line);
|
|
$change = $this->parseChangeLine($line);
|
|
if ($change) {
|
|
$result = $callback($change);
|
|
return $result === false ? false : true;
|
|
} else {
|
|
return true;
|
|
}
|
|
});
|
|
}
|
|
}
|
|
|
|
private function parseChangeLine(string $line): ?Change {
|
|
$code = (int)substr($line, 0, 4);
|
|
if ($code === 0) {
|
|
return null;
|
|
}
|
|
$subPath = str_replace('\\', '/', substr($line, 5));
|
|
if ($this->path === '') {
|
|
return new Change($code, $subPath);
|
|
} else {
|
|
return new Change($code, $this->path . '/' . $subPath);
|
|
}
|
|
}
|
|
|
|
private function checkForError(string $line): void {
|
|
if (substr($line, 0, 16) === 'notify returned ') {
|
|
$error = substr($line, 16);
|
|
throw Exception::fromMap(array_merge(self::EXCEPTION_MAP, Parser::EXCEPTION_MAP), $error, 'Notify is not supported with the used smb version');
|
|
}
|
|
}
|
|
|
|
public function stop(): void {
|
|
$this->listening = false;
|
|
$this->connection->close();
|
|
}
|
|
|
|
public function __destruct() {
|
|
$this->stop();
|
|
}
|
|
}
|