Compare commits
No commits in common. "84d295e08f5215533f8bf6c9f83b34a16807228c" and "e3ab679f515f26476aa48a7ee41459df1a34221a" have entirely different histories.
84d295e08f
...
e3ab679f51
@ -1,25 +0,0 @@
|
|||||||
package com.covas.Entity;
|
|
||||||
|
|
||||||
import java.time.LocalDateTime;
|
|
||||||
import java.util.Collection;
|
|
||||||
|
|
||||||
import com.covas.Json.Organisateurs;
|
|
||||||
|
|
||||||
import io.quarkus.mongodb.panache.PanacheMongoEntity;
|
|
||||||
import io.quarkus.mongodb.panache.common.MongoEntity;
|
|
||||||
|
|
||||||
@MongoEntity(collection="group")
|
|
||||||
public class GroupEntity extends PanacheMongoEntity {
|
|
||||||
|
|
||||||
public String name;
|
|
||||||
|
|
||||||
public Short status;
|
|
||||||
|
|
||||||
public Collection<String> admins;
|
|
||||||
|
|
||||||
public Collection<String> membres;
|
|
||||||
|
|
||||||
public LocalDateTime created_at;
|
|
||||||
public LocalDateTime updated_at;
|
|
||||||
public LocalDateTime deleted_at;
|
|
||||||
}
|
|
@ -26,8 +26,11 @@ import javax.ws.rs.core.Context;
|
|||||||
import javax.ws.rs.core.MediaType;
|
import javax.ws.rs.core.MediaType;
|
||||||
import javax.ws.rs.core.Response;
|
import javax.ws.rs.core.Response;
|
||||||
|
|
||||||
|
import com.covas.Entity.CommentEntity;
|
||||||
import com.covas.Entity.EventEntity;
|
import com.covas.Entity.EventEntity;
|
||||||
|
import com.covas.Entity.PublisherEntity;
|
||||||
import com.covas.Entity.UsersEntity;
|
import com.covas.Entity.UsersEntity;
|
||||||
|
import com.covas.Json.Organisateurs;
|
||||||
|
|
||||||
import io.quarkus.panache.common.Page;
|
import io.quarkus.panache.common.Page;
|
||||||
|
|
||||||
|
@ -1,272 +0,0 @@
|
|||||||
package com.covas.Resources;
|
|
||||||
|
|
||||||
import java.nio.charset.StandardCharsets;
|
|
||||||
import java.time.LocalDateTime;
|
|
||||||
import java.util.List;
|
|
||||||
import java.util.UUID;
|
|
||||||
import java.util.ArrayList;
|
|
||||||
import java.util.Collection;
|
|
||||||
|
|
||||||
|
|
||||||
import javax.annotation.security.RolesAllowed;
|
|
||||||
import javax.inject.Inject;
|
|
||||||
import javax.transaction.Transactional;
|
|
||||||
import javax.ws.rs.core.SecurityContext;
|
|
||||||
import javax.ws.rs.Consumes;
|
|
||||||
import javax.ws.rs.CookieParam;
|
|
||||||
import javax.ws.rs.DELETE;
|
|
||||||
import javax.ws.rs.GET;
|
|
||||||
import javax.ws.rs.PATCH;
|
|
||||||
import javax.ws.rs.PUT;
|
|
||||||
import javax.ws.rs.Path;
|
|
||||||
import javax.ws.rs.PathParam;
|
|
||||||
import javax.ws.rs.Produces;
|
|
||||||
import javax.ws.rs.QueryParam;
|
|
||||||
import javax.ws.rs.core.Context;
|
|
||||||
import javax.ws.rs.core.MediaType;
|
|
||||||
import javax.ws.rs.core.Response;
|
|
||||||
|
|
||||||
import com.covas.Entity.GroupEntity;
|
|
||||||
import com.covas.Entity.UsersEntity;
|
|
||||||
|
|
||||||
import io.quarkus.panache.common.Page;
|
|
||||||
|
|
||||||
import org.bson.types.ObjectId;
|
|
||||||
import org.eclipse.microprofile.jwt.Claims;
|
|
||||||
import org.eclipse.microprofile.jwt.JsonWebToken;
|
|
||||||
import org.jboss.logging.Logger;
|
|
||||||
import org.postgresql.shaded.com.ongres.scram.common.bouncycastle.base64.Base64;
|
|
||||||
|
|
||||||
@Produces(MediaType.APPLICATION_JSON)
|
|
||||||
@Path("group")
|
|
||||||
public class GroupRessources {
|
|
||||||
private static final Logger LOGGER = Logger.getLogger(UsersRessources.class);
|
|
||||||
@Inject
|
|
||||||
JsonWebToken jwt;
|
|
||||||
|
|
||||||
/// Function
|
|
||||||
private Boolean checkUserCookie(String userCookie, UsersEntity users) {
|
|
||||||
if ((userCookie == null) || (users == null)) {
|
|
||||||
return false;
|
|
||||||
}
|
|
||||||
String name = new String(Base64.decode(userCookie), StandardCharsets.UTF_8);
|
|
||||||
if (!name.equals(users.pseudo) && (users.status != 1)) {
|
|
||||||
return false;
|
|
||||||
}
|
|
||||||
return true;
|
|
||||||
}
|
|
||||||
|
|
||||||
private Response.Status getResponseCheck(SecurityContext ctx, String userCookie, UsersEntity users) {
|
|
||||||
if (!ctx.getUserPrincipal().getName().equals(jwt.getName())) {
|
|
||||||
return Response.Status.INTERNAL_SERVER_ERROR;
|
|
||||||
}
|
|
||||||
if (!checkUserCookie(userCookie, users)) {
|
|
||||||
return Response.Status.FORBIDDEN;
|
|
||||||
}
|
|
||||||
return Response.Status.OK;
|
|
||||||
}
|
|
||||||
|
|
||||||
/// Appel HTTP
|
|
||||||
|
|
||||||
|
|
||||||
/// GET
|
|
||||||
@GET
|
|
||||||
@RolesAllowed("Admin")
|
|
||||||
public Response getGroups(@CookieParam("user") String userCookie, @Context SecurityContext ctx,
|
|
||||||
@QueryParam("page") Integer page, @QueryParam("nbPages") Integer nbPages,
|
|
||||||
@QueryParam("status") Short status,
|
|
||||||
@QueryParam("search") String search,
|
|
||||||
@QueryParam("uuid") String uuid) {
|
|
||||||
if(nbPages == null){
|
|
||||||
nbPages = 20;
|
|
||||||
}
|
|
||||||
if(page == null){
|
|
||||||
page = 0;
|
|
||||||
}
|
|
||||||
UUID kid = UUID.fromString(jwt.getClaim(Claims.kid));
|
|
||||||
UsersEntity user = UsersEntity.findById(kid);
|
|
||||||
Response.Status statusHttp = getResponseCheck(ctx, userCookie, user);
|
|
||||||
Response responseHttp = Response.status(statusHttp).build();
|
|
||||||
if (statusHttp.equals(Response.Status.OK)) {
|
|
||||||
List<GroupEntity> listGroups = GroupEntity.findAll().page(Page.of(page, nbPages)).list();
|
|
||||||
|
|
||||||
|
|
||||||
responseHttp = Response.ok(listGroups).build();
|
|
||||||
if(uuid != null){
|
|
||||||
GroupEntity groupSingle= GroupEntity.findById(new ObjectId(uuid));
|
|
||||||
responseHttp = Response.ok(groupSingle).build();
|
|
||||||
}
|
|
||||||
|
|
||||||
if(search != null){
|
|
||||||
List<GroupEntity> groupsList = GroupEntity.find("name", search).page(Page.of(page, nbPages)).list();
|
|
||||||
responseHttp = Response.ok(groupsList).build();
|
|
||||||
}
|
|
||||||
}
|
|
||||||
return responseHttp;
|
|
||||||
}
|
|
||||||
|
|
||||||
@GET
|
|
||||||
@RolesAllowed("Admin")
|
|
||||||
@Path("count")
|
|
||||||
public Response getCount(@CookieParam("user") String userCookie, @Context SecurityContext ctx){
|
|
||||||
UUID kid = UUID.fromString(jwt.getClaim(Claims.kid));
|
|
||||||
UsersEntity user = UsersEntity.findById(kid);
|
|
||||||
Response.Status status = getResponseCheck(ctx, userCookie, user);
|
|
||||||
Response responseHttp = Response.status(status).build();
|
|
||||||
if (status.equals(Response.Status.OK)){
|
|
||||||
responseHttp = Response.ok(GroupEntity.count()).build();
|
|
||||||
}
|
|
||||||
return responseHttp;
|
|
||||||
}
|
|
||||||
|
|
||||||
@GET
|
|
||||||
@RolesAllowed("Admin")
|
|
||||||
@Path("{id}")
|
|
||||||
public Response getSingleGroup(@PathParam("id") String id, @CookieParam("user") String userCookie,
|
|
||||||
@Context SecurityContext ctx) {
|
|
||||||
UUID kid = UUID.fromString(jwt.getClaim(Claims.kid));
|
|
||||||
UsersEntity user = UsersEntity.findById(kid);
|
|
||||||
Response.Status status = getResponseCheck(ctx, userCookie, user);
|
|
||||||
Response responseHttp = Response.status(status).build();
|
|
||||||
if (status.equals(Response.Status.OK)) {
|
|
||||||
GroupEntity group = GroupEntity.findById(new ObjectId(id));
|
|
||||||
responseHttp = Response.status(Response.Status.NOT_FOUND).build();
|
|
||||||
if (group != null) {
|
|
||||||
responseHttp = Response.ok(group).build();
|
|
||||||
}
|
|
||||||
|
|
||||||
}
|
|
||||||
return responseHttp;
|
|
||||||
}
|
|
||||||
|
|
||||||
|
|
||||||
// PUT
|
|
||||||
@PUT
|
|
||||||
@Consumes(MediaType.APPLICATION_JSON)
|
|
||||||
@RolesAllowed({"Admin", "User"})
|
|
||||||
@Path("{id}")
|
|
||||||
@Transactional
|
|
||||||
public Response createGroup(@Context SecurityContext ctx, @CookieParam("user") String userCookie, @PathParam("id") String id, GroupEntity group) {
|
|
||||||
|
|
||||||
UUID kid = UUID.fromString(jwt.getClaim(Claims.kid));
|
|
||||||
UsersEntity user = UsersEntity.findById(kid);
|
|
||||||
Response.Status status = getResponseCheck(ctx, userCookie, user);
|
|
||||||
GroupEntity newGroup = new GroupEntity();
|
|
||||||
if (status.equals(Response.Status.OK)) {
|
|
||||||
newGroup.name = group.name;
|
|
||||||
newGroup.admins = group.admins;
|
|
||||||
newGroup.created_at = LocalDateTime.now();
|
|
||||||
newGroup.updated_at = LocalDateTime.now();
|
|
||||||
newGroup.persist();
|
|
||||||
status = Response.Status.CREATED;
|
|
||||||
|
|
||||||
}
|
|
||||||
return Response.status(status).entity(newGroup).build();
|
|
||||||
}
|
|
||||||
|
|
||||||
|
|
||||||
// DELETE
|
|
||||||
@DELETE
|
|
||||||
@Path("{id}")
|
|
||||||
@RolesAllowed({"Admin", "User"})
|
|
||||||
@Transactional
|
|
||||||
public Response changeStatusSingleGroupToDelete(@Context SecurityContext ctx, @CookieParam("user") String userCookie,
|
|
||||||
@PathParam("id") String id) {
|
|
||||||
UUID kid = UUID.fromString(jwt.getClaim(Claims.kid));
|
|
||||||
UsersEntity user = UsersEntity.findById(kid);
|
|
||||||
Response.Status status = getResponseCheck(ctx, userCookie, user);
|
|
||||||
if (status.equals(Response.Status.OK)) {
|
|
||||||
GroupEntity singleGroup = GroupEntity.find("id", new ObjectId(id)).firstResult();
|
|
||||||
if (singleGroup == null) {
|
|
||||||
status = Response.Status.NOT_FOUND;
|
|
||||||
} else {
|
|
||||||
singleGroup.status = -1;
|
|
||||||
singleGroup.updated_at = LocalDateTime.now();
|
|
||||||
singleGroup.deleted_at = LocalDateTime.now();
|
|
||||||
singleGroup.persist();
|
|
||||||
}
|
|
||||||
}
|
|
||||||
return Response.status(status).build();
|
|
||||||
}
|
|
||||||
|
|
||||||
@DELETE
|
|
||||||
@Path("/disable/{id}")
|
|
||||||
@RolesAllowed({"Admin", "User"})
|
|
||||||
@Transactional
|
|
||||||
public Response changeStatusSingleGroupToDisable(@Context SecurityContext ctx, @CookieParam("user") String userCookie,
|
|
||||||
@PathParam("id") String id) {
|
|
||||||
UUID kid = UUID.fromString(jwt.getClaim(Claims.kid));
|
|
||||||
UsersEntity user = UsersEntity.findById(kid);
|
|
||||||
Response.Status status = getResponseCheck(ctx, userCookie, user);
|
|
||||||
if (status.equals(Response.Status.OK)) {
|
|
||||||
GroupEntity singleGroup = GroupEntity.find("id", new ObjectId(id)).firstResult();
|
|
||||||
if (singleGroup == null) {
|
|
||||||
status = Response.Status.NOT_FOUND;
|
|
||||||
} else {
|
|
||||||
singleGroup.status = 0;
|
|
||||||
singleGroup.updated_at = LocalDateTime.now();
|
|
||||||
singleGroup.deleted_at = LocalDateTime.now();
|
|
||||||
singleGroup.persist();
|
|
||||||
}
|
|
||||||
}
|
|
||||||
return Response.status(status).build();
|
|
||||||
}
|
|
||||||
|
|
||||||
// PATCH
|
|
||||||
@PATCH
|
|
||||||
@RolesAllowed({"Admin", "User"})
|
|
||||||
@Consumes(MediaType.APPLICATION_JSON)
|
|
||||||
@Transactional
|
|
||||||
@Path("{id}")
|
|
||||||
public Response updateGroup(@Context SecurityContext ctx, @CookieParam("user") String userCookie,
|
|
||||||
GroupEntity group, @PathParam("id") String id) {
|
|
||||||
UUID kid = UUID.fromString(jwt.getClaim(Claims.kid));
|
|
||||||
UsersEntity user = UsersEntity.findById(kid);
|
|
||||||
Response.Status status = getResponseCheck(ctx, userCookie, user);
|
|
||||||
|
|
||||||
if (status.equals(Response.Status.OK)) {
|
|
||||||
|
|
||||||
GroupEntity groupOrig = GroupEntity.findById(new ObjectId(id));
|
|
||||||
if (groupOrig == null) {
|
|
||||||
status = Response.Status.NOT_FOUND;
|
|
||||||
} else {
|
|
||||||
groupOrig.name = group.name;
|
|
||||||
|
|
||||||
|
|
||||||
groupOrig.updated_at = LocalDateTime.now();
|
|
||||||
|
|
||||||
if(group.status == 1){
|
|
||||||
groupOrig.deleted_at = null;
|
|
||||||
groupOrig.status = 1;
|
|
||||||
}
|
|
||||||
groupOrig.persist();
|
|
||||||
|
|
||||||
}
|
|
||||||
}
|
|
||||||
return Response.status(status).build();
|
|
||||||
}
|
|
||||||
|
|
||||||
|
|
||||||
|
|
||||||
@PATCH
|
|
||||||
@RolesAllowed({"Admin", "User"})
|
|
||||||
@Consumes(MediaType.APPLICATION_JSON)
|
|
||||||
@Transactional
|
|
||||||
@Path("enable/{id}")
|
|
||||||
public Response enableGroup(@Context SecurityContext ctx, @CookieParam("user") String userCookie, @PathParam("id") String id) {
|
|
||||||
UUID kid = UUID.fromString(jwt.getClaim(Claims.kid));
|
|
||||||
UsersEntity user = UsersEntity.findById(kid);
|
|
||||||
Response.Status status = getResponseCheck(ctx, userCookie, user);
|
|
||||||
if (status.equals(Response.Status.OK)) {
|
|
||||||
|
|
||||||
GroupEntity groupOrig = GroupEntity.findById(new ObjectId(id));
|
|
||||||
if (groupOrig == null) {
|
|
||||||
status = Response.Status.NOT_FOUND;
|
|
||||||
} else {
|
|
||||||
groupOrig.status = 1;
|
|
||||||
groupOrig.persist();
|
|
||||||
}
|
|
||||||
}
|
|
||||||
return Response.status(status).build();
|
|
||||||
}
|
|
||||||
}
|
|
Loading…
x
Reference in New Issue
Block a user