antebudimir/tempus
1
0
Fork 0
mirror of https://github.com/antebudimir/tempus.git synced 2025-12-31 09:33:33 +00:00
Code Issues Projects Releases Packages Wiki Activity Actions

fix: disallow duplicate songs in queue (#252)

Browse source
This commit is contained in:
eddyizm 2025-11-11 11:08:26 -08:00 • committed by GitHub
commit a79543569d
No known key found for this signature in database
GPG key ID: B5690EEEBB952194
1 changed files with 17 additions and 2 deletions
Download patch file Download diff file Expand all files Collapse all files

19
app/src/main/java/com/cappielloantonio/tempo/repository/QueueRepository.java
View file

@ -121,6 +121,15 @@ public class QueueRepository {
} }
} }
private boolean isMediaInQueue(List<Queue> queue, Child media) {
if (queue == null || media == null) return false;
return queue.stream().anyMatch(queueItem ->
queueItem != null && media.getId() != null &&
queueItem.getId().equals(media.getId())
);
}
public void insertAll(List<Child> toAdd, boolean reset, int afterIndex) { public void insertAll(List<Child> toAdd, boolean reset, int afterIndex) {
try { try {
List<Queue> media = new ArrayList<>(); List<Queue> media = new ArrayList<>();
@ -134,8 +143,14 @@ public class QueueRepository {
media = getMediaThreadSafe.getMedia(); media = getMediaThreadSafe.getMedia();
} }
for (int i = 0; i < toAdd.size(); i++) { List<Child> filteredToAdd = toAdd;
Queue queueItem = new Queue(toAdd.get(i)); final List<Queue> finalMedia = media;
filteredToAdd = toAdd.stream()
.filter(child -> !isMediaInQueue(finalMedia, child))
.collect(Collectors.toList());
for (int i = 0; i < filteredToAdd.size(); i++) {
Queue queueItem = new Queue(filteredToAdd.get(i));
media.add(afterIndex + i, queueItem); media.add(afterIndex + i, queueItem);
} }