third-party-mirrors/ultrasonic
1
0
Fork 0
mirror of https://gitlab.com/ultrasonic/ultrasonic.git synced 2025-06-17 07:51:06 +03:00
Code Issues Packages Projects Releases Wiki Activity

Use new subsonic api jukebox control method.

Browse Source 
Signed-off-by: Yahor Berdnikau <egorr.berd@gmail.com>
This commit is contained in:
Yahor Berdnikau 2017-11-07 22:03:52 +01:00
parent 17aaa0f87f
commit db73978596
2 changed files with 69 additions and 132 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

130
ultrasonic/src/main/java/org/moire/ultrasonic/service/RESTMusicService.java
View File

@ -56,6 +56,7 @@ import org.apache.http.protocol.HttpContext;
import org.moire.ultrasonic.R; import org.moire.ultrasonic.R;
import org.moire.ultrasonic.api.subsonic.SubsonicAPIClient; import org.moire.ultrasonic.api.subsonic.SubsonicAPIClient;
import org.moire.ultrasonic.api.subsonic.models.AlbumListType; import org.moire.ultrasonic.api.subsonic.models.AlbumListType;
import org.moire.ultrasonic.api.subsonic.models.JukeboxAction;
import org.moire.ultrasonic.api.subsonic.models.MusicDirectoryChild; import org.moire.ultrasonic.api.subsonic.models.MusicDirectoryChild;
import org.moire.ultrasonic.api.subsonic.response.GetAlbumList2Response; import org.moire.ultrasonic.api.subsonic.response.GetAlbumList2Response;
import org.moire.ultrasonic.api.subsonic.response.GetAlbumListResponse; import org.moire.ultrasonic.api.subsonic.response.GetAlbumListResponse;
@ -71,6 +72,7 @@ import org.moire.ultrasonic.api.subsonic.response.GetPodcastsResponse;
import org.moire.ultrasonic.api.subsonic.response.GetRandomSongsResponse; import org.moire.ultrasonic.api.subsonic.response.GetRandomSongsResponse;
import org.moire.ultrasonic.api.subsonic.response.GetStarredResponse; import org.moire.ultrasonic.api.subsonic.response.GetStarredResponse;
import org.moire.ultrasonic.api.subsonic.response.GetStarredTwoResponse; import org.moire.ultrasonic.api.subsonic.response.GetStarredTwoResponse;
import org.moire.ultrasonic.api.subsonic.response.JukeboxResponse;
import org.moire.ultrasonic.api.subsonic.response.LicenseResponse; import org.moire.ultrasonic.api.subsonic.response.LicenseResponse;
import org.moire.ultrasonic.api.subsonic.response.MusicFoldersResponse; import org.moire.ultrasonic.api.subsonic.response.MusicFoldersResponse;
import org.moire.ultrasonic.api.subsonic.response.SearchResponse; import org.moire.ultrasonic.api.subsonic.response.SearchResponse;
@ -81,6 +83,7 @@ import org.moire.ultrasonic.api.subsonic.response.SubsonicResponse;
import org.moire.ultrasonic.data.APIAlbumConverter; import org.moire.ultrasonic.data.APIAlbumConverter;
import org.moire.ultrasonic.data.APIArtistConverter; import org.moire.ultrasonic.data.APIArtistConverter;
import org.moire.ultrasonic.data.APIIndexesConverter; import org.moire.ultrasonic.data.APIIndexesConverter;
import org.moire.ultrasonic.data.APIJukeboxConverter;
import org.moire.ultrasonic.data.APILyricsConverter; import org.moire.ultrasonic.data.APILyricsConverter;
import org.moire.ultrasonic.data.APIMusicDirectoryConverter; import org.moire.ultrasonic.data.APIMusicDirectoryConverter;
import org.moire.ultrasonic.data.APIMusicFolderConverter; import org.moire.ultrasonic.data.APIMusicFolderConverter;
@ -106,7 +109,6 @@ import org.moire.ultrasonic.service.parser.BookmarkParser;
import org.moire.ultrasonic.service.parser.ChatMessageParser; import org.moire.ultrasonic.service.parser.ChatMessageParser;
import org.moire.ultrasonic.service.parser.ErrorParser; import org.moire.ultrasonic.service.parser.ErrorParser;
import org.moire.ultrasonic.service.parser.GenreParser; import org.moire.ultrasonic.service.parser.GenreParser;
import org.moire.ultrasonic.service.parser.JukeboxStatusParser;
import org.moire.ultrasonic.service.parser.MusicDirectoryParser; import org.moire.ultrasonic.service.parser.MusicDirectoryParser;
import org.moire.ultrasonic.service.parser.RandomSongsParser; import org.moire.ultrasonic.service.parser.RandomSongsParser;
import org.moire.ultrasonic.service.parser.ShareParser; import org.moire.ultrasonic.service.parser.ShareParser;
@ -141,8 +143,6 @@ import java.util.concurrent.atomic.AtomicReference;
import kotlin.Pair; import kotlin.Pair;
import retrofit2.Response; import retrofit2.Response;
import static java.util.Arrays.asList;
/** /**
* @author Sindre Mehus * @author Sindre Mehus
*/ */
@ -872,58 +872,80 @@ public class RESTMusicService implements MusicService
return url; return url;
} }
@Override @Override
public JukeboxStatus updateJukeboxPlaylist(List<String> ids, Context context, ProgressListener progressListener) throws Exception public JukeboxStatus updateJukeboxPlaylist(List<String> ids,
{ Context context,
int n = ids.size(); ProgressListener progressListener) throws Exception {
List<String> parameterNames = new ArrayList<String>(n + 1); updateProgressListener(progressListener, R.string.parser_reading);
parameterNames.add("action"); Response<JukeboxResponse> response = subsonicAPIClient.getApi()
.jukeboxControl(JukeboxAction.SET, null, null, ids, null)
.execute();
checkResponseSuccessful(response);
for (String ignored : ids) return APIJukeboxConverter.toDomainEntity(response.body().getJukebox());
{ }
parameterNames.add("id");
}
List<Object> parameterValues = new ArrayList<Object>(); @Override
parameterValues.add("set"); public JukeboxStatus skipJukebox(int index,
parameterValues.addAll(ids); int offsetSeconds,
Context context,
ProgressListener progressListener) throws Exception {
updateProgressListener(progressListener, R.string.parser_reading);
Response<JukeboxResponse> response = subsonicAPIClient.getApi()
.jukeboxControl(JukeboxAction.SKIP, index, offsetSeconds, null, null)
.execute();
checkResponseSuccessful(response);
return executeJukeboxCommand(context, progressListener, parameterNames, parameterValues); return APIJukeboxConverter.toDomainEntity(response.body().getJukebox());
} }
@Override @Override
public JukeboxStatus skipJukebox(int index, int offsetSeconds, Context context, ProgressListener progressListener) throws Exception public JukeboxStatus stopJukebox(Context context,
{ ProgressListener progressListener) throws Exception {
List<String> parameterNames = asList("action", "index", "offset"); updateProgressListener(progressListener, R.string.parser_reading);
List<Object> parameterValues = Arrays.<Object>asList("skip", index, offsetSeconds); Response<JukeboxResponse> response = subsonicAPIClient.getApi()
return executeJukeboxCommand(context, progressListener, parameterNames, parameterValues); .jukeboxControl(JukeboxAction.STOP, null, null, null, null)
} .execute();
checkResponseSuccessful(response);
@Override return APIJukeboxConverter.toDomainEntity(response.body().getJukebox());
public JukeboxStatus stopJukebox(Context context, ProgressListener progressListener) throws Exception }
{
return executeJukeboxCommand(context, progressListener, Collections.singletonList("action"), Arrays.<Object>asList("stop"));
}
@Override @Override
public JukeboxStatus startJukebox(Context context, ProgressListener progressListener) throws Exception public JukeboxStatus startJukebox(Context context,
{ ProgressListener progressListener) throws Exception {
return executeJukeboxCommand(context, progressListener, Collections.singletonList("action"), Arrays.<Object>asList("start")); updateProgressListener(progressListener, R.string.parser_reading);
} Response<JukeboxResponse> response = subsonicAPIClient.getApi()
.jukeboxControl(JukeboxAction.START, null, null, null, null)
.execute();
checkResponseSuccessful(response);
@Override return APIJukeboxConverter.toDomainEntity(response.body().getJukebox());
public JukeboxStatus getJukeboxStatus(Context context, ProgressListener progressListener) throws Exception }
{
return executeJukeboxCommand(context, progressListener, Collections.singletonList("action"), Arrays.<Object>asList("status"));
}
@Override @Override
public JukeboxStatus setJukeboxGain(float gain, Context context, ProgressListener progressListener) throws Exception public JukeboxStatus getJukeboxStatus(Context context,
{ ProgressListener progressListener) throws Exception {
List<String> parameterNames = asList("action", "gain"); updateProgressListener(progressListener, R.string.parser_reading);
List<Object> parameterValues = Arrays.<Object>asList("setGain", gain); Response<JukeboxResponse> response = subsonicAPIClient.getApi()
return executeJukeboxCommand(context, progressListener, parameterNames, parameterValues); .jukeboxControl(JukeboxAction.STATUS, null, null, null, null)
} .execute();
checkResponseSuccessful(response);
return APIJukeboxConverter.toDomainEntity(response.body().getJukebox());
}
@Override
public JukeboxStatus setJukeboxGain(float gain, Context context,
ProgressListener progressListener) throws Exception {
updateProgressListener(progressListener, R.string.parser_reading);
Response<JukeboxResponse> response = subsonicAPIClient.getApi()
.jukeboxControl(JukeboxAction.SET_GAIN, null, null, null, gain)
.execute();
checkResponseSuccessful(response);
return APIJukeboxConverter.toDomainEntity(response.body().getJukebox());
}
@Override @Override
public List<Share> getShares(boolean refresh, Context context, ProgressListener progressListener) throws Exception public List<Share> getShares(boolean refresh, Context context, ProgressListener progressListener) throws Exception
@ -940,20 +962,6 @@ public class RESTMusicService implements MusicService
} }
} }
private JukeboxStatus executeJukeboxCommand(Context context, ProgressListener progressListener, List<String> parameterNames, List<Object> parameterValues) throws Exception
{
checkServerVersion(context, "1.7", "Jukebox not supported.");
Reader reader = getReader(context, progressListener, "jukeboxControl", null, parameterNames, parameterValues);
try
{
return new JukeboxStatusParser(context).parse(reader);
}
finally
{
Util.close(reader);
}
}
private Reader getReader(Context context, ProgressListener progressListener, String method, HttpParams requestParams) throws Exception private Reader getReader(Context context, ProgressListener progressListener, String method, HttpParams requestParams) throws Exception
{ {
return getReader(context, progressListener, method, requestParams, Collections.<String>emptyList(), Collections.emptyList()); return getReader(context, progressListener, method, requestParams, Collections.<String>emptyList(), Collections.emptyList());

71
ultrasonic/src/main/java/org/moire/ultrasonic/service/parser/JukeboxStatusParser.java
View File

@ -1,71 +0,0 @@
/*
This file is part of Subsonic.
Subsonic is free software: you can redistribute it and/or modify
it under the terms of the GNU General Public License as published by
the Free Software Foundation, either version 3 of the License, or
(at your option) any later version.
Subsonic is distributed in the hope that it will be useful,
but WITHOUT ANY WARRANTY; without even the implied warranty of
MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
GNU General Public License for more details.
You should have received a copy of the GNU General Public License
along with Subsonic. If not, see <http://www.gnu.org/licenses/>.
Copyright 2009 (C) Sindre Mehus
*/
package org.moire.ultrasonic.service.parser;
import android.content.Context;
import org.moire.ultrasonic.domain.JukeboxStatus;
import org.xmlpull.v1.XmlPullParser;
import java.io.Reader;
/**
* @author Sindre Mehus
*/
public class JukeboxStatusParser extends AbstractParser
{
public JukeboxStatusParser(Context context)
{
super(context);
}
public JukeboxStatus parse(Reader reader) throws Exception
{
init(reader);
JukeboxStatus jukeboxStatus = new JukeboxStatus();
int eventType;
do
{
eventType = nextParseEvent();
if (eventType == XmlPullParser.START_TAG)
{
String name = getElementName();
if ("jukeboxPlaylist".equals(name) || "jukeboxStatus".equals(name))
{
jukeboxStatus.setPositionSeconds(getInteger("position"));
jukeboxStatus.setCurrentIndex(getInteger("currentIndex"));
jukeboxStatus.setPlaying(getBoolean("playing"));
jukeboxStatus.setGain(getFloat("gain"));
}
else if ("error".equals(name))
{
handleError();
}
}
} while (eventType != XmlPullParser.END_DOCUMENT);
validate();
return jukeboxStatus;
}
}