org.mitre.uma.service.impl.UmaDataServiceExtension_1_3 クラス

org.mitre.uma.service.impl.UmaDataServiceExtension_1_3 の継承関係図

org.mitre.uma.service.impl.UmaDataServiceExtension_1_3 連携図

公開メンバ関数
boolean	supportsVersion (String version)
void	exportExtensionData (JsonWriter writer) throws IOException
boolean	importExtensionData (String name, JsonReader reader) throws IOException
void	fixExtensionObjectReferences (MITREidDataServiceMaps maps)

限定公開メンバ関数
Date	utcToDate (String value)
String	toUTCString (Date value)

非公開メンバ関数
void	writeTokenPermissions (JsonWriter writer) throws IOException
void	writePermissionTickets (JsonWriter writer) throws IOException
void	writeResourceSets (JsonWriter writer) throws IOException
void	writeSavedRegisteredClients (JsonWriter writer) throws IOException
void	readTokenPermissions (JsonReader reader) throws IOException
void	readPermissionTickets (JsonReader reader) throws IOException
void	readResourceSets (JsonReader reader) throws IOException
void	readSavedRegisteredClients (JsonReader reader) throws IOException

非公開変数類
SavedRegisteredClientService	registeredClientService
ResourceSetRepository	resourceSetRepository
PermissionRepository	permissionRepository
OAuth2TokenRepository	tokenRepository
Map< Long, Set< Long > >	tokenToPermissionRefs = new HashMap<>()
Map< Long, Long >	permissionToResourceRefs = new HashMap<>()
Map< Long, Long >	resourceSetOldToNewIdMap = new HashMap<>()

静的非公開変数類
static final String	THIS_VERSION = MITREidDataService.MITREID_CONNECT_1_3
static final String	REGISTERED_CLIENT = "registeredClient"
static final String	URI = "uri"
static final String	NAME = "name"
static final String	TYPE = "type"
static final String	VALUE = "value"
static final String	CLIENT_ID = "clientId"
static final String	EXPIRATION = "expiration"
static final String	ID = "id"
static final String	ICON_URI = "iconUri"
static final String	OWNER = "owner"
static final String	POLICIES = "policies"
static final String	SCOPES = "scopes"
static final String	CLAIMS_REQUIRED = "claimsRequired"
static final String	ISSUER = "issuer"
static final String	CLAIM_TOKEN_FORMAT = "claimTokenFormat"
static final String	CLAIM_TYPE = "claimType"
static final String	FRIENDLY_NAME = "friendlyName"
static final String	PERMISSIONS = "permissions"
static final String	RESOURCE_SET = "resourceSet"
static final String	PERMISSION_TICKETS = "permissionTickets"
static final String	PERMISSION = "permission"
static final String	TICKET = "ticket"
static final String	CLAIMS_SUPPLIED = "claimsSupplied"
static final String	SAVED_REGISTERED_CLIENTS = "savedRegisteredClients"
static final String	RESOURCE_SETS = "resourceSets"
static final String	TOKEN_PERMISSIONS = "tokenPermissions"
static final String	TOKEN_ID = "tokenId"
static final Logger	logger = LoggerFactory.getLogger(UmaDataServiceExtension_1_3.class)

詳解

著者

jricher

関数詳解

exportExtensionData()

void org.mitre.uma.service.impl.UmaDataServiceExtension_1_3.exportExtensionData ( JsonWriter  writer ) throws IOException

inline

org.mitre.openid.connect.service.MITREidDataServiceExtensionを実装しています。

                                                                              {
                writer.name(SAVED_REGISTERED_CLIENTS);
                writer.beginArray();
                writeSavedRegisteredClients(writer);
                writer.endArray();

                writer.name(RESOURCE_SETS);
                writer.beginArray();
                writeResourceSets(writer);
                writer.endArray();

                writer.name(PERMISSION_TICKETS);
                writer.beginArray();
                writePermissionTickets(writer);
                writer.endArray();

                writer.name(TOKEN_PERMISSIONS);
                writer.beginArray();
                writeTokenPermissions(writer);
                writer.endArray();
        }

fixExtensionObjectReferences()

