org.xdi.oxd.server.op.UpdateSiteOperation クラス

org.xdi.oxd.server.op.UpdateSiteOperation の継承関係図

org.xdi.oxd.server.op.UpdateSiteOperation 連携図

公開メンバ関数
CommandResponse	execute (UpdateSiteParams params)
Class< T >	getParameterClass ()
T	getParams ()
Injector	getInjector ()
HttpService	getHttpService ()
IntrospectionService	getIntrospectionService ()
PublicOpKeyService	getKeyService ()
StateService	getStateService ()
LicenseService	getLicenseService ()
DiscoveryService	getDiscoveryService ()
UmaTokenService	getUmaTokenService ()
RpService	getRpService ()
ConfigurationService	getConfigurationService ()
OxAuthCryptoProvider	getCryptoProvider () throws Exception
Rp	getRp ()
ValidationService	getValidationService ()
Command	getCommand ()
CommandResponse	okResponse (IOpResponse p_data)

限定公開メンバ関数
	UpdateSiteOperation (Command command, final Injector injector)

関数
public< T > T	getInstance (Class< T > type)

非公開メンバ関数
void	persistRp (Rp rp, UpdateSiteParams params)
void	updateRegisteredClient (Rp rp, UpdateSiteParams params)
RegisterRequest	createRegisterClientRequest (Rp rp, UpdateSiteParams params)

静的非公開変数類
static final Logger	LOG = LoggerFactory.getLogger(UpdateSiteOperation.class)

詳解

著者

Yuriy Zabrovarnyy

バージョン

0.9, 11/03/2016

構築子と解体子

UpdateSiteOperation()

org.xdi.oxd.server.op.UpdateSiteOperation.UpdateSiteOperation ( Command  command, final Injector  injector  )

inlineprotected

Base constructor

引数

command

command

                                                                            {
        super(command, injector, UpdateSiteParams.class);
    }

関数詳解

createRegisterClientRequest()

RegisterRequest org.xdi.oxd.server.op.UpdateSiteOperation.createRegisterClientRequest ( Rp  rp, UpdateSiteParams  params  )

inlineprivate

                                                                                        {

        final RegisterRequest request = new RegisterRequest(rp.getClientRegistrationAccessToken());
        request.setHttpMethod(HttpMethod.PUT); // force update

        Date clientSecretExpiresAt = params.getClientSecretExpiresAt();
        if (clientSecretExpiresAt != null && clientSecretExpiresAt.getTime() != 0) {
            // translate it into milliseconds if someone sends it in seconds by miskate
            if (String.valueOf(clientSecretExpiresAt.getTime()).length() < 11) {
                clientSecretExpiresAt = new Date(clientSecretExpiresAt.getTime() * 1000);
            }
            request.setClientSecretExpiresAt(clientSecretExpiresAt);
            rp.setClientSecretExpiresAt(clientSecretExpiresAt);
        }

        List<ResponseType> responseTypes = Lists.newArrayList();
        if (params.getResponseTypes() != null && !params.getResponseTypes().isEmpty()) {
            for (String type : params.getResponseTypes()) {
                responseTypes.add(ResponseType.fromString(type));

                request.setResponseTypes(responseTypes);
                rp.setResponseTypes(params.getResponseTypes());
            }
        }

        List<GrantType> grantTypes = Lists.newArrayList();
        if (params.getGrantType() != null) {
            for (String grantType : params.getGrantType()) {
                GrantType t = GrantType.fromString(grantType);
                if (t != null) {
                    grantTypes.add(t);
                }
            }
        }
        request.setGrantTypes(grantTypes);
        rp.setGrantType(params.getGrantType());

        Set<String> redirectUris = new HashSet<>();
        if (StringUtils.isNotBlank(params.getAuthorizationRedirectUri())) {
            redirectUris.add(params.getAuthorizationRedirectUri());
            rp.setAuthorizationRedirectUri(params.getAuthorizationRedirectUri());
        } else if (StringUtils.isNotBlank(rp.getAuthorizationRedirectUri())) {
            redirectUris.add(rp.getAuthorizationRedirectUri());
        }

        if (params.getRedirectUris() != null && !params.getRedirectUris().isEmpty()) {
            redirectUris.addAll(params.getRedirectUris());
            if (!Strings.isNullOrEmpty(params.getPostLogoutRedirectUri())) {
                redirectUris.add(params.getPostLogoutRedirectUri());
            }

            request.setRedirectUris(Lists.newArrayList(redirectUris));
            rp.setRedirectUris(Lists.newArrayList(redirectUris));
        }

        if (!Strings.isNullOrEmpty(params.getClientJwksUri())) {
            request.setJwksUri(params.getClientJwksUri());
        }

        if (!Strings.isNullOrEmpty(params.getPostLogoutRedirectUri())) {
            request.setPostLogoutRedirectUris(Lists.newArrayList(params.getPostLogoutRedirectUri()));
        }

        if (params.getContacts() != null) {
            request.setContacts(params.getContacts());
            rp.setContacts(params.getContacts());
        } else {
            request.setContacts(rp.getContacts());
        }

        if (params.getScope() != null) {
            request.setScopes(params.getScope());
            rp.setScope(params.getScope());
        } else {
            request.setScopes(rp.getScope());
        }

        if (!Strings.isNullOrEmpty(params.getClientSectorIdentifierUri())) {
            request.setSectorIdentifierUri(params.getClientSectorIdentifierUri());
            rp.setSectorIdentifierUri(params.getClientSectorIdentifierUri());
        }

        if (params.getClientLogoutUri() != null && !params.getClientLogoutUri().isEmpty()) {
            rp.setFrontChannelLogoutUri(Lists.newArrayList(params.getClientLogoutUri()));
            request.setFrontChannelLogoutUris(Lists.newArrayList(params.getClientLogoutUri()));
        } else {
            request.setFrontChannelLogoutUris(rp.getFrontChannelLogoutUri());
        }

        if (params.getClientRequestUris() != null && !params.getClientRequestUris().isEmpty()) {
            request.setRequestUris(params.getClientRequestUris());
        }
        return request;
    }

