org.gluu.oxtrust.util.ServiceUtil クラス

org.gluu.oxtrust.util.ServiceUtil の継承関係図

org.gluu.oxtrust.util.ServiceUtil 連携図

公開メンバ関数
void	deleteGroupFromPerson (GluuGroup group, String dn) throws Exception
String	iterableToString (Iterable<?> list)
void	deleteUserFromGroup (GluuCustomPerson person, String dn) throws Exception
void	personMembersAdder (GluuGroup gluuGroup, String dn) throws Exception
void	groupMembersAdder (GluuCustomPerson gluuPerson, String dn) throws Exception
String	getPersonParentInum ()
String	getPersonParentIname ()
byte []	copyUploadedFile (UploadedFile uploadedFile) throws IOException
String	saveUploadedFile (UploadedFile uploadedFile, String baseDir, String extension) throws IOException

静的公開メンバ関数
static String	saveRandomFile (byte[] array, String baseDir, String extension) throws IOException
static GluuCustomPerson	syncEmailForward (GluuCustomPerson gluuCustomPerson, boolean isScim2) throws Exception
static GluuCustomPerson	syncEmailReverse (GluuCustomPerson gluuCustomPerson, boolean isScim2) throws Exception
static ObjectMapper	getObjectMapper ()
static byte []	readFully (InputStream is) throws IOException

静的関数
	[static initializer]

非公開メンバ関数
boolean	isMemberOfExist (List< String > groups, String dn)
boolean	isMemberExist (List< String > groupMembers, String dn)

非公開変数類
IPersonService	personService
IGroupService	groupService
AppConfiguration	appConfiguration

静的非公開変数類
static Logger	logger = LoggerFactory.getLogger(ServiceUtil.class)
static final long	serialVersionUID = -2842459224631032594L
static final SecureRandom	random = new SecureRandom()
static final ObjectMapper	mapper = new ObjectMapper()

詳解

User: Dejan Maric

関数詳解

[static initializer]()

org.gluu.oxtrust.util.ServiceUtil.[static initializer] ( )

inlinestaticpackage

copyUploadedFile()

byte [] org.gluu.oxtrust.util.ServiceUtil.copyUploadedFile ( UploadedFile  uploadedFile ) throws IOException

inline

Copy uploaded file to byte array.

引数

uploadedFile

戻り値

byte array

例外

IOException

                                                                                 {

        InputStream in = uploadedFile.getInputStream();
        ByteArrayOutputStream out = new ByteArrayOutputStream();
        try {
            int b;
            while ((b = in.read()) != -1) {
                out.write(b);
            }
        } finally {
            out.close();
            in.close();
        }
        return out.toByteArray();
    }

deleteGroupFromPerson()

void org.gluu.oxtrust.util.ServiceUtil.deleteGroupFromPerson ( GluuGroup  group, String  dn  ) throws Exception

inline

Delete a Group from a Person

戻り値

void

例外

Exception

                                                                                   {
        List<String> persons = group.getMembers();
        for (String onePerson : persons) {

            GluuCustomPerson gluuPerson = personService.getPersonByDn(onePerson);
            List<String> memberOflist = gluuPerson.getMemberOf();

            List<String> tempMemberOf = new ArrayList<String>();
            for (String aMemberOf : memberOflist) {
                tempMemberOf.add(aMemberOf);
            }

            for (String oneMemberOf : tempMemberOf) {
                if (oneMemberOf.equalsIgnoreCase(dn)) {
                    tempMemberOf.remove(oneMemberOf);
                    break;
                }
            }

            List<String> cleanMemberOf = new ArrayList<String>();

            for (String aMemberOf : tempMemberOf) {
                cleanMemberOf.add(aMemberOf);
            }

            gluuPerson.setMemberOf(cleanMemberOf);
            personService.updatePerson(gluuPerson);

        }

    }

deleteUserFromGroup()

void org.gluu.oxtrust.util.ServiceUtil.deleteUserFromGroup ( GluuCustomPerson  person, String  dn  ) throws Exception

inline

Delete a person from a group

戻り値

void

例外