void org.mitre.uma.service.impl.UmaDataServiceExtension_1_3.fixExtensionObjectReferences ( MITREidDataServiceMaps  maps )

inline

org.mitre.openid.connect.service.MITREidDataServiceExtensionを実装しています。

                                                                              {
                for (Long permissionId : permissionToResourceRefs.keySet()) {
                        Long oldResourceId = permissionToResourceRefs.get(permissionId);
                        Long newResourceId = resourceSetOldToNewIdMap.get(oldResourceId);
                        Permission p = permissionRepository.getById(permissionId);
                        ResourceSet rs = resourceSetRepository.getById(newResourceId);
                        p.setResourceSet(rs);
                        permissionRepository.saveRawPermission(p);
                        logger.debug("Mapping rsid " + oldResourceId + " to " + newResourceId + " for permission " + permissionId);
                }
                for (Long tokenId : tokenToPermissionRefs.keySet()) {
                        Long newTokenId = maps.getAccessTokenOldToNewIdMap().get(tokenId);
                        OAuth2AccessTokenEntity token = tokenRepository.getAccessTokenById(newTokenId);

                        Set<Permission> permissions = new HashSet<>();
                        for (Long permissionId : tokenToPermissionRefs.get(tokenId)) {
                                Permission p = permissionRepository.getById(permissionId);
                                permissions.add(p);
                        }

                        token.setPermissions(permissions);
                        tokenRepository.saveAccessToken(token);
                }
                permissionToResourceRefs.clear();
                resourceSetOldToNewIdMap.clear();
                tokenToPermissionRefs.clear();
        }

importExtensionData()

boolean org.mitre.uma.service.impl.UmaDataServiceExtension_1_3.importExtensionData ( String  name, JsonReader  reader  ) throws IOException

inline

org.mitre.openid.connect.service.MITREidDataServiceExtensionを実装しています。

                                                                                              {
                if (name.equals(SAVED_REGISTERED_CLIENTS)) {
                        readSavedRegisteredClients(reader);
                        return true;
                } else if (name.equals(RESOURCE_SETS)) {
                        readResourceSets(reader);
                        return true;
                } else if (name.equals(PERMISSION_TICKETS)) {
                        readPermissionTickets(reader);
                        return true;
                } else if (name.equals(TOKEN_PERMISSIONS)) {
                        readTokenPermissions(reader);
                        return true;
                } else {
                        return false;
                }
        }

readPermissionTickets()

void org.mitre.uma.service.impl.UmaDataServiceExtension_1_3.readPermissionTickets ( JsonReader  reader ) throws IOException

inlineprivate

引数