execute()

CommandResponse org.xdi.oxd.server.op.UpdateSiteOperation.execute ( UpdateSiteParams  params )

inline

                                                            {
        final Rp rp = getRp();

        LOG.info("Updating rp ... rp: " + rp);
        persistRp(rp, params);

        UpdateSiteResponse response = new UpdateSiteResponse();
        response.setOxdId(rp.getOxdId());
        return okResponse(response);
    }

getCommand()

Command org.xdi.oxd.server.op.BaseOperation< T extends IParams >.getCommand ( )

inlineinherited

Returns command

戻り値

command

                                {
        return command;
    }

getConfigurationService()

ConfigurationService org.xdi.oxd.server.op.BaseOperation< T extends IParams >.getConfigurationService ( )

inlineinherited

                                                          {
        return getInstance(ConfigurationService.class);
    }

getCryptoProvider()

OxAuthCryptoProvider org.xdi.oxd.server.op.BaseOperation< T extends IParams >.getCryptoProvider ( ) throws Exception

inlineinherited

                                                                     {
        OxdServerConfiguration conf = getConfigurationService().get();
        return new OxAuthCryptoProvider(conf.getCryptProviderKeyStorePath(), conf.getCryptProviderKeyStorePassword(), conf.getCryptProviderDnName());
    }

getDiscoveryService()

DiscoveryService org.xdi.oxd.server.op.BaseOperation< T extends IParams >.getDiscoveryService ( )

inlineinherited

                                                  {
        return getInstance(DiscoveryService.class);
    }

getHttpService()

HttpService org.xdi.oxd.server.op.BaseOperation< T extends IParams >.getHttpService ( )

inlineinherited

                                        {
        return getInstance(HttpService.class);
    }

getInjector()

Injector org.xdi.oxd.server.op.BaseOperation< T extends IParams >.getInjector ( )

inlineinherited

Gets injector.

戻り値

injector

                                  {
        return injector;
    }

getInstance()

public<T> T org.xdi.oxd.server.op.BaseOperation< T extends IParams >.getInstance ( Class< T >  type )

inlinepackageinherited

                                            {
        return injector.getInstance(type);
    }

getIntrospectionService()

IntrospectionService org.xdi.oxd.server.op.BaseOperation< T extends IParams >.getIntrospectionService ( )

inlineinherited

                                                          {
        return getInstance(IntrospectionService.class);
    }

getKeyService()

PublicOpKeyService org.xdi.oxd.server.op.BaseOperation< T extends IParams >.getKeyService ( )

inlineinherited

                                              {
        return getInstance(PublicOpKeyService.class);
    }