Exception

                                                                                         {
        List<String> groups = person.getMemberOf();
        for (String oneGroup : groups) {

            GluuGroup aGroup = groupService.getGroupByDn(oneGroup);
            List<String> groupMembers = aGroup.getMembers();

            List<String> tempGroupMembers = new ArrayList<String>();
            if (groupMembers != null && !groupMembers.isEmpty()) {
                for (String aMember : groupMembers) {
                    tempGroupMembers.add(aMember);
                }
            }

            for (String oneMember : tempGroupMembers) {

                if (oneMember.equalsIgnoreCase(dn)) {

                    tempGroupMembers.remove(oneMember);

                    break;
                }
            }

            List<String> cleanGroupMembers = new ArrayList<String>();
            for (String aMember : tempGroupMembers) {
                cleanGroupMembers.add(aMember);
            }

            aGroup.setMembers(cleanGroupMembers);

            if (aGroup.getMembers() != null && aGroup.getMembers().isEmpty()) {
                aGroup.setMembers(null);  // Reset to no members
            }

            groupService.updateGroup(aGroup);
        }
    }

getObjectMapper()

static ObjectMapper org.gluu.oxtrust.util.ServiceUtil.getObjectMapper ( )

inlinestatic

                                                 {
        return mapper;
    }

getPersonParentIname()

String org.gluu.oxtrust.util.ServiceUtil.getPersonParentIname ( )

inline

                                         {
        return appConfiguration.getOrgIname() + OxTrustConstants.inameDelimiter
                + OxTrustConstants.INAME_PERSON_OBJECTTYPE;
    }

getPersonParentInum()

String org.gluu.oxtrust.util.ServiceUtil.getPersonParentInum ( )

inline

                                        {
        return appConfiguration.getOrgInum() + OxTrustConstants.inumDelimiter
                + OxTrustConstants.INUM_PERSON_OBJECTTYPE;
    }

groupMembersAdder()

void org.gluu.oxtrust.util.ServiceUtil.groupMembersAdder ( GluuCustomPerson  gluuPerson, String  dn  ) throws Exception

inline

Adds a person to a group

戻り値

void

例外

Exception

                                                                                           {
        List<String> groups = gluuPerson.getMemberOf();

        for (String group : groups) {

            GluuGroup oneGroup = groupService.getGroupByDn(group);

            List<String> groupMembers = oneGroup.getMembers();

            if ((groupMembers != null && !groupMembers.isEmpty()) && !isMemberExist(groupMembers, dn)) {

                List<String> cleanGroupMembers = new ArrayList<String>();
                cleanGroupMembers.add(dn);

                for (String personDN : groupMembers) {
                    cleanGroupMembers.add(personDN);
                }

                oneGroup.setMembers(cleanGroupMembers);
                groupService.updateGroup(oneGroup);
            }
        }
    }

isMemberExist()

boolean org.gluu.oxtrust.util.ServiceUtil.isMemberExist ( List< String >  groupMembers, String  dn  )

inlineprivate

checks if the member already exist in a group

戻り値

boolean

                                                                        {

        for (String member : groupMembers) {
            if (member.equalsIgnoreCase(dn)) {
                return true;
            }
        }
        return false;
    }

isMemberOfExist()

boolean org.gluu.oxtrust.util.ServiceUtil.isMemberOfExist ( List< String >  groups, String  dn  )

inlineprivate

checks if the memeberOf attribute already contains a given group

戻り値

boolean

                                                                    {
        for (String group : groups) {
            if (group.equalsIgnoreCase(dn)) {
                return true;
            }

        }
        return false;
    }

iterableToString()

String org.gluu.oxtrust.util.ServiceUtil.iterableToString ( Iterable<?>  list )

inline

                                                     {
        if (list == null) {
            return "";
        }

        StringBuilder sb = new StringBuilder();
        for (Object item : list) {
            sb.append(item);
            sb.append(",");
        }
        if (sb.length() > 0) {
            sb.deleteCharAt(sb.length() - 1);
        }
        return sb.toString();
    }

personMembersAdder()

void org.gluu.oxtrust.util.ServiceUtil.personMembersAdder ( GluuGroup  gluuGroup, String  dn  ) throws Exception

inline

Adds a group to a person's memberOf

戻り値

void

例外