reader

                                                                                 {
                JsonParser parser = new JsonParser();
                reader.beginArray();
                while (reader.hasNext()) {
                        PermissionTicket ticket = new PermissionTicket();
                        reader.beginObject();
                        while (reader.hasNext()) {
                                switch (reader.peek()) {
                                        case END_OBJECT:
                                                continue;
                                        case NAME:
                                                String name = reader.nextName();
                                                if (reader.peek() == JsonToken.NULL) {
                                                        reader.skipValue();
                                                } else if (name.equals(CLAIMS_SUPPLIED)) {
                                                        Set<Claim> claimsSupplied = new HashSet<>();
                                                        reader.beginArray();
                                                        while (reader.hasNext()) {
                                                                Claim c = new Claim();
                                                                reader.beginObject();
                                                                while (reader.hasNext()) {
                                                                        switch (reader.peek()) {
                                                                                case END_OBJECT:
                                                                                        continue;
                                                                                case NAME:
                                                                                        String cname = reader.nextName();
                                                                                        if (reader.peek() == JsonToken.NULL) {
                                                                                                reader.skipValue();
                                                                                        } else if (cname.equals(ISSUER)) {
                                                                                                c.setIssuer(readSet(reader));
                                                                                        } else if (cname.equals(CLAIM_TOKEN_FORMAT)) {
                                                                                                c.setClaimTokenFormat(readSet(reader));
                                                                                        } else if (cname.equals(CLAIM_TYPE)) {
                                                                                                c.setClaimType(reader.nextString());
                                                                                        } else if (cname.equals(FRIENDLY_NAME)) {
                                                                                                c.setFriendlyName(reader.nextString());
                                                                                        } else if (cname.equals(NAME)) {
                                                                                                c.setName(reader.nextString());
                                                                                        } else if (cname.equals(VALUE)) {
                                                                                                JsonElement e = parser.parse(reader.nextString());
                                                                                                c.setValue(e);
                                                                                        } else {
                                                                                                logger.debug("Found unexpected entry");
                                                                                                reader.skipValue();
                                                                                        }
                                                                                        break;
                                                                                default:
                                                                                        logger.debug("Found unexpected entry");
                                                                                        reader.skipValue();
                                                                                        continue;
                                                                        }
                                                                }
                                                                reader.endObject();
                                                                claimsSupplied.add(c);
                                                        }
                                                        reader.endArray();
                                                        ticket.setClaimsSupplied(claimsSupplied);
                                                } else if (name.equals(EXPIRATION)) {
                                                        ticket.setExpiration(utcToDate(reader.nextString()));
                                                } else if (name.equals(PERMISSION)) {
                                                        Permission p = new Permission();
                                                        Long rsid = null;
                                                        reader.beginObject();
                                                        while (reader.hasNext()) {
                                                                switch (reader.peek()) {
                                                                        case END_OBJECT:
                                                                                continue;
                                                                        case NAME:
                                                                                String pname = reader.nextName();
                                                                                if (reader.peek() == JsonToken.NULL) {
                                                                                        reader.skipValue();
                                                                                } else if (pname.equals(RESOURCE_SET)) {
                                                                                        rsid = reader.nextLong();
                                                                                } else if (pname.equals(SCOPES)) {
                                                                                        p.setScopes(readSet(reader));
                                                                                } else {
                                                                                        logger.debug("Found unexpected entry");
                                                                                        reader.skipValue();
                                                                                }
                                                                                break;
                                                                        default:
                                                                                logger.debug("Found unexpected entry");
                                                                                reader.skipValue();
                                                                                continue;
                                                                }
                                                        }
                                                        reader.endObject();
                                                        Permission saved = permissionRepository.saveRawPermission(p);
                                                        permissionToResourceRefs.put(saved.getId(), rsid);
                                                        ticket.setPermission(saved);
                                                } else if (name.equals(TICKET)) {
                                                        ticket.setTicket(reader.nextString());
                                                } else {
                                                        logger.debug("Found unexpected entry");
                                                        reader.skipValue();
                                                }
                                                break;
                                        default:
                                                logger.debug("Found unexpected entry");
                                                reader.skipValue();
                                                continue;
                                }
                        }
                        reader.endObject();
                        permissionRepository.save(ticket);
                }
                reader.endArray();
        }

readResourceSets()

void org.mitre.uma.service.impl.UmaDataServiceExtension_1_3.readResourceSets ( JsonReader  reader ) throws IOException

inlineprivate

引数

