package com.megatim.fdxconsultation.service.impl.chat;
|
|
import com.megatim.fdxconsultation.core.ifaces.administration.UserManager;
|
import com.megatim.fdxconsultation.model.administration.User;
|
import com.megatim.fdxconsultation.model.searchentities.UserSearch;
|
import com.megatim.fdxconsultation.service.ifaces.chat.UserChatListRS;
|
import com.megatim.fdxconsultation.tools.context.AppCommonContext;
|
import com.mgt.rs.security.core.common.AuthenticatedUser;
|
import com.mgt.rs.security.core.common.SecuredClass;
|
import java.util.stream.Collectors;
|
import javax.enterprise.event.Observes;
|
import javax.inject.Inject;
|
import javax.ws.rs.Path;
|
import javax.ws.rs.core.HttpHeaders;
|
import javax.ws.rs.core.Response;
|
|
/**
|
*
|
* @author Gabuntu
|
*/
|
@SecuredClass(module = AppCommonContext.MODULE_ADMINISTRATION, path = "Utilisateurs pour le chat", description = "Utilisateurs pour le chat")
|
@Path("user-chat-list")
|
public class UserChatListRSImpl implements UserChatListRS {
|
|
@Inject
|
private UserManager manager;
|
|
@AuthenticatedUser
|
private User utilisateurConnecte;
|
|
public void handleAuthenticationEvent(@Observes @AuthenticatedUser String username) {
|
utilisateurConnecte = manager.recuperUtilisateur(username);
|
}
|
|
@Override
|
public Response findAll(HttpHeaders headers, UserSearch searchEntity) {
|
return Response.ok(
|
manager.getAll(searchEntity, utilisateurConnecte)
|
.stream()
|
.collect(Collectors.toList())
|
).build();
|
}
|
|
@Override
|
public Long count(HttpHeaders headers, UserSearch searchEntity) {
|
return manager.size(searchEntity);
|
}
|
|
}
|
