gerrit.onap Code Review - ccsdk/features.git/blob

   1 /*
   2  * ============LICENSE_START=======================================================
   3  * ONAP : ccsdk features
   4  * ================================================================================
   5  * Copyright (C) 2021 highstreet technologies GmbH Intellectual Property.
   6  * All rights reserved.
   7  * ================================================================================
   8  * Licensed under the Apache License, Version 2.0 (the "License");
   9  * you may not use this file except in compliance with the License.
  10  * You may obtain a copy of the License at
  11  *
  12  *     http://www.apache.org/licenses/LICENSE-2.0
  13  *
  14  * Unless required by applicable law or agreed to in writing, software
  15  * distributed under the License is distributed on an "AS IS" BASIS,
  16  * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
  17  * See the License for the specific language governing permissions and
  18  * limitations under the License.
  19  * ============LICENSE_END=========================================================
  20  *
  21  */
  22 package org.onap.ccsdk.features.sdnr.wt.oauthprovider.providers;
  23
  24 import com.fasterxml.jackson.core.JsonProcessingException;
  25 import com.fasterxml.jackson.databind.JsonMappingException;
  26 import java.util.HashMap;
  27 import java.util.List;
  28 import java.util.Map;
  29 import java.util.stream.Collectors;
  30 import org.onap.ccsdk.features.sdnr.wt.oauthprovider.data.KeycloakUserTokenPayload;
  31 import org.onap.ccsdk.features.sdnr.wt.oauthprovider.data.OAuthProviderConfig;
  32 import org.onap.ccsdk.features.sdnr.wt.oauthprovider.data.UserTokenPayload;
  33
  34 public class KeycloakProviderService extends AuthService {
  35
  36     public static final String ID = "keycloak";
  37     private Map<String, String> additionalTokenVerifierParams;
  38
  39     public KeycloakProviderService(OAuthProviderConfig config, String redirectUri, TokenCreator tokenCreator) {
  40         super(config, redirectUri, tokenCreator);
  41         this.additionalTokenVerifierParams = new HashMap<>();
  42         this.additionalTokenVerifierParams.put("grant_type", "authorization_code");
  43     }
  44
  45     @Override
  46     protected String getTokenVerifierUri() {
  47         return String.format("/auth/realms/%s/protocol/openid-connect/token", urlEncode(this.config.getRealmName()));
  48     }
  49
  50     @Override
  51     protected String getLoginUrl(String callbackUrl) {
  52         return String.format(
  53                 "%s/auth/realms/%s/protocol/openid-connect/auth?client_id=%s&response_type=code&scope=%s&redirect_uri=%s",
  54                 this.config.getUrl(), urlEncode(this.config.getRealmName()), urlEncode(this.config.getClientId()),
  55                 this.config.getScope(), urlEncode(callbackUrl));
  56     }
  57
  58     @Override
  59     protected List<String> mapRoles(List<String> data) {
  60         final Map<String, String> map = this.config.getRoleMapping();
  61         List<String> filteredRoles =
  62                 data.stream().filter(role -> !role.equals("uma_authorization") && !role.equals("offline_access"))
  63                         .map(r -> map.getOrDefault(r, r)).collect(Collectors.toList());
  64         return filteredRoles;
  65     }
  66
  67     @Override
  68     protected ResponseType getResponseType() {
  69         return ResponseType.CODE;
  70     }
  71
  72     @Override
  73     protected Map<String, String> getAdditionalTokenVerifierParams() {
  74         return this.additionalTokenVerifierParams;
  75
  76     }
  77
  78     @Override
  79     protected boolean doSeperateRolesRequest() {
  80         return false;
  81     }
  82
  83     @Override
  84     protected UserTokenPayload mapAccessToken(String spayload) throws JsonMappingException, JsonProcessingException {
  85         KeycloakUserTokenPayload payload = mapper.readValue(spayload, KeycloakUserTokenPayload.class);
  86         UserTokenPayload data = new UserTokenPayload();
  87         data.setIat(payload.getIat() * 1000L);
  88         data.setExp(payload.getExp() * 1000L);
  89         data.setFamilyName(payload.getFamilyName());
  90         data.setGivenName(payload.getGivenName());
  91         data.setPreferredUsername(payload.getPreferredUsername());
  92         data.setRoles(this.mapRoles(payload.getRealmAccess().getRoles()));
  93         return data;
  94     }
  95
  96     @Override
  97     protected UserTokenPayload requestUserRoles(String access_token, long issued_at, long expires_at) {
  98         return null;
  99     }
 100
 101     @Override
 102     protected boolean verifyState(String state) {
 103         return true;
 104     }
 105
 106
 107 }