reader

                                                                            {
                JsonParser parser = new JsonParser();
                reader.beginArray();
                while (reader.hasNext()) {
                        Long oldId = null;
                        ResourceSet rs = new ResourceSet();
                        reader.beginObject();
                        while (reader.hasNext()) {
                                switch (reader.peek()) {
                                        case END_OBJECT:
                                                continue;
                                        case NAME:
                                                String name = reader.nextName();
                                                if (reader.peek() == JsonToken.NULL) {
                                                        reader.skipValue();
                                                } else if (name.equals(ID)) {
                                                        oldId = reader.nextLong();
                                                } else if (name.equals(CLIENT_ID)) {
                                                        rs.setClientId(reader.nextString());
                                                } else if (name.equals(ICON_URI)) {
                                                        rs.setIconUri(reader.nextString());
                                                } else if (name.equals(NAME)) {
                                                        rs.setName(reader.nextString());
                                                } else if (name.equals(TYPE)) {
                                                        rs.setType(reader.nextString());
                                                } else if (name.equals(URI)) {
                                                        rs.setUri(reader.nextString());
                                                } else if (name.equals(OWNER)) {
                                                        rs.setOwner(reader.nextString());
                                                } else if (name.equals(POLICIES)) {
                                                        Set<Policy> policies = new HashSet<>();
                                                        reader.beginArray();
                                                        while (reader.hasNext()) {
                                                                Policy p = new Policy();
                                                                reader.beginObject();
                                                                while (reader.hasNext()) {
                                                                        switch (reader.peek()) {
                                                                                case END_OBJECT:
                                                                                        continue;
                                                                                case NAME:
                                                                                        String pname = reader.nextName();
                                                                                        if (reader.peek() == JsonToken.NULL) {
                                                                                                reader.skipValue();
                                                                                        } else if (pname.equals(NAME)) {
                                                                                                p.setName(reader.nextString());
                                                                                        } else if (pname.equals(SCOPES)) {
                                                                                                p.setScopes(readSet(reader));
                                                                                        } else if (pname.equals(CLAIMS_REQUIRED)) {
                                                                                                Set<Claim> claimsRequired = new HashSet<>();
                                                                                                reader.beginArray();
                                                                                                while (reader.hasNext()) {
                                                                                                        Claim c = new Claim();
                                                                                                        reader.beginObject();
                                                                                                        while (reader.hasNext()) {
                                                                                                                switch (reader.peek()) {
                                                                                                                        case END_OBJECT:
                                                                                                                                continue;
                                                                                                                        case NAME:
                                                                                                                                String cname = reader.nextName();
                                                                                                                                if (reader.peek() == JsonToken.NULL) {
                                                                                                                                        reader.skipValue();
                                                                                                                                } else if (cname.equals(ISSUER)) {
                                                                                                                                        c.setIssuer(readSet(reader));
                                                                                                                                } else if (cname.equals(CLAIM_TOKEN_FORMAT)) {
                                                                                                                                        c.setClaimTokenFormat(readSet(reader));
                                                                                                                                } else if (cname.equals(CLAIM_TYPE)) {
                                                                                                                                        c.setClaimType(reader.nextString());
                                                                                                                                } else if (cname.equals(FRIENDLY_NAME)) {
                                                                                                                                        c.setFriendlyName(reader.nextString());
                                                                                                                                } else if (cname.equals(NAME)) {
                                                                                                                                        c.setName(reader.nextString());
                                                                                                                                } else if (cname.equals(VALUE)) {
                                                                                                                                        JsonElement e = parser.parse(reader.nextString());
                                                                                                                                        c.setValue(e);
                                                                                                                                } else {
                                                                                                                                        logger.debug("Found unexpected entry");
                                                                                                                                        reader.skipValue();
                                                                                                                                }
                                                                                                                                break;
                                                                                                                        default:
                                                                                                                                logger.debug("Found unexpected entry");
                                                                                                                                reader.skipValue();
                                                                                                                                continue;
                                                                                                                }
                                                                                                        }
                                                                                                        reader.endObject();
                                                                                                        claimsRequired.add(c);
                                                                                                }
                                                                                                reader.endArray();
                                                                                                p.setClaimsRequired(claimsRequired);
                                                                                        } else {
                                                                                                logger.debug("Found unexpected entry");
                                                                                                reader.skipValue();
                                                                                        }
                                                                                        break;
                                                                                default:
                                                                                        logger.debug("Found unexpected entry");
                                                                                        reader.skipValue();
                                                                                        continue;
                                                                        }
                                                                }
                                                                reader.endObject();
                                                                policies.add(p);
                                                        }
                                                        reader.endArray();
                                                        rs.setPolicies(policies);
                                                } else if (name.equals(SCOPES)) {
                                                        rs.setScopes(readSet(reader));
                                                } else {
                                                        logger.debug("Found unexpected entry");
                                                        reader.skipValue();
                                                }
                                                break;
                                        default:
                                                logger.debug("Found unexpected entry");
                                                reader.skipValue();
                                                continue;
                                }
                        }
                        reader.endObject();
                        Long newId = resourceSetRepository.save(rs).getId();
                        resourceSetOldToNewIdMap.put(oldId, newId);
                }
                reader.endArray();
                logger.info("Done reading resource sets");
        }

readSavedRegisteredClients()

void org.mitre.uma.service.impl.UmaDataServiceExtension_1_3.readSavedRegisteredClients ( JsonReader  reader ) throws IOException