Exception

                                                                                    {
        List<String> members = gluuGroup.getMembers();

        for (String member : members) {
            GluuCustomPerson gluuPerson = personService.getPersonByDn(member);

            List<String> groups = gluuPerson.getMemberOf();
            if (!isMemberOfExist(groups, dn)) {

                List<String> cleanGroups = new ArrayList<String>();
                cleanGroups.add(dn);
                for (String aGroup : groups) {
                    cleanGroups.add(aGroup);
                }

                gluuPerson.setMemberOf(cleanGroups);
                personService.updatePerson(gluuPerson);
            }

        }

    }

readFully()

static byte [] org.gluu.oxtrust.util.ServiceUtil.readFully ( InputStream  is ) throws IOException

inlinestatic

Read all bytes from the supplied input stream. Closes the input stream.

引数

is	Input stream

戻り値

All bytes

例外

IOException

If an I/O problem occurs

                                                                      {
        ByteArrayOutputStream baos = null;

        try {
            baos = new ByteArrayOutputStream();

            byte[] buffer = new byte[2048];
            int read = 0;

            while ((read = is.read(buffer)) != -1) {
                baos.write(buffer, 0, read);
            }

            return baos.toByteArray();
        } finally {
            IOUtils.closeQuietly(baos);
            IOUtils.closeQuietly(is);
        }
    }

saveRandomFile()

static String org.gluu.oxtrust.util.ServiceUtil.saveRandomFile ( byte []  array, String  baseDir, String  extension  ) throws IOException

inlinestatic

Save file with random name with provided base directory and extension.

引数

array	binary content of file.
baseDir	Write to directory.
extension	Filename extension.

戻り値

Return full path

例外

IOException

                                                                                                           {
        final String filepath = baseDir + File.separator + Math.abs(random.nextLong()) + "." + extension;

        final File dir = new File(baseDir);
        if (!dir.exists())
            dir.mkdirs();
        else if (!dir.isDirectory())
            throw new IllegalArgumentException("parameter baseDir should be directory. The value: " + baseDir);

        InputStream in = new ByteArrayInputStream(array);
        FileOutputStream out = new FileOutputStream(filepath);
        try {
            int b;
            while ((b = in.read()) != -1) {
                out.write(b);
            }
        } finally {
            in.close();
            out.close();
        }
        return filepath;
    }

saveUploadedFile()

String org.gluu.oxtrust.util.ServiceUtil.saveUploadedFile ( UploadedFile  uploadedFile, String  baseDir, String  extension  ) throws IOException

inline

Save uploaded file with random name.

引数

uploadedFile
baseDir	Write to directory.
extension	Filename extension.

戻り値

Return full path

例外

IOException

                                                                                                                   {
        byte[] fileContent = copyUploadedFile(uploadedFile);

        return saveRandomFile(fileContent, baseDir, extension);
    }

syncEmailForward()

static GluuCustomPerson org.gluu.oxtrust.util.ServiceUtil.syncEmailForward ( GluuCustomPerson  gluuCustomPerson, boolean  isScim2  ) throws Exception

inlinestatic

One-way sync from "oxTrustEmail" to "mail". Ultimately this is persisted so "mail" will be updated by values from "oxTrustEmail".

引数

gluuCustomPerson

戻り値

例外

Exception

                                                                                                                         {

        logger.info(" IN Utils.syncEmailForward()...");

        GluuCustomAttribute oxTrustEmail = gluuCustomPerson.getGluuCustomAttribute("oxTrustEmail");

        if (oxTrustEmail != null && oxTrustEmail.getValues()!=null && oxTrustEmail.getValues().length > 0) {

            String[] oxTrustEmails = oxTrustEmail.getValues();  // JSON array in element 0
            String[] newMails = new String[oxTrustEmails.length];

            ObjectMapper mapper = getObjectMapper();

            if (isScim2) {

                for (int i = 0; i < oxTrustEmails.length; i++) {
                    newMails[i] = mapper.readValue(oxTrustEmails[i], Email.class).getValue();
                }

            }
            gluuCustomPerson.setAttribute("mail", newMails);
        }

        logger.info(" LEAVING Utils.syncEmailForward()...");

        return gluuCustomPerson;
    }

syncEmailReverse()

