Skip to content
Extraits de code Groupes Projets
Valider db135586 rédigé par oussama aftys's avatar oussama aftys
Parcourir les fichiers

minor changes

parent 3e6b70c8
Branches
Étiquettes
1 requête de fusion!20fixed chat sorting problem
Pipeline #10754 en échec avec les étapes
in 21 secondes
......@@ -69,7 +69,7 @@ public class ChatController {
@RequestParam Long streamId, @RequestParam(value = "page", defaultValue = "0") int page,
@RequestParam(value = "size", defaultValue = "100") int size,
@RequestParam(value = "sortBy", defaultValue = "createdAt") String sortBy,
@RequestParam(value = "sortDir", defaultValue = "ASC") String sortDir,
@RequestParam(value = "sortDir", defaultValue = "DESC") String sortDir,
@RequestHeader String requestAuthorization) {
return chatService.getAllMsgByStream(streamId, page, size, sortBy, sortDir);
}
......
package com.marketingconfort.mydressin.mydressinstreamservices.services.impl;
import java.util.Collections;
import java.util.List;
import java.util.stream.Collectors;
......@@ -44,6 +45,7 @@ public class ChatService implements IChatService {
public List<ChatMessageResponse> getAllMsgByStream(long id, int page, int size, String sortBy, String sortDir) {
Pageable pageable = PageRequest.of(page, size, Sort.Direction.fromString(sortDir), sortBy);
List<ChatMessage> chatMessages = chatMessageRepository.findAllMessagesByLiveStreamId(id, pageable );
Collections.reverse(chatMessages);
return chatMessages.stream()
.map(ChatMessageResponse::fromEntity)
.collect(Collectors.toList());
......
......@@ -197,7 +197,7 @@ public class LiveStreamService implements ILiveStreamService {
}
Long pid = liveStream.getFfmpegPid();
liveStream.setStatus(LiveStatus.REVIEW);
liveStream.setVideoLink(liveServerConfig.getCdn() + liveStream.getKeysWork().getKeyStream() + ".flv");
liveStream.setVideoLink(liveServerConfig.getCdn() + liveStream.getKeysWork().getKeyStream() + ".mp4");
liveStreamRepository.save(liveStream);
KeysWork keysWork = keysWorkRepository.findByLiveStream(liveStream);
LiveStopDto stopDto = new LiveStopDto(pid, keysWork.getKeyStream());
......
0% ou .
You are about to add 0 people to the discussion. Proceed with caution.
Terminez d'abord l'édition de ce message.
Veuillez vous inscrire ou vous pour commenter