inlineprivate

引数

reader

                                                                                     {
                reader.beginArray();
                while (reader.hasNext()) {
                        String issuer = null;
                        String clientString = null;
                        reader.beginObject();
                        while (reader.hasNext()) {
                                switch (reader.peek()) {
                                        case END_OBJECT:
                                                continue;
                                        case NAME:
                                                String name = reader.nextName();
                                                if (reader.peek() == JsonToken.NULL) {
                                                        reader.skipValue();
                                                } else if (name.equals(ISSUER)) {
                                                        issuer = reader.nextString();
                                                } else if (name.equals(REGISTERED_CLIENT)) {
                                                        clientString = reader.nextString();
                                                } else {
                                                        logger.debug("Found unexpected entry");
                                                        reader.skipValue();
                                                }
                                                break;
                                        default:
                                                logger.debug("Found unexpected entry");
                                                reader.skipValue();
                                                continue;
                                }
                        }
                        reader.endObject();
                        RegisteredClient client = ClientDetailsEntityJsonProcessor.parseRegistered(clientString);
                        registeredClientService.save(issuer, client);
                        logger.debug("Saved registered client");
                }
                reader.endArray();
                logger.info("Done reading saved registered clients");
        }

readTokenPermissions()

void org.mitre.uma.service.impl.UmaDataServiceExtension_1_3.readTokenPermissions ( JsonReader  reader ) throws IOException

inlineprivate

引数

reader

                                                                                {
                reader.beginArray();
                while(reader.hasNext()) {
                        reader.beginObject();
                        Long tokenId = null;
                        Set<Long> permissions = new HashSet<>();
                        while (reader.hasNext()) {
                                switch(reader.peek()) {
                                        case END_OBJECT:
                                                continue;
                                        case NAME:
                                                String name = reader.nextName();
                                                if (name.equals(TOKEN_ID)) {
                                                        tokenId = reader.nextLong();
                                                } else if (name.equals(PERMISSIONS)) {
                                                        reader.beginArray();
                                                        while (reader.hasNext()) {
                                                                Permission p = new Permission();
                                                                Long rsid = null;
                                                                Set<String> scope = new HashSet<>();
                                                                reader.beginObject();
                                                                while (reader.hasNext()) {
                                                                        switch (reader.peek()) {
                                                                                case END_OBJECT:
                                                                                        continue;
                                                                                case NAME:
                                                                                        String pname = reader.nextName();
                                                                                        if (reader.peek() == JsonToken.NULL) {
                                                                                                reader.skipValue();
                                                                                        } else if (pname.equals(RESOURCE_SET)) {
                                                                                                rsid = reader.nextLong();
                                                                                        } else if (pname.equals(SCOPES)) {
                                                                                                scope = readSet(reader);
                                                                                        } else {
                                                                                                logger.debug("Found unexpected entry");
                                                                                                reader.skipValue();
                                                                                        }
                                                                                        break;
                                                                                default:
                                                                                        logger.debug("Found unexpected entry");
                                                                                        reader.skipValue();
                                                                                        continue;
                                                                        }
                                                                }
                                                                reader.endObject();
                                                                p.setScopes(scope);
                                                                Permission saved = permissionRepository.saveRawPermission(p);
                                                                permissionToResourceRefs.put(saved.getId(), rsid);
                                                                permissions.add(saved.getId());
                                                        }
                                                        reader.endArray();
                                                }
                                                break;
                                        default:
                                                logger.debug("Found unexpected entry");
                                                reader.skipValue();
                                                continue;
                                }
                        }
                        reader.endObject();
                        tokenToPermissionRefs.put(tokenId, permissions);
                }
                reader.endArray();

        }

supportsVersion()

boolean org.mitre.uma.service.impl.UmaDataServiceExtension_1_3.supportsVersion ( String  version )

inline

org.mitre.openid.connect.service.MITREidDataServiceExtensionを実装しています。

                                                       {
                return THIS_VERSION.equals(version);

        }

toUTCString()

String org.mitre.openid.connect.service.impl.MITREidDataServiceSupport.toUTCString ( Date  value )

