447 lines
19 KiB
PHP
447 lines
19 KiB
PHP
<?php
|
|
/** @license MIT
|
|
* Copyright 2017 J. King, Dustin Wilson et al.
|
|
* See LICENSE and AUTHORS files for details */
|
|
|
|
declare(strict_types=1);
|
|
namespace JKingWeb\Arsse\Test\Database;
|
|
|
|
use JKingWeb\Arsse\Arsse;
|
|
use JKingWeb\Arsse\Test\Database;
|
|
use JKingWeb\Arsse\Feed\Exception as FeedException;
|
|
use Phake;
|
|
|
|
trait SeriesSubscription {
|
|
protected $data = [
|
|
'arsse_users' => [
|
|
'columns' => [
|
|
'id' => 'str',
|
|
'password' => 'str',
|
|
'name' => 'str',
|
|
],
|
|
'rows' => [
|
|
["jane.doe@example.com", "", "Jane Doe"],
|
|
["john.doe@example.com", "", "John Doe"],
|
|
],
|
|
],
|
|
'arsse_folders' => [
|
|
'columns' => [
|
|
'id' => "int",
|
|
'owner' => "str",
|
|
'parent' => "int",
|
|
'name' => "str",
|
|
],
|
|
'rows' => [
|
|
[1, "john.doe@example.com", null, "Technology"],
|
|
[2, "john.doe@example.com", 1, "Software"],
|
|
[3, "john.doe@example.com", 1, "Rocketry"],
|
|
[4, "jane.doe@example.com", null, "Politics"],
|
|
[5, "john.doe@example.com", null, "Politics"],
|
|
[6, "john.doe@example.com", 2, "Politics"],
|
|
]
|
|
],
|
|
'arsse_feeds' => [
|
|
'columns' => [
|
|
'id' => "int",
|
|
'url' => "str",
|
|
'title' => "str",
|
|
'username' => "str",
|
|
'password' => "str",
|
|
'next_fetch' => "datetime",
|
|
'favicon' => "str",
|
|
],
|
|
'rows' => [] // filled in the series setup
|
|
],
|
|
'arsse_subscriptions' => [
|
|
'columns' => [
|
|
'id' => "int",
|
|
'owner' => "str",
|
|
'feed' => "int",
|
|
'title' => "str",
|
|
'folder' => "int",
|
|
'pinned' => "bool",
|
|
'order_type' => "int",
|
|
],
|
|
'rows' => [
|
|
[1,"john.doe@example.com",2,null,null,1,2],
|
|
[2,"jane.doe@example.com",2,null,null,0,0],
|
|
[3,"john.doe@example.com",3,"Ook",2,0,1],
|
|
]
|
|
],
|
|
'arsse_articles' => [
|
|
'columns' => [
|
|
'id' => "int",
|
|
'feed' => "int",
|
|
'url_title_hash' => "str",
|
|
'url_content_hash' => "str",
|
|
'title_content_hash' => "str",
|
|
],
|
|
'rows' => [
|
|
[1,2,"","",""],
|
|
[2,2,"","",""],
|
|
[3,2,"","",""],
|
|
[4,2,"","",""],
|
|
[5,2,"","",""],
|
|
[6,3,"","",""],
|
|
[7,3,"","",""],
|
|
[8,3,"","",""],
|
|
]
|
|
],
|
|
'arsse_marks' => [
|
|
'columns' => [
|
|
'article' => "int",
|
|
'subscription' => "int",
|
|
'read' => "bool",
|
|
'starred' => "bool",
|
|
],
|
|
'rows' => [
|
|
[1,2,1,0],
|
|
[2,2,1,0],
|
|
[3,2,1,0],
|
|
[4,2,1,0],
|
|
[5,2,1,0],
|
|
[1,1,1,0],
|
|
[7,3,1,0],
|
|
[8,3,0,0],
|
|
]
|
|
],
|
|
];
|
|
|
|
public function setUpSeries() {
|
|
$this->data['arsse_feeds']['rows'] = [
|
|
[1,"http://example.com/feed1", "Ook", "", "",strtotime("now"),''],
|
|
[2,"http://example.com/feed2", "eek", "", "",strtotime("now - 1 hour"),'http://example.com/favicon.ico'],
|
|
[3,"http://example.com/feed3", "Ack", "", "",strtotime("now + 1 hour"),''],
|
|
];
|
|
// initialize a partial mock of the Database object to later manipulate the feedUpdate method
|
|
Arsse::$db = Phake::partialMock(Database::class, $this->drv);
|
|
$this->user = "john.doe@example.com";
|
|
}
|
|
|
|
public function testAddASubscriptionToAnExistingFeed() {
|
|
$url = "http://example.com/feed1";
|
|
$subID = $this->nextID("arsse_subscriptions");
|
|
Phake::when(Arsse::$db)->feedUpdate->thenReturn(true);
|
|
$this->assertSame($subID, Arsse::$db->subscriptionAdd($this->user, $url));
|
|
Phake::verify(Arsse::$user)->authorize($this->user, "subscriptionAdd");
|
|
Phake::verify(Arsse::$db, Phake::times(0))->feedUpdate(1, true);
|
|
$state = $this->primeExpectations($this->data, [
|
|
'arsse_feeds' => ['id','url','username','password'],
|
|
'arsse_subscriptions' => ['id','owner','feed'],
|
|
]);
|
|
$state['arsse_subscriptions']['rows'][] = [$subID,$this->user,1];
|
|
$this->compareExpectations($state);
|
|
}
|
|
|
|
public function testAddASubscriptionToANewFeed() {
|
|
$url = "http://example.org/feed1";
|
|
$feedID = $this->nextID("arsse_feeds");
|
|
$subID = $this->nextID("arsse_subscriptions");
|
|
Phake::when(Arsse::$db)->feedUpdate->thenReturn(true);
|
|
$this->assertSame($subID, Arsse::$db->subscriptionAdd($this->user, $url, "", "", false));
|
|
Phake::verify(Arsse::$user)->authorize($this->user, "subscriptionAdd");
|
|
Phake::verify(Arsse::$db)->feedUpdate($feedID, true);
|
|
$state = $this->primeExpectations($this->data, [
|
|
'arsse_feeds' => ['id','url','username','password'],
|
|
'arsse_subscriptions' => ['id','owner','feed'],
|
|
]);
|
|
$state['arsse_feeds']['rows'][] = [$feedID,$url,"",""];
|
|
$state['arsse_subscriptions']['rows'][] = [$subID,$this->user,$feedID];
|
|
$this->compareExpectations($state);
|
|
}
|
|
|
|
public function testAddASubscriptionToANewFeedViaDiscovery() {
|
|
$url = "http://localhost:8000/Feed/Discovery/Valid";
|
|
$discovered = "http://localhost:8000/Feed/Discovery/Feed";
|
|
$feedID = $this->nextID("arsse_feeds");
|
|
$subID = $this->nextID("arsse_subscriptions");
|
|
Phake::when(Arsse::$db)->feedUpdate->thenReturn(true);
|
|
$this->assertSame($subID, Arsse::$db->subscriptionAdd($this->user, $url, "", "", true));
|
|
Phake::verify(Arsse::$user)->authorize($this->user, "subscriptionAdd");
|
|
Phake::verify(Arsse::$db)->feedUpdate($feedID, true);
|
|
$state = $this->primeExpectations($this->data, [
|
|
'arsse_feeds' => ['id','url','username','password'],
|
|
'arsse_subscriptions' => ['id','owner','feed'],
|
|
]);
|
|
$state['arsse_feeds']['rows'][] = [$feedID,$discovered,"",""];
|
|
$state['arsse_subscriptions']['rows'][] = [$subID,$this->user,$feedID];
|
|
$this->compareExpectations($state);
|
|
}
|
|
|
|
public function testAddASubscriptionToAnInvalidFeed() {
|
|
$url = "http://example.org/feed1";
|
|
$feedID = $this->nextID("arsse_feeds");
|
|
Phake::when(Arsse::$db)->feedUpdate->thenThrow(new FeedException($url, new \PicoFeed\Client\InvalidUrlException()));
|
|
try {
|
|
Arsse::$db->subscriptionAdd($this->user, $url, "", "", false);
|
|
} catch (FeedException $e) {
|
|
Phake::verify(Arsse::$user)->authorize($this->user, "subscriptionAdd");
|
|
Phake::verify(Arsse::$db)->feedUpdate($feedID, true);
|
|
$state = $this->primeExpectations($this->data, [
|
|
'arsse_feeds' => ['id','url','username','password'],
|
|
'arsse_subscriptions' => ['id','owner','feed'],
|
|
]);
|
|
$this->compareExpectations($state);
|
|
$this->assertException("invalidUrl", "Feed");
|
|
throw $e;
|
|
}
|
|
}
|
|
|
|
public function testAddADuplicateSubscription() {
|
|
$url = "http://example.com/feed2";
|
|
$this->assertException("constraintViolation", "Db", "ExceptionInput");
|
|
Arsse::$db->subscriptionAdd($this->user, $url);
|
|
}
|
|
|
|
public function testAddASubscriptionWithoutAuthority() {
|
|
$url = "http://example.com/feed1";
|
|
Phake::when(Arsse::$user)->authorize->thenReturn(false);
|
|
$this->assertException("notAuthorized", "User", "ExceptionAuthz");
|
|
Arsse::$db->subscriptionAdd($this->user, $url);
|
|
}
|
|
|
|
public function testRemoveASubscription() {
|
|
$this->assertTrue(Arsse::$db->subscriptionRemove($this->user, 1));
|
|
Phake::verify(Arsse::$user)->authorize($this->user, "subscriptionRemove");
|
|
$state = $this->primeExpectations($this->data, [
|
|
'arsse_feeds' => ['id','url','username','password'],
|
|
'arsse_subscriptions' => ['id','owner','feed'],
|
|
]);
|
|
array_shift($state['arsse_subscriptions']['rows']);
|
|
$this->compareExpectations($state);
|
|
}
|
|
|
|
public function testRemoveAMissingSubscription() {
|
|
$this->assertException("subjectMissing", "Db", "ExceptionInput");
|
|
Arsse::$db->subscriptionRemove($this->user, 2112);
|
|
}
|
|
|
|
public function testRemoveAnInvalidSubscription() {
|
|
$this->assertException("typeViolation", "Db", "ExceptionInput");
|
|
Arsse::$db->subscriptionRemove($this->user, -1);
|
|
}
|
|
|
|
public function testRemoveASubscriptionForTheWrongOwner() {
|
|
$this->user = "jane.doe@example.com";
|
|
$this->assertException("subjectMissing", "Db", "ExceptionInput");
|
|
Arsse::$db->subscriptionRemove($this->user, 1);
|
|
}
|
|
|
|
public function testRemoveASubscriptionWithoutAuthority() {
|
|
Phake::when(Arsse::$user)->authorize->thenReturn(false);
|
|
$this->assertException("notAuthorized", "User", "ExceptionAuthz");
|
|
Arsse::$db->subscriptionRemove($this->user, 1);
|
|
}
|
|
|
|
public function testListSubscriptions() {
|
|
$exp = [
|
|
[
|
|
'url' => "http://example.com/feed2",
|
|
'title' => "eek",
|
|
'folder' => null,
|
|
'top_folder' => null,
|
|
'unread' => 4,
|
|
'pinned' => 1,
|
|
'order_type' => 2,
|
|
],
|
|
[
|
|
'url' => "http://example.com/feed3",
|
|
'title' => "Ook",
|
|
'folder' => 2,
|
|
'top_folder' => 1,
|
|
'unread' => 2,
|
|
'pinned' => 0,
|
|
'order_type' => 1,
|
|
],
|
|
];
|
|
$this->assertResult($exp, Arsse::$db->subscriptionList($this->user));
|
|
Phake::verify(Arsse::$user)->authorize($this->user, "subscriptionList");
|
|
$this->assertArraySubset($exp[0], Arsse::$db->subscriptionPropertiesGet($this->user, 1));
|
|
Phake::verify(Arsse::$user)->authorize($this->user, "subscriptionPropertiesGet");
|
|
$this->assertArraySubset($exp[1], Arsse::$db->subscriptionPropertiesGet($this->user, 3));
|
|
}
|
|
|
|
public function testListSubscriptionsInAFolder() {
|
|
$exp = [
|
|
[
|
|
'url' => "http://example.com/feed2",
|
|
'title' => "eek",
|
|
'folder' => null,
|
|
'top_folder' => null,
|
|
'unread' => 4,
|
|
'pinned' => 1,
|
|
'order_type' => 2,
|
|
],
|
|
];
|
|
$this->assertResult($exp, Arsse::$db->subscriptionList($this->user, null, false));
|
|
}
|
|
|
|
public function testListSubscriptionsWithoutRecursion() {
|
|
$exp = [
|
|
[
|
|
'url' => "http://example.com/feed3",
|
|
'title' => "Ook",
|
|
'folder' => 2,
|
|
'top_folder' => 1,
|
|
'unread' => 2,
|
|
'pinned' => 0,
|
|
'order_type' => 1,
|
|
],
|
|
];
|
|
$this->assertResult($exp, Arsse::$db->subscriptionList($this->user, 2));
|
|
}
|
|
|
|
public function testListSubscriptionsInAMissingFolder() {
|
|
$this->assertException("idMissing", "Db", "ExceptionInput");
|
|
Arsse::$db->subscriptionList($this->user, 4);
|
|
}
|
|
|
|
public function testListSubscriptionsWithoutAuthority() {
|
|
Phake::when(Arsse::$user)->authorize->thenReturn(false);
|
|
$this->assertException("notAuthorized", "User", "ExceptionAuthz");
|
|
Arsse::$db->subscriptionList($this->user);
|
|
}
|
|
|
|
public function testCountSubscriptions() {
|
|
$this->assertSame(2, Arsse::$db->subscriptionCount($this->user));
|
|
$this->assertSame(1, Arsse::$db->subscriptionCount($this->user, 2));
|
|
}
|
|
|
|
public function testCountSubscriptionsInAMissingFolder() {
|
|
$this->assertException("idMissing", "Db", "ExceptionInput");
|
|
Arsse::$db->subscriptionCount($this->user, 4);
|
|
}
|
|
|
|
public function testCountSubscriptionsWithoutAuthority() {
|
|
Phake::when(Arsse::$user)->authorize->thenReturn(false);
|
|
$this->assertException("notAuthorized", "User", "ExceptionAuthz");
|
|
Arsse::$db->subscriptionCount($this->user);
|
|
}
|
|
|
|
public function testGetThePropertiesOfAMissingSubscription() {
|
|
$this->assertException("subjectMissing", "Db", "ExceptionInput");
|
|
Arsse::$db->subscriptionPropertiesGet($this->user, 2112);
|
|
}
|
|
|
|
public function testGetThePropertiesOfAnInvalidSubscription() {
|
|
$this->assertException("typeViolation", "Db", "ExceptionInput");
|
|
Arsse::$db->subscriptionPropertiesGet($this->user, -1);
|
|
}
|
|
|
|
public function testGetThePropertiesOfASubscriptionWithoutAuthority() {
|
|
Phake::when(Arsse::$user)->authorize->thenReturn(false);
|
|
$this->assertException("notAuthorized", "User", "ExceptionAuthz");
|
|
Arsse::$db->subscriptionPropertiesGet($this->user, 1);
|
|
}
|
|
|
|
public function testSetThePropertiesOfASubscription() {
|
|
Arsse::$db->subscriptionPropertiesSet($this->user, 1, [
|
|
'title' => "Ook Ook",
|
|
'folder' => 3,
|
|
'pinned' => false,
|
|
'order_type' => 0,
|
|
]);
|
|
Phake::verify(Arsse::$user)->authorize($this->user, "subscriptionPropertiesSet");
|
|
$state = $this->primeExpectations($this->data, [
|
|
'arsse_feeds' => ['id','url','username','password','title'],
|
|
'arsse_subscriptions' => ['id','owner','feed','title','folder','pinned','order_type'],
|
|
]);
|
|
$state['arsse_subscriptions']['rows'][0] = [1,"john.doe@example.com",2,"Ook Ook",3,0,0];
|
|
$this->compareExpectations($state);
|
|
Arsse::$db->subscriptionPropertiesSet($this->user, 1, [
|
|
'title' => null,
|
|
]);
|
|
$state['arsse_subscriptions']['rows'][0] = [1,"john.doe@example.com",2,null,3,0,0];
|
|
$this->compareExpectations($state);
|
|
// making no changes is a valid result
|
|
Arsse::$db->subscriptionPropertiesSet($this->user, 1, ['unhinged' => true]);
|
|
$this->compareExpectations($state);
|
|
}
|
|
|
|
public function testMoveASubscriptionToAMissingFolder() {
|
|
$this->assertException("idMissing", "Db", "ExceptionInput");
|
|
Arsse::$db->subscriptionPropertiesSet($this->user, 1, ['folder' => 4]);
|
|
}
|
|
|
|
public function testMoveASubscriptionToTheRootFolder() {
|
|
$this->assertTrue(Arsse::$db->subscriptionPropertiesSet($this->user, 3, ['folder' => null]));
|
|
}
|
|
|
|
public function testRenameASubscriptionToABlankTitle() {
|
|
$this->assertException("missing", "Db", "ExceptionInput");
|
|
Arsse::$db->subscriptionPropertiesSet($this->user, 1, ['title' => ""]);
|
|
}
|
|
|
|
public function testRenameASubscriptionToAWhitespaceTitle() {
|
|
$this->assertException("whitespace", "Db", "ExceptionInput");
|
|
Arsse::$db->subscriptionPropertiesSet($this->user, 1, ['title' => " "]);
|
|
}
|
|
|
|
public function testRenameASubscriptionToFalse() {
|
|
$this->assertException("typeViolation", "Db", "ExceptionInput");
|
|
Arsse::$db->subscriptionPropertiesSet($this->user, 1, ['title' => false]);
|
|
}
|
|
|
|
public function testRenameASubscriptionToZero() {
|
|
$this->assertTrue(Arsse::$db->subscriptionPropertiesSet($this->user, 1, ['title' => 0]));
|
|
}
|
|
|
|
public function testRenameASubscriptionToAnArray() {
|
|
$this->assertException("typeViolation", "Db", "ExceptionInput");
|
|
Arsse::$db->subscriptionPropertiesSet($this->user, 1, ['title' => []]);
|
|
}
|
|
|
|
public function testSetThePropertiesOfAMissingSubscription() {
|
|
$this->assertException("subjectMissing", "Db", "ExceptionInput");
|
|
Arsse::$db->subscriptionPropertiesSet($this->user, 2112, ['folder' => null]);
|
|
}
|
|
|
|
public function testSetThePropertiesOfAnInvalidSubscription() {
|
|
$this->assertException("typeViolation", "Db", "ExceptionInput");
|
|
Arsse::$db->subscriptionPropertiesSet($this->user, -1, ['folder' => null]);
|
|
}
|
|
|
|
public function testSetThePropertiesOfASubscriptionWithoutAuthority() {
|
|
Phake::when(Arsse::$user)->authorize->thenReturn(false);
|
|
$this->assertException("notAuthorized", "User", "ExceptionAuthz");
|
|
Arsse::$db->subscriptionPropertiesSet($this->user, 1, ['folder' => null]);
|
|
}
|
|
|
|
public function testRetrieveTheFaviconOfASubscription() {
|
|
$exp = "http://example.com/favicon.ico";
|
|
$this->assertSame($exp, Arsse::$db->subscriptionFavicon(1));
|
|
$this->assertSame($exp, Arsse::$db->subscriptionFavicon(2));
|
|
$this->assertSame('', Arsse::$db->subscriptionFavicon(3));
|
|
$this->assertSame('', Arsse::$db->subscriptionFavicon(4));
|
|
// authorization shouldn't have any bearing on this function
|
|
Phake::when(Arsse::$user)->authorize->thenReturn(false);
|
|
$this->assertSame($exp, Arsse::$db->subscriptionFavicon(1));
|
|
$this->assertSame($exp, Arsse::$db->subscriptionFavicon(2));
|
|
$this->assertSame('', Arsse::$db->subscriptionFavicon(3));
|
|
$this->assertSame('', Arsse::$db->subscriptionFavicon(4));
|
|
// invalid IDs should simply return an empty string
|
|
$this->assertSame('', Arsse::$db->subscriptionFavicon(-2112));
|
|
}
|
|
|
|
public function testRetrieveTheFaviconOfASubscriptionWithUser() {
|
|
$exp = "http://example.com/favicon.ico";
|
|
$user = "john.doe@example.com";
|
|
$this->assertSame($exp, Arsse::$db->subscriptionFavicon(1, $user));
|
|
$this->assertSame('', Arsse::$db->subscriptionFavicon(2, $user));
|
|
$this->assertSame('', Arsse::$db->subscriptionFavicon(3, $user));
|
|
$this->assertSame('', Arsse::$db->subscriptionFavicon(4, $user));
|
|
$user = "jane.doe@example.com";
|
|
$this->assertSame('', Arsse::$db->subscriptionFavicon(1, $user));
|
|
$this->assertSame($exp, Arsse::$db->subscriptionFavicon(2, $user));
|
|
$this->assertSame('', Arsse::$db->subscriptionFavicon(3, $user));
|
|
$this->assertSame('', Arsse::$db->subscriptionFavicon(4, $user));
|
|
}
|
|
|
|
public function testRetrieveTheFaviconOfASubscriptionWithUserWithoutAuthority() {
|
|
$exp = "http://example.com/favicon.ico";
|
|
$user = "john.doe@example.com";
|
|
Phake::when(Arsse::$user)->authorize->thenReturn(false);
|
|
$this->assertException("notAuthorized", "User", "ExceptionAuthz");
|
|
Arsse::$db->subscriptionFavicon(-2112, $user);
|
|
}
|
|
}
|