mirror of
https://github.com/RSS-Bridge/rss-bridge.git
synced 2025-03-14 20:21:14 +03:00
[SpotifyBridge] Add new bridge (#1535)
This commit is contained in:
Paroleen
GitHub
parent
1ae7cf6530
commit
3d570761e5
1 changed files with 238 additions and 0 deletions
238
bridges/SpotifyBridge.php
Normal file
238
bridges/SpotifyBridge.php
Normal file
|
|
@ -0,0 +1,238 @@
|
|||
<?php
|
||||
class SpotifyBridge extends BridgeAbstract {
|
||||
const NAME = 'Spotify';
|
||||
const URI = 'https://spotify.com/';
|
||||
const DESCRIPTION = 'Fetches the latest ten albums from one or more artists';
|
||||
const MAINTAINER = 'Paroleen';
|
||||
const CACHE_TIMEOUT = 3600;
|
||||
const PARAMETERS = array( array(
|
||||
'clientid' => array(
|
||||
'name' => 'Client ID',
|
||||
'type' => 'text',
|
||||
'required' => true
|
||||
),
|
||||
'clientsecret' => array(
|
||||
'name' => 'Client secret',
|
||||
'type' => 'text',
|
||||
'required' => true
|
||||
),
|
||||
'spotifyuri' => array(
|
||||
'name' => 'Spotify URIs',
|
||||
'type' => 'text',
|
||||
'required' => true,
|
||||
'exampleValue' => 'spotify:artist:4lianjyuR1tqf6oUX8kjrZ [,spotify:artist:3JsMj0DEzyWc0VDlHuy9Bx]',
|
||||
),
|
||||
'albumtype' => array(
|
||||
'name' => 'Album type',
|
||||
'type' => 'text',
|
||||
'required' => false,
|
||||
'exampleValue' => 'album,single,appears_on,compilation',
|
||||
'defaultValue' => 'album,single'
|
||||
),
|
||||
'country' => array(
|
||||
'name' => 'Country',
|
||||
'type' => 'text',
|
||||
'required' => false,
|
||||
'exampleValue' => 'US',
|
||||
'defaultValue' => 'US'
|
||||
)
|
||||
));
|
||||
|
||||
const TOKENURI = 'https://accounts.spotify.com/api/token';
|
||||
const APIURI = 'https://api.spotify.com/v1/';
|
||||
|
||||
private $uri = '';
|
||||
private $name = '';
|
||||
private $token = '';
|
||||
private $artists = array();
|
||||
private $albums = array();
|
||||
|
||||
public function getURI() {
|
||||
if(empty($this->uri))
|
||||
$this->getArtist();
|
||||
|
||||
return $this->uri;
|
||||
}
|
||||
|
||||
public function getName() {
|
||||
if(empty($this->name))
|
||||
$this->getArtist();
|
||||
|
||||
return $this->name;
|
||||
}
|
||||
|
||||
public function getIcon() {
|
||||
return 'https://www.scdn.co/i/_global/favicon.png';
|
||||
}
|
||||
|
||||
private function getId($artist) {
|
||||
return explode(':', $artist)[2];
|
||||
}
|
||||
|
||||
private function getDate($album_date) {
|
||||
if(strlen($album_date) == 4)
|
||||
$album_date .= '-01-01';
|
||||
elseif(strlen($album_date) == 7)
|
||||
$album_date .= '-01';
|
||||
|
||||
return DateTime::createFromFormat('Y-m-d', $album_date)->getTimestamp();
|
||||
}
|
||||
|
||||
private function getAlbumType() {
|
||||
return $this->getInput('albumtype');
|
||||
}
|
||||
|
||||
private function getCountry() {
|
||||
return $this->getInput('country');
|
||||
}
|
||||
|
||||
private function getToken() {
|
||||
$cacheFac = new CacheFactory();
|
||||
$cacheFac->setWorkingDir(PATH_LIB_CACHES);
|
||||
$cache = $cacheFac->create(Configuration::getConfig('cache', 'type'));
|
||||
$cache->setScope(get_called_class());
|
||||
$cache->setKey(array('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 getArtist() {
|
||||
if(!is_null($this->getInput('spotifyuri')) && strpos($this->getInput('spotifyuri'), ',') === false) {
|
||||
$artist = $this->fetchContent(self::APIURI . 'artists/'
|
||||
. $this->getId($this->artists[0]));
|
||||
$this->uri = $artist['external_urls']['spotify'];
|
||||
$this->name = $artist['name'] . ' - Spotify';
|
||||
} else {
|
||||
$this->uri = parent::getURI();
|
||||
$this->name = parent::getName();
|
||||
}
|
||||
}
|
||||
|
||||
private function getAllArtists() {
|
||||
Debug::log('Parsing all artists');
|
||||
$this->artists = explode(',', $this->getInput('spotifyuri'));
|
||||
}
|
||||
|
||||
private function getAllAlbums() {
|
||||
$this->albums = array();
|
||||
|
||||
$this->getAllArtists();
|
||||
|
||||
Debug::log('Fetching all albums');
|
||||
foreach($this->artists as $artist) {
|
||||
$fetch = true;
|
||||
$offset = 0;
|
||||
|
||||
while($fetch) {
|
||||
$partial_albums = $this->fetchContent(self::APIURI . 'artists/'
|
||||
. $this->getId($artist)
|
||||
. '/albums?limit=50&include_groups='
|
||||
. $this->getAlbumType()
|
||||
. '&country='
|
||||
. $this->getCountry()
|
||||
. '&offset='
|
||||
. $offset);
|
||||
|
||||
if(!empty($partial_albums['items']))
|
||||
$this->albums = array_merge($this->albums,
|
||||
$partial_albums['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, array('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, array('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 sortAlbums() {
|
||||
Debug::log('Sorting albums');
|
||||
usort($this->albums, function($album1, $album2) {
|
||||
if($this->getDate($album1['release_date']) < $this->getDate($album2['release_date']))
|
||||
return 1;
|
||||
else
|
||||
return -1;
|
||||
});
|
||||
}
|
||||
|
||||
public function collectData() {
|
||||
$offset = 0;
|
||||
|
||||
$this->getAllAlbums();
|
||||
$this->sortAlbums();
|
||||
|
||||
Debug::log('Building RSS feed');
|
||||
foreach($this->albums as $album) {
|
||||
$item = array();
|
||||
$item['title'] = $album['name'];
|
||||
$item['uri'] = $album['external_urls']['spotify'];
|
||||
|
||||
$item['timestamp'] = $this->getDate($album['release_date']);
|
||||
$item['author'] = $album['artists'][0]['name'];
|
||||
$item['categories'] = array($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>';
|
||||
|
||||
$this->items[] = $item;
|
||||
|
||||
if(count($this->items) >= 10)
|
||||
break;
|
||||
}
|
||||
}
|
||||
}
|
||||
Loading…
Add table
Reference in a new issue