mirror of
https://codeberg.org/icewind/SMB.git
synced 2026-06-03 17:24:07 +02:00
mark notify tests skipped when smb version isn't supported
This commit is contained in:
parent
bfcac80430
commit
dd47833ed4
1 changed files with 24 additions and 7 deletions
|
|
@ -10,6 +10,7 @@ namespace Icewind\SMB\Test;
|
||||||
use Icewind\SMB\BasicAuth;
|
use Icewind\SMB\BasicAuth;
|
||||||
use Icewind\SMB\Change;
|
use Icewind\SMB\Change;
|
||||||
use Icewind\SMB\Exception\AlreadyExistsException;
|
use Icewind\SMB\Exception\AlreadyExistsException;
|
||||||
|
use Icewind\SMB\Exception\RevisionMismatchException;
|
||||||
use Icewind\SMB\INotifyHandler;
|
use Icewind\SMB\INotifyHandler;
|
||||||
use Icewind\SMB\IShare;
|
use Icewind\SMB\IShare;
|
||||||
use Icewind\SMB\Options;
|
use Icewind\SMB\Options;
|
||||||
|
|
@ -66,7 +67,11 @@ class NotifyHandlerTest extends TestCase {
|
||||||
$share->del('target.txt');
|
$share->del('target.txt');
|
||||||
usleep(1000 * 100);// give it some time
|
usleep(1000 * 100);// give it some time
|
||||||
|
|
||||||
$changes = $process->getChanges();
|
try {
|
||||||
|
$changes = $process->getChanges();
|
||||||
|
} catch (RevisionMismatchException $e) {
|
||||||
|
$this->markTestSkipped("notify not supported with configured smb version");
|
||||||
|
}
|
||||||
$process->stop();
|
$process->stop();
|
||||||
$expected = [
|
$expected = [
|
||||||
new Change(INotifyHandler::NOTIFY_ADDED, 'source.txt'),
|
new Change(INotifyHandler::NOTIFY_ADDED, 'source.txt'),
|
||||||
|
|
@ -91,7 +96,11 @@ class NotifyHandlerTest extends TestCase {
|
||||||
$share->del('sub/source.txt');
|
$share->del('sub/source.txt');
|
||||||
usleep(1000 * 100);// give it some time
|
usleep(1000 * 100);// give it some time
|
||||||
|
|
||||||
$changes = $process->getChanges();
|
try {
|
||||||
|
$changes = $process->getChanges();
|
||||||
|
} catch (RevisionMismatchException $e) {
|
||||||
|
$this->markTestSkipped("notify not supported with configured smb version");
|
||||||
|
}
|
||||||
$process->stop();
|
$process->stop();
|
||||||
|
|
||||||
$expected = [
|
$expected = [
|
||||||
|
|
@ -115,10 +124,14 @@ class NotifyHandlerTest extends TestCase {
|
||||||
$results = [];
|
$results = [];
|
||||||
|
|
||||||
// the notify process buffers incoming messages so callback will be triggered for the above changes
|
// the notify process buffers incoming messages so callback will be triggered for the above changes
|
||||||
$process->listen(function ($change) use (&$results) {
|
try {
|
||||||
$results = $change;
|
$process->listen(function ($change) use (&$results) {
|
||||||
return false; // stop listening
|
$results = $change;
|
||||||
});
|
return false; // stop listening
|
||||||
|
});
|
||||||
|
} catch (RevisionMismatchException $e) {
|
||||||
|
$this->markTestSkipped("notify not supported with configured smb version");
|
||||||
|
}
|
||||||
$this->assertEquals($results, new Change(INotifyHandler::NOTIFY_ADDED, 'source.txt'));
|
$this->assertEquals($results, new Change(INotifyHandler::NOTIFY_ADDED, 'source.txt'));
|
||||||
}
|
}
|
||||||
|
|
||||||
|
|
@ -140,7 +153,11 @@ class NotifyHandlerTest extends TestCase {
|
||||||
$share->del('target.txt');
|
$share->del('target.txt');
|
||||||
usleep(1000 * 100);// give it some time
|
usleep(1000 * 100);// give it some time
|
||||||
|
|
||||||
$changes = $process->getChanges();
|
try {
|
||||||
|
$changes = $process->getChanges();
|
||||||
|
} catch (RevisionMismatchException $e) {
|
||||||
|
$this->markTestSkipped("notify not supported with configured smb version");
|
||||||
|
}
|
||||||
$expected = [
|
$expected = [
|
||||||
new Change(INotifyHandler::NOTIFY_ADDED, 'source.txt'),
|
new Change(INotifyHandler::NOTIFY_ADDED, 'source.txt'),
|
||||||
new Change(INotifyHandler::NOTIFY_RENAMED_OLD, 'source.txt'),
|
new Change(INotifyHandler::NOTIFY_RENAMED_OLD, 'source.txt'),
|
||||||
|
|
|
||||||
Loading…
Add table
Add a link
Reference in a new issue