inlineprotectedinherited

                                                 {
                if (value == null) {
                        return null;
                }
                return dateFormatter.print(value, Locale.ENGLISH);
        }

utcToDate()

Date org.mitre.openid.connect.service.impl.MITREidDataServiceSupport.utcToDate ( String  value )

inlineprotectedinherited

                                               {
                if (value == null) {
                        return null;
                }
                try {
                        return dateFormatter.parse(value, Locale.ENGLISH);
                } catch (ParseException ex) {
                        logger.error("Unable to parse datetime {}", value, ex);
                }
                return null;
        }

writePermissionTickets()

void org.mitre.uma.service.impl.UmaDataServiceExtension_1_3.writePermissionTickets ( JsonWriter  writer ) throws IOException

inlineprivate

引数

writer

例外

IOException

                                                                                  {
                for (PermissionTicket ticket : permissionRepository.getAll()) {
                        writer.beginObject();

                        writer.name(CLAIMS_SUPPLIED);
                        writer.beginArray();
                        for (Claim claim : ticket.getClaimsSupplied()) {
                                writer.beginObject();

                                writer.name(ISSUER);
                                writer.beginArray();
                                for (String issuer : claim.getIssuer()) {
                                        writer.value(issuer);
                                }
                                writer.endArray();
                                writer.name(CLAIM_TOKEN_FORMAT);
                                writer.beginArray();
                                for (String format : claim.getClaimTokenFormat()) {
                                        writer.value(format);
                                }
                                writer.endArray();
                                writer.name(CLAIM_TYPE).value(claim.getClaimType());
                                writer.name(FRIENDLY_NAME).value(claim.getFriendlyName());
                                writer.name(NAME).value(claim.getName());
                                writer.name(VALUE).value(claim.getValue().toString());
                                writer.endObject();
                        }
                        writer.endArray();

                        writer.name(EXPIRATION).value(toUTCString(ticket.getExpiration()));

                        writer.name(PERMISSION);
                        writer.beginObject();
                        Permission p = ticket.getPermission();
                        writer.name(RESOURCE_SET).value(p.getResourceSet().getId());
                        writer.name(SCOPES);
                        writer.beginArray();
                        for (String s : p.getScopes()) {
                                writer.value(s);
                        }
                        writer.endArray();
                        writer.endObject();

                        writer.name(TICKET).value(ticket.getTicket());

                        writer.endObject();
                }


        }

writeResourceSets()

void org.mitre.uma.service.impl.UmaDataServiceExtension_1_3.writeResourceSets ( JsonWriter  writer ) throws IOException

inlineprivate

引数

writer

例外

IOException

                                                                             {
                for (ResourceSet rs : resourceSetRepository.getAll()) {
                        writer.beginObject();
                        writer.name(ID).value(rs.getId());
                        writer.name(CLIENT_ID).value(rs.getClientId());
                        writer.name(ICON_URI).value(rs.getIconUri());
                        writer.name(NAME).value(rs.getName());
                        writer.name(TYPE).value(rs.getType());
                        writer.name(URI).value(rs.getUri());
                        writer.name(OWNER).value(rs.getOwner());
                        writer.name(POLICIES);
                        writer.beginArray();
                        for (Policy policy : rs.getPolicies()) {
                                writer.beginObject();
                                writer.name(NAME).value(policy.getName());
                                writer.name(SCOPES);
                                writer.beginArray();
                                for (String scope : policy.getScopes()) {
                                        writer.value(scope);
                                }
                                writer.endArray();
                                writer.name(CLAIMS_REQUIRED);
                                writer.beginArray();
                                for (Claim claim : policy.getClaimsRequired()) {
                                        writer.beginObject();

                                        writer.name(ISSUER);
                                        writer.beginArray();
                                        for (String issuer : claim.getIssuer()) {
                                                writer.value(issuer);
                                        }
                                        writer.endArray();
                                        writer.name(CLAIM_TOKEN_FORMAT);
                                        writer.beginArray();
                                        for (String format : claim.getClaimTokenFormat()) {
                                                writer.value(format);
                                        }
                                        writer.endArray();
                                        writer.name(CLAIM_TYPE).value(claim.getClaimType());
                                        writer.name(FRIENDLY_NAME).value(claim.getFriendlyName());
                                        writer.name(NAME).value(claim.getName());
                                        writer.name(VALUE).value(claim.getValue().toString());
                                        writer.endObject();
                                }
                                writer.endArray();
                                writer.endObject();
                        }
                        writer.endArray();
                        writer.name(SCOPES);
                        writer.beginArray();
                        for (String scope : rs.getScopes()) {
                                writer.value(scope);
                        }
                        writer.endArray();
                        writer.endObject();
                        logger.debug("Finished writing resource set {}", rs.getId());
                }

        }