static GluuCustomPerson org.gluu.oxtrust.util.ServiceUtil.syncEmailReverse ( GluuCustomPerson  gluuCustomPerson, boolean  isScim2  ) throws Exception

inlinestatic

One-way sync from "mail" to "oxTrustEmail". This method takes current values of "oxTrustEmail" attribute, deletes those that do not match any of those in "mail", and adds new ones that are missing.

引数

gluuCustomPerson
isScim2

戻り値

例外

Exception

                                                                                                                         {

        /*
        Implementation of this method could not be simplified to creating a new empty list for oxTrustEmail and then do
        the respective additions based on current mail values since information such as display, primary, etc. would be lost.
        Instead, it uses set operations to know which existing entries must be removed or retained, and then apply additions
        of new data.
         */
        logger.info(" IN Utils.syncEmailReverse()...");

        GluuCustomAttribute mail = gluuCustomPerson.getGluuCustomAttribute("mail");
        GluuCustomAttribute oxTrustEmail = gluuCustomPerson.getGluuCustomAttribute("oxTrustEmail");

        if (mail == null) {
            gluuCustomPerson.setAttribute("oxTrustEmail", new String[0]);
        }
        else{
            ObjectMapper mapper = getObjectMapper();

            Set<String> mailSet=new HashSet<String>();
            if (mail.getValues()!=null)
                mailSet.addAll(Arrays.asList(mail.getValues()));

            Set<String> mailSetCopy=new HashSet<String>(mailSet);
            Set<String> oxTrustEmailSet =new HashSet<String>();
            List<Email> oxTrustEmails=new ArrayList<Email>();

            if (oxTrustEmail!=null && oxTrustEmail.getValues()!=null){
                for (String oxTrustEmailJson : oxTrustEmail.getValues())
                    oxTrustEmails.add(mapper.readValue(oxTrustEmailJson, Email.class));

                for (Email email : oxTrustEmails)
                    oxTrustEmailSet.add(email.getValue());
            }
            mailSetCopy.removeAll(oxTrustEmailSet); //Keep those in "mail" and not in oxTrustEmail
            oxTrustEmailSet.removeAll(mailSet);     //Keep those in oxTrustEmail and not in "mail"

            List<Integer> delIndexes=new ArrayList<Integer>();
            //Build a list of indexes that should be removed in oxTrustEmails
            for (int i=0;i<oxTrustEmails.size();i++) {
                if (oxTrustEmailSet.contains(oxTrustEmails.get(i).getValue()))
                    delIndexes.add(0, i);
            }
            //Delete unmatched oxTrustEmail entries from highest index to lowest
            for (Integer idx : delIndexes)
                oxTrustEmails.remove(idx.intValue());   //must not pass an Integer directly

            List<String> newValues=new ArrayList<String>();
            for (Email email : oxTrustEmails)
                newValues.add(mapper.writeValueAsString(email));

            for (String mailStr : mailSetCopy){
                Email email = new Email();
                email.setValue(mailStr);
                email.setPrimary(false);
                newValues.add(mapper.writeValueAsString(email));
            }

            gluuCustomPerson.setAttribute("oxTrustEmail", newValues.toArray(new String[0]));

        }

        logger.info(" LEAVING Utils.syncEmailReverse()...");

        return gluuCustomPerson;

    }

メンバ詳解

appConfiguration

AppConfiguration org.gluu.oxtrust.util.ServiceUtil.appConfiguration

private

groupService

IGroupService org.gluu.oxtrust.util.ServiceUtil.groupService

private

logger

Logger org.gluu.oxtrust.util.ServiceUtil.logger = LoggerFactory.getLogger(ServiceUtil.class)

staticprivate

mapper

final ObjectMapper org.gluu.oxtrust.util.ServiceUtil.mapper = new ObjectMapper()

staticprivate

personService

IPersonService org.gluu.oxtrust.util.ServiceUtil.personService

private

random

final SecureRandom org.gluu.oxtrust.util.ServiceUtil.random = new SecureRandom()

staticprivate

serialVersionUID

final long org.gluu.oxtrust.util.ServiceUtil.serialVersionUID = -2842459224631032594L

staticprivate

---

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

• D:/AppData/OpenId/gluu/src/oxTrust/server/src/main/java/org/gluu/oxtrust/util/ServiceUtil.java