rss-bridge/bridges/SpotifyBridge.php
joaomqc bef6fc5cbd
[SpotifyBridge] Add playlists feed (#3116)
* [SpotifyBridge] Add playlists feed

* fix formatting

* remove whitespace

* merge artist and playlist feeds

* fix lint errors
2022-10-27 20:02:01 +02:00

323 lines
8.7 KiB
PHP

<?php
class SpotifyBridge extends BridgeAbstract
{
const NAME = 'Spotify';
const URI = 'https://spotify.com/';
const DESCRIPTION = 'Fetches the latest albums from one or more artists or the latest tracks from one or more playlists';
const MAINTAINER = 'Paroleen';
const CACHE_TIMEOUT = 3600;
const PARAMETERS = [ [
'clientid' => [
'name' => 'Client ID',
'type' => 'text',
'required' => true
],
'clientsecret' => [
'name' => 'Client secret',
'type' => 'text',
'required' => true
],
'country' => [
'name' => 'Country',
'type' => 'text',
'required' => false,
'exampleValue' => 'US',
'defaultValue' => 'US'
],
'limit' => [
'name' => 'Limit',
'type' => 'number',
'required' => false,
'exampleValue' => 10,
'defaultValue' => 10
],
'spotifyuri' => [
'name' => 'Spotify URIs',
'type' => 'text',
'required' => true,
'exampleValue' => 'spotify:artist:4lianjyuR1tqf6oUX8kjrZ [,spotify:playlist:37i9dQZF1DXcBWIGoYBM5M]',
],
'albumtype' => [
'name' => 'Album type',
'type' => 'text',
'required' => false,
'exampleValue' => 'album,single,appears_on,compilation',
'defaultValue' => 'album,single'
]
] ];
const TOKENURI = 'https://accounts.spotify.com/api/token';
const APIURI = 'https://api.spotify.com/v1/';
private $uri = '';
private $name = '';
private $token = '';
private $uris = [];
private $entries = [];
public function getURI()
{
if (empty($this->uri)) {
$this->getFirstEntry();
}
return $this->uri;
}
public function getName()
{
if (empty($this->name)) {
$this->getFirstEntry();
}
return $this->name;
}
public function getIcon()
{
return 'https://www.scdn.co/i/_global/favicon.png';
}
private function getUriType($uri)
{
return explode(':', $uri)[1];
}
private function getId($uri)
{
return explode(':', $uri)[2];
}
private function getDate($entry)
{
if ($entry['type'] === 'album') {
$date = $entry['release_date'];
} else {
$date = $entry['added_at'];
}
if (strlen($date) == 4) {
$date .= '-01-01';
} elseif (strlen($date) == 7) {
$date .= '-01';
}
if (strlen($date) > 10) {
return DateTime::createFromFormat('Y-m-d\TH:i:s\Z', $date)->getTimestamp();
}
return DateTime::createFromFormat('Y-m-d', $date)->getTimestamp();
}
private function getAlbumType()
{
return $this->getInput('albumtype');
}
private function getCountry()
{
return $this->getInput('country');
}
private function getToken()
{
$cacheFactory = new CacheFactory();
$cache = $cacheFactory->create();
$cache->setScope('SpotifyBridge');
$cache->setKey(['token']);
if ($cache->getTime()) {
$time = (new DateTime())->getTimestamp() - $cache->getTime();
Debug::log('Token time: ' . $time);
}
if ($cache->getTime() == false || $time >= 3600) {
Debug::log('Fetching token from Spotify');
$this->fetchToken();
$cache->saveData($this->token);
} else {
Debug::log('Loading token from cache');
$this->token = $cache->loadData();
}
Debug::log('Token: ' . $this->token);
}
private function getFirstEntry()
{
if (!is_null($this->getInput('spotifyuri')) && strpos($this->getInput('spotifyuri'), ',') === false) {
$type = $this->getUriType($this->uris[0]) . 's';
$item = $this->fetchContent(self::APIURI . $type . '/'
. $this->getId($this->uris[0]));
$this->uri = $item['external_urls']['spotify'];
$this->name = $item['name'] . ' - Spotify';
} else {
$this->uri = parent::getURI();
$this->name = parent::getName();
}
}
private function getAllUris()
{
Debug::log('Parsing all uris');
$this->uris = explode(',', $this->getInput('spotifyuri'));
}
private function getAllEntries()
{
$this->entries = [];
$this->getAllUris();
Debug::log('Fetching all entries');
foreach ($this->uris as $uri) {
$type = $this->getUriType($uri) . 's';
$entry_type = $type === 'artists' ? 'albums' : 'tracks';
$fetch = true;
$offset = 0;
$api_url = self::APIURI . $type . '/'
. $this->getId($uri)
. '/' . $entry_type
. '?limit=50&country='
. $this->getCountry();
if ($type === 'artists') {
$api_url = $api_url . '&include_groups=' . $this->getAlbumType();
}
while ($fetch) {
$partial = $this->fetchContent($api_url
. '&offset='
. $offset);
if (!empty($partial['items'])) {
$this->entries = array_merge(
$this->entries,
$partial['items']
);
} else {
$fetch = false;
}
$offset += 50;
}
}
}
private function fetchToken()
{
$curl = curl_init();
curl_setopt($curl, CURLOPT_URL, self::TOKENURI);
curl_setopt($curl, CURLOPT_RETURNTRANSFER, 1);
curl_setopt($curl, CURLOPT_POST, 1);
curl_setopt($curl, CURLOPT_POSTFIELDS, 'grant_type=client_credentials');
curl_setopt($curl, CURLOPT_HTTPHEADER, ['Authorization: Basic '
. base64_encode($this->getInput('clientid')
. ':'
. $this->getInput('clientsecret'))]);
$json = curl_exec($curl);
$json = json_decode($json)->access_token;
curl_close($curl);
$this->token = $json;
}
private function fetchContent($url)
{
$this->getToken();
$curl = curl_init();
curl_setopt($curl, CURLOPT_URL, $url);
curl_setopt($curl, CURLOPT_RETURNTRANSFER, 1);
curl_setopt($curl, CURLOPT_HTTPHEADER, ['Authorization: Bearer '
. $this->token]);
Debug::log('Fetching content from ' . $url);
$json = curl_exec($curl);
$json = json_decode($json, true);
curl_close($curl);
return $json;
}
private function sortEntries()
{
Debug::log('Sorting entries');
usort($this->entries, function ($entry1, $entry2) {
if ($this->getDate($entry1) < $this->getDate($entry2)) {
return 1;
} else {
return -1;
}
});
}
private function getAlbumData($album)
{
$item = [];
$item['title'] = $album['name'];
$item['uri'] = $album['external_urls']['spotify'];
$item['timestamp'] = $this->getDate($album);
$item['author'] = $album['artists'][0]['name'];
$item['categories'] = [$album['album_type']];
$item['content'] = '<img style="width: 256px" src="'
. $album['images'][0]['url']
. '">';
if ($album['total_tracks'] > 1) {
$item['content'] .= '<p>Total tracks: '
. $album['total_tracks']
. '</p>';
}
return $item;
}
private function getTrackData($track)
{
$item = [];
$item['title'] = $track['track']['name'];
$item['uri'] = $track['track']['external_urls']['spotify'];
$item['timestamp'] = $this->getDate($track);
$item['author'] = $track['track']['artists'][0]['name'];
$item['categories'] = ['track'];
$item['content'] = '<img style="width: 256px" src="'
. $track['track']['album']['images'][0]['url']
. '">';
return $item;
}
public function collectData()
{
$offset = 0;
$this->getAllEntries();
$this->sortEntries();
Debug::log('Building RSS feed');
foreach ($this->entries as $entry) {
if ($entry['type'] === 'album') {
$item = $this->getAlbumData($entry);
} else {
$item = $this->getTrackData($entry);
}
$this->items[] = $item;
if ($this->getInput('limit') > 0 && count($this->items) >= $this->getInput('limit')) {
break;
}
}
}
}