writeSavedRegisteredClients()

void org.mitre.uma.service.impl.UmaDataServiceExtension_1_3.writeSavedRegisteredClients ( JsonWriter  writer ) throws IOException

inlineprivate

引数

writer

                                                                                       {
                for (SavedRegisteredClient src : registeredClientService.getAll()) {
                        writer.beginObject();
                        writer.name(ISSUER).value(src.getIssuer());
                        writer.name(REGISTERED_CLIENT).value(src.getRegisteredClient().getSource().toString());
                        writer.endObject();
                        logger.debug("Wrote saved registered client {}", src.getId());
                }
                logger.info("Done writing saved registered clients");
        }

writeTokenPermissions()

void org.mitre.uma.service.impl.UmaDataServiceExtension_1_3.writeTokenPermissions ( JsonWriter  writer ) throws IOException

inlineprivate

引数

writer

例外

IOException

                                                                                 {
                for (OAuth2AccessTokenEntity token : tokenRepository.getAllAccessTokens()) {
                        if (!token.getPermissions().isEmpty()) { // skip tokens that don't have the permissions structure attached
                                writer.beginObject();
                                writer.name(TOKEN_ID).value(token.getId());
                                writer.name(PERMISSIONS);
                                writer.beginArray();
                                for (Permission p : token.getPermissions()) {
                                        writer.beginObject();
                                        writer.name(RESOURCE_SET).value(p.getResourceSet().getId());
                                        writer.name(SCOPES);
                                        writer.beginArray();
                                        for (String s : p.getScopes()) {
                                                writer.value(s);
                                        }
                                        writer.endArray();
                                        writer.endObject();
                                }
                                writer.endArray();

                                writer.endObject();
                        }
                }
        }

メンバ詳解

CLAIM_TOKEN_FORMAT

final String org.mitre.uma.service.impl.UmaDataServiceExtension_1_3.CLAIM_TOKEN_FORMAT = "claimTokenFormat"

staticprivate

CLAIM_TYPE

final String org.mitre.uma.service.impl.UmaDataServiceExtension_1_3.CLAIM_TYPE = "claimType"

staticprivate

CLAIMS_REQUIRED

final String org.mitre.uma.service.impl.UmaDataServiceExtension_1_3.CLAIMS_REQUIRED = "claimsRequired"

staticprivate

CLAIMS_SUPPLIED

final String org.mitre.uma.service.impl.UmaDataServiceExtension_1_3.CLAIMS_SUPPLIED = "claimsSupplied"

staticprivate

CLIENT_ID

final String org.mitre.uma.service.impl.UmaDataServiceExtension_1_3.CLIENT_ID = "clientId"

staticprivate

EXPIRATION

final String org.mitre.uma.service.impl.UmaDataServiceExtension_1_3.EXPIRATION = "expiration"

staticprivate

FRIENDLY_NAME

final String org.mitre.uma.service.impl.UmaDataServiceExtension_1_3.FRIENDLY_NAME = "friendlyName"

staticprivate

ICON_URI

final String org.mitre.uma.service.impl.UmaDataServiceExtension_1_3.ICON_URI = "iconUri"

staticprivate

ID

final String org.mitre.uma.service.impl.UmaDataServiceExtension_1_3.ID = "id"

staticprivate

ISSUER

final String org.mitre.uma.service.impl.UmaDataServiceExtension_1_3.ISSUER = "issuer"

staticprivate

logger

final Logger org.mitre.uma.service.impl.UmaDataServiceExtension_1_3.logger = LoggerFactory.getLogger(UmaDataServiceExtension_1_3.class)

staticprivate

