Compare commits
5 Commits
abe8df688b
...
c4f2631fd5
Author | SHA1 | Date |
---|---|---|
Mauro Mugnaini | c4f2631fd5 | |
Mauro Mugnaini | 761f9c17c2 | |
Mauro Mugnaini | 9f36ccd427 | |
Mauro Mugnaini | 23ee2a5b73 | |
Mauro Mugnaini | 7b5656485b |
|
@ -43,6 +43,14 @@
|
|||
<artifactId>commons-codec</artifactId>
|
||||
<scope>provided</scope>
|
||||
</dependency>
|
||||
<dependency>
|
||||
<groupId>commons-io</groupId>
|
||||
<artifactId>commons-io</artifactId>
|
||||
</dependency>
|
||||
<dependency>
|
||||
<groupId>com.fasterxml.jackson.core</groupId>
|
||||
<artifactId>jackson-databind</artifactId>
|
||||
</dependency>
|
||||
<dependency>
|
||||
<groupId>com.googlecode.json-simple</groupId>
|
||||
<artifactId>json-simple</artifactId>
|
||||
|
|
|
@ -33,6 +33,10 @@
|
|||
<version>${project.version}</version>
|
||||
<scope>provided</scope>
|
||||
</dependency>
|
||||
<dependency>
|
||||
<groupId>io.quarkus</groupId>
|
||||
<artifactId>quarkus-resteasy-reactive</artifactId>
|
||||
</dependency>
|
||||
<dependency>
|
||||
<groupId>io.minio</groupId>
|
||||
<artifactId>minio</artifactId>
|
||||
|
|
|
@ -1,10 +1,11 @@
|
|||
package org.gcube.keycloak.avatar;
|
||||
|
||||
import java.io.InputStream;
|
||||
import java.nio.file.Files;
|
||||
|
||||
import org.gcube.keycloak.avatar.storage.AvatarStorageProvider;
|
||||
import org.jboss.resteasy.annotations.cache.NoCache;
|
||||
import org.jboss.resteasy.plugins.providers.multipart.MultipartFormDataInput;
|
||||
import org.jboss.resteasy.reactive.RestForm;
|
||||
import org.jboss.resteasy.reactive.multipart.FileUpload;
|
||||
import org.keycloak.common.ClientConnection;
|
||||
import org.keycloak.models.KeycloakSession;
|
||||
import org.keycloak.models.RealmModel;
|
||||
|
@ -62,7 +63,7 @@ public class AvatarAdminResource extends AbstractAvatarResource {
|
|||
@NoCache
|
||||
@Path("/{user_id}")
|
||||
@Consumes(MediaType.MULTIPART_FORM_DATA)
|
||||
public Response uploadUserAvatarImage(@PathParam("user_id") String userId, MultipartFormDataInput input) {
|
||||
public Response uploadUserAvatarImage(@PathParam("user_id") String userId, @RestForm(AVATAR_IMAGE_PARAMETER) FileUpload image) {
|
||||
try {
|
||||
if (auth == null) {
|
||||
return Response.status(Response.Status.UNAUTHORIZED).build();
|
||||
|
@ -71,8 +72,7 @@ public class AvatarAdminResource extends AbstractAvatarResource {
|
|||
RealmModel realm = session.getContext().getRealm();
|
||||
UserModel user = session.users().getUserById(session.getContext().getRealm(), userId);
|
||||
|
||||
InputStream imageInputStream = input.getFormDataPart(AVATAR_IMAGE_PARAMETER, InputStream.class, null);
|
||||
saveUserImage(realm, user, imageInputStream);
|
||||
saveUserImage(realm, user, Files.newInputStream(image.uploadedFile()));
|
||||
} catch (ForbiddenException e) {
|
||||
return Response.status(Response.Status.FORBIDDEN).entity(e.getMessage()).build();
|
||||
} catch (Exception e) {
|
||||
|
|
|
@ -1,14 +1,15 @@
|
|||
package org.gcube.keycloak.avatar;
|
||||
|
||||
import java.io.InputStream;
|
||||
import java.nio.file.Files;
|
||||
import java.util.List;
|
||||
|
||||
import org.jboss.resteasy.annotations.cache.NoCache;
|
||||
import org.jboss.resteasy.plugins.providers.multipart.MultipartFormDataInput;
|
||||
import org.jboss.resteasy.reactive.RestForm;
|
||||
import org.jboss.resteasy.reactive.multipart.FileUpload;
|
||||
import org.jboss.resteasy.spi.ResteasyProviderFactory;
|
||||
import org.keycloak.http.HttpRequest;
|
||||
import org.keycloak.models.KeycloakSession;
|
||||
import org.keycloak.services.resources.Cors;
|
||||
import org.keycloak.services.cors.Cors;
|
||||
import org.keycloak.services.resources.RealmsResource;
|
||||
|
||||
import jakarta.ws.rs.Consumes;
|
||||
|
@ -74,7 +75,7 @@ public class AvatarResource extends AbstractAvatarResource {
|
|||
@POST
|
||||
@NoCache
|
||||
@Consumes(MediaType.MULTIPART_FORM_DATA)
|
||||
public Response uploadCurrentUserAvatarImage(MultipartFormDataInput input, @Context UriInfo uriInfo) {
|
||||
public Response uploadCurrentUserAvatarImage(@RestForm(AVATAR_IMAGE_PARAMETER) FileUpload image, @Context UriInfo uriInfo) {
|
||||
if (auth == null) {
|
||||
throw new NotAuthorizedException("Bearer");
|
||||
}
|
||||
|
@ -86,9 +87,7 @@ public class AvatarResource extends AbstractAvatarResource {
|
|||
logger.debugf("Uploading new avatar for user %s in realm %s", auth.getUser(), auth.getSession().getRealm());
|
||||
Response response = null;
|
||||
try {
|
||||
InputStream imageInputStream = input.getFormDataPart(AVATAR_IMAGE_PARAMETER, InputStream.class, null);
|
||||
|
||||
saveUserImage(auth.getSession().getRealm(), auth.getUser(), imageInputStream);
|
||||
saveUserImage(auth.getSession().getRealm(), auth.getUser(), Files.newInputStream(image.uploadedFile()));
|
||||
|
||||
if (uriInfo.getQueryParameters().containsKey("account")) {
|
||||
UriBuilder uriBuilder = RealmsResource.accountUrl(session.getContext().getUri().getBaseUriBuilder());
|
||||
|
|
|
@ -51,6 +51,18 @@ public class NoOpEventPublisherProvider extends OrchestratorEventPublisherProvid
|
|||
// Nothing to do
|
||||
return null;
|
||||
}
|
||||
|
||||
@Override
|
||||
public int getLastSendHTTPResponseCode() {
|
||||
// Nothing to do
|
||||
return 0;
|
||||
}
|
||||
|
||||
@Override
|
||||
public int getLastRetrieveHTTPResponseCode() {
|
||||
// Nothing to do
|
||||
return 0;
|
||||
}
|
||||
};
|
||||
}
|
||||
|
||||
|
|
6
pom.xml
6
pom.xml
|
@ -46,7 +46,7 @@
|
|||
<dependency>
|
||||
<groupId>org.keycloak</groupId>
|
||||
<artifactId>keycloak-parent</artifactId>
|
||||
<version>23.0.5</version>
|
||||
<version>24.0.2</version>
|
||||
<type>pom</type>
|
||||
<scope>import</scope>
|
||||
</dependency>
|
||||
|
@ -107,13 +107,13 @@
|
|||
<dependency>
|
||||
<groupId>com.squareup.okhttp3</groupId>
|
||||
<artifactId>okhttp</artifactId>
|
||||
<!-- <version>${okhttp3.version}</version>-->
|
||||
<version>${okhttp3.version}</version>
|
||||
<scope>runtime</scope>
|
||||
</dependency>
|
||||
<dependency>
|
||||
<groupId>com.squareup.okio</groupId>
|
||||
<artifactId>okio</artifactId>
|
||||
<!-- <version>${okio.version}</version>-->
|
||||
<version>${okio.version}</version>
|
||||
<scope>compile</scope>
|
||||
</dependency>
|
||||
<dependency>
|
||||
|
|
|
@ -60,7 +60,8 @@ public class D4ScienceContextMapperTest {
|
|||
.map(ProviderConfigProperty::getName)
|
||||
.collect(Collectors.toList());
|
||||
|
||||
assertThat(configPropertyNames).containsExactly(OIDCAttributeMapperHelper.TOKEN_CLAIM_NAME,
|
||||
assertThat(configPropertyNames).containsExactlyInAnyOrder(OIDCAttributeMapperHelper.TOKEN_CLAIM_NAME,
|
||||
OIDCAttributeMapperHelper.INCLUDE_IN_LIGHTWEIGHT_ACCESS_TOKEN,
|
||||
OIDCAttributeMapperHelper.INCLUDE_IN_ACCESS_TOKEN, D4ScienceContextMapper.HTTP_REQUEST_HEADER_NAME,
|
||||
D4ScienceContextMapper.NARROW_RESOURCE_ACCESS);
|
||||
}
|
||||
|
@ -109,8 +110,11 @@ public class D4ScienceContextMapperTest {
|
|||
}
|
||||
|
||||
private KeycloakSession givenKeycloakSession(boolean withHeader) {
|
||||
KeycloakSession keycloakSession = Mockito.mock(KeycloakSession.class);
|
||||
ClientModel clientModel = Mockito.mock(ClientModel.class);
|
||||
when(clientModel.getName()).thenReturn("test-client-id");
|
||||
KeycloakContext context = Mockito.mock(KeycloakContext.class);
|
||||
when(context.getClient()).thenReturn(clientModel);
|
||||
KeycloakSession keycloakSession = Mockito.mock(KeycloakSession.class);
|
||||
when(keycloakSession.getContext()).thenReturn(context);
|
||||
HttpHeaders headers = Mockito.mock(HttpHeaders.class);
|
||||
when(context.getRequestHeaders()).thenReturn(headers);
|
||||
|
@ -135,13 +139,12 @@ public class D4ScienceContextMapperTest {
|
|||
}
|
||||
|
||||
return new D4ScienceContextMapper().transformAccessToken(at, mappingModel, keycloakSession,
|
||||
userSessionModel, givenClientSessionContext());
|
||||
userSessionModel, givenClientSessionContext(keycloakSession));
|
||||
}
|
||||
|
||||
private ClientSessionContext givenClientSessionContext() {
|
||||
ClientModel clientModel = Mockito.mock(ClientModel.class);
|
||||
when(clientModel.getName()).thenReturn("test-client-id");
|
||||
private ClientSessionContext givenClientSessionContext(KeycloakSession keycloakSession) {
|
||||
AuthenticatedClientSessionModel acsm = Mockito.mock(AuthenticatedClientSessionModel.class);
|
||||
ClientModel clientModel = keycloakSession.getContext().getClient();
|
||||
when(acsm.getClient()).thenReturn(clientModel);
|
||||
ClientSessionContext csc = Mockito.mock(ClientSessionContext.class);
|
||||
when(csc.getClientSession()).thenReturn(acsm);
|
||||
|
|
Loading…
Reference in New Issue