summaryrefslogtreecommitdiff
path: root/src/libpiano/piano.c
diff options
context:
space:
mode:
authorLars-Dominik Braun <lars@6xq.net>2012-05-01 11:26:30 +0200
committerLars-Dominik Braun <lars@6xq.net>2012-05-01 11:26:30 +0200
commit2996dda98357643334a334a6fcac05cd0c9065ea (patch)
treef0c62aab3ad88d7ce33cd8567ec4279d5b76eac0 /src/libpiano/piano.c
parentb47ecbe9d30952861dabd1591a01bd5964049fcd (diff)
downloadpianobar-windows-2996dda98357643334a334a6fcac05cd0c9065ea.tar.gz
pianobar-windows-2996dda98357643334a334a6fcac05cd0c9065ea.tar.bz2
pianobar-windows-2996dda98357643334a334a6fcac05cd0c9065ea.zip
piano: Split piano.c into request.c and response.c
Diffstat (limited to 'src/libpiano/piano.c')
-rw-r--r--src/libpiano/piano.c1096
1 files changed, 1 insertions, 1095 deletions
diff --git a/src/libpiano/piano.c b/src/libpiano/piano.c
index 0ac96b6..f9dfa51 100644
--- a/src/libpiano/piano.c
+++ b/src/libpiano/piano.c
@@ -29,22 +29,13 @@ THE SOFTWARE.
#include <stdio.h>
#include <string.h>
#include <stdlib.h>
-#include <time.h>
#include <assert.h>
#include <stdint.h>
-#include <json.h>
-
-/* needed for urlencode */
-#include <waitress.h>
#include "piano_private.h"
#include "piano.h"
-#include "crypt.h"
#include "config.h"
-#define PIANO_RPC_PATH "/services/json/?"
-#define PIANO_SEND_BUFFER_SIZE 10000
-
/* initialize piano handle
* @param piano handle
* @return nothing
@@ -154,7 +145,7 @@ static void PianoDestroyGenres (PianoGenre_t *genres) {
/* destroy user information
*/
-static void PianoDestroyUserInfo (PianoUserInfo_t *user) {
+void PianoDestroyUserInfo (PianoUserInfo_t *user) {
free (user->authToken);
free (user->listenerId);
}
@@ -212,1091 +203,6 @@ static const char *PianoAudioFormatToString (PianoAudioFormat_t format) {
}
}
-/* prepare piano request (initializes request type, urlpath and postData)
- * @param piano handle
- * @param request structure
- * @param request type
- */
-PianoReturn_t PianoRequest (PianoHandle_t *ph, PianoRequest_t *req,
- PianoRequestType_t type) {
- const char *jsonSendBuf;
- const char *method = NULL;
- json_object *j = json_object_new_object ();
- /* corrected timestamp */
- time_t timestamp = time (NULL) - ph->timeOffset;
- bool encrypted = true;
-
- assert (ph != NULL);
- assert (req != NULL);
-
- req->type = type;
- /* no tls by default */
- req->secure = false;
-
- switch (req->type) {
- case PIANO_REQUEST_LOGIN: {
- /* authenticate user */
- PianoRequestDataLogin_t *logindata = req->data;
-
- assert (logindata != NULL);
-
- switch (logindata->step) {
- case 0:
- encrypted = false;
- req->secure = true;
-
- json_object_object_add (j, "username",
- json_object_new_string ("android"));
- json_object_object_add (j, "password",
- json_object_new_string ("AC7IBG09A3DTSYM4R41UJWL07VLN8JI7"));
- json_object_object_add (j, "deviceModel",
- json_object_new_string ("android-generic"));
- json_object_object_add (j, "version",
- json_object_new_string ("5"));
- json_object_object_add (j, "includeUrls",
- json_object_new_boolean (true));
- snprintf (req->urlPath, sizeof (req->urlPath),
- PIANO_RPC_PATH "method=auth.partnerLogin");
- break;
-
- case 1: {
- char *urlencAuthToken;
-
- req->secure = true;
-
- json_object_object_add (j, "loginType",
- json_object_new_string ("user"));
- json_object_object_add (j, "username",
- json_object_new_string (logindata->user));
- json_object_object_add (j, "password",
- json_object_new_string (logindata->password));
- json_object_object_add (j, "partnerAuthToken",
- json_object_new_string (ph->partnerAuthToken));
- json_object_object_add (j, "syncTime",
- json_object_new_int (timestamp));
-
- urlencAuthToken = WaitressUrlEncode (ph->partnerAuthToken);
- assert (urlencAuthToken != NULL);
- snprintf (req->urlPath, sizeof (req->urlPath),
- PIANO_RPC_PATH "method=auth.userLogin&"
- "auth_token=%s&partner_id=%i", urlencAuthToken,
- ph->partnerId);
- free (urlencAuthToken);
-
- break;
- }
- }
- break;
- }
-
- case PIANO_REQUEST_GET_STATIONS: {
- /* get stations, user must be authenticated */
- assert (ph->user.listenerId != NULL);
- method = "user.getStationList";
- break;
- }
-
- case PIANO_REQUEST_GET_PLAYLIST: {
- /* get playlist for specified station */
- PianoRequestDataGetPlaylist_t *reqData = req->data;
-
- assert (reqData != NULL);
- assert (reqData->station != NULL);
- assert (reqData->station->id != NULL);
- assert (reqData->format != PIANO_AF_UNKNOWN);
-
- req->secure = true;
-
- json_object_object_add (j, "stationToken",
- json_object_new_string (reqData->station->id));
-
- method = "station.getPlaylist";
- break;
- }
-
- case PIANO_REQUEST_ADD_FEEDBACK: {
- /* low-level, don't use directly (see _RATE_SONG and _MOVE_SONG) */
- PianoRequestDataAddFeedback_t *reqData = req->data;
-
- assert (reqData != NULL);
- assert (reqData->trackToken != NULL);
- assert (reqData->rating != PIANO_RATE_NONE);
-
- json_object_object_add (j, "trackToken",
- json_object_new_string (reqData->trackToken));
- json_object_object_add (j, "isPositive",
- json_object_new_boolean (reqData->rating == PIANO_RATE_LOVE));
-
- method = "station.addFeedback";
- break;
- }
-
- case PIANO_REQUEST_RENAME_STATION: {
- PianoRequestDataRenameStation_t *reqData = req->data;
-
- assert (reqData != NULL);
- assert (reqData->station != NULL);
- assert (reqData->newName != NULL);
-
- json_object_object_add (j, "stationToken",
- json_object_new_string (reqData->station->id));
- json_object_object_add (j, "stationName",
- json_object_new_string (reqData->newName));
-
- method = "station.renameStation";
- break;
- }
-
- case PIANO_REQUEST_DELETE_STATION: {
- /* delete station */
- PianoStation_t *station = req->data;
-
- assert (station != NULL);
- assert (station->id != NULL);
-
- json_object_object_add (j, "stationToken",
- json_object_new_string (station->id));
-
- method = "station.deleteStation";
- break;
- }
-
- case PIANO_REQUEST_SEARCH: {
- /* search for artist/song title */
- PianoRequestDataSearch_t *reqData = req->data;
-
- assert (reqData != NULL);
- assert (reqData->searchStr != NULL);
-
- json_object_object_add (j, "searchText",
- json_object_new_string (reqData->searchStr));
-
- method = "music.search";
- break;
- }
-
- case PIANO_REQUEST_CREATE_STATION: {
- /* create new station from specified musicid (type=mi, get one by
- * performing a search) or shared station id (type=sh) */
- PianoRequestDataCreateStation_t *reqData = req->data;
-
- assert (reqData != NULL);
- assert (reqData->id != NULL);
-
- json_object_object_add (j, "musicToken",
- json_object_new_string (reqData->id));
-
- method = "station.createStation";
- break;
- }
-
- case PIANO_REQUEST_ADD_SEED: {
- /* add another seed to specified station */
- PianoRequestDataAddSeed_t *reqData = req->data;
-
- assert (reqData != NULL);
- assert (reqData->station != NULL);
- assert (reqData->musicId != NULL);
-
- json_object_object_add (j, "musicToken",
- json_object_new_string (reqData->musicId));
- json_object_object_add (j, "stationToken",
- json_object_new_string (reqData->station->id));
-
- method = "station.addMusic";
- break;
- }
-
- case PIANO_REQUEST_ADD_TIRED_SONG: {
- /* ban song for a month from all stations */
- PianoSong_t *song = req->data;
-
- assert (song != NULL);
-
- json_object_object_add (j, "trackToken",
- json_object_new_string (song->trackToken));
-
- method = "user.sleepSong";
- break;
- }
-
- case PIANO_REQUEST_SET_QUICKMIX: {
- /* select stations included in quickmix (see useQuickMix flag of
- * PianoStation_t) */
- PianoStation_t *curStation = ph->stations;
- json_object *a = json_object_new_array ();
-
- while (curStation != NULL) {
- /* quick mix can't contain itself */
- if (curStation->useQuickMix && !curStation->isQuickMix) {
- json_object_array_add (a,
- json_object_new_string (curStation->id));
- }
-
- curStation = curStation->next;
- }
-
- json_object_object_add (j, "quickMixStationIds", a);
-
- method = "user.setQuickMix";
- break;
- }
-
- case PIANO_REQUEST_GET_GENRE_STATIONS: {
- /* receive list of pandora's genre stations */
- method = "station.getGenreStations";
- break;
- }
-
- case PIANO_REQUEST_TRANSFORM_STATION: {
- /* transform shared station into private */
- PianoStation_t *station = req->data;
-
- assert (station != NULL);
-
- json_object_object_add (j, "stationToken",
- json_object_new_string (station->id));
-
- method = "station.transformSharedStation";
- break;
- }
-
- case PIANO_REQUEST_EXPLAIN: {
- /* explain why particular song was played */
- PianoRequestDataExplain_t *reqData = req->data;
-
- assert (reqData != NULL);
- assert (reqData->song != NULL);
-
- json_object_object_add (j, "trackToken",
- json_object_new_string (reqData->song->trackToken));
-
- method = "track.explainTrack";
- break;
- }
-
- case PIANO_REQUEST_GET_SEED_SUGGESTIONS: {
-#if 0
- /* find similar artists */
- PianoRequestDataGetSeedSuggestions_t *reqData = req->data;
-
- assert (reqData != NULL);
- assert (reqData->musicId != NULL);
- assert (reqData->max != 0);
-
- snprintf (xmlSendBuf, sizeof (xmlSendBuf), "<?xml version=\"1.0\"?>"
- "<methodCall><methodName>music.getSeedSuggestions</methodName>"
- "<params><param><value><int>%lu</int></value></param>"
- /* auth token */
- "<param><value><string>%s</string></value></param>"
- /* station id */
- "<param><value><string>%s</string></value></param>"
- /* seed music id */
- "<param><value><string>%s</string></value></param>"
- /* max */
- "<param><value><int>%u</int></value></param>"
- "</params></methodCall>", (unsigned long) timestamp,
- ph->user.authToken, reqData->station->id, reqData->musicId,
- reqData->max);
- snprintf (req->urlPath, sizeof (req->urlPath), PIANO_RPC_PATH
- "rid=%s&lid=%s&method=getSeedSuggestions&arg1=%s&arg2=%u",
- ph->routeId, ph->user.listenerId, reqData->musicId, reqData->max);
-#endif
- break;
- }
-
- case PIANO_REQUEST_BOOKMARK_SONG: {
- /* bookmark song */
- PianoSong_t *song = req->data;
-
- assert (song != NULL);
-
- json_object_object_add (j, "trackToken",
- json_object_new_string (song->trackToken));
-
- method = "bookmark.addSongBookmark";
- break;
- }
-
- case PIANO_REQUEST_BOOKMARK_ARTIST: {
- /* bookmark artist */
- PianoSong_t *song = req->data;
-
- assert (song != NULL);
-
- json_object_object_add (j, "trackToken",
- json_object_new_string (song->trackToken));
-
- method = "bookmark.addArtistBookmark";
- break;
- }
-
- case PIANO_REQUEST_GET_STATION_INFO: {
- /* get station information (seeds and feedback) */
- PianoRequestDataGetStationInfo_t *reqData = req->data;
-
- assert (reqData != NULL);
- assert (reqData->station != NULL);
-
- json_object_object_add (j, "stationToken",
- json_object_new_string (reqData->station->id));
- json_object_object_add (j, "includeExtendedAttributes",
- json_object_new_boolean (true));
-
- method = "station.getStation";
- break;
- }
-
- case PIANO_REQUEST_DELETE_FEEDBACK: {
- PianoSong_t *song = req->data;
-
- assert (song != NULL);
-
- json_object_object_add (j, "feedbackId",
- json_object_new_string (song->feedbackId));
-
- method = "station.deleteFeedback";
- break;
- }
-
- case PIANO_REQUEST_DELETE_SEED: {
- PianoRequestDataDeleteSeed_t *reqData = req->data;
- char *seedId = NULL;
-
- assert (reqData != NULL);
- assert (reqData->song != NULL || reqData->artist != NULL ||
- reqData->station != NULL);
-
- if (reqData->song != NULL) {
- seedId = reqData->song->seedId;
- } else if (reqData->artist != NULL) {
- seedId = reqData->artist->seedId;
- } else if (reqData->station != NULL) {
- seedId = reqData->station->seedId;
- }
-
- assert (seedId != NULL);
-
- json_object_object_add (j, "seedId",
- json_object_new_string (seedId));
-
- method = "station.deleteMusic";
- break;
- }
-
- /* "high-level" wrapper */
- case PIANO_REQUEST_RATE_SONG: {
- /* love/ban song */
- PianoRequestDataRateSong_t *reqData = req->data;
- PianoReturn_t pRet;
-
- assert (reqData != NULL);
- assert (reqData->song != NULL);
- assert (reqData->rating != PIANO_RATE_NONE);
-
- PianoRequestDataAddFeedback_t transformedReqData;
- transformedReqData.stationId = reqData->song->stationId;
- transformedReqData.trackToken = reqData->song->trackToken;
- transformedReqData.rating = reqData->rating;
- req->data = &transformedReqData;
-
- /* create request data (url, post data) */
- pRet = PianoRequest (ph, req, PIANO_REQUEST_ADD_FEEDBACK);
- /* and reset request type/data */
- req->type = PIANO_REQUEST_RATE_SONG;
- req->data = reqData;
-
- return pRet;
- break;
- }
-
- case PIANO_REQUEST_MOVE_SONG: {
- /* move song to a different station, needs two requests */
- PianoRequestDataMoveSong_t *reqData = req->data;
- PianoRequestDataAddFeedback_t transformedReqData;
- PianoReturn_t pRet;
-
- assert (reqData != NULL);
- assert (reqData->song != NULL);
- assert (reqData->from != NULL);
- assert (reqData->to != NULL);
- assert (reqData->step < 2);
-
- transformedReqData.trackToken = reqData->song->trackToken;
- req->data = &transformedReqData;
-
- switch (reqData->step) {
- case 0:
- transformedReqData.stationId = reqData->from->id;
- transformedReqData.rating = PIANO_RATE_BAN;
- break;
-
- case 1:
- transformedReqData.stationId = reqData->to->id;
- transformedReqData.rating = PIANO_RATE_LOVE;
- break;
- }
-
- /* create request data (url, post data) */
- pRet = PianoRequest (ph, req, PIANO_REQUEST_ADD_FEEDBACK);
- /* and reset request type/data */
- req->type = PIANO_REQUEST_MOVE_SONG;
- req->data = reqData;
-
- return pRet;
- break;
- }
- }
-
- /* standard parameter */
- if (method != NULL) {
- char *urlencAuthToken;
-
- assert (ph->user.authToken != NULL);
-
- urlencAuthToken = WaitressUrlEncode (ph->user.authToken);
- assert (urlencAuthToken != NULL);
-
- snprintf (req->urlPath, sizeof (req->urlPath), PIANO_RPC_PATH
- "method=%s&auth_token=%s&partner_id=%i&user_id=%s", method,
- urlencAuthToken, ph->partnerId, ph->user.listenerId);
-
- free (urlencAuthToken);
-
- json_object_object_add (j, "userAuthToken",
- json_object_new_string (ph->user.authToken));
- json_object_object_add (j, "syncTime",
- json_object_new_int (timestamp));
- }
-
- /* json to string */
- jsonSendBuf = json_object_to_json_string (j);
- if (encrypted) {
- if ((req->postData = PianoEncryptString (jsonSendBuf)) == NULL) {
- return PIANO_RET_OUT_OF_MEMORY;
- }
- } else {
- req->postData = strdup (jsonSendBuf);
- }
- json_object_put (j);
-
- return PIANO_RET_OK;
-}
-
-static char *PianoJsonStrdup (json_object *j, const char *key) {
- return strdup (json_object_get_string (json_object_object_get (j, key)));
-}
-
-static void PianoJsonParseStation (json_object *j, PianoStation_t *s) {
- s->name = PianoJsonStrdup (j, "stationName");
- s->id = PianoJsonStrdup (j, "stationToken");
- s->isCreator = !json_object_get_boolean (json_object_object_get (j,
- "isShared"));
- s->isQuickMix = json_object_get_boolean (json_object_object_get (j,
- "isQuickMix"));
-}
-
-/* parse xml response and update data structures/return new data structure
- * @param piano handle
- * @param initialized request (expects responseData to be a NUL-terminated
- * string)
- */
-PianoReturn_t PianoResponse (PianoHandle_t *ph, PianoRequest_t *req) {
- PianoReturn_t ret = PIANO_RET_OK;
- json_object *j, *result, *status;
-
- assert (ph != NULL);
- assert (req != NULL);
-
- j = json_tokener_parse (req->responseData);
-
- status = json_object_object_get (j, "stat");
- if (status == NULL) {
- json_object_put (j);
- return PIANO_RET_INVALID_RESPONSE;
- }
-
- /* error handling */
- if (strcmp (json_object_get_string (status), "ok") != 0) {
- json_object *code = json_object_object_get (j, "code");
- if (code == NULL) {
- ret = PIANO_RET_INVALID_RESPONSE;
- } else {
- ret = json_object_get_int (code)+PIANO_RET_OFFSET;
- }
-
- json_object_put (j);
- return ret;
- }
-
- result = json_object_object_get (j, "result");
-
- switch (req->type) {
- case PIANO_REQUEST_LOGIN: {
- /* authenticate user */
- PianoRequestDataLogin_t *reqData = req->data;
-
- assert (req->responseData != NULL);
- assert (reqData != NULL);
-
- switch (reqData->step) {
- case 0: {
- /* decrypt timestamp */
- const char *cryptedTimestamp = json_object_get_string (
- json_object_object_get (result, "syncTime"));
- unsigned long timestamp = 0;
- const time_t realTimestamp = time (NULL);
- char *decryptedTimestamp = NULL;
- size_t decryptedSize;
-
- ret = PIANO_RET_ERR;
- if ((decryptedTimestamp = PianoDecryptString (cryptedTimestamp,
- &decryptedSize)) != NULL && decryptedSize > 4) {
- /* skip four bytes garbage(?) at beginning */
- timestamp = strtoul (decryptedTimestamp+4, NULL, 0);
- ph->timeOffset = realTimestamp - timestamp;
- ret = PIANO_RET_CONTINUE_REQUEST;
- }
- free (decryptedTimestamp);
- /* get auth token */
- ph->partnerAuthToken = PianoJsonStrdup (result,
- "partnerAuthToken");
- ph->partnerId = json_object_get_int (
- json_object_object_get (result, "partnerId"));
- ++reqData->step;
- break;
- }
-
- case 1:
- /* information exists when reauthenticating, destroy to
- * avoid memleak */
- if (ph->user.listenerId != NULL) {
- PianoDestroyUserInfo (&ph->user);
- }
- ph->user.listenerId = PianoJsonStrdup (result, "userId");
- ph->user.authToken = PianoJsonStrdup (result,
- "userAuthToken");
- break;
- }
- break;
- }
-
- case PIANO_REQUEST_GET_STATIONS: {
- /* get stations */
- assert (req->responseData != NULL);
-
- json_object *stations = json_object_object_get (result,
- "stations"), *mix = NULL;
-
- for (size_t i=0; i < json_object_array_length (stations); i++) {
- PianoStation_t *tmpStation;
- json_object *s = json_object_array_get_idx (stations, i);
-
- if ((tmpStation = calloc (1, sizeof (*tmpStation))) == NULL) {
- return PIANO_RET_OUT_OF_MEMORY;
- }
-
- PianoJsonParseStation (s, tmpStation);
-
- if (tmpStation->isQuickMix) {
- /* fix flags on other stations later */
- mix = json_object_object_get (s, "quickMixStationIds");
- }
-
- /* start new linked list or append */
- if (ph->stations == NULL) {
- ph->stations = tmpStation;
- } else {
- PianoStation_t *curStation = ph->stations;
- while (curStation->next != NULL) {
- curStation = curStation->next;
- }
- curStation->next = tmpStation;
- }
- }
-
- /* fix quickmix flags */
- if (mix != NULL) {
- PianoStation_t *curStation = ph->stations;
- while (curStation != NULL) {
- for (size_t i = 0; i < json_object_array_length (mix); i++) {
- json_object *id = json_object_array_get_idx (mix, i);
- if (strcmp (json_object_get_string (id),
- curStation->id) == 0) {
- curStation->useQuickMix = true;
- }
- }
- curStation = curStation->next;
- }
- }
- break;
- }
-
- case PIANO_REQUEST_GET_PLAYLIST: {
- /* get playlist, usually four songs */
- PianoRequestDataGetPlaylist_t *reqData = req->data;
- PianoSong_t *playlist = NULL;
-
- assert (req->responseData != NULL);
- assert (reqData != NULL);
-
- json_object *items = json_object_object_get (result, "items");
- assert (items != NULL);
-
- for (size_t i=0; i < json_object_array_length (items); i++) {
- json_object *s = json_object_array_get_idx (items, i);
- PianoSong_t *song;
-
- if ((song = calloc (1, sizeof (*song))) == NULL) {
- return PIANO_RET_OUT_OF_MEMORY;
- }
-
- if (json_object_object_get (s, "artistName") == NULL) {
- free (song);
- continue;
- }
- song->audioUrl = strdup (json_object_get_string (json_object_object_get (json_object_object_get (json_object_object_get (s, "audioUrlMap"), "highQuality"), "audioUrl")));
- song->artist = PianoJsonStrdup (s, "artistName");
- song->album = PianoJsonStrdup (s, "albumName");
- song->title = PianoJsonStrdup (s, "songName");
- song->trackToken = PianoJsonStrdup (s, "trackToken");
- song->stationId = PianoJsonStrdup (s, "stationId");
- song->fileGain = json_object_get_double (
- json_object_object_get (s, "trackGain"));
- song->audioFormat = PIANO_AF_AACPLUS;
- switch (json_object_get_int (json_object_object_get (s,
- "songRating"))) {
- case 1:
- song->rating = PIANO_RATE_LOVE;
- break;
- }
-
- /* begin linked list or append */
- if (playlist == NULL) {
- playlist = song;
- } else {
- PianoSong_t *curSong = playlist;
- while (curSong->next != NULL) {
- curSong = curSong->next;
- }
- curSong->next = song;
- }
- }
-
- reqData->retPlaylist = playlist;
- break;
- }
-
- case PIANO_REQUEST_RATE_SONG: {
- /* love/ban song */
- PianoRequestDataRateSong_t *reqData = req->data;
- reqData->song->rating = reqData->rating;
- break;
- }
-
- case PIANO_REQUEST_ADD_FEEDBACK:
- /* never ever use this directly, low-level call */
- assert (0);
- break;
-
- case PIANO_REQUEST_RENAME_STATION: {
- /* rename station and update PianoStation_t structure */
- PianoRequestDataRenameStation_t *reqData = req->data;
-
- assert (reqData != NULL);
- assert (reqData->station != NULL);
- assert (reqData->newName != NULL);
-
- free (reqData->station->name);
- reqData->station->name = strdup (reqData->newName);
- break;
- }
-
- case PIANO_REQUEST_MOVE_SONG: {
- /* move song to different station */
- PianoRequestDataMoveSong_t *reqData = req->data;
-
- assert (req->responseData != NULL);
- assert (reqData != NULL);
- assert (reqData->step < 2);
-
- if (reqData->step == 0) {
- ret = PIANO_RET_CONTINUE_REQUEST;
- ++reqData->step;
- }
- break;
- }
-
- case PIANO_REQUEST_DELETE_STATION: {
- /* delete station from server and station list */
- PianoStation_t *station = req->data;
-
- assert (station != NULL);
-
- /* delete station from local station list */
- PianoStation_t *curStation = ph->stations, *lastStation = NULL;
- while (curStation != NULL) {
- if (curStation == station) {
- if (lastStation != NULL) {
- lastStation->next = curStation->next;
- } else {
- /* first station in list */
- ph->stations = curStation->next;
- }
- PianoDestroyStation (curStation);
- free (curStation);
- break;
- }
- lastStation = curStation;
- curStation = curStation->next;
- }
- break;
- }
-
- case PIANO_REQUEST_SEARCH: {
- /* search artist/song */
- PianoRequestDataSearch_t *reqData = req->data;
- PianoSearchResult_t *searchResult;
-
- assert (req->responseData != NULL);
- assert (reqData != NULL);
-
- searchResult = &reqData->searchResult;
- memset (searchResult, 0, sizeof (*searchResult));
-
- /* get artists */
- json_object *artists = json_object_object_get (result, "artists");
- if (artists != NULL) {
- for (size_t i=0; i < json_object_array_length (artists); i++) {
- json_object *a = json_object_array_get_idx (artists, i);
- PianoArtist_t *artist;
-
- if ((artist = calloc (1, sizeof (*artist))) == NULL) {
- return PIANO_RET_OUT_OF_MEMORY;
- }
-
- artist->name = PianoJsonStrdup (a, "artistName");
- artist->musicId = PianoJsonStrdup (a, "musicToken");
-
- /* add result to linked list */
- if (searchResult->artists == NULL) {
- searchResult->artists = artist;
- } else {
- PianoArtist_t *curArtist = searchResult->artists;
- while (curArtist->next != NULL) {
- curArtist = curArtist->next;
- }
- curArtist->next = artist;
- }
- }
- }
-
- /* get songs */
- json_object *songs = json_object_object_get (result, "songs");
- if (songs != NULL) {
- for (size_t i=0; i < json_object_array_length (songs); i++) {
- json_object *s = json_object_array_get_idx (songs, i);
- PianoSong_t *song;
-
- if ((song = calloc (1, sizeof (*song))) == NULL) {
- return PIANO_RET_OUT_OF_MEMORY;
- }
-
- song->title = PianoJsonStrdup (s, "songName");
- song->artist = PianoJsonStrdup (s, "artistName");
- song->musicId = PianoJsonStrdup (s, "musicToken");
-
- /* add result to linked list */
- if (searchResult->songs == NULL) {
- searchResult->songs = song;
- } else {
- PianoSong_t *curSong = searchResult->songs;
- while (curSong->next != NULL) {
- curSong = curSong->next;
- }
- curSong->next = song;
- }
- }
- }
- break;
- }
-
- case PIANO_REQUEST_CREATE_STATION: {
- /* create station, insert new station into station list on success */
- PianoStation_t *tmpStation;
-
- if ((tmpStation = calloc (1, sizeof (*tmpStation))) == NULL) {
- return PIANO_RET_OUT_OF_MEMORY;
- }
-
- PianoJsonParseStation (result, tmpStation);
-
- /* start new linked list or append */
- if (ph->stations == NULL) {
- ph->stations = tmpStation;
- } else {
- PianoStation_t *curStation = ph->stations;
- while (curStation->next != NULL) {
- curStation = curStation->next;
- }
- curStation->next = tmpStation;
- }
- break;
- }
-
- case PIANO_REQUEST_ADD_SEED:
- case PIANO_REQUEST_ADD_TIRED_SONG:
- case PIANO_REQUEST_SET_QUICKMIX:
- case PIANO_REQUEST_BOOKMARK_SONG:
- case PIANO_REQUEST_BOOKMARK_ARTIST:
- case PIANO_REQUEST_DELETE_FEEDBACK:
- case PIANO_REQUEST_DELETE_SEED:
- /* response unused */
- break;
-
- case PIANO_REQUEST_GET_GENRE_STATIONS: {
- /* get genre stations */
- json_object *categories = json_object_object_get (result, "categories");
- if (categories != NULL) {
- for (size_t i = 0; i < json_object_array_length (categories); i++) {
- json_object *c = json_object_array_get_idx (categories, i);
- PianoGenreCategory_t *tmpGenreCategory;
-
- if ((tmpGenreCategory = calloc (1,
- sizeof (*tmpGenreCategory))) == NULL) {
- return PIANO_RET_OUT_OF_MEMORY;
- }
-
- tmpGenreCategory->name = PianoJsonStrdup (c,
- "categoryName");
-
- /* get genre subnodes */
- json_object *stations = json_object_object_get (c,
- "stations");
- if (stations != NULL) {
- for (size_t k = 0;
- k < json_object_array_length (stations); k++) {
- json_object *s =
- json_object_array_get_idx (stations, k);
- PianoGenre_t *tmpGenre;
-
- if ((tmpGenre = calloc (1,
- sizeof (*tmpGenre))) == NULL) {
- return PIANO_RET_OUT_OF_MEMORY;
- }
-
- /* get genre attributes */
- tmpGenre->name = PianoJsonStrdup (s,
- "stationName");
- tmpGenre->musicId = PianoJsonStrdup (s,
- "stationToken");
-
- /* append station */
- if (tmpGenreCategory->genres == NULL) {
- tmpGenreCategory->genres = tmpGenre;
- } else {
- PianoGenre_t *curGenre =
- tmpGenreCategory->genres;
- while (curGenre->next != NULL) {
- curGenre = curGenre->next;
- }
- curGenre->next = tmpGenre;
- }
- }
- }
- /* append category */
- if (ph->genreStations == NULL) {
- ph->genreStations = tmpGenreCategory;
- } else {
- PianoGenreCategory_t *curCat = ph->genreStations;
- while (curCat->next != NULL) {
- curCat = curCat->next;
- }
- curCat->next = tmpGenreCategory;
- }
- }
- }
- break;
- }
-
- case PIANO_REQUEST_TRANSFORM_STATION: {
- /* transform shared station into private and update isCreator flag */
- PianoStation_t *station = req->data;
-
- assert (req->responseData != NULL);
- assert (station != NULL);
-
- station->isCreator = 1;
- break;
- }
-
- case PIANO_REQUEST_EXPLAIN: {
- /* explain why song was selected */
- PianoRequestDataExplain_t *reqData = req->data;
- const size_t strSize = 1024;
- size_t pos = 0;
-
- assert (reqData != NULL);
-
- json_object *explanations = json_object_object_get (result,
- "explanations");
- if (explanations != NULL) {
- reqData->retExplain = malloc (strSize *
- sizeof (*reqData->retExplain));
- strncpy (reqData->retExplain, "We're playing this track "
- "because it features ", strSize);
- pos = strlen (reqData->retExplain);
- for (size_t i=0; i < json_object_array_length (explanations); i++) {
- json_object *e = json_object_array_get_idx (explanations,
- i);
- const char *s = json_object_get_string (
- json_object_object_get (e, "focusTraitName"));
-
- strncpy (&reqData->retExplain[pos], s, strSize-pos-1);
- pos += strlen (s);
- if (i < json_object_array_length (explanations)-2) {
- strncpy (&reqData->retExplain[pos], ", ", strSize-pos-1);
- pos += 2;
- } else if (i == json_object_array_length (explanations)-2) {
- strncpy (&reqData->retExplain[pos], " and ", strSize-pos-1);
- pos += 5;
- } else {
- strncpy (&reqData->retExplain[pos], ".", strSize-pos-1);
- pos += 1;
- }
- }
- }
- break;
- }
-
- case PIANO_REQUEST_GET_SEED_SUGGESTIONS: {
-#if 0
- /* find similar artists */
- PianoRequestDataGetSeedSuggestions_t *reqData = req->data;
-
- assert (req->responseData != NULL);
- assert (reqData != NULL);
-
- ret = PianoXmlParseSeedSuggestions (req->responseData,
- &reqData->searchResult);
-#endif
- break;
- }
-
- case PIANO_REQUEST_GET_STATION_INFO: {
- /* get station information (seeds and feedback) */
- PianoRequestDataGetStationInfo_t *reqData = req->data;
- PianoStationInfo_t *info;
-
- assert (reqData != NULL);
-
- info = &reqData->info;
- assert (info != NULL);
-
- /* parse music seeds */
- json_object *music = json_object_object_get (result, "music");
- if (music != NULL) {
- /* songs */
- json_object *songs = json_object_object_get (music, "songs");
- if (songs != NULL) {
- for (size_t i = 0; i < json_object_array_length (songs); i++) {
- json_object *s = json_object_array_get_idx (songs, i);
- PianoSong_t *seedSong;
-
- seedSong = calloc (1, sizeof (*seedSong));
- if (seedSong == NULL) {
- return PIANO_RET_OUT_OF_MEMORY;
- }
-
- seedSong->title = PianoJsonStrdup (s, "songName");
- seedSong->artist = PianoJsonStrdup (s, "artistName");
- seedSong->seedId = PianoJsonStrdup (s, "seedId");
-
- if (info->songSeeds == NULL) {
- info->songSeeds = seedSong;
- } else {
- PianoSong_t *curSong = info->songSeeds;
- while (curSong->next != NULL) {
- curSong = curSong->next;
- }
- curSong->next = seedSong;
- }
- }
- }
-
- /* artists */
- json_object *artists = json_object_object_get (music,
- "artists");
- if (artists != NULL) {
- for (size_t i = 0; i < json_object_array_length (artists); i++) {
- json_object *a = json_object_array_get_idx (artists, i);
- PianoArtist_t *seedArtist;
-
- seedArtist = calloc (1, sizeof (*seedArtist));
- if (seedArtist == NULL) {
- return PIANO_RET_OUT_OF_MEMORY;
- }
-
- seedArtist->name = PianoJsonStrdup (a, "artistName");
- seedArtist->seedId = PianoJsonStrdup (a, "seedId");
-
- if (info->artistSeeds == NULL) {
- info->artistSeeds = seedArtist;
- } else {
- PianoArtist_t *curArtist = info->artistSeeds;
- while (curArtist->next != NULL) {
- curArtist = curArtist->next;
- }
- curArtist->next = seedArtist;
- }
- }
- }
- }
-
- /* parse feedback */
- json_object *feedback = json_object_object_get (result,
- "feedback");
- if (feedback != NULL) {
- json_object_object_foreach (feedback, key, val) {
- for (size_t i = 0; i < json_object_array_length (val); i++) {
- json_object *s = json_object_array_get_idx (val, i);
- PianoSong_t *feedbackSong;
-
- feedbackSong = calloc (1, sizeof (*feedbackSong));
- if (feedbackSong == NULL) {
- return PIANO_RET_OUT_OF_MEMORY;
- }
-
- feedbackSong->title = PianoJsonStrdup (s, "songName");
- feedbackSong->artist = PianoJsonStrdup (s,
- "artistName");
- feedbackSong->feedbackId = PianoJsonStrdup (s,
- "feedbackId");
- feedbackSong->rating = json_object_get_boolean (
- json_object_object_get (s, "isPositive")) ?
- PIANO_RATE_LOVE : PIANO_RATE_BAN;
-
-
- if (info->feedback == NULL) {
- info->feedback = feedbackSong;
- } else {
- PianoSong_t *curSong = info->feedback;
- while (curSong->next != NULL) {
- curSong = curSong->next;
- }
- curSong->next = feedbackSong;
- }
- }
- }
- }
- break;
- }
- }
-
- json_object_put (j);
-
- return ret;
-}
/* get station from list by id
* @param search here