NAME

final String org.mitre.uma.service.impl.UmaDataServiceExtension_1_3.NAME = "name"

staticprivate

OWNER

final String org.mitre.uma.service.impl.UmaDataServiceExtension_1_3.OWNER = "owner"

staticprivate

PERMISSION

final String org.mitre.uma.service.impl.UmaDataServiceExtension_1_3.PERMISSION = "permission"

staticprivate

PERMISSION_TICKETS

final String org.mitre.uma.service.impl.UmaDataServiceExtension_1_3.PERMISSION_TICKETS = "permissionTickets"

staticprivate

permissionRepository

PermissionRepository org.mitre.uma.service.impl.UmaDataServiceExtension_1_3.permissionRepository

private

PERMISSIONS

final String org.mitre.uma.service.impl.UmaDataServiceExtension_1_3.PERMISSIONS = "permissions"

staticprivate

permissionToResourceRefs

Map<Long, Long> org.mitre.uma.service.impl.UmaDataServiceExtension_1_3.permissionToResourceRefs = new HashMap<>()

private

POLICIES

final String org.mitre.uma.service.impl.UmaDataServiceExtension_1_3.POLICIES = "policies"

staticprivate

REGISTERED_CLIENT

final String org.mitre.uma.service.impl.UmaDataServiceExtension_1_3.REGISTERED_CLIENT = "registeredClient"

staticprivate

registeredClientService

SavedRegisteredClientService org.mitre.uma.service.impl.UmaDataServiceExtension_1_3.registeredClientService

private

RESOURCE_SET

final String org.mitre.uma.service.impl.UmaDataServiceExtension_1_3.RESOURCE_SET = "resourceSet"

staticprivate

RESOURCE_SETS

final String org.mitre.uma.service.impl.UmaDataServiceExtension_1_3.RESOURCE_SETS = "resourceSets"

staticprivate

resourceSetOldToNewIdMap

Map<Long, Long> org.mitre.uma.service.impl.UmaDataServiceExtension_1_3.resourceSetOldToNewIdMap = new HashMap<>()

private

resourceSetRepository

ResourceSetRepository org.mitre.uma.service.impl.UmaDataServiceExtension_1_3.resourceSetRepository

private

SAVED_REGISTERED_CLIENTS

final String org.mitre.uma.service.impl.UmaDataServiceExtension_1_3.SAVED_REGISTERED_CLIENTS = "savedRegisteredClients"

staticprivate

SCOPES

final String org.mitre.uma.service.impl.UmaDataServiceExtension_1_3.SCOPES = "scopes"

staticprivate

THIS_VERSION

final String org.mitre.uma.service.impl.UmaDataServiceExtension_1_3.THIS_VERSION = MITREidDataService.MITREID_CONNECT_1_3

staticprivate

TICKET

final String org.mitre.uma.service.impl.UmaDataServiceExtension_1_3.TICKET = "ticket"

staticprivate

TOKEN_ID

final String org.mitre.uma.service.impl.UmaDataServiceExtension_1_3.TOKEN_ID = "tokenId"

staticprivate

TOKEN_PERMISSIONS

final String org.mitre.uma.service.impl.UmaDataServiceExtension_1_3.TOKEN_PERMISSIONS = "tokenPermissions"

staticprivate

tokenRepository

OAuth2TokenRepository org.mitre.uma.service.impl.UmaDataServiceExtension_1_3.tokenRepository

private

tokenToPermissionRefs

Map<Long, Set<Long> > org.mitre.uma.service.impl.UmaDataServiceExtension_1_3.tokenToPermissionRefs = new HashMap<>()

private

TYPE

final String org.mitre.uma.service.impl.UmaDataServiceExtension_1_3.TYPE = "type"

staticprivate

URI

final String org.mitre.uma.service.impl.UmaDataServiceExtension_1_3.URI = "uri"

staticprivate

VALUE

final String org.mitre.uma.service.impl.UmaDataServiceExtension_1_3.VALUE = "value"

staticprivate

---

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

• D:/AppData/OpenId/mitreid-connect/src/uma-server/src/main/java/org/mitre/uma/service/impl/UmaDataServiceExtension_1_3.java