getLicenseService()

LicenseService org.xdi.oxd.server.op.BaseOperation< T extends IParams >.getLicenseService ( )

inlineinherited

                                              {
        return getInstance(LicenseService.class);
    }

getParameterClass()

Class<T> org.xdi.oxd.server.op.BaseOperation< T extends IParams >.getParameterClass ( )

inlineinherited

                                        {
        return parameterClass;
    }

getParams()

T org.xdi.oxd.server.op.BaseOperation< T extends IParams >.getParams ( )

inlineinherited

                         {
        return params;
    }

getRp()

Rp org.xdi.oxd.server.op.BaseOperation< T extends IParams >.getRp ( )

inlineinherited

                      {
        if (params instanceof HasOxdIdParams) {
            getValidationService().validate((HasOxdIdParams) params);
            HasOxdIdParams hasOxdId = (HasOxdIdParams) params;
            return getRpService().getRp(hasOxdId.getOxdId());
        }
        throw new ErrorResponseException(ErrorResponseCode.BAD_REQUEST_NO_OXD_ID);
    }

getRpService()

RpService org.xdi.oxd.server.op.BaseOperation< T extends IParams >.getRpService ( )

inlineinherited

                                    {
        return getInstance(RpService.class);
    }

getStateService()

StateService org.xdi.oxd.server.op.BaseOperation< T extends IParams >.getStateService ( )

inlineinherited

                                          {
        return getInstance(StateService.class);
    }

getUmaTokenService()

UmaTokenService org.xdi.oxd.server.op.BaseOperation< T extends IParams >.getUmaTokenService ( )

inlineinherited

                                                {
        return getInstance(UmaTokenService.class);
    }

getValidationService()

ValidationService org.xdi.oxd.server.op.BaseOperation< T extends IParams >.getValidationService ( )

inlineinherited

                                                    {
        return getInstance(ValidationService.class);
    }

okResponse()

CommandResponse org.xdi.oxd.server.op.BaseOperation< T extends IParams >.okResponse ( IOpResponse  p_data )

inlineinherited

Ok response for operation

引数

p_data

response

戻り値

ok response with data

                                                          {
        if (p_data == null) {
            return CommandResponse.createInternalError();
        }
        return CommandResponse.ok().setData(new POJONode(p_data));
    }

persistRp()

void org.xdi.oxd.server.op.UpdateSiteOperation.persistRp ( Rp  rp, UpdateSiteParams  params  )

inlineprivate

                                                           {

        try {
            updateRegisteredClient(rp, params);
            getRpService().update(rp);

            LOG.info("RP updated: " + rp);
        } catch (IOException e) {
            throw new RuntimeException("Failed to persist RP, params: " + params, e);
        }
    }

updateRegisteredClient()

void org.xdi.oxd.server.op.UpdateSiteOperation.updateRegisteredClient ( Rp  rp, UpdateSiteParams  params  )

inlineprivate

                                                                        {
        if (StringUtils.isBlank(rp.getClientRegistrationClientUri())) {
            LOG.error("Registration client url is blank.");
            throw new ErrorResponseException(ErrorResponseCode.INVALID_REGISTRATION_CLIENT_URL);
        }

        final RegisterClient registerClient = new RegisterClient(rp.getClientRegistrationClientUri());
        registerClient.setRequest(createRegisterClientRequest(rp, params));
        registerClient.setExecutor(getHttpService().getClientExecutor());
        final RegisterResponse response = registerClient.exec();
        if (response != null) {
            if (response.getStatus() == 200) {
                LOG.trace("Client updated successfully. for rp - client_id: " + rp.getClientId());
                return;
            } else {
                LOG.error("Response is not OK (200).");
            }
        } else {
            LOG.error("RegisterClient response is null.");
        }
        if (!Strings.isNullOrEmpty(response.getErrorDescription())) {
            LOG.error(response.getErrorDescription());
        }

        throw new RuntimeException("Failed to update client for rp. Details:" + response.getEntity());
    }

メンバ詳解

LOG

final Logger org.xdi.oxd.server.op.UpdateSiteOperation.LOG = LoggerFactory.getLogger(UpdateSiteOperation.class)

staticprivate

---

このクラス詳解は次のファイルから抽出されました:

• D:/AppData/OpenId/gluu/src/oxd/oxd-server/src/main/java/org/xdi/oxd/server/op/UpdateSiteOperation.java